grpc

Documentation

Index

• func AuthInterceptor(expectedToken string) GRPCAuth.AuthFunc
• func LogrusStreamInterceptor(logger *logrus.Entry, reqID string, keys ...string) grpc.StreamServerInterceptor
• func LogrusUnaryInterceptor(logger *logrus.Entry, reqID string, keys ...string) grpc.UnaryServerInterceptor
• type ServerStreamWrapper
  • func (w *ServerStreamWrapper) Context() context.Context

Functions

func AuthInterceptor

func AuthInterceptor(expectedToken string) GRPCAuth.AuthFunc

* AuthInterceptor Function for check authentication send in metadata Example: Bearer token Ref: https://github.com/grpc-ecosystem/go-grpc-middleware

func LogrusStreamInterceptor

func LogrusStreamInterceptor(logger *logrus.Entry, reqID string, keys ...string) grpc.StreamServerInterceptor

* LogrusStreamInterceptor gRPC interceptor to log stream request duration status this function will set field request_id from metadata

func LogrusUnaryInterceptor

func LogrusUnaryInterceptor(logger *logrus.Entry, reqID string, keys ...string) grpc.UnaryServerInterceptor

* //LogrusUnaryInterceptor gRPC interceptor to log unary request duration status this function will set field request_id from metadata

Types

type ServerStreamWrapper

type ServerStreamWrapper struct {
	grpc.ServerStream
	Ctx context.Context
}

func (*ServerStreamWrapper) Context

func (w *ServerStreamWrapper) Context() context.Context