vnode

Documentation

Index

• type VNode
  • func NewVNode(config *model.BuildVNodeConfig, t tunnel.Tunnel) (kn *VNode, err error)
  • func (n *VNode) CheckAndUpdatePod(ctx context.Context, key string, obj interface{}, pod *corev1.Pod)
  • func (n *VNode) CreateNodeLease(ctx context.Context, controllerID string) bool
  • func (n *VNode) DeletePod(key string)
  • func (n *VNode) DeletePodsFromKubernetesForget(ctx context.Context, key string)
  • func (n *VNode) Done() <-chan struct{}
  • func (n *VNode) Err() error
  • func (n *VNode) ExitWhenLeaderChanged() <-chan struct{}
  • func (n *VNode) InitContainerInfo(info model.ContainerStatusData)
  • func (n *VNode) IsLeader() bool
  • func (n *VNode) LoadPodFromController(key string) (any, bool)
  • func (n *VNode) LockRetryLease()
  • func (n *VNode) PodStore(key string, pod *corev1.Pod)
  • func (n *VNode) RenewLease(ctx context.Context, clientID string)
  • func (n *VNode) RetryLease()
  • func (n *VNode) Run(ctx context.Context, initData model.NodeInfo)
  • func (n *VNode) ShouldRetryLease() <-chan struct{}
  • func (n *VNode) Shutdown()
  • func (n *VNode) SyncAllContainerInfo(ctx context.Context, infos []model.ContainerStatusData)
  • func (n *VNode) SyncNodeStatus(data model.NodeStatusData)
  • func (n *VNode) SyncOneContainerInfo(ctx context.Context, info model.ContainerStatusData)
  • func (n *VNode) SyncPodsFromKubernetesEnqueue(ctx context.Context, key string)
  • func (n *VNode) WaitReady(ctx context.Context, timeout time.Duration) error

Types

type VNode

type VNode struct {
	tunnel.Tunnel
	// contains filtered or unexported fields
}

func NewVNode

func NewVNode(config *model.BuildVNodeConfig, t tunnel.Tunnel) (kn *VNode, err error)

func (*VNode) CheckAndUpdatePod

func (n *VNode) CheckAndUpdatePod(ctx context.Context, key string, obj interface{}, pod *corev1.Pod)

func (*VNode) CreateNodeLease

func (n *VNode) CreateNodeLease(ctx context.Context, controllerID string) bool

func (*VNode) DeletePod

func (n *VNode) DeletePod(key string)

func (*VNode) DeletePodsFromKubernetesForget

func (n *VNode) DeletePodsFromKubernetesForget(ctx context.Context, key string)

func (*VNode) Done

func (n *VNode) Done() <-chan struct{}

Done returns a channel that will be closed when the vnode has exited.

func (*VNode) Err

func (n *VNode) Err() error

Err returns err which causes vnode exit

func (*VNode) ExitWhenLeaderChanged

func (n *VNode) ExitWhenLeaderChanged() <-chan struct{}

ExitWhenLeaderChanged returns a channel that will be closed when the vnode leader changed

func (*VNode) InitContainerInfo

func (n *VNode) InitContainerInfo(info model.ContainerStatusData)

func (*VNode) IsLeader

func (n *VNode) IsLeader() bool

IsLeader returns a bool marked current vnode is leader or not

func (*VNode) LoadPodFromController

func (n *VNode) LoadPodFromController(key string) (any, bool)

func (*VNode) LockRetryLease

func (n *VNode) LockRetryLease()

func (*VNode) PodStore

func (n *VNode) PodStore(key string, pod *corev1.Pod)

func (*VNode) RenewLease

func (n *VNode) RenewLease(ctx context.Context, clientID string)

func (*VNode) RetryLease

func (n *VNode) RetryLease()

func (*VNode) Run

func (n *VNode) Run(ctx context.Context, initData model.NodeInfo)

func (*VNode) ShouldRetryLease

func (n *VNode) ShouldRetryLease() <-chan struct{}

func (*VNode) Shutdown

func (n *VNode) Shutdown()

Shutdown is the func of shutting down a vnode when base exit

func (*VNode) SyncAllContainerInfo

func (n *VNode) SyncAllContainerInfo(ctx context.Context, infos []model.ContainerStatusData)

func (*VNode) SyncNodeStatus

func (n *VNode) SyncNodeStatus(data model.NodeStatusData)

func (*VNode) SyncOneContainerInfo

func (n *VNode) SyncOneContainerInfo(ctx context.Context, info model.ContainerStatusData)

func (*VNode) SyncPodsFromKubernetesEnqueue

func (n *VNode) SyncPodsFromKubernetesEnqueue(ctx context.Context, key string)

func (*VNode) WaitReady

func (n *VNode) WaitReady(ctx context.Context, timeout time.Duration) error