monitor

Documentation

Index

• Constants
• type ByID
  • func (a ByID) Len() int
  • func (a ByID) Less(i, j int) bool
  • func (a ByID) Swap(i, j int)
• type DiscoveryConfig
• type DiscoveryListener
• type DiscoveryMonitor
  • func NewDiscoveryMonitor(conf DiscoveryConfig) DiscoveryMonitor
• type Monitor
• type RulesConfig
• type RulesListener
• type RulesMonitor
  • func NewRulesMonitor(conf RulesConfig) RulesMonitor

Constants

const DefaultDiscoveryPollInterval = 1 * time.Second

DefaultDiscoveryPollInterval is the default used for the discovery monitor's poll interval, if no other value is specified. Currently, all existing ServiceDiscovery adapters use caching with background polling, so the 1 second polling here is basically polling a local cache only. Note: this will be removed once the ServiceDiscovery interface exposes a Watch() mechanism.

Types

type ByID

type ByID []*api.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 DiscoveryConfig

type DiscoveryConfig struct {
	Discovery    api.ServiceDiscovery
	Listeners    []DiscoveryListener
	PollInterval time.Duration
}

DiscoveryConfig holds configuration options for the discovery monitor

type DiscoveryListener

type DiscoveryListener interface {
	CatalogChange([]api.ServiceInstance) error
}

DiscoveryListener is notified of changes to the discovery catalog

type DiscoveryMonitor

type DiscoveryMonitor interface {
	Monitor
	AddListener(DiscoveryListener)
	RemoveListener(DiscoveryListener)
}

DiscoveryMonitor interface.

func NewDiscoveryMonitor

func NewDiscoveryMonitor(conf DiscoveryConfig) DiscoveryMonitor

NewDiscoveryMonitor instantiates a new discovery monitor

type Monitor

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

Monitor a source

type RulesConfig

type RulesConfig struct {
	Rules        api.RulesService
	Listeners    []RulesListener
	PollInterval time.Duration
}

RulesConfig holds configuration options for the rules monitor.

type RulesListener

type RulesListener interface {
	RuleChange([]api.Rule) error
}

RulesListener is notified of changes to rules

type RulesMonitor

type RulesMonitor interface {
	Monitor
	AddListener(RulesListener)
	RemoveListener(RulesListener)
}

RulesMonitor interface.

func NewRulesMonitor

func NewRulesMonitor(conf RulesConfig) RulesMonitor

NewRulesMonitor instantiates a new rules monitor