k8smonitor

Documentation

Index

• Constants
• func CreateK8sClientset() (kubernetes.Interface, error)
• func CreateLocalK8sClientset() (kubernetes.Interface, error)
• type IPNet
  • func CreateIPNet(ipnet *net.IPNet) *IPNet
• type Monitor
  • func CreateMonitor(clientset kubernetes.Interface) (*Monitor, error)
  • func (m *Monitor) IsInternalCIDR(ip string) bool
  • func (m *Monitor) Start()
  • func (m *Monitor) Stop()
• type NodeMonitor
  • func CreateNodeMonitor(clientset kubernetes.Interface) (*NodeMonitor, error)
  • func (m *NodeMonitor) IsPodCIDR(ipStr string) bool
  • func (m *NodeMonitor) Start()
  • func (m *NodeMonitor) Stop()
• type ServiceMonitor
  • func CreateServiceMonitor(clientset kubernetes.Interface) (*ServiceMonitor, error)
  • func (m *ServiceMonitor) IsServiceIP(ipStr string) bool
  • func (m *ServiceMonitor) Start()
  • func (m *ServiceMonitor) Stop()

Constants

const ResyncPeriod = 1 * time.Minute

Functions

func CreateK8sClientset

func CreateK8sClientset() (kubernetes.Interface, error)

func CreateLocalK8sClientset

func CreateLocalK8sClientset() (kubernetes.Interface, error)

Types

type IPNet

type IPNet struct {
	Network             *net.IPNet
	NetworkIdentifierIP net.IP
	BroadcastIP         net.IP
}

func CreateIPNet

func CreateIPNet(ipnet *net.IPNet) *IPNet

type Monitor

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

func CreateMonitor

func CreateMonitor(clientset kubernetes.Interface) (*Monitor, error)

func (*Monitor) IsInternalCIDR

func (m *Monitor) IsInternalCIDR(ip string) bool

func (*Monitor) Start

func (m *Monitor) Start()

func (*Monitor) Stop

func (m *Monitor) Stop()

type NodeMonitor

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

func CreateNodeMonitor

func CreateNodeMonitor(clientset kubernetes.Interface) (*NodeMonitor, error)

func (*NodeMonitor) IsPodCIDR

func (m *NodeMonitor) IsPodCIDR(ipStr string) bool

IsPodCIDR returns true if the given pod meeting the following conditions: 1. Included in one of the node's pod CIDRs 2. Not a broadcast IP (the last IP in the CIDR range) 3. Not a network identifier IP (the first IP in the CIDR range).

func (*NodeMonitor) Start

func (m *NodeMonitor) Start()

func (*NodeMonitor) Stop

func (m *NodeMonitor) Stop()

type ServiceMonitor

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

func CreateServiceMonitor

func CreateServiceMonitor(clientset kubernetes.Interface) (*ServiceMonitor, error)

func (*ServiceMonitor) IsServiceIP

func (m *ServiceMonitor) IsServiceIP(ipStr string) bool

func (*ServiceMonitor) Start

func (m *ServiceMonitor) Start()

func (*ServiceMonitor) Stop

func (m *ServiceMonitor) Stop()