pb

package
v0.1.13 Latest Latest
Warning

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

Go to latest
Published: Jan 14, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

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

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

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

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

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

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

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated

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

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String

func (x EventType) String() string

func (EventType) Type

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

func (HealthResponse_Status) EnumDescriptor deprecated

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

Deprecated: Use HealthResponse_Status.Descriptor instead.

func (HealthResponse_Status) Number

func (HealthResponse_Status) String

func (x HealthResponse_Status) String() string

func (HealthResponse_Status) Type

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

Deprecated: Use PlanStep.ProtoReflect.Descriptor instead.

func (*PlanStep) GetDescription

func (x *PlanStep) GetDescription() string

func (*PlanStep) GetId

func (x *PlanStep) GetId() string

func (*PlanStep) GetParameters

func (x *PlanStep) GetParameters() map[string]string

func (*PlanStep) GetToolName

func (x *PlanStep) GetToolName() string

func (*PlanStep) ProtoMessage

func (*PlanStep) ProtoMessage()

func (*PlanStep) ProtoReflect

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

func (*PlanStep) Reset

func (x *PlanStep) Reset()

func (*PlanStep) String

func (x *PlanStep) String() string

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

Deprecated: Use ToolCall.ProtoReflect.Descriptor instead.

func (*ToolCall) GetArguments

func (x *ToolCall) GetArguments() string

func (*ToolCall) GetDisplayName

func (x *ToolCall) GetDisplayName() string

func (*ToolCall) GetId

func (x *ToolCall) GetId() string

func (*ToolCall) GetInternal

func (x *ToolCall) GetInternal() bool

func (*ToolCall) GetName

func (x *ToolCall) GetName() string

func (*ToolCall) GetResult

func (x *ToolCall) GetResult() string

func (*ToolCall) GetStatus

func (x *ToolCall) GetStatus() 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 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) GenerateExecutionPlan

func (UnimplementedAgentServiceServer) GetCapabilities

func (UnimplementedAgentServiceServer) GetMetadata

func (UnimplementedAgentServiceServer) Health

func (UnimplementedAgentServiceServer) Ready

func (UnimplementedAgentServiceServer) Run

func (UnimplementedAgentServiceServer) RunStream

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.

Jump to

Keyboard shortcuts

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