grpcext

Sep 30, 2024

Changes in this version

type InvokeRequest

+ DiscardResponseMessage bool

type StreamRequest

+ DiscardResponseMessage bool

May 13, 2024

Changes in this version

+ type InvokeRequest struct

+ Message []byte

+ Metadata metadata.MD

+ Method string

+ MethodDescriptor protoreflect.MethodDescriptor

+ TagsAndMeta *metrics.TagsAndMeta

+ Timeout time.Duration

+ type InvokeResponse struct

+ Error interface{}

+ Headers map[string][]string

+ Message interface{}

+ Status codes.Code

+ Trailers map[string][]string

type StreamRequest

+ Timeout time.Duration

Jan 29, 2024

Changes in this version

+ var ErrCanceled = errors.New("canceled by client (k6)")

type Conn

+ func (c *Conn) NewStream(ctx context.Context, req StreamRequest, opts ...grpc.CallOption) (*Stream, error)

+ type Stream struct

+ func (s *Stream) CloseSend() error

+ func (s *Stream) ReceiveConverted() (interface{}, error)

+ func (s *Stream) Send(b []byte) error

+ type StreamRequest struct

+ Metadata metadata.MD

+ Method string

+ MethodDescriptor protoreflect.MethodDescriptor

+ TagsAndMeta *metrics.TagsAndMeta

Nov 2, 2022

Changes in this version

type Request

+ TagsAndMeta *metrics.TagsAndMeta

May 4, 2022

Changes in this version

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

+ func DefaultOptions(vu modules.VU) []grpc.DialOption

+ type Conn struct

+ 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 struct

+ Message []byte

+ MethodDescriptor protoreflect.MethodDescriptor

+ Tags map[string]string

+ type Response struct

+ Error interface{}

+ Headers map[string][]string

+ Message interface{}

+ Status codes.Code

+ Trailers map[string][]string