interceptor

Documentation

Index

• func StreamInterceptor(opts ...Option) ...
• type ClientStream
  • func (l *ClientStream) RecvMsg(m interface{}) error
• type HeaderSpanDecorator
• type Option
  • func WithDefaultDecorators() Option
  • func WithHeaderSpanDecorators(decorators ...HeaderSpanDecorator) Option
  • func WithStatsSpanDecorators(decorators ...StatsSpanDecorator) Option
• type StatsSpanDecorator

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)