grpc_interceptor

Documentation

Index

• func NewStreamWrapper(ctx context.Context, accessLogger, errLogger log.LoggerContextIface, ...) *streamWrapper
• func StreamCtxHandleGRPC() grpc.StreamClientInterceptor
• func UnaryCtxHandleGRPC() grpc.UnaryClientInterceptor
• type AppServerInterceptor
  • func NewAppServerInterceptor(debug bool, accessLogger, errLogger log.LoggerContextIface) *AppServerInterceptor
  • func (i *AppServerInterceptor) Logger(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
  • func (i *AppServerInterceptor) Metadata(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
  • func (i *AppServerInterceptor) Recovery(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
  • func (i *AppServerInterceptor) RecoveryStream(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
  • func (i *AppServerInterceptor) StreamLogger(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
  • func (i *AppServerInterceptor) StreamMetadata(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error

Functions

func NewStreamWrapper

func NewStreamWrapper(ctx context.Context,
	accessLogger, errLogger log.LoggerContextIface,
	ss grpc.ServerStream,
	info *grpc.StreamServerInfo,
	requestMeta *rpc_helper.RequestMeta,
	debug bool) *streamWrapper

func StreamCtxHandleGRPC

func StreamCtxHandleGRPC() grpc.StreamClientInterceptor

func UnaryCtxHandleGRPC

func UnaryCtxHandleGRPC() grpc.UnaryClientInterceptor

Types

type AppServerInterceptor

type AppServerInterceptor struct {
	// contains filtered or unexported fields
}

func NewAppServerInterceptor

func NewAppServerInterceptor(debug bool, accessLogger, errLogger log.LoggerContextIface) *AppServerInterceptor

func (*AppServerInterceptor) Logger

func (i *AppServerInterceptor) Logger(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

Logger add app info in ctx.

func (*AppServerInterceptor) Metadata

func (i *AppServerInterceptor) Metadata(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

func (*AppServerInterceptor) Recovery

func (i *AppServerInterceptor) Recovery(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)

Recovery recovers GRPC panic.

func (*AppServerInterceptor) RecoveryStream

func (i *AppServerInterceptor) RecoveryStream(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

RecoveryStream is experimental function

func (*AppServerInterceptor) StreamLogger

func (i *AppServerInterceptor) StreamLogger(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

StreamLogger is experimental function

func (*AppServerInterceptor) StreamMetadata

func (i *AppServerInterceptor) StreamMetadata(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error