watchers

Documentation

Index

• type CoreWatchers
  • func NewCoreWatchers(ctx context.Context, namespaces []string, om ObjectModifier) *CoreWatchers
  • func (w *CoreWatchers) Cancel()
  • func (w *CoreWatchers) EnsureStarted(ctx context.Context)
  • func (w *CoreWatchers) LoadSnapshot(ctx context.Context, snapshot *snapshotTypes.Snapshot)
  • func (w *CoreWatchers) Subscribe(ctx context.Context) <-chan struct{}
• type FallbackWatchers
  • func NewFallbackWatcher(ctx context.Context, namespaces []string, om ObjectModifier) *FallbackWatchers
  • func (w *FallbackWatchers) Cancel()
  • func (w *FallbackWatchers) EnsureStarted(ctx context.Context)
  • func (w *FallbackWatchers) LoadSnapshot(ctx context.Context, snapshot *snapshotTypes.Snapshot)
  • func (w *FallbackWatchers) Subscribe(ctx context.Context) <-chan struct{}
• type ObjectModifier
• type SnapshotWatcher

Types

type CoreWatchers

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

func NewCoreWatchers

func NewCoreWatchers(ctx context.Context, namespaces []string, om ObjectModifier) *CoreWatchers

func (*CoreWatchers) Cancel

func (w *CoreWatchers) Cancel()

func (*CoreWatchers) EnsureStarted

func (w *CoreWatchers) EnsureStarted(ctx context.Context)

func (*CoreWatchers) LoadSnapshot

func (w *CoreWatchers) LoadSnapshot(ctx context.Context, snapshot *snapshotTypes.Snapshot)

func (*CoreWatchers) Subscribe

func (w *CoreWatchers) Subscribe(ctx context.Context) <-chan struct{}

type FallbackWatchers

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

func NewFallbackWatcher

func NewFallbackWatcher(ctx context.Context, namespaces []string, om ObjectModifier) *FallbackWatchers

func (*FallbackWatchers) Cancel

func (w *FallbackWatchers) Cancel()

func (*FallbackWatchers) EnsureStarted

func (w *FallbackWatchers) EnsureStarted(ctx context.Context)

func (*FallbackWatchers) LoadSnapshot

func (w *FallbackWatchers) LoadSnapshot(ctx context.Context, snapshot *snapshotTypes.Snapshot)

func (*FallbackWatchers) Subscribe

func (w *FallbackWatchers) Subscribe(ctx context.Context) <-chan struct{}

type ObjectModifier

type ObjectModifier func(obj runtime.Object)

type SnapshotWatcher

type SnapshotWatcher interface {
	LoadSnapshot(ctx context.Context, snapshot *snapshotTypes.Snapshot)
	Subscribe(ctx context.Context) <-chan struct{}
	EnsureStarted(ctx context.Context)
	Cancel()
}