executor

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

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

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

type Local struct {
}

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

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
}

type Temporal struct{}