vnode_controller

Documentation

Index

• type RuntimeInfoStore
  • func NewRuntimeInfoStore() *RuntimeInfoStore
  • func (r *RuntimeInfoStore) AllNodeNum() int
  • func (r *RuntimeInfoStore) DeleteNode(nodeName string)
  • func (r *RuntimeInfoStore) DeleteVNode(nodeID string)
  • func (r *RuntimeInfoStore) GetLeaseOutdatedVNodeName(leaseDuration time.Duration) []string
  • func (r *RuntimeInfoStore) GetNotReachableNodeInfos(maxUnreachableDuration time.Duration) []model.UnreachableNodeInfo
  • func (r *RuntimeInfoStore) GetVNode(nodeID string) *vnode.VNode
  • func (r *RuntimeInfoStore) GetVNodeByNodeName(nodeName string) *vnode.VNode
  • func (r *RuntimeInfoStore) GetVNodes() []*vnode.VNode
  • func (r *RuntimeInfoStore) NodeMsgArrived(nodeID string)
  • func (r *RuntimeInfoStore) NodeRunning(nodeID string)
  • func (r *RuntimeInfoStore) NodeShutdown(nodeID string)
  • func (r *RuntimeInfoStore) PutNode(nodeName string)
  • func (r *RuntimeInfoStore) PutVNode(nodeID string, vnode *vnode.VNode)
  • func (r *RuntimeInfoStore) PutVNodeIDNX(nodeID string) error
  • func (r *RuntimeInfoStore) PutVNodeLeaseLatestUpdateTime(nodeName string, renewTime time.Time)
  • func (r *RuntimeInfoStore) RunningNodeNum() int
• type VNodeController
  • func NewVNodeController(config *model.BuildVNodeControllerConfig, tunnels []tunnel.Tunnel) (*VNodeController, error)
  • func (brc *VNodeController) Reconcile(_ context.Context, _ reconcile.Request) (reconcile.Result, error)
  • func (brc *VNodeController) SetupWithManager(ctx context.Context, mgr manager.Manager) (err error)

Types

type RuntimeInfoStore

type RuntimeInfoStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

RuntimeInfoStore provide the in memory runtime information.

func NewRuntimeInfoStore

func NewRuntimeInfoStore() *RuntimeInfoStore

func (*RuntimeInfoStore) AllNodeNum

func (r *RuntimeInfoStore) AllNodeNum() int

func (*RuntimeInfoStore) DeleteNode

func (r *RuntimeInfoStore) DeleteNode(nodeName string)

func (*RuntimeInfoStore) DeleteVNode

func (r *RuntimeInfoStore) DeleteVNode(nodeID string)

func (*RuntimeInfoStore) GetLeaseOutdatedVNodeName

func (r *RuntimeInfoStore) GetLeaseOutdatedVNodeName(leaseDuration time.Duration) []string

func (*RuntimeInfoStore) GetNotReachableNodeInfos

func (r *RuntimeInfoStore) GetNotReachableNodeInfos(maxUnreachableDuration time.Duration) []model.UnreachableNodeInfo

func (*RuntimeInfoStore) GetVNode

func (r *RuntimeInfoStore) GetVNode(nodeID string) *vnode.VNode

func (*RuntimeInfoStore) GetVNodeByNodeName

func (r *RuntimeInfoStore) GetVNodeByNodeName(nodeName string) *vnode.VNode

func (*RuntimeInfoStore) GetVNodes

func (r *RuntimeInfoStore) GetVNodes() []*vnode.VNode

func (*RuntimeInfoStore) NodeMsgArrived

func (r *RuntimeInfoStore) NodeMsgArrived(nodeID string)

func (*RuntimeInfoStore) NodeRunning

func (r *RuntimeInfoStore) NodeRunning(nodeID string)

func (*RuntimeInfoStore) NodeShutdown

func (r *RuntimeInfoStore) NodeShutdown(nodeID string)

func (*RuntimeInfoStore) PutNode

func (r *RuntimeInfoStore) PutNode(nodeName string)

func (*RuntimeInfoStore) PutVNode

func (r *RuntimeInfoStore) PutVNode(nodeID string, vnode *vnode.VNode)

func (*RuntimeInfoStore) PutVNodeIDNX

func (r *RuntimeInfoStore) PutVNodeIDNX(nodeID string) error

func (*RuntimeInfoStore) PutVNodeLeaseLatestUpdateTime

func (r *RuntimeInfoStore) PutVNodeLeaseLatestUpdateTime(nodeName string, renewTime time.Time)

func (*RuntimeInfoStore) RunningNodeNum

func (r *RuntimeInfoStore) RunningNodeNum() int

type VNodeController

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

func NewVNodeController

func NewVNodeController(config *model.BuildVNodeControllerConfig, tunnels []tunnel.Tunnel) (*VNodeController, error)

func (*VNodeController) Reconcile

func (brc *VNodeController) Reconcile(_ context.Context, _ reconcile.Request) (reconcile.Result, error)

func (*VNodeController) SetupWithManager

func (brc *VNodeController) SetupWithManager(ctx context.Context, mgr manager.Manager) (err error)