server_interceptor

Documentation

Index

• func StreamInjectLoggerInterceptor(log logger.LoggerInterface) grpc.StreamServerInterceptor
• func StreamInterceptor(log logger.LoggerInterface, opts ...logger_grpc.Option) grpc.StreamServerInterceptor
• func UnaryInjectLoggerInterceptor(log logger.LoggerInterface) grpc.UnaryServerInterceptor
• func UnaryInterceptor(log logger.LoggerInterface, opts ...logger_grpc.Option) grpc.UnaryServerInterceptor
• type StreamWithContext
  • func (s *StreamWithContext) Context() context.Context
• type StreamWrapper
  • func NewServerStreamWrapper(stream grpc.ServerStream, context context.Context, ...) *StreamWrapper
  • func (s *StreamWrapper) Context() context.Context
  • func (s *StreamWrapper) RecvMsg(m interface{}) error
  • func (s *StreamWrapper) SendHeader(md metadata.MD) error
  • func (s *StreamWrapper) SendMsg(m interface{}) error

Functions

func StreamInjectLoggerInterceptor

func StreamInjectLoggerInterceptor(log logger.LoggerInterface) grpc.StreamServerInterceptor

StreamInjectLoggerInterceptor returns a new streaming server interceptor with logger injected.

func StreamInterceptor

func StreamInterceptor(log logger.LoggerInterface, opts ...logger_grpc.Option) grpc.StreamServerInterceptor

StreamInterceptor returns a new streaming server interceptor that log.

func UnaryInjectLoggerInterceptor

func UnaryInjectLoggerInterceptor(log logger.LoggerInterface) grpc.UnaryServerInterceptor

UnaryInjectLoggerInterceptor returns a new unary server interceptors with logger injected.

func UnaryInterceptor

func UnaryInterceptor(log logger.LoggerInterface, opts ...logger_grpc.Option) grpc.UnaryServerInterceptor

UnaryInterceptor returns a new unary server interceptors that log.

Types

type StreamWithContext

type StreamWithContext struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func (*StreamWithContext) Context

func (s *StreamWithContext) Context() context.Context

type StreamWrapper

type StreamWrapper struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func NewServerStreamWrapper

func NewServerStreamWrapper(stream grpc.ServerStream, context context.Context, options *logger_grpc.Options, l logger.LoggerInterface, loggerContext logger.Context) *StreamWrapper

func (*StreamWrapper) Context

func (s *StreamWrapper) Context() context.Context

func (*StreamWrapper) RecvMsg

func (s *StreamWrapper) RecvMsg(m interface{}) error

func (*StreamWrapper) SendHeader

func (s *StreamWrapper) SendHeader(md metadata.MD) error

func (*StreamWrapper) SendMsg

func (s *StreamWrapper) SendMsg(m interface{}) error