executor

Feb 6, 2025

Changes in this version

+ func NewTemporalAgentWorker(client client.Client, broker broker.Broker) worker.Worker

type TemporalProxy

+ func NewTemporal(client client.Client, broker broker.Broker) *TemporalProxy

Jan 15, 2025

Changes in this version

+ type RemoteAgent struct

+ Instructions string

+ Model string

+ Name string

+ ParallelToolCalls bool

+ func (a *RemoteAgent) RenderInstructions(cv types.ContextVars) (string, error)

+ type RemoteRunCommand struct

+ Agent RemoteAgent

+ Checkpoint shorttermmemory.Checkpoint

+ ContextVariables types.ContextVars

+ ID uuid.UUID

+ MaxTurns int

+ Stream bool

+ StructuredOutput *provider.StructuredOutput

+ func RemoteRunCommandFromRunCommand(cmd RunCommand) RemoteRunCommand

+ type RemoteRunResult struct

+ Checkpoint shorttermmemory.Checkpoint

+ ContextVariables types.ContextVars

+ ID uuid.UUID

+ Result string

+ ToolCalls *messages.ToolCallMessage

+ Type RemoteRunResultType

+ type RemoteRunResultType uint8

+ const RemoteRunResultTypeCompletion

+ const RemoteRunResultTypeIncomplete

+ const RemoteRunResultTypeToolCall

type Temporal

+ func (t *Temporal) CallTool(ctx context.Context, tc remoteToolCallParams) (remoteToolCallResult, error)

+ func (t *Temporal) PublishError(ctx context.Context, params completionParams, errMsg string) error

+ func (t *Temporal) Run(ctx workflow.Context, cmd RemoteRunCommand) (string, error)

+ func (t *Temporal) RunChildWorkflow(ctx workflow.Context, cmd RemoteRunCommand) (string, error)

+ func (t *Temporal) RunCompletion(ctx context.Context, cmd completionParams) (RemoteRunResult, error)

+ type TemporalProxy struct

+ func (t *TemporalProxy) Run(ctx context.Context, cmd RunCommand, promise Promise) error

Jan 4, 2025

Changes in this version

type RunCommand

+ StructuredOutput *provider.StructuredOutput

+ func (r RunCommand) WithStructuredOutput(output *provider.StructuredOutput) RunCommand

Jan 4, 2025

Changes in this version

type RunCommand

+ func (r RunCommand) WithResponseSchema(schema *jsonschema.Schema) RunCommand

Jan 3, 2025

Changes in this version

+ func DefaultUnmarshal[T any]() func([]byte) (T, error)

+ func ToJSONSchema[T any]() *jsonschema.Schema

+ type CompletableFuture interface

+ func NewFuture[T any](unmarshal func([]byte) (T, error)) CompletableFuture[T]

+ type Future interface

+ Get func() (T, error)

+ type Promise interface

+ Complete func(string)

+ Error func(error)

type RunCommand

+ func (r *RunCommand) Validate() error

Jan 1, 2025

Changes in this version

+ type Executor interface

+ Run func(context.Context, RunCommand[T]) error

+ type Local struct

+ func NewLocal[T any](broker pubsub.Broker[T]) *Local[T]

+ func (l *Local[T]) Run(ctx context.Context, command RunCommand[T]) error

+ type RunCommand struct

+ Agent api.Owl

+ ContextVariables types.ContextVars

+ Hook events.Hook[T]

+ ID uuid.UUID

+ MaxTurns int

+ ResponseSchema *jsonschema.Schema

+ Stream bool

+ Thread *shorttermmemory.Aggregator

+ UnmarshalResponse func([]byte) (T, error)

+ func NewRunCommand[T any](agent api.Owl, thread *shorttermmemory.Aggregator, hook events.Hook[T]) (RunCommand[T], error)

+ func (r RunCommand[T]) WithContextVariables(contextVariables types.ContextVars) RunCommand[T]

+ func (r RunCommand[T]) WithMaxTurns(maxTurns int) RunCommand[T]

+ func (r RunCommand[T]) WithStream(stream bool) RunCommand[T]

+ type Temporal struct