grpcx

Documentation

Index

• Constants
• func CreateServiceNameInterceptor(serviceName string) (grpc.UnaryServerInterceptor, grpc.StreamServerInterceptor)
• func GetServiceNameFromIncomingContext(ctx context.Context) (string, error)
• func GetServiceNameFromStream(stream grpc.ServerStream) (string, error)
• type GrpcBidiStreamServer
• type PeekableStreamServer
  • func NewPeekableStreamServer[ServerMessage any, ClientMessage any](stream GrpcBidiStreamServer[ServerMessage, ClientMessage]) *PeekableStreamServer[ServerMessage, ClientMessage]
  • func (s *PeekableStreamServer[ServerMessage, ClientMessage]) Peek() (ClientMessage, error)
  • func (s *PeekableStreamServer[ServerMessage, ClientMessage]) Recv() (ClientMessage, error)

Constants

const ServiceNameKey = "x-nitric-service-name"

Functions

func CreateServiceNameInterceptor

func CreateServiceNameInterceptor(serviceName string) (grpc.UnaryServerInterceptor, grpc.StreamServerInterceptor)

func GetServiceNameFromIncomingContext

func GetServiceNameFromIncomingContext(ctx context.Context) (string, error)

GetServiceNameFromIncomingContext extracts the nitric service name from the incoming context of a grpc request

func GetServiceNameFromStream

func GetServiceNameFromStream(stream grpc.ServerStream) (string, error)

GetServiceNameFromStream extracts the nitric service name from the incoming context of a grpc stream

Types

type GrpcBidiStreamServer

type GrpcBidiStreamServer[ServerMessage any, ClientMessage any] interface {
	Send(ServerMessage) error
	Recv() (ClientMessage, error)
	grpc.ServerStream
}

type PeekableStreamServer

type PeekableStreamServer[ServerMessage any, ClientMessage any] struct {
	GrpcBidiStreamServer[ServerMessage, ClientMessage]
	// contains filtered or unexported fields
}

func NewPeekableStreamServer

func NewPeekableStreamServer[ServerMessage any, ClientMessage any](stream GrpcBidiStreamServer[ServerMessage, ClientMessage]) *PeekableStreamServer[ServerMessage, ClientMessage]

func (*PeekableStreamServer[ServerMessage, ClientMessage]) Peek

func (s *PeekableStreamServer[ServerMessage, ClientMessage]) Peek() (ClientMessage, error)

func (*PeekableStreamServer[ServerMessage, ClientMessage]) Recv

func (s *PeekableStreamServer[ServerMessage, ClientMessage]) Recv() (ClientMessage, error)