grpc

package

v0.6.0 Latest Latest Go to latest Published: Oct 23, 2025 License: MIT Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Server struct {
	pb.UnimplementedAgentServiceServer
	// contains filtered or unexported fields
}

Server represents the gRPC server

func New(cfg *config.Config, logger zerolog.Logger) (*Server, error)

New creates a new gRPC server instance

func (s *Server) AgentStream(stream pb.AgentService_AgentStreamServer) error

AgentStream implements the AgentStream RPC method

func (s *Server) ExecuteCommand(ctx context.Context, req *pb.CommandRequest) (*pb.CommandResponse, error)

ExecuteCommand implements the ExecuteCommand RPC method

func (s *Server) GracefulStop()

GracefulStop gracefully stops the gRPC server

func (s *Server) HealthCheck(ctx context.Context, req *pb.HealthCheckRequest) (*pb.HealthCheckResponse, error)

HealthCheck implements the HealthCheck RPC method

func (s *Server) Serve(address string) error

Serve starts the gRPC server

func (s *Server) Stop()

Stop forcefully stops the gRPC server

func (s *Server) StreamLogs(req *pb.LogStreamRequest, stream pb.AgentService_StreamLogsServer) error

StreamLogs implements the StreamLogs RPC method

func (s *Server) UpdateConfig(ctx context.Context, req *pb.ConfigUpdateRequest) (*pb.ConfigUpdateResponse, error)

UpdateConfig implements the UpdateConfig RPC method