-
Notifications
You must be signed in to change notification settings - Fork 51
/
resync.go
39 lines (31 loc) · 866 Bytes
/
resync.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
package podmonitor
import (
"context"
"errors"
"fmt"
corev1 "k8s.io/api/core/v1"
"sigs.k8s.io/controller-runtime/pkg/client"
"sigs.k8s.io/controller-runtime/pkg/event"
)
// ResyncWithAllPods is called from the implemented resync, it will list all pods
// and fire them down the event source (the generic event channel)
func ResyncWithAllPods(ctx context.Context, c client.Client, evCh chan<- event.GenericEvent) error {
if c == nil {
return errors.New("pod: no client available")
}
if evCh == nil {
return errors.New("pod: no event source available")
}
list := &corev1.PodList{}
if err := c.List(ctx, &client.ListOptions{}, list); err != nil {
return fmt.Errorf("pod: %s", err.Error())
}
for _, pod := range list.Items {
p := pod.DeepCopy()
evCh <- event.GenericEvent{
Meta: p.GetObjectMeta(),
Object: p,
}
}
return nil
}