tagging

func ContextWithIOTag ¶

func ContextWithIOTag(parent context.Context, ioTag string) context.Context

func IOTagFromContext ¶

func IOTagFromContext(ctx context.Context) (string, bool)

func NewStreamClientInterceptor ¶

func NewStreamClientInterceptor() grpc.StreamClientInterceptor

NewStreamClientInterceptor creates new gRPC stream interceptor to set an IO tag to gRPC metadata.

func NewStreamServerInterceptor ¶

func NewStreamServerInterceptor() grpc.StreamServerInterceptor

NewStreamServerInterceptor creates new gRPC stream interceptor to extract an IO tag to gRPC metadata.

func NewUnaryClientInterceptor ¶

func NewUnaryClientInterceptor() grpc.UnaryClientInterceptor

NewUnaryClientInterceptor creates new gRPC unary interceptor to set an IO tag to gRPC metadata.

func NewUnaryServerInterceptor ¶

func NewUnaryServerInterceptor() grpc.UnaryServerInterceptor

NewUnaryServerInterceptor creates new gRPC unary interceptor to extract an IO tag to gRPC metadata.