executor

Documentation

Index

• func DefaultUnmarshal[T any]() func([]byte) (T, error)
• func ToJSONSchema[T any]() *jsonschema.Schema
• type CompletableFuture
  • func NewFuture[T any](unmarshal func([]byte) (T, error)) CompletableFuture[T]
• type Executor
• type Future
• type Local
  • func NewLocal() *Local
  • func (l *Local) Run(ctx context.Context, command RunCommand, promise Promise) error
• type Promise
• type RunCommand
  • func NewRunCommand(agent api.Owl, thread *shorttermmemory.Aggregator, hook events.Hook) (RunCommand, error)
  • func (r *RunCommand) ID() uuid.UUID
  • func (r *RunCommand) Validate() error
  • func (r RunCommand) WithContextVariables(contextVariables types.ContextVars) RunCommand
  • func (r RunCommand) WithMaxTurns(maxTurns int) RunCommand
  • func (r RunCommand) WithStream(stream bool) RunCommand
• type Temporal

Functions

func DefaultUnmarshal

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

func ToJSONSchema

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

Types

type CompletableFuture

type CompletableFuture[T any] interface {
	Future[T]
	Promise
}

func NewFuture

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

type Executor

type Executor interface {
	Run(context.Context, RunCommand, Promise) error
	// contains filtered or unexported methods
}

type Future

type Future[T any] interface {
	Get() (T, error)
}

type Local

type Local struct {
}

func NewLocal

func NewLocal() *Local

func (*Local) Run

func (l *Local) Run(ctx context.Context, command RunCommand, promise Promise) error

type Promise

type Promise interface {
	Complete(string)
	Error(error)
}

type RunCommand

type RunCommand struct {
	Agent            api.Owl
	Thread           *shorttermmemory.Aggregator
	ResponseSchema   *jsonschema.Schema
	Stream           bool
	MaxTurns         int
	ContextVariables types.ContextVars
	Hook             events.Hook
	// contains filtered or unexported fields
}

func NewRunCommand

func NewRunCommand(agent api.Owl, thread *shorttermmemory.Aggregator, hook events.Hook) (RunCommand, error)

func (*RunCommand) ID

func (r *RunCommand) ID() uuid.UUID

func (*RunCommand) Validate

func (r *RunCommand) Validate() error

func (RunCommand) WithContextVariables

func (r RunCommand) WithContextVariables(contextVariables types.ContextVars) RunCommand

func (RunCommand) WithMaxTurns

func (r RunCommand) WithMaxTurns(maxTurns int) RunCommand

func (RunCommand) WithStream

func (r RunCommand) WithStream(stream bool) RunCommand

type Temporal

type Temporal struct{}