Help us shape the future of Go! Take the 2026 Go Developer Survey

agui

package
v0.1.58 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 26, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

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

View Source
const ExtensionVersion = "1"
View Source
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

func EncodeEvent(value *WireEvent) ([]byte, error)

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

func ProtocolToolCallID(nativeTurnID, nativeOpID string) string

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

func PublishStandard(ctx context.Context, publisher streaming.Publisher, event *WireEvent) error

PublishStandard is an explicit runtime bridge for a true standard event. Its parent conversation and turn come from trusted execution context.

func ToolStatusPending

func ToolStatusPending(status string) bool

ToolStatusPending identifies native tool states that have not produced an execution result, even when a queue presentation payload is already stored.

func ValidateCapabilities

func ValidateCapabilities(data []byte) error

ValidateCapabilities preserves the difference between omitted and false.

func ValidateEvent

func ValidateEvent(data []byte) error

ValidateEvent enforces every field of all 31 event variants against the pin.

func ValidateInput

func ValidateInput(data []byte) error

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

func ValidateMessage(data []byte) error

ValidateMessage validates all roles and multimodal source variants.

Types

type AgentCapabilities

type AgentCapabilities map[string]any

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 Context

type Context struct {
	Description string `json:"description"`
	Value       string `json:"value"`
}

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 Event) MarshalJSON() ([]byte, error)

func (*Event) UnmarshalJSON

func (event *Event) UnmarshalJSON(raw []byte) error

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

type FeedLifecycleOrigin struct {
	RunID    string `json:"runId"`
	Sequence int64  `json:"sequence"`
}

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 (m Message) MarshalJSON() ([]byte, error)

func (*Message) UnmarshalJSON

func (m *Message) UnmarshalJSON(data []byte) error

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 Outcome

type Outcome struct {
	Type string `json:"type"`
}

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 QueueValue struct {
	Version            string `json:"version"`
	TurnID             string `json:"turnId,omitempty"`
	Sequence           string `json:"sequence,omitempty"`
	Origin             string `json:"origin,omitempty"`
	StartedByMessageID string `json:"startedByMessageId,omitempty"`
}

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) Translate

func (t *Translator) Translate(e *streaming.Event) []Event

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 WireContext struct {
	Description string `json:"description"`
	Value       string `json:"value"`
}

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 WireDataSource struct {
	Type     string `json:"type"`
	Value    string `json:"value"`
	MIMEType string `json:"mimeType"`
}

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

func DecodeEvent(data []byte) (*WireEvent, error)

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 (v WireEvent) MarshalJSON() ([]byte, error)

func (*WireEvent) UnmarshalJSON

func (v *WireEvent) UnmarshalJSON(data []byte) error

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 WireFileSource struct {
	Type     string  `json:"type"`
	Value    string  `json:"value"`
	Provider *string `json:"provider,omitempty"`
	MIMEType *string `json:"mimeType,omitempty"`
}

type WireFunctionCall

type WireFunctionCall struct {
	Name      string `json:"name"`
	Arguments string `json:"arguments"`
}

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 WireMultimodalInputCapabilities

type WireMultimodalInputCapabilities struct {
	Image *bool `json:"image,omitempty"`
	Audio *bool `json:"audio,omitempty"`
	Video *bool `json:"video,omitempty"`
	Pdf   *bool `json:"pdf,omitempty"`
	File  *bool `json:"file,omitempty"`
}

type WireMultimodalOutputCapabilities

type WireMultimodalOutputCapabilities struct {
	Image *bool `json:"image,omitempty"`
	Audio *bool `json:"audio,omitempty"`
}

type WireOutputCapabilities

type WireOutputCapabilities struct {
	StructuredOutput   *bool     `json:"structuredOutput,omitempty"`
	SupportedMimeTypes *[]string `json:"supportedMimeTypes,omitempty"`
}

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 WireReasoningCapabilities

type WireReasoningCapabilities struct {
	Supported *bool `json:"supported,omitempty"`
	Streaming *bool `json:"streaming,omitempty"`
	Encrypted *bool `json:"encrypted,omitempty"`
}

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 WireRole

type WireRole = string

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 WireRunFinishedSuccessOutcome

type WireRunFinishedSuccessOutcome struct {
	Type               string    `json:"type"`
	PendingToolCallIds *[]string `json:"pendingToolCallIds,omitempty"`
}

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 WireStateCapabilities struct {
	Snapshots       *bool `json:"snapshots,omitempty"`
	Deltas          *bool `json:"deltas,omitempty"`
	Memory          *bool `json:"memory,omitempty"`
	PersistentState *bool `json:"persistentState,omitempty"`
}

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 WireSubagentFinishedSuspendedOutcome

type WireSubagentFinishedSuspendedOutcome struct {
	Type         string    `json:"type"`
	InterruptIds *[]string `json:"interruptIds,omitempty"`
}

type WireSubagentInfo

type WireSubagentInfo struct {
	Name        string  `json:"name"`
	Description *string `json:"description,omitempty"`
}

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 WireToolsCapabilities struct {
	Supported      *bool       `json:"supported,omitempty"`
	Items          *[]WireTool `json:"items,omitempty"`
	ParallelCalls  *bool       `json:"parallelCalls,omitempty"`
	ClientProvided *bool       `json:"clientProvided,omitempty"`
}

type WireTransportCapabilities

type WireTransportCapabilities struct {
	Streaming         *bool `json:"streaming,omitempty"`
	Websocket         *bool `json:"websocket,omitempty"`
	HttpBinary        *bool `json:"httpBinary,omitempty"`
	PushNotifications *bool `json:"pushNotifications,omitempty"`
	Resumable         *bool `json:"resumable,omitempty"`
}

type WireUrlSource

type WireUrlSource struct {
	Type     string  `json:"type"`
	Value    string  `json:"value"`
	MIMEType *string `json:"mimeType,omitempty"`
}

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"`
}

Directories

Path Synopsis
Package extensions defines versioned Agently AG-UI extension contracts.
Package extensions defines versioned Agently AG-UI extension contracts.

Jump to

Keyboard shortcuts

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