interceptors

Documentation

Index

• type WrappedClientStream
  • func WrapClientStream(stream grpc.ClientStream) *WrappedClientStream
  • func (w *WrappedClientStream) Context() context.Context
• type WrappedServerStream
  • func WrapServerStream(stream grpc.ServerStream) *WrappedServerStream
  • func (w *WrappedServerStream) Context() context.Context

Types

type WrappedClientStream

type WrappedClientStream struct {
	grpc.ClientStream
	// WrappedContext is the wrapper's own Context. You can assign it.
	WrappedContext context.Context
}

WrappedClientStream is a thin wrapper around grpc.ClientStream that allows modifying context.

func WrapClientStream

func WrapClientStream(stream grpc.ClientStream) *WrappedClientStream

WrapClientStream returns a ClientStream that has the ability to overwrite context.

func (*WrappedClientStream) Context

func (w *WrappedClientStream) Context() context.Context

Context returns the wrapper's WrappedContext, overwriting the nested grpc.ClientStream.Context()

type WrappedServerStream

type WrappedServerStream struct {
	grpc.ServerStream
	// WrappedContext is the wrapper's own Context. You can assign it.
	WrappedContext context.Context
}

WrappedServerStream is a thin wrapper around grpc.ServerStream that allows modifying context.

func WrapServerStream

func WrapServerStream(stream grpc.ServerStream) *WrappedServerStream

WrapServerStream returns a ServerStream that has the ability to overwrite context.

func (*WrappedServerStream) Context

func (w *WrappedServerStream) Context() context.Context

Context returns the wrapper's WrappedContext, overwriting the nested grpc.ServerStream.Context()