agnt5

package

Go to main page

Versions in this module

v0

v0.4.1

Aug 24, 2026

v0.4.0

Aug 8, 2026

Changes in this version

+ var ErrActivationCancelled = errors.New("agnt5: activation cancelled")

+ var ErrActivationContended = errors.New("agnt5: activation is already active")

+ var ErrActivationUnknownOutcome = errors.New("agnt5: activation outcome is unknown")

+ var ErrAgentMaxTurnsExceeded = errors.New("agnt5: agent max turns exceeded")

+ var ErrAgentModelRequired = errors.New("agnt5: agent model is required")

+ var ErrDurabilityUnavailable = errors.New("agnt5: durable activation unavailable")

+ var ErrMCPTransportClosed = errors.New("agnt5: MCP transport closed")

+ var ErrNondeterministicReplay = errors.New("agnt5: non-deterministic replay")

+ var ErrStaleActivationAuthority = errors.New("agnt5: stale activation authority")

+ var ErrToolNotFound = errors.New("agnt5: tool not found")

+ func StepWithKey[T any](ctx *Context, name, key string, fn func(*Context) (T, error)) (T, error)

+ type ActivationError struct

+ ActivationID string

+ Attempt uint32

+ Cause error

+ Code ActivationErrorCode

+ Message string

+ func (e *ActivationError) Error() string

+ func (e *ActivationError) Is(target error) bool

+ func (e *ActivationError) Unwrap() error

+ type ActivationErrorCode string

+ const ActivationErrorCancelled

+ const ActivationErrorContended

+ const ActivationErrorDurabilityUnavailable

+ const ActivationErrorIllegalTransition

+ const ActivationErrorInvalidArgument

+ const ActivationErrorNondeterministicReplay

+ const ActivationErrorPayloadConflict

+ const ActivationErrorReferenceRequired

+ const ActivationErrorRequiredChildUnresolved

+ const ActivationErrorStaleAuthority

+ const ActivationErrorStateVersionConflict

+ const ActivationErrorUnknownOutcome

+ type ActivationExecution struct

+ ActivationID string

+ Attempt uint32

+ IdempotencyKey string

+ func ActivationFromContext(ctx context.Context) (ActivationExecution, bool)

type BatchOption

+ func WithBatchIdempotencyKey(key string) BatchOption

+ type ChildJoinPolicy string

+ const ChildJoinPolicyDetached

+ const ChildJoinPolicyRequired

type Context

+ func (c *Context) Activation() (ActivationExecution, bool)

+ func (c *Context) Sleep(duration time.Duration, opts ...SleepOption) error

+ type DurableActivationMode string

+ const DurableActivationDisabled

+ const DurableActivationPreferred

+ const DurableActivationRequired

+ type DurableActivationStatus struct

+ Degraded bool

+ Enabled bool

+ Mode DurableActivationMode

+ Reason string

type GenerateRequest

+ RecoveryPolicy RecoveryPolicy

type Handoff

+ JoinPolicy ChildJoinPolicy

type HandoffOption

+ func WithHandoffJoinPolicy(policy ChildJoinPolicy) HandoffOption

type MCPClient

+ func (c *MCPClient) Initialize(ctx context.Context) error

+ type MCPNotificationTransport interface

+ Notify func(ctx context.Context, method string, params any) error

+ type MCPRequestError struct

+ Code int

+ Data any

+ Message string

+ func (e *MCPRequestError) Error() string

+ type RecoveryPolicy string

+ const RecoveryPolicyCompensate

+ const RecoveryPolicyDurableSteps

+ const RecoveryPolicyFail

+ const RecoveryPolicyIdempotentRetry

+ const RecoveryPolicyUnknownOutcome

type RunOption

+ func WithIdempotencyKey(key string) RunOption

+ func WithRunIdempotencyKey(key string) RunOption

type SSEMCPTransport

+ func (t *SSEMCPTransport) Notify(ctx context.Context, method string, params any) error

+ type SleepOption func(*sleepOptions)

+ func WithSleepKey(key string) SleepOption

type StdioMCPTransport

+ func (t *StdioMCPTransport) Notify(ctx context.Context, method string, params any) error

type StreamMCPTransport

+ func (t *StreamMCPTransport) Notify(ctx context.Context, method string, params any) error

type SubmitOption

+ func WithSubmitIdempotencyKey(key string) SubmitOption

type Tool

+ DisableDurableActivation bool

+ RecoveryPolicy RecoveryPolicy

type ToolOption

+ func WithToolRecoveryPolicy(policy RecoveryPolicy) ToolOption

+ func WithoutDurableToolActivation() ToolOption

type Worker

+ func (w *Worker) DurableActivationStatus() DurableActivationStatus

type WorkerOption

+ func WithDurableActivationArtifact(sha256 string) WorkerOption

+ func WithDurableActivationMode(mode DurableActivationMode) WorkerOption

v0.3.1

Jul 31, 2026

v0.3.0

Jul 31, 2026

Changes in this version

+ const EvaluatorPresetVersion

+ const EvaluatorSystemPrompt

+ const TraceEvalContextSchema

+ var BuiltInDeterministicScorerNames = []string

+ var BuiltInJudgeScorerNames = []string

+ var EvaluatorOutputSchema = map[string]any

+ func ToolCallNames(calls []ToolCall) []string

+ func ToolTrajectoryMatches(actual, expected []string, mode ToolTrajectoryMode) bool

+ func WithLLMJudgeModel(ctx context.Context, model LanguageModel) context.Context

+ type AssertionResult struct

+ Explanation string

+ Name string

+ Passed bool

+ type BatchEvalItem struct

+ Expected any

+ Index *int

+ Input map[string]any

+ ItemID string

+ func NormalizeBatchEvalItems(inputs []map[string]any, expected []any) []BatchEvalItem

+ type BatchEvalItemResult struct

+ DurationMS int64

+ Error string

+ Index int

+ ItemID string

+ Output json.RawMessage

+ Passed bool

+ RunID string

+ Scores []EvalScore

+ TraceID string

+ func (r BatchEvalItemResult) GetScore(name string) (EvalScore, bool)

+ func (r BatchEvalItemResult) IsFailed() bool

+ func (r BatchEvalItemResult) IsSuccess() bool

+ type BatchEvalOptions struct

+ ComponentType ComponentType

+ DeploymentID string

+ Expected []any

+ MaxConcurrency int

+ Scorers []EvalScorerSpec

+ Timeout time.Duration

+ type BatchEvalResult struct

+ BatchID string

+ Results []BatchEvalItemResult

+ Stats BatchEvalStats

+ Status string

+ func (r BatchEvalResult) FailedItems() []BatchEvalItemResult

+ func (r BatchEvalResult) FailingItems() []BatchEvalItemResult

+ func (r BatchEvalResult) IsPartialFailure() bool

+ func (r BatchEvalResult) IsSuccess() bool

+ func (r BatchEvalResult) Outputs() []json.RawMessage

+ func (r BatchEvalResult) PassRate() float64

+ func (r BatchEvalResult) PassingItems() []BatchEvalItemResult

+ type BatchEvalStats struct

+ AvgDurationMS int64

+ CompletedItems int

+ DurationMS int64

+ FailedItems int

+ PassedItems int

+ TotalItems int

type Client

+ func (c *Client) BatchEval(ctx context.Context, component string, items []BatchEvalItem, ...) *BatchEvalResult

+ type Coherence struct

+ func (p Coherence) ToEvalScorerSpec() EvalScorerSpec

+ type Conciseness struct

+ func (p Conciseness) ToEvalScorerSpec() EvalScorerSpec

+ type Correctness struct

+ func (p Correctness) ToEvalScorerSpec() EvalScorerSpec

+ type CorrectnessConfig = EvaluatorPresetConfig

+ type EvalContext struct

+ Events []TraceEvent

+ Expected any

+ Input any

+ Output any

+ RunID string

+ TraceID string

+ func (c EvalContext) EventsByType(eventType string) []TraceEvent

+ func (c EvalContext) LMCalls() []TraceEvent

+ func (c EvalContext) StepEvents(stepName string) []TraceEvent

+ func (c EvalContext) ToolCallNames() []string

+ func (c EvalContext) ToolCalls() []ToolCall

+ func (c EvalContext) ToolTrajectoryMatches(expected []string, mode ToolTrajectoryMode) bool

+ func (c EvalContext) TotalTokens() int64

+ type EvalError struct

+ Code string

+ Details map[string]any

+ Message string

type EvalResponse

+ DurationMS int64

+ Error *EvalError

+ TraceID string

+ func (r *EvalResponse) DecodeOutput(target any) error

+ func (r *EvalResponse) GetScore(name string) (EvalScore, bool)

+ func (r *EvalResponse) IsError() bool

+ func (r *EvalResponse) IsSuccess() bool

+ func (r *EvalResponse) RaiseForStatus() error

type EvalScore

+ Label string

+ type EvalScorer interface

+ ToEvalScorerSpec func() EvalScorerSpec

type EvalScorerSpec

+ func NamedScorer(name string) EvalScorerSpec

+ func NormalizeEvalScorers(scorers ...any) []EvalScorerSpec

+ func (s EvalScorerSpec) ToEvalScorerSpec() EvalScorerSpec

+ type EvaluatorPresetConfig struct

+ AnswerField string

+ ContextFields []string

+ ExpectedField string

+ IncludeInput *bool

+ InputField string

+ JournalEventFields []string

+ Metadata map[string]any

+ Model string

+ OutputField string

+ ReferenceField string

+ SessionFields []string

+ Temperature float64

+ Threshold *float64

+ type Faithfulness struct

+ func (p Faithfulness) ToEvalScorerSpec() EvalScorerSpec

+ type FaithfulnessConfig = EvaluatorPresetConfig

+ type GoalSuccess struct

+ func (p GoalSuccess) ToEvalScorerSpec() EvalScorerSpec

+ type Harmfulness struct

+ func (p Harmfulness) ToEvalScorerSpec() EvalScorerSpec

+ type Helpfulness struct

+ func (p Helpfulness) ToEvalScorerSpec() EvalScorerSpec

+ type InstructionFollowing struct

+ func (p InstructionFollowing) ToEvalScorerSpec() EvalScorerSpec

+ type LLMJudge struct

+ func NewLLMJudge(config LLMJudgeConfig) LLMJudge

+ func (j LLMJudge) ToEvalScorerSpec() EvalScorerSpec

+ type LLMJudgeConfig struct

+ ChoiceScores map[string]float64

+ Criteria string

+ IncludeInput bool

+ Model string

+ PromptTemplate string

+ SystemPrompt string

+ Temperature float64

+ type Refusal struct

+ func (p Refusal) ToEvalScorerSpec() EvalScorerSpec

+ type ResponseRelevance struct

+ func (p ResponseRelevance) ToEvalScorerSpec() EvalScorerSpec

type ScorerConfig

+ DependsOn []string

+ InputSchema map[string]any

+ IsAsync bool

+ Scope ScorerScope

+ type ScorerContext = Context

+ type ScorerError struct

+ Code string

+ Details map[string]any

+ Message string

+ Scorer string

+ func (e *ScorerError) Error() string

+ type ScorerNameCollisionError struct

+ BuiltIn bool

+ Name string

+ func (e *ScorerNameCollisionError) Error() string

+ func (e *ScorerNameCollisionError) Unwrap() error

+ type ScorerNotFoundError struct

+ Name string

+ func (e *ScorerNotFoundError) Error() string

type ScorerRequest

+ Config map[string]any

+ PeerScores []map[string]any

+ State map[string]any

+ StateSnapshots map[string]any

+ States map[string]any

+ Trace []TraceEvent

+ TraceEvalContext any

type ScorerResult

+ func FailingScorerResult(explanation string) ScorerResult

+ func NewScorerResult(score float64, explanation string) ScorerResult

+ func PassingScorerResult(explanation string) ScorerResult

+ func TraceScorer(trace []TraceEvent, assertions []TraceAssertion) ScorerResult

+ type ScorerResultSummary = EvalScore

+ type ScorerScope string

+ const ScorerScopeFleetRun

+ const ScorerScopeItem

+ const ScorerScopeRun

+ const ScorerScopeSession

+ const ScorerScopeSpan

+ const ScorerScopeTrace

+ type Stereotyping struct

+ func (p Stereotyping) ToEvalScorerSpec() EvalScorerSpec

type ToolCall

+ CallID string

+ EndedAt int64

+ Metadata map[string]any

+ SpanID string

+ StartedAt int64

+ Status string

+ TimestampNS int64

+ func ExtractToolCallsFromEvents(events []TraceEvent) []ToolCall

+ type ToolTrajectoryMode string

+ const ToolTrajectoryAnyOrder

+ const ToolTrajectoryExact

+ const ToolTrajectoryInOrder

+ type TraceAssertion struct

+ func DurationUnder(max time.Duration) TraceAssertion

+ func EventCount(eventType string, min int) TraceAssertion

+ func EventSequence(expected []string) TraceAssertion

+ func MaxLMCalls(max int) TraceAssertion

+ func MaxTokens(max int64) TraceAssertion

+ func NoErrors() TraceAssertion

+ func StepMemoized(stepName string) TraceAssertion

+ func (a TraceAssertion) Check(trace []TraceEvent) AssertionResult

+ type TraceEvalContext struct

+ DeploymentID string

+ EvidenceRefs any

+ ExecutionSteps []TraceEvalExecutionStep

+ Features TraceEvalFeatures

+ Plan TraceEvalPlan

+ ProjectID string

+ RedactionPolicySnapshot any

+ RootRunID string

+ SchemaVersion string

+ Session TraceEvalSession

+ SessionID string

+ Task *TraceEvalTask

+ TraceID string

+ type TraceEvalExecutionStep struct

+ ArgumentsHash string

+ ArgumentsRef string

+ DurationMS int64

+ EndedAt int64

+ ErrorClass string

+ ErrorCode string

+ ErrorSafe string

+ Flags []string

+ Index int64

+ InputHash string

+ InputRef string

+ Kind string

+ MatchesPlanStep *int64

+ Model string

+ Name string

+ OutputHash string

+ OutputRef string

+ PromptHash string

+ PromptRef string

+ Provider string

+ ResponseHash string

+ ResponseRef string

+ ResultHash string

+ ResultRef string

+ Role string

+ RunID string

+ SpanID string

+ StartedAt int64

+ Status string

+ SummarySafe string

+ Tokens int64

+ ToolName string

+ type TraceEvalFeatures struct

+ DuplicateToolCalls []TraceEvalStepGroup

+ ErrorCount int64

+ ExecutionStepCount int64

+ LMCallCount int64

+ OffPathSteps []int64

+ PlanStepsMatched int64

+ PlanStepsMissing []TraceEvalMissingPlanStep

+ PlanStepsTotal int64

+ RetryGroups []TraceEvalRetryGroup

+ ToolCallCount int64

+ TotalTokens int64

+ TurnCount int64

+ UniqueToolCallCount int64

+ type TraceEvalMissingPlanStep struct

+ PlanStepIndex int64

+ TextSafe string

+ type TraceEvalPlan struct

+ Detected bool

+ Steps []TraceEvalPlanStep

+ type TraceEvalPlanStep struct

+ ExpectedAction string

+ ExpectedTool string

+ Index int64

+ TextSafe string

+ type TraceEvalRetryGroup struct

+ Reason string

+ StepIDs []int64

+ type TraceEvalSession struct

+ TurnCount int64

+ Turns []TraceEvalTurn

+ type TraceEvalStepGroup struct

+ Reason string

+ StepIDs []int64

+ ToolName string

+ type TraceEvalTask struct

+ TextSafe string

+ type TraceEvalTurn struct

+ EndedAt int64

+ MessageHash string

+ MessageRef string

+ Role string

+ StartedAt int64

+ SummarySafe string

+ TurnIndex int64

+ type TraceEvent struct

+ CorrelationID string

+ Data map[string]any

+ EventID string

+ EventType string

+ Name string

+ ParentCorrelationID string

+ TimestampNS int64

+ func (e *TraceEvent) UnmarshalJSON(data []byte) error

+ type TraceScorerResult = ScorerResult

v0.2.3

Jul 30, 2026

v0.2.2

Jul 30, 2026

v0.2.1

Jul 26, 2026

Changes in this version

+ func Task[TInput any, TOutput any](ctx *Context, name string, input TInput, ...) (TOutput, error)

type Component

+ InputSchema map[string]any

+ OutputSchema map[string]any

type ComponentInfo

+ InputSchema map[string]any

+ OutputSchema map[string]any

type ComponentOption

+ func WithInputSchema(schema map[string]any) ComponentOption

+ func WithOutputSchema(schema map[string]any) ComponentOption

type Context

+ func (c *Context) Value(key any) any

type ModelStreamChunkType

+ const ModelStreamThinkingDelta

+ const ModelStreamThinkingStart

+ const ModelStreamThinkingStop

v0.2.0

Jul 25, 2026

Changes in this version

+ const EventTypeLogDebug

+ const EventTypeLogError

+ const EventTypeLogInfo

+ const EventTypeLogWarn

+ const EventTypeOutputDelta

+ var ErrComponentNotFound = errors.New("agnt5: component not found")

+ var ErrCoordinatorDraining = errors.New("agnt5: coordinator draining")

+ var ErrDuplicateComponent = errors.New("agnt5: duplicate component")

+ var ErrInvalidComponentName = errors.New("agnt5: invalid component name")

+ var ErrInvalidStepName = errors.New("agnt5: invalid step name")

+ var ErrMissingRoutingMetadata = errors.New("agnt5: missing project or deployment routing metadata")

+ var ErrNilHandler = errors.New("agnt5: nil handler")

+ var ErrNilWorker = errors.New("agnt5: nil worker")

+ var ErrRegistrationRejected = errors.New("agnt5: worker registration rejected")

+ var ErrStateNotFound = errors.New("agnt5: state not found")

+ var ErrTransportNotImplemented = errors.New("agnt5: worker transport not implemented")

+ var ErrUnexpectedRuntimeMessage = errors.New("agnt5: unexpected runtime message")

+ var ErrWorkerReplaced = errors.New("agnt5: worker replaced")

+ func IsSSEOnlyEventType(eventType string) bool

+ func IsWaitingForUserInput(err error) bool

+ func RegisterAgent(w *Worker, agent *Agent, opts ...ComponentOption) error

+ func RegisterChatBot(w *Worker, bot *ChatBot, opts ...ComponentOption) error

+ func RegisterFunction[In any, Out any](w *Worker, name string, handler func(*Context, In) (Out, error), ...) error

+ func RegisterRaw(w *Worker, name string, componentType ComponentType, ...) error

+ func RegisterScorer(w *Worker, config ScorerConfig, opts ...ComponentOption) error

+ func RegisterTool(w *Worker, tool Tool, opts ...ComponentOption) error

+ func RegisterWorkflow[In any, Out any](w *Worker, name string, handler func(*Context, In) (Out, error), ...) error

+ func Step[T any](ctx *Context, name string, fn func(context.Context) (T, error)) (T, error)

+ type Agent struct

+ Cache *PromptCache

+ CacheControl bool

+ CacheTTL string

+ Handoffs []Handoff

+ Instructions string

+ MaxTurns int

+ Model LanguageModel

+ Name string

+ Tools []Tool

+ func NewAgent(name string, opts ...AgentOption) (*Agent, error)

+ func (a *Agent) Run(ctx *Context, input AgentInput) (AgentResult, error)

+ type AgentInput struct

+ Message string

+ Messages []Message

+ type AgentManager struct

+ func NewAgentManager(registry *AgentRegistry) *AgentManager

+ func (m *AgentManager) Get(name string) (*Agent, bool)

+ func (m *AgentManager) List() []*Agent

+ func (m *AgentManager) Register(agent *Agent) error

+ func (m *AgentManager) Run(ctx *Context, name string, input AgentInput) (AgentResult, error)

+ type AgentOption func(*Agent)

+ func WithAgentCacheControl(enabled bool, ttl string) AgentOption

+ func WithAgentHandoffs(handoffs ...Handoff) AgentOption

+ func WithAgentInstructions(instructions string) AgentOption

+ func WithAgentMaxTurns(maxTurns int) AgentOption

+ func WithAgentModel(model LanguageModel) AgentOption

+ func WithAgentPromptCache(cache *PromptCache) AgentOption

+ func WithAgentTools(tools ...Tool) AgentOption

+ type AgentRegistry struct

+ func DefaultAgentRegistry() *AgentRegistry

+ func NewAgentRegistry() *AgentRegistry

+ func (r *AgentRegistry) Clear()

+ func (r *AgentRegistry) Get(name string) (*Agent, bool)

+ func (r *AgentRegistry) List() []*Agent

+ func (r *AgentRegistry) Register(agent *Agent) error

+ type AgentResult struct

+ AgentName string

+ HandoffMetadata map[string]any

+ HandoffTo string

+ Messages []Message

+ Metadata map[string]any

+ Response string

+ ToolCallDetails []AgentToolCall

+ ToolCalls int

+ type AgentToolCall struct

+ Arguments map[string]any

+ Error string

+ Handoff string

+ ID string

+ Iteration int

+ Name string

+ Result any

+ type AnthropicConfig struct

+ APIKey string

+ BaseURL string

+ HTTPClient *http.Client

+ Model string

+ Version string

+ type AnthropicModel struct

+ func NewAnthropicModel(config AnthropicConfig) *AnthropicModel

+ func (m *AnthropicModel) Generate(ctx context.Context, request GenerateRequest) (GenerateResponse, error)

+ type AzureOpenAIConfig struct

+ APIKey string

+ APIVersion string

+ Deployment string

+ Endpoint string

+ HTTPClient *http.Client

+ type BatchItemError struct

+ Code string

+ Details map[string]any

+ Message string

+ type BatchItemInput struct

+ Index *int

+ Input any

+ ItemID string

+ Metadata map[string]string

+ TimeoutMS int64

+ func NewBatchItem(input any, opts ...BatchItemOption) BatchItemInput

+ type BatchItemOption func(*BatchItemInput)

+ func WithBatchItemID(itemID string) BatchItemOption

+ func WithBatchItemIndex(index int) BatchItemOption

+ func WithBatchItemMetadata(metadata map[string]string) BatchItemOption

+ func WithBatchItemTimeoutMS(timeoutMS int64) BatchItemOption

+ type BatchItemResult struct

+ CompletedAt *time.Time

+ DurationMS *int64

+ Error *BatchItemError

+ Index int

+ ItemID string

+ Output json.RawMessage

+ Raw map[string]any

+ RunID string

+ StartedAt *time.Time

+ Status RunStatus

+ func (r BatchItemResult) DecodeOutput(target any) error

+ func (r BatchItemResult) IsFailed() bool

+ func (r BatchItemResult) IsSuccess() bool

+ type BatchOption func(*batchConfig)

+ func WithBatchComponentType(componentType ComponentType) BatchOption

+ func WithBatchContinueOnFailure(continueOnFailure bool) BatchOption

+ func WithBatchDefaultItemTimeoutMS(timeoutMS int64) BatchOption

+ func WithBatchHTTPTimeout(timeout time.Duration) BatchOption

+ func WithBatchMaxConcurrency(maxConcurrency int) BatchOption

+ func WithBatchMetadata(metadata map[string]string) BatchOption

+ func WithBatchRawItems() BatchOption

+ func WithBatchTenant(tenantID string) BatchOption

+ func WithBatchTimeoutMS(timeoutMS int64) BatchOption

+ type BatchResult struct

+ BatchID string

+ CreatedAt *time.Time

+ Raw map[string]any

+ Results []BatchItemResult

+ RunIDs []string

+ Stats *BatchStats

+ Status BatchStatus

+ TotalItems int

+ TraceID string

+ func (r *BatchResult) FailedItems() []BatchItemResult

+ func (r *BatchResult) IsPartialFailure() bool

+ func (r *BatchResult) IsSuccess() bool

+ func (r *BatchResult) Outputs() []json.RawMessage

+ func (r *BatchResult) SuccessfulOutputs() []json.RawMessage

+ type BatchStats struct

+ AvgItemDurationMS int64

+ CancelledItems int

+ CompletedItems int

+ DurationMS int64

+ FailedItems int

+ PendingItems int

+ TotalItems int

+ type BatchStatus string

+ const BatchStatusCancelled

+ const BatchStatusCompleted

+ const BatchStatusFailed

+ const BatchStatusPartialFailure

+ const BatchStatusPending

+ const BatchStatusQueued

+ const BatchStatusRunning

+ const BatchStatusStarted

+ const BatchStatusUnknown

+ type BatchStatusResponse struct

+ BatchID string

+ CompletedAt *time.Time

+ Found bool

+ Raw map[string]any

+ Results []BatchItemResult

+ StartedAt *time.Time

+ Stats *BatchStats

+ Status BatchStatus

+ SubmittedAt *time.Time

+ TraceID string

+ func (r *BatchStatusResponse) IsCompleted() bool

+ func (r *BatchStatusResponse) IsRunning() bool

+ type BatchStreamEvent struct

+ BatchID string

+ Data json.RawMessage

+ EventType string

+ Metadata map[string]any

+ Raw map[string]any

+ RunID string

+ type CancelBatchResponse struct

+ BatchID string

+ CancelledItems int

+ CompletedItems int

+ Raw map[string]any

+ Status BatchStatus

+ type CancelRunResponse struct

+ Offset int64

+ Raw map[string]any

+ RunID string

+ Status string

+ type ChatBot struct

+ Agent *Agent

+ Name string

+ func NewChatBot(name string, agent *Agent) (*ChatBot, error)

+ func (b *ChatBot) Handle(ctx *Context, message ChatMessage) (ChatResponse, error)

+ type ChatMessage struct

+ Content string

+ Metadata map[string]any

+ Role MessageRole

+ SessionID string

+ UserID string

+ type ChatResponse struct

+ Message ChatMessage

+ SessionID string

+ type Client struct

+ func NewClient(gatewayURL string, opts ...ClientOption) (*Client, error)

+ func (c *Client) Batch(ctx context.Context, component string, items any, opts ...BatchOption) (*BatchResult, error)

+ func (c *Client) BatchStream(ctx context.Context, component string, items any, ...) error

+ func (c *Client) CancelBatch(ctx context.Context, batchID, reason string, timeout time.Duration) (*CancelBatchResponse, error)

+ func (c *Client) CancelRun(ctx context.Context, runID string, reason string, opts ...RunOption) (*CancelRunResponse, error)

+ func (c *Client) Chat(ctx context.Context, agent string, message ChatMessage, opts ...RunOption) (*ChatResponse, error)

+ func (c *Client) Eval(ctx context.Context, request EvalRequest, opts ...RunOption) (*EvalResponse, error)

+ func (c *Client) GetBatchStatus(ctx context.Context, batchID string, includeResults bool, ...) (*BatchStatusResponse, error)

+ func (c *Client) GetEvents(ctx context.Context, runID string) (*EventsResponse, error)

+ func (c *Client) GetResult(ctx context.Context, runID string) (*RunResponse, error)

+ func (c *Client) GetStatus(ctx context.Context, runID string) (*StatusResponse, error)

+ func (c *Client) ResumeWorkflow(ctx context.Context, runID string, userResponse any, opts ...RunOption) (*ResumeWorkflowResponse, error)

+ func (c *Client) Run(ctx context.Context, component string, input any, opts ...RunOption) (*RunResponse, error)

+ func (c *Client) Session(sessionID string) *SessionProxy

+ func (c *Client) Stream(ctx context.Context, component string, input any, handle func(string) error, ...) error

+ func (c *Client) StreamEvents(ctx context.Context, component string, input any, ...) error

+ func (c *Client) Submit(ctx context.Context, component string, input any, opts ...SubmitOption) (*SubmitResponse, error)

+ func (c *Client) WaitForResult(ctx context.Context, runID string, timeout, pollInterval time.Duration) (*RunResponse, error)

+ func (c *Client) Workflow(name string) *WorkflowProxy

+ type ClientError struct

+ Body string

+ Method string

+ StatusCode int

+ URL string

+ func (e *ClientError) Error() string

+ type ClientOption func(*clientConfig)

+ func WithAPIKey(apiKey string) ClientOption

+ func WithClientDeploymentID(deploymentID string) ClientOption

+ func WithClientTimeout(timeout time.Duration) ClientOption

+ func WithHTTPClient(httpClient *http.Client) ClientOption

+ func WithTenantID(tenantID string) ClientOption

+ type Component struct

+ Config map[string]string

+ Metadata map[string]string

+ Name string

+ Triggers []TriggerSpec

+ Type ComponentType

+ func (c Component) Info() ComponentInfo

+ type ComponentInfo struct

+ Config map[string]string

+ Metadata map[string]string

+ Name string

+ Triggers []TriggerSpec

+ Type ComponentType

+ type ComponentOption func(*Component)

+ func WithBackoff(backoffType string, multiplier float64) ComponentOption

+ func WithComponentConfig(config map[string]string) ComponentOption

+ func WithComponentMetadata(metadata map[string]string) ComponentOption

+ func WithCron(expression string) ComponentOption

+ func WithRetry(maxAttempts, initialIntervalMS, maxIntervalMS int) ComponentOption

+ func WithTriggers(triggers ...TriggerSpec) ComponentOption

+ type ComponentType string

+ const ComponentTypeAgent

+ const ComponentTypeChat

+ const ComponentTypeEntity

+ const ComponentTypeFunction

+ const ComponentTypeMCP

+ const ComponentTypeRun

+ const ComponentTypeScorer

+ const ComponentTypeTool

+ const ComponentTypeWorkflow

+ type Context struct

+ func (c *Context) AskUser(request UserInputRequest) (string, error)

+ func (c *Context) Attempt() int

+ func (c *Context) ComponentName() string

+ func (c *Context) ComponentType() ComponentType

+ func (c *Context) Emit(event Event) error

+ func (c *Context) Events() []Event

+ func (c *Context) Generate(model LanguageModel, request GenerateRequest) (GenerateResponse, error)

+ func (c *Context) InvocationID() string

+ func (c *Context) IsStreaming() bool

+ func (c *Context) LeaseID() string

+ func (c *Context) Logger() *Logger

+ func (c *Context) Memory() *MemoryAccessor

+ func (c *Context) Metadata(key string) string

+ func (c *Context) MetadataMap() map[string]string

+ func (c *Context) Output(delta string)

+ func (c *Context) RequestApproval(prompt string, metadata map[string]any) (bool, error)

+ func (c *Context) RunID() string

+ func (c *Context) Sandbox() SandboxRunner

+ func (c *Context) SetSandbox(sandbox SandboxRunner)

+ func (c *Context) State() *StateManager

+ type ConversationMemory struct

+ func (m *ConversationMemory) Append(ctx context.Context, message MemoryMessage) error

+ func (m *ConversationMemory) Messages(ctx context.Context) ([]MemoryMessage, error)

+ type EvalRequest struct

+ Component string

+ ComponentType ComponentType

+ Expected any

+ Input any

+ Metadata map[string]any

+ Scorers []EvalScorerSpec

+ type EvalResponse struct

+ Output json.RawMessage

+ Passed bool

+ Raw map[string]any

+ RunID string

+ Scores []EvalScore

+ type EvalScore struct

+ Explanation string

+ Metadata map[string]any

+ Passed bool

+ Score float64

+ Scorer string

+ type EvalScorerSpec struct

+ Config map[string]any

+ Name string

+ type Event struct

+ ContentIndex int

+ CorrelationID string

+ Data any

+ Metadata map[string]string

+ ParentCorrelationID string

+ RunID string

+ Sequence int64

+ SourceTimestampNS int64

+ Type string

+ type EventsResponse struct

+ Count int

+ Items []RunEvent

+ Raw map[string]any

+ type ExecuteCodeResult struct

+ ExitCode int

+ Stderr string

+ Stdout string

+ type FileInfo struct

+ IsDir bool

+ Path string

+ Size int64

+ type GenerateRequest struct

+ Cache *PromptCache

+ CacheControl bool

+ CacheTTL string

+ GoogleCachedContent string

+ MaxTokens *int

+ Messages []Message

+ Metadata map[string]any

+ Model string

+ Temperature *float64

+ Tools []Tool

+ type GenerateResponse struct

+ Content string

+ FinishReason string

+ ID string

+ Metadata map[string]any

+ Model string

+ ToolCalls []ToolCall

+ Usage TokenUsage

+ type GoogleConfig struct

+ APIKey string

+ BaseURL string

+ HTTPClient *http.Client

+ Model string

+ Version string

+ type GoogleModel struct

+ func NewGeminiModel(config GoogleConfig) *GoogleModel

+ func NewGoogleModel(config GoogleConfig) *GoogleModel

+ func (m *GoogleModel) CreateCachedContent(ctx context.Context, model string, system string, contents []string, ...) (string, error)

+ func (m *GoogleModel) DeleteCachedContent(ctx context.Context, name string) error

+ func (m *GoogleModel) Generate(ctx context.Context, request GenerateRequest) (GenerateResponse, error)

+ type HITLInputType string

+ const HITLApproval

+ const HITLMultiSelect

+ const HITLSelect

+ const HITLText

+ type HITLOption struct

+ Label string

+ Value string

+ type HTTPSandbox struct

+ APIKey string

+ Endpoint string

+ HTTPClient *http.Client

+ func NewHTTPSandbox(endpoint string, apiKey string) *HTTPSandbox

+ func (s *HTTPSandbox) ExecuteCode(ctx context.Context, language, code string) (ExecuteCodeResult, error)

+ func (s *HTTPSandbox) ListFiles(ctx context.Context, path string) (ListFilesResult, error)

+ func (s *HTTPSandbox) ReadFile(ctx context.Context, path string) (ReadFileResult, error)

+ func (s *HTTPSandbox) RunCommand(ctx context.Context, command []string) (RunCommandResult, error)

+ func (s *HTTPSandbox) WriteFile(ctx context.Context, path string, content []byte) (WriteFileResult, error)

+ type Handoff struct

+ Agent *Agent

+ Description string

+ Metadata map[string]any

+ PassFullHistory bool

+ ToolName string

+ func NewHandoff(agent *Agent, opts ...HandoffOption) (Handoff, error)

+ type HandoffOption func(*Handoff)

+ func WithHandoffDescription(description string) HandoffOption

+ func WithHandoffFullHistory(pass bool) HandoffOption

+ func WithHandoffMetadata(metadata map[string]any) HandoffOption

+ func WithHandoffToolName(toolName string) HandoffOption

+ type InMemorySandbox struct

+ func NewInMemorySandbox() *InMemorySandbox

+ func (s *InMemorySandbox) ExecuteCode(ctx context.Context, language, code string) (ExecuteCodeResult, error)

+ func (s *InMemorySandbox) ListFiles(ctx context.Context, path string) (ListFilesResult, error)

+ func (s *InMemorySandbox) ReadFile(ctx context.Context, path string) (ReadFileResult, error)

+ func (s *InMemorySandbox) RunCommand(ctx context.Context, command []string) (RunCommandResult, error)

+ func (s *InMemorySandbox) WriteFile(ctx context.Context, path string, content []byte) (WriteFileResult, error)

+ type InMemoryStateStore struct

+ func NewInMemoryStateStore() *InMemoryStateStore

+ func (s *InMemoryStateStore) Delete(_ context.Context, scope StateScope, namespace, key string) error

+ func (s *InMemoryStateStore) Get(_ context.Context, scope StateScope, namespace, key string) (any, bool, error)

+ func (s *InMemoryStateStore) List(_ context.Context, scope StateScope, namespace string) (map[string]any, error)

+ func (s *InMemoryStateStore) Set(_ context.Context, scope StateScope, namespace, key string, value any) error

+ type Invocation struct

+ Attempt int

+ ComponentName string

+ ComponentType ComponentType

+ ID string

+ Input []byte

+ IsStreaming bool

+ LeaseID string

+ Metadata map[string]string

+ RunID string

+ StreamFallback bool

+ type InvocationResult struct

+ Events []Event

+ LeaseID string

+ Metadata map[string]string

+ Output []byte

+ type KVMemory struct

+ func (m *KVMemory) Delete(ctx context.Context, key string) error

+ func (m *KVMemory) Get(ctx context.Context, key string) (any, error)

+ func (m *KVMemory) List(ctx context.Context) (map[string]any, error)

+ func (m *KVMemory) Set(ctx context.Context, key string, value any) error

+ type LanguageModel interface

+ Generate func(ctx context.Context, request GenerateRequest) (GenerateResponse, error)

+ type ListFilesResult struct

+ Files []FileInfo

+ Path string

+ type Logger struct

+ func (l *Logger) Debug(message string, keyvals ...any)

+ func (l *Logger) Error(message string, keyvals ...any)

+ func (l *Logger) Info(message string, keyvals ...any)

+ func (l *Logger) Warn(message string, keyvals ...any)

+ type MCPCallToolResult struct

+ Content []map[string]any

+ IsError bool

+ Raw map[string]any

+ type MCPClient struct

+ func NewMCPClient(transport MCPTransport) (*MCPClient, error)

+ func (c *MCPClient) CallTool(ctx context.Context, name string, arguments map[string]any) (MCPCallToolResult, error)

+ func (c *MCPClient) Close() error

+ func (c *MCPClient) ListTools(ctx context.Context) ([]MCPTool, error)

+ type MCPResource struct

+ Description string

+ MimeType string

+ Name string

+ URI string

+ type MCPTool struct

+ Description string

+ InputSchema map[string]any

+ Name string

+ type MCPTransport interface

+ Close func() error

+ Request func(ctx context.Context, method string, params any) (map[string]any, error)

+ type MemoryAccessor struct

+ func NewMemoryAccessor(store StateStore, ctx MemoryContext) *MemoryAccessor

+ func (m *MemoryAccessor) Conversation() *ConversationMemory

+ func (m *MemoryAccessor) KV(scope MemoryScope) *KVMemory

+ func (m *MemoryAccessor) Working() *WorkingMemory

+ type MemoryContext struct

+ RunID string

+ SessionID string

+ UserID string

+ type MemoryMessage struct

+ Content string

+ CreatedAt time.Time

+ Metadata map[string]any

+ Role string

+ type MemoryResult struct

+ Key string

+ Metadata map[string]any

+ Score float64

+ Value any

+ type MemoryScope string

+ const MemoryScopeGlobal

+ const MemoryScopeRun

+ const MemoryScopeSession

+ const MemoryScopeUser

+ type Message struct

+ Content string

+ Name string

+ Role MessageRole

+ ToolCallID string

+ ToolCalls []ToolCall

+ type MessageRole string

+ const MessageRoleAssistant

+ const MessageRoleSystem

+ const MessageRoleTool

+ const MessageRoleUser

+ type ModelStreamChunk struct

+ Arguments map[string]any

+ ArgumentsDelta string

+ Content string

+ Index int

+ ToolCallID string

+ ToolName string

+ Type ModelStreamChunkType

+ type ModelStreamChunkType string

+ const ModelStreamMessageDelta

+ const ModelStreamMessageStart

+ const ModelStreamMessageStop

+ const ModelStreamToolCallDelta

+ const ModelStreamToolCallStart

+ const ModelStreamToolCallStop

+ type OpenAIConfig struct

+ APIKey string

+ APIKeyHeader string

+ AuthScheme string

+ BaseURL string

+ HTTPClient *http.Client

+ Headers map[string]string

+ Model string

+ Organization string

+ Path string

+ type OpenAIModel struct

+ func NewAzureOpenAIModel(config AzureOpenAIConfig) *OpenAIModel

+ func NewDeepSeekModel(config OpenAIConfig) *OpenAIModel

+ func NewGroqModel(config OpenAIConfig) *OpenAIModel

+ func NewMistralModel(config OpenAIConfig) *OpenAIModel

+ func NewMoonshotModel(config OpenAIConfig) *OpenAIModel

+ func NewOllamaModel(config OpenAIConfig) *OpenAIModel

+ func NewOpenAIModel(config OpenAIConfig) *OpenAIModel

+ func NewOpenRouterModel(config OpenAIConfig) *OpenAIModel

+ func NewTogetherModel(config OpenAIConfig) *OpenAIModel

+ func NewXAIModel(config OpenAIConfig) *OpenAIModel

+ func (m *OpenAIModel) Generate(ctx context.Context, request GenerateRequest) (GenerateResponse, error)

+ type PromptCache struct

+ Enabled bool

+ Key string

+ Resource string

+ Retention string

+ TTL string

+ func EnablePromptCache() *PromptCache

+ func PromptCacheResource(name string) *PromptCache

+ func PromptCacheWithTTL(ttl string) *PromptCache

+ type ReadFileResult struct

+ Content []byte

+ Path string

+ type ReceivedEvent struct

+ ContentIndex int

+ Data map[string]any

+ EventType string

+ RunID string

+ Sequence int

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) ComponentInfos() []ComponentInfo

+ func (r *Registry) Get(name string) (Component, bool)

+ func (r *Registry) List() []Component

+ func (r *Registry) Register(component Component) error

+ type ResumeWorkflowResponse struct

+ Offset int64

+ Raw map[string]any

+ RunID string

+ Status string

+ type RunCommandResult struct

+ ExitCode int

+ Stderr string

+ Stdout string

+ type RunError struct

+ Attempts int

+ ErrorCode string

+ MaxAttempts int

+ Message string

+ Metadata map[string]any

+ RunID string

+ func (e *RunError) Error() string

+ func (e *RunError) ExhaustedRetries() bool

+ func (e *RunError) WasRetried() bool

+ type RunErrorDetail struct

+ Code string

+ Details map[string]any

+ Message string

+ type RunEvent struct

+ CorrelationID string

+ CreatedAt *time.Time

+ Data json.RawMessage

+ EventType string

+ ID string

+ InputData json.RawMessage

+ Metadata map[string]any

+ OutputData json.RawMessage

+ ParentCorrelationID string

+ ParentEventID string

+ Raw map[string]any

+ RunID string

+ StepKey string

+ TimestampNS int64

+ TraceID string

+ type RunOption func(*runConfig)

+ func WithRunComponentType(componentType ComponentType) RunOption

+ func WithRunHeader(key, value string) RunOption

+ func WithRunHeaders(headers map[string]string) RunOption

+ func WithRunSessionID(sessionID string) RunOption

+ func WithRunTenant(tenantID string) RunOption

+ func WithRunTimeout(timeout time.Duration) RunOption

+ func WithRunUserID(userID string) RunOption

+ type RunResponse struct

+ CompletedAt *time.Time

+ Component string

+ CreatedAt *time.Time

+ DurationMS *int64

+ Error *RunErrorDetail

+ FailedAt *time.Time

+ Metadata map[string]any

+ Output json.RawMessage

+ Raw map[string]any

+ RunID string

+ SessionID string

+ StartedAt *time.Time

+ Status RunStatus

+ StatusCode int

+ TraceID string

+ func (r *RunResponse) DecodeOutput(target any) error

+ func (r *RunResponse) IsError() bool

+ func (r *RunResponse) IsPending() bool

+ func (r *RunResponse) IsSuccess() bool

+ func (r *RunResponse) RaiseForStatus() error

+ type RunStatus string

+ const RunStatusAwaitingInput

+ const RunStatusAwaitingUserInput

+ const RunStatusCancelled

+ const RunStatusCompleted

+ const RunStatusEnqueued

+ const RunStatusFailed

+ const RunStatusPaused

+ const RunStatusQueued

+ const RunStatusRunning

+ const RunStatusStarted

+ const RunStatusTimeout

+ const RunStatusUnknown

+ type SSEMCPTransport struct

+ Endpoint string

+ HTTPClient *http.Client

+ Headers map[string]string

+ func NewSSEMCPTransport(endpoint string, headers map[string]string) *SSEMCPTransport

+ func (t *SSEMCPTransport) Close() error

+ func (t *SSEMCPTransport) Request(ctx context.Context, method string, params any) (map[string]any, error)

+ type SandboxRunner interface

+ ExecuteCode func(ctx context.Context, language, code string) (ExecuteCodeResult, error)

+ ListFiles func(ctx context.Context, path string) (ListFilesResult, error)

+ ReadFile func(ctx context.Context, path string) (ReadFileResult, error)

+ RunCommand func(ctx context.Context, command []string) (RunCommandResult, error)

+ WriteFile func(ctx context.Context, path string, content []byte) (WriteFileResult, error)

+ type ScorerConfig struct

+ Description string

+ Handler ScorerHandler

+ Metadata map[string]any

+ Name string

+ func ContainsScorer() ScorerConfig

+ func ExactMatchScorer() ScorerConfig

+ type ScorerHandler func(context.Context, ScorerRequest) (ScorerResult, error)

+ type ScorerRegistry struct

+ func DefaultScorerRegistry() *ScorerRegistry

+ func NewScorerRegistry() *ScorerRegistry

+ func (r *ScorerRegistry) Clear()

+ func (r *ScorerRegistry) Get(name string) (ScorerConfig, bool)

+ func (r *ScorerRegistry) List() []ScorerConfig

+ func (r *ScorerRegistry) Register(config ScorerConfig) error

+ func (r *ScorerRegistry) Run(ctx context.Context, name string, request ScorerRequest) (ScorerResult, error)

+ type ScorerRequest struct

+ Events []RunEvent

+ Expected any

+ Input any

+ Metadata map[string]any

+ Output any

+ type ScorerResult struct

+ Explanation string

+ Label string

+ Metadata map[string]any

+ Passed bool

+ Score float64

+ type ScriptedModel struct

+ Responses []GenerateResponse

+ func (m *ScriptedModel) Generate(_ context.Context, request GenerateRequest) (GenerateResponse, error)

+ type ServerConfig struct

+ Args []string

+ Command string

+ Env map[string]string

+ Name string

+ Transport TransportType

+ URL string

+ type SessionProxy struct

+ func (p *SessionProxy) Run(ctx context.Context, component string, input any, opts ...RunOption) (*RunResponse, error)

+ func (p *SessionProxy) WithUser(userID string) *SessionProxy

+ func (p *SessionProxy) Workflow(name string) *SessionWorkflowProxy

+ type SessionWorkflowProxy struct

+ func (p *SessionWorkflowProxy) Run(ctx context.Context, input any, opts ...RunOption) (*RunResponse, error)

+ type StateManager struct

+ func NewStateManager(store StateStore, scope StateScope, namespace string) *StateManager

+ func (s *StateManager) Delete(ctx context.Context, key string) error

+ func (s *StateManager) Get(ctx context.Context, key string) (any, error)

+ func (s *StateManager) GetString(ctx context.Context, key string) (string, error)

+ func (s *StateManager) List(ctx context.Context) (map[string]any, error)

+ func (s *StateManager) Scope(scope StateScope, namespace string) *StateManager

+ func (s *StateManager) Set(ctx context.Context, key string, value any) error

+ type StateScope string

+ const StateScopeGlobal

+ const StateScopeRun

+ const StateScopeSession

+ const StateScopeUser

+ type StateStore interface

+ Delete func(ctx context.Context, scope StateScope, namespace, key string) error

+ Get func(ctx context.Context, scope StateScope, namespace, key string) (any, bool, error)

+ List func(ctx context.Context, scope StateScope, namespace string) (map[string]any, error)

+ Set func(ctx context.Context, scope StateScope, namespace, key string, value any) error

+ type StaticMCPTransport struct

+ Responses map[string]map[string]any

+ func (t StaticMCPTransport) Close() error

+ func (t StaticMCPTransport) Request(_ context.Context, method string, _ any) (map[string]any, error)

+ type StaticModel struct

+ Content string

+ Model string

+ ToolCalls []ToolCall

+ func (m StaticModel) Generate(_ context.Context, request GenerateRequest) (GenerateResponse, error)

+ type StatusResponse struct

+ CompletedAt *time.Time

+ Component string

+ CreatedAt *time.Time

+ Metadata map[string]any

+ Raw map[string]any

+ RunID string

+ StartedAt *time.Time

+ Status RunStatus

+ StatusCode int

+ TraceID string

+ func (r *StatusResponse) IsComplete() bool

+ func (r *StatusResponse) IsRunning() bool

+ type StdioMCPTransport struct

+ func NewStdioMCPTransport(ctx context.Context, command string, args ...string) (*StdioMCPTransport, error)

+ func NewStdioMCPTransportConfig(ctx context.Context, config ServerConfig) (*StdioMCPTransport, error)

+ func (t *StdioMCPTransport) Close() error

+ func (t *StdioMCPTransport) Request(ctx context.Context, method string, params any) (map[string]any, error)

+ type StreamMCPTransport struct

+ func NewStreamMCPTransport(rw io.ReadWriter) *StreamMCPTransport

+ func (t *StreamMCPTransport) Close() error

+ func (t *StreamMCPTransport) Request(ctx context.Context, method string, params any) (map[string]any, error)

+ type StreamingLanguageModel interface

+ Stream func(ctx context.Context, request GenerateRequest, ...) (GenerateResponse, error)

+ type SubmitLinks struct

+ SelfURL string

+ type SubmitOption func(*submitConfig)

+ func WithSubmitComponentType(componentType ComponentType) SubmitOption

+ func WithSubmitMetadata(metadata map[string]string) SubmitOption

+ func WithSubmitTenant(tenantID string) SubmitOption

+ type SubmitResponse struct

+ Component string

+ CreatedAt *time.Time

+ Links *SubmitLinks

+ Raw map[string]any

+ RunID string

+ Status RunStatus

+ StatusCode int

+ TraceID string

+ func (r *SubmitResponse) StatusURL() string

+ type TokenUsage struct

+ CacheCreationTokens int

+ CachedTokens int

+ InputTokens int

+ OutputTokens int

+ TotalTokens int

+ type Tool struct

+ Description string

+ Handler ToolHandler

+ Metadata map[string]any

+ Name string

+ Schema map[string]any

+ func NewTool(name string, handler ToolHandler, opts ...ToolOption) (Tool, error)

+ type ToolCall struct

+ Arguments map[string]any

+ ID string

+ Name string

+ Raw map[string]any

+ type ToolHandler func(context.Context, map[string]any) (any, error)

+ type ToolOption func(*Tool)

+ func WithToolDescription(description string) ToolOption

+ func WithToolMetadata(metadata map[string]any) ToolOption

+ func WithToolSchema(schema map[string]any) ToolOption

+ type ToolRegistry struct

+ func DefaultToolRegistry() *ToolRegistry

+ func NewToolRegistry() *ToolRegistry

+ func (r *ToolRegistry) CallTool(ctx context.Context, name string, input map[string]any) (any, error)

+ func (r *ToolRegistry) Clear()

+ func (r *ToolRegistry) Get(name string) (Tool, bool)

+ func (r *ToolRegistry) List() []Tool

+ func (r *ToolRegistry) Register(tool Tool) error

+ type TransportType string

+ const TransportTypeSSE

+ const TransportTypeStdio

+ type TriggerSpec struct

+ BatchWindowMS int64

+ DelayExpression string

+ EventName string

+ FilterExpression string

+ InputMapping string

+ TriggerID string

+ TriggerType string

+ func EventTrigger(name string) TriggerSpec

+ func WebhookTrigger(source, event string) TriggerSpec

+ type UserInputRequest struct

+ AllowCustom bool

+ ID string

+ Metadata map[string]any

+ Options []HITLOption

+ Prompt string

+ Skippable bool

+ Type HITLInputType

+ type WaitingForUserInputError struct

+ Request UserInputRequest

+ func (e *WaitingForUserInputError) Error() string

+ type Worker struct

+ func NewWorker(serviceName string, opts ...WorkerOption) *Worker

+ func (w *Worker) Components() []ComponentInfo

+ func (w *Worker) CoordinatorEndpoint() string

+ func (w *Worker) DeploymentID() string

+ func (w *Worker) EngineEndpoint() string

+ func (w *Worker) MaxConcurrency() uint32

+ func (w *Worker) Metadata() map[string]string

+ func (w *Worker) ProjectID() string

+ func (w *Worker) Registry() *Registry

+ func (w *Worker) Run(ctx context.Context) error

+ func (w *Worker) ServiceName() string

+ func (w *Worker) ServiceType() string

+ func (w *Worker) ServiceVersion() string

+ func (w *Worker) WorkerID() string

+ func (w *Worker) WorkerMode() WorkerMode

+ type WorkerMode string

+ const WorkerModePull

+ const WorkerModePush

+ type WorkerOption func(*Worker)

+ func WithCoordinatorEndpoint(endpoint string) WorkerOption

+ func WithDeploymentID(deploymentID string) WorkerOption

+ func WithEngineEndpoint(endpoint string) WorkerOption

+ func WithMaxConcurrency(maxConcurrency uint32) WorkerOption

+ func WithMaxReconnects(maxReconnects uint32) WorkerOption

+ func WithMetadata(metadata map[string]string) WorkerOption

+ func WithProjectID(projectID string) WorkerOption

+ func WithReconnectBackoff(initial, max time.Duration) WorkerOption

+ func WithServiceType(serviceType string) WorkerOption

+ func WithServiceVersion(version string) WorkerOption

+ func WithStateStore(store StateStore) WorkerOption

+ func WithWorkerID(workerID string) WorkerOption

+ func WithWorkerMode(mode WorkerMode) WorkerOption

+ type WorkflowProxy struct

+ func (p *WorkflowProxy) Run(ctx context.Context, input any, opts ...RunOption) (*RunResponse, error)

+ func (p *WorkflowProxy) Submit(ctx context.Context, input any, opts ...SubmitOption) (*SubmitResponse, error)

+ type WorkingMemory struct

+ func (m *WorkingMemory) Get(ctx context.Context) (string, error)

+ func (m *WorkingMemory) Set(ctx context.Context, value string) error

+ type WriteFileResult struct

+ Bytes int

+ Path string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL