loadtestpb

package
v0.0.0-...-8f338b7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 13, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthService        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterLoadTesterServer 

func RegisterLoadTesterServer(s *grpc.Server, srv LoadTesterServer)

Types

type BidirectionalStreamingReply 

type BidirectionalStreamingReply struct {
	SeqId             int64  `protobuf:"varint,1,opt,name=seq_id,json=seqId,proto3" json:"seq_id,omitempty"`
	StreamSeqIdServer int64  `protobuf:"varint,2,opt,name=stream_seq_id_server,json=streamSeqIdServer,proto3" json:"stream_seq_id_server,omitempty"`
	Payload           string `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*BidirectionalStreamingReply) Descriptor 

func (*BidirectionalStreamingReply) Descriptor() ([]byte, []int)

func (*BidirectionalStreamingReply) Equal 

func (this *BidirectionalStreamingReply) Equal(that interface{}) bool

func (*BidirectionalStreamingReply) GetPayload 

func (m *BidirectionalStreamingReply) GetPayload() string

func (*BidirectionalStreamingReply) GetSeqId 

func (m *BidirectionalStreamingReply) GetSeqId() int64

func (*BidirectionalStreamingReply) GetStreamSeqIdServer 

func (m *BidirectionalStreamingReply) GetStreamSeqIdServer() int64

func (*BidirectionalStreamingReply) GoString 

func (this *BidirectionalStreamingReply) GoString() string

func (*BidirectionalStreamingReply) Marshal 

func (m *BidirectionalStreamingReply) Marshal() (dAtA []byte, err error)

func (*BidirectionalStreamingReply) MarshalTo 

func (m *BidirectionalStreamingReply) MarshalTo(dAtA []byte) (int, error)

func (*BidirectionalStreamingReply) MarshalToSizedBuffer 

func (m *BidirectionalStreamingReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BidirectionalStreamingReply) ProtoMessage 

func (*BidirectionalStreamingReply) ProtoMessage()

func (*BidirectionalStreamingReply) Reset 

func (m *BidirectionalStreamingReply) Reset()

func (*BidirectionalStreamingReply) Size 

func (m *BidirectionalStreamingReply) Size() (n int)

func (*BidirectionalStreamingReply) String 

func (this *BidirectionalStreamingReply) String() string

func (*BidirectionalStreamingReply) Unmarshal 

func (m *BidirectionalStreamingReply) Unmarshal(dAtA []byte) error

func (*BidirectionalStreamingReply) XXX_DiscardUnknown 

func (m *BidirectionalStreamingReply) XXX_DiscardUnknown()

func (*BidirectionalStreamingReply) XXX_Marshal 

func (m *BidirectionalStreamingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BidirectionalStreamingReply) XXX_Merge 

func (m *BidirectionalStreamingReply) XXX_Merge(src proto.Message)

func (*BidirectionalStreamingReply) XXX_Size 

func (m *BidirectionalStreamingReply) XXX_Size() int

func (*BidirectionalStreamingReply) XXX_Unmarshal 

func (m *BidirectionalStreamingReply) XXX_Unmarshal(b []byte) error

type BidirectionalStreamingRequest 

type BidirectionalStreamingRequest struct {
	SeqId                     int64  `protobuf:"varint,1,opt,name=seq_id,json=seqId,proto3" json:"seq_id,omitempty"`
	StreamSeqIdClient         int64  `protobuf:"varint,2,opt,name=stream_seq_id_client,json=streamSeqIdClient,proto3" json:"stream_seq_id_client,omitempty"`
	Payload                   string `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	BytesRequestedNextMessage int32  `` /* 141-byte string literal not displayed */
}

func (*BidirectionalStreamingRequest) Descriptor 

func (*BidirectionalStreamingRequest) Descriptor() ([]byte, []int)

func (*BidirectionalStreamingRequest) Equal 

func (this *BidirectionalStreamingRequest) Equal(that interface{}) bool

func (*BidirectionalStreamingRequest) GetBytesRequestedNextMessage 

func (m *BidirectionalStreamingRequest) GetBytesRequestedNextMessage() int32

func (*BidirectionalStreamingRequest) GetPayload 

func (m *BidirectionalStreamingRequest) GetPayload() string

func (*BidirectionalStreamingRequest) GetSeqId 

func (m *BidirectionalStreamingRequest) GetSeqId() int64

func (*BidirectionalStreamingRequest) GetStreamSeqIdClient 

func (m *BidirectionalStreamingRequest) GetStreamSeqIdClient() int64

func (*BidirectionalStreamingRequest) GoString 

func (this *BidirectionalStreamingRequest) GoString() string

func (*BidirectionalStreamingRequest) Marshal 

func (m *BidirectionalStreamingRequest) Marshal() (dAtA []byte, err error)

func (*BidirectionalStreamingRequest) MarshalTo 

func (m *BidirectionalStreamingRequest) MarshalTo(dAtA []byte) (int, error)

func (*BidirectionalStreamingRequest) MarshalToSizedBuffer 

func (m *BidirectionalStreamingRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BidirectionalStreamingRequest) ProtoMessage 

func (*BidirectionalStreamingRequest) ProtoMessage()

func (*BidirectionalStreamingRequest) Reset 

func (m *BidirectionalStreamingRequest) Reset()

func (*BidirectionalStreamingRequest) Size 

func (m *BidirectionalStreamingRequest) Size() (n int)

func (*BidirectionalStreamingRequest) String 

func (this *BidirectionalStreamingRequest) String() string

func (*BidirectionalStreamingRequest) Unmarshal 

func (m *BidirectionalStreamingRequest) Unmarshal(dAtA []byte) error

func (*BidirectionalStreamingRequest) XXX_DiscardUnknown 

func (m *BidirectionalStreamingRequest) XXX_DiscardUnknown()

func (*BidirectionalStreamingRequest) XXX_Marshal 

func (m *BidirectionalStreamingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BidirectionalStreamingRequest) XXX_Merge 

func (m *BidirectionalStreamingRequest) XXX_Merge(src proto.Message)

func (*BidirectionalStreamingRequest) XXX_Size 

func (m *BidirectionalStreamingRequest) XXX_Size() int

func (*BidirectionalStreamingRequest) XXX_Unmarshal 

func (m *BidirectionalStreamingRequest) XXX_Unmarshal(b []byte) error

type ClientStreamingReply 

type ClientStreamingReply struct {
	SeqId   int64  `protobuf:"varint,1,opt,name=seq_id,json=seqId,proto3" json:"seq_id,omitempty"`
	Payload string `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*ClientStreamingReply) Descriptor 

func (*ClientStreamingReply) Descriptor() ([]byte, []int)

func (*ClientStreamingReply) Equal 

func (this *ClientStreamingReply) Equal(that interface{}) bool

func (*ClientStreamingReply) GetPayload 

func (m *ClientStreamingReply) GetPayload() string

func (*ClientStreamingReply) GetSeqId 

func (m *ClientStreamingReply) GetSeqId() int64

func (*ClientStreamingReply) GoString 

func (this *ClientStreamingReply) GoString() string

func (*ClientStreamingReply) Marshal 

func (m *ClientStreamingReply) Marshal() (dAtA []byte, err error)

func (*ClientStreamingReply) MarshalTo 

func (m *ClientStreamingReply) MarshalTo(dAtA []byte) (int, error)

func (*ClientStreamingReply) MarshalToSizedBuffer 

func (m *ClientStreamingReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStreamingReply) ProtoMessage 

func (*ClientStreamingReply) ProtoMessage()

func (*ClientStreamingReply) Reset 

func (m *ClientStreamingReply) Reset()

func (*ClientStreamingReply) Size 

func (m *ClientStreamingReply) Size() (n int)

func (*ClientStreamingReply) String 

func (this *ClientStreamingReply) String() string

func (*ClientStreamingReply) Unmarshal 

func (m *ClientStreamingReply) Unmarshal(dAtA []byte) error

func (*ClientStreamingReply) XXX_DiscardUnknown 

func (m *ClientStreamingReply) XXX_DiscardUnknown()

func (*ClientStreamingReply) XXX_Marshal 

func (m *ClientStreamingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientStreamingReply) XXX_Merge 

func (m *ClientStreamingReply) XXX_Merge(src proto.Message)

func (*ClientStreamingReply) XXX_Size 

func (m *ClientStreamingReply) XXX_Size() int

func (*ClientStreamingReply) XXX_Unmarshal 

func (m *ClientStreamingReply) XXX_Unmarshal(b []byte) error

type ClientStreamingRequest 

type ClientStreamingRequest struct {
	SeqId          int64  `protobuf:"varint,1,opt,name=seq_id,json=seqId,proto3" json:"seq_id,omitempty"`
	StreamSeqId    int64  `protobuf:"varint,2,opt,name=stream_seq_id,json=streamSeqId,proto3" json:"stream_seq_id,omitempty"`
	Payload        string `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	BytesRequested int32  `protobuf:"varint,4,opt,name=bytes_requested,json=bytesRequested,proto3" json:"bytes_requested,omitempty"`
}

func (*ClientStreamingRequest) Descriptor 

func (*ClientStreamingRequest) Descriptor() ([]byte, []int)

func (*ClientStreamingRequest) Equal 

func (this *ClientStreamingRequest) Equal(that interface{}) bool

func (*ClientStreamingRequest) GetBytesRequested 

func (m *ClientStreamingRequest) GetBytesRequested() int32

func (*ClientStreamingRequest) GetPayload 

func (m *ClientStreamingRequest) GetPayload() string

func (*ClientStreamingRequest) GetSeqId 

func (m *ClientStreamingRequest) GetSeqId() int64

func (*ClientStreamingRequest) GetStreamSeqId 

func (m *ClientStreamingRequest) GetStreamSeqId() int64

func (*ClientStreamingRequest) GoString 

func (this *ClientStreamingRequest) GoString() string

func (*ClientStreamingRequest) Marshal 

func (m *ClientStreamingRequest) Marshal() (dAtA []byte, err error)

func (*ClientStreamingRequest) MarshalTo 

func (m *ClientStreamingRequest) MarshalTo(dAtA []byte) (int, error)

func (*ClientStreamingRequest) MarshalToSizedBuffer 

func (m *ClientStreamingRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStreamingRequest) ProtoMessage 

func (*ClientStreamingRequest) ProtoMessage()

func (*ClientStreamingRequest) Reset 

func (m *ClientStreamingRequest) Reset()

func (*ClientStreamingRequest) Size 

func (m *ClientStreamingRequest) Size() (n int)

func (*ClientStreamingRequest) String 

func (this *ClientStreamingRequest) String() string

func (*ClientStreamingRequest) Unmarshal 

func (m *ClientStreamingRequest) Unmarshal(dAtA []byte) error

func (*ClientStreamingRequest) XXX_DiscardUnknown 

func (m *ClientStreamingRequest) XXX_DiscardUnknown()

func (*ClientStreamingRequest) XXX_Marshal 

func (m *ClientStreamingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientStreamingRequest) XXX_Merge 

func (m *ClientStreamingRequest) XXX_Merge(src proto.Message)

func (*ClientStreamingRequest) XXX_Size 

func (m *ClientStreamingRequest) XXX_Size() int

func (*ClientStreamingRequest) XXX_Unmarshal 

func (m *ClientStreamingRequest) XXX_Unmarshal(b []byte) error

type LoadTesterClient 

type LoadTesterClient interface {
	Unary(ctx context.Context, in *UnaryRequest, opts ...grpc.CallOption) (*UnaryReply, error)
	ClientStreaming(ctx context.Context, opts ...grpc.CallOption) (LoadTester_ClientStreamingClient, error)
	ServerStreaming(ctx context.Context, in *ServerStreamingRequest, opts ...grpc.CallOption) (LoadTester_ServerStreamingClient, error)
	BidirectionalStreaming(ctx context.Context, opts ...grpc.CallOption) (LoadTester_BidirectionalStreamingClient, error)
}

LoadTesterClient is the client API for LoadTester service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLoadTesterClient 

func NewLoadTesterClient(cc *grpc.ClientConn) LoadTesterClient

type LoadTesterServer 

type LoadTesterServer interface {
	Unary(context.Context, *UnaryRequest) (*UnaryReply, error)
	ClientStreaming(LoadTester_ClientStreamingServer) error
	ServerStreaming(*ServerStreamingRequest, LoadTester_ServerStreamingServer) error
	BidirectionalStreaming(LoadTester_BidirectionalStreamingServer) error
}

LoadTesterServer is the server API for LoadTester service.

type LoadTester_BidirectionalStreamingClient 

type LoadTester_BidirectionalStreamingClient interface {
	Send(*BidirectionalStreamingRequest) error
	Recv() (*BidirectionalStreamingReply, error)
	grpc.ClientStream
}

type LoadTester_BidirectionalStreamingServer 

type LoadTester_BidirectionalStreamingServer interface {
	Send(*BidirectionalStreamingReply) error
	Recv() (*BidirectionalStreamingRequest, error)
	grpc.ServerStream
}

type LoadTester_ClientStreamingClient 

type LoadTester_ClientStreamingClient interface {
	Send(*ClientStreamingRequest) error
	CloseAndRecv() (*ClientStreamingReply, error)
	grpc.ClientStream
}

type LoadTester_ClientStreamingServer 

type LoadTester_ClientStreamingServer interface {
	SendAndClose(*ClientStreamingReply) error
	Recv() (*ClientStreamingRequest, error)
	grpc.ServerStream
}

type LoadTester_ServerStreamingClient 

type LoadTester_ServerStreamingClient interface {
	Recv() (*ServerStreamingReply, error)
	grpc.ClientStream
}

type LoadTester_ServerStreamingServer 

type LoadTester_ServerStreamingServer interface {
	Send(*ServerStreamingReply) error
	grpc.ServerStream
}

type ServerStreamingReply 

type ServerStreamingReply struct {
	SeqId       int64  `protobuf:"varint,1,opt,name=seq_id,json=seqId,proto3" json:"seq_id,omitempty"`
	StreamSeqId int64  `protobuf:"varint,2,opt,name=stream_seq_id,json=streamSeqId,proto3" json:"stream_seq_id,omitempty"`
	Payload     string `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*ServerStreamingReply) Descriptor 

func (*ServerStreamingReply) Descriptor() ([]byte, []int)

func (*ServerStreamingReply) Equal 

func (this *ServerStreamingReply) Equal(that interface{}) bool

func (*ServerStreamingReply) GetPayload 

func (m *ServerStreamingReply) GetPayload() string

func (*ServerStreamingReply) GetSeqId 

func (m *ServerStreamingReply) GetSeqId() int64

func (*ServerStreamingReply) GetStreamSeqId 

func (m *ServerStreamingReply) GetStreamSeqId() int64

func (*ServerStreamingReply) GoString 

func (this *ServerStreamingReply) GoString() string

func (*ServerStreamingReply) Marshal 

func (m *ServerStreamingReply) Marshal() (dAtA []byte, err error)

func (*ServerStreamingReply) MarshalTo 

func (m *ServerStreamingReply) MarshalTo(dAtA []byte) (int, error)

func (*ServerStreamingReply) MarshalToSizedBuffer 

func (m *ServerStreamingReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServerStreamingReply) ProtoMessage 

func (*ServerStreamingReply) ProtoMessage()

func (*ServerStreamingReply) Reset 

func (m *ServerStreamingReply) Reset()

func (*ServerStreamingReply) Size 

func (m *ServerStreamingReply) Size() (n int)

func (*ServerStreamingReply) String 

func (this *ServerStreamingReply) String() string

func (*ServerStreamingReply) Unmarshal 

func (m *ServerStreamingReply) Unmarshal(dAtA []byte) error

func (*ServerStreamingReply) XXX_DiscardUnknown 

func (m *ServerStreamingReply) XXX_DiscardUnknown()

func (*ServerStreamingReply) XXX_Marshal 

func (m *ServerStreamingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerStreamingReply) XXX_Merge 

func (m *ServerStreamingReply) XXX_Merge(src proto.Message)

func (*ServerStreamingReply) XXX_Size 

func (m *ServerStreamingReply) XXX_Size() int

func (*ServerStreamingReply) XXX_Unmarshal 

func (m *ServerStreamingReply) XXX_Unmarshal(b []byte) error

type ServerStreamingRequest 

type ServerStreamingRequest struct {
	SeqId                    int64  `protobuf:"varint,1,opt,name=seq_id,json=seqId,proto3" json:"seq_id,omitempty"`
	Payload                  string `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	MessagesRequested        int32  `protobuf:"varint,3,opt,name=messages_requested,json=messagesRequested,proto3" json:"messages_requested,omitempty"`
	BytesRequestedPerMessage int32  `` /* 138-byte string literal not displayed */
}

func (*ServerStreamingRequest) Descriptor 

func (*ServerStreamingRequest) Descriptor() ([]byte, []int)

func (*ServerStreamingRequest) Equal 

func (this *ServerStreamingRequest) Equal(that interface{}) bool

func (*ServerStreamingRequest) GetBytesRequestedPerMessage 

func (m *ServerStreamingRequest) GetBytesRequestedPerMessage() int32

func (*ServerStreamingRequest) GetMessagesRequested 

func (m *ServerStreamingRequest) GetMessagesRequested() int32

func (*ServerStreamingRequest) GetPayload 

func (m *ServerStreamingRequest) GetPayload() string

func (*ServerStreamingRequest) GetSeqId 

func (m *ServerStreamingRequest) GetSeqId() int64

func (*ServerStreamingRequest) GoString 

func (this *ServerStreamingRequest) GoString() string

func (*ServerStreamingRequest) Marshal 

func (m *ServerStreamingRequest) Marshal() (dAtA []byte, err error)

func (*ServerStreamingRequest) MarshalTo 

func (m *ServerStreamingRequest) MarshalTo(dAtA []byte) (int, error)

func (*ServerStreamingRequest) MarshalToSizedBuffer 

func (m *ServerStreamingRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServerStreamingRequest) ProtoMessage 

func (*ServerStreamingRequest) ProtoMessage()

func (*ServerStreamingRequest) Reset 

func (m *ServerStreamingRequest) Reset()

func (*ServerStreamingRequest) Size 

func (m *ServerStreamingRequest) Size() (n int)

func (*ServerStreamingRequest) String 

func (this *ServerStreamingRequest) String() string

func (*ServerStreamingRequest) Unmarshal 

func (m *ServerStreamingRequest) Unmarshal(dAtA []byte) error

func (*ServerStreamingRequest) XXX_DiscardUnknown 

func (m *ServerStreamingRequest) XXX_DiscardUnknown()

func (*ServerStreamingRequest) XXX_Marshal 

func (m *ServerStreamingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerStreamingRequest) XXX_Merge 

func (m *ServerStreamingRequest) XXX_Merge(src proto.Message)

func (*ServerStreamingRequest) XXX_Size 

func (m *ServerStreamingRequest) XXX_Size() int

func (*ServerStreamingRequest) XXX_Unmarshal 

func (m *ServerStreamingRequest) XXX_Unmarshal(b []byte) error

type UnaryReply 

type UnaryReply struct {
	SeqId   int64  `protobuf:"varint,1,opt,name=seq_id,json=seqId,proto3" json:"seq_id,omitempty"`
	Payload string `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*UnaryReply) Descriptor 

func (*UnaryReply) Descriptor() ([]byte, []int)

func (*UnaryReply) Equal 

func (this *UnaryReply) Equal(that interface{}) bool

func (*UnaryReply) GetPayload 

func (m *UnaryReply) GetPayload() string

func (*UnaryReply) GetSeqId 

func (m *UnaryReply) GetSeqId() int64

func (*UnaryReply) GoString 

func (this *UnaryReply) GoString() string

func (*UnaryReply) Marshal 

func (m *UnaryReply) Marshal() (dAtA []byte, err error)

func (*UnaryReply) MarshalTo 

func (m *UnaryReply) MarshalTo(dAtA []byte) (int, error)

func (*UnaryReply) MarshalToSizedBuffer 

func (m *UnaryReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnaryReply) ProtoMessage 

func (*UnaryReply) ProtoMessage()

func (*UnaryReply) Reset 

func (m *UnaryReply) Reset()

func (*UnaryReply) Size 

func (m *UnaryReply) Size() (n int)

func (*UnaryReply) String 

func (this *UnaryReply) String() string

func (*UnaryReply) Unmarshal 

func (m *UnaryReply) Unmarshal(dAtA []byte) error

func (*UnaryReply) XXX_DiscardUnknown 

func (m *UnaryReply) XXX_DiscardUnknown()

func (*UnaryReply) XXX_Marshal 

func (m *UnaryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnaryReply) XXX_Merge 

func (m *UnaryReply) XXX_Merge(src proto.Message)

func (*UnaryReply) XXX_Size 

func (m *UnaryReply) XXX_Size() int

func (*UnaryReply) XXX_Unmarshal 

func (m *UnaryReply) XXX_Unmarshal(b []byte) error

type UnaryRequest 

type UnaryRequest struct {
	SeqId          int64  `protobuf:"varint,1,opt,name=seq_id,json=seqId,proto3" json:"seq_id,omitempty"`
	Payload        string `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	BytesRequested int32  `protobuf:"varint,3,opt,name=bytes_requested,json=bytesRequested,proto3" json:"bytes_requested,omitempty"`
}

func (*UnaryRequest) Descriptor 

func (*UnaryRequest) Descriptor() ([]byte, []int)

func (*UnaryRequest) Equal 

func (this *UnaryRequest) Equal(that interface{}) bool

func (*UnaryRequest) GetBytesRequested 

func (m *UnaryRequest) GetBytesRequested() int32

func (*UnaryRequest) GetPayload 

func (m *UnaryRequest) GetPayload() string

func (*UnaryRequest) GetSeqId 

func (m *UnaryRequest) GetSeqId() int64

func (*UnaryRequest) GoString 

func (this *UnaryRequest) GoString() string

func (*UnaryRequest) Marshal 

func (m *UnaryRequest) Marshal() (dAtA []byte, err error)

func (*UnaryRequest) MarshalTo 

func (m *UnaryRequest) MarshalTo(dAtA []byte) (int, error)

func (*UnaryRequest) MarshalToSizedBuffer 

func (m *UnaryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnaryRequest) ProtoMessage 

func (*UnaryRequest) ProtoMessage()

func (*UnaryRequest) Reset 

func (m *UnaryRequest) Reset()

func (*UnaryRequest) Size 

func (m *UnaryRequest) Size() (n int)

func (*UnaryRequest) String 

func (this *UnaryRequest) String() string

func (*UnaryRequest) Unmarshal 

func (m *UnaryRequest) Unmarshal(dAtA []byte) error

func (*UnaryRequest) XXX_DiscardUnknown 

func (m *UnaryRequest) XXX_DiscardUnknown()

func (*UnaryRequest) XXX_Marshal 

func (m *UnaryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnaryRequest) XXX_Merge 

func (m *UnaryRequest) XXX_Merge(src proto.Message)

func (*UnaryRequest) XXX_Size 

func (m *UnaryRequest) XXX_Size() int

func (*UnaryRequest) XXX_Unmarshal 

func (m *UnaryRequest) XXX_Unmarshal(b []byte) error

type UnimplementedLoadTesterServer 

type UnimplementedLoadTesterServer struct {
}

UnimplementedLoadTesterServer can be embedded to have forward compatible implementations.

func (*UnimplementedLoadTesterServer) BidirectionalStreaming 

func (*UnimplementedLoadTesterServer) BidirectionalStreaming(srv LoadTester_BidirectionalStreamingServer) error

func (*UnimplementedLoadTesterServer) ClientStreaming 

func (*UnimplementedLoadTesterServer) ClientStreaming(srv LoadTester_ClientStreamingServer) error

func (*UnimplementedLoadTesterServer) ServerStreaming 

func (*UnimplementedLoadTesterServer) ServerStreaming(req *ServerStreamingRequest, srv LoadTester_ServerStreamingServer) error

func (*UnimplementedLoadTesterServer) Unary 

func (*UnimplementedLoadTesterServer) Unary(ctx context.Context, req *UnaryRequest) (*UnaryReply, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.