grpc_testing

Nov 17, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 12, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 11, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 2, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 8, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 11, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 6, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ var File_benchmark_grpc_testing_control_proto protoreflect.FileDescriptor

+ var File_benchmark_grpc_testing_messages_proto protoreflect.FileDescriptor

+ var File_benchmark_grpc_testing_payloads_proto protoreflect.FileDescriptor

+ var File_benchmark_grpc_testing_services_proto protoreflect.FileDescriptor

+ var File_benchmark_grpc_testing_stats_proto protoreflect.FileDescriptor

type ByteBufferParams

+ func (x *ByteBufferParams) ProtoReflect() protoreflect.Message

type ClientArgs

+ func (x *ClientArgs) ProtoReflect() protoreflect.Message

type ClientConfig

+ func (x *ClientConfig) ProtoReflect() protoreflect.Message

type ClientStats

+ func (x *ClientStats) ProtoReflect() protoreflect.Message

type ClientStatus

+ func (x *ClientStatus) ProtoReflect() protoreflect.Message

type ClientType

+ func (ClientType) Descriptor() protoreflect.EnumDescriptor

+ func (ClientType) Type() protoreflect.EnumType

+ func (x ClientType) Enum() *ClientType

+ func (x ClientType) Number() protoreflect.EnumNumber

type ClosedLoopParams

+ func (x *ClosedLoopParams) ProtoReflect() protoreflect.Message

type ComplexProtoParams

+ func (x *ComplexProtoParams) ProtoReflect() protoreflect.Message

type CompressionType

+ func (CompressionType) Descriptor() protoreflect.EnumDescriptor

+ func (CompressionType) Type() protoreflect.EnumType

+ func (x CompressionType) Enum() *CompressionType

+ func (x CompressionType) Number() protoreflect.EnumNumber

type CoreRequest

+ func (x *CoreRequest) ProtoReflect() protoreflect.Message

type CoreResponse

+ func (x *CoreResponse) ProtoReflect() protoreflect.Message

type DeterministicParams

+ func (x *DeterministicParams) ProtoReflect() protoreflect.Message

type EchoStatus

+ func (x *EchoStatus) ProtoReflect() protoreflect.Message

type HistogramData

+ func (x *HistogramData) ProtoReflect() protoreflect.Message

type HistogramParams

+ func (x *HistogramParams) ProtoReflect() protoreflect.Message

type LoadParams

+ func (x *LoadParams) ProtoReflect() protoreflect.Message

type Mark

+ func (x *Mark) ProtoReflect() protoreflect.Message

type ParetoParams

+ func (x *ParetoParams) ProtoReflect() protoreflect.Message

type Payload

+ func (x *Payload) ProtoReflect() protoreflect.Message

type PayloadConfig

+ func (x *PayloadConfig) ProtoReflect() protoreflect.Message

type PayloadType

+ func (PayloadType) Descriptor() protoreflect.EnumDescriptor

+ func (PayloadType) Type() protoreflect.EnumType

+ func (x PayloadType) Enum() *PayloadType

+ func (x PayloadType) Number() protoreflect.EnumNumber

type PoissonParams

+ func (x *PoissonParams) ProtoReflect() protoreflect.Message

type ReconnectInfo

+ func (x *ReconnectInfo) ProtoReflect() protoreflect.Message

type ReconnectParams

+ func (x *ReconnectParams) ProtoReflect() protoreflect.Message

type ResponseParameters

+ func (x *ResponseParameters) ProtoReflect() protoreflect.Message

type RpcType

+ func (RpcType) Descriptor() protoreflect.EnumDescriptor

+ func (RpcType) Type() protoreflect.EnumType

+ func (x RpcType) Enum() *RpcType

+ func (x RpcType) Number() protoreflect.EnumNumber

type Scenario

+ func (x *Scenario) ProtoReflect() protoreflect.Message

type Scenarios

+ func (x *Scenarios) ProtoReflect() protoreflect.Message

type SecurityParams

+ func (x *SecurityParams) ProtoReflect() protoreflect.Message

type ServerArgs

+ func (x *ServerArgs) ProtoReflect() protoreflect.Message

type ServerConfig

+ func (x *ServerConfig) ProtoReflect() protoreflect.Message

type ServerStats

+ func (x *ServerStats) ProtoReflect() protoreflect.Message

type ServerStatus

+ func (x *ServerStatus) ProtoReflect() protoreflect.Message

type ServerType

+ func (ServerType) Descriptor() protoreflect.EnumDescriptor

+ func (ServerType) Type() protoreflect.EnumType

+ func (x ServerType) Enum() *ServerType

+ func (x ServerType) Number() protoreflect.EnumNumber

type SimpleProtoParams

+ func (x *SimpleProtoParams) ProtoReflect() protoreflect.Message

type SimpleRequest

+ func (x *SimpleRequest) ProtoReflect() protoreflect.Message

type SimpleResponse

+ func (x *SimpleResponse) ProtoReflect() protoreflect.Message

type StreamingInputCallRequest

+ func (x *StreamingInputCallRequest) ProtoReflect() protoreflect.Message

type StreamingInputCallResponse

+ func (x *StreamingInputCallResponse) ProtoReflect() protoreflect.Message

type StreamingOutputCallRequest

+ func (x *StreamingOutputCallRequest) ProtoReflect() protoreflect.Message

type StreamingOutputCallResponse

+ func (x *StreamingOutputCallResponse) ProtoReflect() protoreflect.Message

type UniformParams

+ func (x *UniformParams) ProtoReflect() protoreflect.Message

type Void

+ func (x *Void) ProtoReflect() protoreflect.Message

Oct 20, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 8, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ type UnsafeBenchmarkServiceServer interface

+ type UnsafeWorkerServiceServer interface

Aug 25, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Sep 8, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ func RegisterBenchmarkServiceService(s grpc.ServiceRegistrar, srv *BenchmarkServiceService)

+ func RegisterWorkerServiceService(s grpc.ServiceRegistrar, srv *WorkerServiceService)

+ type BenchmarkServiceService struct

+ StreamingCall func(BenchmarkService_StreamingCallServer) error

+ UnaryCall func(context.Context, *SimpleRequest) (*SimpleResponse, error)

+ UnconstrainedStreamingCall func(BenchmarkService_UnconstrainedStreamingCallServer) error

+ func NewBenchmarkServiceService(s interface{}) *BenchmarkServiceService

+ type UnstableBenchmarkServiceService interface

+ StreamingCall func(BenchmarkService_StreamingCallServer) error

+ UnaryCall func(context.Context, *SimpleRequest) (*SimpleResponse, error)

+ UnconstrainedStreamingCall func(BenchmarkService_UnconstrainedStreamingCallServer) error

+ type UnstableWorkerServiceService interface

+ CoreCount func(context.Context, *CoreRequest) (*CoreResponse, error)

+ QuitWorker func(context.Context, *Void) (*Void, error)

+ RunClient func(WorkerService_RunClientServer) error

+ RunServer func(WorkerService_RunServerServer) error

+ type WorkerServiceService struct

+ CoreCount func(context.Context, *CoreRequest) (*CoreResponse, error)

+ QuitWorker func(context.Context, *Void) (*Void, error)

+ RunClient func(WorkerService_RunClientServer) error

+ RunServer func(WorkerService_RunServerServer) error

+ func NewWorkerServiceService(s interface{}) *WorkerServiceService

Jul 23, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 25, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 30, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 11, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 25, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 22, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 21, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 8, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 23, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 21, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 5, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 6, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 10, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 28, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Feb 5, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 28, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 17, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 17, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 8, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 5, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Sep 25, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

type ClientArgs

+ func (*ClientArgs) XXX_OneofWrappers() []interface{}

type LoadParams

+ func (*LoadParams) XXX_OneofWrappers() []interface{}

type PayloadConfig

+ func (*PayloadConfig) XXX_OneofWrappers() []interface{}

type ServerArgs

+ func (*ServerArgs) XXX_OneofWrappers() []interface{}

+ type UnimplementedBenchmarkServiceServer struct

+ func (*UnimplementedBenchmarkServiceServer) StreamingCall(srv BenchmarkService_StreamingCallServer) error

+ func (*UnimplementedBenchmarkServiceServer) UnaryCall(ctx context.Context, req *SimpleRequest) (*SimpleResponse, error)

+ func (*UnimplementedBenchmarkServiceServer) UnconstrainedStreamingCall(srv BenchmarkService_UnconstrainedStreamingCallServer) error

+ type UnimplementedWorkerServiceServer struct

+ func (*UnimplementedWorkerServiceServer) CoreCount(ctx context.Context, req *CoreRequest) (*CoreResponse, error)

+ func (*UnimplementedWorkerServiceServer) QuitWorker(ctx context.Context, req *Void) (*Void, error)

+ func (*UnimplementedWorkerServiceServer) RunClient(srv WorkerService_RunClientServer) error

+ func (*UnimplementedWorkerServiceServer) RunServer(srv WorkerService_RunServerServer) error

Sep 11, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 13, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Sep 11, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 13, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 25, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 2, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Sep 17, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 13, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 25, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 4, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

May 22, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 18, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 9, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 20, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Feb 26, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 20, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 15, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

type BenchmarkServiceClient

+ UnconstrainedStreamingCall func(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_UnconstrainedStreamingCallClient, error)

type BenchmarkServiceServer

+ UnconstrainedStreamingCall func(BenchmarkService_UnconstrainedStreamingCallServer) error

+ type BenchmarkService_UnconstrainedStreamingCallClient interface

+ Recv func() (*SimpleResponse, error)

+ Send func(*SimpleRequest) error

+ type BenchmarkService_UnconstrainedStreamingCallServer interface

+ Recv func() (*SimpleRequest, error)

+ Send func(*SimpleResponse) error

Dec 4, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 23, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Sep 11, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 31, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 19, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 7, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 6, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

May 8, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

type ByteBufferParams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ByteBufferParams) XXX_Merge(src proto.Message)

+ func (m *ByteBufferParams) XXX_DiscardUnknown()

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

+ func (m *ByteBufferParams) XXX_Size() int

+ func (m *ByteBufferParams) XXX_Unmarshal(b []byte) error

type ClientArgs

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ClientArgs) XXX_Merge(src proto.Message)

+ func (m *ClientArgs) XXX_DiscardUnknown()

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

+ func (m *ClientArgs) XXX_Size() int

+ func (m *ClientArgs) XXX_Unmarshal(b []byte) error

type ClientConfig

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ClientConfig) XXX_Merge(src proto.Message)

+ func (m *ClientConfig) XXX_DiscardUnknown()

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

+ func (m *ClientConfig) XXX_Size() int

+ func (m *ClientConfig) XXX_Unmarshal(b []byte) error

type ClientStats

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ClientStats) XXX_Merge(src proto.Message)

+ func (m *ClientStats) XXX_DiscardUnknown()

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

+ func (m *ClientStats) XXX_Size() int

+ func (m *ClientStats) XXX_Unmarshal(b []byte) error

type ClientStatus

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ClientStatus) XXX_Merge(src proto.Message)

+ func (m *ClientStatus) XXX_DiscardUnknown()

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

+ func (m *ClientStatus) XXX_Size() int

+ func (m *ClientStatus) XXX_Unmarshal(b []byte) error

type ClosedLoopParams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ClosedLoopParams) XXX_Merge(src proto.Message)

+ func (m *ClosedLoopParams) XXX_DiscardUnknown()

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

+ func (m *ClosedLoopParams) XXX_Size() int

+ func (m *ClosedLoopParams) XXX_Unmarshal(b []byte) error

type ComplexProtoParams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ComplexProtoParams) XXX_Merge(src proto.Message)

+ func (m *ComplexProtoParams) XXX_DiscardUnknown()

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

+ func (m *ComplexProtoParams) XXX_Size() int

+ func (m *ComplexProtoParams) XXX_Unmarshal(b []byte) error

type CoreRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *CoreRequest) XXX_Merge(src proto.Message)

+ func (m *CoreRequest) XXX_DiscardUnknown()

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

+ func (m *CoreRequest) XXX_Size() int

+ func (m *CoreRequest) XXX_Unmarshal(b []byte) error

type CoreResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *CoreResponse) XXX_Merge(src proto.Message)

+ func (m *CoreResponse) XXX_DiscardUnknown()

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

+ func (m *CoreResponse) XXX_Size() int

+ func (m *CoreResponse) XXX_Unmarshal(b []byte) error

type DeterministicParams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *DeterministicParams) XXX_Merge(src proto.Message)

+ func (m *DeterministicParams) XXX_DiscardUnknown()

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

+ func (m *DeterministicParams) XXX_Size() int

+ func (m *DeterministicParams) XXX_Unmarshal(b []byte) error

type EchoStatus

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *EchoStatus) XXX_Merge(src proto.Message)

+ func (m *EchoStatus) XXX_DiscardUnknown()

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

+ func (m *EchoStatus) XXX_Size() int

+ func (m *EchoStatus) XXX_Unmarshal(b []byte) error

type HistogramData

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *HistogramData) XXX_Merge(src proto.Message)

+ func (m *HistogramData) XXX_DiscardUnknown()

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

+ func (m *HistogramData) XXX_Size() int

+ func (m *HistogramData) XXX_Unmarshal(b []byte) error

type HistogramParams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *HistogramParams) XXX_Merge(src proto.Message)

+ func (m *HistogramParams) XXX_DiscardUnknown()

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

+ func (m *HistogramParams) XXX_Size() int

+ func (m *HistogramParams) XXX_Unmarshal(b []byte) error

type LoadParams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *LoadParams) XXX_Merge(src proto.Message)

+ func (m *LoadParams) XXX_DiscardUnknown()

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

+ func (m *LoadParams) XXX_Size() int

+ func (m *LoadParams) XXX_Unmarshal(b []byte) error

type Mark

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *Mark) XXX_Merge(src proto.Message)

+ func (m *Mark) XXX_DiscardUnknown()

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

+ func (m *Mark) XXX_Size() int

+ func (m *Mark) XXX_Unmarshal(b []byte) error

type ParetoParams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ParetoParams) XXX_Merge(src proto.Message)

+ func (m *ParetoParams) XXX_DiscardUnknown()

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

+ func (m *ParetoParams) XXX_Size() int

+ func (m *ParetoParams) XXX_Unmarshal(b []byte) error

type Payload

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *Payload) XXX_Merge(src proto.Message)

+ func (m *Payload) XXX_DiscardUnknown()

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

+ func (m *Payload) XXX_Size() int

+ func (m *Payload) XXX_Unmarshal(b []byte) error

type PayloadConfig

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *PayloadConfig) XXX_Merge(src proto.Message)

+ func (m *PayloadConfig) XXX_DiscardUnknown()

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

+ func (m *PayloadConfig) XXX_Size() int

+ func (m *PayloadConfig) XXX_Unmarshal(b []byte) error

type PoissonParams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *PoissonParams) XXX_Merge(src proto.Message)

+ func (m *PoissonParams) XXX_DiscardUnknown()

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

+ func (m *PoissonParams) XXX_Size() int

+ func (m *PoissonParams) XXX_Unmarshal(b []byte) error

type ReconnectInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ReconnectInfo) XXX_Merge(src proto.Message)

+ func (m *ReconnectInfo) XXX_DiscardUnknown()

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

+ func (m *ReconnectInfo) XXX_Size() int

+ func (m *ReconnectInfo) XXX_Unmarshal(b []byte) error

type ReconnectParams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ReconnectParams) XXX_Merge(src proto.Message)

+ func (m *ReconnectParams) XXX_DiscardUnknown()

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

+ func (m *ReconnectParams) XXX_Size() int

+ func (m *ReconnectParams) XXX_Unmarshal(b []byte) error

type ResponseParameters

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ResponseParameters) XXX_Merge(src proto.Message)

+ func (m *ResponseParameters) XXX_DiscardUnknown()

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

+ func (m *ResponseParameters) XXX_Size() int

+ func (m *ResponseParameters) XXX_Unmarshal(b []byte) error

type Scenario

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *Scenario) XXX_Merge(src proto.Message)

+ func (m *Scenario) XXX_DiscardUnknown()

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

+ func (m *Scenario) XXX_Size() int

+ func (m *Scenario) XXX_Unmarshal(b []byte) error

type Scenarios

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *Scenarios) XXX_Merge(src proto.Message)

+ func (m *Scenarios) XXX_DiscardUnknown()

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

+ func (m *Scenarios) XXX_Size() int

+ func (m *Scenarios) XXX_Unmarshal(b []byte) error

type SecurityParams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *SecurityParams) XXX_Merge(src proto.Message)

+ func (m *SecurityParams) XXX_DiscardUnknown()

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

+ func (m *SecurityParams) XXX_Size() int

+ func (m *SecurityParams) XXX_Unmarshal(b []byte) error

type ServerArgs

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ServerArgs) XXX_Merge(src proto.Message)

+ func (m *ServerArgs) XXX_DiscardUnknown()

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

+ func (m *ServerArgs) XXX_Size() int

+ func (m *ServerArgs) XXX_Unmarshal(b []byte) error

type ServerConfig

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ServerConfig) XXX_Merge(src proto.Message)

+ func (m *ServerConfig) XXX_DiscardUnknown()

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

+ func (m *ServerConfig) XXX_Size() int

+ func (m *ServerConfig) XXX_Unmarshal(b []byte) error

type ServerStats

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ServerStats) XXX_Merge(src proto.Message)

+ func (m *ServerStats) XXX_DiscardUnknown()

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

+ func (m *ServerStats) XXX_Size() int

+ func (m *ServerStats) XXX_Unmarshal(b []byte) error

type ServerStatus

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ServerStatus) XXX_Merge(src proto.Message)

+ func (m *ServerStatus) XXX_DiscardUnknown()

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

+ func (m *ServerStatus) XXX_Size() int

+ func (m *ServerStatus) XXX_Unmarshal(b []byte) error

type SimpleProtoParams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *SimpleProtoParams) XXX_Merge(src proto.Message)

+ func (m *SimpleProtoParams) XXX_DiscardUnknown()

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

+ func (m *SimpleProtoParams) XXX_Size() int

+ func (m *SimpleProtoParams) XXX_Unmarshal(b []byte) error

type SimpleRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *SimpleRequest) XXX_Merge(src proto.Message)

+ func (m *SimpleRequest) XXX_DiscardUnknown()

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

+ func (m *SimpleRequest) XXX_Size() int

+ func (m *SimpleRequest) XXX_Unmarshal(b []byte) error

type SimpleResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *SimpleResponse) XXX_Merge(src proto.Message)

+ func (m *SimpleResponse) XXX_DiscardUnknown()

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

+ func (m *SimpleResponse) XXX_Size() int

+ func (m *SimpleResponse) XXX_Unmarshal(b []byte) error

type StreamingInputCallRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *StreamingInputCallRequest) XXX_Merge(src proto.Message)

+ func (m *StreamingInputCallRequest) XXX_DiscardUnknown()

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

+ func (m *StreamingInputCallRequest) XXX_Size() int

+ func (m *StreamingInputCallRequest) XXX_Unmarshal(b []byte) error

type StreamingInputCallResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *StreamingInputCallResponse) XXX_Merge(src proto.Message)

+ func (m *StreamingInputCallResponse) XXX_DiscardUnknown()

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

+ func (m *StreamingInputCallResponse) XXX_Size() int

+ func (m *StreamingInputCallResponse) XXX_Unmarshal(b []byte) error

type StreamingOutputCallRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *StreamingOutputCallRequest) XXX_Merge(src proto.Message)

+ func (m *StreamingOutputCallRequest) XXX_DiscardUnknown()

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

+ func (m *StreamingOutputCallRequest) XXX_Size() int

+ func (m *StreamingOutputCallRequest) XXX_Unmarshal(b []byte) error

type StreamingOutputCallResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *StreamingOutputCallResponse) XXX_Merge(src proto.Message)

+ func (m *StreamingOutputCallResponse) XXX_DiscardUnknown()

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

+ func (m *StreamingOutputCallResponse) XXX_Size() int

+ func (m *StreamingOutputCallResponse) XXX_Unmarshal(b []byte) error

type UniformParams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *UniformParams) XXX_Merge(src proto.Message)

+ func (m *UniformParams) XXX_DiscardUnknown()

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

+ func (m *UniformParams) XXX_Size() int

+ func (m *UniformParams) XXX_Unmarshal(b []byte) error

type Void

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *Void) XXX_Merge(src proto.Message)

+ func (m *Void) XXX_DiscardUnknown()

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

+ func (m *Void) XXX_Size() int

+ func (m *Void) XXX_Unmarshal(b []byte) error

Apr 9, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 4, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 29, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 27, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 28, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Feb 14, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 19, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 8, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 2, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 13, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 21, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 18, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 4, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 14, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 3, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 25, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 11, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 30, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

type ByteBufferParams

+ func (m *ByteBufferParams) GetReqSize() int32

+ func (m *ByteBufferParams) GetRespSize() int32

type ClientConfig

+ func (m *ClientConfig) GetAsyncClientThreads() int32

+ func (m *ClientConfig) GetClientChannels() int32

+ func (m *ClientConfig) GetClientType() ClientType

+ func (m *ClientConfig) GetCoreLimit() int32

+ func (m *ClientConfig) GetCoreList() []int32

+ func (m *ClientConfig) GetOutstandingRpcsPerChannel() int32

+ func (m *ClientConfig) GetRpcType() RpcType

+ func (m *ClientConfig) GetServerTargets() []string

type ClientStats

+ func (m *ClientStats) GetTimeElapsed() float64

+ func (m *ClientStats) GetTimeSystem() float64

+ func (m *ClientStats) GetTimeUser() float64

type CoreResponse

+ func (m *CoreResponse) GetCores() int32

type DeterministicParams

+ func (m *DeterministicParams) GetOfferedLoad() float64

type EchoStatus

+ func (m *EchoStatus) GetCode() int32

+ func (m *EchoStatus) GetMessage() string

type HistogramData

+ func (m *HistogramData) GetBucket() []uint32

+ func (m *HistogramData) GetCount() float64

+ func (m *HistogramData) GetMaxSeen() float64

+ func (m *HistogramData) GetMinSeen() float64

+ func (m *HistogramData) GetSum() float64

+ func (m *HistogramData) GetSumOfSquares() float64

type HistogramParams

+ func (m *HistogramParams) GetMaxPossible() float64

+ func (m *HistogramParams) GetResolution() float64

type Mark

+ func (m *Mark) GetReset_() bool

type ParetoParams

+ func (m *ParetoParams) GetAlpha() float64

+ func (m *ParetoParams) GetInterarrivalBase() float64

type Payload

+ func (m *Payload) GetBody() []byte

+ func (m *Payload) GetType() PayloadType

type PoissonParams

+ func (m *PoissonParams) GetOfferedLoad() float64

type ReconnectInfo

+ func (m *ReconnectInfo) GetBackoffMs() []int32

+ func (m *ReconnectInfo) GetPassed() bool

type ReconnectParams

+ func (m *ReconnectParams) GetMaxReconnectBackoffMs() int32

type ResponseParameters

+ func (m *ResponseParameters) GetIntervalUs() int32

+ func (m *ResponseParameters) GetSize() int32

type Scenario

+ func (m *Scenario) GetBenchmarkSeconds() int32

+ func (m *Scenario) GetName() string

+ func (m *Scenario) GetNumClients() int32

+ func (m *Scenario) GetNumServers() int32

+ func (m *Scenario) GetSpawnLocalWorkerCount() int32

+ func (m *Scenario) GetWarmupSeconds() int32

type SecurityParams

+ func (m *SecurityParams) GetServerHostOverride() string

+ func (m *SecurityParams) GetUseTestCa() bool

type ServerConfig

+ func (m *ServerConfig) GetAsyncServerThreads() int32

+ func (m *ServerConfig) GetCoreLimit() int32

+ func (m *ServerConfig) GetCoreList() []int32

+ func (m *ServerConfig) GetPort() int32

+ func (m *ServerConfig) GetServerType() ServerType

type ServerStats

+ func (m *ServerStats) GetTimeElapsed() float64

+ func (m *ServerStats) GetTimeSystem() float64

+ func (m *ServerStats) GetTimeUser() float64

type ServerStatus

+ func (m *ServerStatus) GetCores() int32

+ func (m *ServerStatus) GetPort() int32

type SimpleProtoParams

+ func (m *SimpleProtoParams) GetReqSize() int32

+ func (m *SimpleProtoParams) GetRespSize() int32

type SimpleRequest

+ func (m *SimpleRequest) GetFillOauthScope() bool

+ func (m *SimpleRequest) GetFillUsername() bool

+ func (m *SimpleRequest) GetResponseCompression() CompressionType

+ func (m *SimpleRequest) GetResponseSize() int32

+ func (m *SimpleRequest) GetResponseType() PayloadType

type SimpleResponse

+ func (m *SimpleResponse) GetOauthScope() string

+ func (m *SimpleResponse) GetUsername() string

type StreamingInputCallResponse

+ func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32

type StreamingOutputCallRequest

+ func (m *StreamingOutputCallRequest) GetResponseCompression() CompressionType

+ func (m *StreamingOutputCallRequest) GetResponseType() PayloadType

type UniformParams

+ func (m *UniformParams) GetInterarrivalHi() float64

+ func (m *UniformParams) GetInterarrivalLo() float64

Aug 14, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 27, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 19, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 22, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 14, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 7, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 28, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 7, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 14, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 2, 2016 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 3, 2016 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 17, 2016 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 3, 2016 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 19, 2016 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 11, 2016 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ var ClientType_name = map[int32]string

+ var ClientType_value = map[string]int32

+ var CompressionType_name = map[int32]string

+ var CompressionType_value = map[string]int32

+ var PayloadType_name = map[int32]string

+ var PayloadType_value = map[string]int32

+ var RpcType_name = map[int32]string

+ var RpcType_value = map[string]int32

+ var ServerType_name = map[int32]string

+ var ServerType_value = map[string]int32

+ func RegisterBenchmarkServiceServer(s *grpc.Server, srv BenchmarkServiceServer)

+ func RegisterWorkerServiceServer(s *grpc.Server, srv WorkerServiceServer)

+ type BenchmarkServiceClient interface

+ StreamingCall func(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_StreamingCallClient, error)

+ UnaryCall func(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error)

+ func NewBenchmarkServiceClient(cc *grpc.ClientConn) BenchmarkServiceClient

+ type BenchmarkServiceServer interface

+ StreamingCall func(BenchmarkService_StreamingCallServer) error

+ UnaryCall func(context.Context, *SimpleRequest) (*SimpleResponse, error)

+ type BenchmarkService_StreamingCallClient interface

+ Recv func() (*SimpleResponse, error)

+ Send func(*SimpleRequest) error

+ type BenchmarkService_StreamingCallServer interface

+ Recv func() (*SimpleRequest, error)

+ Send func(*SimpleResponse) error

+ type ByteBufferParams struct

+ ReqSize int32

+ RespSize int32

+ func (*ByteBufferParams) Descriptor() ([]byte, []int)

+ func (*ByteBufferParams) ProtoMessage()

+ func (m *ByteBufferParams) Reset()

+ func (m *ByteBufferParams) String() string

+ type ClientArgs struct

+ Argtype isClientArgs_Argtype

+ func (*ClientArgs) Descriptor() ([]byte, []int)

+ func (*ClientArgs) ProtoMessage()

+ func (*ClientArgs) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *ClientArgs) GetArgtype() isClientArgs_Argtype

+ func (m *ClientArgs) GetMark() *Mark

+ func (m *ClientArgs) GetSetup() *ClientConfig

+ func (m *ClientArgs) Reset()

+ func (m *ClientArgs) String() string

+ type ClientArgs_Mark struct

+ Mark *Mark

+ type ClientArgs_Setup struct

+ Setup *ClientConfig

+ type ClientConfig struct

+ AsyncClientThreads int32

+ ClientChannels int32

+ ClientType ClientType

+ CoreLimit int32

+ CoreList []int32

+ HistogramParams *HistogramParams

+ LoadParams *LoadParams

+ OutstandingRpcsPerChannel int32

+ PayloadConfig *PayloadConfig

+ RpcType RpcType

+ SecurityParams *SecurityParams

+ ServerTargets []string

+ func (*ClientConfig) Descriptor() ([]byte, []int)

+ func (*ClientConfig) ProtoMessage()

+ func (m *ClientConfig) GetHistogramParams() *HistogramParams

+ func (m *ClientConfig) GetLoadParams() *LoadParams

+ func (m *ClientConfig) GetPayloadConfig() *PayloadConfig

+ func (m *ClientConfig) GetSecurityParams() *SecurityParams

+ func (m *ClientConfig) Reset()

+ func (m *ClientConfig) String() string

+ type ClientStats struct

+ Latencies *HistogramData

+ TimeElapsed float64

+ TimeSystem float64

+ TimeUser float64

+ func (*ClientStats) Descriptor() ([]byte, []int)

+ func (*ClientStats) ProtoMessage()

+ func (m *ClientStats) GetLatencies() *HistogramData

+ func (m *ClientStats) Reset()

+ func (m *ClientStats) String() string

+ type ClientStatus struct

+ Stats *ClientStats

+ func (*ClientStatus) Descriptor() ([]byte, []int)

+ func (*ClientStatus) ProtoMessage()

+ func (m *ClientStatus) GetStats() *ClientStats

+ func (m *ClientStatus) Reset()

+ func (m *ClientStatus) String() string

+ type ClientType int32

+ const ClientType_ASYNC_CLIENT

+ const ClientType_SYNC_CLIENT

+ func (ClientType) EnumDescriptor() ([]byte, []int)

+ func (x ClientType) String() string

+ type ClosedLoopParams struct

+ func (*ClosedLoopParams) Descriptor() ([]byte, []int)

+ func (*ClosedLoopParams) ProtoMessage()

+ func (m *ClosedLoopParams) Reset()

+ func (m *ClosedLoopParams) String() string

+ type ComplexProtoParams struct

+ func (*ComplexProtoParams) Descriptor() ([]byte, []int)

+ func (*ComplexProtoParams) ProtoMessage()

+ func (m *ComplexProtoParams) Reset()

+ func (m *ComplexProtoParams) String() string

+ type CompressionType int32

+ const CompressionType_DEFLATE

+ const CompressionType_GZIP

+ const CompressionType_NONE

+ func (CompressionType) EnumDescriptor() ([]byte, []int)

+ func (x CompressionType) String() string

+ type CoreRequest struct

+ func (*CoreRequest) Descriptor() ([]byte, []int)

+ func (*CoreRequest) ProtoMessage()

+ func (m *CoreRequest) Reset()

+ func (m *CoreRequest) String() string

+ type CoreResponse struct

+ Cores int32

+ func (*CoreResponse) Descriptor() ([]byte, []int)

+ func (*CoreResponse) ProtoMessage()

+ func (m *CoreResponse) Reset()

+ func (m *CoreResponse) String() string

+ type DeterministicParams struct

+ OfferedLoad float64

+ func (*DeterministicParams) Descriptor() ([]byte, []int)

+ func (*DeterministicParams) ProtoMessage()

+ func (m *DeterministicParams) Reset()

+ func (m *DeterministicParams) String() string

+ type EchoStatus struct

+ Code int32

+ Message string

+ func (*EchoStatus) Descriptor() ([]byte, []int)

+ func (*EchoStatus) ProtoMessage()

+ func (m *EchoStatus) Reset()

+ func (m *EchoStatus) String() string

+ type HistogramData struct

+ Bucket []uint32

+ Count float64

+ MaxSeen float64

+ MinSeen float64

+ Sum float64

+ SumOfSquares float64

+ func (*HistogramData) Descriptor() ([]byte, []int)

+ func (*HistogramData) ProtoMessage()

+ func (m *HistogramData) Reset()

+ func (m *HistogramData) String() string

+ type HistogramParams struct

+ MaxPossible float64

+ Resolution float64

+ func (*HistogramParams) Descriptor() ([]byte, []int)

+ func (*HistogramParams) ProtoMessage()

+ func (m *HistogramParams) Reset()

+ func (m *HistogramParams) String() string

+ type LoadParams struct

+ Load isLoadParams_Load

+ func (*LoadParams) Descriptor() ([]byte, []int)

+ func (*LoadParams) ProtoMessage()

+ func (*LoadParams) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *LoadParams) GetClosedLoop() *ClosedLoopParams

+ func (m *LoadParams) GetDeterm() *DeterministicParams

+ func (m *LoadParams) GetLoad() isLoadParams_Load

+ func (m *LoadParams) GetPareto() *ParetoParams

+ func (m *LoadParams) GetPoisson() *PoissonParams

+ func (m *LoadParams) GetUniform() *UniformParams

+ func (m *LoadParams) Reset()

+ func (m *LoadParams) String() string

+ type LoadParams_ClosedLoop struct

+ ClosedLoop *ClosedLoopParams

+ type LoadParams_Determ struct

+ Determ *DeterministicParams

+ type LoadParams_Pareto struct

+ Pareto *ParetoParams

+ type LoadParams_Poisson struct

+ Poisson *PoissonParams

+ type LoadParams_Uniform struct

+ Uniform *UniformParams

+ type Mark struct

+ Reset_ bool

+ func (*Mark) Descriptor() ([]byte, []int)

+ func (*Mark) ProtoMessage()

+ func (m *Mark) Reset()

+ func (m *Mark) String() string

+ type ParetoParams struct

+ Alpha float64

+ InterarrivalBase float64

+ func (*ParetoParams) Descriptor() ([]byte, []int)

+ func (*ParetoParams) ProtoMessage()

+ func (m *ParetoParams) Reset()

+ func (m *ParetoParams) String() string

+ type Payload struct

+ Body []byte

+ Type PayloadType

+ func (*Payload) Descriptor() ([]byte, []int)

+ func (*Payload) ProtoMessage()

+ func (m *Payload) Reset()

+ func (m *Payload) String() string

+ type PayloadConfig struct

+ Payload isPayloadConfig_Payload

+ func (*PayloadConfig) Descriptor() ([]byte, []int)

+ func (*PayloadConfig) ProtoMessage()

+ func (*PayloadConfig) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *PayloadConfig) GetBytebufParams() *ByteBufferParams

+ func (m *PayloadConfig) GetComplexParams() *ComplexProtoParams

+ func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload

+ func (m *PayloadConfig) GetSimpleParams() *SimpleProtoParams

+ func (m *PayloadConfig) Reset()

+ func (m *PayloadConfig) String() string

+ type PayloadConfig_BytebufParams struct

+ BytebufParams *ByteBufferParams

+ type PayloadConfig_ComplexParams struct

+ ComplexParams *ComplexProtoParams

+ type PayloadConfig_SimpleParams struct

+ SimpleParams *SimpleProtoParams

+ type PayloadType int32

+ const PayloadType_COMPRESSABLE

+ const PayloadType_RANDOM

+ const PayloadType_UNCOMPRESSABLE

+ func (PayloadType) EnumDescriptor() ([]byte, []int)

+ func (x PayloadType) String() string

+ type PoissonParams struct

+ OfferedLoad float64

+ func (*PoissonParams) Descriptor() ([]byte, []int)

+ func (*PoissonParams) ProtoMessage()

+ func (m *PoissonParams) Reset()

+ func (m *PoissonParams) String() string

+ type ReconnectInfo struct

+ BackoffMs []int32

+ Passed bool

+ func (*ReconnectInfo) Descriptor() ([]byte, []int)

+ func (*ReconnectInfo) ProtoMessage()

+ func (m *ReconnectInfo) Reset()

+ func (m *ReconnectInfo) String() string

+ type ReconnectParams struct

+ MaxReconnectBackoffMs int32

+ func (*ReconnectParams) Descriptor() ([]byte, []int)

+ func (*ReconnectParams) ProtoMessage()

+ func (m *ReconnectParams) Reset()

+ func (m *ReconnectParams) String() string

+ type ResponseParameters struct

+ IntervalUs int32

+ Size int32

+ func (*ResponseParameters) Descriptor() ([]byte, []int)

+ func (*ResponseParameters) ProtoMessage()

+ func (m *ResponseParameters) Reset()

+ func (m *ResponseParameters) String() string

+ type RpcType int32

+ const RpcType_STREAMING

+ const RpcType_UNARY

+ func (RpcType) EnumDescriptor() ([]byte, []int)

+ func (x RpcType) String() string

+ type Scenario struct

+ BenchmarkSeconds int32

+ ClientConfig *ClientConfig

+ Name string

+ NumClients int32

+ NumServers int32

+ ServerConfig *ServerConfig

+ SpawnLocalWorkerCount int32

+ WarmupSeconds int32

+ func (*Scenario) Descriptor() ([]byte, []int)

+ func (*Scenario) ProtoMessage()

+ func (m *Scenario) GetClientConfig() *ClientConfig

+ func (m *Scenario) GetServerConfig() *ServerConfig

+ func (m *Scenario) Reset()

+ func (m *Scenario) String() string

+ type Scenarios struct

+ Scenarios []*Scenario

+ func (*Scenarios) Descriptor() ([]byte, []int)

+ func (*Scenarios) ProtoMessage()

+ func (m *Scenarios) GetScenarios() []*Scenario

+ func (m *Scenarios) Reset()

+ func (m *Scenarios) String() string

+ type SecurityParams struct

+ ServerHostOverride string

+ UseTestCa bool

+ func (*SecurityParams) Descriptor() ([]byte, []int)

+ func (*SecurityParams) ProtoMessage()

+ func (m *SecurityParams) Reset()

+ func (m *SecurityParams) String() string

+ type ServerArgs struct

+ Argtype isServerArgs_Argtype

+ func (*ServerArgs) Descriptor() ([]byte, []int)

+ func (*ServerArgs) ProtoMessage()

+ func (*ServerArgs) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *ServerArgs) GetArgtype() isServerArgs_Argtype

+ func (m *ServerArgs) GetMark() *Mark

+ func (m *ServerArgs) GetSetup() *ServerConfig

+ func (m *ServerArgs) Reset()

+ func (m *ServerArgs) String() string

+ type ServerArgs_Mark struct

+ Mark *Mark

+ type ServerArgs_Setup struct

+ Setup *ServerConfig

+ type ServerConfig struct

+ AsyncServerThreads int32

+ CoreLimit int32

+ CoreList []int32

+ PayloadConfig *PayloadConfig

+ Port int32

+ SecurityParams *SecurityParams

+ ServerType ServerType

+ func (*ServerConfig) Descriptor() ([]byte, []int)

+ func (*ServerConfig) ProtoMessage()

+ func (m *ServerConfig) GetPayloadConfig() *PayloadConfig

+ func (m *ServerConfig) GetSecurityParams() *SecurityParams

+ func (m *ServerConfig) Reset()

+ func (m *ServerConfig) String() string

+ type ServerStats struct

+ TimeElapsed float64

+ TimeSystem float64

+ TimeUser float64

+ func (*ServerStats) Descriptor() ([]byte, []int)

+ func (*ServerStats) ProtoMessage()

+ func (m *ServerStats) Reset()

+ func (m *ServerStats) String() string

+ type ServerStatus struct

+ Cores int32

+ Port int32

+ Stats *ServerStats

+ func (*ServerStatus) Descriptor() ([]byte, []int)

+ func (*ServerStatus) ProtoMessage()

+ func (m *ServerStatus) GetStats() *ServerStats

+ func (m *ServerStatus) Reset()

+ func (m *ServerStatus) String() string

+ type ServerType int32

+ const ServerType_ASYNC_GENERIC_SERVER

+ const ServerType_ASYNC_SERVER

+ const ServerType_SYNC_SERVER

+ func (ServerType) EnumDescriptor() ([]byte, []int)

+ func (x ServerType) String() string

+ type SimpleProtoParams struct

+ ReqSize int32

+ RespSize int32

+ func (*SimpleProtoParams) Descriptor() ([]byte, []int)

+ func (*SimpleProtoParams) ProtoMessage()

+ func (m *SimpleProtoParams) Reset()

+ func (m *SimpleProtoParams) String() string

+ type SimpleRequest struct

+ FillOauthScope bool

+ FillUsername bool

+ Payload *Payload

+ ResponseCompression CompressionType

+ ResponseSize int32

+ ResponseStatus *EchoStatus

+ ResponseType PayloadType

+ func (*SimpleRequest) Descriptor() ([]byte, []int)

+ func (*SimpleRequest) ProtoMessage()

+ func (m *SimpleRequest) GetPayload() *Payload

+ func (m *SimpleRequest) GetResponseStatus() *EchoStatus

+ func (m *SimpleRequest) Reset()

+ func (m *SimpleRequest) String() string

+ type SimpleResponse struct

+ OauthScope string

+ Payload *Payload

+ Username string

+ func (*SimpleResponse) Descriptor() ([]byte, []int)

+ func (*SimpleResponse) ProtoMessage()

+ func (m *SimpleResponse) GetPayload() *Payload

+ func (m *SimpleResponse) Reset()

+ func (m *SimpleResponse) String() string

+ type StreamingInputCallRequest struct

+ Payload *Payload

+ func (*StreamingInputCallRequest) Descriptor() ([]byte, []int)

+ func (*StreamingInputCallRequest) ProtoMessage()

+ func (m *StreamingInputCallRequest) GetPayload() *Payload

+ func (m *StreamingInputCallRequest) Reset()

+ func (m *StreamingInputCallRequest) String() string

+ type StreamingInputCallResponse struct

+ AggregatedPayloadSize int32

+ func (*StreamingInputCallResponse) Descriptor() ([]byte, []int)

+ func (*StreamingInputCallResponse) ProtoMessage()

+ func (m *StreamingInputCallResponse) Reset()

+ func (m *StreamingInputCallResponse) String() string

+ type StreamingOutputCallRequest struct

+ Payload *Payload

+ ResponseCompression CompressionType

+ ResponseParameters []*ResponseParameters

+ ResponseStatus *EchoStatus

+ ResponseType PayloadType

+ func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int)

+ func (*StreamingOutputCallRequest) ProtoMessage()

+ func (m *StreamingOutputCallRequest) GetPayload() *Payload

+ func (m *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters

+ func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

+ func (m *StreamingOutputCallRequest) Reset()

+ func (m *StreamingOutputCallRequest) String() string

+ type StreamingOutputCallResponse struct

+ Payload *Payload

+ func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int)

+ func (*StreamingOutputCallResponse) ProtoMessage()

+ func (m *StreamingOutputCallResponse) GetPayload() *Payload

+ func (m *StreamingOutputCallResponse) Reset()

+ func (m *StreamingOutputCallResponse) String() string

+ type UniformParams struct

+ InterarrivalHi float64

+ InterarrivalLo float64

+ func (*UniformParams) Descriptor() ([]byte, []int)

+ func (*UniformParams) ProtoMessage()

+ func (m *UniformParams) Reset()

+ func (m *UniformParams) String() string

+ type Void struct

+ func (*Void) Descriptor() ([]byte, []int)

+ func (*Void) ProtoMessage()

+ func (m *Void) Reset()

+ func (m *Void) String() string

+ type WorkerServiceClient interface

+ CoreCount func(ctx context.Context, in *CoreRequest, opts ...grpc.CallOption) (*CoreResponse, error)

+ QuitWorker func(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error)

+ RunClient func(ctx context.Context, opts ...grpc.CallOption) (WorkerService_RunClientClient, error)

+ RunServer func(ctx context.Context, opts ...grpc.CallOption) (WorkerService_RunServerClient, error)

+ func NewWorkerServiceClient(cc *grpc.ClientConn) WorkerServiceClient

+ type WorkerServiceServer interface

+ CoreCount func(context.Context, *CoreRequest) (*CoreResponse, error)

+ QuitWorker func(context.Context, *Void) (*Void, error)

+ RunClient func(WorkerService_RunClientServer) error

+ RunServer func(WorkerService_RunServerServer) error

+ type WorkerService_RunClientClient interface

+ Recv func() (*ClientStatus, error)

+ Send func(*ClientArgs) error

+ type WorkerService_RunClientServer interface

+ Recv func() (*ClientArgs, error)

+ Send func(*ClientStatus) error

+ type WorkerService_RunServerClient interface

+ Recv func() (*ServerStatus, error)

+ Send func(*ServerArgs) error

+ type WorkerService_RunServerServer interface

+ Recv func() (*ServerArgs, error)

+ Send func(*ServerStatus) error