Documentation
¶
Index ¶
- func LoggingInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, ...) (any, error)
- func StreamLoggingInterceptor(srv any, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
- type Server
- func (s *Server) DeleteConversation(ctx context.Context, req *proto.DeleteConversationRequest) (*proto.DeleteConversationResponse, error)
- func (s *Server) Exec(req *proto.ExecRequest, stream grpc.ServerStreamingServer[proto.ExecResponse]) error
- func (s *Server) GracefulStop()
- func (s *Server) Serve(address string, opts ...grpc.ServerOption) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func LoggingInterceptor ¶ added in v0.2.0
func LoggingInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (any, error)
LoggingInterceptor logs unary RPC details, including latency, errors, and conversation ID if present.
func StreamLoggingInterceptor ¶ added in v0.2.0
func StreamLoggingInterceptor(srv any, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error
StreamLoggingInterceptor logs stream RPC connection details and latency.
Types ¶
type Server ¶
type Server struct {
proto.UnimplementedExecutionServiceServer
proto.UnimplementedConversationServiceServer
// contains filtered or unexported fields
}
Server implements the AXService gRPC service.
func (*Server) DeleteConversation ¶
func (s *Server) DeleteConversation(ctx context.Context, req *proto.DeleteConversationRequest) (*proto.DeleteConversationResponse, error)
func (*Server) Exec ¶
func (s *Server) Exec(req *proto.ExecRequest, stream grpc.ServerStreamingServer[proto.ExecResponse]) error
Exec executes a new agentic task with streaming responses.
func (*Server) GracefulStop ¶
func (s *Server) GracefulStop()
GracefulStop stops the gRPC server gracefully.
Source Files
Click to show internal directories.
Click to hide internal directories.