workflow

Documentation

Index

• type CloudConfig
• type CloudProvider
• type NetworkResult
  • func SetupNetworkActivity(ctx context.Context, project *ProjectResult) (*NetworkResult, error)
• type NodeResult
  • func ProvisionNodeActivity(ctx context.Context, project *ProjectResult) (*NodeResult, error)
  • func ProvisionNodeWorkflow(ctx workflow.Context, project *ProjectResult) (*NodeResult, error)
• type ProjectResult
  • func CloudProvisionWorkflow(ctx workflow.Context, cfg CloudConfig) (*ProjectResult, error)
  • func CreateProjectActivity(ctx context.Context, config CloudConfig) (*ProjectResult, error)
• type Resource

Types

type CloudConfig

type CloudConfig struct {
	Provider CloudProvider
	Region   string
	Subnet   string
	VMCount  int
}

type CloudProvider

type CloudProvider string

const (
	CloudProviderAWS   CloudProvider = "AWS"
	CloudProviderAzure CloudProvider = "Azure"
)

type NetworkResult

type NetworkResult struct {
	ID     string
	Region string
	Subnet *net.IPNet
}

func SetupNetworkActivity

func SetupNetworkActivity(ctx context.Context, project *ProjectResult) (*NetworkResult, error)

type NodeResult

type NodeResult struct {
	ID      string
	Name    string
	Address string
	Port    int32
}

func ProvisionNodeActivity

func ProvisionNodeActivity(ctx context.Context, project *ProjectResult) (*NodeResult, error)

func ProvisionNodeWorkflow

func ProvisionNodeWorkflow(ctx workflow.Context, project *ProjectResult) (*NodeResult, error)

Run as a child worker

type ProjectResult

type ProjectResult struct {
	CloudConfig

	ID string

	Network *NetworkResult
	Nodes   []*NodeResult
}

func CloudProvisionWorkflow

func CloudProvisionWorkflow(ctx workflow.Context, cfg CloudConfig) (*ProjectResult, error)

func CreateProjectActivity

func CreateProjectActivity(ctx context.Context, config CloudConfig) (*ProjectResult, error)

type Resource

type Resource struct {
	ID string
}