aop

package module
v0.0.0-...-fddd243 Latest Latest
Warning

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

Go to latest
Published: Aug 27, 2026 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const JSONMediaType = "application/json"

Variables

View Source
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.

View Source
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.

View Source
var File_aop_chat_proto protoreflect.FileDescriptor
View Source
var File_aop_content_proto protoreflect.FileDescriptor
View Source
var File_aop_envelope_proto protoreflect.FileDescriptor
View Source
var File_aop_event_proto protoreflect.FileDescriptor
View Source
var File_aop_protocol_proto protoreflect.FileDescriptor
View Source
var File_aop_value_proto protoreflect.FileDescriptor

Functions

func DecodeJSON

func DecodeJSON[T any](value *EncodedValue) (T, error)

func FindTypedExtension

func FindTypedExtension(event *Event, target proto.Message) (bool, error)

FindTypedExtension unmarshals the extension matching target's protobuf full name. Unknown extensions are ignored and remain preserved on the Event.

func Kind

func Kind(event *Event) string

func SetTypedExtension

func SetTypedExtension(event *Event, value proto.Message) error

SetTypedExtension packs value into Event.extensions and replaces an existing extension with the same protobuf full name.

func Unwrap

func Unwrap(envelope *Envelope) (proto.Message, error)

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 Image

func Image(mediaType string, data []byte) *Content

func MediaData

func MediaData(kind, mediaType, filename string, data []byte) *Content

func MediaURI

func MediaURI(kind, mediaType, filename, uri string) *Content

func Reasoning

func Reasoning(text string) *Content

func Text

func Text(text string) *Content

func (*Content) Descriptor deprecated

func (*Content) Descriptor() ([]byte, []int)

Deprecated: Use Content.ProtoReflect.Descriptor instead.

func (*Content) GetMedia

func (x *Content) GetMedia() *MediaContent

func (*Content) GetReasoning

func (x *Content) GetReasoning() *ReasoningContent

func (*Content) GetRefusal

func (x *Content) GetRefusal() string

func (*Content) GetText

func (x *Content) GetText() *TextContent

func (*Content) GetToolCall

func (x *Content) GetToolCall() *ToolCall

func (*Content) GetToolResult

func (x *Content) GetToolResult() *ToolResult

func (*Content) GetValue

func (x *Content) GetValue() isContent_Value

func (*Content) ProtoMessage

func (*Content) ProtoMessage()

func (*Content) ProtoReflect

func (x *Content) ProtoReflect() protoreflect.Message

func (*Content) Reset

func (x *Content) Reset()

func (*Content) String

func (x *Content) String() string

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

func (x DeltaOperation) Enum() *DeltaOperation

func (DeltaOperation) EnumDescriptor deprecated

func (DeltaOperation) EnumDescriptor() ([]byte, []int)

Deprecated: Use DeltaOperation.Descriptor instead.

func (DeltaOperation) Number

func (DeltaOperation) String

func (x DeltaOperation) String() string

func (DeltaOperation) Type

type Direction

type Direction int32
const (
	Direction_DIRECTION_UNSPECIFIED Direction = 0
	Direction_DIRECTION_REQUEST     Direction = 1
	Direction_DIRECTION_RESPONSE    Direction = 2
)

func (Direction) Descriptor

func (Direction) Descriptor() protoreflect.EnumDescriptor

func (Direction) Enum

func (x Direction) Enum() *Direction

func (Direction) EnumDescriptor deprecated

func (Direction) EnumDescriptor() ([]byte, []int)

Deprecated: Use Direction.Descriptor instead.

func (Direction) Number

func (x Direction) Number() protoreflect.EnumNumber

func (Direction) String

func (x Direction) String() string

func (Direction) Type

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 MustWrap

func MustWrap(id, replyTo string, message proto.Message) *Envelope

func Wrap

func Wrap(id, replyTo string, message proto.Message) (*Envelope, error)

func (*Envelope) Descriptor deprecated

func (*Envelope) Descriptor() ([]byte, []int)

Deprecated: Use Envelope.ProtoReflect.Descriptor instead.

func (*Envelope) GetDeliveryCursor

func (x *Envelope) GetDeliveryCursor() string

func (*Envelope) GetId

func (x *Envelope) GetId() string

func (*Envelope) GetPayload

func (x *Envelope) GetPayload() *anypb.Any

func (*Envelope) GetReplyTo

func (x *Envelope) GetReplyTo() string

func (*Envelope) ProtoMessage

func (*Envelope) ProtoMessage()

func (*Envelope) ProtoReflect

func (x *Envelope) ProtoReflect() protoreflect.Message

func (*Envelope) Reset

func (x *Envelope) Reset()

func (*Envelope) String

func (x *Envelope) String() string

type EnvelopeStream

type EnvelopeStream interface {
	Recv() (*Envelope, error)
	Send(*Envelope) error
}

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) Descriptor() ([]byte, []int)

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetEmittedAt

func (x *Event) GetEmittedAt() *timestamppb.Timestamp

func (*Event) GetEmitter

func (x *Event) GetEmitter() string

func (*Event) GetError

func (x *Event) GetError() *ProtocolError

func (*Event) GetExtension

func (x *Event) GetExtension() *anypb.Any

func (*Event) GetExtensions

func (x *Event) GetExtensions() []*anypb.Any

func (*Event) GetId

func (x *Event) GetId() string

func (*Event) GetMessage

func (x *Event) GetMessage() *Message

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

func (x *Event) GetSeq() uint64

func (*Event) GetSessionEnded

func (x *Event) GetSessionEnded() *SessionEnded

func (*Event) GetSessionId

func (x *Event) GetSessionId() string

func (*Event) GetSessionStarted

func (x *Event) GetSessionStarted() *SessionStarted

func (*Event) GetStatus

func (x *Event) GetStatus() *Status

func (*Event) GetToolCall

func (x *Event) GetToolCall() *ToolCall

func (*Event) GetToolCallDelta

func (x *Event) GetToolCallDelta() *ToolCallDelta

func (*Event) GetToolResult

func (x *Event) GetToolResult() *ToolResult

func (*Event) GetTurnEnded

func (x *Event) GetTurnEnded() *TurnEnded

func (*Event) GetTurnId

func (x *Event) GetTurnId() string

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

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

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_Extension struct {
	Extension *anypb.Any `protobuf:"bytes,24,opt,name=extension,proto3,oneof"`
}

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) Descriptor() ([]byte, []int)

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetContent

func (x *Message) GetContent() []*Content

func (*Message) GetId

func (x *Message) GetId() string

func (*Message) GetName

func (x *Message) GetName() string

func (*Message) GetRole

func (x *Message) GetRole() string

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) ProtoReflect

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset

func (x *Message) Reset()

func (*Message) String

func (x *Message) String() string

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

type NamespaceHandler func(context.Context, *Envelope, proto.Message, SendFunc) error

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) Descriptor() ([]byte, []int)

Deprecated: Use Rejection.ProtoReflect.Descriptor instead.

func (*Rejection) GetCode

func (x *Rejection) GetCode() string

func (*Rejection) GetMessage

func (x *Rejection) GetMessage() string

func (*Rejection) GetRetryable

func (x *Rejection) GetRetryable() bool

func (*Rejection) ProtoMessage

func (*Rejection) ProtoMessage()

func (*Rejection) ProtoReflect

func (x *Rejection) ProtoReflect() protoreflect.Message

func (*Rejection) Reset

func (x *Rejection) Reset()

func (*Rejection) String

func (x *Rejection) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetData

func (x *Resource) GetData() []byte

func (*Resource) GetFilename

func (x *Resource) GetFilename() string

func (*Resource) GetMediaType

func (x *Resource) GetMediaType() string

func (*Resource) GetSource

func (x *Resource) GetSource() isResource_Source

func (*Resource) GetUri

func (x *Resource) GetUri() string

func (*Resource) ProtoMessage

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect

func (x *Resource) ProtoReflect() protoreflect.Message

func (*Resource) Reset

func (x *Resource) Reset()

func (*Resource) String

func (x *Resource) String() string

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 SendFunc

type SendFunc func(*Envelope) error

SendFunc writes one Envelope on the connection owned by the caller.

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) Descriptor() ([]byte, []int)

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetId

func (x *Session) GetId() string

func (*Session) GetNodeId

func (x *Session) GetNodeId() string

func (*Session) GetState

func (x *Session) GetState() string

func (*Session) GetTitle

func (x *Session) GetTitle() string

func (*Session) ProtoMessage

func (*Session) ProtoMessage()

func (*Session) ProtoReflect

func (x *Session) ProtoReflect() protoreflect.Message

func (*Session) Reset

func (x *Session) Reset()

func (*Session) String

func (x *Session) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetState

func (x *Status) GetState() string

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) ProtoReflect

func (x *Status) ProtoReflect() protoreflect.Message

func (*Status) Reset

func (x *Status) Reset()

func (*Status) String

func (x *Status) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use ToolCall.ProtoReflect.Descriptor instead.

func (*ToolCall) GetArguments

func (x *ToolCall) GetArguments() *EncodedValue

func (*ToolCall) GetId

func (x *ToolCall) GetId() string

func (*ToolCall) GetKind

func (x *ToolCall) GetKind() string

func (*ToolCall) GetName

func (x *ToolCall) GetName() string

func (*ToolCall) GetWorkingDirectory

func (x *ToolCall) GetWorkingDirectory() string

func (*ToolCall) ProtoMessage

func (*ToolCall) ProtoMessage()

func (*ToolCall) ProtoReflect

func (x *ToolCall) ProtoReflect() protoreflect.Message

func (*ToolCall) Reset

func (x *ToolCall) Reset()

func (*ToolCall) String

func (x *ToolCall) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use TurnEnded.ProtoReflect.Descriptor instead.

func (*TurnEnded) GetContextTokens

func (x *TurnEnded) GetContextTokens() uint64

func (*TurnEnded) GetError

func (x *TurnEnded) GetError() *ProtocolError

func (*TurnEnded) GetStopReason

func (x *TurnEnded) GetStopReason() string

func (*TurnEnded) GetUsage

func (x *TurnEnded) GetUsage() *TokenUsage

func (*TurnEnded) ProtoMessage

func (*TurnEnded) ProtoMessage()

func (*TurnEnded) ProtoReflect

func (x *TurnEnded) ProtoReflect() protoreflect.Message

func (*TurnEnded) Reset

func (x *TurnEnded) Reset()

func (*TurnEnded) String

func (x *TurnEnded) String() string

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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