workflow

Documentation

Index

• func NewService(nodeRepo repository.Node, excRepo repository.Execution, ...) service.Workflow
• type Service
  • func (s *Service) GetExecution(ctx context.Context, id workflow.ExecutionIdentifier) (*workflow.Execution, error)
  • func (s *Service) LaunchDeprovisionNodeWorkflow(ctx context.Context, id node.Identifier) (workflow.ExecutionIdentifier, error)
  • func (s *Service) LaunchProvisionNodeWorkflow(ctx context.Context, prov *provider.Provider, location provider.Location, ...) (workflow.ExecutionIdentifier, error)

Functions

func NewService

func NewService(nodeRepo repository.Node, excRepo repository.Execution, tails map[string]gateway.Tailnet, platformGws map[string]gateway.Platform) service.Workflow

Types

type Service

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

func (*Service) GetExecution

func (s *Service) GetExecution(ctx context.Context, id workflow.ExecutionIdentifier) (*workflow.Execution, error)

func (*Service) LaunchDeprovisionNodeWorkflow

func (s *Service) LaunchDeprovisionNodeWorkflow(ctx context.Context, id node.Identifier) (workflow.ExecutionIdentifier, error)

func (*Service) LaunchProvisionNodeWorkflow

func (s *Service) LaunchProvisionNodeWorkflow(ctx context.Context, prov *provider.Provider, location provider.Location, tn *tailnet.Tailnet, ephemeral bool) (workflow.ExecutionIdentifier, error)