orchestrator

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

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)
}

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

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

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