interceptor

package
v0.0.0-...-45b1c9c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 13, 2022 License: MIT Imports: 10 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StreamInterceptor

func StreamInterceptor(opts ...Option) func(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error)

Types

type ClientStream

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

func (*ClientStream) RecvMsg

func (l *ClientStream) RecvMsg(m interface{}) error

type HeaderSpanDecorator

type HeaderSpanDecorator func(ctx context.Context, span trace.Span, header metadata.MD)

type Option

type Option func(*interceptorOption)

func WithDefaultDecorators

func WithDefaultDecorators() Option

func WithHeaderSpanDecorators

func WithHeaderSpanDecorators(decorators ...HeaderSpanDecorator) Option

func WithStatsSpanDecorators

func WithStatsSpanDecorators(decorators ...StatsSpanDecorator) Option

type StatsSpanDecorator

type StatsSpanDecorator func(ctx context.Context, span trace.Span, stats *spanner.ResultSetStats)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL