interceptors

Aug 21, 2023

Changes in this version

+ var AllCodes = []codes.Code

+ func StreamClientInterceptor(reportable ClientReportable) grpc.StreamClientInterceptor

+ func StreamServerInterceptor(reportable ServerReportable) grpc.StreamServerInterceptor

+ func UnaryClientInterceptor(reportable ClientReportable) grpc.UnaryClientInterceptor

+ func UnaryServerInterceptor(reportable ServerReportable) grpc.UnaryServerInterceptor

+ type CallMeta struct

+ IsClient bool

+ Method string

+ ReqOrNil any

+ Service string

+ Typ GRPCType

+ func NewClientCallMeta(fullMethod string, streamDesc *grpc.StreamDesc, reqOrNil any) CallMeta

+ func NewServerCallMeta(fullMethod string, streamInfo *grpc.StreamServerInfo, reqOrNil any) CallMeta

+ func (c CallMeta) FullMethod() string

+ type ClientReportable interface

+ ClientReporter func(context.Context, CallMeta) (Reporter, context.Context)

+ type CommonReportableFunc func(ctx context.Context, c CallMeta) (Reporter, context.Context)

+ func (f CommonReportableFunc) ClientReporter(ctx context.Context, c CallMeta) (Reporter, context.Context)

+ func (f CommonReportableFunc) ServerReporter(ctx context.Context, c CallMeta) (Reporter, context.Context)

+ type GRPCType string

+ const BidiStream

+ const ClientStream

+ const ServerStream

+ const Unary

+ type NoopReporter struct

+ func (NoopReporter) PostCall(error, time.Duration)

+ func (NoopReporter) PostMsgReceive(any, error, time.Duration)

+ func (NoopReporter) PostMsgSend(any, error, time.Duration)

+ type Reporter interface

+ PostCall func(err error, rpcDuration time.Duration)

+ PostMsgReceive func(replyProto any, err error, recvDuration time.Duration)

+ PostMsgSend func(reqProto any, err error, sendDuration time.Duration)

+ type ServerReportable interface

+ ServerReporter func(context.Context, CallMeta) (Reporter, context.Context)