observer

Documentation

Index

• Variables
• func Run(stop chan struct{}, stopped chan struct{}, clock clockwork.Clock, ...)
• type Observer
  • func NewObserver(lc fx.Lifecycle, cfg config.Config, clock clockwork.Clock, ...) *Observer
• type Opts

Variables

var Module = fx.Module("observer",
	fx.Provide(provideObserverConfigs),
	fx.Invoke(
		serverobserver.New,
		instanceobserver.New,
		probeobserver.New,
	),
	fx.Provide(NewObserver),
)

Functions

func Run

func Run(
	stop chan struct{},
	stopped chan struct{},
	clock clockwork.Clock,
	logger *zerolog.Logger,
	collector *metrics.Collector,
	cfg config.Config,
)

Types

type Observer

type Observer struct{}

func NewObserver

func NewObserver(
	lc fx.Lifecycle,
	cfg config.Config,
	clock clockwork.Clock,
	collector *metrics.Collector,
	logger *zerolog.Logger,
) *Observer

type Opts

type Opts struct {
	fx.Out

	ServerObserverOpts serverobserver.Opts
}