Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)
- type AgentServiceClient
- type AgentServiceServer
- type AgentService_RunStreamClient
- type AgentService_RunStreamServer
- type ApprovalRequest
- func (*ApprovalRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApprovalRequest) GetApproved() bool
- func (x *ApprovalRequest) GetModifications() string
- func (x *ApprovalRequest) GetPlanId() string
- func (*ApprovalRequest) ProtoMessage()
- func (x *ApprovalRequest) ProtoReflect() protoreflect.Message
- func (x *ApprovalRequest) Reset()
- func (x *ApprovalRequest) String() string
- type ApprovalResponse
- func (*ApprovalResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApprovalResponse) GetError() string
- func (x *ApprovalResponse) GetResult() string
- func (*ApprovalResponse) ProtoMessage()
- func (x *ApprovalResponse) ProtoReflect() protoreflect.Message
- func (x *ApprovalResponse) Reset()
- func (x *ApprovalResponse) String() string
- type CapabilitiesRequest
- type CapabilitiesResponse
- func (*CapabilitiesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CapabilitiesResponse) GetSubAgents() []string
- func (x *CapabilitiesResponse) GetSupportsExecutionPlans() bool
- func (x *CapabilitiesResponse) GetSupportsMemory() bool
- func (x *CapabilitiesResponse) GetSupportsStreaming() bool
- func (x *CapabilitiesResponse) GetTools() []string
- func (*CapabilitiesResponse) ProtoMessage()
- func (x *CapabilitiesResponse) ProtoReflect() protoreflect.Message
- func (x *CapabilitiesResponse) Reset()
- func (x *CapabilitiesResponse) String() string
- type EventType
- type HealthRequest
- type HealthResponse
- func (*HealthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HealthResponse) GetMessage() string
- func (x *HealthResponse) GetStatus() HealthResponse_Status
- func (*HealthResponse) ProtoMessage()
- func (x *HealthResponse) ProtoReflect() protoreflect.Message
- func (x *HealthResponse) Reset()
- func (x *HealthResponse) String() string
- type HealthResponse_Status
- func (HealthResponse_Status) Descriptor() protoreflect.EnumDescriptor
- func (x HealthResponse_Status) Enum() *HealthResponse_Status
- func (HealthResponse_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x HealthResponse_Status) Number() protoreflect.EnumNumber
- func (x HealthResponse_Status) String() string
- func (HealthResponse_Status) Type() protoreflect.EnumType
- type MetadataRequest
- type MetadataResponse
- func (*MetadataResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MetadataResponse) GetCapabilities() []string
- func (x *MetadataResponse) GetDescription() string
- func (x *MetadataResponse) GetName() string
- func (x *MetadataResponse) GetProperties() map[string]string
- func (x *MetadataResponse) GetSystemPrompt() string
- func (*MetadataResponse) ProtoMessage()
- func (x *MetadataResponse) ProtoReflect() protoreflect.Message
- func (x *MetadataResponse) Reset()
- func (x *MetadataResponse) String() string
- type PlanRequest
- func (*PlanRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PlanRequest) GetContext() map[string]string
- func (x *PlanRequest) GetConversationId() string
- func (x *PlanRequest) GetInput() string
- func (x *PlanRequest) GetOrgId() string
- func (*PlanRequest) ProtoMessage()
- func (x *PlanRequest) ProtoReflect() protoreflect.Message
- func (x *PlanRequest) Reset()
- func (x *PlanRequest) String() string
- type PlanResponse
- func (*PlanResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PlanResponse) GetError() string
- func (x *PlanResponse) GetFormattedPlan() string
- func (x *PlanResponse) GetPlanId() string
- func (x *PlanResponse) GetSteps() []*PlanStep
- func (*PlanResponse) ProtoMessage()
- func (x *PlanResponse) ProtoReflect() protoreflect.Message
- func (x *PlanResponse) Reset()
- func (x *PlanResponse) String() string
- type PlanStep
- func (*PlanStep) Descriptor() ([]byte, []int)deprecated
- func (x *PlanStep) GetDescription() string
- func (x *PlanStep) GetId() string
- func (x *PlanStep) GetParameters() map[string]string
- func (x *PlanStep) GetToolName() string
- func (*PlanStep) ProtoMessage()
- func (x *PlanStep) ProtoReflect() protoreflect.Message
- func (x *PlanStep) Reset()
- func (x *PlanStep) String() string
- type ReadinessRequest
- type ReadinessResponse
- func (*ReadinessResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReadinessResponse) GetMessage() string
- func (x *ReadinessResponse) GetReady() bool
- func (*ReadinessResponse) ProtoMessage()
- func (x *ReadinessResponse) ProtoReflect() protoreflect.Message
- func (x *ReadinessResponse) Reset()
- func (x *ReadinessResponse) String() string
- type RunRequest
- func (*RunRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RunRequest) GetContext() map[string]string
- func (x *RunRequest) GetConversationId() string
- func (x *RunRequest) GetInput() string
- func (x *RunRequest) GetMaxIterations() int32
- func (x *RunRequest) GetOrgId() string
- func (*RunRequest) ProtoMessage()
- func (x *RunRequest) ProtoReflect() protoreflect.Message
- func (x *RunRequest) Reset()
- func (x *RunRequest) String() string
- type RunResponse
- func (*RunResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RunResponse) GetError() string
- func (x *RunResponse) GetMetadata() map[string]string
- func (x *RunResponse) GetOutput() string
- func (*RunResponse) ProtoMessage()
- func (x *RunResponse) ProtoReflect() protoreflect.Message
- func (x *RunResponse) Reset()
- func (x *RunResponse) String() string
- type RunStreamResponse
- func (*RunStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RunStreamResponse) GetChunk() string
- func (x *RunStreamResponse) GetError() string
- func (x *RunStreamResponse) GetEventType() EventType
- func (x *RunStreamResponse) GetIsFinal() bool
- func (x *RunStreamResponse) GetMetadata() map[string]string
- func (x *RunStreamResponse) GetThinking() string
- func (x *RunStreamResponse) GetTimestamp() int64
- func (x *RunStreamResponse) GetToolCall() *ToolCall
- func (*RunStreamResponse) ProtoMessage()
- func (x *RunStreamResponse) ProtoReflect() protoreflect.Message
- func (x *RunStreamResponse) Reset()
- func (x *RunStreamResponse) String() string
- type ToolCall
- func (*ToolCall) Descriptor() ([]byte, []int)deprecated
- func (x *ToolCall) GetArguments() string
- func (x *ToolCall) GetDisplayName() string
- func (x *ToolCall) GetId() string
- func (x *ToolCall) GetInternal() bool
- func (x *ToolCall) GetName() string
- func (x *ToolCall) GetResult() string
- func (x *ToolCall) GetStatus() string
- func (*ToolCall) ProtoMessage()
- func (x *ToolCall) ProtoReflect() protoreflect.Message
- func (x *ToolCall) Reset()
- func (x *ToolCall) String() string
- type UnimplementedAgentServiceServer
- func (UnimplementedAgentServiceServer) ApproveExecutionPlan(context.Context, *ApprovalRequest) (*ApprovalResponse, error)
- func (UnimplementedAgentServiceServer) GenerateExecutionPlan(context.Context, *PlanRequest) (*PlanResponse, error)
- func (UnimplementedAgentServiceServer) GetCapabilities(context.Context, *CapabilitiesRequest) (*CapabilitiesResponse, error)
- func (UnimplementedAgentServiceServer) GetMetadata(context.Context, *MetadataRequest) (*MetadataResponse, error)
- func (UnimplementedAgentServiceServer) Health(context.Context, *HealthRequest) (*HealthResponse, error)
- func (UnimplementedAgentServiceServer) Ready(context.Context, *ReadinessRequest) (*ReadinessResponse, error)
- func (UnimplementedAgentServiceServer) Run(context.Context, *RunRequest) (*RunResponse, error)
- func (UnimplementedAgentServiceServer) RunStream(*RunRequest, grpc.ServerStreamingServer[RunStreamResponse]) error
- type UnsafeAgentServiceServer
Constants ¶
const ( AgentService_Run_FullMethodName = "/agent.AgentService/Run" AgentService_RunStream_FullMethodName = "/agent.AgentService/RunStream" AgentService_GetMetadata_FullMethodName = "/agent.AgentService/GetMetadata" AgentService_GetCapabilities_FullMethodName = "/agent.AgentService/GetCapabilities" AgentService_Health_FullMethodName = "/agent.AgentService/Health" AgentService_Ready_FullMethodName = "/agent.AgentService/Ready" AgentService_GenerateExecutionPlan_FullMethodName = "/agent.AgentService/GenerateExecutionPlan" AgentService_ApproveExecutionPlan_FullMethodName = "/agent.AgentService/ApproveExecutionPlan" )
Variables ¶
var ( EventType_name = map[int32]string{ 0: "EVENT_TYPE_UNSPECIFIED", 1: "EVENT_TYPE_MESSAGE_START", 2: "EVENT_TYPE_CONTENT", 3: "EVENT_TYPE_THINKING", 4: "EVENT_TYPE_TOOL_CALL", 5: "EVENT_TYPE_TOOL_RESULT", 6: "EVENT_TYPE_ERROR", 7: "EVENT_TYPE_COMPLETE", 8: "EVENT_TYPE_MESSAGE_STOP", } EventType_value = map[string]int32{ "EVENT_TYPE_UNSPECIFIED": 0, "EVENT_TYPE_MESSAGE_START": 1, "EVENT_TYPE_CONTENT": 2, "EVENT_TYPE_THINKING": 3, "EVENT_TYPE_TOOL_CALL": 4, "EVENT_TYPE_TOOL_RESULT": 5, "EVENT_TYPE_ERROR": 6, "EVENT_TYPE_COMPLETE": 7, "EVENT_TYPE_MESSAGE_STOP": 8, } )
Enum value maps for EventType.
var ( HealthResponse_Status_name = map[int32]string{ 0: "UNKNOWN", 1: "SERVING", 2: "NOT_SERVING", 3: "SERVICE_UNKNOWN", } HealthResponse_Status_value = map[string]int32{ "UNKNOWN": 0, "SERVING": 1, "NOT_SERVING": 2, "SERVICE_UNKNOWN": 3, } )
Enum value maps for HealthResponse_Status.
var AgentService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "agent.AgentService", HandlerType: (*AgentServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Run", Handler: _AgentService_Run_Handler, }, { MethodName: "GetMetadata", Handler: _AgentService_GetMetadata_Handler, }, { MethodName: "GetCapabilities", Handler: _AgentService_GetCapabilities_Handler, }, { MethodName: "Health", Handler: _AgentService_Health_Handler, }, { MethodName: "Ready", Handler: _AgentService_Ready_Handler, }, { MethodName: "GenerateExecutionPlan", Handler: _AgentService_GenerateExecutionPlan_Handler, }, { MethodName: "ApproveExecutionPlan", Handler: _AgentService_ApproveExecutionPlan_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "RunStream", Handler: _AgentService_RunStream_Handler, ServerStreams: true, }, }, Metadata: "agent.proto", }
AgentService_ServiceDesc is the grpc.ServiceDesc for AgentService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_agent_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAgentServiceServer ¶
func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)
Types ¶
type AgentServiceClient ¶
type AgentServiceClient interface {
// Run executes the agent with the given input
Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)
// RunStream executes the agent with streaming response
RunStream(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[RunStreamResponse], error)
// GetMetadata returns agent metadata
GetMetadata(ctx context.Context, in *MetadataRequest, opts ...grpc.CallOption) (*MetadataResponse, error)
// GetCapabilities returns agent capabilities
GetCapabilities(ctx context.Context, in *CapabilitiesRequest, opts ...grpc.CallOption) (*CapabilitiesResponse, error)
// Health check endpoint
Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
// Readiness check endpoint
Ready(ctx context.Context, in *ReadinessRequest, opts ...grpc.CallOption) (*ReadinessResponse, error)
// Generate execution plan (if supported)
GenerateExecutionPlan(ctx context.Context, in *PlanRequest, opts ...grpc.CallOption) (*PlanResponse, error)
// Approve execution plan (if supported)
ApproveExecutionPlan(ctx context.Context, in *ApprovalRequest, opts ...grpc.CallOption) (*ApprovalResponse, error)
}
AgentServiceClient is the client API for AgentService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
AgentService defines the gRPC service for agent operations
func NewAgentServiceClient ¶
func NewAgentServiceClient(cc grpc.ClientConnInterface) AgentServiceClient
type AgentServiceServer ¶
type AgentServiceServer interface {
// Run executes the agent with the given input
Run(context.Context, *RunRequest) (*RunResponse, error)
// RunStream executes the agent with streaming response
RunStream(*RunRequest, grpc.ServerStreamingServer[RunStreamResponse]) error
// GetMetadata returns agent metadata
GetMetadata(context.Context, *MetadataRequest) (*MetadataResponse, error)
// GetCapabilities returns agent capabilities
GetCapabilities(context.Context, *CapabilitiesRequest) (*CapabilitiesResponse, error)
// Health check endpoint
Health(context.Context, *HealthRequest) (*HealthResponse, error)
// Readiness check endpoint
Ready(context.Context, *ReadinessRequest) (*ReadinessResponse, error)
// Generate execution plan (if supported)
GenerateExecutionPlan(context.Context, *PlanRequest) (*PlanResponse, error)
// Approve execution plan (if supported)
ApproveExecutionPlan(context.Context, *ApprovalRequest) (*ApprovalResponse, error)
// contains filtered or unexported methods
}
AgentServiceServer is the server API for AgentService service. All implementations must embed UnimplementedAgentServiceServer for forward compatibility.
AgentService defines the gRPC service for agent operations
type AgentService_RunStreamClient ¶
type AgentService_RunStreamClient = grpc.ServerStreamingClient[RunStreamResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AgentService_RunStreamServer ¶
type AgentService_RunStreamServer = grpc.ServerStreamingServer[RunStreamResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ApprovalRequest ¶
type ApprovalRequest struct {
PlanId string `protobuf:"bytes,1,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"`
Approved bool `protobuf:"varint,2,opt,name=approved,proto3" json:"approved,omitempty"`
Modifications string `protobuf:"bytes,3,opt,name=modifications,proto3" json:"modifications,omitempty"`
// contains filtered or unexported fields
}
ApprovalRequest for approving execution plans
func (*ApprovalRequest) Descriptor
deprecated
func (*ApprovalRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApprovalRequest.ProtoReflect.Descriptor instead.
func (*ApprovalRequest) GetApproved ¶
func (x *ApprovalRequest) GetApproved() bool
func (*ApprovalRequest) GetModifications ¶
func (x *ApprovalRequest) GetModifications() string
func (*ApprovalRequest) GetPlanId ¶
func (x *ApprovalRequest) GetPlanId() string
func (*ApprovalRequest) ProtoMessage ¶
func (*ApprovalRequest) ProtoMessage()
func (*ApprovalRequest) ProtoReflect ¶
func (x *ApprovalRequest) ProtoReflect() protoreflect.Message
func (*ApprovalRequest) Reset ¶
func (x *ApprovalRequest) Reset()
func (*ApprovalRequest) String ¶
func (x *ApprovalRequest) String() string
type ApprovalResponse ¶
type ApprovalResponse struct {
Result string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
ApprovalResponse contains the approval result
func (*ApprovalResponse) Descriptor
deprecated
func (*ApprovalResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApprovalResponse.ProtoReflect.Descriptor instead.
func (*ApprovalResponse) GetError ¶
func (x *ApprovalResponse) GetError() string
func (*ApprovalResponse) GetResult ¶
func (x *ApprovalResponse) GetResult() string
func (*ApprovalResponse) ProtoMessage ¶
func (*ApprovalResponse) ProtoMessage()
func (*ApprovalResponse) ProtoReflect ¶
func (x *ApprovalResponse) ProtoReflect() protoreflect.Message
func (*ApprovalResponse) Reset ¶
func (x *ApprovalResponse) Reset()
func (*ApprovalResponse) String ¶
func (x *ApprovalResponse) String() string
type CapabilitiesRequest ¶
type CapabilitiesRequest struct {
// contains filtered or unexported fields
}
CapabilitiesRequest for getting agent capabilities
func (*CapabilitiesRequest) Descriptor
deprecated
func (*CapabilitiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use CapabilitiesRequest.ProtoReflect.Descriptor instead.
func (*CapabilitiesRequest) ProtoMessage ¶
func (*CapabilitiesRequest) ProtoMessage()
func (*CapabilitiesRequest) ProtoReflect ¶
func (x *CapabilitiesRequest) ProtoReflect() protoreflect.Message
func (*CapabilitiesRequest) Reset ¶
func (x *CapabilitiesRequest) Reset()
func (*CapabilitiesRequest) String ¶
func (x *CapabilitiesRequest) String() string
type CapabilitiesResponse ¶
type CapabilitiesResponse struct {
Tools []string `protobuf:"bytes,1,rep,name=tools,proto3" json:"tools,omitempty"`
SubAgents []string `protobuf:"bytes,2,rep,name=sub_agents,json=subAgents,proto3" json:"sub_agents,omitempty"`
SupportsExecutionPlans bool `` /* 130-byte string literal not displayed */
SupportsMemory bool `protobuf:"varint,4,opt,name=supports_memory,json=supportsMemory,proto3" json:"supports_memory,omitempty"`
SupportsStreaming bool `protobuf:"varint,5,opt,name=supports_streaming,json=supportsStreaming,proto3" json:"supports_streaming,omitempty"`
// contains filtered or unexported fields
}
CapabilitiesResponse contains agent capabilities
func (*CapabilitiesResponse) Descriptor
deprecated
func (*CapabilitiesResponse) Descriptor() ([]byte, []int)
Deprecated: Use CapabilitiesResponse.ProtoReflect.Descriptor instead.
func (*CapabilitiesResponse) GetSubAgents ¶
func (x *CapabilitiesResponse) GetSubAgents() []string
func (*CapabilitiesResponse) GetSupportsExecutionPlans ¶
func (x *CapabilitiesResponse) GetSupportsExecutionPlans() bool
func (*CapabilitiesResponse) GetSupportsMemory ¶
func (x *CapabilitiesResponse) GetSupportsMemory() bool
func (*CapabilitiesResponse) GetSupportsStreaming ¶
func (x *CapabilitiesResponse) GetSupportsStreaming() bool
func (*CapabilitiesResponse) GetTools ¶
func (x *CapabilitiesResponse) GetTools() []string
func (*CapabilitiesResponse) ProtoMessage ¶
func (*CapabilitiesResponse) ProtoMessage()
func (*CapabilitiesResponse) ProtoReflect ¶
func (x *CapabilitiesResponse) ProtoReflect() protoreflect.Message
func (*CapabilitiesResponse) Reset ¶
func (x *CapabilitiesResponse) Reset()
func (*CapabilitiesResponse) String ¶
func (x *CapabilitiesResponse) String() string
type EventType ¶
type EventType int32
EventType enum for different types of streaming events
const ( EventType_EVENT_TYPE_UNSPECIFIED EventType = 0 EventType_EVENT_TYPE_MESSAGE_START EventType = 1 EventType_EVENT_TYPE_CONTENT EventType = 2 EventType_EVENT_TYPE_THINKING EventType = 3 EventType_EVENT_TYPE_TOOL_CALL EventType = 4 EventType_EVENT_TYPE_TOOL_RESULT EventType = 5 EventType_EVENT_TYPE_ERROR EventType = 6 EventType_EVENT_TYPE_COMPLETE EventType = 7 EventType_EVENT_TYPE_MESSAGE_STOP EventType = 8 )
func (EventType) Descriptor ¶
func (EventType) Descriptor() protoreflect.EnumDescriptor
func (EventType) EnumDescriptor
deprecated
func (EventType) Number ¶
func (x EventType) Number() protoreflect.EnumNumber
func (EventType) Type ¶
func (EventType) Type() protoreflect.EnumType
type HealthRequest ¶
type HealthRequest struct {
// contains filtered or unexported fields
}
HealthRequest for health checks
func (*HealthRequest) Descriptor
deprecated
func (*HealthRequest) Descriptor() ([]byte, []int)
Deprecated: Use HealthRequest.ProtoReflect.Descriptor instead.
func (*HealthRequest) ProtoMessage ¶
func (*HealthRequest) ProtoMessage()
func (*HealthRequest) ProtoReflect ¶
func (x *HealthRequest) ProtoReflect() protoreflect.Message
func (*HealthRequest) Reset ¶
func (x *HealthRequest) Reset()
func (*HealthRequest) String ¶
func (x *HealthRequest) String() string
type HealthResponse ¶
type HealthResponse struct {
Status HealthResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=agent.HealthResponse_Status" json:"status,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
HealthResponse contains health status
func (*HealthResponse) Descriptor
deprecated
func (*HealthResponse) Descriptor() ([]byte, []int)
Deprecated: Use HealthResponse.ProtoReflect.Descriptor instead.
func (*HealthResponse) GetMessage ¶
func (x *HealthResponse) GetMessage() string
func (*HealthResponse) GetStatus ¶
func (x *HealthResponse) GetStatus() HealthResponse_Status
func (*HealthResponse) ProtoMessage ¶
func (*HealthResponse) ProtoMessage()
func (*HealthResponse) ProtoReflect ¶
func (x *HealthResponse) ProtoReflect() protoreflect.Message
func (*HealthResponse) Reset ¶
func (x *HealthResponse) Reset()
func (*HealthResponse) String ¶
func (x *HealthResponse) String() string
type HealthResponse_Status ¶
type HealthResponse_Status int32
const ( HealthResponse_UNKNOWN HealthResponse_Status = 0 HealthResponse_SERVING HealthResponse_Status = 1 HealthResponse_NOT_SERVING HealthResponse_Status = 2 HealthResponse_SERVICE_UNKNOWN HealthResponse_Status = 3 )
func (HealthResponse_Status) Descriptor ¶
func (HealthResponse_Status) Descriptor() protoreflect.EnumDescriptor
func (HealthResponse_Status) Enum ¶
func (x HealthResponse_Status) Enum() *HealthResponse_Status
func (HealthResponse_Status) EnumDescriptor
deprecated
func (HealthResponse_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use HealthResponse_Status.Descriptor instead.
func (HealthResponse_Status) Number ¶
func (x HealthResponse_Status) Number() protoreflect.EnumNumber
func (HealthResponse_Status) String ¶
func (x HealthResponse_Status) String() string
func (HealthResponse_Status) Type ¶
func (HealthResponse_Status) Type() protoreflect.EnumType
type MetadataRequest ¶
type MetadataRequest struct {
// contains filtered or unexported fields
}
MetadataRequest for getting agent metadata
func (*MetadataRequest) Descriptor
deprecated
func (*MetadataRequest) Descriptor() ([]byte, []int)
Deprecated: Use MetadataRequest.ProtoReflect.Descriptor instead.
func (*MetadataRequest) ProtoMessage ¶
func (*MetadataRequest) ProtoMessage()
func (*MetadataRequest) ProtoReflect ¶
func (x *MetadataRequest) ProtoReflect() protoreflect.Message
func (*MetadataRequest) Reset ¶
func (x *MetadataRequest) Reset()
func (*MetadataRequest) String ¶
func (x *MetadataRequest) String() string
type MetadataResponse ¶
type MetadataResponse struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
SystemPrompt string `protobuf:"bytes,3,opt,name=system_prompt,json=systemPrompt,proto3" json:"system_prompt,omitempty"`
Capabilities []string `protobuf:"bytes,4,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
Properties map[string]string `` /* 147-byte string literal not displayed */
// contains filtered or unexported fields
}
MetadataResponse contains agent metadata
func (*MetadataResponse) Descriptor
deprecated
func (*MetadataResponse) Descriptor() ([]byte, []int)
Deprecated: Use MetadataResponse.ProtoReflect.Descriptor instead.
func (*MetadataResponse) GetCapabilities ¶
func (x *MetadataResponse) GetCapabilities() []string
func (*MetadataResponse) GetDescription ¶
func (x *MetadataResponse) GetDescription() string
func (*MetadataResponse) GetName ¶
func (x *MetadataResponse) GetName() string
func (*MetadataResponse) GetProperties ¶
func (x *MetadataResponse) GetProperties() map[string]string
func (*MetadataResponse) GetSystemPrompt ¶
func (x *MetadataResponse) GetSystemPrompt() string
func (*MetadataResponse) ProtoMessage ¶
func (*MetadataResponse) ProtoMessage()
func (*MetadataResponse) ProtoReflect ¶
func (x *MetadataResponse) ProtoReflect() protoreflect.Message
func (*MetadataResponse) Reset ¶
func (x *MetadataResponse) Reset()
func (*MetadataResponse) String ¶
func (x *MetadataResponse) String() string
type PlanRequest ¶
type PlanRequest struct {
Input string `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
Context map[string]string `` /* 141-byte string literal not displayed */
OrgId string `protobuf:"bytes,3,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
ConversationId string `protobuf:"bytes,4,opt,name=conversation_id,json=conversationId,proto3" json:"conversation_id,omitempty"`
// contains filtered or unexported fields
}
PlanRequest for generating execution plans
func (*PlanRequest) Descriptor
deprecated
func (*PlanRequest) Descriptor() ([]byte, []int)
Deprecated: Use PlanRequest.ProtoReflect.Descriptor instead.
func (*PlanRequest) GetContext ¶
func (x *PlanRequest) GetContext() map[string]string
func (*PlanRequest) GetConversationId ¶
func (x *PlanRequest) GetConversationId() string
func (*PlanRequest) GetInput ¶
func (x *PlanRequest) GetInput() string
func (*PlanRequest) GetOrgId ¶
func (x *PlanRequest) GetOrgId() string
func (*PlanRequest) ProtoMessage ¶
func (*PlanRequest) ProtoMessage()
func (*PlanRequest) ProtoReflect ¶
func (x *PlanRequest) ProtoReflect() protoreflect.Message
func (*PlanRequest) Reset ¶
func (x *PlanRequest) Reset()
func (*PlanRequest) String ¶
func (x *PlanRequest) String() string
type PlanResponse ¶
type PlanResponse struct {
PlanId string `protobuf:"bytes,1,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"`
FormattedPlan string `protobuf:"bytes,2,opt,name=formatted_plan,json=formattedPlan,proto3" json:"formatted_plan,omitempty"`
Steps []*PlanStep `protobuf:"bytes,3,rep,name=steps,proto3" json:"steps,omitempty"`
Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
PlanResponse contains the execution plan
func (*PlanResponse) Descriptor
deprecated
func (*PlanResponse) Descriptor() ([]byte, []int)
Deprecated: Use PlanResponse.ProtoReflect.Descriptor instead.
func (*PlanResponse) GetError ¶
func (x *PlanResponse) GetError() string
func (*PlanResponse) GetFormattedPlan ¶
func (x *PlanResponse) GetFormattedPlan() string
func (*PlanResponse) GetPlanId ¶
func (x *PlanResponse) GetPlanId() string
func (*PlanResponse) GetSteps ¶
func (x *PlanResponse) GetSteps() []*PlanStep
func (*PlanResponse) ProtoMessage ¶
func (*PlanResponse) ProtoMessage()
func (*PlanResponse) ProtoReflect ¶
func (x *PlanResponse) ProtoReflect() protoreflect.Message
func (*PlanResponse) Reset ¶
func (x *PlanResponse) Reset()
func (*PlanResponse) String ¶
func (x *PlanResponse) String() string
type PlanStep ¶
type PlanStep struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
ToolName string `protobuf:"bytes,3,opt,name=tool_name,json=toolName,proto3" json:"tool_name,omitempty"`
Parameters map[string]string `` /* 147-byte string literal not displayed */
// contains filtered or unexported fields
}
PlanStep represents a step in an execution plan
func (*PlanStep) Descriptor
deprecated
func (*PlanStep) GetDescription ¶
func (*PlanStep) GetParameters ¶
func (*PlanStep) GetToolName ¶
func (*PlanStep) ProtoMessage ¶
func (*PlanStep) ProtoMessage()
func (*PlanStep) ProtoReflect ¶
func (x *PlanStep) ProtoReflect() protoreflect.Message
type ReadinessRequest ¶
type ReadinessRequest struct {
// contains filtered or unexported fields
}
ReadinessRequest for readiness checks
func (*ReadinessRequest) Descriptor
deprecated
func (*ReadinessRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadinessRequest.ProtoReflect.Descriptor instead.
func (*ReadinessRequest) ProtoMessage ¶
func (*ReadinessRequest) ProtoMessage()
func (*ReadinessRequest) ProtoReflect ¶
func (x *ReadinessRequest) ProtoReflect() protoreflect.Message
func (*ReadinessRequest) Reset ¶
func (x *ReadinessRequest) Reset()
func (*ReadinessRequest) String ¶
func (x *ReadinessRequest) String() string
type ReadinessResponse ¶
type ReadinessResponse struct {
Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
ReadinessResponse contains readiness status
func (*ReadinessResponse) Descriptor
deprecated
func (*ReadinessResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadinessResponse.ProtoReflect.Descriptor instead.
func (*ReadinessResponse) GetMessage ¶
func (x *ReadinessResponse) GetMessage() string
func (*ReadinessResponse) GetReady ¶
func (x *ReadinessResponse) GetReady() bool
func (*ReadinessResponse) ProtoMessage ¶
func (*ReadinessResponse) ProtoMessage()
func (*ReadinessResponse) ProtoReflect ¶
func (x *ReadinessResponse) ProtoReflect() protoreflect.Message
func (*ReadinessResponse) Reset ¶
func (x *ReadinessResponse) Reset()
func (*ReadinessResponse) String ¶
func (x *ReadinessResponse) String() string
type RunRequest ¶
type RunRequest struct {
Input string `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
Context map[string]string `` /* 141-byte string literal not displayed */
OrgId string `protobuf:"bytes,3,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
MaxIterations int32 `protobuf:"varint,4,opt,name=max_iterations,json=maxIterations,proto3" json:"max_iterations,omitempty"`
ConversationId string `protobuf:"bytes,5,opt,name=conversation_id,json=conversationId,proto3" json:"conversation_id,omitempty"`
// contains filtered or unexported fields
}
RunRequest contains the input for agent execution
func (*RunRequest) Descriptor
deprecated
func (*RunRequest) Descriptor() ([]byte, []int)
Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.
func (*RunRequest) GetContext ¶
func (x *RunRequest) GetContext() map[string]string
func (*RunRequest) GetConversationId ¶
func (x *RunRequest) GetConversationId() string
func (*RunRequest) GetInput ¶
func (x *RunRequest) GetInput() string
func (*RunRequest) GetMaxIterations ¶
func (x *RunRequest) GetMaxIterations() int32
func (*RunRequest) GetOrgId ¶
func (x *RunRequest) GetOrgId() string
func (*RunRequest) ProtoMessage ¶
func (*RunRequest) ProtoMessage()
func (*RunRequest) ProtoReflect ¶
func (x *RunRequest) ProtoReflect() protoreflect.Message
func (*RunRequest) Reset ¶
func (x *RunRequest) Reset()
func (*RunRequest) String ¶
func (x *RunRequest) String() string
type RunResponse ¶
type RunResponse struct {
Output string `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
Metadata map[string]string `` /* 143-byte string literal not displayed */
// contains filtered or unexported fields
}
RunResponse contains the agent's response
func (*RunResponse) Descriptor
deprecated
func (*RunResponse) Descriptor() ([]byte, []int)
Deprecated: Use RunResponse.ProtoReflect.Descriptor instead.
func (*RunResponse) GetError ¶
func (x *RunResponse) GetError() string
func (*RunResponse) GetMetadata ¶
func (x *RunResponse) GetMetadata() map[string]string
func (*RunResponse) GetOutput ¶
func (x *RunResponse) GetOutput() string
func (*RunResponse) ProtoMessage ¶
func (*RunResponse) ProtoMessage()
func (*RunResponse) ProtoReflect ¶
func (x *RunResponse) ProtoReflect() protoreflect.Message
func (*RunResponse) Reset ¶
func (x *RunResponse) Reset()
func (*RunResponse) String ¶
func (x *RunResponse) String() string
type RunStreamResponse ¶
type RunStreamResponse struct {
Chunk string `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
IsFinal bool `protobuf:"varint,2,opt,name=is_final,json=isFinal,proto3" json:"is_final,omitempty"`
Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
// Enhanced fields for richer streaming events
EventType EventType `protobuf:"varint,4,opt,name=event_type,json=eventType,proto3,enum=agent.EventType" json:"event_type,omitempty"`
ToolCall *ToolCall `protobuf:"bytes,5,opt,name=tool_call,json=toolCall,proto3" json:"tool_call,omitempty"`
Thinking string `protobuf:"bytes,6,opt,name=thinking,proto3" json:"thinking,omitempty"`
Metadata map[string]string `` /* 143-byte string literal not displayed */
Timestamp int64 `protobuf:"varint,8,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Unix timestamp in milliseconds
// contains filtered or unexported fields
}
RunStreamResponse for streaming responses
func (*RunStreamResponse) Descriptor
deprecated
func (*RunStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use RunStreamResponse.ProtoReflect.Descriptor instead.
func (*RunStreamResponse) GetChunk ¶
func (x *RunStreamResponse) GetChunk() string
func (*RunStreamResponse) GetError ¶
func (x *RunStreamResponse) GetError() string
func (*RunStreamResponse) GetEventType ¶
func (x *RunStreamResponse) GetEventType() EventType
func (*RunStreamResponse) GetIsFinal ¶
func (x *RunStreamResponse) GetIsFinal() bool
func (*RunStreamResponse) GetMetadata ¶
func (x *RunStreamResponse) GetMetadata() map[string]string
func (*RunStreamResponse) GetThinking ¶
func (x *RunStreamResponse) GetThinking() string
func (*RunStreamResponse) GetTimestamp ¶
func (x *RunStreamResponse) GetTimestamp() int64
func (*RunStreamResponse) GetToolCall ¶
func (x *RunStreamResponse) GetToolCall() *ToolCall
func (*RunStreamResponse) ProtoMessage ¶
func (*RunStreamResponse) ProtoMessage()
func (*RunStreamResponse) ProtoReflect ¶
func (x *RunStreamResponse) ProtoReflect() protoreflect.Message
func (*RunStreamResponse) Reset ¶
func (x *RunStreamResponse) Reset()
func (*RunStreamResponse) String ¶
func (x *RunStreamResponse) 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"`
DisplayName string `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
Internal bool `protobuf:"varint,4,opt,name=internal,proto3" json:"internal,omitempty"`
Arguments string `protobuf:"bytes,5,opt,name=arguments,proto3" json:"arguments,omitempty"`
Result string `protobuf:"bytes,6,opt,name=result,proto3" json:"result,omitempty"`
Status string `protobuf:"bytes,7,opt,name=status,proto3" json:"status,omitempty"` // "received", "executing", "completed", "error"
// contains filtered or unexported fields
}
ToolCall message for tool execution information
func (*ToolCall) Descriptor
deprecated
func (*ToolCall) GetArguments ¶
func (*ToolCall) GetDisplayName ¶
func (*ToolCall) GetInternal ¶
func (*ToolCall) ProtoMessage ¶
func (*ToolCall) ProtoMessage()
func (*ToolCall) ProtoReflect ¶
func (x *ToolCall) ProtoReflect() protoreflect.Message
type UnimplementedAgentServiceServer ¶
type UnimplementedAgentServiceServer struct{}
UnimplementedAgentServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedAgentServiceServer) ApproveExecutionPlan ¶
func (UnimplementedAgentServiceServer) ApproveExecutionPlan(context.Context, *ApprovalRequest) (*ApprovalResponse, error)
func (UnimplementedAgentServiceServer) GenerateExecutionPlan ¶
func (UnimplementedAgentServiceServer) GenerateExecutionPlan(context.Context, *PlanRequest) (*PlanResponse, error)
func (UnimplementedAgentServiceServer) GetCapabilities ¶
func (UnimplementedAgentServiceServer) GetCapabilities(context.Context, *CapabilitiesRequest) (*CapabilitiesResponse, error)
func (UnimplementedAgentServiceServer) GetMetadata ¶
func (UnimplementedAgentServiceServer) GetMetadata(context.Context, *MetadataRequest) (*MetadataResponse, error)
func (UnimplementedAgentServiceServer) Health ¶
func (UnimplementedAgentServiceServer) Health(context.Context, *HealthRequest) (*HealthResponse, error)
func (UnimplementedAgentServiceServer) Ready ¶
func (UnimplementedAgentServiceServer) Ready(context.Context, *ReadinessRequest) (*ReadinessResponse, error)
func (UnimplementedAgentServiceServer) Run ¶
func (UnimplementedAgentServiceServer) Run(context.Context, *RunRequest) (*RunResponse, error)
func (UnimplementedAgentServiceServer) RunStream ¶
func (UnimplementedAgentServiceServer) RunStream(*RunRequest, grpc.ServerStreamingServer[RunStreamResponse]) error
type UnsafeAgentServiceServer ¶
type UnsafeAgentServiceServer interface {
// contains filtered or unexported methods
}
UnsafeAgentServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServiceServer will result in compilation errors.