operator

Documentation

Index

• type Iterator
  • func New(ctx context.Context, logger logging.Logger, iterate func(), watchers []Watcher) *Iterator
  • func (i *Iterator) Initialize() error
  • func (i *Iterator) Run()
• type Watcher

Types

type Iterator

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

func New

func New(ctx context.Context,
	logger logging.Logger,
	iterate func(),
	watchers []Watcher) *Iterator

func (*Iterator) Initialize

func (i *Iterator) Initialize() error

func (*Iterator) Run

func (i *Iterator) Run()

type Watcher

type Watcher interface {
	Watch(fire chan<- struct{}) error
}