controlplane

Documentation

Index

• Variables
• type Checker
  • func NewChecker(nodeToHostForChecks map[string]string, checkers []hook.NodeChecker, ...) *Checker
  • func (c *Checker) IsAllNodesReady(ctx context.Context) error
• type ConfirmFunc
• type HookForDestroyPipeline
  • func NewHookForDestroyPipeline(getter kubernetes.KubeClientProvider, nodeToDestroy string, commanderMode bool) *HookForDestroyPipeline
  • func (h *HookForDestroyPipeline) AfterAction(_ context.Context, runner terraform.RunnerInterface) error
  • func (h *HookForDestroyPipeline) BeforeAction(ctx context.Context, runner terraform.RunnerInterface) (bool, error)
  • func (h *HookForDestroyPipeline) IsReady() error
• type HookForUpdatePipeline
  • func NewHookForUpdatePipeline(kubeGetter kubernetes.KubeClientProvider, ...) *HookForUpdatePipeline
  • func (h *HookForUpdatePipeline) AfterAction(ctx context.Context, runner terraform.RunnerInterface) error
  • func (h *HookForUpdatePipeline) BeforeAction(ctx context.Context, runner terraform.RunnerInterface) (bool, error)
  • func (h *HookForUpdatePipeline) IsReady() error
  • func (h *HookForUpdatePipeline) WithConfirm(confirm func(msg string) bool) *HookForUpdatePipeline
  • func (h *HookForUpdatePipeline) WithNodeToConverge(nodeToConverge string) *HookForUpdatePipeline
  • func (h *HookForUpdatePipeline) WithSourceCommandName(name string) *HookForUpdatePipeline
• type KubeProxyChecker
  • func NewKubeProxyChecker() *KubeProxyChecker
  • func (c *KubeProxyChecker) IsReady(ctx context.Context, nodeName string) (bool, error)
  • func (c *KubeProxyChecker) Name() string
  • func (c *KubeProxyChecker) WithAskPassword(f bool) *KubeProxyChecker
  • func (c *KubeProxyChecker) WithClusterUUID(uuid string) *KubeProxyChecker
  • func (c *KubeProxyChecker) WithExternalIPs(ips map[string]string) *KubeProxyChecker
  • func (c *KubeProxyChecker) WithInitParams(p *client.KubernetesInitParams) *KubeProxyChecker
  • func (c *KubeProxyChecker) WithLogResult(f bool) *KubeProxyChecker
  • func (c *KubeProxyChecker) WithSSHCredentials(input session.Input, privateKeys ...session.AgentPrivateKey) *KubeProxyChecker
  • func (c *KubeProxyChecker) WithStopProxy(f bool) *KubeProxyChecker
• type ManagerReadinessChecker
  • func NewManagerReadinessChecker(getter kubernetes.KubeClientProvider) *ManagerReadinessChecker
  • func (c *ManagerReadinessChecker) IsReady(ctx context.Context, nodeName string) (bool, error)
  • func (c *ManagerReadinessChecker) IsReadyAll(ctx context.Context) error
  • func (c *ManagerReadinessChecker) Name() string

Variables

var DefaultConfirm = ConfirmFunc(func(msg string) bool {
	return true
})

var ErrControlPlaneIsNotReady = errors.New("Control plane is not ready\n")

var ErrSingleMasterClusterTerraformPlanHasDestructiveChanges = fmt.Errorf("single master cluster terraform plan has destructive changes")

Types

type Checker

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

func NewChecker

func NewChecker(nodeToHostForChecks map[string]string, checkers []hook.NodeChecker, sourceCommandName string, confirm ConfirmFunc) *Checker

func (*Checker) IsAllNodesReady

func (c *Checker) IsAllNodesReady(ctx context.Context) error

type ConfirmFunc

type ConfirmFunc func(msg string) bool

type HookForDestroyPipeline

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

func NewHookForDestroyPipeline

func NewHookForDestroyPipeline(getter kubernetes.KubeClientProvider, nodeToDestroy string, commanderMode bool) *HookForDestroyPipeline

func (*HookForDestroyPipeline) AfterAction

func (h *HookForDestroyPipeline) AfterAction(_ context.Context, runner terraform.RunnerInterface) error

func (*HookForDestroyPipeline) BeforeAction

func (h *HookForDestroyPipeline) BeforeAction(ctx context.Context, runner terraform.RunnerInterface) (bool, error)

func (*HookForDestroyPipeline) IsReady

func (h *HookForDestroyPipeline) IsReady() error

type HookForUpdatePipeline

type HookForUpdatePipeline struct {
	*Checker
	// contains filtered or unexported fields
}

func NewHookForUpdatePipeline

func NewHookForUpdatePipeline(
	kubeGetter kubernetes.KubeClientProvider,
	nodeToHostForChecks map[string]string,
	clusterUUID string,
	commanderMode bool,
) *HookForUpdatePipeline

func (*HookForUpdatePipeline) AfterAction

func (h *HookForUpdatePipeline) AfterAction(ctx context.Context, runner terraform.RunnerInterface) error

func (*HookForUpdatePipeline) BeforeAction

func (h *HookForUpdatePipeline) BeforeAction(ctx context.Context, runner terraform.RunnerInterface) (bool, error)

func (*HookForUpdatePipeline) IsReady

func (h *HookForUpdatePipeline) IsReady() error

func (*HookForUpdatePipeline) WithConfirm

func (h *HookForUpdatePipeline) WithConfirm(confirm func(msg string) bool) *HookForUpdatePipeline

func (*HookForUpdatePipeline) WithNodeToConverge

func (h *HookForUpdatePipeline) WithNodeToConverge(nodeToConverge string) *HookForUpdatePipeline

func (*HookForUpdatePipeline) WithSourceCommandName

func (h *HookForUpdatePipeline) WithSourceCommandName(name string) *HookForUpdatePipeline

type KubeProxyChecker

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

func NewKubeProxyChecker

func NewKubeProxyChecker() *KubeProxyChecker

func (*KubeProxyChecker) IsReady

func (c *KubeProxyChecker) IsReady(ctx context.Context, nodeName string) (bool, error)

func (*KubeProxyChecker) Name

func (c *KubeProxyChecker) Name() string

func (*KubeProxyChecker) WithAskPassword

func (c *KubeProxyChecker) WithAskPassword(f bool) *KubeProxyChecker

func (*KubeProxyChecker) WithClusterUUID

func (c *KubeProxyChecker) WithClusterUUID(uuid string) *KubeProxyChecker

func (*KubeProxyChecker) WithExternalIPs

func (c *KubeProxyChecker) WithExternalIPs(ips map[string]string) *KubeProxyChecker

func (*KubeProxyChecker) WithInitParams

func (c *KubeProxyChecker) WithInitParams(p *client.KubernetesInitParams) *KubeProxyChecker

func (*KubeProxyChecker) WithLogResult

func (c *KubeProxyChecker) WithLogResult(f bool) *KubeProxyChecker

func (*KubeProxyChecker) WithSSHCredentials

func (c *KubeProxyChecker) WithSSHCredentials(input session.Input, privateKeys ...session.AgentPrivateKey) *KubeProxyChecker

func (*KubeProxyChecker) WithStopProxy

func (c *KubeProxyChecker) WithStopProxy(f bool) *KubeProxyChecker

type ManagerReadinessChecker

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

func NewManagerReadinessChecker

func NewManagerReadinessChecker(getter kubernetes.KubeClientProvider) *ManagerReadinessChecker

func (*ManagerReadinessChecker) IsReady

func (c *ManagerReadinessChecker) IsReady(ctx context.Context, nodeName string) (bool, error)

func (*ManagerReadinessChecker) IsReadyAll

func (c *ManagerReadinessChecker) IsReadyAll(ctx context.Context) error

func (*ManagerReadinessChecker) Name

func (c *ManagerReadinessChecker) Name() string