monitor

Documentation

Index

• type ByID
  • func (a ByID) Len() int
  • func (a ByID) Less(i, j int) bool
  • func (a ByID) Swap(i, j int)
• type ControllerConfig
• type ControllerListener
• type Monitor
  • func NewController(conf ControllerConfig) Monitor
  • func NewRegistry(conf RegistryConfig) Monitor
• type RegistryConfig
• type RegistryListener

Types

type ByID

type ByID []client.ServiceInstance

ByID sorts by ID

func (ByID) Len

func (a ByID) Len() int

Len of the array

func (ByID) Less

func (a ByID) Less(i, j int) bool

Less i and j

func (ByID) Swap

func (a ByID) Swap(i, j int)

Swap i and j

type ControllerConfig

type ControllerConfig struct {
	Client       client.Client
	Listeners    []ControllerListener
	PollInterval time.Duration
}

ControllerConfig options

type ControllerListener

type ControllerListener interface {
	RuleChange([]rules.Rule) error
}

ControllerListener is notified of changes to controller

type Monitor

type Monitor interface {
	Start() error
	Stop() error
}

Monitor a source

func NewController

func NewController(conf ControllerConfig) Monitor

NewController instantiates a new instance

func NewRegistry

func NewRegistry(conf RegistryConfig) Monitor

NewRegistry instantiates new instance

type RegistryConfig

type RegistryConfig struct {
	PollInterval   time.Duration
	RegistryClient client.Discovery
	Listeners      []RegistryListener
}

RegistryConfig options

type RegistryListener

type RegistryListener interface {
	CatalogChange([]client.ServiceInstance) error
}

RegistryListener is notified of changes to the registry catalog