Documentation
¶
Index ¶
- Constants
- Variables
- func DecodeJSON[T any](value *EncodedValue) (T, error)
- func FindTypedExtension(event *Event, target proto.Message) (bool, error)
- func Kind(event *Event) string
- func SetTypedExtension(event *Event, value proto.Message) error
- func Unwrap(envelope *Envelope) (proto.Message, error)
- type AgentAccepted
- func (*AgentAccepted) Descriptor() ([]byte, []int)deprecated
- func (x *AgentAccepted) GetCapabilities() []string
- func (x *AgentAccepted) GetNodeId() string
- func (*AgentAccepted) ProtoMessage()
- func (x *AgentAccepted) ProtoReflect() protoreflect.Message
- func (x *AgentAccepted) Reset()
- func (x *AgentAccepted) String() string
- type AgentHello
- func (*AgentHello) Descriptor() ([]byte, []int)deprecated
- func (x *AgentHello) GetCapabilities() []string
- func (x *AgentHello) GetName() string
- func (x *AgentHello) GetNodeId() string
- func (x *AgentHello) GetRuntime() *AgentRuntimeInfo
- func (x *AgentHello) GetTools() []*ToolDefinition
- func (*AgentHello) ProtoMessage()
- func (x *AgentHello) ProtoReflect() protoreflect.Message
- func (x *AgentHello) Reset()
- func (x *AgentHello) String() string
- type AgentRuntimeInfo
- func (*AgentRuntimeInfo) Descriptor() ([]byte, []int)deprecated
- func (x *AgentRuntimeInfo) GetArch() string
- func (x *AgentRuntimeInfo) GetHostname() string
- func (x *AgentRuntimeInfo) GetMetadata() *structpb.Struct
- func (x *AgentRuntimeInfo) GetOs() string
- func (x *AgentRuntimeInfo) GetPid() int32
- func (x *AgentRuntimeInfo) GetUsername() string
- func (x *AgentRuntimeInfo) GetWorkingDir() string
- func (*AgentRuntimeInfo) ProtoMessage()
- func (x *AgentRuntimeInfo) ProtoReflect() protoreflect.Message
- func (x *AgentRuntimeInfo) Reset()
- func (x *AgentRuntimeInfo) String() string
- type AgentStats
- func (*AgentStats) Descriptor() ([]byte, []int)deprecated
- func (x *AgentStats) GetCacheReadTokens() uint64
- func (x *AgentStats) GetCacheWriteTokens() uint64
- func (x *AgentStats) GetInputTokens() uint64
- func (x *AgentStats) GetLastEvent() string
- func (x *AgentStats) GetOutputTokens() uint64
- func (x *AgentStats) GetRunningTools() uint64
- func (x *AgentStats) GetToolCalls() uint64
- func (x *AgentStats) GetTotalTokens() uint64
- func (x *AgentStats) GetTurns() uint64
- func (*AgentStats) ProtoMessage()
- func (x *AgentStats) ProtoReflect() protoreflect.Message
- func (x *AgentStats) Reset()
- func (x *AgentStats) String() string
- type AgentStatus
- func (*AgentStatus) Descriptor() ([]byte, []int)deprecated
- func (x *AgentStatus) GetBound() bool
- func (x *AgentStatus) GetConfigError() string
- func (x *AgentStatus) GetModel() string
- func (x *AgentStatus) GetProvider() string
- func (x *AgentStatus) GetSpace() string
- func (*AgentStatus) ProtoMessage()
- func (x *AgentStatus) ProtoReflect() protoreflect.Message
- func (x *AgentStatus) Reset()
- func (x *AgentStatus) String() string
- type Annotation
- func (*Annotation) Descriptor() ([]byte, []int)deprecated
- func (x *Annotation) GetEnd() uint64
- func (x *Annotation) GetStart() uint64
- func (x *Annotation) GetTitle() string
- func (x *Annotation) GetType() string
- func (x *Annotation) GetUri() string
- func (*Annotation) ProtoMessage()
- func (x *Annotation) ProtoReflect() protoreflect.Message
- func (x *Annotation) Reset()
- func (x *Annotation) String() string
- type CancelOperation
- func (*CancelOperation) Descriptor() ([]byte, []int)deprecated
- func (x *CancelOperation) GetReason() string
- func (x *CancelOperation) GetTargetId() string
- func (*CancelOperation) ProtoMessage()
- func (x *CancelOperation) ProtoReflect() protoreflect.Message
- func (x *CancelOperation) Reset()
- func (x *CancelOperation) String() string
- type CancelTurnRequest
- func (*CancelTurnRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CancelTurnRequest) GetReason() string
- func (x *CancelTurnRequest) GetSessionId() string
- func (x *CancelTurnRequest) GetTurnId() string
- func (*CancelTurnRequest) ProtoMessage()
- func (x *CancelTurnRequest) ProtoReflect() protoreflect.Message
- func (x *CancelTurnRequest) Reset()
- func (x *CancelTurnRequest) String() string
- type CancelTurnResponse
- func (*CancelTurnResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CancelTurnResponse) GetAccepted() *TurnReceipt
- func (x *CancelTurnResponse) GetOutcome() isCancelTurnResponse_Outcome
- func (x *CancelTurnResponse) GetRejected() *Rejection
- func (*CancelTurnResponse) ProtoMessage()
- func (x *CancelTurnResponse) ProtoReflect() protoreflect.Message
- func (x *CancelTurnResponse) Reset()
- func (x *CancelTurnResponse) String() string
- type CancelTurnResponse_Accepted
- type CancelTurnResponse_Rejected
- type CloseSessionRequest
- func (*CloseSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CloseSessionRequest) GetReason() string
- func (x *CloseSessionRequest) GetSessionId() string
- func (*CloseSessionRequest) ProtoMessage()
- func (x *CloseSessionRequest) ProtoReflect() protoreflect.Message
- func (x *CloseSessionRequest) Reset()
- func (x *CloseSessionRequest) String() string
- type CloseSessionResponse
- func (*CloseSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CloseSessionResponse) GetAccepted() *Session
- func (x *CloseSessionResponse) GetOutcome() isCloseSessionResponse_Outcome
- func (x *CloseSessionResponse) GetRejected() *Rejection
- func (*CloseSessionResponse) ProtoMessage()
- func (x *CloseSessionResponse) ProtoReflect() protoreflect.Message
- func (x *CloseSessionResponse) Reset()
- func (x *CloseSessionResponse) String() string
- type CloseSessionResponse_Accepted
- type CloseSessionResponse_Rejected
- type Content
- func (*Content) Descriptor() ([]byte, []int)deprecated
- func (x *Content) GetMedia() *MediaContent
- func (x *Content) GetReasoning() *ReasoningContent
- func (x *Content) GetRefusal() string
- func (x *Content) GetText() *TextContent
- func (x *Content) GetToolCall() *ToolCall
- func (x *Content) GetToolResult() *ToolResult
- func (x *Content) GetValue() isContent_Value
- func (*Content) ProtoMessage()
- func (x *Content) ProtoReflect() protoreflect.Message
- func (x *Content) Reset()
- func (x *Content) String() string
- type Content_Media
- type Content_Reasoning
- type Content_Refusal
- type Content_Text
- type Content_ToolCall
- type Content_ToolResult
- type DeltaOperation
- func (DeltaOperation) Descriptor() protoreflect.EnumDescriptor
- func (x DeltaOperation) Enum() *DeltaOperation
- func (DeltaOperation) EnumDescriptor() ([]byte, []int)deprecated
- func (x DeltaOperation) Number() protoreflect.EnumNumber
- func (x DeltaOperation) String() string
- func (DeltaOperation) Type() protoreflect.EnumType
- type Direction
- type EncodedValue
- func (*EncodedValue) Descriptor() ([]byte, []int)deprecated
- func (x *EncodedValue) GetData() []byte
- func (x *EncodedValue) GetMediaType() string
- func (*EncodedValue) ProtoMessage()
- func (x *EncodedValue) ProtoReflect() protoreflect.Message
- func (x *EncodedValue) Reset()
- func (x *EncodedValue) String() string
- type Envelope
- func (*Envelope) Descriptor() ([]byte, []int)deprecated
- func (x *Envelope) GetDeliveryCursor() string
- func (x *Envelope) GetId() string
- func (x *Envelope) GetPayload() *anypb.Any
- func (x *Envelope) GetReplyTo() string
- func (*Envelope) ProtoMessage()
- func (x *Envelope) ProtoReflect() protoreflect.Message
- func (x *Envelope) Reset()
- func (x *Envelope) String() string
- type EnvelopeStream
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetEmittedAt() *timestamppb.Timestamp
- func (x *Event) GetEmitter() string
- func (x *Event) GetError() *ProtocolError
- func (x *Event) GetExtension() *anypb.Any
- func (x *Event) GetExtensions() []*anypb.Any
- func (x *Event) GetId() string
- func (x *Event) GetMessage() *Message
- func (x *Event) GetMessageDelta() *MessageDelta
- func (x *Event) GetPayload() isEvent_Payload
- func (x *Event) GetProviderFrame() *ProviderFrame
- func (x *Event) GetSeq() uint64
- func (x *Event) GetSessionEnded() *SessionEnded
- func (x *Event) GetSessionId() string
- func (x *Event) GetSessionStarted() *SessionStarted
- func (x *Event) GetStatus() *Status
- func (x *Event) GetToolCall() *ToolCall
- func (x *Event) GetToolCallDelta() *ToolCallDelta
- func (x *Event) GetToolResult() *ToolResult
- func (x *Event) GetTurnEnded() *TurnEnded
- func (x *Event) GetTurnId() string
- func (x *Event) GetTurnStarted() *TurnStarted
- func (x *Event) GetUsage() *TokenUsage
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type EventDelivery
- func (*EventDelivery) Descriptor() ([]byte, []int)deprecated
- func (x *EventDelivery) GetCursor() string
- func (x *EventDelivery) GetEvent() *Event
- func (*EventDelivery) ProtoMessage()
- func (x *EventDelivery) ProtoReflect() protoreflect.Message
- func (x *EventDelivery) Reset()
- func (x *EventDelivery) String() string
- type EventEmitter
- type Event_Error
- type Event_Extension
- type Event_Message
- type Event_MessageDelta
- type Event_ProviderFrame
- type Event_SessionEnded
- type Event_SessionStarted
- type Event_Status
- type Event_ToolCall
- type Event_ToolCallDelta
- type Event_ToolResult
- type Event_TurnEnded
- type Event_TurnStarted
- type Event_Usage
- type ListEventsRequest
- func (*ListEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListEventsRequest) GetAfterCursor() string
- func (x *ListEventsRequest) GetLimit() uint32
- func (x *ListEventsRequest) GetSessionId() string
- func (*ListEventsRequest) ProtoMessage()
- func (x *ListEventsRequest) ProtoReflect() protoreflect.Message
- func (x *ListEventsRequest) Reset()
- func (x *ListEventsRequest) String() string
- type ListEventsResponse
- func (*ListEventsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListEventsResponse) GetEvents() []*EventDelivery
- func (x *ListEventsResponse) GetNextCursor() string
- func (*ListEventsResponse) ProtoMessage()
- func (x *ListEventsResponse) ProtoReflect() protoreflect.Message
- func (x *ListEventsResponse) Reset()
- func (x *ListEventsResponse) String() string
- type MediaContent
- func (*MediaContent) Descriptor() ([]byte, []int)deprecated
- func (x *MediaContent) GetKind() string
- func (x *MediaContent) GetResource() *Resource
- func (x *MediaContent) GetTranscript() string
- func (*MediaContent) ProtoMessage()
- func (x *MediaContent) ProtoReflect() protoreflect.Message
- func (x *MediaContent) Reset()
- func (x *MediaContent) String() string
- type Message
- func (*Message) Descriptor() ([]byte, []int)deprecated
- func (x *Message) GetContent() []*Content
- func (x *Message) GetId() string
- func (x *Message) GetName() string
- func (x *Message) GetRole() string
- func (*Message) ProtoMessage()
- func (x *Message) ProtoReflect() protoreflect.Message
- func (x *Message) Reset()
- func (x *Message) String() string
- type MessageDelta
- func (*MessageDelta) Descriptor() ([]byte, []int)deprecated
- func (x *MessageDelta) GetContent() *Content
- func (x *MessageDelta) GetContentIndex() uint32
- func (x *MessageDelta) GetData() []byte
- func (x *MessageDelta) GetMessageId() string
- func (x *MessageDelta) GetOperation() DeltaOperation
- func (x *MessageDelta) GetReasoning() string
- func (x *MessageDelta) GetRefusal() string
- func (x *MessageDelta) GetText() string
- func (x *MessageDelta) GetToolArguments() string
- func (x *MessageDelta) GetValue() isMessageDelta_Value
- func (*MessageDelta) ProtoMessage()
- func (x *MessageDelta) ProtoReflect() protoreflect.Message
- func (x *MessageDelta) Reset()
- func (x *MessageDelta) String() string
- type MessageDelta_Content
- type MessageDelta_Data
- type MessageDelta_Reasoning
- type MessageDelta_Refusal
- type MessageDelta_Text
- type MessageDelta_ToolArguments
- type NamespaceHandler
- type NamespaceMux
- type OpenSessionRequest
- func (*OpenSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OpenSessionRequest) GetExtensions() []*anypb.Any
- func (x *OpenSessionRequest) GetNodeId() string
- func (x *OpenSessionRequest) GetParentSessionId() string
- func (x *OpenSessionRequest) GetParentToolCallId() string
- func (x *OpenSessionRequest) GetSessionId() string
- func (x *OpenSessionRequest) GetTitle() string
- func (*OpenSessionRequest) ProtoMessage()
- func (x *OpenSessionRequest) ProtoReflect() protoreflect.Message
- func (x *OpenSessionRequest) Reset()
- func (x *OpenSessionRequest) String() string
- type OpenSessionResponse
- func (*OpenSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OpenSessionResponse) GetAccepted() *Session
- func (x *OpenSessionResponse) GetOutcome() isOpenSessionResponse_Outcome
- func (x *OpenSessionResponse) GetRejected() *Rejection
- func (*OpenSessionResponse) ProtoMessage()
- func (x *OpenSessionResponse) ProtoReflect() protoreflect.Message
- func (x *OpenSessionResponse) Reset()
- func (x *OpenSessionResponse) String() string
- type OpenSessionResponse_Accepted
- type OpenSessionResponse_Rejected
- type ProtocolError
- func (*ProtocolError) Descriptor() ([]byte, []int)deprecated
- func (x *ProtocolError) GetCode() string
- func (x *ProtocolError) GetMessage() string
- func (x *ProtocolError) GetRetryable() bool
- func (*ProtocolError) ProtoMessage()
- func (x *ProtocolError) ProtoReflect() protoreflect.Message
- func (x *ProtocolError) Reset()
- func (x *ProtocolError) String() string
- type ProtocolMessage
- func (*ProtocolMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ProtocolMessage) GetAgentAccepted() *AgentAccepted
- func (x *ProtocolMessage) GetAgentHello() *AgentHello
- func (x *ProtocolMessage) GetAgentStats() *AgentStats
- func (x *ProtocolMessage) GetAgentStatus() *AgentStatus
- func (x *ProtocolMessage) GetCancelOperation() *CancelOperation
- func (x *ProtocolMessage) GetCancelTurnRequest() *CancelTurnRequest
- func (x *ProtocolMessage) GetCancelTurnResponse() *CancelTurnResponse
- func (x *ProtocolMessage) GetCloseSessionRequest() *CloseSessionRequest
- func (x *ProtocolMessage) GetCloseSessionResponse() *CloseSessionResponse
- func (x *ProtocolMessage) GetEvent() *Event
- func (x *ProtocolMessage) GetListEventsRequest() *ListEventsRequest
- func (x *ProtocolMessage) GetListEventsResponse() *ListEventsResponse
- func (x *ProtocolMessage) GetMessage() isProtocolMessage_Message
- func (x *ProtocolMessage) GetOpenSessionRequest() *OpenSessionRequest
- func (x *ProtocolMessage) GetOpenSessionResponse() *OpenSessionResponse
- func (x *ProtocolMessage) GetProtocolError() *ProtocolError
- func (x *ProtocolMessage) GetRunTurnRequest() *RunTurnRequest
- func (x *ProtocolMessage) GetRunTurnResponse() *RunTurnResponse
- func (x *ProtocolMessage) GetWatchEventsRequest() *WatchEventsRequest
- func (*ProtocolMessage) ProtoMessage()
- func (x *ProtocolMessage) ProtoReflect() protoreflect.Message
- func (x *ProtocolMessage) Reset()
- func (x *ProtocolMessage) String() string
- type ProtocolMessage_AgentAccepted
- type ProtocolMessage_AgentHello
- type ProtocolMessage_AgentStats
- type ProtocolMessage_AgentStatus
- type ProtocolMessage_CancelOperation
- type ProtocolMessage_CancelTurnRequest
- type ProtocolMessage_CancelTurnResponse
- type ProtocolMessage_CloseSessionRequest
- type ProtocolMessage_CloseSessionResponse
- type ProtocolMessage_Event
- type ProtocolMessage_ListEventsRequest
- type ProtocolMessage_ListEventsResponse
- type ProtocolMessage_OpenSessionRequest
- type ProtocolMessage_OpenSessionResponse
- type ProtocolMessage_ProtocolError
- type ProtocolMessage_RunTurnRequest
- type ProtocolMessage_RunTurnResponse
- type ProtocolMessage_WatchEventsRequest
- type ProviderFrame
- func (*ProviderFrame) Descriptor() ([]byte, []int)deprecated
- func (x *ProviderFrame) GetDirection() Direction
- func (x *ProviderFrame) GetEventType() string
- func (x *ProviderFrame) GetMediaType() string
- func (x *ProviderFrame) GetMetadata() []*ProviderMetadata
- func (x *ProviderFrame) GetPayload() []byte
- func (x *ProviderFrame) GetProtocol() string
- func (x *ProviderFrame) GetProvider() string
- func (x *ProviderFrame) GetTransport() string
- func (*ProviderFrame) ProtoMessage()
- func (x *ProviderFrame) ProtoReflect() protoreflect.Message
- func (x *ProviderFrame) Reset()
- func (x *ProviderFrame) String() string
- type ProviderMetadata
- func (*ProviderMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *ProviderMetadata) GetName() string
- func (x *ProviderMetadata) GetValue() []byte
- func (*ProviderMetadata) ProtoMessage()
- func (x *ProviderMetadata) ProtoReflect() protoreflect.Message
- func (x *ProviderMetadata) Reset()
- func (x *ProviderMetadata) String() string
- type ReasoningContent
- type Rejection
- func (*Rejection) Descriptor() ([]byte, []int)deprecated
- func (x *Rejection) GetCode() string
- func (x *Rejection) GetMessage() string
- func (x *Rejection) GetRetryable() bool
- func (*Rejection) ProtoMessage()
- func (x *Rejection) ProtoReflect() protoreflect.Message
- func (x *Rejection) Reset()
- func (x *Rejection) String() string
- type Resource
- func (*Resource) Descriptor() ([]byte, []int)deprecated
- func (x *Resource) GetData() []byte
- func (x *Resource) GetFilename() string
- func (x *Resource) GetMediaType() string
- func (x *Resource) GetSource() isResource_Source
- func (x *Resource) GetUri() string
- func (*Resource) ProtoMessage()
- func (x *Resource) ProtoReflect() protoreflect.Message
- func (x *Resource) Reset()
- func (x *Resource) String() string
- type Resource_Data
- type Resource_Uri
- type RunTurnRequest
- func (*RunTurnRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RunTurnRequest) GetContinueSession() bool
- func (x *RunTurnRequest) GetExtensions() []*anypb.Any
- func (x *RunTurnRequest) GetInput() *Message
- func (x *RunTurnRequest) GetMaxTurns() uint32
- func (x *RunTurnRequest) GetSessionId() string
- func (x *RunTurnRequest) GetTurnId() string
- func (*RunTurnRequest) ProtoMessage()
- func (x *RunTurnRequest) ProtoReflect() protoreflect.Message
- func (x *RunTurnRequest) Reset()
- func (x *RunTurnRequest) String() string
- type RunTurnResponse
- func (*RunTurnResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RunTurnResponse) GetAccepted() *TurnReceipt
- func (x *RunTurnResponse) GetOutcome() isRunTurnResponse_Outcome
- func (x *RunTurnResponse) GetRejected() *Rejection
- func (*RunTurnResponse) ProtoMessage()
- func (x *RunTurnResponse) ProtoReflect() protoreflect.Message
- func (x *RunTurnResponse) Reset()
- func (x *RunTurnResponse) String() string
- type RunTurnResponse_Accepted
- type RunTurnResponse_Rejected
- type SendFunc
- type Session
- func (*Session) Descriptor() ([]byte, []int)deprecated
- func (x *Session) GetId() string
- func (x *Session) GetNodeId() string
- func (x *Session) GetState() string
- func (x *Session) GetTitle() string
- func (*Session) ProtoMessage()
- func (x *Session) ProtoReflect() protoreflect.Message
- func (x *Session) Reset()
- func (x *Session) String() string
- type SessionEnded
- type SessionStarted
- func (*SessionStarted) Descriptor() ([]byte, []int)deprecated
- func (x *SessionStarted) GetModel() string
- func (x *SessionStarted) GetParentSessionId() string
- func (x *SessionStarted) GetParentToolCallId() string
- func (*SessionStarted) ProtoMessage()
- func (x *SessionStarted) ProtoReflect() protoreflect.Message
- func (x *SessionStarted) Reset()
- func (x *SessionStarted) String() string
- type Status
- type TextContent
- func (*TextContent) Descriptor() ([]byte, []int)deprecated
- func (x *TextContent) GetAnnotations() []*Annotation
- func (x *TextContent) GetText() string
- func (*TextContent) ProtoMessage()
- func (x *TextContent) ProtoReflect() protoreflect.Message
- func (x *TextContent) Reset()
- func (x *TextContent) String() string
- type TokenUsage
- func (*TokenUsage) Descriptor() ([]byte, []int)deprecated
- func (x *TokenUsage) GetDetail() map[string]uint64
- func (x *TokenUsage) GetInputTokens() uint64
- func (x *TokenUsage) GetModel() string
- func (x *TokenUsage) GetOutputTokens() uint64
- func (x *TokenUsage) GetTotalTokens() uint64
- func (*TokenUsage) ProtoMessage()
- func (x *TokenUsage) ProtoReflect() protoreflect.Message
- func (x *TokenUsage) Reset()
- func (x *TokenUsage) String() string
- type ToolCall
- func (*ToolCall) Descriptor() ([]byte, []int)deprecated
- func (x *ToolCall) GetArguments() *EncodedValue
- func (x *ToolCall) GetId() string
- func (x *ToolCall) GetKind() string
- func (x *ToolCall) GetName() string
- func (x *ToolCall) GetWorkingDirectory() string
- func (*ToolCall) ProtoMessage()
- func (x *ToolCall) ProtoReflect() protoreflect.Message
- func (x *ToolCall) Reset()
- func (x *ToolCall) String() string
- type ToolCallDelta
- func (*ToolCallDelta) Descriptor() ([]byte, []int)deprecated
- func (x *ToolCallDelta) GetArguments() []byte
- func (x *ToolCallDelta) GetCallId() string
- func (x *ToolCallDelta) GetIndex() uint32
- func (x *ToolCallDelta) GetName() string
- func (*ToolCallDelta) ProtoMessage()
- func (x *ToolCallDelta) ProtoReflect() protoreflect.Message
- func (x *ToolCallDelta) Reset()
- func (x *ToolCallDelta) String() string
- type ToolDefinition
- func (*ToolDefinition) Descriptor() ([]byte, []int)deprecated
- func (x *ToolDefinition) GetDescription() string
- func (x *ToolDefinition) GetInputSchema() *EncodedValue
- func (x *ToolDefinition) GetName() string
- func (x *ToolDefinition) GetType() string
- func (*ToolDefinition) ProtoMessage()
- func (x *ToolDefinition) ProtoReflect() protoreflect.Message
- func (x *ToolDefinition) Reset()
- func (x *ToolDefinition) String() string
- type ToolResult
- func (*ToolResult) Descriptor() ([]byte, []int)deprecated
- func (x *ToolResult) GetCallId() string
- func (x *ToolResult) GetDurationMs() uint64
- func (x *ToolResult) GetIsError() bool
- func (x *ToolResult) GetName() string
- func (x *ToolResult) GetOutput() []*Content
- func (x *ToolResult) GetTerminate() bool
- func (*ToolResult) ProtoMessage()
- func (x *ToolResult) ProtoReflect() protoreflect.Message
- func (x *ToolResult) Reset()
- func (x *ToolResult) String() string
- type TurnEnded
- func (*TurnEnded) Descriptor() ([]byte, []int)deprecated
- func (x *TurnEnded) GetContextTokens() uint64
- func (x *TurnEnded) GetError() *ProtocolError
- func (x *TurnEnded) GetStopReason() string
- func (x *TurnEnded) GetUsage() *TokenUsage
- func (*TurnEnded) ProtoMessage()
- func (x *TurnEnded) ProtoReflect() protoreflect.Message
- func (x *TurnEnded) Reset()
- func (x *TurnEnded) String() string
- type TurnReceipt
- func (*TurnReceipt) Descriptor() ([]byte, []int)deprecated
- func (x *TurnReceipt) GetSessionId() string
- func (x *TurnReceipt) GetState() string
- func (x *TurnReceipt) GetTurnId() string
- func (*TurnReceipt) ProtoMessage()
- func (x *TurnReceipt) ProtoReflect() protoreflect.Message
- func (x *TurnReceipt) Reset()
- func (x *TurnReceipt) String() string
- type TurnStarted
- type WatchEventsRequest
- func (*WatchEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WatchEventsRequest) GetAfterCursor() string
- func (x *WatchEventsRequest) GetSessionId() string
- func (*WatchEventsRequest) ProtoMessage()
- func (x *WatchEventsRequest) ProtoReflect() protoreflect.Message
- func (x *WatchEventsRequest) Reset()
- func (x *WatchEventsRequest) String() string
Constants ¶
const JSONMediaType = "application/json"
Variables ¶
var ( DeltaOperation_name = map[int32]string{ 0: "DELTA_OPERATION_UNSPECIFIED", 1: "DELTA_OPERATION_START", 2: "DELTA_OPERATION_APPEND", 3: "DELTA_OPERATION_REPLACE", 4: "DELTA_OPERATION_END", } DeltaOperation_value = map[string]int32{ "DELTA_OPERATION_UNSPECIFIED": 0, "DELTA_OPERATION_START": 1, "DELTA_OPERATION_APPEND": 2, "DELTA_OPERATION_REPLACE": 3, "DELTA_OPERATION_END": 4, } )
Enum value maps for DeltaOperation.
var ( Direction_name = map[int32]string{ 0: "DIRECTION_UNSPECIFIED", 1: "DIRECTION_REQUEST", 2: "DIRECTION_RESPONSE", } Direction_value = map[string]int32{ "DIRECTION_UNSPECIFIED": 0, "DIRECTION_REQUEST": 1, "DIRECTION_RESPONSE": 2, } )
Enum value maps for Direction.
var File_aop_chat_proto protoreflect.FileDescriptor
var File_aop_content_proto protoreflect.FileDescriptor
var File_aop_envelope_proto protoreflect.FileDescriptor
var File_aop_event_proto protoreflect.FileDescriptor
var File_aop_protocol_proto protoreflect.FileDescriptor
var File_aop_value_proto protoreflect.FileDescriptor
Functions ¶
func DecodeJSON ¶
func DecodeJSON[T any](value *EncodedValue) (T, error)
func FindTypedExtension ¶
FindTypedExtension unmarshals the extension matching target's protobuf full name. Unknown extensions are ignored and remain preserved on the Event.
func SetTypedExtension ¶
SetTypedExtension packs value into Event.extensions and replaces an existing extension with the same protobuf full name.
Types ¶
type AgentAccepted ¶
type AgentAccepted struct {
NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
Capabilities []string `protobuf:"bytes,2,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
// contains filtered or unexported fields
}
func (*AgentAccepted) Descriptor
deprecated
func (*AgentAccepted) Descriptor() ([]byte, []int)
Deprecated: Use AgentAccepted.ProtoReflect.Descriptor instead.
func (*AgentAccepted) GetCapabilities ¶
func (x *AgentAccepted) GetCapabilities() []string
func (*AgentAccepted) GetNodeId ¶
func (x *AgentAccepted) GetNodeId() string
func (*AgentAccepted) ProtoMessage ¶
func (*AgentAccepted) ProtoMessage()
func (*AgentAccepted) ProtoReflect ¶
func (x *AgentAccepted) ProtoReflect() protoreflect.Message
func (*AgentAccepted) Reset ¶
func (x *AgentAccepted) Reset()
func (*AgentAccepted) String ¶
func (x *AgentAccepted) String() string
type AgentHello ¶
type AgentHello struct {
NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Capabilities []string `protobuf:"bytes,4,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
Tools []*ToolDefinition `protobuf:"bytes,6,rep,name=tools,proto3" json:"tools,omitempty"`
Runtime *AgentRuntimeInfo `protobuf:"bytes,7,opt,name=runtime,proto3" json:"runtime,omitempty"`
// contains filtered or unexported fields
}
func (*AgentHello) Descriptor
deprecated
func (*AgentHello) Descriptor() ([]byte, []int)
Deprecated: Use AgentHello.ProtoReflect.Descriptor instead.
func (*AgentHello) GetCapabilities ¶
func (x *AgentHello) GetCapabilities() []string
func (*AgentHello) GetName ¶
func (x *AgentHello) GetName() string
func (*AgentHello) GetNodeId ¶
func (x *AgentHello) GetNodeId() string
func (*AgentHello) GetRuntime ¶
func (x *AgentHello) GetRuntime() *AgentRuntimeInfo
func (*AgentHello) GetTools ¶
func (x *AgentHello) GetTools() []*ToolDefinition
func (*AgentHello) ProtoMessage ¶
func (*AgentHello) ProtoMessage()
func (*AgentHello) ProtoReflect ¶
func (x *AgentHello) ProtoReflect() protoreflect.Message
func (*AgentHello) Reset ¶
func (x *AgentHello) Reset()
func (*AgentHello) String ¶
func (x *AgentHello) String() string
type AgentRuntimeInfo ¶
type AgentRuntimeInfo struct {
Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
WorkingDir string `protobuf:"bytes,3,opt,name=working_dir,json=workingDir,proto3" json:"working_dir,omitempty"`
Os string `protobuf:"bytes,4,opt,name=os,proto3" json:"os,omitempty"`
Arch string `protobuf:"bytes,5,opt,name=arch,proto3" json:"arch,omitempty"`
Pid int32 `protobuf:"varint,6,opt,name=pid,proto3" json:"pid,omitempty"`
Metadata *structpb.Struct `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata,omitempty"`
// contains filtered or unexported fields
}
func (*AgentRuntimeInfo) Descriptor
deprecated
func (*AgentRuntimeInfo) Descriptor() ([]byte, []int)
Deprecated: Use AgentRuntimeInfo.ProtoReflect.Descriptor instead.
func (*AgentRuntimeInfo) GetArch ¶
func (x *AgentRuntimeInfo) GetArch() string
func (*AgentRuntimeInfo) GetHostname ¶
func (x *AgentRuntimeInfo) GetHostname() string
func (*AgentRuntimeInfo) GetMetadata ¶
func (x *AgentRuntimeInfo) GetMetadata() *structpb.Struct
func (*AgentRuntimeInfo) GetOs ¶
func (x *AgentRuntimeInfo) GetOs() string
func (*AgentRuntimeInfo) GetPid ¶
func (x *AgentRuntimeInfo) GetPid() int32
func (*AgentRuntimeInfo) GetUsername ¶
func (x *AgentRuntimeInfo) GetUsername() string
func (*AgentRuntimeInfo) GetWorkingDir ¶
func (x *AgentRuntimeInfo) GetWorkingDir() string
func (*AgentRuntimeInfo) ProtoMessage ¶
func (*AgentRuntimeInfo) ProtoMessage()
func (*AgentRuntimeInfo) ProtoReflect ¶
func (x *AgentRuntimeInfo) ProtoReflect() protoreflect.Message
func (*AgentRuntimeInfo) Reset ¶
func (x *AgentRuntimeInfo) Reset()
func (*AgentRuntimeInfo) String ¶
func (x *AgentRuntimeInfo) String() string
type AgentStats ¶
type AgentStats struct {
Turns uint64 `protobuf:"varint,1,opt,name=turns,proto3" json:"turns,omitempty"`
ToolCalls uint64 `protobuf:"varint,2,opt,name=tool_calls,json=toolCalls,proto3" json:"tool_calls,omitempty"`
RunningTools uint64 `protobuf:"varint,3,opt,name=running_tools,json=runningTools,proto3" json:"running_tools,omitempty"`
InputTokens uint64 `protobuf:"varint,4,opt,name=input_tokens,json=inputTokens,proto3" json:"input_tokens,omitempty"`
OutputTokens uint64 `protobuf:"varint,5,opt,name=output_tokens,json=outputTokens,proto3" json:"output_tokens,omitempty"`
TotalTokens uint64 `protobuf:"varint,6,opt,name=total_tokens,json=totalTokens,proto3" json:"total_tokens,omitempty"`
CacheReadTokens uint64 `protobuf:"varint,7,opt,name=cache_read_tokens,json=cacheReadTokens,proto3" json:"cache_read_tokens,omitempty"`
CacheWriteTokens uint64 `protobuf:"varint,8,opt,name=cache_write_tokens,json=cacheWriteTokens,proto3" json:"cache_write_tokens,omitempty"`
LastEvent string `protobuf:"bytes,11,opt,name=last_event,json=lastEvent,proto3" json:"last_event,omitempty"`
// contains filtered or unexported fields
}
func (*AgentStats) Descriptor
deprecated
func (*AgentStats) Descriptor() ([]byte, []int)
Deprecated: Use AgentStats.ProtoReflect.Descriptor instead.
func (*AgentStats) GetCacheReadTokens ¶
func (x *AgentStats) GetCacheReadTokens() uint64
func (*AgentStats) GetCacheWriteTokens ¶
func (x *AgentStats) GetCacheWriteTokens() uint64
func (*AgentStats) GetInputTokens ¶
func (x *AgentStats) GetInputTokens() uint64
func (*AgentStats) GetLastEvent ¶
func (x *AgentStats) GetLastEvent() string
func (*AgentStats) GetOutputTokens ¶
func (x *AgentStats) GetOutputTokens() uint64
func (*AgentStats) GetRunningTools ¶
func (x *AgentStats) GetRunningTools() uint64
func (*AgentStats) GetToolCalls ¶
func (x *AgentStats) GetToolCalls() uint64
func (*AgentStats) GetTotalTokens ¶
func (x *AgentStats) GetTotalTokens() uint64
func (*AgentStats) GetTurns ¶
func (x *AgentStats) GetTurns() uint64
func (*AgentStats) ProtoMessage ¶
func (*AgentStats) ProtoMessage()
func (*AgentStats) ProtoReflect ¶
func (x *AgentStats) ProtoReflect() protoreflect.Message
func (*AgentStats) Reset ¶
func (x *AgentStats) Reset()
func (*AgentStats) String ¶
func (x *AgentStats) String() string
type AgentStatus ¶
type AgentStatus struct {
Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
Model string `protobuf:"bytes,2,opt,name=model,proto3" json:"model,omitempty"`
Space string `protobuf:"bytes,3,opt,name=space,proto3" json:"space,omitempty"`
Bound bool `protobuf:"varint,4,opt,name=bound,proto3" json:"bound,omitempty"`
ConfigError string `protobuf:"bytes,6,opt,name=config_error,json=configError,proto3" json:"config_error,omitempty"`
// contains filtered or unexported fields
}
func (*AgentStatus) Descriptor
deprecated
func (*AgentStatus) Descriptor() ([]byte, []int)
Deprecated: Use AgentStatus.ProtoReflect.Descriptor instead.
func (*AgentStatus) GetBound ¶
func (x *AgentStatus) GetBound() bool
func (*AgentStatus) GetConfigError ¶
func (x *AgentStatus) GetConfigError() string
func (*AgentStatus) GetModel ¶
func (x *AgentStatus) GetModel() string
func (*AgentStatus) GetProvider ¶
func (x *AgentStatus) GetProvider() string
func (*AgentStatus) GetSpace ¶
func (x *AgentStatus) GetSpace() string
func (*AgentStatus) ProtoMessage ¶
func (*AgentStatus) ProtoMessage()
func (*AgentStatus) ProtoReflect ¶
func (x *AgentStatus) ProtoReflect() protoreflect.Message
func (*AgentStatus) Reset ¶
func (x *AgentStatus) Reset()
func (*AgentStatus) String ¶
func (x *AgentStatus) String() string
type Annotation ¶
type Annotation struct {
Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
Start uint64 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
End uint64 `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`
Title string `protobuf:"bytes,4,opt,name=title,proto3" json:"title,omitempty"`
Uri string `protobuf:"bytes,5,opt,name=uri,proto3" json:"uri,omitempty"`
// contains filtered or unexported fields
}
func (*Annotation) Descriptor
deprecated
func (*Annotation) Descriptor() ([]byte, []int)
Deprecated: Use Annotation.ProtoReflect.Descriptor instead.
func (*Annotation) GetEnd ¶
func (x *Annotation) GetEnd() uint64
func (*Annotation) GetStart ¶
func (x *Annotation) GetStart() uint64
func (*Annotation) GetTitle ¶
func (x *Annotation) GetTitle() string
func (*Annotation) GetType ¶
func (x *Annotation) GetType() string
func (*Annotation) GetUri ¶
func (x *Annotation) GetUri() string
func (*Annotation) ProtoMessage ¶
func (*Annotation) ProtoMessage()
func (*Annotation) ProtoReflect ¶
func (x *Annotation) ProtoReflect() protoreflect.Message
func (*Annotation) Reset ¶
func (x *Annotation) Reset()
func (*Annotation) String ¶
func (x *Annotation) String() string
type CancelOperation ¶
type CancelOperation struct {
TargetId string `protobuf:"bytes,1,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
// contains filtered or unexported fields
}
func (*CancelOperation) Descriptor
deprecated
func (*CancelOperation) Descriptor() ([]byte, []int)
Deprecated: Use CancelOperation.ProtoReflect.Descriptor instead.
func (*CancelOperation) GetReason ¶
func (x *CancelOperation) GetReason() string
func (*CancelOperation) GetTargetId ¶
func (x *CancelOperation) GetTargetId() string
func (*CancelOperation) ProtoMessage ¶
func (*CancelOperation) ProtoMessage()
func (*CancelOperation) ProtoReflect ¶
func (x *CancelOperation) ProtoReflect() protoreflect.Message
func (*CancelOperation) Reset ¶
func (x *CancelOperation) Reset()
func (*CancelOperation) String ¶
func (x *CancelOperation) String() string
type CancelTurnRequest ¶
type CancelTurnRequest struct {
SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
TurnId string `protobuf:"bytes,3,opt,name=turn_id,json=turnId,proto3" json:"turn_id,omitempty"`
Reason string `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
// contains filtered or unexported fields
}
func (*CancelTurnRequest) Descriptor
deprecated
func (*CancelTurnRequest) Descriptor() ([]byte, []int)
Deprecated: Use CancelTurnRequest.ProtoReflect.Descriptor instead.
func (*CancelTurnRequest) GetReason ¶
func (x *CancelTurnRequest) GetReason() string
func (*CancelTurnRequest) GetSessionId ¶
func (x *CancelTurnRequest) GetSessionId() string
func (*CancelTurnRequest) GetTurnId ¶
func (x *CancelTurnRequest) GetTurnId() string
func (*CancelTurnRequest) ProtoMessage ¶
func (*CancelTurnRequest) ProtoMessage()
func (*CancelTurnRequest) ProtoReflect ¶
func (x *CancelTurnRequest) ProtoReflect() protoreflect.Message
func (*CancelTurnRequest) Reset ¶
func (x *CancelTurnRequest) Reset()
func (*CancelTurnRequest) String ¶
func (x *CancelTurnRequest) String() string
type CancelTurnResponse ¶
type CancelTurnResponse struct {
// Types that are valid to be assigned to Outcome:
//
// *CancelTurnResponse_Accepted
// *CancelTurnResponse_Rejected
Outcome isCancelTurnResponse_Outcome `protobuf_oneof:"outcome"`
// contains filtered or unexported fields
}
func (*CancelTurnResponse) Descriptor
deprecated
func (*CancelTurnResponse) Descriptor() ([]byte, []int)
Deprecated: Use CancelTurnResponse.ProtoReflect.Descriptor instead.
func (*CancelTurnResponse) GetAccepted ¶
func (x *CancelTurnResponse) GetAccepted() *TurnReceipt
func (*CancelTurnResponse) GetOutcome ¶
func (x *CancelTurnResponse) GetOutcome() isCancelTurnResponse_Outcome
func (*CancelTurnResponse) GetRejected ¶
func (x *CancelTurnResponse) GetRejected() *Rejection
func (*CancelTurnResponse) ProtoMessage ¶
func (*CancelTurnResponse) ProtoMessage()
func (*CancelTurnResponse) ProtoReflect ¶
func (x *CancelTurnResponse) ProtoReflect() protoreflect.Message
func (*CancelTurnResponse) Reset ¶
func (x *CancelTurnResponse) Reset()
func (*CancelTurnResponse) String ¶
func (x *CancelTurnResponse) String() string
type CancelTurnResponse_Accepted ¶
type CancelTurnResponse_Accepted struct {
Accepted *TurnReceipt `protobuf:"bytes,2,opt,name=accepted,proto3,oneof"`
}
type CancelTurnResponse_Rejected ¶
type CancelTurnResponse_Rejected struct {
Rejected *Rejection `protobuf:"bytes,3,opt,name=rejected,proto3,oneof"`
}
type CloseSessionRequest ¶
type CloseSessionRequest struct {
SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
// contains filtered or unexported fields
}
func (*CloseSessionRequest) Descriptor
deprecated
func (*CloseSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseSessionRequest.ProtoReflect.Descriptor instead.
func (*CloseSessionRequest) GetReason ¶
func (x *CloseSessionRequest) GetReason() string
func (*CloseSessionRequest) GetSessionId ¶
func (x *CloseSessionRequest) GetSessionId() string
func (*CloseSessionRequest) ProtoMessage ¶
func (*CloseSessionRequest) ProtoMessage()
func (*CloseSessionRequest) ProtoReflect ¶
func (x *CloseSessionRequest) ProtoReflect() protoreflect.Message
func (*CloseSessionRequest) Reset ¶
func (x *CloseSessionRequest) Reset()
func (*CloseSessionRequest) String ¶
func (x *CloseSessionRequest) String() string
type CloseSessionResponse ¶
type CloseSessionResponse struct {
// Types that are valid to be assigned to Outcome:
//
// *CloseSessionResponse_Accepted
// *CloseSessionResponse_Rejected
Outcome isCloseSessionResponse_Outcome `protobuf_oneof:"outcome"`
// contains filtered or unexported fields
}
func (*CloseSessionResponse) Descriptor
deprecated
func (*CloseSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CloseSessionResponse.ProtoReflect.Descriptor instead.
func (*CloseSessionResponse) GetAccepted ¶
func (x *CloseSessionResponse) GetAccepted() *Session
func (*CloseSessionResponse) GetOutcome ¶
func (x *CloseSessionResponse) GetOutcome() isCloseSessionResponse_Outcome
func (*CloseSessionResponse) GetRejected ¶
func (x *CloseSessionResponse) GetRejected() *Rejection
func (*CloseSessionResponse) ProtoMessage ¶
func (*CloseSessionResponse) ProtoMessage()
func (*CloseSessionResponse) ProtoReflect ¶
func (x *CloseSessionResponse) ProtoReflect() protoreflect.Message
func (*CloseSessionResponse) Reset ¶
func (x *CloseSessionResponse) Reset()
func (*CloseSessionResponse) String ¶
func (x *CloseSessionResponse) String() string
type CloseSessionResponse_Accepted ¶
type CloseSessionResponse_Accepted struct {
Accepted *Session `protobuf:"bytes,2,opt,name=accepted,proto3,oneof"`
}
type CloseSessionResponse_Rejected ¶
type CloseSessionResponse_Rejected struct {
Rejected *Rejection `protobuf:"bytes,3,opt,name=rejected,proto3,oneof"`
}
type Content ¶
type Content struct {
// Types that are valid to be assigned to Value:
//
// *Content_Text
// *Content_Reasoning
// *Content_Refusal
// *Content_Media
// *Content_ToolCall
// *Content_ToolResult
Value isContent_Value `protobuf_oneof:"value"`
// contains filtered or unexported fields
}
func (*Content) Descriptor
deprecated
func (*Content) GetMedia ¶
func (x *Content) GetMedia() *MediaContent
func (*Content) GetReasoning ¶
func (x *Content) GetReasoning() *ReasoningContent
func (*Content) GetRefusal ¶
func (*Content) GetText ¶
func (x *Content) GetText() *TextContent
func (*Content) GetToolCall ¶
func (*Content) GetToolResult ¶
func (x *Content) GetToolResult() *ToolResult
func (*Content) ProtoMessage ¶
func (*Content) ProtoMessage()
func (*Content) ProtoReflect ¶
func (x *Content) ProtoReflect() protoreflect.Message
type Content_Media ¶
type Content_Media struct {
Media *MediaContent `protobuf:"bytes,4,opt,name=media,proto3,oneof"`
}
type Content_Reasoning ¶
type Content_Reasoning struct {
Reasoning *ReasoningContent `protobuf:"bytes,2,opt,name=reasoning,proto3,oneof"`
}
type Content_Refusal ¶
type Content_Refusal struct {
Refusal string `protobuf:"bytes,3,opt,name=refusal,proto3,oneof"`
}
type Content_Text ¶
type Content_Text struct {
Text *TextContent `protobuf:"bytes,1,opt,name=text,proto3,oneof"`
}
type Content_ToolCall ¶
type Content_ToolCall struct {
ToolCall *ToolCall `protobuf:"bytes,5,opt,name=tool_call,json=toolCall,proto3,oneof"`
}
type Content_ToolResult ¶
type Content_ToolResult struct {
ToolResult *ToolResult `protobuf:"bytes,6,opt,name=tool_result,json=toolResult,proto3,oneof"`
}
type DeltaOperation ¶
type DeltaOperation int32
const ( DeltaOperation_DELTA_OPERATION_UNSPECIFIED DeltaOperation = 0 DeltaOperation_DELTA_OPERATION_START DeltaOperation = 1 DeltaOperation_DELTA_OPERATION_APPEND DeltaOperation = 2 DeltaOperation_DELTA_OPERATION_REPLACE DeltaOperation = 3 DeltaOperation_DELTA_OPERATION_END DeltaOperation = 4 )
func (DeltaOperation) Descriptor ¶
func (DeltaOperation) Descriptor() protoreflect.EnumDescriptor
func (DeltaOperation) Enum ¶
func (x DeltaOperation) Enum() *DeltaOperation
func (DeltaOperation) EnumDescriptor
deprecated
func (DeltaOperation) EnumDescriptor() ([]byte, []int)
Deprecated: Use DeltaOperation.Descriptor instead.
func (DeltaOperation) Number ¶
func (x DeltaOperation) Number() protoreflect.EnumNumber
func (DeltaOperation) String ¶
func (x DeltaOperation) String() string
func (DeltaOperation) Type ¶
func (DeltaOperation) Type() protoreflect.EnumType
type Direction ¶
type Direction int32
func (Direction) Descriptor ¶
func (Direction) Descriptor() protoreflect.EnumDescriptor
func (Direction) EnumDescriptor
deprecated
func (Direction) Number ¶
func (x Direction) Number() protoreflect.EnumNumber
func (Direction) Type ¶
func (Direction) Type() protoreflect.EnumType
type EncodedValue ¶
type EncodedValue struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
MediaType string `protobuf:"bytes,2,opt,name=media_type,json=mediaType,proto3" json:"media_type,omitempty"`
// contains filtered or unexported fields
}
EncodedValue carries genuinely opaque data whose schema is not protobuf, notably provider/tool JSON arguments and JSON Schema documents.
func JSONValue ¶
func JSONValue(value any) (*EncodedValue, error)
func (*EncodedValue) Descriptor
deprecated
func (*EncodedValue) Descriptor() ([]byte, []int)
Deprecated: Use EncodedValue.ProtoReflect.Descriptor instead.
func (*EncodedValue) GetData ¶
func (x *EncodedValue) GetData() []byte
func (*EncodedValue) GetMediaType ¶
func (x *EncodedValue) GetMediaType() string
func (*EncodedValue) ProtoMessage ¶
func (*EncodedValue) ProtoMessage()
func (*EncodedValue) ProtoReflect ¶
func (x *EncodedValue) ProtoReflect() protoreflect.Message
func (*EncodedValue) Reset ¶
func (x *EncodedValue) Reset()
func (*EncodedValue) String ¶
func (x *EncodedValue) String() string
type Envelope ¶
type Envelope struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
ReplyTo string `protobuf:"bytes,2,opt,name=reply_to,json=replyTo,proto3" json:"reply_to,omitempty"`
DeliveryCursor string `protobuf:"bytes,3,opt,name=delivery_cursor,json=deliveryCursor,proto3" json:"delivery_cursor,omitempty"`
Payload *anypb.Any `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
// contains filtered or unexported fields
}
Envelope is the only AOP wire envelope. Business namespaces are carried by Any and never extend this message with a global oneof.
func (*Envelope) Descriptor
deprecated
func (*Envelope) GetDeliveryCursor ¶
func (*Envelope) GetPayload ¶
func (*Envelope) GetReplyTo ¶
func (*Envelope) ProtoMessage ¶
func (*Envelope) ProtoMessage()
func (*Envelope) ProtoReflect ¶
func (x *Envelope) ProtoReflect() protoreflect.Message
type EnvelopeStream ¶
EnvelopeStream is the transport boundary for AOP. Implementations only frame and carry protobuf Envelopes; application routing and lifecycle stay in the concrete Hub or AgentRuntime loop.
A caller must use at most one Recv goroutine and one Send goroutine.
type Event ¶
type Event struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
EmittedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=emitted_at,json=emittedAt,proto3" json:"emitted_at,omitempty"`
SessionId string `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
TurnId string `protobuf:"bytes,4,opt,name=turn_id,json=turnId,proto3" json:"turn_id,omitempty"`
Emitter string `protobuf:"bytes,5,opt,name=emitter,proto3" json:"emitter,omitempty"`
Seq uint64 `protobuf:"varint,6,opt,name=seq,proto3" json:"seq,omitempty"`
Extensions []*anypb.Any `protobuf:"bytes,8,rep,name=extensions,proto3" json:"extensions,omitempty"`
// Types that are valid to be assigned to Payload:
//
// *Event_SessionStarted
// *Event_SessionEnded
// *Event_TurnStarted
// *Event_TurnEnded
// *Event_Message
// *Event_MessageDelta
// *Event_ToolCall
// *Event_ToolCallDelta
// *Event_ToolResult
// *Event_Usage
// *Event_Error
// *Event_Status
// *Event_ProviderFrame
// *Event_Extension
Payload isEvent_Payload `protobuf_oneof:"payload"`
// contains filtered or unexported fields
}
func (*Event) Descriptor
deprecated
func (*Event) GetEmittedAt ¶
func (x *Event) GetEmittedAt() *timestamppb.Timestamp
func (*Event) GetEmitter ¶
func (*Event) GetError ¶
func (x *Event) GetError() *ProtocolError
func (*Event) GetExtension ¶
func (*Event) GetExtensions ¶
func (*Event) GetMessage ¶
func (*Event) GetMessageDelta ¶
func (x *Event) GetMessageDelta() *MessageDelta
func (*Event) GetPayload ¶
func (x *Event) GetPayload() isEvent_Payload
func (*Event) GetProviderFrame ¶
func (x *Event) GetProviderFrame() *ProviderFrame
func (*Event) GetSessionEnded ¶
func (x *Event) GetSessionEnded() *SessionEnded
func (*Event) GetSessionId ¶
func (*Event) GetSessionStarted ¶
func (x *Event) GetSessionStarted() *SessionStarted
func (*Event) GetToolCall ¶
func (*Event) GetToolCallDelta ¶
func (x *Event) GetToolCallDelta() *ToolCallDelta
func (*Event) GetToolResult ¶
func (x *Event) GetToolResult() *ToolResult
func (*Event) GetTurnEnded ¶
func (*Event) GetTurnStarted ¶
func (x *Event) GetTurnStarted() *TurnStarted
func (*Event) GetUsage ¶
func (x *Event) GetUsage() *TokenUsage
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type EventDelivery ¶
type EventDelivery struct {
Cursor string `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
Event *Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
// contains filtered or unexported fields
}
func (*EventDelivery) Descriptor
deprecated
func (*EventDelivery) Descriptor() ([]byte, []int)
Deprecated: Use EventDelivery.ProtoReflect.Descriptor instead.
func (*EventDelivery) GetCursor ¶
func (x *EventDelivery) GetCursor() string
func (*EventDelivery) GetEvent ¶
func (x *EventDelivery) GetEvent() *Event
func (*EventDelivery) ProtoMessage ¶
func (*EventDelivery) ProtoMessage()
func (*EventDelivery) ProtoReflect ¶
func (x *EventDelivery) ProtoReflect() protoreflect.Message
func (*EventDelivery) Reset ¶
func (x *EventDelivery) Reset()
func (*EventDelivery) String ¶
func (x *EventDelivery) String() string
type EventEmitter ¶
type EventEmitter interface {
Emit(*Event)
}
type Event_Error ¶
type Event_Error struct {
Error *ProtocolError `protobuf:"bytes,20,opt,name=error,proto3,oneof"`
}
type Event_Extension ¶
type Event_Message ¶
type Event_Message struct {
Message *Message `protobuf:"bytes,14,opt,name=message,proto3,oneof"`
}
type Event_MessageDelta ¶
type Event_MessageDelta struct {
MessageDelta *MessageDelta `protobuf:"bytes,15,opt,name=message_delta,json=messageDelta,proto3,oneof"`
}
type Event_ProviderFrame ¶
type Event_ProviderFrame struct {
ProviderFrame *ProviderFrame `protobuf:"bytes,23,opt,name=provider_frame,json=providerFrame,proto3,oneof"`
}
type Event_SessionEnded ¶
type Event_SessionEnded struct {
SessionEnded *SessionEnded `protobuf:"bytes,11,opt,name=session_ended,json=sessionEnded,proto3,oneof"`
}
type Event_SessionStarted ¶
type Event_SessionStarted struct {
SessionStarted *SessionStarted `protobuf:"bytes,10,opt,name=session_started,json=sessionStarted,proto3,oneof"`
}
type Event_Status ¶
type Event_Status struct {
Status *Status `protobuf:"bytes,21,opt,name=status,proto3,oneof"`
}
type Event_ToolCall ¶
type Event_ToolCall struct {
ToolCall *ToolCall `protobuf:"bytes,16,opt,name=tool_call,json=toolCall,proto3,oneof"`
}
type Event_ToolCallDelta ¶
type Event_ToolCallDelta struct {
ToolCallDelta *ToolCallDelta `protobuf:"bytes,17,opt,name=tool_call_delta,json=toolCallDelta,proto3,oneof"`
}
type Event_ToolResult ¶
type Event_ToolResult struct {
ToolResult *ToolResult `protobuf:"bytes,18,opt,name=tool_result,json=toolResult,proto3,oneof"`
}
type Event_TurnEnded ¶
type Event_TurnEnded struct {
TurnEnded *TurnEnded `protobuf:"bytes,13,opt,name=turn_ended,json=turnEnded,proto3,oneof"`
}
type Event_TurnStarted ¶
type Event_TurnStarted struct {
TurnStarted *TurnStarted `protobuf:"bytes,12,opt,name=turn_started,json=turnStarted,proto3,oneof"`
}
type Event_Usage ¶
type Event_Usage struct {
Usage *TokenUsage `protobuf:"bytes,19,opt,name=usage,proto3,oneof"`
}
type ListEventsRequest ¶
type ListEventsRequest struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
AfterCursor string `protobuf:"bytes,2,opt,name=after_cursor,json=afterCursor,proto3" json:"after_cursor,omitempty"`
Limit uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
// contains filtered or unexported fields
}
func (*ListEventsRequest) Descriptor
deprecated
func (*ListEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListEventsRequest.ProtoReflect.Descriptor instead.
func (*ListEventsRequest) GetAfterCursor ¶
func (x *ListEventsRequest) GetAfterCursor() string
func (*ListEventsRequest) GetLimit ¶
func (x *ListEventsRequest) GetLimit() uint32
func (*ListEventsRequest) GetSessionId ¶
func (x *ListEventsRequest) GetSessionId() string
func (*ListEventsRequest) ProtoMessage ¶
func (*ListEventsRequest) ProtoMessage()
func (*ListEventsRequest) ProtoReflect ¶
func (x *ListEventsRequest) ProtoReflect() protoreflect.Message
func (*ListEventsRequest) Reset ¶
func (x *ListEventsRequest) Reset()
func (*ListEventsRequest) String ¶
func (x *ListEventsRequest) String() string
type ListEventsResponse ¶
type ListEventsResponse struct {
Events []*EventDelivery `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
NextCursor string `protobuf:"bytes,2,opt,name=next_cursor,json=nextCursor,proto3" json:"next_cursor,omitempty"`
// contains filtered or unexported fields
}
func (*ListEventsResponse) Descriptor
deprecated
func (*ListEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListEventsResponse.ProtoReflect.Descriptor instead.
func (*ListEventsResponse) GetEvents ¶
func (x *ListEventsResponse) GetEvents() []*EventDelivery
func (*ListEventsResponse) GetNextCursor ¶
func (x *ListEventsResponse) GetNextCursor() string
func (*ListEventsResponse) ProtoMessage ¶
func (*ListEventsResponse) ProtoMessage()
func (*ListEventsResponse) ProtoReflect ¶
func (x *ListEventsResponse) ProtoReflect() protoreflect.Message
func (*ListEventsResponse) Reset ¶
func (x *ListEventsResponse) Reset()
func (*ListEventsResponse) String ¶
func (x *ListEventsResponse) String() string
type MediaContent ¶
type MediaContent struct {
Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
Resource *Resource `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
Transcript string `protobuf:"bytes,3,opt,name=transcript,proto3" json:"transcript,omitempty"`
// contains filtered or unexported fields
}
func (*MediaContent) Descriptor
deprecated
func (*MediaContent) Descriptor() ([]byte, []int)
Deprecated: Use MediaContent.ProtoReflect.Descriptor instead.
func (*MediaContent) GetKind ¶
func (x *MediaContent) GetKind() string
func (*MediaContent) GetResource ¶
func (x *MediaContent) GetResource() *Resource
func (*MediaContent) GetTranscript ¶
func (x *MediaContent) GetTranscript() string
func (*MediaContent) ProtoMessage ¶
func (*MediaContent) ProtoMessage()
func (*MediaContent) ProtoReflect ¶
func (x *MediaContent) ProtoReflect() protoreflect.Message
func (*MediaContent) Reset ¶
func (x *MediaContent) Reset()
func (*MediaContent) String ¶
func (x *MediaContent) String() string
type Message ¶
type Message struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Role string `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
Content []*Content `protobuf:"bytes,4,rep,name=content,proto3" json:"content,omitempty"`
// contains filtered or unexported fields
}
func (*Message) Descriptor
deprecated
func (*Message) GetContent ¶
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) ProtoReflect ¶
func (x *Message) ProtoReflect() protoreflect.Message
type MessageDelta ¶
type MessageDelta struct {
MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
ContentIndex uint32 `protobuf:"varint,2,opt,name=content_index,json=contentIndex,proto3" json:"content_index,omitempty"`
Operation DeltaOperation `protobuf:"varint,3,opt,name=operation,proto3,enum=aop.DeltaOperation" json:"operation,omitempty"`
// Types that are valid to be assigned to Value:
//
// *MessageDelta_Text
// *MessageDelta_Reasoning
// *MessageDelta_Refusal
// *MessageDelta_Data
// *MessageDelta_ToolArguments
// *MessageDelta_Content
Value isMessageDelta_Value `protobuf_oneof:"value"`
// contains filtered or unexported fields
}
func (*MessageDelta) Descriptor
deprecated
func (*MessageDelta) Descriptor() ([]byte, []int)
Deprecated: Use MessageDelta.ProtoReflect.Descriptor instead.
func (*MessageDelta) GetContent ¶
func (x *MessageDelta) GetContent() *Content
func (*MessageDelta) GetContentIndex ¶
func (x *MessageDelta) GetContentIndex() uint32
func (*MessageDelta) GetData ¶
func (x *MessageDelta) GetData() []byte
func (*MessageDelta) GetMessageId ¶
func (x *MessageDelta) GetMessageId() string
func (*MessageDelta) GetOperation ¶
func (x *MessageDelta) GetOperation() DeltaOperation
func (*MessageDelta) GetReasoning ¶
func (x *MessageDelta) GetReasoning() string
func (*MessageDelta) GetRefusal ¶
func (x *MessageDelta) GetRefusal() string
func (*MessageDelta) GetText ¶
func (x *MessageDelta) GetText() string
func (*MessageDelta) GetToolArguments ¶
func (x *MessageDelta) GetToolArguments() string
func (*MessageDelta) GetValue ¶
func (x *MessageDelta) GetValue() isMessageDelta_Value
func (*MessageDelta) ProtoMessage ¶
func (*MessageDelta) ProtoMessage()
func (*MessageDelta) ProtoReflect ¶
func (x *MessageDelta) ProtoReflect() protoreflect.Message
func (*MessageDelta) Reset ¶
func (x *MessageDelta) Reset()
func (*MessageDelta) String ¶
func (x *MessageDelta) String() string
type MessageDelta_Content ¶
type MessageDelta_Content struct {
Content *Content `protobuf:"bytes,9,opt,name=content,proto3,oneof"`
}
type MessageDelta_Data ¶
type MessageDelta_Data struct {
Data []byte `protobuf:"bytes,7,opt,name=data,proto3,oneof"`
}
type MessageDelta_Reasoning ¶
type MessageDelta_Reasoning struct {
Reasoning string `protobuf:"bytes,5,opt,name=reasoning,proto3,oneof"`
}
type MessageDelta_Refusal ¶
type MessageDelta_Refusal struct {
Refusal string `protobuf:"bytes,6,opt,name=refusal,proto3,oneof"`
}
type MessageDelta_Text ¶
type MessageDelta_Text struct {
Text string `protobuf:"bytes,4,opt,name=text,proto3,oneof"`
}
type MessageDelta_ToolArguments ¶
type MessageDelta_ToolArguments struct {
ToolArguments string `protobuf:"bytes,8,opt,name=tool_arguments,json=toolArguments,proto3,oneof"`
}
type NamespaceHandler ¶
NamespaceHandler processes one registered top-level namespace message. The handler owns business semantics; NamespaceMux only decodes and routes.
type NamespaceMux ¶
type NamespaceMux struct {
// contains filtered or unexported fields
}
NamespaceMux routes Envelope.payload by protobuf full name. Mux instances are application-owned; there is no global registry or lifecycle ownership.
func NewNamespaceMux ¶
func NewNamespaceMux() *NamespaceMux
func (*NamespaceMux) Dispatch ¶
func (m *NamespaceMux) Dispatch(ctx context.Context, envelope *Envelope, send SendFunc) (handled bool, err error)
Dispatch decodes and handles one registered namespace. Unknown namespaces return handled=false so the connection owner can emit its protocol error.
func (*NamespaceMux) Register ¶
func (m *NamespaceMux) Register(prototype proto.Message, handler NamespaceHandler) error
Register adds one namespace protocol-message handler. Applications register namespaces during construction, before Dispatch is used concurrently.
type OpenSessionRequest ¶
type OpenSessionRequest struct {
SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
NodeId string `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
Title string `protobuf:"bytes,4,opt,name=title,proto3" json:"title,omitempty"`
ParentSessionId string `protobuf:"bytes,5,opt,name=parent_session_id,json=parentSessionId,proto3" json:"parent_session_id,omitempty"`
ParentToolCallId string `protobuf:"bytes,6,opt,name=parent_tool_call_id,json=parentToolCallId,proto3" json:"parent_tool_call_id,omitempty"`
Extensions []*anypb.Any `protobuf:"bytes,8,rep,name=extensions,proto3" json:"extensions,omitempty"`
// contains filtered or unexported fields
}
func (*OpenSessionRequest) Descriptor
deprecated
func (*OpenSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use OpenSessionRequest.ProtoReflect.Descriptor instead.
func (*OpenSessionRequest) GetExtensions ¶
func (x *OpenSessionRequest) GetExtensions() []*anypb.Any
func (*OpenSessionRequest) GetNodeId ¶
func (x *OpenSessionRequest) GetNodeId() string
func (*OpenSessionRequest) GetParentSessionId ¶
func (x *OpenSessionRequest) GetParentSessionId() string
func (*OpenSessionRequest) GetParentToolCallId ¶
func (x *OpenSessionRequest) GetParentToolCallId() string
func (*OpenSessionRequest) GetSessionId ¶
func (x *OpenSessionRequest) GetSessionId() string
func (*OpenSessionRequest) GetTitle ¶
func (x *OpenSessionRequest) GetTitle() string
func (*OpenSessionRequest) ProtoMessage ¶
func (*OpenSessionRequest) ProtoMessage()
func (*OpenSessionRequest) ProtoReflect ¶
func (x *OpenSessionRequest) ProtoReflect() protoreflect.Message
func (*OpenSessionRequest) Reset ¶
func (x *OpenSessionRequest) Reset()
func (*OpenSessionRequest) String ¶
func (x *OpenSessionRequest) String() string
type OpenSessionResponse ¶
type OpenSessionResponse struct {
// Types that are valid to be assigned to Outcome:
//
// *OpenSessionResponse_Accepted
// *OpenSessionResponse_Rejected
Outcome isOpenSessionResponse_Outcome `protobuf_oneof:"outcome"`
// contains filtered or unexported fields
}
func (*OpenSessionResponse) Descriptor
deprecated
func (*OpenSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use OpenSessionResponse.ProtoReflect.Descriptor instead.
func (*OpenSessionResponse) GetAccepted ¶
func (x *OpenSessionResponse) GetAccepted() *Session
func (*OpenSessionResponse) GetOutcome ¶
func (x *OpenSessionResponse) GetOutcome() isOpenSessionResponse_Outcome
func (*OpenSessionResponse) GetRejected ¶
func (x *OpenSessionResponse) GetRejected() *Rejection
func (*OpenSessionResponse) ProtoMessage ¶
func (*OpenSessionResponse) ProtoMessage()
func (*OpenSessionResponse) ProtoReflect ¶
func (x *OpenSessionResponse) ProtoReflect() protoreflect.Message
func (*OpenSessionResponse) Reset ¶
func (x *OpenSessionResponse) Reset()
func (*OpenSessionResponse) String ¶
func (x *OpenSessionResponse) String() string
type OpenSessionResponse_Accepted ¶
type OpenSessionResponse_Accepted struct {
Accepted *Session `protobuf:"bytes,2,opt,name=accepted,proto3,oneof"`
}
type OpenSessionResponse_Rejected ¶
type OpenSessionResponse_Rejected struct {
Rejected *Rejection `protobuf:"bytes,3,opt,name=rejected,proto3,oneof"`
}
type ProtocolError ¶
type ProtocolError struct {
Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
Retryable bool `protobuf:"varint,3,opt,name=retryable,proto3" json:"retryable,omitempty"`
// contains filtered or unexported fields
}
func (*ProtocolError) Descriptor
deprecated
func (*ProtocolError) Descriptor() ([]byte, []int)
Deprecated: Use ProtocolError.ProtoReflect.Descriptor instead.
func (*ProtocolError) GetCode ¶
func (x *ProtocolError) GetCode() string
func (*ProtocolError) GetMessage ¶
func (x *ProtocolError) GetMessage() string
func (*ProtocolError) GetRetryable ¶
func (x *ProtocolError) GetRetryable() bool
func (*ProtocolError) ProtoMessage ¶
func (*ProtocolError) ProtoMessage()
func (*ProtocolError) ProtoReflect ¶
func (x *ProtocolError) ProtoReflect() protoreflect.Message
func (*ProtocolError) Reset ¶
func (x *ProtocolError) Reset()
func (*ProtocolError) String ¶
func (x *ProtocolError) String() string
type ProtocolMessage ¶
type ProtocolMessage struct {
// Types that are valid to be assigned to Message:
//
// *ProtocolMessage_AgentHello
// *ProtocolMessage_AgentAccepted
// *ProtocolMessage_AgentStatus
// *ProtocolMessage_AgentStats
// *ProtocolMessage_OpenSessionRequest
// *ProtocolMessage_OpenSessionResponse
// *ProtocolMessage_RunTurnRequest
// *ProtocolMessage_RunTurnResponse
// *ProtocolMessage_CancelTurnRequest
// *ProtocolMessage_CancelTurnResponse
// *ProtocolMessage_CloseSessionRequest
// *ProtocolMessage_CloseSessionResponse
// *ProtocolMessage_WatchEventsRequest
// *ProtocolMessage_ListEventsRequest
// *ProtocolMessage_ListEventsResponse
// *ProtocolMessage_Event
// *ProtocolMessage_CancelOperation
// *ProtocolMessage_ProtocolError
Message isProtocolMessage_Message `protobuf_oneof:"message"`
// contains filtered or unexported fields
}
ProtocolMessage is the typed union for the AOP core namespace. Extension packages define their own ProtocolMessage and do not modify this one.
func (*ProtocolMessage) Descriptor
deprecated
func (*ProtocolMessage) Descriptor() ([]byte, []int)
Deprecated: Use ProtocolMessage.ProtoReflect.Descriptor instead.
func (*ProtocolMessage) GetAgentAccepted ¶
func (x *ProtocolMessage) GetAgentAccepted() *AgentAccepted
func (*ProtocolMessage) GetAgentHello ¶
func (x *ProtocolMessage) GetAgentHello() *AgentHello
func (*ProtocolMessage) GetAgentStats ¶
func (x *ProtocolMessage) GetAgentStats() *AgentStats
func (*ProtocolMessage) GetAgentStatus ¶
func (x *ProtocolMessage) GetAgentStatus() *AgentStatus
func (*ProtocolMessage) GetCancelOperation ¶
func (x *ProtocolMessage) GetCancelOperation() *CancelOperation
func (*ProtocolMessage) GetCancelTurnRequest ¶
func (x *ProtocolMessage) GetCancelTurnRequest() *CancelTurnRequest
func (*ProtocolMessage) GetCancelTurnResponse ¶
func (x *ProtocolMessage) GetCancelTurnResponse() *CancelTurnResponse
func (*ProtocolMessage) GetCloseSessionRequest ¶
func (x *ProtocolMessage) GetCloseSessionRequest() *CloseSessionRequest
func (*ProtocolMessage) GetCloseSessionResponse ¶
func (x *ProtocolMessage) GetCloseSessionResponse() *CloseSessionResponse
func (*ProtocolMessage) GetEvent ¶
func (x *ProtocolMessage) GetEvent() *Event
func (*ProtocolMessage) GetListEventsRequest ¶
func (x *ProtocolMessage) GetListEventsRequest() *ListEventsRequest
func (*ProtocolMessage) GetListEventsResponse ¶
func (x *ProtocolMessage) GetListEventsResponse() *ListEventsResponse
func (*ProtocolMessage) GetMessage ¶
func (x *ProtocolMessage) GetMessage() isProtocolMessage_Message
func (*ProtocolMessage) GetOpenSessionRequest ¶
func (x *ProtocolMessage) GetOpenSessionRequest() *OpenSessionRequest
func (*ProtocolMessage) GetOpenSessionResponse ¶
func (x *ProtocolMessage) GetOpenSessionResponse() *OpenSessionResponse
func (*ProtocolMessage) GetProtocolError ¶
func (x *ProtocolMessage) GetProtocolError() *ProtocolError
func (*ProtocolMessage) GetRunTurnRequest ¶
func (x *ProtocolMessage) GetRunTurnRequest() *RunTurnRequest
func (*ProtocolMessage) GetRunTurnResponse ¶
func (x *ProtocolMessage) GetRunTurnResponse() *RunTurnResponse
func (*ProtocolMessage) GetWatchEventsRequest ¶
func (x *ProtocolMessage) GetWatchEventsRequest() *WatchEventsRequest
func (*ProtocolMessage) ProtoMessage ¶
func (*ProtocolMessage) ProtoMessage()
func (*ProtocolMessage) ProtoReflect ¶
func (x *ProtocolMessage) ProtoReflect() protoreflect.Message
func (*ProtocolMessage) Reset ¶
func (x *ProtocolMessage) Reset()
func (*ProtocolMessage) String ¶
func (x *ProtocolMessage) String() string
type ProtocolMessage_AgentAccepted ¶
type ProtocolMessage_AgentAccepted struct {
AgentAccepted *AgentAccepted `protobuf:"bytes,11,opt,name=agent_accepted,json=agentAccepted,proto3,oneof"`
}
type ProtocolMessage_AgentHello ¶
type ProtocolMessage_AgentHello struct {
AgentHello *AgentHello `protobuf:"bytes,10,opt,name=agent_hello,json=agentHello,proto3,oneof"`
}
type ProtocolMessage_AgentStats ¶
type ProtocolMessage_AgentStats struct {
AgentStats *AgentStats `protobuf:"bytes,13,opt,name=agent_stats,json=agentStats,proto3,oneof"`
}
type ProtocolMessage_AgentStatus ¶
type ProtocolMessage_AgentStatus struct {
AgentStatus *AgentStatus `protobuf:"bytes,12,opt,name=agent_status,json=agentStatus,proto3,oneof"`
}
type ProtocolMessage_CancelOperation ¶
type ProtocolMessage_CancelOperation struct {
CancelOperation *CancelOperation `protobuf:"bytes,40,opt,name=cancel_operation,json=cancelOperation,proto3,oneof"`
}
type ProtocolMessage_CancelTurnRequest ¶
type ProtocolMessage_CancelTurnRequest struct {
CancelTurnRequest *CancelTurnRequest `protobuf:"bytes,24,opt,name=cancel_turn_request,json=cancelTurnRequest,proto3,oneof"`
}
type ProtocolMessage_CancelTurnResponse ¶
type ProtocolMessage_CancelTurnResponse struct {
CancelTurnResponse *CancelTurnResponse `protobuf:"bytes,25,opt,name=cancel_turn_response,json=cancelTurnResponse,proto3,oneof"`
}
type ProtocolMessage_CloseSessionRequest ¶
type ProtocolMessage_CloseSessionRequest struct {
CloseSessionRequest *CloseSessionRequest `protobuf:"bytes,26,opt,name=close_session_request,json=closeSessionRequest,proto3,oneof"`
}
type ProtocolMessage_CloseSessionResponse ¶
type ProtocolMessage_CloseSessionResponse struct {
CloseSessionResponse *CloseSessionResponse `protobuf:"bytes,27,opt,name=close_session_response,json=closeSessionResponse,proto3,oneof"`
}
type ProtocolMessage_Event ¶
type ProtocolMessage_Event struct {
Event *Event `protobuf:"bytes,31,opt,name=event,proto3,oneof"`
}
type ProtocolMessage_ListEventsRequest ¶
type ProtocolMessage_ListEventsRequest struct {
ListEventsRequest *ListEventsRequest `protobuf:"bytes,29,opt,name=list_events_request,json=listEventsRequest,proto3,oneof"`
}
type ProtocolMessage_ListEventsResponse ¶
type ProtocolMessage_ListEventsResponse struct {
ListEventsResponse *ListEventsResponse `protobuf:"bytes,30,opt,name=list_events_response,json=listEventsResponse,proto3,oneof"`
}
type ProtocolMessage_OpenSessionRequest ¶
type ProtocolMessage_OpenSessionRequest struct {
OpenSessionRequest *OpenSessionRequest `protobuf:"bytes,20,opt,name=open_session_request,json=openSessionRequest,proto3,oneof"`
}
type ProtocolMessage_OpenSessionResponse ¶
type ProtocolMessage_OpenSessionResponse struct {
OpenSessionResponse *OpenSessionResponse `protobuf:"bytes,21,opt,name=open_session_response,json=openSessionResponse,proto3,oneof"`
}
type ProtocolMessage_ProtocolError ¶
type ProtocolMessage_ProtocolError struct {
ProtocolError *ProtocolError `protobuf:"bytes,41,opt,name=protocol_error,json=protocolError,proto3,oneof"`
}
type ProtocolMessage_RunTurnRequest ¶
type ProtocolMessage_RunTurnRequest struct {
RunTurnRequest *RunTurnRequest `protobuf:"bytes,22,opt,name=run_turn_request,json=runTurnRequest,proto3,oneof"`
}
type ProtocolMessage_RunTurnResponse ¶
type ProtocolMessage_RunTurnResponse struct {
RunTurnResponse *RunTurnResponse `protobuf:"bytes,23,opt,name=run_turn_response,json=runTurnResponse,proto3,oneof"`
}
type ProtocolMessage_WatchEventsRequest ¶
type ProtocolMessage_WatchEventsRequest struct {
WatchEventsRequest *WatchEventsRequest `protobuf:"bytes,28,opt,name=watch_events_request,json=watchEventsRequest,proto3,oneof"`
}
type ProviderFrame ¶
type ProviderFrame struct {
Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
EventType string `protobuf:"bytes,3,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
Direction Direction `protobuf:"varint,4,opt,name=direction,proto3,enum=aop.Direction" json:"direction,omitempty"`
Transport string `protobuf:"bytes,5,opt,name=transport,proto3" json:"transport,omitempty"`
Payload []byte `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
MediaType string `protobuf:"bytes,7,opt,name=media_type,json=mediaType,proto3" json:"media_type,omitempty"`
Metadata []*ProviderMetadata `protobuf:"bytes,8,rep,name=metadata,proto3" json:"metadata,omitempty"`
// contains filtered or unexported fields
}
ProviderFrame preserves one exact provider body or stream frame.
func (*ProviderFrame) Descriptor
deprecated
func (*ProviderFrame) Descriptor() ([]byte, []int)
Deprecated: Use ProviderFrame.ProtoReflect.Descriptor instead.
func (*ProviderFrame) GetDirection ¶
func (x *ProviderFrame) GetDirection() Direction
func (*ProviderFrame) GetEventType ¶
func (x *ProviderFrame) GetEventType() string
func (*ProviderFrame) GetMediaType ¶
func (x *ProviderFrame) GetMediaType() string
func (*ProviderFrame) GetMetadata ¶
func (x *ProviderFrame) GetMetadata() []*ProviderMetadata
func (*ProviderFrame) GetPayload ¶
func (x *ProviderFrame) GetPayload() []byte
func (*ProviderFrame) GetProtocol ¶
func (x *ProviderFrame) GetProtocol() string
func (*ProviderFrame) GetProvider ¶
func (x *ProviderFrame) GetProvider() string
func (*ProviderFrame) GetTransport ¶
func (x *ProviderFrame) GetTransport() string
func (*ProviderFrame) ProtoMessage ¶
func (*ProviderFrame) ProtoMessage()
func (*ProviderFrame) ProtoReflect ¶
func (x *ProviderFrame) ProtoReflect() protoreflect.Message
func (*ProviderFrame) Reset ¶
func (x *ProviderFrame) Reset()
func (*ProviderFrame) String ¶
func (x *ProviderFrame) String() string
type ProviderMetadata ¶
type ProviderMetadata struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*ProviderMetadata) Descriptor
deprecated
func (*ProviderMetadata) Descriptor() ([]byte, []int)
Deprecated: Use ProviderMetadata.ProtoReflect.Descriptor instead.
func (*ProviderMetadata) GetName ¶
func (x *ProviderMetadata) GetName() string
func (*ProviderMetadata) GetValue ¶
func (x *ProviderMetadata) GetValue() []byte
func (*ProviderMetadata) ProtoMessage ¶
func (*ProviderMetadata) ProtoMessage()
func (*ProviderMetadata) ProtoReflect ¶
func (x *ProviderMetadata) ProtoReflect() protoreflect.Message
func (*ProviderMetadata) Reset ¶
func (x *ProviderMetadata) Reset()
func (*ProviderMetadata) String ¶
func (x *ProviderMetadata) String() string
type ReasoningContent ¶
type ReasoningContent struct {
Text string `protobuf:"bytes,1,opt,name=text,proto3" json:"text,omitempty"`
// contains filtered or unexported fields
}
func (*ReasoningContent) Descriptor
deprecated
func (*ReasoningContent) Descriptor() ([]byte, []int)
Deprecated: Use ReasoningContent.ProtoReflect.Descriptor instead.
func (*ReasoningContent) GetText ¶
func (x *ReasoningContent) GetText() string
func (*ReasoningContent) ProtoMessage ¶
func (*ReasoningContent) ProtoMessage()
func (*ReasoningContent) ProtoReflect ¶
func (x *ReasoningContent) ProtoReflect() protoreflect.Message
func (*ReasoningContent) Reset ¶
func (x *ReasoningContent) Reset()
func (*ReasoningContent) String ¶
func (x *ReasoningContent) String() string
type Rejection ¶
type Rejection struct {
Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
Retryable bool `protobuf:"varint,3,opt,name=retryable,proto3" json:"retryable,omitempty"`
// contains filtered or unexported fields
}
func (*Rejection) Descriptor
deprecated
func (*Rejection) GetMessage ¶
func (*Rejection) GetRetryable ¶
func (*Rejection) ProtoMessage ¶
func (*Rejection) ProtoMessage()
func (*Rejection) ProtoReflect ¶
func (x *Rejection) ProtoReflect() protoreflect.Message
type Resource ¶
type Resource struct {
// Types that are valid to be assigned to Source:
//
// *Resource_Data
// *Resource_Uri
Source isResource_Source `protobuf_oneof:"source"`
MediaType string `protobuf:"bytes,3,opt,name=media_type,json=mediaType,proto3" json:"media_type,omitempty"`
Filename string `protobuf:"bytes,4,opt,name=filename,proto3" json:"filename,omitempty"`
// contains filtered or unexported fields
}
func (*Resource) Descriptor
deprecated
func (*Resource) GetFilename ¶
func (*Resource) GetMediaType ¶
func (*Resource) ProtoMessage ¶
func (*Resource) ProtoMessage()
func (*Resource) ProtoReflect ¶
func (x *Resource) ProtoReflect() protoreflect.Message
type Resource_Data ¶
type Resource_Data struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3,oneof"`
}
type Resource_Uri ¶
type Resource_Uri struct {
Uri string `protobuf:"bytes,2,opt,name=uri,proto3,oneof"`
}
type RunTurnRequest ¶
type RunTurnRequest struct {
SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
TurnId string `protobuf:"bytes,3,opt,name=turn_id,json=turnId,proto3" json:"turn_id,omitempty"`
Input *Message `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
ContinueSession bool `protobuf:"varint,5,opt,name=continue_session,json=continueSession,proto3" json:"continue_session,omitempty"`
MaxTurns uint32 `protobuf:"varint,6,opt,name=max_turns,json=maxTurns,proto3" json:"max_turns,omitempty"`
Extensions []*anypb.Any `protobuf:"bytes,8,rep,name=extensions,proto3" json:"extensions,omitempty"`
// contains filtered or unexported fields
}
func (*RunTurnRequest) Descriptor
deprecated
func (*RunTurnRequest) Descriptor() ([]byte, []int)
Deprecated: Use RunTurnRequest.ProtoReflect.Descriptor instead.
func (*RunTurnRequest) GetContinueSession ¶
func (x *RunTurnRequest) GetContinueSession() bool
func (*RunTurnRequest) GetExtensions ¶
func (x *RunTurnRequest) GetExtensions() []*anypb.Any
func (*RunTurnRequest) GetInput ¶
func (x *RunTurnRequest) GetInput() *Message
func (*RunTurnRequest) GetMaxTurns ¶
func (x *RunTurnRequest) GetMaxTurns() uint32
func (*RunTurnRequest) GetSessionId ¶
func (x *RunTurnRequest) GetSessionId() string
func (*RunTurnRequest) GetTurnId ¶
func (x *RunTurnRequest) GetTurnId() string
func (*RunTurnRequest) ProtoMessage ¶
func (*RunTurnRequest) ProtoMessage()
func (*RunTurnRequest) ProtoReflect ¶
func (x *RunTurnRequest) ProtoReflect() protoreflect.Message
func (*RunTurnRequest) Reset ¶
func (x *RunTurnRequest) Reset()
func (*RunTurnRequest) String ¶
func (x *RunTurnRequest) String() string
type RunTurnResponse ¶
type RunTurnResponse struct {
// Types that are valid to be assigned to Outcome:
//
// *RunTurnResponse_Accepted
// *RunTurnResponse_Rejected
Outcome isRunTurnResponse_Outcome `protobuf_oneof:"outcome"`
// contains filtered or unexported fields
}
func (*RunTurnResponse) Descriptor
deprecated
func (*RunTurnResponse) Descriptor() ([]byte, []int)
Deprecated: Use RunTurnResponse.ProtoReflect.Descriptor instead.
func (*RunTurnResponse) GetAccepted ¶
func (x *RunTurnResponse) GetAccepted() *TurnReceipt
func (*RunTurnResponse) GetOutcome ¶
func (x *RunTurnResponse) GetOutcome() isRunTurnResponse_Outcome
func (*RunTurnResponse) GetRejected ¶
func (x *RunTurnResponse) GetRejected() *Rejection
func (*RunTurnResponse) ProtoMessage ¶
func (*RunTurnResponse) ProtoMessage()
func (*RunTurnResponse) ProtoReflect ¶
func (x *RunTurnResponse) ProtoReflect() protoreflect.Message
func (*RunTurnResponse) Reset ¶
func (x *RunTurnResponse) Reset()
func (*RunTurnResponse) String ¶
func (x *RunTurnResponse) String() string
type RunTurnResponse_Accepted ¶
type RunTurnResponse_Accepted struct {
Accepted *TurnReceipt `protobuf:"bytes,2,opt,name=accepted,proto3,oneof"`
}
type RunTurnResponse_Rejected ¶
type RunTurnResponse_Rejected struct {
Rejected *Rejection `protobuf:"bytes,3,opt,name=rejected,proto3,oneof"`
}
type Session ¶
type Session struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
State string `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
NodeId string `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
Title string `protobuf:"bytes,4,opt,name=title,proto3" json:"title,omitempty"`
// contains filtered or unexported fields
}
func (*Session) Descriptor
deprecated
func (*Session) ProtoMessage ¶
func (*Session) ProtoMessage()
func (*Session) ProtoReflect ¶
func (x *Session) ProtoReflect() protoreflect.Message
type SessionEnded ¶
type SessionEnded struct {
Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
// contains filtered or unexported fields
}
func (*SessionEnded) Descriptor
deprecated
func (*SessionEnded) Descriptor() ([]byte, []int)
Deprecated: Use SessionEnded.ProtoReflect.Descriptor instead.
func (*SessionEnded) GetReason ¶
func (x *SessionEnded) GetReason() string
func (*SessionEnded) ProtoMessage ¶
func (*SessionEnded) ProtoMessage()
func (*SessionEnded) ProtoReflect ¶
func (x *SessionEnded) ProtoReflect() protoreflect.Message
func (*SessionEnded) Reset ¶
func (x *SessionEnded) Reset()
func (*SessionEnded) String ¶
func (x *SessionEnded) String() string
type SessionStarted ¶
type SessionStarted struct {
Model string `protobuf:"bytes,1,opt,name=model,proto3" json:"model,omitempty"`
ParentSessionId string `protobuf:"bytes,2,opt,name=parent_session_id,json=parentSessionId,proto3" json:"parent_session_id,omitempty"`
ParentToolCallId string `protobuf:"bytes,3,opt,name=parent_tool_call_id,json=parentToolCallId,proto3" json:"parent_tool_call_id,omitempty"`
// contains filtered or unexported fields
}
func (*SessionStarted) Descriptor
deprecated
func (*SessionStarted) Descriptor() ([]byte, []int)
Deprecated: Use SessionStarted.ProtoReflect.Descriptor instead.
func (*SessionStarted) GetModel ¶
func (x *SessionStarted) GetModel() string
func (*SessionStarted) GetParentSessionId ¶
func (x *SessionStarted) GetParentSessionId() string
func (*SessionStarted) GetParentToolCallId ¶
func (x *SessionStarted) GetParentToolCallId() string
func (*SessionStarted) ProtoMessage ¶
func (*SessionStarted) ProtoMessage()
func (*SessionStarted) ProtoReflect ¶
func (x *SessionStarted) ProtoReflect() protoreflect.Message
func (*SessionStarted) Reset ¶
func (x *SessionStarted) Reset()
func (*SessionStarted) String ¶
func (x *SessionStarted) String() string
type Status ¶
type Status struct {
State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
// contains filtered or unexported fields
}
func (*Status) Descriptor
deprecated
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) ProtoReflect ¶
func (x *Status) ProtoReflect() protoreflect.Message
type TextContent ¶
type TextContent struct {
Text string `protobuf:"bytes,1,opt,name=text,proto3" json:"text,omitempty"`
Annotations []*Annotation `protobuf:"bytes,2,rep,name=annotations,proto3" json:"annotations,omitempty"`
// contains filtered or unexported fields
}
func (*TextContent) Descriptor
deprecated
func (*TextContent) Descriptor() ([]byte, []int)
Deprecated: Use TextContent.ProtoReflect.Descriptor instead.
func (*TextContent) GetAnnotations ¶
func (x *TextContent) GetAnnotations() []*Annotation
func (*TextContent) GetText ¶
func (x *TextContent) GetText() string
func (*TextContent) ProtoMessage ¶
func (*TextContent) ProtoMessage()
func (*TextContent) ProtoReflect ¶
func (x *TextContent) ProtoReflect() protoreflect.Message
func (*TextContent) Reset ¶
func (x *TextContent) Reset()
func (*TextContent) String ¶
func (x *TextContent) String() string
type TokenUsage ¶
type TokenUsage struct {
InputTokens uint64 `protobuf:"varint,1,opt,name=input_tokens,json=inputTokens,proto3" json:"input_tokens,omitempty"`
OutputTokens uint64 `protobuf:"varint,2,opt,name=output_tokens,json=outputTokens,proto3" json:"output_tokens,omitempty"`
TotalTokens uint64 `protobuf:"varint,3,opt,name=total_tokens,json=totalTokens,proto3" json:"total_tokens,omitempty"`
Model string `protobuf:"bytes,4,opt,name=model,proto3" json:"model,omitempty"`
Detail map[string]uint64 `` /* 140-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*TokenUsage) Descriptor
deprecated
func (*TokenUsage) Descriptor() ([]byte, []int)
Deprecated: Use TokenUsage.ProtoReflect.Descriptor instead.
func (*TokenUsage) GetDetail ¶
func (x *TokenUsage) GetDetail() map[string]uint64
func (*TokenUsage) GetInputTokens ¶
func (x *TokenUsage) GetInputTokens() uint64
func (*TokenUsage) GetModel ¶
func (x *TokenUsage) GetModel() string
func (*TokenUsage) GetOutputTokens ¶
func (x *TokenUsage) GetOutputTokens() uint64
func (*TokenUsage) GetTotalTokens ¶
func (x *TokenUsage) GetTotalTokens() uint64
func (*TokenUsage) ProtoMessage ¶
func (*TokenUsage) ProtoMessage()
func (*TokenUsage) ProtoReflect ¶
func (x *TokenUsage) ProtoReflect() protoreflect.Message
func (*TokenUsage) Reset ¶
func (x *TokenUsage) Reset()
func (*TokenUsage) String ¶
func (x *TokenUsage) String() string
type ToolCall ¶
type ToolCall struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Kind string `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
Arguments *EncodedValue `protobuf:"bytes,4,opt,name=arguments,proto3" json:"arguments,omitempty"`
WorkingDirectory string `protobuf:"bytes,5,opt,name=working_directory,json=workingDirectory,proto3" json:"working_directory,omitempty"`
// contains filtered or unexported fields
}
func (*ToolCall) Descriptor
deprecated
func (*ToolCall) GetArguments ¶
func (x *ToolCall) GetArguments() *EncodedValue
func (*ToolCall) GetWorkingDirectory ¶
func (*ToolCall) ProtoMessage ¶
func (*ToolCall) ProtoMessage()
func (*ToolCall) ProtoReflect ¶
func (x *ToolCall) ProtoReflect() protoreflect.Message
type ToolCallDelta ¶
type ToolCallDelta struct {
CallId string `protobuf:"bytes,1,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
Index uint32 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
Arguments []byte `protobuf:"bytes,4,opt,name=arguments,proto3" json:"arguments,omitempty"`
// contains filtered or unexported fields
}
func (*ToolCallDelta) Descriptor
deprecated
func (*ToolCallDelta) Descriptor() ([]byte, []int)
Deprecated: Use ToolCallDelta.ProtoReflect.Descriptor instead.
func (*ToolCallDelta) GetArguments ¶
func (x *ToolCallDelta) GetArguments() []byte
func (*ToolCallDelta) GetCallId ¶
func (x *ToolCallDelta) GetCallId() string
func (*ToolCallDelta) GetIndex ¶
func (x *ToolCallDelta) GetIndex() uint32
func (*ToolCallDelta) GetName ¶
func (x *ToolCallDelta) GetName() string
func (*ToolCallDelta) ProtoMessage ¶
func (*ToolCallDelta) ProtoMessage()
func (*ToolCallDelta) ProtoReflect ¶
func (x *ToolCallDelta) ProtoReflect() protoreflect.Message
func (*ToolCallDelta) Reset ¶
func (x *ToolCallDelta) Reset()
func (*ToolCallDelta) String ¶
func (x *ToolCallDelta) String() string
type ToolDefinition ¶
type ToolDefinition struct {
Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
InputSchema *EncodedValue `protobuf:"bytes,4,opt,name=input_schema,json=inputSchema,proto3" json:"input_schema,omitempty"`
// contains filtered or unexported fields
}
ToolDefinition is the provider-neutral function/tool contract advertised by an Agent. Provider adapters translate this schema at their wire boundary.
func (*ToolDefinition) Descriptor
deprecated
func (*ToolDefinition) Descriptor() ([]byte, []int)
Deprecated: Use ToolDefinition.ProtoReflect.Descriptor instead.
func (*ToolDefinition) GetDescription ¶
func (x *ToolDefinition) GetDescription() string
func (*ToolDefinition) GetInputSchema ¶
func (x *ToolDefinition) GetInputSchema() *EncodedValue
func (*ToolDefinition) GetName ¶
func (x *ToolDefinition) GetName() string
func (*ToolDefinition) GetType ¶
func (x *ToolDefinition) GetType() string
func (*ToolDefinition) ProtoMessage ¶
func (*ToolDefinition) ProtoMessage()
func (*ToolDefinition) ProtoReflect ¶
func (x *ToolDefinition) ProtoReflect() protoreflect.Message
func (*ToolDefinition) Reset ¶
func (x *ToolDefinition) Reset()
func (*ToolDefinition) String ¶
func (x *ToolDefinition) String() string
type ToolResult ¶
type ToolResult struct {
CallId string `protobuf:"bytes,1,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
Output []*Content `protobuf:"bytes,2,rep,name=output,proto3" json:"output,omitempty"`
IsError bool `protobuf:"varint,3,opt,name=is_error,json=isError,proto3" json:"is_error,omitempty"`
Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
DurationMs uint64 `protobuf:"varint,6,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
Terminate bool `protobuf:"varint,7,opt,name=terminate,proto3" json:"terminate,omitempty"`
// contains filtered or unexported fields
}
func (*ToolResult) Descriptor
deprecated
func (*ToolResult) Descriptor() ([]byte, []int)
Deprecated: Use ToolResult.ProtoReflect.Descriptor instead.
func (*ToolResult) GetCallId ¶
func (x *ToolResult) GetCallId() string
func (*ToolResult) GetDurationMs ¶
func (x *ToolResult) GetDurationMs() uint64
func (*ToolResult) GetIsError ¶
func (x *ToolResult) GetIsError() bool
func (*ToolResult) GetName ¶
func (x *ToolResult) GetName() string
func (*ToolResult) GetOutput ¶
func (x *ToolResult) GetOutput() []*Content
func (*ToolResult) GetTerminate ¶
func (x *ToolResult) GetTerminate() bool
func (*ToolResult) ProtoMessage ¶
func (*ToolResult) ProtoMessage()
func (*ToolResult) ProtoReflect ¶
func (x *ToolResult) ProtoReflect() protoreflect.Message
func (*ToolResult) Reset ¶
func (x *ToolResult) Reset()
func (*ToolResult) String ¶
func (x *ToolResult) String() string
type TurnEnded ¶
type TurnEnded struct {
StopReason string `protobuf:"bytes,1,opt,name=stop_reason,json=stopReason,proto3" json:"stop_reason,omitempty"`
Error *ProtocolError `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
Usage *TokenUsage `protobuf:"bytes,3,opt,name=usage,proto3" json:"usage,omitempty"`
ContextTokens uint64 `protobuf:"varint,4,opt,name=context_tokens,json=contextTokens,proto3" json:"context_tokens,omitempty"`
// contains filtered or unexported fields
}
func (*TurnEnded) Descriptor
deprecated
func (*TurnEnded) GetContextTokens ¶
func (*TurnEnded) GetError ¶
func (x *TurnEnded) GetError() *ProtocolError
func (*TurnEnded) GetStopReason ¶
func (*TurnEnded) GetUsage ¶
func (x *TurnEnded) GetUsage() *TokenUsage
func (*TurnEnded) ProtoMessage ¶
func (*TurnEnded) ProtoMessage()
func (*TurnEnded) ProtoReflect ¶
func (x *TurnEnded) ProtoReflect() protoreflect.Message
type TurnReceipt ¶
type TurnReceipt struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
TurnId string `protobuf:"bytes,2,opt,name=turn_id,json=turnId,proto3" json:"turn_id,omitempty"`
State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
// contains filtered or unexported fields
}
func (*TurnReceipt) Descriptor
deprecated
func (*TurnReceipt) Descriptor() ([]byte, []int)
Deprecated: Use TurnReceipt.ProtoReflect.Descriptor instead.
func (*TurnReceipt) GetSessionId ¶
func (x *TurnReceipt) GetSessionId() string
func (*TurnReceipt) GetState ¶
func (x *TurnReceipt) GetState() string
func (*TurnReceipt) GetTurnId ¶
func (x *TurnReceipt) GetTurnId() string
func (*TurnReceipt) ProtoMessage ¶
func (*TurnReceipt) ProtoMessage()
func (*TurnReceipt) ProtoReflect ¶
func (x *TurnReceipt) ProtoReflect() protoreflect.Message
func (*TurnReceipt) Reset ¶
func (x *TurnReceipt) Reset()
func (*TurnReceipt) String ¶
func (x *TurnReceipt) String() string
type TurnStarted ¶
type TurnStarted struct {
// contains filtered or unexported fields
}
func (*TurnStarted) Descriptor
deprecated
func (*TurnStarted) Descriptor() ([]byte, []int)
Deprecated: Use TurnStarted.ProtoReflect.Descriptor instead.
func (*TurnStarted) ProtoMessage ¶
func (*TurnStarted) ProtoMessage()
func (*TurnStarted) ProtoReflect ¶
func (x *TurnStarted) ProtoReflect() protoreflect.Message
func (*TurnStarted) Reset ¶
func (x *TurnStarted) Reset()
func (*TurnStarted) String ¶
func (x *TurnStarted) String() string
type WatchEventsRequest ¶
type WatchEventsRequest struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
AfterCursor string `protobuf:"bytes,2,opt,name=after_cursor,json=afterCursor,proto3" json:"after_cursor,omitempty"`
// contains filtered or unexported fields
}
func (*WatchEventsRequest) Descriptor
deprecated
func (*WatchEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchEventsRequest.ProtoReflect.Descriptor instead.
func (*WatchEventsRequest) GetAfterCursor ¶
func (x *WatchEventsRequest) GetAfterCursor() string
func (*WatchEventsRequest) GetSessionId ¶
func (x *WatchEventsRequest) GetSessionId() string
func (*WatchEventsRequest) ProtoMessage ¶
func (*WatchEventsRequest) ProtoMessage()
func (*WatchEventsRequest) ProtoReflect ¶
func (x *WatchEventsRequest) ProtoReflect() protoreflect.Message
func (*WatchEventsRequest) Reset ¶
func (x *WatchEventsRequest) Reset()
func (*WatchEventsRequest) String ¶
func (x *WatchEventsRequest) String() string