executor

Documentation

Index

• Variables
• type Executor
• type Handler
• type MySQLDBDoneState
  • func (s MySQLDBDoneState) DebugString() string
• type MySQLInputState
  • func (s MySQLInputState) DebugString() string
  • func (s MySQLInputState) Kind() ResourceKind
• type MySQLInstanceReadyState
  • func (s MySQLInstanceReadyState) DebugString() string
• type PostgresDBDoneState
  • func (s PostgresDBDoneState) DebugString() string
• type PostgresInputState
  • func (s PostgresInputState) DebugString() string
  • func (s PostgresInputState) Kind() ResourceKind
• type PostgresInstanceReadyState
  • func (s PostgresInstanceReadyState) DebugString() string
• type ProvisionRunner
  • func (r *ProvisionRunner) Run(ctx context.Context) ([]State, error)
• type ResourceKind
• type RunnerStage
• type State

Variables

var AllResources []ResourceKind

Types

type Executor

type Executor interface {
	// Stage returns the stage that the executor belongs to.
	// Prepare prepares the executor for execution.
	Prepare(ctx context.Context, input State) error
	// Execute executes the executor, returning the next states.
	Execute(ctx context.Context) ([]State, error)
}

type Handler

type Handler struct {
	Executor Executor
	Handles  []State
}

type MySQLDBDoneState

type MySQLDBDoneState struct {
	MySQLInstanceReadyState
	Connector schema.DatabaseConnector
}

func (MySQLDBDoneState) DebugString

func (s MySQLDBDoneState) DebugString() string

type MySQLInputState

type MySQLInputState struct {
	ResourceID string
	Cluster    string
	Module     string
}

func (MySQLInputState) DebugString

func (s MySQLInputState) DebugString() string

func (MySQLInputState) Kind

func (s MySQLInputState) Kind() ResourceKind

type MySQLInstanceReadyState

type MySQLInstanceReadyState struct {
	MySQLInputState

	MasterUserSecretARN string
	WriteEndpoint       string
	ReadEndpoint        string
}

func (MySQLInstanceReadyState) DebugString

func (s MySQLInstanceReadyState) DebugString() string

type PostgresDBDoneState

type PostgresDBDoneState struct {
	PostgresInstanceReadyState
	Connector schema.DatabaseConnector
}

func (PostgresDBDoneState) DebugString

func (s PostgresDBDoneState) DebugString() string

type PostgresInputState

type PostgresInputState struct {
	ResourceID string
	Cluster    string
	Module     string
}

func (PostgresInputState) DebugString

func (s PostgresInputState) DebugString() string

func (PostgresInputState) Kind

func (s PostgresInputState) Kind() ResourceKind

type PostgresInstanceReadyState

type PostgresInstanceReadyState struct {
	PostgresInputState

	MasterUserSecretARN string
	WriteEndpoint       string
	ReadEndpoint        string
}

func (PostgresInstanceReadyState) DebugString

func (s PostgresInstanceReadyState) DebugString() string

type ProvisionRunner

type ProvisionRunner struct {
	CurrentState []State
	Stages       []RunnerStage
	// contains filtered or unexported fields
}

func (*ProvisionRunner) Run

func (r *ProvisionRunner) Run(ctx context.Context) ([]State, error)

type ResourceKind

type ResourceKind string

const (
	ResourceKindPostgres ResourceKind = "postgres"
	ResourceKindMySQL    ResourceKind = "mysql"
)

type RunnerStage

type RunnerStage struct {
	Name      string
	Executors []Handler
}

type State

type State interface {
	DebugString() string
}

State of a single resource in execution.