executor

Dec 31, 2024

Changes in this version

type Local

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

Dec 31, 2024

Changes in this version

+ type Executor interface

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

+ type Local struct

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

+ type RunCommand struct

+ Agent bubo.Agent

+ ContextVariables types.ContextVars

+ Hook pubsub.Hook

+ ID uuid.UUID

+ MaxTurns int

+ ResponseSchema *jsonschema.Schema

+ Stream bool

+ Thread *runstate.Aggregator

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

+ func NewRunCommand[T any](agent bubo.Agent, thread *runstate.Aggregator, hook pubsub.Hook) (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