monitor

Documentation

Index

• type ConfigMapMonitor
  • func New(configMapName string, namespace string, ...) (*ConfigMapMonitor, error)
  • func (cmm *ConfigMapMonitor) End(ctx context.Context, namespace, name string)
  • func (cmm *ConfigMapMonitor) Handle(ctx context.Context, event *watch.Event)
• type ConfigurationRegistry

Types

type ConfigMapMonitor

type ConfigMapMonitor struct {
	watcher.ObjectMonitorInterface
	ConfigurationRegistry ConfigurationRegistry
	ConfigMapName         string
	Namespace             string
	// contains filtered or unexported fields
}

func New

func New(configMapName string, namespace string, ConfigurationRegistry ConfigurationRegistry) (*ConfigMapMonitor, error)

func (*ConfigMapMonitor) End

func (cmm *ConfigMapMonitor) End(ctx context.Context, namespace, name string)

func (*ConfigMapMonitor) Handle

func (cmm *ConfigMapMonitor) Handle(ctx context.Context, event *watch.Event)

type ConfigurationRegistry

type ConfigurationRegistry interface {
	SetTrench(*nspAPI.Trench)
	SetConduits([]*nspAPI.Conduit)
	SetStreams([]*nspAPI.Stream)
	SetFlows([]*nspAPI.Flow)
	SetVips([]*nspAPI.Vip)
	SetAttractors([]*nspAPI.Attractor)
	SetGateways([]*nspAPI.Gateway)
}