orchestrator

package

v0.1.0 Latest Latest Go to latest Published: Aug 5, 2025 License: MIT Imports: 10 Imported by: 0

Details

Package orchestrator provides the core orchestration engine

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	Runtime      runtime.Runtime
	MessageQueue messagequeue.MessageQueue
	StateManager state.StateManager
}

Config holds orchestrator configuration

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

Orchestrator manages agent lifecycle and workflow execution

func New(config Config) (*Orchestrator, error)

New creates a new orchestrator instance

func (o *Orchestrator) CreateWorkflow(ctx context.Context, workflow *types.Workflow) error

CreateWorkflow creates a new workflow

func (o *Orchestrator) GetWorkflow(ctx context.Context, workflowID string) (*types.Workflow, error)

GetWorkflow returns workflow information

func (o *Orchestrator) ListWorkflows(ctx context.Context, filter map[string]string) ([]*types.Workflow, error)

ListWorkflows returns all workflows

func (o *Orchestrator) Start() error

Start starts the orchestrator

func (o *Orchestrator) StartWorkflow(ctx context.Context, workflowID string) error

StartWorkflow starts executing a workflow

func (o *Orchestrator) Stop() error

Stop stops the orchestrator

func (o *Orchestrator) StopWorkflow(ctx context.Context, workflowID string) error

StopWorkflow stops a running workflow