api

package
v0.0.0-...-4b2b8ef Latest Latest
Warning

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

 Go to latest Published: Mar 29, 2026 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AgentHandler 

type AgentHandler struct {
	v1connect.UnimplementedAgentServiceHandler
	// contains filtered or unexported fields
}

func NewAgentHandler 

func NewAgentHandler(db *memory.Client, analytics analytics.Client) *AgentHandler

func (*AgentHandler) CreateAgent 

func (h *AgentHandler) CreateAgent(ctx context.Context, req *connect.Request[v1.CreateAgentRequest]) (*connect.Response[v1.CreateAgentResponse], error)

func (*AgentHandler) DeleteAgent 

func (h *AgentHandler) DeleteAgent(ctx context.Context, req *connect.Request[v1.DeleteAgentRequest]) (*connect.Response[v1.DeleteAgentResponse], error)

func (*AgentHandler) GetAgent 

func (h *AgentHandler) GetAgent(ctx context.Context, req *connect.Request[v1.GetAgentRequest]) (*connect.Response[v1.GetAgentResponse], error)

func (*AgentHandler) ListAgents 

func (h *AgentHandler) ListAgents(ctx context.Context, req *connect.Request[v1.ListAgentsRequest]) (*connect.Response[v1.ListAgentsResponse], error)

func (*AgentHandler) UpdateAgent 

func (h *AgentHandler) UpdateAgent(ctx context.Context, req *connect.Request[v1.UpdateAgentRequest]) (*connect.Response[v1.UpdateAgentResponse], error)

type AgentRuntime 

type AgentRuntime interface {
	Memory() *memory.Client
	Encryption() *secret.Encryption
}

type AuthHandler 

type AuthHandler struct {
	v1connect.UnimplementedAuthServiceHandler
	// contains filtered or unexported fields
}

func NewAuthHandler 

func NewAuthHandler(db *memory.Client, tokenProvider *auth.TokenProvider) *AuthHandler

func (*AuthHandler) CreateSetupCode 

func (h *AuthHandler) CreateSetupCode(ctx context.Context, req *connect.Request[v1.CreateSetupCodeRequest]) (*connect.Response[v1.CreateSetupCodeResponse], error)

func (*AuthHandler) CreateToken 

func (h *AuthHandler) CreateToken(ctx context.Context, req *connect.Request[v1.CreateTokenRequest]) (*connect.Response[v1.CreateTokenResponse], error)

func (*AuthHandler) ExchangeSetupCode 

func (h *AuthHandler) ExchangeSetupCode(ctx context.Context, req *connect.Request[v1.ExchangeSetupCodeRequest]) (*connect.Response[v1.ExchangeSetupCodeResponse], error)

func (*AuthHandler) ListTokens 

func (h *AuthHandler) ListTokens(ctx context.Context, req *connect.Request[v1.ListTokensRequest]) (*connect.Response[v1.ListTokensResponse], error)

func (*AuthHandler) RevokeToken 

func (h *AuthHandler) RevokeToken(ctx context.Context, req *connect.Request[v1.RevokeTokenRequest]) (*connect.Response[v1.RevokeTokenResponse], error)

type EventHandler 

type EventHandler struct {
	v1connect.UnimplementedEventServiceHandler
	// contains filtered or unexported fields
}

EventHandler implements the EventService for streaming events to clients.

func NewEventHandler 

func NewEventHandler(db *memory.Client, eventRouter *event.EventRouter) *EventHandler

NewEventHandler creates a new EventHandler.

func (*EventHandler) Subscribe 

func (h *EventHandler) Subscribe(
	ctx context.Context,
	req *connect.Request[v1.EventSubscribeRequest],
	stream *connect.ServerStream[v1.EventSubscribeResponse],
) error

Subscribe streams events matching the filter criteria.

type Handler 

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

func NewHandler 

func NewHandler(opts HandlerOptions) *Handler

func (Handler) ServeHTTP 

func (h Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type HandlerOptions 

type HandlerOptions struct {
	DB            *memory.Client
	Encryption    *secret.Encryption
	AgentRuntime  AgentRuntime
	TokenProvider *auth.TokenProvider
	Skills        *skill.SkillManager

	EventRouter *event.EventRouter
	Analytics   analytics.Client

	RequestOptions []connect.HandlerOption
}

type MessageHandler 

type MessageHandler struct {
	v1connect.UnimplementedMessageServiceHandler
	// contains filtered or unexported fields
}

func NewMessageHandler 

func NewMessageHandler(db *memory.Client, runtime AgentRuntime, eventRouter *event.EventRouter) *MessageHandler

func (*MessageHandler) CreateMessage 

func (h *MessageHandler) CreateMessage(ctx context.Context, req *connect.Request[v1.CreateMessageRequest]) (*connect.Response[v1.CreateMessageResponse], error)

func (*MessageHandler) DeleteMessage 

func (h *MessageHandler) DeleteMessage(ctx context.Context, req *connect.Request[v1.DeleteMessageRequest]) (*connect.Response[v1.DeleteMessageResponse], error)

func (*MessageHandler) GetMessage 

func (h *MessageHandler) GetMessage(ctx context.Context, req *connect.Request[v1.GetMessageRequest]) (*connect.Response[v1.GetMessageResponse], error)

func (*MessageHandler) ListMessages 

func (h *MessageHandler) ListMessages(ctx context.Context, req *connect.Request[v1.ListMessagesRequest]) (*connect.Response[v1.ListMessagesResponse], error)

func (*MessageHandler) UpdateMessage 

func (h *MessageHandler) UpdateMessage(ctx context.Context, req *connect.Request[v1.UpdateMessageRequest]) (*connect.Response[v1.UpdateMessageResponse], error)

type ModelHandler 

type ModelHandler struct {
	v1connect.UnimplementedModelServiceHandler
	// contains filtered or unexported fields
}

func NewModelHandler 

func NewModelHandler(db *memory.Client) *ModelHandler

func (*ModelHandler) CreateModel 

func (h *ModelHandler) CreateModel(ctx context.Context, req *connect.Request[v1.CreateModelRequest]) (*connect.Response[v1.CreateModelResponse], error)

func (*ModelHandler) DeleteModel 

func (h *ModelHandler) DeleteModel(ctx context.Context, req *connect.Request[v1.DeleteModelRequest]) (*connect.Response[v1.DeleteModelResponse], error)

func (*ModelHandler) GetModel 

func (h *ModelHandler) GetModel(ctx context.Context, req *connect.Request[v1.GetModelRequest]) (*connect.Response[v1.GetModelResponse], error)

func (*ModelHandler) ListModels 

func (h *ModelHandler) ListModels(ctx context.Context, req *connect.Request[v1.ListModelsRequest]) (*connect.Response[v1.ListModelsResponse], error)

func (*ModelHandler) UpdateModel 

func (h *ModelHandler) UpdateModel(ctx context.Context, req *connect.Request[v1.UpdateModelRequest]) (*connect.Response[v1.UpdateModelResponse], error)

type ModelProviderHandler 

type ModelProviderHandler struct {
	v1connect.UnimplementedModelProviderServiceHandler
	// contains filtered or unexported fields
}

func NewModelProviderHandler 

func NewModelProviderHandler(db *memory.Client, encryption *secret.Encryption) *ModelProviderHandler

func (*ModelProviderHandler) CreateModelProvider 

func (h *ModelProviderHandler) CreateModelProvider(ctx context.Context, req *connect.Request[v1.CreateModelProviderRequest]) (*connect.Response[v1.CreateModelProviderResponse], error)

func (*ModelProviderHandler) DeleteModelProvider 

func (h *ModelProviderHandler) DeleteModelProvider(ctx context.Context, req *connect.Request[v1.DeleteModelProviderRequest]) (*connect.Response[v1.DeleteModelProviderResponse], error)

func (*ModelProviderHandler) GetModelProvider 

func (h *ModelProviderHandler) GetModelProvider(ctx context.Context, req *connect.Request[v1.GetModelProviderRequest]) (*connect.Response[v1.GetModelProviderResponse], error)

func (*ModelProviderHandler) ListModelProviders 

func (h *ModelProviderHandler) ListModelProviders(ctx context.Context, req *connect.Request[v1.ListModelProvidersRequest]) (*connect.Response[v1.ListModelProvidersResponse], error)

func (*ModelProviderHandler) UpdateModelProvider 

func (h *ModelProviderHandler) UpdateModelProvider(ctx context.Context, req *connect.Request[v1.UpdateModelProviderRequest]) (*connect.Response[v1.UpdateModelProviderResponse], error)

type Server 

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

func NewServer 

func NewServer(runtime AgentRuntime, listener net.Listener, eventRouter *event.EventRouter, analyticsClient analytics.Client, skillInstaller *skill.SkillManager) *Server

func (*Server) ListenAndServe 

func (s *Server) ListenAndServe(ctx context.Context) error

func (*Server) Shutdown 

func (s *Server) Shutdown(ctx context.Context) error

type SkillHandler 

type SkillHandler struct {
	v1connect.UnimplementedSkillServiceHandler
	// contains filtered or unexported fields
}

func NewSkillHandler 

func NewSkillHandler(installer *skill.SkillManager) *SkillHandler

func (*SkillHandler) DeleteSkill 

func (h *SkillHandler) DeleteSkill(ctx context.Context, req *connect.Request[v1.DeleteSkillRequest]) (*connect.Response[v1.DeleteSkillResponse], error)

func (*SkillHandler) InstallSkill 

func (h *SkillHandler) InstallSkill(ctx context.Context, req *connect.Request[v1.InstallSkillRequest]) (*connect.Response[v1.InstallSkillResponse], error)

func (*SkillHandler) ListSkills 

func (h *SkillHandler) ListSkills(ctx context.Context, req *connect.Request[v1.ListSkillsRequest]) (*connect.Response[v1.ListSkillsResponse], error)

func (*SkillHandler) UpdateSkill 

func (h *SkillHandler) UpdateSkill(ctx context.Context, req *connect.Request[v1.UpdateSkillRequest]) (*connect.Response[v1.UpdateSkillResponse], error)

type TaskHandler 

type TaskHandler struct {
	v1connect.UnimplementedTaskServiceHandler
	// contains filtered or unexported fields
}

func NewTaskHandler 

func NewTaskHandler(db *memory.Client, eventRouter *event.EventRouter, runtime AgentRuntime, analytics analytics.Client) *TaskHandler

func (*TaskHandler) CreateTask 

func (h *TaskHandler) CreateTask(ctx context.Context, req *connect.Request[v1.CreateTaskRequest]) (*connect.Response[v1.CreateTaskResponse], error)

func (*TaskHandler) DeleteTask 

func (h *TaskHandler) DeleteTask(ctx context.Context, req *connect.Request[v1.DeleteTaskRequest]) (*connect.Response[v1.DeleteTaskResponse], error)

func (*TaskHandler) GetTask 

func (h *TaskHandler) GetTask(ctx context.Context, req *connect.Request[v1.GetTaskRequest]) (*connect.Response[v1.GetTaskResponse], error)

func (*TaskHandler) ListTasks 

func (h *TaskHandler) ListTasks(ctx context.Context, req *connect.Request[v1.ListTasksRequest]) (*connect.Response[v1.ListTasksResponse], error)

func (*TaskHandler) SuspendTask 

func (h *TaskHandler) SuspendTask(ctx context.Context, req *connect.Request[v1.SuspendTaskRequest]) (*connect.Response[v1.SuspendTaskResponse], error)

func (*TaskHandler) UpdateTask 

func (h *TaskHandler) UpdateTask(ctx context.Context, req *connect.Request[v1.UpdateTaskRequest]) (*connect.Response[v1.UpdateTaskResponse], error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.