watcher

Documentation

Index

• type Event
• type EventSource
  • func (e EventSource) String() string
• type PrometheusCRWatcher
  • func NewPrometheusCRWatcher(logger logr.Logger, cfg allocatorconfig.Config) (*PrometheusCRWatcher, error)
  • func (w *PrometheusCRWatcher) Close() error
  • func (w *PrometheusCRWatcher) LoadConfig(ctx context.Context) (*promconfig.Config, error)
  • func (w *PrometheusCRWatcher) Watch(upstreamEvents chan Event, upstreamErrors chan error) error
• type Watcher

Types

type Event

type Event struct {
	Source  EventSource
	Watcher Watcher
}

type EventSource

type EventSource int

const (
	EventSourceConfigMap EventSource = iota
	EventSourcePrometheusCR
)

func (EventSource) String

func (e EventSource) String() string

type PrometheusCRWatcher

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

func NewPrometheusCRWatcher

func NewPrometheusCRWatcher(logger logr.Logger, cfg allocatorconfig.Config) (*PrometheusCRWatcher, error)

func (*PrometheusCRWatcher) Close

func (w *PrometheusCRWatcher) Close() error

func (*PrometheusCRWatcher) LoadConfig

func (w *PrometheusCRWatcher) LoadConfig(ctx context.Context) (*promconfig.Config, error)

func (*PrometheusCRWatcher) Watch

func (w *PrometheusCRWatcher) Watch(upstreamEvents chan Event, upstreamErrors chan error) error

Watch wrapped informers and wait for an initial sync.

type Watcher

type Watcher interface {
	// Watch watcher and supply channels which will receive change events
	Watch(upstreamEvents chan Event, upstreamErrors chan error) error
	LoadConfig(ctx context.Context) (*promconfig.Config, error)
	Close() error
}