grpc_testing

package

Go to main page

Versions in this module

v1

v1.14.0

Jul 31, 2018

v1.13.0

Jun 19, 2018

v1.12.2

Jun 7, 2018

v1.12.1

Jun 6, 2018

v1.12.0

May 8, 2018

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

v1.11.3

Apr 9, 2018

v1.11.2

Apr 4, 2018

v1.11.1

Mar 29, 2018

v1.11.0

Mar 27, 2018

v1.10.1

Mar 28, 2018

v1.10.0

Feb 14, 2018

v1.9.2

Jan 19, 2018

v1.9.1

Jan 8, 2018

v1.9.0

Jan 2, 2018

v1.8.2

Dec 13, 2017

v1.8.0

Nov 21, 2017

v1.7.5

Dec 18, 2017

v1.7.4

Dec 4, 2017

v1.7.3

Nov 14, 2017

v1.7.2

Nov 3, 2017

v1.7.1

Oct 25, 2017

v1.7.0

Oct 11, 2017

v1.6.0

Aug 30, 2017

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

v1.5.2

Aug 14, 2017

v1.5.1

Jul 27, 2017

v1.5.0

Jul 19, 2017

v1.4.2

Jun 22, 2017

v1.4.1

Jun 14, 2017

v1.4.0

Jun 7, 2017

v1.3.0

Apr 28, 2017

v1.2.1

Apr 7, 2017

v1.2.0

Mar 14, 2017

v1.0.5

Dec 2, 2016

v1.0.4

Nov 3, 2016

v1.0.3

Oct 17, 2016

v1.0.2

Oct 3, 2016

v1.0.1-GA

Aug 19, 2016

v1.0.0

Jul 11, 2016

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL