orchestrator

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

type ExecutionSDK interface {
	GetStream(f *executionsdk.Filter) *executionsdk.Listener
	Get(hash hash.Hash) (*execution.Execution, error)
	Execute(processHash, instanceHash, eventHash, parentHash hash.Hash, stepID string, taskKey string, inputData *types.Struct, tags []string) (executionHash hash.Hash, err error)
}

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

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