executor

type ErrArgMissing struct {
	ArgName string
}

type ErrInvalidArgumentType struct {
	Name     string
	Expected string
	Received string
}

type ErrInvalidParams struct {
	ExecutorName  string
	MissingParams []string
}

type ErrOperatorNotFound struct {
	ExecutorName string
	OperatorName string
}

type Executor interface {
	Execute(ctx context.Context, params *ExecutorParams) *ExecutorResult
}

type ExecutorParamOption func(*ExecutorParams)

type ExecutorParams struct {
	Operator    string
	Transport   transport.Transport
	VectorStore vector.Store
	Args        map[string]any

	Children []*WorkflowNode
	Routes   []*WorkflowRoute
	Branches []*WorkflowBranch
	// contains filtered or unexported fields
}

type ExecutorResult struct {
	Name     string
	Operator string
	Err      error
	Values   map[string]any
}

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

type WorkflowBranch struct {
	Name  string
	Nodes []*WorkflowNode
}

type WorkflowNode struct {
	Executor Executor
	Operator string
	NodeType string
	Args     map[string]any

	Children []*WorkflowNode
	Routes   []*WorkflowRoute
	Branches []*WorkflowBranch
}

type WorkflowRoute struct {
	Key         string
	Description string
	Nodes       []*WorkflowNode
}