orchestrator

Documentation

Index

• type EventSDK
• type ExecutionSDK
• type Orchestrator
  • func New(event EventSDK, execution ExecutionSDK, process ProcessSDK, runner RunnerSDK) *Orchestrator
  • func (s *Orchestrator) Start() error
• type ProcessSDK
• type RunnerSDK

Types

type EventSDK

type EventSDK interface {
	GetStream(f *eventsdk.Filter) *eventsdk.Listener
}

EventSDK event interface needed for the orchestrator

type ExecutionSDK

type ExecutionSDK interface {
	Stream(ctx context.Context, req *api.StreamExecutionRequest) (chan *execution.Execution, chan error, error)
	Get(hash hash.Hash) (*execution.Execution, error)
	Create(req *api.CreateExecutionRequest) (*execution.Execution, error)
}

ExecutionSDK execution interface needed for the orchestrator

type Orchestrator

type Orchestrator struct {
	ErrC chan error
	// contains filtered or unexported fields
}

Orchestrator manages the executions based on the definition of the processes

func New

func New(event EventSDK, execution ExecutionSDK, process ProcessSDK, runner RunnerSDK) *Orchestrator

New creates a new Process instance

func (*Orchestrator) Start

func (s *Orchestrator) Start() error

Start the process engine

type ProcessSDK

type ProcessSDK interface {
	List() ([]*process.Process, error)
}

ProcessSDK process interface needed for the orchestrator

type RunnerSDK

type RunnerSDK interface {
	List(f *runnersdk.Filter) ([]*runner.Runner, error)
}

RunnerSDK is the interface of the runner sdk needed for the orchestrator