mirror of
https://github.com/kubeshark/kubeshark.git
synced 2025-06-29 09:39:54 +00:00
Update watch.go
This commit is contained in:
parent
99bf92a699
commit
129e7c9488
@ -9,9 +9,6 @@ import (
|
|||||||
"k8s.io/apimachinery/pkg/watch"
|
"k8s.io/apimachinery/pkg/watch"
|
||||||
)
|
)
|
||||||
|
|
||||||
// FilteredWatch starts listening to Kubernetes events and emits modified
|
|
||||||
// containers/pods. The first result is targets added, the second is targets
|
|
||||||
// removed
|
|
||||||
func FilteredWatch(ctx context.Context, watcher watch.Interface, podFilter *regexp.Regexp) (chan *corev1.Pod, chan *corev1.Pod, chan *corev1.Pod, chan error) {
|
func FilteredWatch(ctx context.Context, watcher watch.Interface, podFilter *regexp.Regexp) (chan *corev1.Pod, chan *corev1.Pod, chan *corev1.Pod, chan error) {
|
||||||
addedChan := make(chan *corev1.Pod)
|
addedChan := make(chan *corev1.Pod)
|
||||||
modifiedChan := make(chan *corev1.Pod)
|
modifiedChan := make(chan *corev1.Pod)
|
||||||
|
Loading…
Reference in New Issue
Block a user