connectrpc

package
v1.8.2 Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Overview

Package connectrpc provides a Connect-RPC server implementation for the cagent API.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Server 

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

Server implements the Connect-RPC AgentService.

func New 

func New(ctx context.Context, sessionStore session.Store, runConfig *config.RuntimeConfig, refreshInterval time.Duration, agentSources config.Sources) (*Server, error)

New creates a new Connect-RPC server.

func (*Server) CreateSession 

func (s *Server) CreateSession(ctx context.Context, req *connect.Request[cagentv1.CreateSessionRequest]) (*connect.Response[cagentv1.CreateSessionResponse], error)

CreateSession creates a new session.

func (*Server) DeleteSession 

func (s *Server) DeleteSession(ctx context.Context, req *connect.Request[cagentv1.DeleteSessionRequest]) (*connect.Response[cagentv1.DeleteSessionResponse], error)

DeleteSession deletes a session by ID.

func (*Server) GetAgent 

func (s *Server) GetAgent(ctx context.Context, req *connect.Request[cagentv1.GetAgentRequest]) (*connect.Response[cagentv1.GetAgentResponse], error)

GetAgent returns the configuration for a specific agent.

func (*Server) GetSession 

func (s *Server) GetSession(ctx context.Context, req *connect.Request[cagentv1.GetSessionRequest]) (*connect.Response[cagentv1.GetSessionResponse], error)

GetSession returns a specific session by ID.

func (*Server) Handler 

func (s *Server) Handler() http.Handler

Handler returns an http.Handler for the Connect-RPC server.

func (*Server) ListAgents 

func (s *Server) ListAgents(ctx context.Context, _ *connect.Request[cagentv1.ListAgentsRequest]) (*connect.Response[cagentv1.ListAgentsResponse], error)

ListAgents returns all available agents.

func (*Server) ListSessions 

func (s *Server) ListSessions(ctx context.Context, _ *connect.Request[cagentv1.ListSessionsRequest]) (*connect.Response[cagentv1.ListSessionsResponse], error)

ListSessions returns all sessions.

func (*Server) Ping 

func (s *Server) Ping(_ context.Context, _ *connect.Request[cagentv1.PingRequest]) (*connect.Response[cagentv1.PingResponse], error)

Ping is a health check endpoint.

func (*Server) ResumeElicitation 

func (s *Server) ResumeElicitation(ctx context.Context, req *connect.Request[cagentv1.ResumeElicitationRequest]) (*connect.Response[cagentv1.ResumeElicitationResponse], error)

ResumeElicitation resumes an elicitation request.

func (*Server) ResumeSession 

func (s *Server) ResumeSession(ctx context.Context, req *connect.Request[cagentv1.ResumeSessionRequest]) (*connect.Response[cagentv1.ResumeSessionResponse], error)

ResumeSession resumes a paused session.

func (*Server) RunAgent 

func (s *Server) RunAgent(ctx context.Context, req *connect.Request[cagentv1.RunAgentRequest], stream *connect.ServerStream[cagentv1.Event]) error

RunAgent runs an agent loop and streams events.

func (*Server) Serve 

func (s *Server) Serve(ctx context.Context, ln net.Listener) error

Serve starts the Connect-RPC server on the given listener.

func (*Server) ToggleToolApproval 

func (s *Server) ToggleToolApproval(ctx context.Context, req *connect.Request[cagentv1.ToggleToolApprovalRequest]) (*connect.Response[cagentv1.ToggleToolApprovalResponse], error)

ToggleToolApproval toggles the YOLO mode for a session.

Source Files

View all Source files

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.