Documentation
¶
Index ¶
- type ContainerRestartDetector
- type Dispatcher
- type Reconciler
- func (w *Reconciler) ExtraSelectors(key types.NamespacedName) []labels.Selector
- func (w *Reconciler) HasNamespaceWatch(key types.NamespacedName, ns k8s.Namespace) bool
- func (w *Reconciler) HasUIDWatch(key types.NamespacedName, uid types.UID) bool
- func (w *Reconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
- func (w *Reconciler) SetClient(client ctrlclient.Client)
- func (w *Reconciler) SetupWithManager(mgr ctrl.Manager) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ContainerRestartDetector ¶
type ContainerRestartDetector struct{}
func NewContainerRestartDetector ¶
func NewContainerRestartDetector() *ContainerRestartDetector
func (*ContainerRestartDetector) Detect ¶
func (c *ContainerRestartDetector) Detect(dispatcher Dispatcher, prevStatus v1alpha1.KubernetesDiscoveryStatus, current v1alpha1.KubernetesDiscovery)
type Dispatcher ¶
type Reconciler ¶
type Reconciler struct {
// contains filtered or unexported fields
}
func NewReconciler ¶
func NewReconciler(kCli k8s.Client, ownerFetcher k8s.OwnerFetcher, restartDetector *ContainerRestartDetector, st store.RStore) *Reconciler
func (*Reconciler) ExtraSelectors ¶
func (w *Reconciler) ExtraSelectors(key types.NamespacedName) []labels.Selector
ExtraSelectors returns the extra selectors for a given KubernetesDiscovery object.
This is intended for use in tests.
func (*Reconciler) HasNamespaceWatch ¶
func (w *Reconciler) HasNamespaceWatch(key types.NamespacedName, ns k8s.Namespace) bool
HasNamespaceWatch returns true if the key is a watcher for the given namespace.
This is intended for use in tests.
func (*Reconciler) HasUIDWatch ¶
func (w *Reconciler) HasUIDWatch(key types.NamespacedName, uid types.UID) bool
HasUIDWatch returns true if the key is a watcher for the given K8s UID.
This is intended for use in tests.
func (*Reconciler) Reconcile ¶
func (w *Reconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
Reconcile manages namespace watches for the modified KubernetesDiscovery object.
func (*Reconciler) SetClient ¶
func (w *Reconciler) SetClient(client ctrlclient.Client)
func (*Reconciler) SetupWithManager ¶
func (w *Reconciler) SetupWithManager(mgr ctrl.Manager) error
Click to show internal directories.
Click to hide internal directories.