server

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 New(c *controller.Controller) *Server
  • func (s *Server) CreateInteraction(req *proto.CreateInteractionEvent, ...) error
  • func (s *Server) GracefulStop()
  • func (s *Server) Serve(address string, opts ...grpc.ServerOption) error

Functions

func LoggingInterceptor

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

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.UnimplementedInteractionsServiceServer
	// contains filtered or unexported fields
}

Server implements the AXService gRPC service.

func New

func New(c *controller.Controller) *Server

New creates a new controller server.

func (*Server) CreateInteraction

func (s *Server) CreateInteraction(req *proto.CreateInteractionEvent, stream grpc.ServerStreamingServer[proto.CreateInteractionResponse]) error

CreateInteraction executes a new agentic task with streaming responses.

func (*Server) GracefulStop

func (s *Server) GracefulStop()

GracefulStop stops the gRPC server gracefully.

func (*Server) Serve

func (s *Server) Serve(address string, opts ...grpc.ServerOption) error

Serve starts the gRPC server on the specified address.