Versions in this module Expand all Collapse all v1 v1.0.0 Jun 24, 2021 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) + UnconstrainedStreamingCall func(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_UnconstrainedStreamingCallClient, error) + func NewBenchmarkServiceClient(cc grpc.ClientConnInterface) BenchmarkServiceClient + type BenchmarkServiceServer interface + StreamingCall func(BenchmarkService_StreamingCallServer) error + UnaryCall func(context.Context, *SimpleRequest) (*SimpleResponse, error) + UnconstrainedStreamingCall func(BenchmarkService_UnconstrainedStreamingCallServer) 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 BenchmarkService_UnconstrainedStreamingCallClient interface + Recv func() (*SimpleResponse, error) + Send func(*SimpleRequest) error + type BenchmarkService_UnconstrainedStreamingCallServer interface + Recv func() (*SimpleRequest, error) + Send func(*SimpleResponse) error + type ByteBufferParams struct + ReqSize int32 + RespSize int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ByteBufferParams) Descriptor() ([]byte, []int) + func (*ByteBufferParams) ProtoMessage() + func (m *ByteBufferParams) GetReqSize() int32 + func (m *ByteBufferParams) GetRespSize() int32 + func (m *ByteBufferParams) Reset() + func (m *ByteBufferParams) String() string + func (m *ByteBufferParams) XXX_DiscardUnknown() + func (m *ByteBufferParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ByteBufferParams) XXX_Merge(src proto.Message) + func (m *ByteBufferParams) XXX_Size() int + func (m *ByteBufferParams) XXX_Unmarshal(b []byte) error + type ClientArgs struct + Argtype isClientArgs_Argtype + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClientArgs) Descriptor() ([]byte, []int) + func (*ClientArgs) ProtoMessage() + func (*ClientArgs) XXX_OneofWrappers() []interface{} + 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 + func (m *ClientArgs) XXX_DiscardUnknown() + func (m *ClientArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClientArgs) XXX_Merge(src proto.Message) + func (m *ClientArgs) XXX_Size() int + func (m *ClientArgs) XXX_Unmarshal(b []byte) error + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClientConfig) Descriptor() ([]byte, []int) + func (*ClientConfig) ProtoMessage() + 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) GetHistogramParams() *HistogramParams + func (m *ClientConfig) GetLoadParams() *LoadParams + func (m *ClientConfig) GetOutstandingRpcsPerChannel() int32 + func (m *ClientConfig) GetPayloadConfig() *PayloadConfig + func (m *ClientConfig) GetRpcType() RpcType + func (m *ClientConfig) GetSecurityParams() *SecurityParams + func (m *ClientConfig) GetServerTargets() []string + func (m *ClientConfig) Reset() + func (m *ClientConfig) String() string + func (m *ClientConfig) XXX_DiscardUnknown() + func (m *ClientConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClientConfig) XXX_Merge(src proto.Message) + func (m *ClientConfig) XXX_Size() int + func (m *ClientConfig) XXX_Unmarshal(b []byte) error + type ClientStats struct + Latencies *HistogramData + TimeElapsed float64 + TimeSystem float64 + TimeUser float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClientStats) Descriptor() ([]byte, []int) + func (*ClientStats) ProtoMessage() + func (m *ClientStats) GetLatencies() *HistogramData + func (m *ClientStats) GetTimeElapsed() float64 + func (m *ClientStats) GetTimeSystem() float64 + func (m *ClientStats) GetTimeUser() float64 + func (m *ClientStats) Reset() + func (m *ClientStats) String() string + func (m *ClientStats) XXX_DiscardUnknown() + func (m *ClientStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClientStats) XXX_Merge(src proto.Message) + func (m *ClientStats) XXX_Size() int + func (m *ClientStats) XXX_Unmarshal(b []byte) error + type ClientStatus struct + Stats *ClientStats + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClientStatus) Descriptor() ([]byte, []int) + func (*ClientStatus) ProtoMessage() + func (m *ClientStatus) GetStats() *ClientStats + func (m *ClientStatus) Reset() + func (m *ClientStatus) String() string + func (m *ClientStatus) XXX_DiscardUnknown() + func (m *ClientStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClientStatus) XXX_Merge(src proto.Message) + func (m *ClientStatus) XXX_Size() int + func (m *ClientStatus) XXX_Unmarshal(b []byte) error + type ClientType int32 + const ClientType_ASYNC_CLIENT + const ClientType_SYNC_CLIENT + func (ClientType) EnumDescriptor() ([]byte, []int) + func (x ClientType) String() string + type ClosedLoopParams struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClosedLoopParams) Descriptor() ([]byte, []int) + func (*ClosedLoopParams) ProtoMessage() + func (m *ClosedLoopParams) Reset() + func (m *ClosedLoopParams) String() string + func (m *ClosedLoopParams) XXX_DiscardUnknown() + func (m *ClosedLoopParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClosedLoopParams) XXX_Merge(src proto.Message) + func (m *ClosedLoopParams) XXX_Size() int + func (m *ClosedLoopParams) XXX_Unmarshal(b []byte) error + type ComplexProtoParams struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ComplexProtoParams) Descriptor() ([]byte, []int) + func (*ComplexProtoParams) ProtoMessage() + func (m *ComplexProtoParams) Reset() + func (m *ComplexProtoParams) String() string + func (m *ComplexProtoParams) XXX_DiscardUnknown() + func (m *ComplexProtoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ComplexProtoParams) XXX_Merge(src proto.Message) + func (m *ComplexProtoParams) XXX_Size() int + func (m *ComplexProtoParams) XXX_Unmarshal(b []byte) error + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CoreRequest) Descriptor() ([]byte, []int) + func (*CoreRequest) ProtoMessage() + func (m *CoreRequest) Reset() + func (m *CoreRequest) String() string + func (m *CoreRequest) XXX_DiscardUnknown() + func (m *CoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CoreRequest) XXX_Merge(src proto.Message) + func (m *CoreRequest) XXX_Size() int + func (m *CoreRequest) XXX_Unmarshal(b []byte) error + type CoreResponse struct + Cores int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CoreResponse) Descriptor() ([]byte, []int) + func (*CoreResponse) ProtoMessage() + func (m *CoreResponse) GetCores() int32 + func (m *CoreResponse) Reset() + func (m *CoreResponse) String() string + func (m *CoreResponse) XXX_DiscardUnknown() + func (m *CoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CoreResponse) XXX_Merge(src proto.Message) + func (m *CoreResponse) XXX_Size() int + func (m *CoreResponse) XXX_Unmarshal(b []byte) error + type DeterministicParams struct + OfferedLoad float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeterministicParams) Descriptor() ([]byte, []int) + func (*DeterministicParams) ProtoMessage() + func (m *DeterministicParams) GetOfferedLoad() float64 + func (m *DeterministicParams) Reset() + func (m *DeterministicParams) String() string + func (m *DeterministicParams) XXX_DiscardUnknown() + func (m *DeterministicParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeterministicParams) XXX_Merge(src proto.Message) + func (m *DeterministicParams) XXX_Size() int + func (m *DeterministicParams) XXX_Unmarshal(b []byte) error + type EchoStatus struct + Code int32 + Message string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EchoStatus) Descriptor() ([]byte, []int) + func (*EchoStatus) ProtoMessage() + func (m *EchoStatus) GetCode() int32 + func (m *EchoStatus) GetMessage() string + func (m *EchoStatus) Reset() + func (m *EchoStatus) String() string + func (m *EchoStatus) XXX_DiscardUnknown() + func (m *EchoStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EchoStatus) XXX_Merge(src proto.Message) + func (m *EchoStatus) XXX_Size() int + func (m *EchoStatus) XXX_Unmarshal(b []byte) error + type HistogramData struct + Bucket []uint32 + Count float64 + MaxSeen float64 + MinSeen float64 + Sum float64 + SumOfSquares float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HistogramData) Descriptor() ([]byte, []int) + func (*HistogramData) ProtoMessage() + 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 + func (m *HistogramData) Reset() + func (m *HistogramData) String() string + func (m *HistogramData) XXX_DiscardUnknown() + func (m *HistogramData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HistogramData) XXX_Merge(src proto.Message) + func (m *HistogramData) XXX_Size() int + func (m *HistogramData) XXX_Unmarshal(b []byte) error + type HistogramParams struct + MaxPossible float64 + Resolution float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HistogramParams) Descriptor() ([]byte, []int) + func (*HistogramParams) ProtoMessage() + func (m *HistogramParams) GetMaxPossible() float64 + func (m *HistogramParams) GetResolution() float64 + func (m *HistogramParams) Reset() + func (m *HistogramParams) String() string + func (m *HistogramParams) XXX_DiscardUnknown() + func (m *HistogramParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HistogramParams) XXX_Merge(src proto.Message) + func (m *HistogramParams) XXX_Size() int + func (m *HistogramParams) XXX_Unmarshal(b []byte) error + type LoadParams struct + Load isLoadParams_Load + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LoadParams) Descriptor() ([]byte, []int) + func (*LoadParams) ProtoMessage() + func (*LoadParams) XXX_OneofWrappers() []interface{} + 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 + func (m *LoadParams) XXX_DiscardUnknown() + func (m *LoadParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LoadParams) XXX_Merge(src proto.Message) + func (m *LoadParams) XXX_Size() int + func (m *LoadParams) XXX_Unmarshal(b []byte) error + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Mark) Descriptor() ([]byte, []int) + func (*Mark) ProtoMessage() + func (m *Mark) GetReset_() bool + func (m *Mark) Reset() + func (m *Mark) String() string + func (m *Mark) XXX_DiscardUnknown() + func (m *Mark) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Mark) XXX_Merge(src proto.Message) + func (m *Mark) XXX_Size() int + func (m *Mark) XXX_Unmarshal(b []byte) error + type ParetoParams struct + Alpha float64 + InterarrivalBase float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ParetoParams) Descriptor() ([]byte, []int) + func (*ParetoParams) ProtoMessage() + func (m *ParetoParams) GetAlpha() float64 + func (m *ParetoParams) GetInterarrivalBase() float64 + func (m *ParetoParams) Reset() + func (m *ParetoParams) String() string + func (m *ParetoParams) XXX_DiscardUnknown() + func (m *ParetoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ParetoParams) XXX_Merge(src proto.Message) + func (m *ParetoParams) XXX_Size() int + func (m *ParetoParams) XXX_Unmarshal(b []byte) error + type Payload struct + Body []byte + Type PayloadType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Payload) Descriptor() ([]byte, []int) + func (*Payload) ProtoMessage() + func (m *Payload) GetBody() []byte + func (m *Payload) GetType() PayloadType + func (m *Payload) Reset() + func (m *Payload) String() string + func (m *Payload) XXX_DiscardUnknown() + func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Payload) XXX_Merge(src proto.Message) + func (m *Payload) XXX_Size() int + func (m *Payload) XXX_Unmarshal(b []byte) error + type PayloadConfig struct + Payload isPayloadConfig_Payload + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PayloadConfig) Descriptor() ([]byte, []int) + func (*PayloadConfig) ProtoMessage() + func (*PayloadConfig) XXX_OneofWrappers() []interface{} + 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 + func (m *PayloadConfig) XXX_DiscardUnknown() + func (m *PayloadConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PayloadConfig) XXX_Merge(src proto.Message) + func (m *PayloadConfig) XXX_Size() int + func (m *PayloadConfig) XXX_Unmarshal(b []byte) error + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PoissonParams) Descriptor() ([]byte, []int) + func (*PoissonParams) ProtoMessage() + func (m *PoissonParams) GetOfferedLoad() float64 + func (m *PoissonParams) Reset() + func (m *PoissonParams) String() string + func (m *PoissonParams) XXX_DiscardUnknown() + func (m *PoissonParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PoissonParams) XXX_Merge(src proto.Message) + func (m *PoissonParams) XXX_Size() int + func (m *PoissonParams) XXX_Unmarshal(b []byte) error + type ReconnectInfo struct + BackoffMs []int32 + Passed bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReconnectInfo) Descriptor() ([]byte, []int) + func (*ReconnectInfo) ProtoMessage() + func (m *ReconnectInfo) GetBackoffMs() []int32 + func (m *ReconnectInfo) GetPassed() bool + func (m *ReconnectInfo) Reset() + func (m *ReconnectInfo) String() string + func (m *ReconnectInfo) XXX_DiscardUnknown() + func (m *ReconnectInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReconnectInfo) XXX_Merge(src proto.Message) + func (m *ReconnectInfo) XXX_Size() int + func (m *ReconnectInfo) XXX_Unmarshal(b []byte) error + type ReconnectParams struct + MaxReconnectBackoffMs int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReconnectParams) Descriptor() ([]byte, []int) + func (*ReconnectParams) ProtoMessage() + func (m *ReconnectParams) GetMaxReconnectBackoffMs() int32 + func (m *ReconnectParams) Reset() + func (m *ReconnectParams) String() string + func (m *ReconnectParams) XXX_DiscardUnknown() + func (m *ReconnectParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReconnectParams) XXX_Merge(src proto.Message) + func (m *ReconnectParams) XXX_Size() int + func (m *ReconnectParams) XXX_Unmarshal(b []byte) error + type ResponseParameters struct + IntervalUs int32 + Size int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResponseParameters) Descriptor() ([]byte, []int) + func (*ResponseParameters) ProtoMessage() + func (m *ResponseParameters) GetIntervalUs() int32 + func (m *ResponseParameters) GetSize() int32 + func (m *ResponseParameters) Reset() + func (m *ResponseParameters) String() string + func (m *ResponseParameters) XXX_DiscardUnknown() + func (m *ResponseParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResponseParameters) XXX_Merge(src proto.Message) + func (m *ResponseParameters) XXX_Size() int + func (m *ResponseParameters) XXX_Unmarshal(b []byte) error + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Scenario) Descriptor() ([]byte, []int) + func (*Scenario) ProtoMessage() + func (m *Scenario) GetBenchmarkSeconds() int32 + func (m *Scenario) GetClientConfig() *ClientConfig + func (m *Scenario) GetName() string + func (m *Scenario) GetNumClients() int32 + func (m *Scenario) GetNumServers() int32 + func (m *Scenario) GetServerConfig() *ServerConfig + func (m *Scenario) GetSpawnLocalWorkerCount() int32 + func (m *Scenario) GetWarmupSeconds() int32 + func (m *Scenario) Reset() + func (m *Scenario) String() string + func (m *Scenario) XXX_DiscardUnknown() + func (m *Scenario) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Scenario) XXX_Merge(src proto.Message) + func (m *Scenario) XXX_Size() int + func (m *Scenario) XXX_Unmarshal(b []byte) error + type Scenarios struct + Scenarios []*Scenario + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Scenarios) Descriptor() ([]byte, []int) + func (*Scenarios) ProtoMessage() + func (m *Scenarios) GetScenarios() []*Scenario + func (m *Scenarios) Reset() + func (m *Scenarios) String() string + func (m *Scenarios) XXX_DiscardUnknown() + func (m *Scenarios) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Scenarios) XXX_Merge(src proto.Message) + func (m *Scenarios) XXX_Size() int + func (m *Scenarios) XXX_Unmarshal(b []byte) error + type SecurityParams struct + ServerHostOverride string + UseTestCa bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SecurityParams) Descriptor() ([]byte, []int) + func (*SecurityParams) ProtoMessage() + func (m *SecurityParams) GetServerHostOverride() string + func (m *SecurityParams) GetUseTestCa() bool + func (m *SecurityParams) Reset() + func (m *SecurityParams) String() string + func (m *SecurityParams) XXX_DiscardUnknown() + func (m *SecurityParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SecurityParams) XXX_Merge(src proto.Message) + func (m *SecurityParams) XXX_Size() int + func (m *SecurityParams) XXX_Unmarshal(b []byte) error + type ServerArgs struct + Argtype isServerArgs_Argtype + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ServerArgs) Descriptor() ([]byte, []int) + func (*ServerArgs) ProtoMessage() + func (*ServerArgs) XXX_OneofWrappers() []interface{} + 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 + func (m *ServerArgs) XXX_DiscardUnknown() + func (m *ServerArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ServerArgs) XXX_Merge(src proto.Message) + func (m *ServerArgs) XXX_Size() int + func (m *ServerArgs) XXX_Unmarshal(b []byte) error + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ServerConfig) Descriptor() ([]byte, []int) + func (*ServerConfig) ProtoMessage() + func (m *ServerConfig) GetAsyncServerThreads() int32 + func (m *ServerConfig) GetCoreLimit() int32 + func (m *ServerConfig) GetCoreList() []int32 + func (m *ServerConfig) GetPayloadConfig() *PayloadConfig + func (m *ServerConfig) GetPort() int32 + func (m *ServerConfig) GetSecurityParams() *SecurityParams + func (m *ServerConfig) GetServerType() ServerType + func (m *ServerConfig) Reset() + func (m *ServerConfig) String() string + func (m *ServerConfig) XXX_DiscardUnknown() + func (m *ServerConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ServerConfig) XXX_Merge(src proto.Message) + func (m *ServerConfig) XXX_Size() int + func (m *ServerConfig) XXX_Unmarshal(b []byte) error + type ServerStats struct + TimeElapsed float64 + TimeSystem float64 + TimeUser float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ServerStats) Descriptor() ([]byte, []int) + func (*ServerStats) ProtoMessage() + func (m *ServerStats) GetTimeElapsed() float64 + func (m *ServerStats) GetTimeSystem() float64 + func (m *ServerStats) GetTimeUser() float64 + func (m *ServerStats) Reset() + func (m *ServerStats) String() string + func (m *ServerStats) XXX_DiscardUnknown() + func (m *ServerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ServerStats) XXX_Merge(src proto.Message) + func (m *ServerStats) XXX_Size() int + func (m *ServerStats) XXX_Unmarshal(b []byte) error + type ServerStatus struct + Cores int32 + Port int32 + Stats *ServerStats + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ServerStatus) Descriptor() ([]byte, []int) + func (*ServerStatus) ProtoMessage() + func (m *ServerStatus) GetCores() int32 + func (m *ServerStatus) GetPort() int32 + func (m *ServerStatus) GetStats() *ServerStats + func (m *ServerStatus) Reset() + func (m *ServerStatus) String() string + func (m *ServerStatus) XXX_DiscardUnknown() + func (m *ServerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ServerStatus) XXX_Merge(src proto.Message) + func (m *ServerStatus) XXX_Size() int + func (m *ServerStatus) XXX_Unmarshal(b []byte) error + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SimpleProtoParams) Descriptor() ([]byte, []int) + func (*SimpleProtoParams) ProtoMessage() + func (m *SimpleProtoParams) GetReqSize() int32 + func (m *SimpleProtoParams) GetRespSize() int32 + func (m *SimpleProtoParams) Reset() + func (m *SimpleProtoParams) String() string + func (m *SimpleProtoParams) XXX_DiscardUnknown() + func (m *SimpleProtoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SimpleProtoParams) XXX_Merge(src proto.Message) + func (m *SimpleProtoParams) XXX_Size() int + func (m *SimpleProtoParams) XXX_Unmarshal(b []byte) error + type SimpleRequest struct + FillOauthScope bool + FillUsername bool + Payload *Payload + ResponseCompression CompressionType + ResponseSize int32 + ResponseStatus *EchoStatus + ResponseType PayloadType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SimpleRequest) Descriptor() ([]byte, []int) + func (*SimpleRequest) ProtoMessage() + func (m *SimpleRequest) GetFillOauthScope() bool + func (m *SimpleRequest) GetFillUsername() bool + func (m *SimpleRequest) GetPayload() *Payload + func (m *SimpleRequest) GetResponseCompression() CompressionType + func (m *SimpleRequest) GetResponseSize() int32 + func (m *SimpleRequest) GetResponseStatus() *EchoStatus + func (m *SimpleRequest) GetResponseType() PayloadType + func (m *SimpleRequest) Reset() + func (m *SimpleRequest) String() string + func (m *SimpleRequest) XXX_DiscardUnknown() + func (m *SimpleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SimpleRequest) XXX_Merge(src proto.Message) + func (m *SimpleRequest) XXX_Size() int + func (m *SimpleRequest) XXX_Unmarshal(b []byte) error + type SimpleResponse struct + OauthScope string + Payload *Payload + Username string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SimpleResponse) Descriptor() ([]byte, []int) + func (*SimpleResponse) ProtoMessage() + func (m *SimpleResponse) GetOauthScope() string + func (m *SimpleResponse) GetPayload() *Payload + func (m *SimpleResponse) GetUsername() string + func (m *SimpleResponse) Reset() + func (m *SimpleResponse) String() string + func (m *SimpleResponse) XXX_DiscardUnknown() + func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SimpleResponse) XXX_Merge(src proto.Message) + func (m *SimpleResponse) XXX_Size() int + func (m *SimpleResponse) XXX_Unmarshal(b []byte) error + type StreamingInputCallRequest struct + Payload *Payload + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamingInputCallRequest) Descriptor() ([]byte, []int) + func (*StreamingInputCallRequest) ProtoMessage() + func (m *StreamingInputCallRequest) GetPayload() *Payload + func (m *StreamingInputCallRequest) Reset() + func (m *StreamingInputCallRequest) String() string + func (m *StreamingInputCallRequest) XXX_DiscardUnknown() + func (m *StreamingInputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamingInputCallRequest) XXX_Merge(src proto.Message) + func (m *StreamingInputCallRequest) XXX_Size() int + func (m *StreamingInputCallRequest) XXX_Unmarshal(b []byte) error + type StreamingInputCallResponse struct + AggregatedPayloadSize int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamingInputCallResponse) Descriptor() ([]byte, []int) + func (*StreamingInputCallResponse) ProtoMessage() + func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32 + func (m *StreamingInputCallResponse) Reset() + func (m *StreamingInputCallResponse) String() string + func (m *StreamingInputCallResponse) XXX_DiscardUnknown() + func (m *StreamingInputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamingInputCallResponse) XXX_Merge(src proto.Message) + func (m *StreamingInputCallResponse) XXX_Size() int + func (m *StreamingInputCallResponse) XXX_Unmarshal(b []byte) error + type StreamingOutputCallRequest struct + Payload *Payload + ResponseCompression CompressionType + ResponseParameters []*ResponseParameters + ResponseStatus *EchoStatus + ResponseType PayloadType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int) + func (*StreamingOutputCallRequest) ProtoMessage() + func (m *StreamingOutputCallRequest) GetPayload() *Payload + func (m *StreamingOutputCallRequest) GetResponseCompression() CompressionType + func (m *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters + func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus + func (m *StreamingOutputCallRequest) GetResponseType() PayloadType + func (m *StreamingOutputCallRequest) Reset() + func (m *StreamingOutputCallRequest) String() string + func (m *StreamingOutputCallRequest) XXX_DiscardUnknown() + func (m *StreamingOutputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamingOutputCallRequest) XXX_Merge(src proto.Message) + func (m *StreamingOutputCallRequest) XXX_Size() int + func (m *StreamingOutputCallRequest) XXX_Unmarshal(b []byte) error + type StreamingOutputCallResponse struct + Payload *Payload + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int) + func (*StreamingOutputCallResponse) ProtoMessage() + func (m *StreamingOutputCallResponse) GetPayload() *Payload + func (m *StreamingOutputCallResponse) Reset() + func (m *StreamingOutputCallResponse) String() string + func (m *StreamingOutputCallResponse) XXX_DiscardUnknown() + func (m *StreamingOutputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamingOutputCallResponse) XXX_Merge(src proto.Message) + func (m *StreamingOutputCallResponse) XXX_Size() int + func (m *StreamingOutputCallResponse) XXX_Unmarshal(b []byte) error + type UniformParams struct + InterarrivalHi float64 + InterarrivalLo float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UniformParams) Descriptor() ([]byte, []int) + func (*UniformParams) ProtoMessage() + func (m *UniformParams) GetInterarrivalHi() float64 + func (m *UniformParams) GetInterarrivalLo() float64 + func (m *UniformParams) Reset() + func (m *UniformParams) String() string + func (m *UniformParams) XXX_DiscardUnknown() + func (m *UniformParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UniformParams) XXX_Merge(src proto.Message) + func (m *UniformParams) XXX_Size() int + func (m *UniformParams) XXX_Unmarshal(b []byte) error + 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 + type Void struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Void) Descriptor() ([]byte, []int) + func (*Void) ProtoMessage() + func (m *Void) Reset() + func (m *Void) String() string + func (m *Void) XXX_DiscardUnknown() + func (m *Void) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Void) XXX_Merge(src proto.Message) + func (m *Void) XXX_Size() int + func (m *Void) XXX_Unmarshal(b []byte) error + 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.ClientConnInterface) 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