grpcext

Documentation

Overview

Package grpcext allows gRPC requests collecting stats info.

Index

• func DebugStat(logger logrus.FieldLogger, stat grpcstats.RPCStats, httpDebugOption string)
• func DefaultOptions(getState func() *lib.State) []grpc.DialOption
• type Conn
  • func Dial(ctx context.Context, addr string, options ...grpc.DialOption) (*Conn, error)
  • func (c *Conn) Close() error
  • func (c *Conn) Invoke(ctx context.Context, url string, md metadata.MD, req Request, ...) (*Response, error)
  • func (c *Conn) Reflect(ctx context.Context) (*descriptorpb.FileDescriptorSet, error)
• type Request
• type Response

Functions

func DebugStat

func DebugStat(logger logrus.FieldLogger, stat grpcstats.RPCStats, httpDebugOption string)

DebugStat prints debugging information based on RPCStats.

func DefaultOptions

func DefaultOptions(getState func() *lib.State) []grpc.DialOption

DefaultOptions generates an option set with common options for requests from a VU.

Types

type Conn

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

Conn is a gRPC client connection.

func Dial

func Dial(ctx context.Context, addr string, options ...grpc.DialOption) (*Conn, error)

Dial establish a gRPC connection.

func (*Conn) Close

func (c *Conn) Close() error

Close closes the underhood connection.

func (*Conn) Invoke

func (c *Conn) Invoke(
	ctx context.Context,
	url string,
	md metadata.MD,
	req Request,
	opts ...grpc.CallOption,
) (*Response, error)

Invoke executes a unary gRPC request.

func (*Conn) Reflect

func (c *Conn) Reflect(ctx context.Context) (*descriptorpb.FileDescriptorSet, error)

Reflect returns using the reflection the FileDescriptorSet describing the service.

type Request

type Request struct {
	MethodDescriptor protoreflect.MethodDescriptor
	TagsAndMeta      *metrics.TagsAndMeta
	Message          []byte
}

Request represents a gRPC request.

type Response

type Response struct {
	Message  interface{}
	Error    interface{}
	Headers  map[string][]string
	Trailers map[string][]string
	Status   codes.Code
}

Response represents a gRPC response.