cluster

May 8, 2026

Changes in this version

+ type ClusterDetector struct

+ func NewClusterDetector(nodeID string, clusterType config.ClusterType) *ClusterDetector

+ func (cd *ClusterDetector) DetectCluster() (*ClusterInfo, error)

+ func (cd *ClusterDetector) GetKubeconfig(clusterInfo *ClusterInfo) ([]byte, error)

+ func (cd *ClusterDetector) ValidateKubeconfig(kubeconfigData []byte) error

+ type ClusterInfo struct

+ DetectedAt time.Time

+ KubeconfigPath string

+ Status string

+ Type string

+ Version string

+ type KubeconfigManager struct

+ func NewKubeconfigManager(hostmgrClient *hostmgr_client.Client, nodeID string) *KubeconfigManager

+ func (km *KubeconfigManager) ClearKubeconfig(ctx context.Context, confs *config.NodeAgentConfig) error

+ func (km *KubeconfigManager) GetClusterStatus(clusterInfo *ClusterInfo) string

+ func (km *KubeconfigManager) GetLastKubeconfig() []byte

+ func (km *KubeconfigManager) HasKubeconfig() bool

+ func (km *KubeconfigManager) KubeconfigSize() int

+ func (km *KubeconfigManager) NotifyKubeconfig(ctx context.Context, kubeconfigData []byte, clusterInfo *ClusterInfo, ...) error