monitor

Documentation

Index

• Constants
• func NewAgentMonitor(client client.Client, ipMonitor ofportIpMonitor) (*agentMonitor, error)
• type IpMonitor
  • func (i *IpMonitor) HandleUpdatedOfport(dataChan <-chan map[uint32][]types.IPAddress, stopChan <-chan struct{})
  • func (i *IpMonitor) Run(dataChan <-chan map[uint32][]types.IPAddress, stopChan <-chan struct{})

Constants

const (
	AgentNameConfigPath = "/var/lib/lynx/agent/name"
)

Functions

func NewAgentMonitor

func NewAgentMonitor(client client.Client, ipMonitor ofportIpMonitor) (*agentMonitor, error)

NewAgentMonitor return a new agentMonitor with kubernetes client and ipMonitor.

Types

type IpMonitor

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

func (*IpMonitor) HandleUpdatedOfport

func (i *IpMonitor) HandleUpdatedOfport(dataChan <-chan map[uint32][]types.IPAddress, stopChan <-chan struct{})

func (*IpMonitor) Run

func (i *IpMonitor) Run(dataChan <-chan map[uint32][]types.IPAddress, stopChan <-chan struct{})