controller

Documentation

Index

• Constants
• type Controller
  • func NewController(config *daemonconfig.Configuration, ...) (*Controller, error)
  • func (c *Controller) GetIPInstanceLister() networkinglister.IPInstanceLister
  • func (c *Controller) GetIPInstanceSynced() cache.InformerSynced
  • func (c *Controller) GetNetworkLister() networkinglister.NetworkLister
  • func (c *Controller) Run(stopCh <-chan struct{}) error
• type NodeIPCache
  • func NewNodeIPCache() *NodeIPCache
  • func (nic *NodeIPCache) SearchIP(ip net.IP) (net.HardwareAddr, bool)
  • func (nic *NodeIPCache) UpdateNodeIPs(nodeList []*v1.Node, localNodeName string, ...) error

Constants

const (
	ActionReconcileSubnet     = "ReconcileSubnet"
	ActionReconcileIPInstance = "ReconcileIPInstance"
	ActionReconcileNode       = "ReconcileNode"

	ByInstanceIPIndexer = "instanceIP"
	ByEndpointIPIndexer = "endpointIP"

	// to reduce channel block times while neigh netlink update increase.
	NeighUpdateChanSize = 2000
	LinkUpdateChainSize = 200
	AddrUpdateChainSize = 200

	NetlinkSubscribeRetryInterval = 10 * time.Second
)

Types

type Controller

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

Controller is a set of kubernetes controllers

func NewController

func NewController(config *daemonconfig.Configuration,
	hybridnetInformerFactory hybridnetinformer.SharedInformerFactory,
	kubeInformerFactory informers.SharedInformerFactory) (*Controller, error)

NewController returns a Controller to watch kubernetes CRD object events

func (*Controller) GetIPInstanceLister

func (c *Controller) GetIPInstanceLister() networkinglister.IPInstanceLister

func (*Controller) GetIPInstanceSynced

func (c *Controller) GetIPInstanceSynced() cache.InformerSynced

func (*Controller) GetNetworkLister

func (c *Controller) GetNetworkLister() networkinglister.NetworkLister

func (*Controller) Run

func (c *Controller) Run(stopCh <-chan struct{}) error

Run a Controller

type NodeIPCache

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

func NewNodeIPCache

func NewNodeIPCache() *NodeIPCache

func (*NodeIPCache) SearchIP

func (nic *NodeIPCache) SearchIP(ip net.IP) (net.HardwareAddr, bool)

func (*NodeIPCache) UpdateNodeIPs

func (nic *NodeIPCache) UpdateNodeIPs(nodeList []*v1.Node, localNodeName string, remoteVtepList []*networkingv1.RemoteVtep) error