pod

Documentation

Index

• type PodFilter
• type PodWatcher
  • func New(nodename string) *PodWatcher
  • func (p *PodWatcher) PodNotifierFunc(f PodFilter, listeners ...podListener) reconcile.Func
  • func (p *PodWatcher) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (p *PodWatcher) SetupWithManager(mgr ctrl.Manager) error

Types

type PodFilter

type PodFilter func([]v1.Pod) []v1.Pod

var PodNetworkFilter PodFilter = func(pods []v1.Pod) []v1.Pod {
	var filtered []v1.Pod
	for _, pod := range pods {
		if !pod.Spec.HostNetwork {
			filtered = append(filtered, pod)
		}
	}
	return filtered
}

type PodWatcher

type PodWatcher struct {
	ReconcileFuncs []reconcile.Func
	// contains filtered or unexported fields
}

func New

func New(nodename string) *PodWatcher

func (*PodWatcher) PodNotifierFunc

func (p *PodWatcher) PodNotifierFunc(f PodFilter, listeners ...podListener) reconcile.Func

func (*PodWatcher) Reconcile

func (p *PodWatcher) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*PodWatcher) SetupWithManager

func (p *PodWatcher) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager Sets up the reconciler with a new manager, filtering using NodeNetworkConfigFilter on nodeName.