vnode

Nov 12, 2024

Changes in this version

type VNode

+ func (n *VNode) ListPodFromController() ([]*corev1.Pod, bool)

Oct 22, 2024

Changes in this version

type VNode

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

Oct 17, 2024

Changes in this version

type VNode

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

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

+ func (n *VNode) IsLeader() bool

+ func (n *VNode) LockRetryLease()

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

+ func (n *VNode) RetryLease()

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

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

Sep 24, 2024

Changes in this version

type VNode

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

Sep 11, 2024

Changes in this version

+ type VNode struct

+ 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) 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) LoadPodFromController(key string) (any, bool)

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

+ func (n *VNode) Run(ctx context.Context)

+ func (n *VNode) Shutdown()

+ func (n *VNode) SyncAllContainerInfo(infos []model.ContainerStatusData)

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

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

+ func (n *VNode) SyncSingleContainerInfo(info model.ContainerStatusData)

+ func (n *VNode) WaitReady(timeout time.Duration) error