wms

Documentation

Index

• type Step
  • func NewStep(id string, name string, command string, workingDirectory string, shell string) *Step
  • func (t *Step) GetArguments() []string
  • func (t *Step) GetCommand() string
  • func (t *Step) GetID() string
  • func (t *Step) GetName() string
  • func (t *Step) GetShell() string
  • func (t *Step) GetWorkingDirectory() string
  • func (t *Step) Trigger(start wms_types.StepTriggerLambda, progress wms_types.StepProgressLambda, ...) error
• type Workflow
  • func NewWorkflow(soloCtx *context_types.CliContext, serviceWorkingDirectory string, ...) *Workflow
  • func (t *Workflow) StepIterator() iter.Seq[wms_types.Step]
• type WorkflowExecTracker
  • func LoadWorkflowExecTracker(filePath string) (*WorkflowExecTracker, error)
  • func (t *WorkflowExecTracker) Clear(serviceName []string, workflowNames []commonworkflow.WorkflowName) error
  • func (t *WorkflowExecTracker) MarkExecuted(serviceName string, workflowName commonworkflow.WorkflowName) (bool, error)
  • func (t *WorkflowExecTracker) Save() error
• type WorkflowFactory
  • func NewWorkflowFactory() *WorkflowFactory
  • func (t *WorkflowFactory) Make(soloCtx *context_types.CliContext, orchestrator container_types.Orchestrator, ...) (wms_types.Workflow, error)
• type WorkflowGuard
  • func NewWorkflowGuard(soloCtx *context.CliContext, workflows []workflowcommon.WorkflowName, ...) *WorkflowGuard
  • func (t *WorkflowGuard) Publish(event events_types.Event)
  • func (t *WorkflowGuard) Wait(...) error
• type WorkflowGuardFactory
  • func NewWorkflowGuardFactory(soloCtx *context.CliContext) *WorkflowGuardFactory
  • func (t *WorkflowGuardFactory) Build(workflowNames []workflowcommon.WorkflowName, containerNames []string) wms_types.WorkflowGuard

Types

type Step

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

func NewStep

func NewStep(id string, name string, command string, workingDirectory string, shell string) *Step

func (*Step) GetArguments

func (t *Step) GetArguments() []string

func (*Step) GetCommand

func (t *Step) GetCommand() string

func (*Step) GetID

func (t *Step) GetID() string

func (*Step) GetName

func (t *Step) GetName() string

func (*Step) GetShell

func (t *Step) GetShell() string

func (*Step) GetWorkingDirectory

func (t *Step) GetWorkingDirectory() string

func (*Step) Trigger

func (t *Step) Trigger(
	start wms_types.StepTriggerLambda,
	progress wms_types.StepProgressLambda,
	complete wms_types.StepCompleteLambda,
) error

type Workflow

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

func NewWorkflow

func NewWorkflow(
	soloCtx *context_types.CliContext,
	serviceWorkingDirectory string,
	workflow compose_types.ServiceWorkflowConfig,
) *Workflow

func (*Workflow) StepIterator

func (t *Workflow) StepIterator() iter.Seq[wms_types.Step]

type WorkflowExecTracker

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

func LoadWorkflowExecTracker

func LoadWorkflowExecTracker(filePath string) (*WorkflowExecTracker, error)

func (*WorkflowExecTracker) Clear

func (t *WorkflowExecTracker) Clear(serviceName []string, workflowNames []commonworkflow.WorkflowName) error

func (*WorkflowExecTracker) MarkExecuted

func (t *WorkflowExecTracker) MarkExecuted(serviceName string, workflowName commonworkflow.WorkflowName) (bool, error)

func (*WorkflowExecTracker) Save

func (t *WorkflowExecTracker) Save() error

type WorkflowFactory

type WorkflowFactory struct{}

func NewWorkflowFactory

func NewWorkflowFactory() *WorkflowFactory

func (*WorkflowFactory) Make

func (t *WorkflowFactory) Make(
	soloCtx *context_types.CliContext,
	orchestrator container_types.Orchestrator,
	serviceName string,
	workflowName workflowcommon.WorkflowName,
) (wms_types.Workflow, error)

type WorkflowGuard

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

func NewWorkflowGuard

func NewWorkflowGuard(
	soloCtx *context.CliContext,
	workflows []workflowcommon.WorkflowName,
	containers []string,
) *WorkflowGuard

func (*WorkflowGuard) Publish

func (t *WorkflowGuard) Publish(event events_types.Event)

func (*WorkflowGuard) Wait

func (t *WorkflowGuard) Wait(callback func(container string, guardCallback func(name workflowcommon.WorkflowName) error) error) error

type WorkflowGuardFactory

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

func NewWorkflowGuardFactory

func NewWorkflowGuardFactory(soloCtx *context.CliContext) *WorkflowGuardFactory

func (*WorkflowGuardFactory) Build

func (t *WorkflowGuardFactory) Build(workflowNames []workflowcommon.WorkflowName, containerNames []string) wms_types.WorkflowGuard