Versions in this module Expand all Collapse all v0 v0.1.0 Jul 29, 2024 Changes in this version + type BaseNode struct + BaseBizInfoChan chan []ark.ArkBizInfo + BaseHealthInfoChan chan ark.HealthData + func NewBaseNode(config *BuildBaseNodeConfig) (kn *BaseNode, err error) + func (n *BaseNode) CheckAndUpdatePod(ctx context.Context, key string, obj interface{}, pod *corev1.Pod) + func (n *BaseNode) DeletePod(key string) + func (n *BaseNode) DeletePodsFromKubernetesForget(ctx context.Context, key string) + func (n *BaseNode) Done() <-chan struct{} + func (n *BaseNode) Err() error + func (n *BaseNode) Exit() + func (n *BaseNode) LoadPodFromController(key string) (any, bool) + func (n *BaseNode) PodStore(key string, pod *corev1.Pod) + func (n *BaseNode) Run(ctx context.Context) + func (n *BaseNode) SyncPodsFromKubernetesEnqueue(ctx context.Context, key string) + func (n *BaseNode) WaitReady(ctx context.Context, timeout time.Duration) error + type BuildBaseNodeConfig struct + BizName string + BizVersion string + KubeClient kubernetes.Interface + NodeID string + NodeIP string + PodInformer informer.PodInformer + PodLister lister.PodLister + TechStack string + Tunnel tunnel.Tunnel
Go to main page