instance

Documentation

Index

• type Tracker
  • func NewTracker(name string, plugin instance.Plugin, tick <-chan time.Time, ...) *Tracker
  • func (m *Tracker) List(topic types.Path) ([]string, error)
  • func (m *Tracker) PublishOn(events chan<- *event.Event)
  • func (m *Tracker) Stop()

Types

type Tracker

type Tracker struct {

	// Plugin is the instance plugin to use
	Plugin instance.Plugin

	// Name is the name of the plugin
	Name string
	// contains filtered or unexported fields
}

Tracker implements the event spi -- just just calls the Describe to get a list of known instances, and report anything it hasn't seen before, or if anything that disappeared.

func NewTracker

func NewTracker(name string, plugin instance.Plugin, tick <-chan time.Time, tags map[string]string) *Tracker

NewTracker returns an event plugin implementation that can generate events based on resources it trackers

func (*Tracker) List

func (m *Tracker) List(topic types.Path) ([]string, error)

List returns the nodes under the given topic

func (*Tracker) PublishOn

func (m *Tracker) PublishOn(events chan<- *event.Event)

PublishOn sets the channel to publish on

func (*Tracker) Stop

func (m *Tracker) Stop()

Stop stops the Tracker