runner

Documentation

Index

• Variables
• type CacheOptions
• type Event
• type EventType
• type Monitor
• type MonitorFactory
• type OpenAIOptions
• type Options
• type Runner
  • func New(opts ...Options) (*Runner, error)
  • func (r *Runner) Run(ctx context.Context, prg types.Program, env []string, input string) (output string, err error)

Variables

var (
	EventTypeCallStart    = EventType("callStart")
	EventTypeCallContinue = EventType("callContinue")
	EventTypeCallSubCalls = EventType("callSubCalls")
	EventTypeCallProgress = EventType("callProgress")
	EventTypeChat         = EventType("callChat")
	EventTypeCallFinish   = EventType("callFinish")
)

Types

type CacheOptions

type CacheOptions cache.Options

type Event

type Event struct {
	Time               time.Time              `json:"time,omitempty"`
	CallContext        *engine.Context        `json:"callContext,omitempty"`
	ToolSubCalls       map[string]engine.Call `json:"toolSubCalls,omitempty"`
	ToolResults        int                    `json:"toolResults,omitempty"`
	Type               EventType              `json:"type,omitempty"`
	ChatCompletionID   string                 `json:"chatCompletionId,omitempty"`
	ChatRequest        any                    `json:"chatRequest,omitempty"`
	ChatResponse       any                    `json:"chatResponse,omitempty"`
	ChatResponseCached bool                   `json:"chatResponseCached,omitempty"`
	Content            string                 `json:"content,omitempty"`
}

type EventType

type EventType string

type Monitor

type Monitor interface {
	Event(event Event)
	Stop(output string, err error)
}

type MonitorFactory

type MonitorFactory interface {
	Start(ctx context.Context, prg *types.Program, env []string, input string) (Monitor, error)
}

type OpenAIOptions

type OpenAIOptions openai.Options

type Options

type Options struct {
	CacheOptions
	OpenAIOptions
	MonitorFactory MonitorFactory `usage:"-"`
}

type Runner

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

func New

func New(opts ...Options) (*Runner, error)

func (*Runner) Run

func (r *Runner) Run(ctx context.Context, prg types.Program, env []string, input string) (output string, err error)