grpc: google.golang.org/grpc/benchmark/grpc_testing Index | Files

package grpc_testing

import "google.golang.org/grpc/benchmark/grpc_testing"

Package grpc_testing is a generated protocol buffer package.

It is generated from these files:

control.proto
messages.proto
payloads.proto
services.proto
stats.proto

It has these top-level messages:

PoissonParams
UniformParams
DeterministicParams
ParetoParams
ClosedLoopParams
LoadParams
SecurityParams
ClientConfig
ClientStatus
Mark
ClientArgs
ServerConfig
ServerArgs
ServerStatus
CoreRequest
CoreResponse
Void
Scenario
Scenarios
Payload
EchoStatus
SimpleRequest
SimpleResponse
StreamingInputCallRequest
StreamingInputCallResponse
ResponseParameters
StreamingOutputCallRequest
StreamingOutputCallResponse
ReconnectParams
ReconnectInfo
ByteBufferParams
SimpleProtoParams
ComplexProtoParams
PayloadConfig
ServerStats
HistogramParams
HistogramData
ClientStats

Index

Package Files

control.pb.go messages.pb.go payloads.pb.go services.pb.go stats.pb.go

Variables

var ClientType_name = map[int32]string{
    0:  "SYNC_CLIENT",
    1:  "ASYNC_CLIENT",
}
var ClientType_value = map[string]int32{
    "SYNC_CLIENT":  0,
    "ASYNC_CLIENT": 1,
}
var CompressionType_name = map[int32]string{
    0:  "NONE",
    1:  "GZIP",
    2:  "DEFLATE",
}
var CompressionType_value = map[string]int32{
    "NONE":    0,
    "GZIP":    1,
    "DEFLATE": 2,
}
var PayloadType_name = map[int32]string{
    0:  "COMPRESSABLE",
    1:  "UNCOMPRESSABLE",
    2:  "RANDOM",
}
var PayloadType_value = map[string]int32{
    "COMPRESSABLE":   0,
    "UNCOMPRESSABLE": 1,
    "RANDOM":         2,
}
var RpcType_name = map[int32]string{
    0:  "UNARY",
    1:  "STREAMING",
}
var RpcType_value = map[string]int32{
    "UNARY":     0,
    "STREAMING": 1,
}
var ServerType_name = map[int32]string{
    0:  "SYNC_SERVER",
    1:  "ASYNC_SERVER",
    2:  "ASYNC_GENERIC_SERVER",
}
var ServerType_value = map[string]int32{
    "SYNC_SERVER":          0,
    "ASYNC_SERVER":         1,
    "ASYNC_GENERIC_SERVER": 2,
}

func RegisterBenchmarkServiceServer Uses

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

func RegisterWorkerServiceServer Uses

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

type BenchmarkServiceClient Uses

type BenchmarkServiceClient interface {
    // One request followed by one response.
    // The server returns the client payload as-is.
    UnaryCall(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
    // One request followed by one response.
    // The server returns the client payload as-is.
    StreamingCall(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_StreamingCallClient, error)
}

func NewBenchmarkServiceClient Uses

func NewBenchmarkServiceClient(cc *grpc.ClientConn) BenchmarkServiceClient

type BenchmarkServiceServer Uses

type BenchmarkServiceServer interface {
    // One request followed by one response.
    // The server returns the client payload as-is.
    UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
    // One request followed by one response.
    // The server returns the client payload as-is.
    StreamingCall(BenchmarkService_StreamingCallServer) error
}

type BenchmarkService_StreamingCallClient Uses

type BenchmarkService_StreamingCallClient interface {
    Send(*SimpleRequest) error
    Recv() (*SimpleResponse, error)
    grpc.ClientStream
}

type BenchmarkService_StreamingCallServer Uses

type BenchmarkService_StreamingCallServer interface {
    Send(*SimpleResponse) error
    Recv() (*SimpleRequest, error)
    grpc.ServerStream
}

type ByteBufferParams Uses

type ByteBufferParams struct {
    ReqSize  int32 `protobuf:"varint,1,opt,name=req_size,json=reqSize" json:"req_size,omitempty"`
    RespSize int32 `protobuf:"varint,2,opt,name=resp_size,json=respSize" json:"resp_size,omitempty"`
}

func (*ByteBufferParams) Descriptor Uses

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

func (*ByteBufferParams) GetReqSize Uses

func (m *ByteBufferParams) GetReqSize() int32

func (*ByteBufferParams) GetRespSize Uses

func (m *ByteBufferParams) GetRespSize() int32

func (*ByteBufferParams) ProtoMessage Uses

func (*ByteBufferParams) ProtoMessage()

func (*ByteBufferParams) Reset Uses

func (m *ByteBufferParams) Reset()

func (*ByteBufferParams) String Uses

func (m *ByteBufferParams) String() string

type ClientArgs Uses

type ClientArgs struct {
    // Types that are valid to be assigned to Argtype:
    //	*ClientArgs_Setup
    //	*ClientArgs_Mark
    Argtype isClientArgs_Argtype `protobuf_oneof:"argtype"`
}

func (*ClientArgs) Descriptor Uses

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

func (*ClientArgs) GetArgtype Uses

func (m *ClientArgs) GetArgtype() isClientArgs_Argtype

func (*ClientArgs) GetMark Uses

func (m *ClientArgs) GetMark() *Mark

func (*ClientArgs) GetSetup Uses

func (m *ClientArgs) GetSetup() *ClientConfig

func (*ClientArgs) ProtoMessage Uses

func (*ClientArgs) ProtoMessage()

func (*ClientArgs) Reset Uses

func (m *ClientArgs) Reset()

func (*ClientArgs) String Uses

func (m *ClientArgs) String() string

func (*ClientArgs) XXX_OneofFuncs Uses

func (*ClientArgs) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ClientArgs_Mark Uses

type ClientArgs_Mark struct {
    Mark *Mark `protobuf:"bytes,2,opt,name=mark,oneof"`
}

type ClientArgs_Setup Uses

type ClientArgs_Setup struct {
    Setup *ClientConfig `protobuf:"bytes,1,opt,name=setup,oneof"`
}

type ClientConfig Uses

type ClientConfig struct {
    // List of targets to connect to. At least one target needs to be specified.
    ServerTargets  []string        `protobuf:"bytes,1,rep,name=server_targets,json=serverTargets" json:"server_targets,omitempty"`
    ClientType     ClientType      `protobuf:"varint,2,opt,name=client_type,json=clientType,enum=grpc.testing.ClientType" json:"client_type,omitempty"`
    SecurityParams *SecurityParams `protobuf:"bytes,3,opt,name=security_params,json=securityParams" json:"security_params,omitempty"`
    // How many concurrent RPCs to start for each channel.
    // For synchronous client, use a separate thread for each outstanding RPC.
    OutstandingRpcsPerChannel int32 `protobuf:"varint,4,opt,name=outstanding_rpcs_per_channel,json=outstandingRpcsPerChannel" json:"outstanding_rpcs_per_channel,omitempty"`
    // Number of independent client channels to create.
    // i-th channel will connect to server_target[i % server_targets.size()]
    ClientChannels int32 `protobuf:"varint,5,opt,name=client_channels,json=clientChannels" json:"client_channels,omitempty"`
    // Only for async client. Number of threads to use to start/manage RPCs.
    AsyncClientThreads int32   `protobuf:"varint,7,opt,name=async_client_threads,json=asyncClientThreads" json:"async_client_threads,omitempty"`
    RpcType            RpcType `protobuf:"varint,8,opt,name=rpc_type,json=rpcType,enum=grpc.testing.RpcType" json:"rpc_type,omitempty"`
    // The requested load for the entire client (aggregated over all the threads).
    LoadParams      *LoadParams      `protobuf:"bytes,10,opt,name=load_params,json=loadParams" json:"load_params,omitempty"`
    PayloadConfig   *PayloadConfig   `protobuf:"bytes,11,opt,name=payload_config,json=payloadConfig" json:"payload_config,omitempty"`
    HistogramParams *HistogramParams `protobuf:"bytes,12,opt,name=histogram_params,json=histogramParams" json:"histogram_params,omitempty"`
    // Specify the cores we should run the client on, if desired
    CoreList  []int32 `protobuf:"varint,13,rep,packed,name=core_list,json=coreList" json:"core_list,omitempty"`
    CoreLimit int32   `protobuf:"varint,14,opt,name=core_limit,json=coreLimit" json:"core_limit,omitempty"`
}

func (*ClientConfig) Descriptor Uses

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

func (*ClientConfig) GetAsyncClientThreads Uses

func (m *ClientConfig) GetAsyncClientThreads() int32

func (*ClientConfig) GetClientChannels Uses

func (m *ClientConfig) GetClientChannels() int32

func (*ClientConfig) GetClientType Uses

func (m *ClientConfig) GetClientType() ClientType

func (*ClientConfig) GetCoreLimit Uses

func (m *ClientConfig) GetCoreLimit() int32

func (*ClientConfig) GetCoreList Uses

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

func (*ClientConfig) GetHistogramParams Uses

func (m *ClientConfig) GetHistogramParams() *HistogramParams

func (*ClientConfig) GetLoadParams Uses

func (m *ClientConfig) GetLoadParams() *LoadParams

func (*ClientConfig) GetOutstandingRpcsPerChannel Uses

func (m *ClientConfig) GetOutstandingRpcsPerChannel() int32

func (*ClientConfig) GetPayloadConfig Uses

func (m *ClientConfig) GetPayloadConfig() *PayloadConfig

func (*ClientConfig) GetRpcType Uses

func (m *ClientConfig) GetRpcType() RpcType

func (*ClientConfig) GetSecurityParams Uses

func (m *ClientConfig) GetSecurityParams() *SecurityParams

func (*ClientConfig) GetServerTargets Uses

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

func (*ClientConfig) ProtoMessage Uses

func (*ClientConfig) ProtoMessage()

func (*ClientConfig) Reset Uses

func (m *ClientConfig) Reset()

func (*ClientConfig) String Uses

func (m *ClientConfig) String() string

type ClientStats Uses

type ClientStats struct {
    // Latency histogram. Data points are in nanoseconds.
    Latencies *HistogramData `protobuf:"bytes,1,opt,name=latencies" json:"latencies,omitempty"`
    // See ServerStats for details.
    TimeElapsed float64 `protobuf:"fixed64,2,opt,name=time_elapsed,json=timeElapsed" json:"time_elapsed,omitempty"`
    TimeUser    float64 `protobuf:"fixed64,3,opt,name=time_user,json=timeUser" json:"time_user,omitempty"`
    TimeSystem  float64 `protobuf:"fixed64,4,opt,name=time_system,json=timeSystem" json:"time_system,omitempty"`
}

func (*ClientStats) Descriptor Uses

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

func (*ClientStats) GetLatencies Uses

func (m *ClientStats) GetLatencies() *HistogramData

func (*ClientStats) GetTimeElapsed Uses

func (m *ClientStats) GetTimeElapsed() float64

func (*ClientStats) GetTimeSystem Uses

func (m *ClientStats) GetTimeSystem() float64

func (*ClientStats) GetTimeUser Uses

func (m *ClientStats) GetTimeUser() float64

func (*ClientStats) ProtoMessage Uses

func (*ClientStats) ProtoMessage()

func (*ClientStats) Reset Uses

func (m *ClientStats) Reset()

func (*ClientStats) String Uses

func (m *ClientStats) String() string

type ClientStatus Uses

type ClientStatus struct {
    Stats *ClientStats `protobuf:"bytes,1,opt,name=stats" json:"stats,omitempty"`
}

func (*ClientStatus) Descriptor Uses

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

func (*ClientStatus) GetStats Uses

func (m *ClientStatus) GetStats() *ClientStats

func (*ClientStatus) ProtoMessage Uses

func (*ClientStatus) ProtoMessage()

func (*ClientStatus) Reset Uses

func (m *ClientStatus) Reset()

func (*ClientStatus) String Uses

func (m *ClientStatus) String() string

type ClientType Uses

type ClientType int32
const (
    ClientType_SYNC_CLIENT  ClientType = 0
    ClientType_ASYNC_CLIENT ClientType = 1
)

func (ClientType) EnumDescriptor Uses

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

func (ClientType) String Uses

func (x ClientType) String() string

type ClosedLoopParams Uses

type ClosedLoopParams struct {
}

Once an RPC finishes, immediately start a new one. No configuration parameters needed.

func (*ClosedLoopParams) Descriptor Uses

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

func (*ClosedLoopParams) ProtoMessage Uses

func (*ClosedLoopParams) ProtoMessage()

func (*ClosedLoopParams) Reset Uses

func (m *ClosedLoopParams) Reset()

func (*ClosedLoopParams) String Uses

func (m *ClosedLoopParams) String() string

type ComplexProtoParams Uses

type ComplexProtoParams struct {
}

func (*ComplexProtoParams) Descriptor Uses

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

func (*ComplexProtoParams) ProtoMessage Uses

func (*ComplexProtoParams) ProtoMessage()

func (*ComplexProtoParams) Reset Uses

func (m *ComplexProtoParams) Reset()

func (*ComplexProtoParams) String Uses

func (m *ComplexProtoParams) String() string

type CompressionType Uses

type CompressionType int32

Compression algorithms

const (
    // No compression
    CompressionType_NONE    CompressionType = 0
    CompressionType_GZIP    CompressionType = 1
    CompressionType_DEFLATE CompressionType = 2
)

func (CompressionType) EnumDescriptor Uses

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

func (CompressionType) String Uses

func (x CompressionType) String() string

type CoreRequest Uses

type CoreRequest struct {
}

func (*CoreRequest) Descriptor Uses

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

func (*CoreRequest) ProtoMessage Uses

func (*CoreRequest) ProtoMessage()

func (*CoreRequest) Reset Uses

func (m *CoreRequest) Reset()

func (*CoreRequest) String Uses

func (m *CoreRequest) String() string

type CoreResponse Uses

type CoreResponse struct {
    // Number of cores available on the server
    Cores int32 `protobuf:"varint,1,opt,name=cores" json:"cores,omitempty"`
}

func (*CoreResponse) Descriptor Uses

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

func (*CoreResponse) GetCores Uses

func (m *CoreResponse) GetCores() int32

func (*CoreResponse) ProtoMessage Uses

func (*CoreResponse) ProtoMessage()

func (*CoreResponse) Reset Uses

func (m *CoreResponse) Reset()

func (*CoreResponse) String Uses

func (m *CoreResponse) String() string

type DeterministicParams Uses

type DeterministicParams struct {
    OfferedLoad float64 `protobuf:"fixed64,1,opt,name=offered_load,json=offeredLoad" json:"offered_load,omitempty"`
}

func (*DeterministicParams) Descriptor Uses

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

func (*DeterministicParams) GetOfferedLoad Uses

func (m *DeterministicParams) GetOfferedLoad() float64

func (*DeterministicParams) ProtoMessage Uses

func (*DeterministicParams) ProtoMessage()

func (*DeterministicParams) Reset Uses

func (m *DeterministicParams) Reset()

func (*DeterministicParams) String Uses

func (m *DeterministicParams) String() string

type EchoStatus Uses

type EchoStatus struct {
    Code    int32  `protobuf:"varint,1,opt,name=code" json:"code,omitempty"`
    Message string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
}

A protobuf representation for grpc status. This is used by test clients to specify a status that the server should attempt to return.

func (*EchoStatus) Descriptor Uses

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

func (*EchoStatus) GetCode Uses

func (m *EchoStatus) GetCode() int32

func (*EchoStatus) GetMessage Uses

func (m *EchoStatus) GetMessage() string

func (*EchoStatus) ProtoMessage Uses

func (*EchoStatus) ProtoMessage()

func (*EchoStatus) Reset Uses

func (m *EchoStatus) Reset()

func (*EchoStatus) String Uses

func (m *EchoStatus) String() string

type HistogramData Uses

type HistogramData struct {
    Bucket       []uint32 `protobuf:"varint,1,rep,packed,name=bucket" json:"bucket,omitempty"`
    MinSeen      float64  `protobuf:"fixed64,2,opt,name=min_seen,json=minSeen" json:"min_seen,omitempty"`
    MaxSeen      float64  `protobuf:"fixed64,3,opt,name=max_seen,json=maxSeen" json:"max_seen,omitempty"`
    Sum          float64  `protobuf:"fixed64,4,opt,name=sum" json:"sum,omitempty"`
    SumOfSquares float64  `protobuf:"fixed64,5,opt,name=sum_of_squares,json=sumOfSquares" json:"sum_of_squares,omitempty"`
    Count        float64  `protobuf:"fixed64,6,opt,name=count" json:"count,omitempty"`
}

Histogram data based on grpc/support/histogram.c

func (*HistogramData) Descriptor Uses

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

func (*HistogramData) GetBucket Uses

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

func (*HistogramData) GetCount Uses

func (m *HistogramData) GetCount() float64

func (*HistogramData) GetMaxSeen Uses

func (m *HistogramData) GetMaxSeen() float64

func (*HistogramData) GetMinSeen Uses

func (m *HistogramData) GetMinSeen() float64

func (*HistogramData) GetSum Uses

func (m *HistogramData) GetSum() float64

func (*HistogramData) GetSumOfSquares Uses

func (m *HistogramData) GetSumOfSquares() float64

func (*HistogramData) ProtoMessage Uses

func (*HistogramData) ProtoMessage()

func (*HistogramData) Reset Uses

func (m *HistogramData) Reset()

func (*HistogramData) String Uses

func (m *HistogramData) String() string

type HistogramParams Uses

type HistogramParams struct {
    Resolution  float64 `protobuf:"fixed64,1,opt,name=resolution" json:"resolution,omitempty"`
    MaxPossible float64 `protobuf:"fixed64,2,opt,name=max_possible,json=maxPossible" json:"max_possible,omitempty"`
}

Histogram params based on grpc/support/histogram.c

func (*HistogramParams) Descriptor Uses

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

func (*HistogramParams) GetMaxPossible Uses

func (m *HistogramParams) GetMaxPossible() float64

func (*HistogramParams) GetResolution Uses

func (m *HistogramParams) GetResolution() float64

func (*HistogramParams) ProtoMessage Uses

func (*HistogramParams) ProtoMessage()

func (*HistogramParams) Reset Uses

func (m *HistogramParams) Reset()

func (*HistogramParams) String Uses

func (m *HistogramParams) String() string

type LoadParams Uses

type LoadParams struct {
    // Types that are valid to be assigned to Load:
    //	*LoadParams_ClosedLoop
    //	*LoadParams_Poisson
    //	*LoadParams_Uniform
    //	*LoadParams_Determ
    //	*LoadParams_Pareto
    Load isLoadParams_Load `protobuf_oneof:"load"`
}

func (*LoadParams) Descriptor Uses

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

func (*LoadParams) GetClosedLoop Uses

func (m *LoadParams) GetClosedLoop() *ClosedLoopParams

func (*LoadParams) GetDeterm Uses

func (m *LoadParams) GetDeterm() *DeterministicParams

func (*LoadParams) GetLoad Uses

func (m *LoadParams) GetLoad() isLoadParams_Load

func (*LoadParams) GetPareto Uses

func (m *LoadParams) GetPareto() *ParetoParams

func (*LoadParams) GetPoisson Uses

func (m *LoadParams) GetPoisson() *PoissonParams

func (*LoadParams) GetUniform Uses

func (m *LoadParams) GetUniform() *UniformParams

func (*LoadParams) ProtoMessage Uses

func (*LoadParams) ProtoMessage()

func (*LoadParams) Reset Uses

func (m *LoadParams) Reset()

func (*LoadParams) String Uses

func (m *LoadParams) String() string

func (*LoadParams) XXX_OneofFuncs Uses

func (*LoadParams) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type LoadParams_ClosedLoop Uses

type LoadParams_ClosedLoop struct {
    ClosedLoop *ClosedLoopParams `protobuf:"bytes,1,opt,name=closed_loop,json=closedLoop,oneof"`
}

type LoadParams_Determ Uses

type LoadParams_Determ struct {
    Determ *DeterministicParams `protobuf:"bytes,4,opt,name=determ,oneof"`
}

type LoadParams_Pareto Uses

type LoadParams_Pareto struct {
    Pareto *ParetoParams `protobuf:"bytes,5,opt,name=pareto,oneof"`
}

type LoadParams_Poisson Uses

type LoadParams_Poisson struct {
    Poisson *PoissonParams `protobuf:"bytes,2,opt,name=poisson,oneof"`
}

type LoadParams_Uniform Uses

type LoadParams_Uniform struct {
    Uniform *UniformParams `protobuf:"bytes,3,opt,name=uniform,oneof"`
}

type Mark Uses

type Mark struct {
    // if true, the stats will be reset after taking their snapshot.
    Reset_ bool `protobuf:"varint,1,opt,name=reset" json:"reset,omitempty"`
}

Request current stats

func (*Mark) Descriptor Uses

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

func (*Mark) GetReset_ Uses

func (m *Mark) GetReset_() bool

func (*Mark) ProtoMessage Uses

func (*Mark) ProtoMessage()

func (*Mark) Reset Uses

func (m *Mark) Reset()

func (*Mark) String Uses

func (m *Mark) String() string

type ParetoParams Uses

type ParetoParams struct {
    InterarrivalBase float64 `protobuf:"fixed64,1,opt,name=interarrival_base,json=interarrivalBase" json:"interarrival_base,omitempty"`
    Alpha            float64 `protobuf:"fixed64,2,opt,name=alpha" json:"alpha,omitempty"`
}

func (*ParetoParams) Descriptor Uses

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

func (*ParetoParams) GetAlpha Uses

func (m *ParetoParams) GetAlpha() float64

func (*ParetoParams) GetInterarrivalBase Uses

func (m *ParetoParams) GetInterarrivalBase() float64

func (*ParetoParams) ProtoMessage Uses

func (*ParetoParams) ProtoMessage()

func (*ParetoParams) Reset Uses

func (m *ParetoParams) Reset()

func (*ParetoParams) String Uses

func (m *ParetoParams) String() string

type Payload Uses

type Payload struct {
    // The type of data in body.
    Type PayloadType `protobuf:"varint,1,opt,name=type,enum=grpc.testing.PayloadType" json:"type,omitempty"`
    // Primary contents of payload.
    Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
}

A block of data, to simply increase gRPC message size.

func (*Payload) Descriptor Uses

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

func (*Payload) GetBody Uses

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

func (*Payload) GetType Uses

func (m *Payload) GetType() PayloadType

func (*Payload) ProtoMessage Uses

func (*Payload) ProtoMessage()

func (*Payload) Reset Uses

func (m *Payload) Reset()

func (*Payload) String Uses

func (m *Payload) String() string

type PayloadConfig Uses

type PayloadConfig struct {
    // Types that are valid to be assigned to Payload:
    //	*PayloadConfig_BytebufParams
    //	*PayloadConfig_SimpleParams
    //	*PayloadConfig_ComplexParams
    Payload isPayloadConfig_Payload `protobuf_oneof:"payload"`
}

func (*PayloadConfig) Descriptor Uses

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

func (*PayloadConfig) GetBytebufParams Uses

func (m *PayloadConfig) GetBytebufParams() *ByteBufferParams

func (*PayloadConfig) GetComplexParams Uses

func (m *PayloadConfig) GetComplexParams() *ComplexProtoParams

func (*PayloadConfig) GetPayload Uses

func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload

func (*PayloadConfig) GetSimpleParams Uses

func (m *PayloadConfig) GetSimpleParams() *SimpleProtoParams

func (*PayloadConfig) ProtoMessage Uses

func (*PayloadConfig) ProtoMessage()

func (*PayloadConfig) Reset Uses

func (m *PayloadConfig) Reset()

func (*PayloadConfig) String Uses

func (m *PayloadConfig) String() string

func (*PayloadConfig) XXX_OneofFuncs Uses

func (*PayloadConfig) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type PayloadConfig_BytebufParams Uses

type PayloadConfig_BytebufParams struct {
    BytebufParams *ByteBufferParams `protobuf:"bytes,1,opt,name=bytebuf_params,json=bytebufParams,oneof"`
}

type PayloadConfig_ComplexParams Uses

type PayloadConfig_ComplexParams struct {
    ComplexParams *ComplexProtoParams `protobuf:"bytes,3,opt,name=complex_params,json=complexParams,oneof"`
}

type PayloadConfig_SimpleParams Uses

type PayloadConfig_SimpleParams struct {
    SimpleParams *SimpleProtoParams `protobuf:"bytes,2,opt,name=simple_params,json=simpleParams,oneof"`
}

type PayloadType Uses

type PayloadType int32

The type of payload that should be returned.

const (
    // Compressable text format.
    PayloadType_COMPRESSABLE PayloadType = 0
    // Uncompressable binary format.
    PayloadType_UNCOMPRESSABLE PayloadType = 1
    // Randomly chosen from all other formats defined in this enum.
    PayloadType_RANDOM PayloadType = 2
)

func (PayloadType) EnumDescriptor Uses

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

func (PayloadType) String Uses

func (x PayloadType) String() string

type PoissonParams Uses

type PoissonParams struct {
    // The rate of arrivals (a.k.a. lambda parameter of the exp distribution).
    OfferedLoad float64 `protobuf:"fixed64,1,opt,name=offered_load,json=offeredLoad" json:"offered_load,omitempty"`
}

Parameters of poisson process distribution, which is a good representation of activity coming in from independent identical stationary sources.

func (*PoissonParams) Descriptor Uses

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

func (*PoissonParams) GetOfferedLoad Uses

func (m *PoissonParams) GetOfferedLoad() float64

func (*PoissonParams) ProtoMessage Uses

func (*PoissonParams) ProtoMessage()

func (*PoissonParams) Reset Uses

func (m *PoissonParams) Reset()

func (*PoissonParams) String Uses

func (m *PoissonParams) String() string

type ReconnectInfo Uses

type ReconnectInfo struct {
    Passed    bool    `protobuf:"varint,1,opt,name=passed" json:"passed,omitempty"`
    BackoffMs []int32 `protobuf:"varint,2,rep,packed,name=backoff_ms,json=backoffMs" json:"backoff_ms,omitempty"`
}

For reconnect interop test only. Server tells client whether its reconnects are following the spec and the reconnect backoffs it saw.

func (*ReconnectInfo) Descriptor Uses

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

func (*ReconnectInfo) GetBackoffMs Uses

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

func (*ReconnectInfo) GetPassed Uses

func (m *ReconnectInfo) GetPassed() bool

func (*ReconnectInfo) ProtoMessage Uses

func (*ReconnectInfo) ProtoMessage()

func (*ReconnectInfo) Reset Uses

func (m *ReconnectInfo) Reset()

func (*ReconnectInfo) String Uses

func (m *ReconnectInfo) String() string

type ReconnectParams Uses

type ReconnectParams struct {
    MaxReconnectBackoffMs int32 `protobuf:"varint,1,opt,name=max_reconnect_backoff_ms,json=maxReconnectBackoffMs" json:"max_reconnect_backoff_ms,omitempty"`
}

For reconnect interop test only. Client tells server what reconnection parameters it used.

func (*ReconnectParams) Descriptor Uses

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

func (*ReconnectParams) GetMaxReconnectBackoffMs Uses

func (m *ReconnectParams) GetMaxReconnectBackoffMs() int32

func (*ReconnectParams) ProtoMessage Uses

func (*ReconnectParams) ProtoMessage()

func (*ReconnectParams) Reset Uses

func (m *ReconnectParams) Reset()

func (*ReconnectParams) String Uses

func (m *ReconnectParams) String() string

type ResponseParameters Uses

type ResponseParameters struct {
    // Desired payload sizes in responses from the server.
    // If response_type is COMPRESSABLE, this denotes the size before compression.
    Size int32 `protobuf:"varint,1,opt,name=size" json:"size,omitempty"`
    // Desired interval between consecutive responses in the response stream in
    // microseconds.
    IntervalUs int32 `protobuf:"varint,2,opt,name=interval_us,json=intervalUs" json:"interval_us,omitempty"`
}

Configuration for a particular response.

func (*ResponseParameters) Descriptor Uses

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

func (*ResponseParameters) GetIntervalUs Uses

func (m *ResponseParameters) GetIntervalUs() int32

func (*ResponseParameters) GetSize Uses

func (m *ResponseParameters) GetSize() int32

func (*ResponseParameters) ProtoMessage Uses

func (*ResponseParameters) ProtoMessage()

func (*ResponseParameters) Reset Uses

func (m *ResponseParameters) Reset()

func (*ResponseParameters) String Uses

func (m *ResponseParameters) String() string

type RpcType Uses

type RpcType int32
const (
    RpcType_UNARY     RpcType = 0
    RpcType_STREAMING RpcType = 1
)

func (RpcType) EnumDescriptor Uses

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

func (RpcType) String Uses

func (x RpcType) String() string

type Scenario Uses

type Scenario struct {
    // Human readable name for this scenario
    Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
    // Client configuration
    ClientConfig *ClientConfig `protobuf:"bytes,2,opt,name=client_config,json=clientConfig" json:"client_config,omitempty"`
    // Number of clients to start for the test
    NumClients int32 `protobuf:"varint,3,opt,name=num_clients,json=numClients" json:"num_clients,omitempty"`
    // Server configuration
    ServerConfig *ServerConfig `protobuf:"bytes,4,opt,name=server_config,json=serverConfig" json:"server_config,omitempty"`
    // Number of servers to start for the test
    NumServers int32 `protobuf:"varint,5,opt,name=num_servers,json=numServers" json:"num_servers,omitempty"`
    // Warmup period, in seconds
    WarmupSeconds int32 `protobuf:"varint,6,opt,name=warmup_seconds,json=warmupSeconds" json:"warmup_seconds,omitempty"`
    // Benchmark time, in seconds
    BenchmarkSeconds int32 `protobuf:"varint,7,opt,name=benchmark_seconds,json=benchmarkSeconds" json:"benchmark_seconds,omitempty"`
    // Number of workers to spawn locally (usually zero)
    SpawnLocalWorkerCount int32 `protobuf:"varint,8,opt,name=spawn_local_worker_count,json=spawnLocalWorkerCount" json:"spawn_local_worker_count,omitempty"`
}

A single performance scenario: input to qps_json_driver

func (*Scenario) Descriptor Uses

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

func (*Scenario) GetBenchmarkSeconds Uses

func (m *Scenario) GetBenchmarkSeconds() int32

func (*Scenario) GetClientConfig Uses

func (m *Scenario) GetClientConfig() *ClientConfig

func (*Scenario) GetName Uses

func (m *Scenario) GetName() string

func (*Scenario) GetNumClients Uses

func (m *Scenario) GetNumClients() int32

func (*Scenario) GetNumServers Uses

func (m *Scenario) GetNumServers() int32

func (*Scenario) GetServerConfig Uses

func (m *Scenario) GetServerConfig() *ServerConfig

func (*Scenario) GetSpawnLocalWorkerCount Uses

func (m *Scenario) GetSpawnLocalWorkerCount() int32

func (*Scenario) GetWarmupSeconds Uses

func (m *Scenario) GetWarmupSeconds() int32

func (*Scenario) ProtoMessage Uses

func (*Scenario) ProtoMessage()

func (*Scenario) Reset Uses

func (m *Scenario) Reset()

func (*Scenario) String Uses

func (m *Scenario) String() string

type Scenarios Uses

type Scenarios struct {
    Scenarios []*Scenario `protobuf:"bytes,1,rep,name=scenarios" json:"scenarios,omitempty"`
}

A set of scenarios to be run with qps_json_driver

func (*Scenarios) Descriptor Uses

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

func (*Scenarios) GetScenarios Uses

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

func (*Scenarios) ProtoMessage Uses

func (*Scenarios) ProtoMessage()

func (*Scenarios) Reset Uses

func (m *Scenarios) Reset()

func (*Scenarios) String Uses

func (m *Scenarios) String() string

type SecurityParams Uses

type SecurityParams struct {
    UseTestCa          bool   `protobuf:"varint,1,opt,name=use_test_ca,json=useTestCa" json:"use_test_ca,omitempty"`
    ServerHostOverride string `protobuf:"bytes,2,opt,name=server_host_override,json=serverHostOverride" json:"server_host_override,omitempty"`
}

presence of SecurityParams implies use of TLS

func (*SecurityParams) Descriptor Uses

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

func (*SecurityParams) GetServerHostOverride Uses

func (m *SecurityParams) GetServerHostOverride() string

func (*SecurityParams) GetUseTestCa Uses

func (m *SecurityParams) GetUseTestCa() bool

func (*SecurityParams) ProtoMessage Uses

func (*SecurityParams) ProtoMessage()

func (*SecurityParams) Reset Uses

func (m *SecurityParams) Reset()

func (*SecurityParams) String Uses

func (m *SecurityParams) String() string

type ServerArgs Uses

type ServerArgs struct {
    // Types that are valid to be assigned to Argtype:
    //	*ServerArgs_Setup
    //	*ServerArgs_Mark
    Argtype isServerArgs_Argtype `protobuf_oneof:"argtype"`
}

func (*ServerArgs) Descriptor Uses

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

func (*ServerArgs) GetArgtype Uses

func (m *ServerArgs) GetArgtype() isServerArgs_Argtype

func (*ServerArgs) GetMark Uses

func (m *ServerArgs) GetMark() *Mark

func (*ServerArgs) GetSetup Uses

func (m *ServerArgs) GetSetup() *ServerConfig

func (*ServerArgs) ProtoMessage Uses

func (*ServerArgs) ProtoMessage()

func (*ServerArgs) Reset Uses

func (m *ServerArgs) Reset()

func (*ServerArgs) String Uses

func (m *ServerArgs) String() string

func (*ServerArgs) XXX_OneofFuncs Uses

func (*ServerArgs) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ServerArgs_Mark Uses

type ServerArgs_Mark struct {
    Mark *Mark `protobuf:"bytes,2,opt,name=mark,oneof"`
}

type ServerArgs_Setup Uses

type ServerArgs_Setup struct {
    Setup *ServerConfig `protobuf:"bytes,1,opt,name=setup,oneof"`
}

type ServerConfig Uses

type ServerConfig struct {
    ServerType     ServerType      `protobuf:"varint,1,opt,name=server_type,json=serverType,enum=grpc.testing.ServerType" json:"server_type,omitempty"`
    SecurityParams *SecurityParams `protobuf:"bytes,2,opt,name=security_params,json=securityParams" json:"security_params,omitempty"`
    // Port on which to listen. Zero means pick unused port.
    Port int32 `protobuf:"varint,4,opt,name=port" json:"port,omitempty"`
    // Only for async server. Number of threads used to serve the requests.
    AsyncServerThreads int32 `protobuf:"varint,7,opt,name=async_server_threads,json=asyncServerThreads" json:"async_server_threads,omitempty"`
    // Specify the number of cores to limit server to, if desired
    CoreLimit int32 `protobuf:"varint,8,opt,name=core_limit,json=coreLimit" json:"core_limit,omitempty"`
    // payload config, used in generic server
    PayloadConfig *PayloadConfig `protobuf:"bytes,9,opt,name=payload_config,json=payloadConfig" json:"payload_config,omitempty"`
    // Specify the cores we should run the server on, if desired
    CoreList []int32 `protobuf:"varint,10,rep,packed,name=core_list,json=coreList" json:"core_list,omitempty"`
}

func (*ServerConfig) Descriptor Uses

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

func (*ServerConfig) GetAsyncServerThreads Uses

func (m *ServerConfig) GetAsyncServerThreads() int32

func (*ServerConfig) GetCoreLimit Uses

func (m *ServerConfig) GetCoreLimit() int32

func (*ServerConfig) GetCoreList Uses

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

func (*ServerConfig) GetPayloadConfig Uses

func (m *ServerConfig) GetPayloadConfig() *PayloadConfig

func (*ServerConfig) GetPort Uses

func (m *ServerConfig) GetPort() int32

func (*ServerConfig) GetSecurityParams Uses

func (m *ServerConfig) GetSecurityParams() *SecurityParams

func (*ServerConfig) GetServerType Uses

func (m *ServerConfig) GetServerType() ServerType

func (*ServerConfig) ProtoMessage Uses

func (*ServerConfig) ProtoMessage()

func (*ServerConfig) Reset Uses

func (m *ServerConfig) Reset()

func (*ServerConfig) String Uses

func (m *ServerConfig) String() string

type ServerStats Uses

type ServerStats struct {
    // wall clock time change in seconds since last reset
    TimeElapsed float64 `protobuf:"fixed64,1,opt,name=time_elapsed,json=timeElapsed" json:"time_elapsed,omitempty"`
    // change in user time (in seconds) used by the server since last reset
    TimeUser float64 `protobuf:"fixed64,2,opt,name=time_user,json=timeUser" json:"time_user,omitempty"`
    // change in server time (in seconds) used by the server process and all
    // threads since last reset
    TimeSystem float64 `protobuf:"fixed64,3,opt,name=time_system,json=timeSystem" json:"time_system,omitempty"`
}

func (*ServerStats) Descriptor Uses

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

func (*ServerStats) GetTimeElapsed Uses

func (m *ServerStats) GetTimeElapsed() float64

func (*ServerStats) GetTimeSystem Uses

func (m *ServerStats) GetTimeSystem() float64

func (*ServerStats) GetTimeUser Uses

func (m *ServerStats) GetTimeUser() float64

func (*ServerStats) ProtoMessage Uses

func (*ServerStats) ProtoMessage()

func (*ServerStats) Reset Uses

func (m *ServerStats) Reset()

func (*ServerStats) String Uses

func (m *ServerStats) String() string

type ServerStatus Uses

type ServerStatus struct {
    Stats *ServerStats `protobuf:"bytes,1,opt,name=stats" json:"stats,omitempty"`
    // the port bound by the server
    Port int32 `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
    // Number of cores available to the server
    Cores int32 `protobuf:"varint,3,opt,name=cores" json:"cores,omitempty"`
}

func (*ServerStatus) Descriptor Uses

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

func (*ServerStatus) GetCores Uses

func (m *ServerStatus) GetCores() int32

func (*ServerStatus) GetPort Uses

func (m *ServerStatus) GetPort() int32

func (*ServerStatus) GetStats Uses

func (m *ServerStatus) GetStats() *ServerStats

func (*ServerStatus) ProtoMessage Uses

func (*ServerStatus) ProtoMessage()

func (*ServerStatus) Reset Uses

func (m *ServerStatus) Reset()

func (*ServerStatus) String Uses

func (m *ServerStatus) String() string

type ServerType Uses

type ServerType int32
const (
    ServerType_SYNC_SERVER          ServerType = 0
    ServerType_ASYNC_SERVER         ServerType = 1
    ServerType_ASYNC_GENERIC_SERVER ServerType = 2
)

func (ServerType) EnumDescriptor Uses

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

func (ServerType) String Uses

func (x ServerType) String() string

type SimpleProtoParams Uses

type SimpleProtoParams struct {
    ReqSize  int32 `protobuf:"varint,1,opt,name=req_size,json=reqSize" json:"req_size,omitempty"`
    RespSize int32 `protobuf:"varint,2,opt,name=resp_size,json=respSize" json:"resp_size,omitempty"`
}

func (*SimpleProtoParams) Descriptor Uses

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

func (*SimpleProtoParams) GetReqSize Uses

func (m *SimpleProtoParams) GetReqSize() int32

func (*SimpleProtoParams) GetRespSize Uses

func (m *SimpleProtoParams) GetRespSize() int32

func (*SimpleProtoParams) ProtoMessage Uses

func (*SimpleProtoParams) ProtoMessage()

func (*SimpleProtoParams) Reset Uses

func (m *SimpleProtoParams) Reset()

func (*SimpleProtoParams) String Uses

func (m *SimpleProtoParams) String() string

type SimpleRequest Uses

type SimpleRequest struct {
    // Desired payload type in the response from the server.
    // If response_type is RANDOM, server randomly chooses one from other formats.
    ResponseType PayloadType `protobuf:"varint,1,opt,name=response_type,json=responseType,enum=grpc.testing.PayloadType" json:"response_type,omitempty"`
    // Desired payload size in the response from the server.
    // If response_type is COMPRESSABLE, this denotes the size before compression.
    ResponseSize int32 `protobuf:"varint,2,opt,name=response_size,json=responseSize" json:"response_size,omitempty"`
    // Optional input payload sent along with the request.
    Payload *Payload `protobuf:"bytes,3,opt,name=payload" json:"payload,omitempty"`
    // Whether SimpleResponse should include username.
    FillUsername bool `protobuf:"varint,4,opt,name=fill_username,json=fillUsername" json:"fill_username,omitempty"`
    // Whether SimpleResponse should include OAuth scope.
    FillOauthScope bool `protobuf:"varint,5,opt,name=fill_oauth_scope,json=fillOauthScope" json:"fill_oauth_scope,omitempty"`
    // Compression algorithm to be used by the server for the response (stream)
    ResponseCompression CompressionType `protobuf:"varint,6,opt,name=response_compression,json=responseCompression,enum=grpc.testing.CompressionType" json:"response_compression,omitempty"`
    // Whether server should return a given status
    ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus" json:"response_status,omitempty"`
}

Unary request.

func (*SimpleRequest) Descriptor Uses

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

func (*SimpleRequest) GetFillOauthScope Uses

func (m *SimpleRequest) GetFillOauthScope() bool

func (*SimpleRequest) GetFillUsername Uses

func (m *SimpleRequest) GetFillUsername() bool

func (*SimpleRequest) GetPayload Uses

func (m *SimpleRequest) GetPayload() *Payload

func (*SimpleRequest) GetResponseCompression Uses

func (m *SimpleRequest) GetResponseCompression() CompressionType

func (*SimpleRequest) GetResponseSize Uses

func (m *SimpleRequest) GetResponseSize() int32

func (*SimpleRequest) GetResponseStatus Uses

func (m *SimpleRequest) GetResponseStatus() *EchoStatus

func (*SimpleRequest) GetResponseType Uses

func (m *SimpleRequest) GetResponseType() PayloadType

func (*SimpleRequest) ProtoMessage Uses

func (*SimpleRequest) ProtoMessage()

func (*SimpleRequest) Reset Uses

func (m *SimpleRequest) Reset()

func (*SimpleRequest) String Uses

func (m *SimpleRequest) String() string

type SimpleResponse Uses

type SimpleResponse struct {
    // Payload to increase message size.
    Payload *Payload `protobuf:"bytes,1,opt,name=payload" json:"payload,omitempty"`
    // The user the request came from, for verifying authentication was
    // successful when the client expected it.
    Username string `protobuf:"bytes,2,opt,name=username" json:"username,omitempty"`
    // OAuth scope.
    OauthScope string `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope" json:"oauth_scope,omitempty"`
}

Unary response, as configured by the request.

func (*SimpleResponse) Descriptor Uses

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

func (*SimpleResponse) GetOauthScope Uses

func (m *SimpleResponse) GetOauthScope() string

func (*SimpleResponse) GetPayload Uses

func (m *SimpleResponse) GetPayload() *Payload

func (*SimpleResponse) GetUsername Uses

func (m *SimpleResponse) GetUsername() string

func (*SimpleResponse) ProtoMessage Uses

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse) Reset Uses

func (m *SimpleResponse) Reset()

func (*SimpleResponse) String Uses

func (m *SimpleResponse) String() string

type StreamingInputCallRequest Uses

type StreamingInputCallRequest struct {
    // Optional input payload sent along with the request.
    Payload *Payload `protobuf:"bytes,1,opt,name=payload" json:"payload,omitempty"`
}

Client-streaming request.

func (*StreamingInputCallRequest) Descriptor Uses

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

func (*StreamingInputCallRequest) GetPayload Uses

func (m *StreamingInputCallRequest) GetPayload() *Payload

func (*StreamingInputCallRequest) ProtoMessage Uses

func (*StreamingInputCallRequest) ProtoMessage()

func (*StreamingInputCallRequest) Reset Uses

func (m *StreamingInputCallRequest) Reset()

func (*StreamingInputCallRequest) String Uses

func (m *StreamingInputCallRequest) String() string

type StreamingInputCallResponse Uses

type StreamingInputCallResponse struct {
    // Aggregated size of payloads received from the client.
    AggregatedPayloadSize int32 `protobuf:"varint,1,opt,name=aggregated_payload_size,json=aggregatedPayloadSize" json:"aggregated_payload_size,omitempty"`
}

Client-streaming response.

func (*StreamingInputCallResponse) Descriptor Uses

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

func (*StreamingInputCallResponse) GetAggregatedPayloadSize Uses

func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32

func (*StreamingInputCallResponse) ProtoMessage Uses

func (*StreamingInputCallResponse) ProtoMessage()

func (*StreamingInputCallResponse) Reset Uses

func (m *StreamingInputCallResponse) Reset()

func (*StreamingInputCallResponse) String Uses

func (m *StreamingInputCallResponse) String() string

type StreamingOutputCallRequest Uses

type StreamingOutputCallRequest struct {
    // Desired payload type in the response from the server.
    // If response_type is RANDOM, the payload from each response in the stream
    // might be of different types. This is to simulate a mixed type of payload
    // stream.
    ResponseType PayloadType `protobuf:"varint,1,opt,name=response_type,json=responseType,enum=grpc.testing.PayloadType" json:"response_type,omitempty"`
    // Configuration for each expected response message.
    ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters" json:"response_parameters,omitempty"`
    // Optional input payload sent along with the request.
    Payload *Payload `protobuf:"bytes,3,opt,name=payload" json:"payload,omitempty"`
    // Compression algorithm to be used by the server for the response (stream)
    ResponseCompression CompressionType `protobuf:"varint,6,opt,name=response_compression,json=responseCompression,enum=grpc.testing.CompressionType" json:"response_compression,omitempty"`
    // Whether server should return a given status
    ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus" json:"response_status,omitempty"`
}

Server-streaming request.

func (*StreamingOutputCallRequest) Descriptor Uses

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

func (*StreamingOutputCallRequest) GetPayload Uses

func (m *StreamingOutputCallRequest) GetPayload() *Payload

func (*StreamingOutputCallRequest) GetResponseCompression Uses

func (m *StreamingOutputCallRequest) GetResponseCompression() CompressionType

func (*StreamingOutputCallRequest) GetResponseParameters Uses

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

func (*StreamingOutputCallRequest) GetResponseStatus Uses

func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

func (*StreamingOutputCallRequest) GetResponseType Uses

func (m *StreamingOutputCallRequest) GetResponseType() PayloadType

func (*StreamingOutputCallRequest) ProtoMessage Uses

func (*StreamingOutputCallRequest) ProtoMessage()

func (*StreamingOutputCallRequest) Reset Uses

func (m *StreamingOutputCallRequest) Reset()

func (*StreamingOutputCallRequest) String Uses

func (m *StreamingOutputCallRequest) String() string

type StreamingOutputCallResponse Uses

type StreamingOutputCallResponse struct {
    // Payload to increase response size.
    Payload *Payload `protobuf:"bytes,1,opt,name=payload" json:"payload,omitempty"`
}

Server-streaming response, as configured by the request and parameters.

func (*StreamingOutputCallResponse) Descriptor Uses

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

func (*StreamingOutputCallResponse) GetPayload Uses

func (m *StreamingOutputCallResponse) GetPayload() *Payload

func (*StreamingOutputCallResponse) ProtoMessage Uses

func (*StreamingOutputCallResponse) ProtoMessage()

func (*StreamingOutputCallResponse) Reset Uses

func (m *StreamingOutputCallResponse) Reset()

func (*StreamingOutputCallResponse) String Uses

func (m *StreamingOutputCallResponse) String() string

type UniformParams Uses

type UniformParams struct {
    InterarrivalLo float64 `protobuf:"fixed64,1,opt,name=interarrival_lo,json=interarrivalLo" json:"interarrival_lo,omitempty"`
    InterarrivalHi float64 `protobuf:"fixed64,2,opt,name=interarrival_hi,json=interarrivalHi" json:"interarrival_hi,omitempty"`
}

func (*UniformParams) Descriptor Uses

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

func (*UniformParams) GetInterarrivalHi Uses

func (m *UniformParams) GetInterarrivalHi() float64

func (*UniformParams) GetInterarrivalLo Uses

func (m *UniformParams) GetInterarrivalLo() float64

func (*UniformParams) ProtoMessage Uses

func (*UniformParams) ProtoMessage()

func (*UniformParams) Reset Uses

func (m *UniformParams) Reset()

func (*UniformParams) String Uses

func (m *UniformParams) String() string

type Void Uses

type Void struct {
}

func (*Void) Descriptor Uses

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

func (*Void) ProtoMessage Uses

func (*Void) ProtoMessage()

func (*Void) Reset Uses

func (m *Void) Reset()

func (*Void) String Uses

func (m *Void) String() string

type WorkerServiceClient Uses

type WorkerServiceClient interface {
    // Start server with specified workload.
    // First request sent specifies the ServerConfig followed by ServerStatus
    // response. After that, a "Mark" can be sent anytime to request the latest
    // stats. Closing the stream will initiate shutdown of the test server
    // and once the shutdown has finished, the OK status is sent to terminate
    // this RPC.
    RunServer(ctx context.Context, opts ...grpc.CallOption) (WorkerService_RunServerClient, error)
    // Start client with specified workload.
    // First request sent specifies the ClientConfig followed by ClientStatus
    // response. After that, a "Mark" can be sent anytime to request the latest
    // stats. Closing the stream will initiate shutdown of the test client
    // and once the shutdown has finished, the OK status is sent to terminate
    // this RPC.
    RunClient(ctx context.Context, opts ...grpc.CallOption) (WorkerService_RunClientClient, error)
    // Just return the core count - unary call
    CoreCount(ctx context.Context, in *CoreRequest, opts ...grpc.CallOption) (*CoreResponse, error)
    // Quit this worker
    QuitWorker(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error)
}

func NewWorkerServiceClient Uses

func NewWorkerServiceClient(cc *grpc.ClientConn) WorkerServiceClient

type WorkerServiceServer Uses

type WorkerServiceServer interface {
    // Start server with specified workload.
    // First request sent specifies the ServerConfig followed by ServerStatus
    // response. After that, a "Mark" can be sent anytime to request the latest
    // stats. Closing the stream will initiate shutdown of the test server
    // and once the shutdown has finished, the OK status is sent to terminate
    // this RPC.
    RunServer(WorkerService_RunServerServer) error
    // Start client with specified workload.
    // First request sent specifies the ClientConfig followed by ClientStatus
    // response. After that, a "Mark" can be sent anytime to request the latest
    // stats. Closing the stream will initiate shutdown of the test client
    // and once the shutdown has finished, the OK status is sent to terminate
    // this RPC.
    RunClient(WorkerService_RunClientServer) error
    // Just return the core count - unary call
    CoreCount(context.Context, *CoreRequest) (*CoreResponse, error)
    // Quit this worker
    QuitWorker(context.Context, *Void) (*Void, error)
}

type WorkerService_RunClientClient Uses

type WorkerService_RunClientClient interface {
    Send(*ClientArgs) error
    Recv() (*ClientStatus, error)
    grpc.ClientStream
}

type WorkerService_RunClientServer Uses

type WorkerService_RunClientServer interface {
    Send(*ClientStatus) error
    Recv() (*ClientArgs, error)
    grpc.ServerStream
}

type WorkerService_RunServerClient Uses

type WorkerService_RunServerClient interface {
    Send(*ServerArgs) error
    Recv() (*ServerStatus, error)
    grpc.ClientStream
}

type WorkerService_RunServerServer Uses

type WorkerService_RunServerServer interface {
    Send(*ServerStatus) error
    Recv() (*ServerArgs, error)
    grpc.ServerStream
}

Package grpc_testing imports 5 packages (graph) and is imported by 21 packages. Updated 2017-08-18. Refresh now. Tools for package owners.