Versions in this module Expand all Collapse all v1 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
Go to main page