aggregator

Documentation

Index

• type Aggregator
  • func NewAggregator(snapshots chan<- string, k8sWatches chan<- []watchapi.KubernetesWatchSpec, ...) *Aggregator
  • func (a *Aggregator) Work(p *supervisor.Process) error
• type WatchHook
  • func ExecWatchHook(watchHooks []string) WatchHook

Types

type Aggregator

type Aggregator struct {

	// Public input channels that other things can use to send us information.
	KubernetesEvents chan<- thingkube.K8sEvent      // Kubernetes state
	ConsulEvents     chan<- thingconsul.ConsulEvent // Consul endpoints
	// contains filtered or unexported fields
}

func NewAggregator

func NewAggregator(snapshots chan<- string, k8sWatches chan<- []watchapi.KubernetesWatchSpec, consulWatches chan<- []watchapi.ConsulWatchSpec,
	requiredKinds []string, watchHook WatchHook, limiter limiter.Limiter, validator *kates.Validator) *Aggregator

func (*Aggregator) Work

func (a *Aggregator) Work(p *supervisor.Process) error

type WatchHook

type WatchHook func(p *supervisor.Process, snapshot string) watchapi.WatchSet

func ExecWatchHook

func ExecWatchHook(watchHooks []string) WatchHook