entity

Documentation

Index

• func CreateNodeGroup(ctx context.Context, kubeCl *client.KubernetesClient, nodeGroupName string, ...) error
• func CreateOrUpdateNodeUser(ctx context.Context, kubeProvider kubernetes.KubeClientProviderWithCtx, ...) error
• func DeleteNode(ctx context.Context, kubeCl *client.KubernetesClient, nodeName string) error
• func DeleteNodeGroup(ctx context.Context, kubeCl *client.KubernetesClient, nodeGroupName string) error
• func DeleteNodeUser(ctx context.Context, kubeProvider kubernetes.KubeClientProviderWithCtx, ...) error
• func GetCloudConfig(ctx context.Context, kubeCl *client.KubernetesClient, nodeGroupName string, ...) (string, error)
• func GetMetaConfig(ctx context.Context, kubeCl *client.KubernetesClient, logger log.Logger, ...) (*config.MetaConfig, error)
• func GetNodeGroup(ctx context.Context, kubeCl *client.KubernetesClient, nodeGroupName string) (*unstructured.Unstructured, error)
• func GetNodeGroupDirect(ctx context.Context, kubeCl *client.KubernetesClient, nodeGroupName string) (*unstructured.Unstructured, error)
• func GetNodeGroupTemplates(ctx context.Context, kubeCl *client.KubernetesClient) (map[string]map[string]interface{}, error)
• func GetNodeGroups(ctx context.Context, kubeCl *client.KubernetesClient) ([]unstructured.Unstructured, error)
• func IsNodeExistsInCluster(ctx context.Context, kubeCl *client.KubernetesClient, nodeName string, ...) (bool, error)
• func UnstructuredToNodeGroup(o *unstructured.Unstructured) (*v1.NodeGroup, error)
• func UpdateNodeGroup(ctx context.Context, kubeCl *client.KubernetesClient, nodeGroupName string, ...) error
• func WaitForNodesBecomeReady(ctx context.Context, kubeCl *client.KubernetesClient, ...) error
• func WaitForNodesListBecomeReady(ctx context.Context, kubeCl *client.KubernetesClient, nodes []string, ...) error
• func WaitForSingleNodeBecomeReady(ctx context.Context, kubeCl *client.KubernetesClient, nodeName string) error
• type NodeIP
  • func GetMasterNodesIPs(ctx context.Context, kubeProvider kubernetes.KubeClientProviderWithCtx, ...) ([]NodeIP, error)
  • func (i *NodeIP) Name() string
• type NodeUserPresentsChecker
• type NodeUserPresentsWaiter
  • func NewConvergerNodeUserExistsWaiter(kubeProvider kubernetes.KubeClientProviderWithCtx) *NodeUserPresentsWaiter
  • func NewNodeUserExistsWaiter(checker NodeUserPresentsChecker, ...) *NodeUserPresentsWaiter
  • func (w *NodeUserPresentsWaiter) WaitPresentOnNodes(ctx context.Context, nodeUser *v1.NodeUserCredentials) error
  • func (w *NodeUserPresentsWaiter) WithParams(params retry.Params) *NodeUserPresentsWaiter

Functions

func CreateNodeGroup

func CreateNodeGroup(ctx context.Context, kubeCl *client.KubernetesClient, nodeGroupName string, logger log.Logger, data map[string]interface{}) error

func CreateOrUpdateNodeUser

func CreateOrUpdateNodeUser(ctx context.Context, kubeProvider kubernetes.KubeClientProviderWithCtx, nodeUser *v1.NodeUser, loopParams retry.Params) error

func DeleteNode

func DeleteNode(ctx context.Context, kubeCl *client.KubernetesClient, nodeName string) error

func DeleteNodeGroup

func DeleteNodeGroup(ctx context.Context, kubeCl *client.KubernetesClient, nodeGroupName string) error

func DeleteNodeUser

func DeleteNodeUser(ctx context.Context, kubeProvider kubernetes.KubeClientProviderWithCtx, name string) error

func GetCloudConfig

func GetCloudConfig(ctx context.Context, kubeCl *client.KubernetesClient, nodeGroupName string, showDeckhouseLogs bool, logger log.Logger, apiserverHosts ...string) (string, error)

func GetMetaConfig

func GetMetaConfig(ctx context.Context, kubeCl *client.KubernetesClient, logger log.Logger, dc *directoryconfig.DirectoryConfig) (*config.MetaConfig, error)

func GetNodeGroup

func GetNodeGroup(ctx context.Context, kubeCl *client.KubernetesClient, nodeGroupName string) (*unstructured.Unstructured, error)

func GetNodeGroupDirect

func GetNodeGroupDirect(ctx context.Context, kubeCl *client.KubernetesClient, nodeGroupName string) (*unstructured.Unstructured, error)

func GetNodeGroupTemplates

func GetNodeGroupTemplates(ctx context.Context, kubeCl *client.KubernetesClient) (map[string]map[string]interface{}, error)

func GetNodeGroups

func GetNodeGroups(ctx context.Context, kubeCl *client.KubernetesClient) ([]unstructured.Unstructured, error)

func IsNodeExistsInCluster

func IsNodeExistsInCluster(ctx context.Context, kubeCl *client.KubernetesClient, nodeName string, logger log.Logger) (bool, error)

func UnstructuredToNodeGroup

func UnstructuredToNodeGroup(o *unstructured.Unstructured) (*v1.NodeGroup, error)

func UpdateNodeGroup

func UpdateNodeGroup(ctx context.Context, kubeCl *client.KubernetesClient, nodeGroupName string, ng *unstructured.Unstructured) error

func WaitForNodesBecomeReady

func WaitForNodesBecomeReady(ctx context.Context, kubeCl *client.KubernetesClient, nodeGroupsMap map[string]int) error

func WaitForNodesListBecomeReady

func WaitForNodesListBecomeReady(ctx context.Context, kubeCl *client.KubernetesClient, nodes []string, checker hook.NodeChecker) error

func WaitForSingleNodeBecomeReady

func WaitForSingleNodeBecomeReady(ctx context.Context, kubeCl *client.KubernetesClient, nodeName string) error

Types

type NodeIP

type NodeIP struct {
	InternalIP string
	ExternalIP string
	NodeName   string
}

func GetMasterNodesIPs

func GetMasterNodesIPs(ctx context.Context, kubeProvider kubernetes.KubeClientProviderWithCtx, loopParams retry.Params) ([]NodeIP, error)

func (*NodeIP) Name

func (i *NodeIP) Name() string

type NodeUserPresentsChecker

type NodeUserPresentsChecker func(node corev1.Node) bool

type NodeUserPresentsWaiter

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

func NewConvergerNodeUserExistsWaiter

func NewConvergerNodeUserExistsWaiter(kubeProvider kubernetes.KubeClientProviderWithCtx) *NodeUserPresentsWaiter

func NewNodeUserExistsWaiter

func NewNodeUserExistsWaiter(checker NodeUserPresentsChecker, kubeProvider kubernetes.KubeClientProviderWithCtx) *NodeUserPresentsWaiter

func (*NodeUserPresentsWaiter) WaitPresentOnNodes

func (w *NodeUserPresentsWaiter) WaitPresentOnNodes(ctx context.Context, nodeUser *v1.NodeUserCredentials) error

func (*NodeUserPresentsWaiter) WithParams

func (w *NodeUserPresentsWaiter) WithParams(params retry.Params) *NodeUserPresentsWaiter