proto

type AgentEnd struct {
	// contains filtered or unexported fields
}

type AgentMessage struct {
	ConversationId string `protobuf:"bytes,1,opt,name=conversation_id,json=conversationId,proto3" json:"conversation_id,omitempty"`
	ExecId         string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	// Types that are valid to be assigned to Type:
	//
	//	*AgentMessage_Start
	//	*AgentMessage_Outputs
	//	*AgentMessage_End
	Type isAgentMessage_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type AgentMessage_End struct {
	End *AgentEnd `protobuf:"bytes,5,opt,name=end,proto3,oneof"`
}

type AgentMessage_Outputs struct {
	Outputs *AgentOutputs `protobuf:"bytes,4,opt,name=outputs,proto3,oneof"`
}

type AgentMessage_Start struct {
	Start *AgentStart `protobuf:"bytes,3,opt,name=start,proto3,oneof"`
}

type AgentOutputs struct {
	Messages []*Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

type AgentServiceClient interface {
	// Connect is used by agents to connect to the controller.
	Connect(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[AgentMessage, AgentMessage], error)
	// HealthCheck checks if the agent is healthy and responsive
	HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}

type AgentServiceServer interface {
	// Connect is used by agents to connect to the controller.
	Connect(grpc.BidiStreamingServer[AgentMessage, AgentMessage]) error
	// HealthCheck checks if the agent is healthy and responsive
	HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	// contains filtered or unexported methods
}

type AgentService_ConnectClient = grpc.BidiStreamingClient[AgentMessage, AgentMessage]

type AgentService_ConnectServer = grpc.BidiStreamingServer[AgentMessage, AgentMessage]

type AgentStart struct {
	AgentId     string     `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	AgentConfig []byte     `protobuf:"bytes,2,opt,name=agent_config,json=agentConfig,proto3" json:"agent_config,omitempty"`
	Messages    []*Message `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

type ApprovalDecision struct {
	Approved bool `protobuf:"varint,1,opt,name=approved,proto3" json:"approved,omitempty"`
	// contains filtered or unexported fields
}

type AudioContent struct {
	MimeType AudioContent_MimeType `protobuf:"varint,1,opt,name=mime_type,json=mimeType,proto3,enum=ax.AudioContent_MimeType" json:"mime_type,omitempty"`
	// Types that are valid to be assigned to DataOrUri:
	//
	//	*AudioContent_Data
	//	*AudioContent_Uri
	DataOrUri  isAudioContent_DataOrUri `protobuf_oneof:"data_or_uri"`
	Channels   int32                    `protobuf:"varint,7,opt,name=channels,proto3" json:"channels,omitempty"`
	SampleRate int32                    `protobuf:"varint,8,opt,name=sample_rate,json=sampleRate,proto3" json:"sample_rate,omitempty"`
	// contains filtered or unexported fields
}

type AudioContent_Data struct {
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type AudioContent_MimeType int32

type AudioContent_Uri struct {
	Uri string `protobuf:"bytes,5,opt,name=uri,proto3,oneof"`
}

type ConfirmationContent struct {
	Id       string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Question string `protobuf:"bytes,4,opt,name=question,proto3" json:"question,omitempty"`
	// Types that are valid to be assigned to Decision:
	//
	//	*ConfirmationContent_Approval
	//	*ConfirmationContent_Decline
	Decision isConfirmationContent_Decision `protobuf_oneof:"decision"`
	// contains filtered or unexported fields
}

type ConfirmationContent_Approval struct {
	Approval *ApprovalDecision `protobuf:"bytes,5,opt,name=approval,proto3,oneof"`
}

type ConfirmationContent_Decline struct {
	Decline *DeclineDecision `protobuf:"bytes,6,opt,name=decline,proto3,oneof"`
}

type Content struct {

	// Types that are valid to be assigned to Type:
	//
	//	*Content_Thought
	//	*Content_Text
	//	*Content_Image
	//	*Content_Audio
	//	*Content_Document
	//	*Content_Video
	//	*Content_Confirmation
	//	*Content_ToolCall
	//	*Content_ToolResult
	Type isContent_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type Content_Audio struct {
	Audio *AudioContent `protobuf:"bytes,12,opt,name=audio,proto3,oneof"`
}

type Content_Confirmation struct {
	Confirmation *ConfirmationContent `protobuf:"bytes,26,opt,name=confirmation,proto3,oneof"` // TODO(jbd): Remove out of the Content.
}

type Content_Document struct {
	Document *DocumentContent `protobuf:"bytes,13,opt,name=document,proto3,oneof"`
}

type Content_Image struct {
	Image *ImageContent `protobuf:"bytes,11,opt,name=image,proto3,oneof"`
}

type Content_Text struct {
	Text *TextContent `protobuf:"bytes,10,opt,name=text,proto3,oneof"`
}

type Content_Thought struct {
	Thought *ThoughtContent `protobuf:"bytes,5,opt,name=thought,proto3,oneof"`
}

type Content_ToolCall struct {
	ToolCall *ToolCallContent `protobuf:"bytes,24,opt,name=tool_call,json=toolCall,proto3,oneof"`
}

type Content_ToolResult struct {
	ToolResult *ToolResultContent `protobuf:"bytes,25,opt,name=tool_result,json=toolResult,proto3,oneof"`
}

type Content_Video struct {
	Video *VideoContent `protobuf:"bytes,14,opt,name=video,proto3,oneof"`
}

type ControllerServiceClient interface {
	// Exec executes an agentic task or resumes an existing one with streaming responses
	// If the conversation_id already exists, it will be resumed.
	Exec(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ExecResponse], error)
}

type ControllerServiceServer interface {
	// Exec executes an agentic task or resumes an existing one with streaming responses
	// If the conversation_id already exists, it will be resumed.
	Exec(*ExecRequest, grpc.ServerStreamingServer[ExecResponse]) error
	// contains filtered or unexported methods
}

type ControllerService_ExecClient = grpc.ServerStreamingClient[ExecResponse]

type ControllerService_ExecServer = grpc.ServerStreamingServer[ExecResponse]

type ConversationEvent struct {
	ConversationId string     `protobuf:"bytes,1,opt,name=conversation_id,json=conversationId,proto3" json:"conversation_id,omitempty"`
	Seq            int32      `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"`
	ExecId         string     `protobuf:"bytes,3,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Messages       []*Message `protobuf:"bytes,4,rep,name=messages,proto3" json:"messages,omitempty"`
	State          State      `protobuf:"varint,5,opt,name=state,proto3,enum=ax.State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

type ConversationServiceClient interface {
	// Deletes conversational events and all event log resources
	// for its children executions.
	DeleteConversation(ctx context.Context, in *DeleteConversationRequest, opts ...grpc.CallOption) (*DeleteConversationResponse, error)
	// Fork forks an event log from a specific conversation.
	ForkConversation(ctx context.Context, in *ForkConversationRequest, opts ...grpc.CallOption) (*ForkConversationResponse, error)
}

type ConversationServiceServer interface {
	// Deletes conversational events and all event log resources
	// for its children executions.
	DeleteConversation(context.Context, *DeleteConversationRequest) (*DeleteConversationResponse, error)
	// Fork forks an event log from a specific conversation.
	ForkConversation(context.Context, *ForkConversationRequest) (*ForkConversationResponse, error)
	// contains filtered or unexported methods
}

type DeclineDecision struct {
	Declined bool `protobuf:"varint,1,opt,name=declined,proto3" json:"declined,omitempty"`
	// contains filtered or unexported fields
}

type DeleteConversationRequest struct {
	ConversationId string `protobuf:"bytes,1,opt,name=conversation_id,json=conversationId,proto3" json:"conversation_id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteConversationResponse struct {
	// contains filtered or unexported fields
}

type DocumentContent struct {
	MimeType DocumentContent_MimeType `protobuf:"varint,1,opt,name=mime_type,json=mimeType,proto3,enum=ax.DocumentContent_MimeType" json:"mime_type,omitempty"`
	// Types that are valid to be assigned to DataOrUri:
	//
	//	*DocumentContent_Data
	//	*DocumentContent_Uri
	DataOrUri isDocumentContent_DataOrUri `protobuf_oneof:"data_or_uri"`
	// contains filtered or unexported fields
}

type DocumentContent_Data struct {
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type DocumentContent_MimeType int32

type DocumentContent_Uri struct {
	Uri string `protobuf:"bytes,5,opt,name=uri,proto3,oneof"`
}

type ExecRequest struct {
	ConversationId string     `protobuf:"bytes,1,opt,name=conversation_id,json=conversationId,proto3" json:"conversation_id,omitempty"` // Unique conversation identifier
	Inputs         []*Message `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`                                       // New inputs
	LastSeq        int32      `protobuf:"varint,3,opt,name=last_seq,json=lastSeq,proto3" json:"last_seq,omitempty"`                     // Last sequence number seen by the client
	AgentId        string     `protobuf:"bytes,4,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`                      // Agent ID, if empty planner is used
	AgentConfig    []byte     `protobuf:"bytes,5,opt,name=agent_config,json=agentConfig,proto3" json:"agent_config,omitempty"`          // Agent configuration if any
	// contains filtered or unexported fields
}

type ExecResponse struct {
	Outputs []*Message `protobuf:"bytes,1,rep,name=outputs,proto3" json:"outputs,omitempty"` // Output content
	Seq     int32      `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"`        // Seq of the outputs
	// contains filtered or unexported fields
}

type ExecutionEvent struct {
	ExecId      string                 `protobuf:"bytes,1,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	AgentId     string                 `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	AgentConfig []byte                 `protobuf:"bytes,3,opt,name=agent_config,json=agentConfig,proto3" json:"agent_config,omitempty"`
	Inputs      []*Message             `protobuf:"bytes,4,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs     []*Message             `protobuf:"bytes,5,rep,name=outputs,proto3" json:"outputs,omitempty"`
	State       State                  `protobuf:"varint,6,opt,name=state,proto3,enum=ax.State" json:"state,omitempty"`
	Timestamp   *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type ForkConversationRequest struct {

	// Required: The source conversation ID to fork from.
	SrcConversationId string `protobuf:"bytes,1,opt,name=src_conversation_id,json=srcConversationId,proto3" json:"src_conversation_id,omitempty"`
	// Optional: The sequence number to fork from.
	// Defaults to the latest sequence if not set or set to 0.
	SrcSeq int32 `protobuf:"varint,2,opt,name=src_seq,json=srcSeq,proto3" json:"src_seq,omitempty"` // TODO(jbd): Replace this with snapshot_id.
	// Optional: The destination conversation ID.
	// Generates a new UUID if not provided.
	DestConversationId string `protobuf:"bytes,3,opt,name=dest_conversation_id,json=destConversationId,proto3" json:"dest_conversation_id,omitempty"`
	// contains filtered or unexported fields
}

type ForkConversationResponse struct {
	ConversationId string `protobuf:"bytes,1,opt,name=conversation_id,json=conversationId,proto3" json:"conversation_id,omitempty"` // The ID of the new conversation
	// contains filtered or unexported fields
}

type FunctionCallContent struct {
	Name      string           `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Arguments *structpb.Struct `protobuf:"bytes,4,opt,name=arguments,proto3" json:"arguments,omitempty"`
	// contains filtered or unexported fields
}

type FunctionResultContent struct {
	Name string `protobuf:"bytes,8,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are valid to be assigned to Result:
	//
	//	*FunctionResultContent_Response
	Result isFunctionResultContent_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

type FunctionResultContent_Response struct {
	Response *structpb.Struct `protobuf:"bytes,3,opt,name=response,proto3,oneof"`
}

type HealthCheckRequest struct {
	// contains filtered or unexported fields
}

type HealthCheckResponse struct {
	Healthy bool   `protobuf:"varint,1,opt,name=healthy,proto3" json:"healthy,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ImageContent struct {
	MimeType ImageContent_MimeType `protobuf:"varint,1,opt,name=mime_type,json=mimeType,proto3,enum=ax.ImageContent_MimeType" json:"mime_type,omitempty"`
	// Types that are valid to be assigned to DataOrUri:
	//
	//	*ImageContent_Data
	//	*ImageContent_Uri
	DataOrUri  isImageContent_DataOrUri `protobuf_oneof:"data_or_uri"`
	Resolution MediaResolution          `protobuf:"varint,5,opt,name=resolution,proto3,enum=ax.MediaResolution" json:"resolution,omitempty"`
	// contains filtered or unexported fields
}

type ImageContent_Data struct {
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type ImageContent_MimeType int32

type ImageContent_Uri struct {
	Uri string `protobuf:"bytes,6,opt,name=uri,proto3,oneof"`
}

type MediaResolution int32

type Message struct {
	Role    string   `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`       // user, assistant, or model
	Content *Content `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` // content of the message
	// If true, the message is stored only in the execution log
	// (for resumption) but not in the conversation history,
	// and not emitted to the client or any agent.
	InternalOnly bool `protobuf:"varint,3,opt,name=internal_only,json=internalOnly,proto3" json:"internal_only,omitempty"`
	// contains filtered or unexported fields
}

type State int32

type TextContent struct {
	Text string `protobuf:"bytes,3,opt,name=text,proto3" json:"text,omitempty"`
	// contains filtered or unexported fields
}

type ThoughtContent struct {
	Signature []byte                   `protobuf:"bytes,7,opt,name=signature,proto3" json:"signature,omitempty"`
	Summary   []*ThoughtSummaryContent `protobuf:"bytes,9,rep,name=summary,proto3" json:"summary,omitempty"`
	// contains filtered or unexported fields
}

type ThoughtSummaryContent struct {

	// Types that are valid to be assigned to Type:
	//
	//	*ThoughtSummaryContent_Text
	Type isThoughtSummaryContent_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type ThoughtSummaryContent_Text struct {
	Text *TextContent `protobuf:"bytes,1,opt,name=text,proto3,oneof"`
}

type ToolCallContent struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`               // A unique ID for this specific tool call.
	Signature []byte `protobuf:"bytes,9,opt,name=signature,proto3" json:"signature,omitempty"` // A signature hash for backend validation.
	// Types that are valid to be assigned to Type:
	//
	//	*ToolCallContent_FunctionCall
	Type isToolCallContent_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type ToolCallContent_FunctionCall struct {
	FunctionCall *FunctionCallContent `protobuf:"bytes,2,opt,name=function_call,json=functionCall,proto3,oneof"`
}

type ToolResultContent struct {
	CallId    string `protobuf:"bytes,8,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"` // ID to match the ID from the function call block.
	Signature []byte `protobuf:"bytes,9,opt,name=signature,proto3" json:"signature,omitempty"`         // A signature hash for backend validation.
	// Types that are valid to be assigned to Type:
	//
	//	*ToolResultContent_FunctionResult
	Type isToolResultContent_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type ToolResultContent_FunctionResult struct {
	FunctionResult *FunctionResultContent `protobuf:"bytes,2,opt,name=function_result,json=functionResult,proto3,oneof"`
}

type UnimplementedAgentServiceServer struct{}

type UnimplementedControllerServiceServer struct{}

type UnimplementedConversationServiceServer struct{}

type UnsafeAgentServiceServer interface {
	// contains filtered or unexported methods
}

type UnsafeControllerServiceServer interface {
	// contains filtered or unexported methods
}

type UnsafeConversationServiceServer interface {
	// contains filtered or unexported methods
}

type VideoContent struct {
	MimeType VideoContent_MimeType `protobuf:"varint,1,opt,name=mime_type,json=mimeType,proto3,enum=ax.VideoContent_MimeType" json:"mime_type,omitempty"`
	// Types that are valid to be assigned to DataOrUri:
	//
	//	*VideoContent_Data
	//	*VideoContent_Uri
	DataOrUri  isVideoContent_DataOrUri `protobuf_oneof:"data_or_uri"`
	Resolution MediaResolution          `protobuf:"varint,5,opt,name=resolution,proto3,enum=ax.MediaResolution" json:"resolution,omitempty"`
	// contains filtered or unexported fields
}

type VideoContent_Data struct {
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type VideoContent_MimeType int32

type VideoContent_Uri struct {
	Uri string `protobuf:"bytes,6,opt,name=uri,proto3,oneof"`
}