controller

Documentation

Index

• Constants
• type CtrlHub
  • func NewCtrlHub(config *daemonconfig.Configuration, mgr ctrl.Manager, logger logr.Logger) (*CtrlHub, error)
  • func (c *CtrlHub) CacheSynced(ctx context.Context) bool
  • func (c *CtrlHub) GetBGPManager() *bgp.Manager
  • func (c *CtrlHub) GetMgrAPIReader() client.Reader
  • func (c *CtrlHub) GetMgrClient() client.Client
  • func (c *CtrlHub) Run(ctx context.Context) error
• type NodeIPCache
  • func NewNodeIPCache() *NodeIPCache
  • func (nic *NodeIPCache) SearchIP(ip net.IP) (net.HardwareAddr, bool)
  • func (nic *NodeIPCache) UpdateNodeIPs(nodeInfoList []networkingv1.NodeInfo, localNodeName string, ...) error

Constants

const (
	InstanceIPIndex = "instanceIP"
	EndpointIPIndex = "endpointIP"

	NeighUpdateChanSize = 2000
	LinkUpdateChainSize = 200
	AddrUpdateChainSize = 200

	NetlinkSubscribeRetryInterval = 10 * time.Second
)

Types

type CtrlHub

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

func NewCtrlHub

func NewCtrlHub(config *daemonconfig.Configuration, mgr ctrl.Manager, logger logr.Logger) (*CtrlHub, error)

func (*CtrlHub) CacheSynced

func (c *CtrlHub) CacheSynced(ctx context.Context) bool

func (*CtrlHub) GetBGPManager

func (c *CtrlHub) GetBGPManager() *bgp.Manager

func (*CtrlHub) GetMgrAPIReader

func (c *CtrlHub) GetMgrAPIReader() client.Reader

func (*CtrlHub) GetMgrClient

func (c *CtrlHub) GetMgrClient() client.Client

func (*CtrlHub) Run

func (c *CtrlHub) Run(ctx context.Context) error

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(nodeInfoList []networkingv1.NodeInfo, localNodeName string, remoteVtepList []*multiclusterv1.RemoteVtep) error