server

package

v0.2.1 Latest Latest Go to latest Published: Feb 2, 2026 License: MIT Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/AjaxZhan/AgentFense

Links

Open Source Insights

Documentation ¶

Overview ¶

Package server provides gRPC server implementations for sandbox and codebase services.

Index ¶

type CodebaseServiceServer
- func NewCodebaseServiceServer(manager *codebase.Manager) *CodebaseServiceServer
type Config
type SandboxServiceServer
- func NewSandboxServiceServer(rt sbruntime.RuntimeWithExecutor, cbManager *codebase.Manager) *SandboxServiceServer
type Server
- func New(cfg *Config, rt sbruntime.RuntimeWithExecutor, cbManager *codebase.Manager) (*Server, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type CodebaseServiceServer ¶

type CodebaseServiceServer struct {
	pb.UnimplementedCodebaseServiceServer
	// contains filtered or unexported fields
}

CodebaseServiceServer implements the CodebaseService gRPC interface.

func NewCodebaseServiceServer ¶

func NewCodebaseServiceServer(manager *codebase.Manager) *CodebaseServiceServer

NewCodebaseServiceServer creates a new CodebaseServiceServer.

func (*CodebaseServiceServer) CreateCodebase ¶

func (s *CodebaseServiceServer) CreateCodebase(ctx context.Context, req *pb.CreateCodebaseRequest) (*pb.Codebase, error)

CreateCodebase creates a new codebase.

func (*CodebaseServiceServer) DeleteCodebase ¶

func (s *CodebaseServiceServer) DeleteCodebase(ctx context.Context, req *pb.DeleteCodebaseRequest) (*pb.Empty, error)

DeleteCodebase deletes a codebase.

func (*CodebaseServiceServer) DownloadFile ¶

func (s *CodebaseServiceServer) DownloadFile(req *pb.DownloadFileRequest, stream grpc.ServerStreamingServer[pb.FileChunk]) error

DownloadFile downloads a file from a codebase.

func (*CodebaseServiceServer) GetCodebase ¶

func (s *CodebaseServiceServer) GetCodebase(ctx context.Context, req *pb.GetCodebaseRequest) (*pb.Codebase, error)

GetCodebase retrieves information about a codebase.

func (*CodebaseServiceServer) ListCodebases ¶

func (s *CodebaseServiceServer) ListCodebases(ctx context.Context, req *pb.ListCodebasesRequest) (*pb.ListCodebasesResponse, error)

ListCodebases lists all codebases for an owner.

func (*CodebaseServiceServer) ListFiles ¶

func (s *CodebaseServiceServer) ListFiles(ctx context.Context, req *pb.ListFilesRequest) (*pb.ListFilesResponse, error)

ListFiles lists files in a codebase directory.

func (*CodebaseServiceServer) UploadFiles ¶

func (s *CodebaseServiceServer) UploadFiles(stream grpc.ClientStreamingServer[pb.UploadChunk, pb.UploadResult]) error

UploadFiles uploads files to a codebase via streaming.

type Config ¶

type Config struct {
	GRPCAddr string
	RESTAddr string // Optional REST gateway address
}

Config holds server configuration.

type SandboxServiceServer ¶

type SandboxServiceServer struct {
	pb.UnimplementedSandboxServiceServer
	// contains filtered or unexported fields
}

SandboxServiceServer implements the SandboxService gRPC interface.

func NewSandboxServiceServer ¶

func NewSandboxServiceServer(rt sbruntime.RuntimeWithExecutor, cbManager *codebase.Manager) *SandboxServiceServer

NewSandboxServiceServer creates a new SandboxServiceServer.

func (*SandboxServiceServer) CreateSandbox ¶

func (s *SandboxServiceServer) CreateSandbox(ctx context.Context, req *pb.CreateSandboxRequest) (*pb.Sandbox, error)

CreateSandbox creates a new sandbox with specified configuration.

func (*SandboxServiceServer) CreateSession ¶

func (s *SandboxServiceServer) CreateSession(ctx context.Context, req *pb.CreateSessionRequest) (*pb.Session, error)

CreateSession creates a new shell session within a sandbox.

func (*SandboxServiceServer) DestroySandbox ¶

func (s *SandboxServiceServer) DestroySandbox(ctx context.Context, req *pb.DestroySandboxRequest) (*pb.Empty, error)

DestroySandbox destroys a sandbox and releases resources.

func (*SandboxServiceServer) DestroySession ¶

func (s *SandboxServiceServer) DestroySession(ctx context.Context, req *pb.DestroySessionRequest) (*pb.Empty, error)

DestroySession destroys a session and kills all its child processes.

func (*SandboxServiceServer) Exec ¶

func (s *SandboxServiceServer) Exec(ctx context.Context, req *pb.ExecRequest) (*pb.ExecResult, error)

Exec executes a command in a sandbox.

func (*SandboxServiceServer) ExecStream ¶

func (s *SandboxServiceServer) ExecStream(req *pb.ExecRequest, stream grpc.ServerStreamingServer[pb.ExecOutput]) error

ExecStream executes a command and streams output.

func (*SandboxServiceServer) GetSandbox ¶

func (s *SandboxServiceServer) GetSandbox(ctx context.Context, req *pb.GetSandboxRequest) (*pb.Sandbox, error)

GetSandbox retrieves information about a sandbox.

func (*SandboxServiceServer) GetSession ¶

func (s *SandboxServiceServer) GetSession(ctx context.Context, req *pb.GetSessionRequest) (*pb.Session, error)

GetSession retrieves information about a session.

func (*SandboxServiceServer) ListSandboxes ¶

func (s *SandboxServiceServer) ListSandboxes(ctx context.Context, req *pb.ListSandboxesRequest) (*pb.ListSandboxesResponse, error)

ListSandboxes lists all sandboxes.

func (*SandboxServiceServer) ListSessions ¶

func (s *SandboxServiceServer) ListSessions(ctx context.Context, req *pb.ListSessionsRequest) (*pb.ListSessionsResponse, error)

ListSessions lists all sessions for a sandbox.

func (*SandboxServiceServer) SessionExec ¶

func (s *SandboxServiceServer) SessionExec(ctx context.Context, req *pb.SessionExecRequest) (*pb.ExecResult, error)

SessionExec executes a command within a session (stateful).

func (*SandboxServiceServer) SessionExecStream ¶

func (s *SandboxServiceServer) SessionExecStream(req *pb.SessionExecRequest, stream grpc.ServerStreamingServer[pb.ExecOutput]) error

SessionExecStream executes a command within a session and streams output.

func (*SandboxServiceServer) StartSandbox ¶

func (s *SandboxServiceServer) StartSandbox(ctx context.Context, req *pb.StartSandboxRequest) (*pb.Sandbox, error)

StartSandbox starts a pending sandbox.

func (*SandboxServiceServer) StopSandbox ¶

func (s *SandboxServiceServer) StopSandbox(ctx context.Context, req *pb.StopSandboxRequest) (*pb.Sandbox, error)

StopSandbox stops a running sandbox.

type Server ¶

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

Server represents the gRPC server.

func New ¶

func New(cfg *Config, rt sbruntime.RuntimeWithExecutor, cbManager *codebase.Manager) (*Server, error)

New creates a new gRPC server.

func (*Server) Start ¶

func (s *Server) Start() error

Start starts the gRPC server.

func (*Server) StartWithGateway ¶

func (s *Server) StartWithGateway() error

StartWithGateway starts both gRPC and REST gateway servers.

func (*Server) Stop ¶

func (s *Server) Stop()

Stop gracefully stops the server.

Source Files ¶

View all Source files

server.go

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