internal

Documentation

Index

• func NewGRPCServer(svc *agent.Service, agentName, model string) runtimev1.AgentRuntimeServer
• type GRPCServer
  • func (s *GRPCServer) Chat(ctx context.Context, req *runtimev1.ChatRequest) (*runtimev1.ChatResponse, error)
  • func (s *GRPCServer) ChatStream(req *runtimev1.ChatStreamRequest, ...) error
  • func (s *GRPCServer) DeleteSession(ctx context.Context, req *runtimev1.DeleteSessionRequest) (*runtimev1.DeleteSessionResponse, error)
  • func (s *GRPCServer) Health(_ context.Context, _ *runtimev1.HealthRequest) (*runtimev1.HealthResponse, error)
  • func (s *GRPCServer) ListSessionMessages(ctx context.Context, req *runtimev1.ListSessionMessagesRequest) (*runtimev1.ListSessionMessagesResponse, error)
  • func (s *GRPCServer) ListSessions(ctx context.Context, _ *runtimev1.ListSessionsRequest) (*runtimev1.ListSessionsResponse, error)
  • func (s *GRPCServer) PromptObject(ctx context.Context, req *runtimev1.PromptObjectRequest) (*runtimev1.PromptObjectResponse, error)
  • func (s *GRPCServer) Ready(_ context.Context, _ *runtimev1.ReadyRequest) (*runtimev1.ReadyResponse, error)

Functions

func NewGRPCServer

func NewGRPCServer(svc *agent.Service, agentName, model string) runtimev1.AgentRuntimeServer

Types

type GRPCServer

type GRPCServer struct {
	runtimev1.UnimplementedAgentRuntimeServer
	// contains filtered or unexported fields
}

func (*GRPCServer) Chat

func (s *GRPCServer) Chat(ctx context.Context, req *runtimev1.ChatRequest) (*runtimev1.ChatResponse, error)

func (*GRPCServer) ChatStream

func (s *GRPCServer) ChatStream(
	req *runtimev1.ChatStreamRequest, stream runtimev1.AgentRuntime_ChatStreamServer,
) error

func (*GRPCServer) DeleteSession

func (s *GRPCServer) DeleteSession(
	ctx context.Context, req *runtimev1.DeleteSessionRequest,
) (*runtimev1.DeleteSessionResponse, error)

func (*GRPCServer) Health

func (s *GRPCServer) Health(
	_ context.Context, _ *runtimev1.HealthRequest,
) (*runtimev1.HealthResponse, error)

func (*GRPCServer) ListSessionMessages

func (s *GRPCServer) ListSessionMessages(
	ctx context.Context, req *runtimev1.ListSessionMessagesRequest,
) (*runtimev1.ListSessionMessagesResponse, error)

func (*GRPCServer) ListSessions

func (s *GRPCServer) ListSessions(
	ctx context.Context, _ *runtimev1.ListSessionsRequest,
) (*runtimev1.ListSessionsResponse, error)

func (*GRPCServer) PromptObject

func (s *GRPCServer) PromptObject(
	ctx context.Context, req *runtimev1.PromptObjectRequest,
) (*runtimev1.PromptObjectResponse, error)

func (*GRPCServer) Ready

func (s *GRPCServer) Ready(
	_ context.Context, _ *runtimev1.ReadyRequest,
) (*runtimev1.ReadyResponse, error)