Documentation
¶
Index ¶
- func SetupLoggingInterceptors(logger *zap.Logger) (grpc.UnaryServerInterceptor, grpc.StreamServerInterceptor)
- type LoggingInterceptor
- func (i LoggingInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc
- func (i LoggingInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc
- func (i LoggingInterceptor) WrapUnary(next connect.UnaryFunc) connect.UnaryFunc
- type RandomTraceGetter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetupLoggingInterceptors ¶
func SetupLoggingInterceptors(logger *zap.Logger) (grpc.UnaryServerInterceptor, grpc.StreamServerInterceptor)
Types ¶
type LoggingInterceptor ¶
type LoggingInterceptor struct {
// contains filtered or unexported fields
}
func NewConnectLoggingInterceptor ¶
func NewConnectLoggingInterceptor(logger *zap.Logger) LoggingInterceptor
func (LoggingInterceptor) WrapStreamingClient ¶
func (i LoggingInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc
Noop
func (LoggingInterceptor) WrapStreamingHandler ¶
func (i LoggingInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc
type RandomTraceGetter ¶
type RandomTraceGetter struct{}
RandomTrace is a fallback to insert a random trace ID if none was acquired from previous header lookups
func (RandomTraceGetter) Extract ¶
func (p RandomTraceGetter) Extract(ctx context.Context, carrier propagation.TextMapCarrier) context.Context
Extract gives you a context with random TraceID and SpanID inserted if it didn't exist yet
func (RandomTraceGetter) Fields ¶
func (p RandomTraceGetter) Fields() []string
Fields returns an empty list in RandomTraceGetter
func (RandomTraceGetter) Inject ¶
func (p RandomTraceGetter) Inject(ctx context.Context, carrier propagation.TextMapCarrier)
Inject does not inject anything in RandomTraceGetter
Click to show internal directories.
Click to hide internal directories.