proto

Documentation

Index

• func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)
• type AgentServiceClient
  • func NewAgentServiceClient(cc grpc.ClientConnInterface) AgentServiceClient
• type AgentServiceServer
• type AgentService_ListenClient
• type AgentService_ListenServer
• type ExecuteRequest
• type ExecuteResponse
• type ListenRequest
• type ListenResponse
• type Message
• type SendRequest
• type SendResponse
• type SessionContext
• type SessionEntry
• type SessionUpdate
• type UnimplementedAgentServiceServer
  • func (UnimplementedAgentServiceServer) Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
  • func (UnimplementedAgentServiceServer) Listen(*ListenRequest, AgentService_ListenServer) error
  • func (UnimplementedAgentServiceServer) Send(context.Context, *SendRequest) (*SendResponse, error)

Functions

func RegisterAgentServiceServer

func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)

RegisterAgentServiceServer registers the agent service with gRPC

Types

type AgentServiceClient

type AgentServiceClient interface {
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
	Send(ctx context.Context, in *SendRequest, opts ...grpc.CallOption) (*SendResponse, error)
	Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (AgentService_ListenClient, error)
}

AgentServiceClient is the client interface for the agent service

func NewAgentServiceClient

func NewAgentServiceClient(cc grpc.ClientConnInterface) AgentServiceClient

NewAgentServiceClient creates a new AgentServiceClient

type AgentServiceServer

type AgentServiceServer interface {
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
	Send(context.Context, *SendRequest) (*SendResponse, error)
	Listen(*ListenRequest, AgentService_ListenServer) error
}

AgentServiceServer is the server interface for the agent service

type AgentService_ListenClient

type AgentService_ListenClient interface {
	Recv() (*ListenResponse, error)
	grpc.ClientStream
}

AgentService_ListenClient is the client interface for the Listen streaming RPC

type AgentService_ListenServer

type AgentService_ListenServer interface {
	Send(*ListenResponse) error
	grpc.ServerStream
}

AgentService_ListenServer is the server interface for the Listen streaming RPC

type ExecuteRequest

type ExecuteRequest struct {
	AgentName string
	Input     *Message

	// Session context (optional)
	SessionID      string          // Session ID to use
	IncludeHistory bool            // Whether to include conversation history
	SessionContext *SessionContext // Full session context if needed
}

ExecuteRequest represents a request to execute an agent

type ExecuteResponse

type ExecuteResponse struct {
	Output *Message

	// Session updates (if session was used)
	SessionUpdate *SessionUpdate
}

ExecuteResponse represents the response from agent execution

type ListenRequest

type ListenRequest struct {
	AgentName string
}

ListenRequest represents a request to listen for messages from an agent

type ListenResponse

type ListenResponse struct {
	Message *Message
}

ListenResponse wraps a message for streaming

type Message

type Message struct {
	Id        string
	Type      string
	Payload   string
	Timestamp string
	Metadata  map[string]interface{}
}

Message represents a message in the agent system

type SendRequest

type SendRequest struct {
	Target  string
	Message *Message
}

SendRequest represents a request to send a message to an agent

type SendResponse

type SendResponse struct {
	Success bool
}

SendResponse represents the response from sending a message

type SessionContext

type SessionContext struct {
	ID        string
	UserID    string
	AgentName string
	History   []*Message // Conversation history
}

SessionContext contains session information passed in requests

type SessionEntry

type SessionEntry struct {
	ID        string
	ParentID  string
	Timestamp int64
	Type      string
	Data      []byte
}

SessionEntry represents a session log entry

type SessionUpdate

type SessionUpdate struct {
	NewEntries   []*SessionEntry
	MessageCount int32
}

SessionUpdate contains session changes from agent execution

type UnimplementedAgentServiceServer

type UnimplementedAgentServiceServer struct{}

UnimplementedAgentServiceServer provides default implementations

func (UnimplementedAgentServiceServer) Execute

func (UnimplementedAgentServiceServer) Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)

func (UnimplementedAgentServiceServer) Listen

func (UnimplementedAgentServiceServer) Listen(*ListenRequest, AgentService_ListenServer) error

func (UnimplementedAgentServiceServer) Send

func (UnimplementedAgentServiceServer) Send(context.Context, *SendRequest) (*SendResponse, error)