watchset

Documentation

Index

• func SleepWithContext(ctx context.Context, d time.Duration)
• type ControllerInterestSet
  • func (s *ControllerInterestSet) Close()
  • func (s *ControllerInterestSet) ReconcileFailed()
  • func (s *ControllerInterestSet) ReconcileSuccess()
• type ControllerManager
  • func (m *ControllerManager) ReconcileStart(ctx context.Context, id types.NamespacedName) *ControllerInterestSet
  • func (m *ControllerManager) Stop()
• type DependencySet
  • func (x *DependencySet) String() string
  • func (d *DependencySet) TrackingDynamicClient(inner dynamic.Interface) dynamic.Interface
  • func (x *DependencySet) WatchList(gvr schema.GroupVersionResource, ns string, opts metav1.ListOptions)
  • func (x *DependencySet) WatchObject(gvr schema.GroupVersionResource, nn types.NamespacedName, rv string)
• type GRNN
• type InterestSet
  • func (s *InterestSet) AddDependencies(dependencies *DependencySet)
  • func (s *InterestSet) Close()
  • func (s *InterestSet) ReplaceAllDependencies(dependencies *DependencySet)
• type Manager
  • func NewManager(mgr manager.Manager) (*Manager, error)
  • func (w *Manager) NewControllerManager(controller controller.Controller) (*ControllerManager, error)

Functions

func SleepWithContext

func SleepWithContext(ctx context.Context, d time.Duration)

SleepWithContext is like time.Sleep but returns early if the context is Done.

Types

type ControllerInterestSet

type ControllerInterestSet struct {
	*DependencySet
	// contains filtered or unexported fields
}

func (*ControllerInterestSet) Close

func (s *ControllerInterestSet) Close()

func (*ControllerInterestSet) ReconcileFailed

func (s *ControllerInterestSet) ReconcileFailed()

func (*ControllerInterestSet) ReconcileSuccess

func (s *ControllerInterestSet) ReconcileSuccess()

type ControllerManager

type ControllerManager struct {
	// contains filtered or unexported fields
}

func (*ControllerManager) ReconcileStart

func (m *ControllerManager) ReconcileStart(ctx context.Context, id types.NamespacedName) *ControllerInterestSet

func (*ControllerManager) Stop

func (m *ControllerManager) Stop()

type DependencySet

type DependencySet struct {
	// contains filtered or unexported fields
}

func (*DependencySet) String

func (x *DependencySet) String() string

func (*DependencySet) TrackingDynamicClient

func (d *DependencySet) TrackingDynamicClient(inner dynamic.Interface) dynamic.Interface

func (*DependencySet) WatchList

func (x *DependencySet) WatchList(gvr schema.GroupVersionResource, ns string, opts metav1.ListOptions)

func (*DependencySet) WatchObject

func (x *DependencySet) WatchObject(gvr schema.GroupVersionResource, nn types.NamespacedName, rv string)

type GRNN

type GRNN struct {
	GR schema.GroupResource
	NN types.NamespacedName
}

type InterestSet

type InterestSet struct {
	// contains filtered or unexported fields
}

InterestSet represents a client that wants to know the ongoing status of a set of objects. The guarantee is that once we call ReplaceAllObjects, we will try to watch objects from that point onwards. TODO: Should we have a status on the InterestSet, to indicate that all our watches are healthy? TODO: Can we / should we fold this into applyset? Similar data structure...

func (*InterestSet) AddDependencies

func (s *InterestSet) AddDependencies(dependencies *DependencySet)

ReplaceAllDependencies completely replaces all the objects of interest.

func (*InterestSet) Close

func (s *InterestSet) Close()

Close indicates that this InterestSet is no longer in use.

func (*InterestSet) ReplaceAllDependencies

func (s *InterestSet) ReplaceAllDependencies(dependencies *DependencySet)

ReplaceAllDependencies completely replaces all the objects of interest.

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func NewManager

func NewManager(mgr manager.Manager) (*Manager, error)

func (*Manager) NewControllerManager

func (w *Manager) NewControllerManager(controller controller.Controller) (*ControllerManager, error)