Documentation
¶
Overview ¶
Package agui implements the supported AG-UI 1.0 chat boundary. Schema pin: ag-ui-protocol/ag-ui@e60019d258cf43ecc5ad19e8d374f1c31cbf2b94, spec/1.0/schema.json; matching @ag-ui/core version 1.0.1.
Code generated by internal/generate/generate.py; DO NOT EDIT.
Index ¶
- Constants
- func EncodeCapabilities(value *WireAgentCapabilities) ([]byte, error)
- func EncodeEvent(value *WireEvent) ([]byte, error)
- func EncodeInput(value *WireRunAgentInput) ([]byte, error)
- func ProtocolToolCallID(nativeTurnID, nativeOpID string) string
- func PublishStandard(ctx context.Context, publisher streaming.Publisher, event *WireEvent) error
- func ToolStatusPending(status string) bool
- func ValidateCapabilities(data []byte) error
- func ValidateEvent(data []byte) error
- func ValidateInput(data []byte) error
- func ValidateMessage(data []byte) error
- type AgentCapabilities
- type AttachmentRef
- type CapabilitiesValue
- type Context
- type Event
- type ExecutionPayload
- type Extension
- type FeedLifecycleFact
- type FeedLifecycleOrigin
- type ForwardedProps
- type Message
- type Outcome
- type ProgressValue
- type QueueValue
- type RunAgentInput
- type Tool
- type Translator
- func (t *Translator) ActiveInvocations() []requestctx.Invocation
- func (t *Translator) CompleteText(id, content string) []Event
- func (t *Translator) Done() bool
- func (t *Translator) EmitNativeUserIdentity(nativeTurnID, clientMessageID, nativeUserMessageID string) ([]Event, error)
- func (t *Translator) EmitStandard(event *WireEvent) ([]Event, error)
- func (t *Translator) Fail(message, code string) []Event
- func (t *Translator) Finish(outcome string) []Event
- func (t *Translator) HasText() bool
- func (t *Translator) HasToolCall(nativeTurnID, nativeCallID string) bool
- func (t *Translator) HasToolResult(publicToolCallID string) bool
- func (t *Translator) InvocationReturned(result requestctx.InvocationResult) []Event
- func (t *Translator) ReconcileApprovalReceipt(nativeTurnID, toolCallID string, snapshot, result *WireEvent) ([]Event, error)
- func (t *Translator) ReconcileSubagentEvent(invocation requestctx.Invocation, event *WireEvent) ([]Event, error)
- func (t *Translator) RecoverableInvocations() []requestctx.Invocation
- func (t *Translator) RegisterInvocation(invocation requestctx.Invocation) []Event
- func (t *Translator) SeedMessages(messages []json.RawMessage) error
- func (t *Translator) SetNativeIdentity(nativeTurnID string) error
- func (t *Translator) Start() []Event
- func (t *Translator) String() string
- func (t *Translator) SubagentHasText(invocationID string) bool
- func (t *Translator) Translate(e *streaming.Event) []Event
- func (t *Translator) TranslateSubagent(invocation requestctx.Invocation, e *streaming.Event) []Event
- type WireActivityDeltaEvent
- type WireActivityMessage
- type WireActivitySnapshotEvent
- type WireAddOperation
- type WireAgentCapabilities
- type WireAssistantMessage
- type WireAttributable
- type WireAudioPart
- type WireBaseEvent
- type WireBaseMessage
- type WireContentPart
- type WireContext
- type WireCopyOperation
- type WireCustomEvent
- type WireDataSource
- type WireDeveloperMessage
- type WireDocumentPart
- type WireEvent
- type WireEventType
- type WireExecutionCapabilities
- type WireFileSource
- type WireFunctionCall
- type WireHumanInTheLoopCapabilities
- type WireIdentityCapabilities
- type WireImagePart
- type WireInterrupt
- type WireJsonPatch
- type WireJsonPatchOperation
- type WireJsonPointer
- type WireMessage
- type WireMessagesSnapshotEvent
- type WireMetadata
- type WireMoveOperation
- type WireMultiAgentCapabilities
- type WireMultimodalCapabilities
- type WireMultimodalInputCapabilities
- type WireMultimodalOutputCapabilities
- type WireOutputCapabilities
- type WirePartSource
- type WireRawEvent
- type WireReasoningCapabilities
- type WireReasoningEncryptedValueEvent
- type WireReasoningEncryptedValueSubtype
- type WireReasoningEndEvent
- type WireReasoningMessage
- type WireReasoningMessageChunkEvent
- type WireReasoningMessageContentEvent
- type WireReasoningMessageEndEvent
- type WireReasoningMessageStartEvent
- type WireReasoningStartEvent
- type WireRemoveOperation
- type WireReplaceOperation
- type WireResumeEntry
- type WireRole
- type WireRunAgentInput
- type WireRunErrorEvent
- type WireRunFinishedCancelledOutcome
- type WireRunFinishedEvent
- type WireRunFinishedInterruptOutcome
- type WireRunFinishedOutcome
- type WireRunFinishedSuccessOutcome
- type WireRunStartedEvent
- type WireState
- type WireStateCapabilities
- type WireStateDeltaEvent
- type WireStateSnapshotEvent
- type WireStepFinishedEvent
- type WireStepStartedEvent
- type WireSubagentErrorEvent
- type WireSubagentFinishedEvent
- type WireSubagentFinishedOutcome
- type WireSubagentFinishedSuccessOutcome
- type WireSubagentFinishedSuspendedOutcome
- type WireSubagentInfo
- type WireSubagentRunId
- type WireSubagentStartedEvent
- type WireSystemMessage
- type WireTestOperation
- type WireTextMessageChunkEvent
- type WireTextMessageContentEvent
- type WireTextMessageEndEvent
- type WireTextMessageRole
- type WireTextMessageStartEvent
- type WireTextPart
- type WireTokenUsage
- type WireTool
- type WireToolCall
- type WireToolCallArgsEvent
- type WireToolCallChunkEvent
- type WireToolCallEndEvent
- type WireToolCallResultEvent
- type WireToolCallResultEventContent
- type WireToolCallResultEventContentVariant1
- type WireToolCallResultEventContentVariant2
- type WireToolCallStartEvent
- type WireToolMessage
- type WireToolMessageContent
- type WireToolMessageContentVariant1
- type WireToolMessageContentVariant2
- type WireToolsCapabilities
- type WireTransportCapabilities
- type WireUrlSource
- type WireUserMessage
- type WireUserMessageContent
- type WireUserMessageContentVariant1
- type WireUserMessageContentVariant2
- type WireVideoPart
Constants ¶
const ExtensionVersion = "1"
const ProtocolVersion = "1.0"
Variables ¶
This section is empty.
Functions ¶
func EncodeCapabilities ¶
func EncodeCapabilities(value *WireAgentCapabilities) ([]byte, error)
EncodeCapabilities validates the exact typed discovery descriptor.
func EncodeEvent ¶
EncodeEvent validates a constructed typed event before it reaches transport. A union's pointer choice does not replace its required wire discriminator.
func EncodeInput ¶
func EncodeInput(value *WireRunAgentInput) ([]byte, error)
EncodeInput checks producer-side requiredness and optional non-null values.
func ProtocolToolCallID ¶
ProtocolToolCallID scopes a native op id to its stable logical turn. A resumed turn keeps the same alias even when its external protocol run id changes.
func PublishStandard ¶
PublishStandard is an explicit runtime bridge for a true standard event. Its parent conversation and turn come from trusted execution context.
func ToolStatusPending ¶
ToolStatusPending identifies native tool states that have not produced an execution result, even when a queue presentation payload is already stored.
func ValidateCapabilities ¶
ValidateCapabilities preserves the difference between omitted and false.
func ValidateEvent ¶
ValidateEvent enforces every field of all 31 event variants against the pin.
func ValidateInput ¶
ValidateInput checks the exact pinned wire schema before decoding into the supported profile's Go types. Optional null values and unknown fields are rejected according to AG-UI 1.0, including nested union message shapes.
func ValidateMessage ¶
ValidateMessage validates all roles and multimodal source variants.
Types ¶
type AgentCapabilities ¶
type AttachmentRef ¶
type AttachmentRef struct {
Name string `json:"name,omitempty"`
URI string `json:"uri"`
Mime string `json:"mime,omitempty"`
StagingFolder string `json:"stagingFolder,omitempty"`
}
AttachmentRef references files admitted by the existing authenticated file service. Binary contents use the standard content model or file transfer API.
type CapabilitiesValue ¶
type CapabilitiesValue struct {
Version string `json:"version"`
Capabilities AgentCapabilities `json:"capabilities"`
}
type Event ¶
type Event struct {
// Standard carries a validated full event variant while retaining the legacy producer API.
Standard json.RawMessage `json:"-"`
Type string `json:"type"`
Timestamp int64 `json:"timestamp,omitempty"`
ThreadID string `json:"threadId,omitempty"`
RunID string `json:"runId,omitempty"`
ProtocolVersion string `json:"protocolVersion,omitempty"`
MessageID string `json:"messageId,omitempty"`
Role string `json:"role,omitempty"`
Delta string `json:"delta,omitempty"`
ToolCallID string `json:"toolCallId,omitempty"`
ToolCallName string `json:"toolCallName,omitempty"`
ParentMessageID string `json:"parentMessageId,omitempty"`
Content *string `json:"content,omitempty"`
Message string `json:"message,omitempty"`
Code string `json:"code,omitempty"`
Outcome *Outcome `json:"outcome,omitempty"`
Name string `json:"name,omitempty"`
Value any `json:"value,omitempty"`
// contains filtered or unexported fields
}
Event is the producer's supported event union. Only the fields belonging to the event discriminator are populated; schema-1.0.json is the wire authority.
func StandardEvent ¶
func StandardEvent(raw json.RawMessage) (Event, error)
func (Event) MarshalJSON ¶
func (*Event) UnmarshalJSON ¶
UnmarshalJSON retains the complete standard variant while populating the original convenience fields when their types match. In particular STATE_DELTA arrays and multipart tool results must not fail decoding into the producer's older string convenience fields. Full typed access is available via DecodeEvent.
type ExecutionPayload ¶
type ExecutionPayload struct {
AgentID string `json:"agentId,omitempty"`
Model string `json:"model,omitempty"`
BackendTools []string `json:"backendTools,omitempty"`
ToolBundles []string `json:"toolBundles,omitempty"`
AutoSelectTools *bool `json:"autoSelectTools,omitempty"`
AutoSummarize *bool `json:"autoSummarize,omitempty"`
DisableChains *bool `json:"disableChains,omitempty"`
AllowedChains []string `json:"allowedChains,omitempty"`
ResourceURIs []string `json:"resourceURIs,omitempty"`
ToolCallExposure *string `json:"toolCallExposure,omitempty"`
UseServerState *bool `json:"useServerState,omitempty"`
ReasoningEffort *string `json:"reasoningEffort,omitempty"`
DisplayQuery *string `json:"displayQuery,omitempty"`
Context json.RawMessage `json:"context,omitempty"`
Attachments []AttachmentRef `json:"attachments,omitempty"`
}
type Extension ¶
type Extension struct {
Version string `json:"version"`
Operation string `json:"operation"`
RequestID string `json:"requestId,omitempty"`
Payload *ExecutionPayload `json:"payload,omitempty"`
}
type FeedLifecycleFact ¶
type FeedLifecycleFact struct {
Active bool
At time.Time
Origin *FeedLifecycleOrigin
Journal *FeedLifecycleOrigin
Inherited bool
}
func ReadFeedLifecycleFact ¶
func ReadFeedLifecycleFact(raw json.RawMessage, threadID, feedID string, journalRunID ...string) (FeedLifecycleFact, bool)
ReadFeedLifecycleFact accepts only explicit version-one lifecycle booleans. A retained feed payload or event emission timestamp is not lifecycle evidence.
func ValidateFeedLifecycleSources ¶
func ValidateFeedLifecycleSources(facts []FeedLifecycleFact) []FeedLifecycleFact
ValidateFeedLifecycleSources is called only after a complete principal/thread snapshot. A claimed source must match an actual original fact in that snapshot. Foreign/missing sources lose sequence authority; their timestamps are unchanged.
type FeedLifecycleOrigin ¶
FeedLifecycleOrigin identifies an original journal fact, never a refresh's position. It becomes ordering authority only after scoped journal validation.
type ForwardedProps ¶
type ForwardedProps struct {
Agently *Extension `json:"agently,omitempty"`
}
type Message ¶
type Message struct {
ActivityType string `json:"activityType,omitempty"`
EncryptedValue *string `json:"encryptedValue,omitempty"`
SubagentRunID *string `json:"subagentRunId,omitempty"`
ID string `json:"id"`
Role string `json:"role"`
Content json.RawMessage `json:"content,omitempty"`
Name string `json:"name,omitempty"`
ToolCallID string `json:"toolCallId,omitempty"`
ToolCalls json.RawMessage `json:"toolCalls,omitempty"`
Metadata json.RawMessage `json:"metadata,omitempty"`
Error *string `json:"error,omitempty"`
// contains filtered or unexported fields
}
Content remains raw to preserve and reject unsupported multimodal inputs at the HTTP boundary without silently coercing them into chat text.
func (Message) MarshalJSON ¶
func (*Message) UnmarshalJSON ¶
Message keeps the complete schema-validated snapshot while retaining the convenient fields used by native boundary code. Unknown optional standard fields and explicitly empty optional values must not disappear on a resume.
type ProgressValue ¶
type ProgressValue struct {
Version string `json:"version"`
Kind string `json:"kind"`
MessageID string `json:"messageId,omitempty"`
ToolCallID string `json:"toolCallId,omitempty"`
Status string `json:"status,omitempty"`
Content string `json:"content,omitempty"`
Source string `json:"source,omitempty"`
}
type QueueValue ¶
type RunAgentInput ¶
type RunAgentInput struct {
ThreadID string `json:"threadId"`
RunID string `json:"runId"`
ProtocolVersion string `json:"protocolVersion,omitempty"`
ParentRunID string `json:"parentRunId,omitempty"`
State json.RawMessage `json:"state,omitempty"`
Messages []Message `json:"messages"`
Tools []Tool `json:"tools,omitempty"`
Context []Context `json:"context,omitempty"`
ForwardedProps json.RawMessage `json:"forwardedProps,omitempty"`
Resume json.RawMessage `json:"resume,omitempty"`
}
type Tool ¶
type Tool struct {
Name string `json:"name"`
Description string `json:"description"`
Parameters json.RawMessage `json:"parameters"`
Metadata json.RawMessage `json:"metadata,omitempty"`
}
type Translator ¶
type Translator struct {
// contains filtered or unexported fields
}
Translator is run-scoped and must be used by one ordered stream consumer. Correlation and authorization of internal turn events belongs to the handler.
func NewTranslator ¶
func NewTranslator(threadID, runID string) *Translator
func RestoreTranslator ¶
func RestoreTranslator(threadID, runID string, events []json.RawMessage) (*Translator, error)
RestoreTranslator restores producer sequencing and its full message graph from a validated durable journal. It emits nothing and never runs an agent. Native sequence replay filtering still belongs to the worker's saved cursor.
func (*Translator) ActiveInvocations ¶
func (t *Translator) ActiveInvocations() []requestctx.Invocation
func (*Translator) CompleteText ¶
func (t *Translator) CompleteText(id, content string) []Event
CompleteText is useful for synchronous preset answers without bus text events.
func (*Translator) Done ¶
func (t *Translator) Done() bool
func (*Translator) EmitNativeUserIdentity ¶
func (t *Translator) EmitNativeUserIdentity(nativeTurnID, clientMessageID, nativeUserMessageID string) ([]Event, error)
EmitNativeUserIdentity is a restricted trusted producer, not the generic runtime ProtocolEvent bridge. It binds identity to this translator's native run.
func (*Translator) EmitStandard ¶
func (t *Translator) EmitStandard(event *WireEvent) ([]Event, error)
EmitStandard is the explicit bridge for runtime producers of standard RAW, ACTIVITY_DELTA, chunks, state, reasoning and extension events. It validates the true standard variant and never relabels native implementation events as RAW.
func (*Translator) Fail ¶
func (t *Translator) Fail(message, code string) []Event
func (*Translator) Finish ¶
func (t *Translator) Finish(outcome string) []Event
func (*Translator) HasText ¶
func (t *Translator) HasText() bool
HasText reports whether the stream has emitted assistant text. A handler can use it to avoid repeating a synchronous answer under a second message ID.
func (*Translator) HasToolCall ¶
func (t *Translator) HasToolCall(nativeTurnID, nativeCallID string) bool
HasToolCall checks the run graph, including calls authored by descendants.
func (*Translator) HasToolResult ¶
func (t *Translator) HasToolResult(publicToolCallID string) bool
HasToolResult reports an authoritative receipt or emitted result by public protocol tool-call ID. Historical calls are not current-run open lanes.
func (*Translator) InvocationReturned ¶
func (t *Translator) InvocationReturned(result requestctx.InvocationResult) []Event
InvocationReturned carries the real Query return status. Preset success has completion evidence even without a bus terminal. A queued return stays open.
func (*Translator) ReconcileApprovalReceipt ¶
func (t *Translator) ReconcileApprovalReceipt(nativeTurnID, toolCallID string, snapshot, result *WireEvent) ([]Event, error)
ReconcileApprovalReceipt is the native inspector's restricted publication seam. It permits validated authoritative snapshots and the receipt for one already-known tool bound to this native turn; generic producers remain unable to forge server-owned presentation or invocation metadata.
func (*Translator) ReconcileSubagentEvent ¶
func (t *Translator) ReconcileSubagentEvent(invocation requestctx.Invocation, event *WireEvent) ([]Event, error)
ReconcileSubagentEvent is the native inspector's restricted recovery seam. Unlike the generic ProtocolEvent bridge it can retain already-authenticated presentation metadata in snapshots/results. Registration remains authoritative.
func (*Translator) RecoverableInvocations ¶
func (t *Translator) RecoverableInvocations() []requestctx.Invocation
RecoverableInvocations includes registered native work whose first event may not have reached the observer; it makes no claim that execution has started.
func (*Translator) RegisterInvocation ¶
func (t *Translator) RegisterInvocation(invocation requestctx.Invocation) []Event
RegisterInvocation records causal linkage without claiming execution has started. Detached work belongs to an independent protocol run with parentRunId.
func (*Translator) SeedMessages ¶
func (t *Translator) SeedMessages(messages []json.RawMessage) error
SeedMessages installs the authoritative full message graph before native run events. Replacement snapshots preserve every role, tool, media part, metadata and opaque continuation value in this graph.
func (*Translator) SetNativeIdentity ¶
func (t *Translator) SetNativeIdentity(nativeTurnID string) error
SetNativeIdentity enables production aliases before the run starts. Prototype callers retain raw ids unless they explicitly opt in.
func (*Translator) Start ¶
func (t *Translator) Start() []Event
func (*Translator) String ¶
func (t *Translator) String() string
func (*Translator) SubagentHasText ¶
func (t *Translator) SubagentHasText(invocationID string) bool
SubagentHasText reports whether this causally registered invocation already emitted text, allowing a preset return to provide fallback content once.
func (*Translator) TranslateSubagent ¶
func (t *Translator) TranslateSubagent(invocation requestctx.Invocation, e *streaming.Event) []Event
TranslateSubagent consumes only a causally registered invocation's real native turn. Linking or queuing does not imply that the child has started/completed.
type WireActivityDeltaEvent ¶
type WireActivityDeltaEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
MessageID string `json:"messageId"`
ActivityType string `json:"activityType"`
Patch WireJsonPatch `json:"patch"`
}
func (*WireActivityDeltaEvent) UnmarshalJSON ¶
func (v *WireActivityDeltaEvent) UnmarshalJSON(data []byte) error
type WireActivityMessage ¶
type WireActivityMessage struct {
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
ID string `json:"id"`
Role string `json:"role"`
ActivityType string `json:"activityType"`
Content map[string]json.RawMessage `json:"content"`
Metadata *WireMetadata `json:"metadata,omitempty"`
}
type WireActivitySnapshotEvent ¶
type WireActivitySnapshotEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
MessageID string `json:"messageId"`
ActivityType string `json:"activityType"`
Content map[string]json.RawMessage `json:"content"`
Replace *bool `json:"replace,omitempty"`
}
func (*WireActivitySnapshotEvent) UnmarshalJSON ¶
func (v *WireActivitySnapshotEvent) UnmarshalJSON(data []byte) error
type WireAddOperation ¶
type WireAddOperation struct {
Op string `json:"op"`
Path WireJsonPointer `json:"path"`
Value json.RawMessage `json:"value"`
Extra map[string]json.RawMessage `json:"-"`
}
func (WireAddOperation) MarshalJSON ¶
func (v WireAddOperation) MarshalJSON() ([]byte, error)
func (*WireAddOperation) UnmarshalJSON ¶
func (v *WireAddOperation) UnmarshalJSON(data []byte) error
type WireAgentCapabilities ¶
type WireAgentCapabilities struct {
Identity *WireIdentityCapabilities `json:"identity,omitempty"`
Transport *WireTransportCapabilities `json:"transport,omitempty"`
Tools *WireToolsCapabilities `json:"tools,omitempty"`
Output *WireOutputCapabilities `json:"output,omitempty"`
State *WireStateCapabilities `json:"state,omitempty"`
MultiAgent *WireMultiAgentCapabilities `json:"multiAgent,omitempty"`
Reasoning *WireReasoningCapabilities `json:"reasoning,omitempty"`
Multimodal *WireMultimodalCapabilities `json:"multimodal,omitempty"`
Execution *WireExecutionCapabilities `json:"execution,omitempty"`
HumanInTheLoop *WireHumanInTheLoopCapabilities `json:"humanInTheLoop,omitempty"`
Custom *map[string]json.RawMessage `json:"custom,omitempty"`
}
func DecodeCapabilities ¶
func DecodeCapabilities(data []byte) (*WireAgentCapabilities, error)
DecodeCapabilities returns the complete typed capability descriptor. Pointer fields distinguish an omitted (unknown) capability from an explicit false.
type WireAssistantMessage ¶
type WireAssistantMessage struct {
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
ID string `json:"id"`
Role string `json:"role"`
Name *string `json:"name,omitempty"`
EncryptedValue *string `json:"encryptedValue,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
Content *string `json:"content,omitempty"`
ToolCalls *[]WireToolCall `json:"toolCalls,omitempty"`
}
type WireAttributable ¶
type WireAttributable struct {
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
}
type WireAudioPart ¶
type WireAudioPart struct {
Type string `json:"type"`
ID *string `json:"id,omitempty"`
Source WirePartSource `json:"source"`
Metadata *json.RawMessage `json:"metadata,omitempty"`
}
type WireBaseEvent ¶
type WireBaseEvent struct {
Type WireEventType `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
}
func (*WireBaseEvent) UnmarshalJSON ¶
func (v *WireBaseEvent) UnmarshalJSON(data []byte) error
type WireBaseMessage ¶
type WireBaseMessage struct {
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
ID string `json:"id"`
Role string `json:"role"`
Name *string `json:"name,omitempty"`
EncryptedValue *string `json:"encryptedValue,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
}
type WireContentPart ¶
type WireContentPart struct {
TextPart *WireTextPart `json:"-"`
ImagePart *WireImagePart `json:"-"`
AudioPart *WireAudioPart `json:"-"`
VideoPart *WireVideoPart `json:"-"`
DocumentPart *WireDocumentPart `json:"-"`
}
func (WireContentPart) MarshalJSON ¶
func (v WireContentPart) MarshalJSON() ([]byte, error)
func (*WireContentPart) UnmarshalJSON ¶
func (v *WireContentPart) UnmarshalJSON(data []byte) error
type WireContext ¶
type WireCopyOperation ¶
type WireCopyOperation struct {
Op string `json:"op"`
From WireJsonPointer `json:"from"`
Path WireJsonPointer `json:"path"`
Extra map[string]json.RawMessage `json:"-"`
}
func (WireCopyOperation) MarshalJSON ¶
func (v WireCopyOperation) MarshalJSON() ([]byte, error)
func (*WireCopyOperation) UnmarshalJSON ¶
func (v *WireCopyOperation) UnmarshalJSON(data []byte) error
type WireCustomEvent ¶
type WireCustomEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
Name string `json:"name"`
Value json.RawMessage `json:"value"`
}
func (*WireCustomEvent) UnmarshalJSON ¶
func (v *WireCustomEvent) UnmarshalJSON(data []byte) error
type WireDataSource ¶
type WireDeveloperMessage ¶
type WireDeveloperMessage struct {
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
ID string `json:"id"`
Role string `json:"role"`
Name *string `json:"name,omitempty"`
EncryptedValue *string `json:"encryptedValue,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
Content string `json:"content"`
}
type WireDocumentPart ¶
type WireDocumentPart struct {
Type string `json:"type"`
ID *string `json:"id,omitempty"`
Source WirePartSource `json:"source"`
Metadata *json.RawMessage `json:"metadata,omitempty"`
}
type WireEvent ¶
type WireEvent struct {
TextMessageStartEvent *WireTextMessageStartEvent `json:"-"`
TextMessageContentEvent *WireTextMessageContentEvent `json:"-"`
TextMessageEndEvent *WireTextMessageEndEvent `json:"-"`
TextMessageChunkEvent *WireTextMessageChunkEvent `json:"-"`
ToolCallStartEvent *WireToolCallStartEvent `json:"-"`
ToolCallArgsEvent *WireToolCallArgsEvent `json:"-"`
ToolCallEndEvent *WireToolCallEndEvent `json:"-"`
ToolCallChunkEvent *WireToolCallChunkEvent `json:"-"`
ToolCallResultEvent *WireToolCallResultEvent `json:"-"`
StateSnapshotEvent *WireStateSnapshotEvent `json:"-"`
StateDeltaEvent *WireStateDeltaEvent `json:"-"`
MessagesSnapshotEvent *WireMessagesSnapshotEvent `json:"-"`
ActivitySnapshotEvent *WireActivitySnapshotEvent `json:"-"`
ActivityDeltaEvent *WireActivityDeltaEvent `json:"-"`
RawEvent *WireRawEvent `json:"-"`
CustomEvent *WireCustomEvent `json:"-"`
RunStartedEvent *WireRunStartedEvent `json:"-"`
RunFinishedEvent *WireRunFinishedEvent `json:"-"`
RunErrorEvent *WireRunErrorEvent `json:"-"`
StepStartedEvent *WireStepStartedEvent `json:"-"`
StepFinishedEvent *WireStepFinishedEvent `json:"-"`
ReasoningStartEvent *WireReasoningStartEvent `json:"-"`
ReasoningMessageStartEvent *WireReasoningMessageStartEvent `json:"-"`
ReasoningMessageContentEvent *WireReasoningMessageContentEvent `json:"-"`
ReasoningMessageEndEvent *WireReasoningMessageEndEvent `json:"-"`
ReasoningMessageChunkEvent *WireReasoningMessageChunkEvent `json:"-"`
ReasoningEndEvent *WireReasoningEndEvent `json:"-"`
ReasoningEncryptedValueEvent *WireReasoningEncryptedValueEvent `json:"-"`
SubagentStartedEvent *WireSubagentStartedEvent `json:"-"`
SubagentFinishedEvent *WireSubagentFinishedEvent `json:"-"`
SubagentErrorEvent *WireSubagentErrorEvent `json:"-"`
}
func DecodeEvent ¶
DecodeEvent validates the pinned event schema and returns its typed variant. Sequence ownership and lifecycle rules must additionally be enforced by the consumer: a structurally valid content event need not have an open message.
func (WireEvent) MarshalJSON ¶
func (*WireEvent) UnmarshalJSON ¶
type WireEventType ¶
type WireEventType = string
type WireExecutionCapabilities ¶
type WireExecutionCapabilities struct {
CodeExecution *bool `json:"codeExecution,omitempty"`
Sandboxed *bool `json:"sandboxed,omitempty"`
MaxIterations *int64 `json:"maxIterations,omitempty"`
MaxExecutionTime *int64 `json:"maxExecutionTime,omitempty"`
}
func (*WireExecutionCapabilities) UnmarshalJSON ¶
func (v *WireExecutionCapabilities) UnmarshalJSON(data []byte) error
type WireFileSource ¶
type WireFunctionCall ¶
type WireHumanInTheLoopCapabilities ¶
type WireHumanInTheLoopCapabilities struct {
Supported *bool `json:"supported,omitempty"`
Approvals *bool `json:"approvals,omitempty"`
Interventions *bool `json:"interventions,omitempty"`
Feedback *bool `json:"feedback,omitempty"`
Interrupts *bool `json:"interrupts,omitempty"`
ApproveWithEdits *bool `json:"approveWithEdits,omitempty"`
}
type WireIdentityCapabilities ¶
type WireIdentityCapabilities struct {
Name *string `json:"name,omitempty"`
Type *string `json:"type,omitempty"`
Description *string `json:"description,omitempty"`
Version *string `json:"version,omitempty"`
Provider *string `json:"provider,omitempty"`
DocumentationURL *string `json:"documentationUrl,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
}
type WireImagePart ¶
type WireImagePart struct {
Type string `json:"type"`
ID *string `json:"id,omitempty"`
Source WirePartSource `json:"source"`
Metadata *json.RawMessage `json:"metadata,omitempty"`
}
type WireInterrupt ¶
type WireInterrupt struct {
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
ID string `json:"id"`
Reason string `json:"reason"`
Message *string `json:"message,omitempty"`
ToolCallID *string `json:"toolCallId,omitempty"`
ResponseSchema *map[string]json.RawMessage `json:"responseSchema,omitempty"`
ExpiresAt *string `json:"expiresAt,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
}
type WireJsonPatch ¶
type WireJsonPatch = []WireJsonPatchOperation
type WireJsonPatchOperation ¶
type WireJsonPatchOperation struct {
AddOperation *WireAddOperation `json:"-"`
RemoveOperation *WireRemoveOperation `json:"-"`
ReplaceOperation *WireReplaceOperation `json:"-"`
MoveOperation *WireMoveOperation `json:"-"`
CopyOperation *WireCopyOperation `json:"-"`
TestOperation *WireTestOperation `json:"-"`
}
func (WireJsonPatchOperation) MarshalJSON ¶
func (v WireJsonPatchOperation) MarshalJSON() ([]byte, error)
func (*WireJsonPatchOperation) UnmarshalJSON ¶
func (v *WireJsonPatchOperation) UnmarshalJSON(data []byte) error
type WireJsonPointer ¶
type WireJsonPointer = string
type WireMessage ¶
type WireMessage struct {
DeveloperMessage *WireDeveloperMessage `json:"-"`
SystemMessage *WireSystemMessage `json:"-"`
AssistantMessage *WireAssistantMessage `json:"-"`
UserMessage *WireUserMessage `json:"-"`
ToolMessage *WireToolMessage `json:"-"`
ActivityMessage *WireActivityMessage `json:"-"`
ReasoningMessage *WireReasoningMessage `json:"-"`
}
func (WireMessage) MarshalJSON ¶
func (v WireMessage) MarshalJSON() ([]byte, error)
func (*WireMessage) UnmarshalJSON ¶
func (v *WireMessage) UnmarshalJSON(data []byte) error
type WireMessagesSnapshotEvent ¶
type WireMessagesSnapshotEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
Messages []WireMessage `json:"messages"`
}
func (*WireMessagesSnapshotEvent) UnmarshalJSON ¶
func (v *WireMessagesSnapshotEvent) UnmarshalJSON(data []byte) error
type WireMetadata ¶
type WireMetadata map[string]json.RawMessage
type WireMoveOperation ¶
type WireMoveOperation struct {
Op string `json:"op"`
From WireJsonPointer `json:"from"`
Path WireJsonPointer `json:"path"`
Extra map[string]json.RawMessage `json:"-"`
}
func (WireMoveOperation) MarshalJSON ¶
func (v WireMoveOperation) MarshalJSON() ([]byte, error)
func (*WireMoveOperation) UnmarshalJSON ¶
func (v *WireMoveOperation) UnmarshalJSON(data []byte) error
type WireMultiAgentCapabilities ¶
type WireMultiAgentCapabilities struct {
Supported *bool `json:"supported,omitempty"`
Delegation *bool `json:"delegation,omitempty"`
Handoffs *bool `json:"handoffs,omitempty"`
Subagents *[]WireSubagentInfo `json:"subagents,omitempty"`
}
type WireMultimodalCapabilities ¶
type WireMultimodalCapabilities struct {
Input *WireMultimodalInputCapabilities `json:"input,omitempty"`
Output *WireMultimodalOutputCapabilities `json:"output,omitempty"`
}
type WireOutputCapabilities ¶
type WirePartSource ¶
type WirePartSource struct {
DataSource *WireDataSource `json:"-"`
UrlSource *WireUrlSource `json:"-"`
FileSource *WireFileSource `json:"-"`
}
func (WirePartSource) MarshalJSON ¶
func (v WirePartSource) MarshalJSON() ([]byte, error)
func (*WirePartSource) UnmarshalJSON ¶
func (v *WirePartSource) UnmarshalJSON(data []byte) error
type WireRawEvent ¶
type WireRawEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
Event json.RawMessage `json:"event"`
Source *string `json:"source,omitempty"`
}
func (*WireRawEvent) UnmarshalJSON ¶
func (v *WireRawEvent) UnmarshalJSON(data []byte) error
type WireReasoningEncryptedValueEvent ¶
type WireReasoningEncryptedValueEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
Subtype WireReasoningEncryptedValueSubtype `json:"subtype"`
EntityId string `json:"entityId"`
EncryptedValue string `json:"encryptedValue"`
}
func (*WireReasoningEncryptedValueEvent) UnmarshalJSON ¶
func (v *WireReasoningEncryptedValueEvent) UnmarshalJSON(data []byte) error
type WireReasoningEncryptedValueSubtype ¶
type WireReasoningEncryptedValueSubtype = string
type WireReasoningEndEvent ¶
type WireReasoningEndEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
MessageID string `json:"messageId"`
}
func (*WireReasoningEndEvent) UnmarshalJSON ¶
func (v *WireReasoningEndEvent) UnmarshalJSON(data []byte) error
type WireReasoningMessage ¶
type WireReasoningMessage struct {
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
ID string `json:"id"`
Role string `json:"role"`
Content string `json:"content"`
EncryptedValue *string `json:"encryptedValue,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
}
type WireReasoningMessageChunkEvent ¶
type WireReasoningMessageChunkEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
MessageID *string `json:"messageId,omitempty"`
Delta *string `json:"delta,omitempty"`
}
func (*WireReasoningMessageChunkEvent) UnmarshalJSON ¶
func (v *WireReasoningMessageChunkEvent) UnmarshalJSON(data []byte) error
type WireReasoningMessageContentEvent ¶
type WireReasoningMessageContentEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
MessageID string `json:"messageId"`
Delta string `json:"delta"`
}
func (*WireReasoningMessageContentEvent) UnmarshalJSON ¶
func (v *WireReasoningMessageContentEvent) UnmarshalJSON(data []byte) error
type WireReasoningMessageEndEvent ¶
type WireReasoningMessageEndEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
MessageID string `json:"messageId"`
}
func (*WireReasoningMessageEndEvent) UnmarshalJSON ¶
func (v *WireReasoningMessageEndEvent) UnmarshalJSON(data []byte) error
type WireReasoningMessageStartEvent ¶
type WireReasoningMessageStartEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
MessageID string `json:"messageId"`
Role string `json:"role"`
}
func (*WireReasoningMessageStartEvent) UnmarshalJSON ¶
func (v *WireReasoningMessageStartEvent) UnmarshalJSON(data []byte) error
type WireReasoningStartEvent ¶
type WireReasoningStartEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
MessageID string `json:"messageId"`
}
func (*WireReasoningStartEvent) UnmarshalJSON ¶
func (v *WireReasoningStartEvent) UnmarshalJSON(data []byte) error
type WireRemoveOperation ¶
type WireRemoveOperation struct {
Op string `json:"op"`
Path WireJsonPointer `json:"path"`
Extra map[string]json.RawMessage `json:"-"`
}
func (WireRemoveOperation) MarshalJSON ¶
func (v WireRemoveOperation) MarshalJSON() ([]byte, error)
func (*WireRemoveOperation) UnmarshalJSON ¶
func (v *WireRemoveOperation) UnmarshalJSON(data []byte) error
type WireReplaceOperation ¶
type WireReplaceOperation struct {
Op string `json:"op"`
Path WireJsonPointer `json:"path"`
Value json.RawMessage `json:"value"`
Extra map[string]json.RawMessage `json:"-"`
}
func (WireReplaceOperation) MarshalJSON ¶
func (v WireReplaceOperation) MarshalJSON() ([]byte, error)
func (*WireReplaceOperation) UnmarshalJSON ¶
func (v *WireReplaceOperation) UnmarshalJSON(data []byte) error
type WireResumeEntry ¶
type WireResumeEntry struct {
InterruptId string `json:"interruptId"`
Status string `json:"status"`
Payload *json.RawMessage `json:"payload,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
}
type WireRunAgentInput ¶
type WireRunAgentInput struct {
ThreadID string `json:"threadId"`
RunID string `json:"runId"`
ProtocolVersion *string `json:"protocolVersion,omitempty"`
ParentRunID *string `json:"parentRunId,omitempty"`
State *WireState `json:"state,omitempty"`
Messages []WireMessage `json:"messages"`
Tools *[]WireTool `json:"tools,omitempty"`
Context *[]WireContext `json:"context,omitempty"`
ForwardedProps *json.RawMessage `json:"forwardedProps,omitempty"`
Resume *[]WireResumeEntry `json:"resume,omitempty"`
}
func DecodeInput ¶
func DecodeInput(data []byte) (*WireRunAgentInput, error)
DecodeInput retains every standard input field, including multimodal message bodies, resume entries, metadata, and opaque continuation values.
type WireRunErrorEvent ¶
type WireRunErrorEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
Message string `json:"message"`
Code *string `json:"code,omitempty"`
Usage *[]WireTokenUsage `json:"usage,omitempty"`
}
func (*WireRunErrorEvent) UnmarshalJSON ¶
func (v *WireRunErrorEvent) UnmarshalJSON(data []byte) error
type WireRunFinishedCancelledOutcome ¶
type WireRunFinishedCancelledOutcome struct {
Type string `json:"type"`
}
type WireRunFinishedEvent ¶
type WireRunFinishedEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
ThreadID string `json:"threadId"`
RunID string `json:"runId"`
Result *json.RawMessage `json:"result,omitempty"`
Outcome *WireRunFinishedOutcome `json:"outcome,omitempty"`
Usage *[]WireTokenUsage `json:"usage,omitempty"`
}
func (*WireRunFinishedEvent) UnmarshalJSON ¶
func (v *WireRunFinishedEvent) UnmarshalJSON(data []byte) error
type WireRunFinishedInterruptOutcome ¶
type WireRunFinishedInterruptOutcome struct {
Type string `json:"type"`
Interrupts []WireInterrupt `json:"interrupts"`
}
type WireRunFinishedOutcome ¶
type WireRunFinishedOutcome struct {
RunFinishedSuccessOutcome *WireRunFinishedSuccessOutcome `json:"-"`
RunFinishedInterruptOutcome *WireRunFinishedInterruptOutcome `json:"-"`
RunFinishedCancelledOutcome *WireRunFinishedCancelledOutcome `json:"-"`
}
func (WireRunFinishedOutcome) MarshalJSON ¶
func (v WireRunFinishedOutcome) MarshalJSON() ([]byte, error)
func (*WireRunFinishedOutcome) UnmarshalJSON ¶
func (v *WireRunFinishedOutcome) UnmarshalJSON(data []byte) error
type WireRunStartedEvent ¶
type WireRunStartedEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
ThreadID string `json:"threadId"`
RunID string `json:"runId"`
ProtocolVersion *string `json:"protocolVersion,omitempty"`
ParentRunID *string `json:"parentRunId,omitempty"`
Input *WireRunAgentInput `json:"input,omitempty"`
}
func (*WireRunStartedEvent) UnmarshalJSON ¶
func (v *WireRunStartedEvent) UnmarshalJSON(data []byte) error
type WireState ¶
type WireState = json.RawMessage
type WireStateCapabilities ¶
type WireStateDeltaEvent ¶
type WireStateDeltaEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
Delta WireJsonPatch `json:"delta"`
}
func (*WireStateDeltaEvent) UnmarshalJSON ¶
func (v *WireStateDeltaEvent) UnmarshalJSON(data []byte) error
type WireStateSnapshotEvent ¶
type WireStateSnapshotEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
Snapshot WireState `json:"snapshot"`
}
func (*WireStateSnapshotEvent) UnmarshalJSON ¶
func (v *WireStateSnapshotEvent) UnmarshalJSON(data []byte) error
type WireStepFinishedEvent ¶
type WireStepFinishedEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
StepName string `json:"stepName"`
}
func (*WireStepFinishedEvent) UnmarshalJSON ¶
func (v *WireStepFinishedEvent) UnmarshalJSON(data []byte) error
type WireStepStartedEvent ¶
type WireStepStartedEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
StepName string `json:"stepName"`
}
func (*WireStepStartedEvent) UnmarshalJSON ¶
func (v *WireStepStartedEvent) UnmarshalJSON(data []byte) error
type WireSubagentErrorEvent ¶
type WireSubagentErrorEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID WireSubagentRunId `json:"subagentRunId"`
Message string `json:"message"`
Code *string `json:"code,omitempty"`
}
func (*WireSubagentErrorEvent) UnmarshalJSON ¶
func (v *WireSubagentErrorEvent) UnmarshalJSON(data []byte) error
type WireSubagentFinishedEvent ¶
type WireSubagentFinishedEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID WireSubagentRunId `json:"subagentRunId"`
Result *json.RawMessage `json:"result,omitempty"`
Outcome *WireSubagentFinishedOutcome `json:"outcome,omitempty"`
}
func (*WireSubagentFinishedEvent) UnmarshalJSON ¶
func (v *WireSubagentFinishedEvent) UnmarshalJSON(data []byte) error
type WireSubagentFinishedOutcome ¶
type WireSubagentFinishedOutcome struct {
SubagentFinishedSuccessOutcome *WireSubagentFinishedSuccessOutcome `json:"-"`
SubagentFinishedSuspendedOutcome *WireSubagentFinishedSuspendedOutcome `json:"-"`
}
func (WireSubagentFinishedOutcome) MarshalJSON ¶
func (v WireSubagentFinishedOutcome) MarshalJSON() ([]byte, error)
func (*WireSubagentFinishedOutcome) UnmarshalJSON ¶
func (v *WireSubagentFinishedOutcome) UnmarshalJSON(data []byte) error
type WireSubagentFinishedSuccessOutcome ¶
type WireSubagentFinishedSuccessOutcome struct {
Type string `json:"type"`
}
type WireSubagentInfo ¶
type WireSubagentRunId ¶
type WireSubagentRunId = string
type WireSubagentStartedEvent ¶
type WireSubagentStartedEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID WireSubagentRunId `json:"subagentRunId"`
Name string `json:"name"`
Description *string `json:"description,omitempty"`
ParentSubagentRunId *WireSubagentRunId `json:"parentSubagentRunId,omitempty"`
ParentToolCallId *string `json:"parentToolCallId,omitempty"`
ParentMessageID *string `json:"parentMessageId,omitempty"`
}
func (*WireSubagentStartedEvent) UnmarshalJSON ¶
func (v *WireSubagentStartedEvent) UnmarshalJSON(data []byte) error
type WireSystemMessage ¶
type WireSystemMessage struct {
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
ID string `json:"id"`
Role string `json:"role"`
Name *string `json:"name,omitempty"`
EncryptedValue *string `json:"encryptedValue,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
Content string `json:"content"`
}
type WireTestOperation ¶
type WireTestOperation struct {
Op string `json:"op"`
Path WireJsonPointer `json:"path"`
Value json.RawMessage `json:"value"`
Extra map[string]json.RawMessage `json:"-"`
}
func (WireTestOperation) MarshalJSON ¶
func (v WireTestOperation) MarshalJSON() ([]byte, error)
func (*WireTestOperation) UnmarshalJSON ¶
func (v *WireTestOperation) UnmarshalJSON(data []byte) error
type WireTextMessageChunkEvent ¶
type WireTextMessageChunkEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
MessageID *string `json:"messageId,omitempty"`
Role *WireTextMessageRole `json:"role,omitempty"`
Delta *string `json:"delta,omitempty"`
Name *string `json:"name,omitempty"`
}
func (*WireTextMessageChunkEvent) UnmarshalJSON ¶
func (v *WireTextMessageChunkEvent) UnmarshalJSON(data []byte) error
type WireTextMessageContentEvent ¶
type WireTextMessageContentEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
MessageID string `json:"messageId"`
Delta string `json:"delta"`
}
func (*WireTextMessageContentEvent) UnmarshalJSON ¶
func (v *WireTextMessageContentEvent) UnmarshalJSON(data []byte) error
type WireTextMessageEndEvent ¶
type WireTextMessageEndEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
MessageID string `json:"messageId"`
}
func (*WireTextMessageEndEvent) UnmarshalJSON ¶
func (v *WireTextMessageEndEvent) UnmarshalJSON(data []byte) error
type WireTextMessageRole ¶
type WireTextMessageRole = string
type WireTextMessageStartEvent ¶
type WireTextMessageStartEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
MessageID string `json:"messageId"`
Role *WireTextMessageRole `json:"role,omitempty"`
Name *string `json:"name,omitempty"`
}
func (*WireTextMessageStartEvent) UnmarshalJSON ¶
func (v *WireTextMessageStartEvent) UnmarshalJSON(data []byte) error
type WireTextPart ¶
type WireTextPart struct {
Type string `json:"type"`
ID *string `json:"id,omitempty"`
Text string `json:"text"`
Metadata *json.RawMessage `json:"metadata,omitempty"`
}
type WireTokenUsage ¶
type WireTokenUsage struct {
Provider *string `json:"provider,omitempty"`
Model *string `json:"model,omitempty"`
InputTokens *int64 `json:"inputTokens,omitempty"`
OutputTokens *int64 `json:"outputTokens,omitempty"`
TotalTokens *int64 `json:"totalTokens,omitempty"`
ReasoningTokens *int64 `json:"reasoningTokens,omitempty"`
CachedInputTokens *int64 `json:"cachedInputTokens,omitempty"`
CacheWriteInputTokens *int64 `json:"cacheWriteInputTokens,omitempty"`
}
func (*WireTokenUsage) UnmarshalJSON ¶
func (v *WireTokenUsage) UnmarshalJSON(data []byte) error
type WireTool ¶
type WireTool struct {
Name string `json:"name"`
Description string `json:"description"`
Parameters *json.RawMessage `json:"parameters,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
}
type WireToolCall ¶
type WireToolCall struct {
ID string `json:"id"`
Type string `json:"type"`
Function WireFunctionCall `json:"function"`
EncryptedValue *string `json:"encryptedValue,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
}
type WireToolCallArgsEvent ¶
type WireToolCallArgsEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
ToolCallID string `json:"toolCallId"`
Delta string `json:"delta"`
}
func (*WireToolCallArgsEvent) UnmarshalJSON ¶
func (v *WireToolCallArgsEvent) UnmarshalJSON(data []byte) error
type WireToolCallChunkEvent ¶
type WireToolCallChunkEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
ToolCallID *string `json:"toolCallId,omitempty"`
ToolCallName *string `json:"toolCallName,omitempty"`
ParentMessageID *string `json:"parentMessageId,omitempty"`
Delta *string `json:"delta,omitempty"`
}
func (*WireToolCallChunkEvent) UnmarshalJSON ¶
func (v *WireToolCallChunkEvent) UnmarshalJSON(data []byte) error
type WireToolCallEndEvent ¶
type WireToolCallEndEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
ToolCallID string `json:"toolCallId"`
}
func (*WireToolCallEndEvent) UnmarshalJSON ¶
func (v *WireToolCallEndEvent) UnmarshalJSON(data []byte) error
type WireToolCallResultEvent ¶
type WireToolCallResultEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
MessageID string `json:"messageId"`
ToolCallID string `json:"toolCallId"`
Content WireToolCallResultEventContent `json:"content"`
Role *string `json:"role,omitempty"`
}
func (*WireToolCallResultEvent) UnmarshalJSON ¶
func (v *WireToolCallResultEvent) UnmarshalJSON(data []byte) error
type WireToolCallResultEventContent ¶
type WireToolCallResultEventContent struct {
Variant1 *string `json:"-"`
Variant2 *[]WireContentPart `json:"-"`
}
func (WireToolCallResultEventContent) MarshalJSON ¶
func (v WireToolCallResultEventContent) MarshalJSON() ([]byte, error)
func (*WireToolCallResultEventContent) UnmarshalJSON ¶
func (v *WireToolCallResultEventContent) UnmarshalJSON(data []byte) error
type WireToolCallResultEventContentVariant1 ¶
type WireToolCallResultEventContentVariant1 = string
type WireToolCallResultEventContentVariant2 ¶
type WireToolCallResultEventContentVariant2 = []WireContentPart
type WireToolCallStartEvent ¶
type WireToolCallStartEvent struct {
Type string `json:"type"`
Timestamp *int64 `json:"timestamp,omitempty"`
RawEvent *json.RawMessage `json:"rawEvent,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
ToolCallID string `json:"toolCallId"`
ToolCallName string `json:"toolCallName"`
ParentMessageID *string `json:"parentMessageId,omitempty"`
}
func (*WireToolCallStartEvent) UnmarshalJSON ¶
func (v *WireToolCallStartEvent) UnmarshalJSON(data []byte) error
type WireToolMessage ¶
type WireToolMessage struct {
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
ID string `json:"id"`
Role string `json:"role"`
Content WireToolMessageContent `json:"content"`
ToolCallID string `json:"toolCallId"`
Error *string `json:"error,omitempty"`
EncryptedValue *string `json:"encryptedValue,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
}
type WireToolMessageContent ¶
type WireToolMessageContent struct {
Variant1 *string `json:"-"`
Variant2 *[]WireContentPart `json:"-"`
}
func (WireToolMessageContent) MarshalJSON ¶
func (v WireToolMessageContent) MarshalJSON() ([]byte, error)
func (*WireToolMessageContent) UnmarshalJSON ¶
func (v *WireToolMessageContent) UnmarshalJSON(data []byte) error
type WireToolMessageContentVariant1 ¶
type WireToolMessageContentVariant1 = string
type WireToolMessageContentVariant2 ¶
type WireToolMessageContentVariant2 = []WireContentPart
type WireToolsCapabilities ¶
type WireUrlSource ¶
type WireUserMessage ¶
type WireUserMessage struct {
SubagentRunID *WireSubagentRunId `json:"subagentRunId,omitempty"`
ID string `json:"id"`
Role string `json:"role"`
Name *string `json:"name,omitempty"`
EncryptedValue *string `json:"encryptedValue,omitempty"`
Metadata *WireMetadata `json:"metadata,omitempty"`
Content WireUserMessageContent `json:"content"`
}
type WireUserMessageContent ¶
type WireUserMessageContent struct {
Variant1 *string `json:"-"`
Variant2 *[]WireContentPart `json:"-"`
}
func (WireUserMessageContent) MarshalJSON ¶
func (v WireUserMessageContent) MarshalJSON() ([]byte, error)
func (*WireUserMessageContent) UnmarshalJSON ¶
func (v *WireUserMessageContent) UnmarshalJSON(data []byte) error
type WireUserMessageContentVariant1 ¶
type WireUserMessageContentVariant1 = string
type WireUserMessageContentVariant2 ¶
type WireUserMessageContentVariant2 = []WireContentPart
type WireVideoPart ¶
type WireVideoPart struct {
Type string `json:"type"`
ID *string `json:"id,omitempty"`
Source WirePartSource `json:"source"`
Metadata *json.RawMessage `json:"metadata,omitempty"`
}
Source Files
¶
- emitter.go
- event_compat.go
- feed_lifecycle.go
- identity.go
- message.go
- tool_status.go
- translator.go
- translator_approval_receipt.go
- translator_history.go
- translator_model.go
- translator_presentation.go
- translator_restore.go
- translator_subagent.go
- translator_subagent_presentation.go
- types.go
- validate.go
- wire.go
- wire_generated.go
- wire_integer.go
Directories
¶
| Path | Synopsis |
|---|---|
|
Package extensions defines versioned Agently AG-UI extension contracts.
|
Package extensions defines versioned Agently AG-UI extension contracts. |