sdk

Mar 10, 2026

Changes in this version

type EvaluateOpts

+ RuntimeConfigPath string

type Option

+ func WithRuntimeConfig(path string) Option

Mar 9, 2026

Changes in this version

+ func Evaluate(ctx context.Context, opts EvaluateOpts) ([]evals.EvalResult, error)

+ type A2AAgentBuilder struct

+ func NewA2AAgent(url string) *A2AAgentBuilder

+ func (b *A2AAgentBuilder) Build() *tools.A2AConfig

+ func (b *A2AAgentBuilder) WithAuth(scheme, token string) *A2AAgentBuilder

+ func (b *A2AAgentBuilder) WithAuthFromEnv(scheme, envVar string) *A2AAgentBuilder

+ func (b *A2AAgentBuilder) WithHeader(key, value string) *A2AAgentBuilder

+ func (b *A2AAgentBuilder) WithHeaderFromEnv(headerEnv string) *A2AAgentBuilder

+ func (b *A2AAgentBuilder) WithRetryPolicy(maxRetries, initialDelayMs, maxDelayMs int) *A2AAgentBuilder

+ func (b *A2AAgentBuilder) WithSkillFilter(filter *tools.A2ASkillFilter) *A2AAgentBuilder

+ func (b *A2AAgentBuilder) WithTimeout(ms int) *A2AAgentBuilder

+ type EvaluateOpts struct

+ EvalDefs []evals.EvalDef

+ EventBus *events.EventBus

+ JudgeProvider any

+ JudgeTargets map[string]any

+ Logger *slog.Logger

+ Messages []types.Message

+ PackData []byte

+ PackPath string

+ PromptName string

+ Registry *evals.EvalTypeRegistry

+ SessionID string

+ SkipSchemaValidation bool

+ Timeout time.Duration

+ TracerProvider trace.TracerProvider

+ Trigger evals.EvalTrigger

+ TurnIndex int

type MCPServerBuilder

+ func (b *MCPServerBuilder) WithTimeout(ms int) *MCPServerBuilder

+ func (b *MCPServerBuilder) WithToolFilter(filter *mcp.ToolFilter) *MCPServerBuilder

+ func (b *MCPServerBuilder) WithWorkingDir(dir string) *MCPServerBuilder

type Option

+ func WithA2AAgent(builder *A2AAgentBuilder) Option

Mar 8, 2026

Changes in this version

+ const DefaultMaxConcurrentEvals

+ var ErrShutdownManagerClosed = errors.New("shutdown manager is closed; cannot register new conversations")

+ func GracefulShutdown(mgr *ShutdownManager, timeout time.Duration)

type Conversation

+ func (c *Conversation) SendToolResultMultimodal(_ context.Context, callID string, parts []types.ContentPart) error

type Option

+ func WithMaxConcurrentEvals(n int) Option

+ func WithShutdownManager(mgr *ShutdownManager) Option

+ type ShutdownManager struct

+ func NewShutdownManager() *ShutdownManager

+ func (m *ShutdownManager) Deregister(id string)

+ func (m *ShutdownManager) Len() int

+ func (m *ShutdownManager) Register(id string, conv io.Closer) error

+ func (m *ShutdownManager) Shutdown(ctx context.Context) error

Mar 4, 2026

Changes in this version

type Option

+ func WithEvalRunner(r *evals.EvalRunner) Option

+ func WithEvalsDisabled() Option

Mar 4, 2026

Changes in this version

type ChunkType

+ const ChunkClientTool

+ type ClientToolHandler func(ctx context.Context, req ClientToolRequest) (any, error)

+ type ClientToolRequest struct

+ Args map[string]any

+ CallID string

+ Categories []string

+ ConsentMsg string

+ Descriptor *tools.ToolDescriptor

+ ToolName string

+ type ClientToolRequestEvent struct

+ Args map[string]any

+ CallID string

+ Categories []string

+ ConsentMsg string

+ ToolName string

type Conversation

+ func (c *Conversation) OnClientTool(name string, handler ClientToolHandler)

+ func (c *Conversation) OnClientTools(handlers map[string]ClientToolHandler)

+ func (c *Conversation) OnStreamEvent(handler StreamEventHandler)

+ func (c *Conversation) RejectClientTool(_ context.Context, callID, reason string)

+ func (c *Conversation) Resume(ctx context.Context) (*Response, error)

+ func (c *Conversation) ResumeStream(ctx context.Context) <-chan StreamChunk

+ func (c *Conversation) SendToolResult(_ context.Context, callID string, result any) error

+ func (c *Conversation) StreamWithCallback(ctx context.Context, message any, opts ...SendOption) (*Response, error)

type Option

+ func WithRecording(cfg *RecordingConfig) Option

+ type PendingClientTool struct

+ Args map[string]any

+ CallID string

+ Categories []string

+ ConsentMsg string

+ ToolName string

+ type RecordingConfig struct

+ IncludeAudio bool

+ IncludeImages bool

+ IncludeVideo bool

+ func DefaultRecordingConfig() RecordingConfig

type Response

+ func (r *Response) ClientTools() []PendingClientTool

+ func (r *Response) HasPendingClientTools() bool

+ type ResponseTestOption func(*Response)

+ func WithClientToolsForTest(tools []PendingClientTool) ResponseTestOption

type StreamChunk

+ ClientTool *PendingClientTool

+ type StreamDoneEvent struct

+ Response *Response

+ type StreamEventHandler func(event StreamEvent)

+ type TextDeltaEvent struct

+ Delta string

Mar 3, 2026

Changes in this version

type Option

+ func WithExecutionTimeout(d time.Duration) Option

Mar 1, 2026

Changes in this version

type Option

+ func WithLogger(l *slog.Logger) Option

Feb 26, 2026

Changes in this version

type A2AServerOption

+ func WithA2AConversationTTL(d time.Duration) A2AServerOption

+ func WithA2AIdleTimeout(d time.Duration) A2AServerOption

+ func WithA2AMaxBodySize(n int64) A2AServerOption

+ func WithA2AReadTimeout(d time.Duration) A2AServerOption

+ func WithA2ATaskTTL(d time.Duration) A2AServerOption

+ func WithA2AWriteTimeout(d time.Duration) A2AServerOption

type Option

+ func WithProviderHook(h hooks.ProviderHook) Option

+ func WithSessionHook(h hooks.SessionHook) Option

+ func WithToolHook(h hooks.ToolHook) Option

+ func WithTracerProvider(tp trace.TracerProvider) Option

+ type PackTemplate struct

+ func LoadTemplate(packPath string, opts ...Option) (*PackTemplate, error)

+ func (t *PackTemplate) Open(promptName string, opts ...Option) (*Conversation, error)

+ func (t *PackTemplate) OpenDuplex(promptName string, opts ...Option) (*Conversation, error)

+ func (t *PackTemplate) Pack() *pack.Pack

type Response

+ func NewResponseForTest(text string, toolCalls []types.MessageToolCall) *Response

Feb 23, 2026

Changes in this version

+ var ErrNoWorkflow = errors.New("pack has no workflow section")

+ var ErrWorkflowClosed = errors.New("workflow conversation is closed")

+ var ErrWorkflowTerminal = errors.New("workflow is in terminal state")

+ type A2ACapability struct

+ func NewA2ACapability() *A2ACapability

+ func (c *A2ACapability) Close() error

+ func (c *A2ACapability) Init(ctx CapabilityContext) error

+ func (c *A2ACapability) Name() string

+ func (c *A2ACapability) RegisterTools(registry *tools.Registry)

+ type AgentToolResolver struct

+ func NewAgentToolResolver(pack *prompt.Pack) *AgentToolResolver

+ func (r *AgentToolResolver) IsAgentTool(toolName string) bool

+ func (r *AgentToolResolver) MemberNames() []string

+ func (r *AgentToolResolver) ResolveAgentTools(toolNames []string) []*tools.ToolDescriptor

+ func (r *AgentToolResolver) SetEndpointResolver(er EndpointResolver)

+ type Capability interface

+ Close func() error

+ Init func(ctx CapabilityContext) error

+ Name func() string

+ RegisterTools func(registry *tools.Registry)

+ type CapabilityContext struct

+ Pack *pack.Pack

+ PromptName string

+ type EndpointResolver interface

+ Resolve func(agentName string) string

+ type LocalAgentExecutor struct

+ func NewLocalAgentExecutor(members map[string]*Conversation) *LocalAgentExecutor

+ func (e *LocalAgentExecutor) Execute(descriptor *tools.ToolDescriptor, args json.RawMessage) (json.RawMessage, error)

+ func (e *LocalAgentExecutor) Name() string

+ type MapEndpointResolver struct

+ Endpoints map[string]string

+ func (r *MapEndpointResolver) Resolve(agentName string) string

+ type MultiAgentSession struct

+ func OpenMultiAgent(packPath string, opts ...Option) (*MultiAgentSession, error)

+ func (s *MultiAgentSession) Close() error

+ func (s *MultiAgentSession) Entry() *Conversation

+ func (s *MultiAgentSession) Members() map[string]*Conversation

+ func (s *MultiAgentSession) Send(ctx context.Context, message any, opts ...SendOption) (*Response, error)

type Option

+ func WithAgentEndpoints(resolver EndpointResolver) Option

+ func WithAutoSummarize(provider providers.Provider, threshold, batchSize int) Option

+ func WithCapability(capability Capability) Option

+ func WithContextCarryForward() Option

+ func WithContextRetrieval(embeddingProvider providers.EmbeddingProvider, topK int) Option

+ func WithContextWindow(recentMessages int) Option

+ func WithMaxActiveSkillsOption(n int) Option

+ func WithSkillSelectorOption(s skills.SkillSelector) Option

+ func WithSkillsDir(dir string) Option

+ type SkillsCapability struct

+ func NewSkillsCapability(sources []skills.SkillSource, opts ...SkillsOption) *SkillsCapability

+ func (c *SkillsCapability) Close() error

+ func (c *SkillsCapability) Executor() *skills.Executor

+ func (c *SkillsCapability) Init(ctx CapabilityContext) error

+ func (c *SkillsCapability) Name() string

+ func (c *SkillsCapability) RegisterTools(registry *tools.Registry)

+ type SkillsOption func(*SkillsCapability)

+ func WithMaxActiveSkills(n int) SkillsOption

+ func WithSkillSelector(s skills.SkillSelector) SkillsOption

+ type StatefulCapability interface

+ RefreshTools func(registry *tools.Registry)

+ type StaticEndpointResolver struct

+ BaseURL string

+ func (r *StaticEndpointResolver) Resolve(_ string) string

+ type WorkflowCapability struct

+ func NewWorkflowCapability() *WorkflowCapability

+ func (w *WorkflowCapability) Close() error

+ func (w *WorkflowCapability) Init(ctx CapabilityContext) error

+ func (w *WorkflowCapability) Name() string

+ func (w *WorkflowCapability) RegisterTools(_ *tools.Registry)

+ func (w *WorkflowCapability) RegisterToolsForState(registry *tools.Registry, state *workflow.State)

+ type WorkflowConversation struct

+ func OpenWorkflow(packPath string, opts ...Option) (*WorkflowConversation, error)

+ func ResumeWorkflow(workflowID, packPath string, opts ...Option) (*WorkflowConversation, error)

+ func (wc *WorkflowConversation) ActiveConversation() *Conversation

+ func (wc *WorkflowConversation) AvailableEvents() []string

+ func (wc *WorkflowConversation) Close() error

+ func (wc *WorkflowConversation) Context() *workflow.Context

+ func (wc *WorkflowConversation) CurrentPromptTask() string

+ func (wc *WorkflowConversation) CurrentState() string

+ func (wc *WorkflowConversation) IsComplete() bool

+ func (wc *WorkflowConversation) OrchestrationMode() workflow.Orchestration

+ func (wc *WorkflowConversation) Send(ctx context.Context, message any, opts ...SendOption) (*Response, error)

+ func (wc *WorkflowConversation) Transition(event string) (string, error)

Feb 15, 2026

Changes in this version

+ var ErrInvalidTransition = errors.New("a2a: invalid state transition")

+ var ErrTaskAlreadyExists = errors.New("a2a: task already exists")

+ var ErrTaskNotFound = errors.New("a2a: task not found")

+ var ErrTaskTerminal = errors.New("a2a: task is in a terminal state")

+ type A2AConversationOpener func(contextID string) (a2aConv, error)

+ func A2AOpener(packPath, promptName string, opts ...Option) A2AConversationOpener

+ type A2AServer struct

+ func NewA2AServer(opener A2AConversationOpener, opts ...A2AServerOption) *A2AServer

+ func (s *A2AServer) Handler() http.Handler

+ func (s *A2AServer) ListenAndServe() error

+ func (s *A2AServer) Serve(ln net.Listener) error

+ func (s *A2AServer) Shutdown(ctx context.Context) error

+ type A2AServerOption func(*A2AServer)

+ func WithA2ACard(card *a2a.AgentCard) A2AServerOption

+ func WithA2APort(port int) A2AServerOption

+ func WithA2ATaskStore(store A2ATaskStore) A2AServerOption

+ type A2ATaskStore interface

+ AddArtifacts func(taskID string, artifacts []a2a.Artifact) error

+ Cancel func(taskID string) error

+ Create func(taskID, contextID string) (*a2a.Task, error)

+ Get func(taskID string) (*a2a.Task, error)

+ List func(contextID string, limit, offset int) ([]*a2a.Task, error)

+ SetState func(taskID string, state a2a.TaskState, msg *a2a.Message) error

+ type InMemoryA2ATaskStore struct

+ func NewInMemoryA2ATaskStore() *InMemoryA2ATaskStore

+ func (s *InMemoryA2ATaskStore) AddArtifacts(taskID string, artifacts []a2a.Artifact) error

+ func (s *InMemoryA2ATaskStore) Cancel(taskID string) error

+ func (s *InMemoryA2ATaskStore) Create(taskID, contextID string) (*a2a.Task, error)

+ func (s *InMemoryA2ATaskStore) Get(taskID string) (*a2a.Task, error)

+ func (s *InMemoryA2ATaskStore) List(contextID string, limit, offset int) ([]*a2a.Task, error)

+ func (s *InMemoryA2ATaskStore) SetState(taskID string, state a2a.TaskState, msg *a2a.Message) error

+ type JudgeProvider struct

+ func NewJudgeProvider(p providers.Provider) *JudgeProvider

+ func (jp *JudgeProvider) Judge(ctx context.Context, opts handlers.JudgeOpts) (*handlers.JudgeResult, error)

type Option

+ func WithA2ATools(bridge *a2a.ToolBridge) Option

+ func WithEvalDispatcher(d evals.EvalDispatcher) Option

+ func WithEvalRegistry(r *evals.EvalTypeRegistry) Option

+ func WithJudgeProvider(jp handlers.JudgeProvider) Option

+ func WithResultWriters(writers ...evals.ResultWriter) Option

Jan 24, 2026

Changes in this version

+ type CredentialOption interface

+ func WithCredentialAPIKey(key string) CredentialOption

+ func WithCredentialEnv(envVar string) CredentialOption

+ func WithCredentialFile(path string) CredentialOption

type Option

+ func WithAzure(endpoint string, opts ...PlatformOption) Option

+ func WithBedrock(region string, opts ...PlatformOption) Option

+ func WithVertex(region, project string, opts ...PlatformOption) Option

+ type PlatformOption interface

+ func WithPlatformEndpoint(endpoint string) PlatformOption

+ func WithPlatformProject(project string) PlatformOption

+ func WithPlatformRegion(region string) PlatformOption

type SendOption

+ func WithDocumentData(data []byte, mimeType string) SendOption

+ func WithDocumentFile(path string) SendOption

Jan 15, 2026

Changes in this version

type Conversation

+ func (c *Conversation) SendFrame(ctx context.Context, frame *session.ImageFrame) error

+ func (c *Conversation) SendVideoChunk(ctx context.Context, chunk *session.VideoChunk) error

type Option

+ func WithAutoResize(maxWidth, maxHeight int) Option

+ func WithImagePreprocessing(cfg *stage.ImagePreprocessConfig) Option

+ func WithJSONMode() Option

+ func WithResponseFormat(format *providers.ResponseFormat) Option

+ func WithStreamingVideo(cfg *VideoStreamConfig) Option

type SendOption

+ func WithAudioData(data []byte, mimeType string) SendOption

+ func WithVideoData(data []byte, mimeType string) SendOption

+ func WithVideoFile(path string) SendOption

+ type VideoStreamConfig struct

+ EnableResize bool

+ MaxHeight int

+ MaxWidth int

+ Quality int

+ TargetFPS float64

+ func DefaultVideoStreamConfig() *VideoStreamConfig

Dec 23, 2025

Changes in this version

type Conversation

+ func OpenDuplex(packPath, promptName string, opts ...Option) (*Conversation, error)

+ func (c *Conversation) Done() (<-chan struct{}, error)

+ func (c *Conversation) Response() (<-chan providers.StreamChunk, error)

+ func (c *Conversation) SendChunk(ctx context.Context, chunk *providers.StreamChunk) error

+ func (c *Conversation) SendText(ctx context.Context, text string) error

+ func (c *Conversation) SessionError() error

+ func (c *Conversation) TriggerStart(ctx context.Context, message string) error

type Option

+ func WithEventStore(store events.EventStore) Option

+ func WithRelevanceTruncation(cfg *RelevanceConfig) Option

+ func WithStreamingConfig(streamingConfig *providers.StreamingInputConfig) Option

+ func WithTTS(service tts.Service) Option

+ func WithTurnDetector(detector audio.TurnDetector) Option

+ func WithVADMode(sttService stt.Service, ttsService tts.Service, cfg *VADModeConfig) Option

+ func WithVariableProvider(p variables.Provider) Option

+ func WithVariables(vars map[string]string) Option

+ type RelevanceConfig struct

+ AlwaysKeepSystemRole bool

+ CustomQuery string

+ EmbeddingProvider providers.EmbeddingProvider

+ LastNCount int

+ MinRecentMessages int

+ QuerySource string

+ SimilarityThreshold float64

+ type SessionMode int

+ const DuplexMode

+ const UnaryMode

+ type VADModeConfig struct

+ Language string

+ MaxTurnDuration time.Duration

+ MinSpeechDuration time.Duration

+ SampleRate int

+ SilenceDuration time.Duration

+ Speed float64

+ Voice string

+ func DefaultVADModeConfig() *VADModeConfig

Dec 9, 2025

Changes in this version

+ var ErrConversationClosed = errors.New("conversation is closed")

+ var ErrConversationNotFound = errors.New("conversation not found")

+ var ErrNoStateStore = errors.New("no state store configured")

+ var ErrProviderNotDetected = errors.New("could not detect provider: no API keys found in environment")

+ var ErrToolNotInPack = errors.New("tool not defined in pack")

+ var ErrToolNotRegistered = errors.New("tool handler not registered")

+ type ChunkType int

+ const ChunkDone

+ const ChunkMedia

+ const ChunkText

+ const ChunkToolCall

+ func (t ChunkType) String() string

type Conversation

+ func Open(packPath, promptName string, opts ...Option) (*Conversation, error)

+ func Resume(conversationID, packPath, promptName string, opts ...Option) (*Conversation, error)

+ func (c *Conversation) CheckPending(name string, args map[string]any) (*sdktools.PendingToolCall, bool)

+ func (c *Conversation) Clear()

+ func (c *Conversation) Close() error

+ func (c *Conversation) EventBus() *events.EventBus

+ func (c *Conversation) Fork() *Conversation

+ func (c *Conversation) GetVar(name string) string

+ func (c *Conversation) ID() string

+ func (c *Conversation) Messages() []types.Message

+ func (c *Conversation) OnTool(name string, handler ToolHandler)

+ func (c *Conversation) OnToolAsync(name string, checkFunc func(args map[string]any) sdktools.PendingResult, ...)

+ func (c *Conversation) OnToolCtx(name string, handler ToolHandlerCtx)

+ func (c *Conversation) OnToolExecutor(name string, executor tools.Executor)

+ func (c *Conversation) OnToolHTTP(name string, config *sdktools.HTTPToolConfig)

+ func (c *Conversation) OnTools(handlers map[string]ToolHandler)

+ func (c *Conversation) PendingTools() []*sdktools.PendingToolCall

+ func (c *Conversation) RejectTool(id, reason string) (*sdktools.ToolResolution, error)

+ func (c *Conversation) ResolveTool(id string) (*sdktools.ToolResolution, error)

+ func (c *Conversation) SetVar(name, value string)

+ func (c *Conversation) SetVars(vars map[string]any)

+ func (c *Conversation) SetVarsFromEnv(prefix string)

+ func (c *Conversation) Stream(ctx context.Context, message any, opts ...SendOption) <-chan StreamChunk

+ func (c *Conversation) StreamRaw(ctx context.Context, message any) (<-chan streamPkg.Chunk, error)

+ func (c *Conversation) ToolRegistry() *tools.Registry

+ type MCPServerBuilder struct

+ func NewMCPServer(name, command string, args ...string) *MCPServerBuilder

+ func (b *MCPServerBuilder) Build() mcp.ServerConfig

+ func (b *MCPServerBuilder) WithArgs(args ...string) *MCPServerBuilder

+ func (b *MCPServerBuilder) WithEnv(key, value string) *MCPServerBuilder

+ type Option func(*config) error

+ func WithAPIKey(key string) Option

+ func WithConversationID(id string) Option

+ func WithDisabledValidators(names ...string) Option

+ func WithMCP(name, command string, args ...string) Option

+ func WithMCPServer(builder *MCPServerBuilder) Option

+ func WithModel(model string) Option

+ func WithSkipSchemaValidation() Option

+ func WithStrictValidation() Option

+ func WithTokenBudget(tokens int) Option

+ func WithTruncation(strategy string) Option

+ func WithValidationMode(mode ValidationMode) Option

+ type PackError struct

+ Cause error

+ Path string

+ func (e *PackError) Error() string

+ func (e *PackError) Unwrap() error

+ type PendingTool struct

+ Arguments map[string]any

+ ID string

+ Message string

+ Name string

+ Reason string

+ type ProviderError struct

+ Cause error

+ Message string

+ Provider string

+ StatusCode int

+ func (e *ProviderError) Error() string

+ func (e *ProviderError) Unwrap() error

type Response

+ func (r *Response) Duration() time.Duration

+ func (r *Response) HasMedia() bool

+ func (r *Response) HasToolCalls() bool

+ func (r *Response) InputTokens() int

+ func (r *Response) Message() *types.Message

+ func (r *Response) OutputTokens() int

+ func (r *Response) Parts() []types.ContentPart

+ func (r *Response) Text() string

+ type SendOption func(*sendConfig) error

+ func WithAudioFile(path string) SendOption

+ func WithFile(name string, data []byte) SendOption

+ func WithImageData(data []byte, mimeType string, detail ...*string) SendOption

+ func WithImageFile(path string, detail ...*string) SendOption

+ func WithImageURL(url string, detail ...*string) SendOption

+ type StreamChunk struct

+ Error error

+ Media *types.MediaContent

+ Message *Response

+ Text string

+ ToolCall *types.MessageToolCall

+ Type ChunkType

+ type ToolError struct

+ Cause error

+ ToolName string

+ func (e *ToolError) Error() string

+ func (e *ToolError) Unwrap() error

+ type ToolHandler func(args map[string]any) (any, error)

+ type ToolHandlerCtx func(ctx context.Context, args map[string]any) (any, error)

+ type ValidationError struct

+ Details map[string]any

+ Message string

+ ValidatorType string

+ func AsValidationError(err error) (*ValidationError, bool)

+ func (e *ValidationError) Error() string

+ type ValidationMode int

+ const ValidationModeDisabled

+ const ValidationModeError

+ const ValidationModeWarn

Dec 5, 2025

Changes in this version

type Conversation

+ func (c *Conversation) AddEventListener(listener events.Listener)

type ManagerOption

+ func WithEventBus(bus *events.EventBus) ManagerOption

Nov 26, 2025

Changes in this version

type ManagerConfig

+ EnableMediaExternalization bool

+ MediaDefaultPolicy string

+ MediaSizeThresholdKB int64

type ManagerOption

+ func WithMediaStorage(storageService storage.MediaStorageService) ManagerOption

type PipelineBuilder

+ func (pb *PipelineBuilder) WithMediaExternalization(storageService storage.MediaStorageService, sizeThresholdKB int64, ...) *PipelineBuilder

Nov 17, 2025

Changes in this version

type Prompt

+ MediaConfig *prompt.MediaConfig

Nov 2, 2025

Changes in this version

+ const RoleAssistant

+ const RoleTool

+ const RoleUser

+ var ErrInvalidConfig = errors.New("invalid configuration")

+ var ErrPackNotFound = errors.New("pack not found")

+ var ErrPromptNotFound = errors.New("prompt not found")

+ var ErrProviderFailed = errors.New("provider request failed")

+ var ErrValidationFailed = errors.New("validation failed")

+ func IsRetryableError(err error) bool

+ func IsTemporaryError(err error) bool

+ func WrapPackError(err error, packPath string) error

+ func WrapProviderError(err error, provider string) error

+ func WrapValidationError(err error, validator string) error

+ type Conversation struct

+ func (c *Conversation) AddToolResult(toolCallID, result string) error

+ func (c *Conversation) Continue(ctx context.Context) (*Response, error)

+ func (c *Conversation) GetHistory() []types.Message

+ func (c *Conversation) GetID() string

+ func (c *Conversation) GetPendingTools() []tools.PendingToolInfo

+ func (c *Conversation) GetUserID() string

+ func (c *Conversation) HasPendingTools() bool

+ func (c *Conversation) Send(ctx context.Context, userMessage string, opts ...SendOptions) (*Response, error)

+ func (c *Conversation) SendStream(ctx context.Context, userMessage string, opts ...SendOptions) (<-chan StreamEvent, error)

+ type ConversationConfig struct

+ ContextPolicy *middleware.ContextBuilderPolicy

+ ConversationID string

+ Metadata map[string]interface{}

+ PromptName string

+ SystemPrompt string

+ UserID string

+ Variables map[string]interface{}

+ type ConversationManager struct

+ func NewConversationManager(opts ...ManagerOption) (*ConversationManager, error)

+ func (cm *ConversationManager) CreateConversation(ctx context.Context, pack *Pack, config ConversationConfig) (*Conversation, error)

+ func (cm *ConversationManager) GetConversation(ctx context.Context, conversationID string, pack *Pack) (*Conversation, error)

+ func (cm *ConversationManager) LoadPack(packPath string) (*Pack, error)

+ type CustomContextMiddleware interface

+ type ManagerConfig struct

+ DefaultTimeout time.Duration

+ EnableMetrics bool

+ MaxConcurrentExecutions int

+ type ManagerOption func(*ConversationManager) error

+ func WithConfig(config ManagerConfig) ManagerOption

+ func WithProvider(provider providers.Provider) ManagerOption

+ func WithStateStore(store statestore.Store) ManagerOption

+ func WithToolRegistry(registry *tools.Registry) ManagerOption

+ type MiddlewareConfig struct

+ Config map[string]interface{}

+ Type string

+ type ModelOverride struct

+ SystemTemplateSuffix string

+ type ObservabilityMiddleware interface

+ type Pack struct

+ Description string

+ Fragments map[string]string

+ ID string

+ Name string

+ Prompts map[string]*Prompt

+ TemplateEngine TemplateEngine

+ Tools map[string]*Tool

+ Version string

+ func (p *Pack) CreateRegistry() (*prompt.Registry, error)

+ func (p *Pack) GetPrompt(taskType string) (*Prompt, error)

+ func (p *Pack) GetTools(taskType string) ([]*Tool, error)

+ func (p *Pack) ListPrompts() []string

+ type PackManager struct

+ func NewPackManager() *PackManager

+ func (pm *PackManager) GetPack(packPath string) (*Pack, bool)

+ func (pm *PackManager) LoadPack(packPath string) (*Pack, error)

+ type Parameters struct

+ MaxTokens int

+ Temperature float32

+ TopK *int

+ TopP float32

+ type PipelineBuilder struct

+ func NewPipelineBuilder() *PipelineBuilder

+ func (pb *PipelineBuilder) Build() *pipeline.Pipeline

+ func (pb *PipelineBuilder) WithConfig(config *pipeline.PipelineRuntimeConfig) *PipelineBuilder

+ func (pb *PipelineBuilder) WithMiddleware(m pipeline.Middleware) *PipelineBuilder

+ func (pb *PipelineBuilder) WithProvider(provider providers.Provider, toolRegistry *tools.Registry, ...) *PipelineBuilder

+ func (pb *PipelineBuilder) WithSimpleProvider(provider providers.Provider) *PipelineBuilder

+ func (pb *PipelineBuilder) WithTemplate() *PipelineBuilder

+ type PipelineConfig struct

+ Middleware []*MiddlewareConfig

+ Stages []string

+ type Prompt struct

+ Description string

+ ID string

+ ModelOverrides map[string]*ModelOverride

+ Name string

+ Parameters *Parameters

+ Pipeline *PipelineConfig

+ SystemTemplate string

+ TestedModels []*TestedModel

+ ToolNames []string

+ ToolPolicy *ToolPolicy

+ Validators []*Validator

+ Variables []*Variable

+ Version string

+ type Response struct

+ Content string

+ Cost float64

+ LatencyMs int64

+ PendingTools []tools.PendingToolInfo

+ TokensUsed int

+ ToolCalls []types.MessageToolCall

+ Truncated bool

+ Validations []types.ValidationResult

+ type SendOptions struct

+ MaxToolCalls int

+ Metadata map[string]interface{}

+ Stream bool

+ type StreamEvent struct

+ Content string

+ Error error

+ Final *Response

+ ToolCall *types.MessageToolCall

+ Type string

+ type TemplateEngine struct

+ Features []string

+ Syntax string

+ Version string

+ type TestedModel struct

+ AvgCost float64

+ AvgLatencyMs int

+ AvgTokens int

+ Date string

+ Model string

+ Provider string

+ SuccessRate float64

+ type Tool struct

+ Description string

+ Name string

+ Parameters map[string]interface{}

+ type ToolPolicy struct

+ Blocklist []string

+ MaxRounds int

+ MaxToolCallsPerTurn int

+ ToolChoice string

+ type Validator struct

+ Enabled bool

+ FailOnViolation bool

+ Params map[string]interface{}

+ Type string

+ type Variable struct

+ Default interface{}

+ Description string

+ Example interface{}

+ Name string

+ Required bool

+ Type string

+ Validation map[string]interface{}