converge

Documentation

Index

• type AutoConverger
  • func NewAutoConverger(runner *runner, listenAddress string, interval time.Duration) *AutoConverger
  • func (c *AutoConverger) Start(ctx *convergectx.Context) error
• type ConvergeResult
• type ConvergeStatus
• type Converger
  • func NewConverger(params *Params) *Converger
  • func (c *Converger) AutoConverge() error
  • func (c *Converger) Converge(ctx context.Context) (*ConvergeResult, error)
  • func (c *Converger) GetLastState() phases.DhctlState
• type Params

Types

type AutoConverger

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

func NewAutoConverger

func NewAutoConverger(runner *runner, listenAddress string, interval time.Duration) *AutoConverger

func (*AutoConverger) Start

func (c *AutoConverger) Start(ctx *convergectx.Context) error

type ConvergeResult

type ConvergeResult struct {
	Status      ConvergeStatus     `json:"status"`
	CheckResult *check.CheckResult `json:"check_result,omitempty"`
}

type ConvergeStatus

type ConvergeStatus string

const (
	ConvergeStatusInSync                          ConvergeStatus = "InSync"
	ConvergeStatusConverged                       ConvergeStatus = "Converged"
	ConvergeStatusNeedApproveForDestructiveChange ConvergeStatus = "NeedApproveForDestructiveChange"
)

type Converger

type Converger struct {
	*Params
	PhasedExecutionContext phases.DefaultPhasedExecutionContext
	// contains filtered or unexported fields
}

func NewConverger

func NewConverger(params *Params) *Converger

func (*Converger) AutoConverge

func (c *Converger) AutoConverge() error

func (*Converger) Converge

func (c *Converger) Converge(ctx context.Context) (*ConvergeResult, error)

func (*Converger) GetLastState

func (c *Converger) GetLastState() phases.DhctlState

type Params

type Params struct {
	SSHClient  *ssh.Client
	KubeClient *client.KubernetesClient // optional

	OnPhaseFunc            phases.DefaultOnPhaseFunc
	AutoDismissDestructive bool
	AutoApprove            bool

	*client.KubernetesInitParams

	CommanderMode bool
	CommanderUUID uuid.UUID
	*commander.CommanderModeParams
	Checker                    *check.Checker
	OnCheckResult              func(*check.CheckResult) error
	ApproveDestructiveChangeID string

	TerraformContext *terraform.TerraformContext
}

TODO(remove-global-app): Support all needed parameters in Params, remove usage of app.*