exclusion

Documentation

Index

• type Watcher
  • func NewWatcher(triremeNets []string, kubeClient kubernetes.Client, ...) (*Watcher, error)
  • func (w *Watcher) Start()
  • func (w *Watcher) Stop()

Types

type Watcher

type Watcher struct {
	// contains filtered or unexported fields
}

Watcher is maintaining the state of the ExclusionList.

func NewWatcher

func NewWatcher(triremeNets []string, kubeClient kubernetes.Client, excluder supervisor.Excluder) (*Watcher, error)

NewWatcher generates a new Watcher

func (*Watcher) Start

func (w *Watcher) Start()

Start launches the Exclusion Watcher The exclusion watcher listens to all the service events and Blocking. Use go.

func (*Watcher) Stop

func (w *Watcher) Stop()

Stop stops the Excluder updater.