grpcutils

Documentation

Index

• func AppendHeaders(parent context.Context, headers []string) context.Context
• func LogRequests(ctx context.Context, method string, req, reply interface{}, ...) error
• func LogStream(ctx context.Context, sd *grpc.StreamDesc, conn *grpc.ClientConn, method string, ...) (grpc.ClientStream, error)

Functions

func AppendHeaders

func AppendHeaders(parent context.Context, headers []string) context.Context

AppendHeaders parses the provided GRPC headers and attaches them to the provided context.

func LogRequests

func LogRequests(
	ctx context.Context,
	method string, req,
	reply interface{},
	cc *grpc.ClientConn,
	invoker grpc.UnaryInvoker,
	opts ...grpc.CallOption,
) error

LogRequests logs the gRPC backend as well as request duration when the log level is set to debug or higher.

func LogStream

func LogStream(
	ctx context.Context,
	sd *grpc.StreamDesc,
	conn *grpc.ClientConn,
	method string,
	streamer grpc.Streamer,
	opts ...grpc.CallOption,
) (grpc.ClientStream, error)

LogStream prints the method at DEBUG level at the start of the stream.