streams

Documentation

Index

• func NewWrappedStream(ctx context.Context, s grpc.ServerStream) grpc.ServerStream
• type TracingContext
• type WrappedStream
  • func (s *WrappedStream) Context() context.Context
  • func (w *WrappedStream) RecvMsg(m interface{}) error
  • func (w *WrappedStream) SendHeader(meta metadata.MD) error
  • func (w *WrappedStream) SendMsg(m interface{}) error
  • func (w *WrappedStream) SetHeader(meta metadata.MD) error
  • func (w *WrappedStream) SetTrailer(meta metadata.MD)

Functions

func NewWrappedStream

func NewWrappedStream(ctx context.Context, s grpc.ServerStream) grpc.ServerStream

Types

type TracingContext

type TracingContext string

const TracingContextParent TracingContext = "TracingContext"

type WrappedStream

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

func (*WrappedStream) Context

func (s *WrappedStream) Context() context.Context

func (*WrappedStream) RecvMsg

func (w *WrappedStream) RecvMsg(m interface{}) error

func (*WrappedStream) SendHeader

func (w *WrappedStream) SendHeader(meta metadata.MD) error

func (*WrappedStream) SendMsg

func (w *WrappedStream) SendMsg(m interface{}) error

func (*WrappedStream) SetHeader

func (w *WrappedStream) SetHeader(meta metadata.MD) error

func (*WrappedStream) SetTrailer

func (w *WrappedStream) SetTrailer(meta metadata.MD)