discovery

Documentation

Index

• Variables
• type Config
  • func (cfg *Config) Check() *Config
• type Discovery
  • func NewNoopDiscovery() Discovery
• type GetOpt
• type GetOpts
• type Result
• type WatchOpt
• type WatchOpts
• type Watcher

Variables

var (
	ErrWatcherStopped = errors.New("err watcher stopped")
	ErrTimeout        = errors.New("err watcher timeout")
)

Types

type Config

type Config struct {
	Interval  time.Duration `yaml:"interval"`
	Driver    string        `yaml:"driver"`
	DriverCfg *config.Node  `yaml:"driver_config"`
}

func (*Config) Check

func (cfg *Config) Check() *Config

type Discovery

type Discovery interface {
	String() string
	Watch(ctx context.Context, srv string, opts ...WatchOpt) result.Result[Watcher]
	GetService(ctx context.Context, srv string, opts ...GetOpt) result.Result[[]*service.Service]
}

func NewNoopDiscovery

func NewNoopDiscovery() Discovery

type GetOpt

type GetOpt func(*GetOpts)

type GetOpts

type GetOpts struct {
	Timeout time.Duration
}

type Result

type Result struct {
	Action  lavapbv1.EventType
	Service *service.Service
}

Result is returned by a call to Next on the watcher. Actions can be create, update, delete

type WatchOpt

type WatchOpt func(*WatchOpts)

type WatchOpts

type WatchOpts struct {
	Service string
}

type Watcher

type Watcher interface {
	// Next is a blocking call
	Next() result.Result[*Result]
	Stop() error
}

Watcher is an interface that returns updates about services within the registry.