watcher

package

v0.93.0 Latest Latest Go to latest Published: Feb 23, 2024 License: Apache-2.0 Imports: 27 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/decisiveai/opentelemetry-operator

Links

Open Source Insights

Documentation ¶

Index ¶

type Event
type EventSource
- func (e EventSource) String() string
type FileWatcher
- func NewFileWatcher(logger logr.Logger, configFilePath string) (*FileWatcher, error)
type PrometheusCRWatcher
- func NewPrometheusCRWatcher(ctx context.Context, logger logr.Logger, cfg allocatorconfig.Config) (*PrometheusCRWatcher, error)
type Watcher

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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 FileWatcher ¶

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

func NewFileWatcher ¶

func NewFileWatcher(logger logr.Logger, configFilePath string) (*FileWatcher, error)

func (*FileWatcher) Close ¶

func (f *FileWatcher) Close() error

func (*FileWatcher) LoadConfig ¶

func (f *FileWatcher) LoadConfig(_ context.Context) (*promconfig.Config, error)

func (*FileWatcher) Watch ¶

func (f *FileWatcher) Watch(upstreamEvents chan Event, upstreamErrors chan error) error

type PrometheusCRWatcher ¶

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

func NewPrometheusCRWatcher ¶

func NewPrometheusCRWatcher(ctx context.Context, 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
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL