Documentation

Overview

    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

    Constants

    This section is empty.

    Variables

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

    Functions

    func RegisterBenchmarkServiceServer

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

    func RegisterWorkerServiceServer

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

    Types

    type BenchmarkServiceClient

    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

    func NewBenchmarkServiceClient(cc *grpc.ClientConn) BenchmarkServiceClient

    type BenchmarkServiceServer

    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

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

    type BenchmarkService_StreamingCallServer

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

    type ByteBufferParams

    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

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

    func (*ByteBufferParams) GetReqSize

    func (m *ByteBufferParams) GetReqSize() int32

    func (*ByteBufferParams) GetRespSize

    func (m *ByteBufferParams) GetRespSize() int32

    func (*ByteBufferParams) ProtoMessage

    func (*ByteBufferParams) ProtoMessage()

    func (*ByteBufferParams) Reset

    func (m *ByteBufferParams) Reset()

    func (*ByteBufferParams) String

    func (m *ByteBufferParams) String() string

    type ClientArgs

    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

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

    func (*ClientArgs) GetArgtype

    func (m *ClientArgs) GetArgtype() isClientArgs_Argtype

    func (*ClientArgs) GetMark

    func (m *ClientArgs) GetMark() *Mark

    func (*ClientArgs) GetSetup

    func (m *ClientArgs) GetSetup() *ClientConfig

    func (*ClientArgs) ProtoMessage

    func (*ClientArgs) ProtoMessage()

    func (*ClientArgs) Reset

    func (m *ClientArgs) Reset()

    func (*ClientArgs) String

    func (m *ClientArgs) String() string

    func (*ClientArgs) XXX_OneofFuncs

    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

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

      type ClientArgs_Setup

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

      type ClientConfig

      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 `` /* 134-byte string literal not displayed */
      	// 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

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

      func (*ClientConfig) GetAsyncClientThreads

      func (m *ClientConfig) GetAsyncClientThreads() int32

      func (*ClientConfig) GetClientChannels

      func (m *ClientConfig) GetClientChannels() int32

      func (*ClientConfig) GetClientType

      func (m *ClientConfig) GetClientType() ClientType

      func (*ClientConfig) GetCoreLimit

      func (m *ClientConfig) GetCoreLimit() int32

      func (*ClientConfig) GetCoreList

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

      func (*ClientConfig) GetHistogramParams

      func (m *ClientConfig) GetHistogramParams() *HistogramParams

      func (*ClientConfig) GetLoadParams

      func (m *ClientConfig) GetLoadParams() *LoadParams

      func (*ClientConfig) GetOutstandingRpcsPerChannel

      func (m *ClientConfig) GetOutstandingRpcsPerChannel() int32

      func (*ClientConfig) GetPayloadConfig

      func (m *ClientConfig) GetPayloadConfig() *PayloadConfig

      func (*ClientConfig) GetRpcType

      func (m *ClientConfig) GetRpcType() RpcType

      func (*ClientConfig) GetSecurityParams

      func (m *ClientConfig) GetSecurityParams() *SecurityParams

      func (*ClientConfig) GetServerTargets

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

      func (*ClientConfig) ProtoMessage

      func (*ClientConfig) ProtoMessage()

      func (*ClientConfig) Reset

      func (m *ClientConfig) Reset()

      func (*ClientConfig) String

      func (m *ClientConfig) String() string

      type ClientStats

      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

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

      func (*ClientStats) GetLatencies

      func (m *ClientStats) GetLatencies() *HistogramData

      func (*ClientStats) GetTimeElapsed

      func (m *ClientStats) GetTimeElapsed() float64

      func (*ClientStats) GetTimeSystem

      func (m *ClientStats) GetTimeSystem() float64

      func (*ClientStats) GetTimeUser

      func (m *ClientStats) GetTimeUser() float64

      func (*ClientStats) ProtoMessage

      func (*ClientStats) ProtoMessage()

      func (*ClientStats) Reset

      func (m *ClientStats) Reset()

      func (*ClientStats) String

      func (m *ClientStats) String() string

      type ClientStatus

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

      func (*ClientStatus) Descriptor

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

      func (*ClientStatus) GetStats

      func (m *ClientStatus) GetStats() *ClientStats

      func (*ClientStatus) ProtoMessage

      func (*ClientStatus) ProtoMessage()

      func (*ClientStatus) Reset

      func (m *ClientStatus) Reset()

      func (*ClientStatus) String

      func (m *ClientStatus) String() string

      type ClientType

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

      func (ClientType) EnumDescriptor

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

      func (ClientType) String

      func (x ClientType) String() string

      type ClosedLoopParams

      type ClosedLoopParams struct {
      }

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

        func (*ClosedLoopParams) Descriptor

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

        func (*ClosedLoopParams) ProtoMessage

        func (*ClosedLoopParams) ProtoMessage()

        func (*ClosedLoopParams) Reset

        func (m *ClosedLoopParams) Reset()

        func (*ClosedLoopParams) String

        func (m *ClosedLoopParams) String() string

        type ComplexProtoParams

        type ComplexProtoParams struct {
        }

        func (*ComplexProtoParams) Descriptor

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

        func (*ComplexProtoParams) ProtoMessage

        func (*ComplexProtoParams) ProtoMessage()

        func (*ComplexProtoParams) Reset

        func (m *ComplexProtoParams) Reset()

        func (*ComplexProtoParams) String

        func (m *ComplexProtoParams) String() string

        type CompressionType

        type CompressionType int32

          Compression algorithms

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

          func (CompressionType) EnumDescriptor

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

          func (CompressionType) String

          func (x CompressionType) String() string

          type CoreRequest

          type CoreRequest struct {
          }

          func (*CoreRequest) Descriptor

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

          func (*CoreRequest) ProtoMessage

          func (*CoreRequest) ProtoMessage()

          func (*CoreRequest) Reset

          func (m *CoreRequest) Reset()

          func (*CoreRequest) String

          func (m *CoreRequest) String() string

          type CoreResponse

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

          func (*CoreResponse) Descriptor

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

          func (*CoreResponse) GetCores

          func (m *CoreResponse) GetCores() int32

          func (*CoreResponse) ProtoMessage

          func (*CoreResponse) ProtoMessage()

          func (*CoreResponse) Reset

          func (m *CoreResponse) Reset()

          func (*CoreResponse) String

          func (m *CoreResponse) String() string

          type DeterministicParams

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

          func (*DeterministicParams) Descriptor

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

          func (*DeterministicParams) GetOfferedLoad

          func (m *DeterministicParams) GetOfferedLoad() float64

          func (*DeterministicParams) ProtoMessage

          func (*DeterministicParams) ProtoMessage()

          func (*DeterministicParams) Reset

          func (m *DeterministicParams) Reset()

          func (*DeterministicParams) String

          func (m *DeterministicParams) String() string

          type EchoStatus

          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

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

            func (*EchoStatus) GetCode

            func (m *EchoStatus) GetCode() int32

            func (*EchoStatus) GetMessage

            func (m *EchoStatus) GetMessage() string

            func (*EchoStatus) ProtoMessage

            func (*EchoStatus) ProtoMessage()

            func (*EchoStatus) Reset

            func (m *EchoStatus) Reset()

            func (*EchoStatus) String

            func (m *EchoStatus) String() string

            type HistogramData

            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

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

              func (*HistogramData) GetBucket

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

              func (*HistogramData) GetCount

              func (m *HistogramData) GetCount() float64

              func (*HistogramData) GetMaxSeen

              func (m *HistogramData) GetMaxSeen() float64

              func (*HistogramData) GetMinSeen

              func (m *HistogramData) GetMinSeen() float64

              func (*HistogramData) GetSum

              func (m *HistogramData) GetSum() float64

              func (*HistogramData) GetSumOfSquares

              func (m *HistogramData) GetSumOfSquares() float64

              func (*HistogramData) ProtoMessage

              func (*HistogramData) ProtoMessage()

              func (*HistogramData) Reset

              func (m *HistogramData) Reset()

              func (*HistogramData) String

              func (m *HistogramData) String() string

              type HistogramParams

              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

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

                func (*HistogramParams) GetMaxPossible

                func (m *HistogramParams) GetMaxPossible() float64

                func (*HistogramParams) GetResolution

                func (m *HistogramParams) GetResolution() float64

                func (*HistogramParams) ProtoMessage

                func (*HistogramParams) ProtoMessage()

                func (*HistogramParams) Reset

                func (m *HistogramParams) Reset()

                func (*HistogramParams) String

                func (m *HistogramParams) String() string

                type LoadParams

                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

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

                func (*LoadParams) GetClosedLoop

                func (m *LoadParams) GetClosedLoop() *ClosedLoopParams

                func (*LoadParams) GetDeterm

                func (m *LoadParams) GetDeterm() *DeterministicParams

                func (*LoadParams) GetLoad

                func (m *LoadParams) GetLoad() isLoadParams_Load

                func (*LoadParams) GetPareto

                func (m *LoadParams) GetPareto() *ParetoParams

                func (*LoadParams) GetPoisson

                func (m *LoadParams) GetPoisson() *PoissonParams

                func (*LoadParams) GetUniform

                func (m *LoadParams) GetUniform() *UniformParams

                func (*LoadParams) ProtoMessage

                func (*LoadParams) ProtoMessage()

                func (*LoadParams) Reset

                func (m *LoadParams) Reset()

                func (*LoadParams) String

                func (m *LoadParams) String() string

                func (*LoadParams) XXX_OneofFuncs

                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

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

                  type LoadParams_Determ

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

                  type LoadParams_Pareto

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

                  type LoadParams_Poisson

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

                  type LoadParams_Uniform

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

                  type Mark

                  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

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

                    func (*Mark) GetReset_

                    func (m *Mark) GetReset_() bool

                    func (*Mark) ProtoMessage

                    func (*Mark) ProtoMessage()

                    func (*Mark) Reset

                    func (m *Mark) Reset()

                    func (*Mark) String

                    func (m *Mark) String() string

                    type ParetoParams

                    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

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

                    func (*ParetoParams) GetAlpha

                    func (m *ParetoParams) GetAlpha() float64

                    func (*ParetoParams) GetInterarrivalBase

                    func (m *ParetoParams) GetInterarrivalBase() float64

                    func (*ParetoParams) ProtoMessage

                    func (*ParetoParams) ProtoMessage()

                    func (*ParetoParams) Reset

                    func (m *ParetoParams) Reset()

                    func (*ParetoParams) String

                    func (m *ParetoParams) String() string

                    type Payload

                    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

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

                      func (*Payload) GetBody

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

                      func (*Payload) GetType

                      func (m *Payload) GetType() PayloadType

                      func (*Payload) ProtoMessage

                      func (*Payload) ProtoMessage()

                      func (*Payload) Reset

                      func (m *Payload) Reset()

                      func (*Payload) String

                      func (m *Payload) String() string

                      type PayloadConfig

                      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

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

                      func (*PayloadConfig) GetBytebufParams

                      func (m *PayloadConfig) GetBytebufParams() *ByteBufferParams

                      func (*PayloadConfig) GetComplexParams

                      func (m *PayloadConfig) GetComplexParams() *ComplexProtoParams

                      func (*PayloadConfig) GetPayload

                      func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload

                      func (*PayloadConfig) GetSimpleParams

                      func (m *PayloadConfig) GetSimpleParams() *SimpleProtoParams

                      func (*PayloadConfig) ProtoMessage

                      func (*PayloadConfig) ProtoMessage()

                      func (*PayloadConfig) Reset

                      func (m *PayloadConfig) Reset()

                      func (*PayloadConfig) String

                      func (m *PayloadConfig) String() string

                      func (*PayloadConfig) XXX_OneofFuncs

                      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

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

                        type PayloadConfig_ComplexParams

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

                        type PayloadConfig_SimpleParams

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

                        type PayloadType

                        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

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

                          func (PayloadType) String

                          func (x PayloadType) String() string

                          type PoissonParams

                          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

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

                            func (*PoissonParams) GetOfferedLoad

                            func (m *PoissonParams) GetOfferedLoad() float64

                            func (*PoissonParams) ProtoMessage

                            func (*PoissonParams) ProtoMessage()

                            func (*PoissonParams) Reset

                            func (m *PoissonParams) Reset()

                            func (*PoissonParams) String

                            func (m *PoissonParams) String() string

                            type ReconnectInfo

                            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

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

                              func (*ReconnectInfo) GetBackoffMs

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

                              func (*ReconnectInfo) GetPassed

                              func (m *ReconnectInfo) GetPassed() bool

                              func (*ReconnectInfo) ProtoMessage

                              func (*ReconnectInfo) ProtoMessage()

                              func (*ReconnectInfo) Reset

                              func (m *ReconnectInfo) Reset()

                              func (*ReconnectInfo) String

                              func (m *ReconnectInfo) String() string

                              type ReconnectParams

                              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

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

                                func (*ReconnectParams) GetMaxReconnectBackoffMs

                                func (m *ReconnectParams) GetMaxReconnectBackoffMs() int32

                                func (*ReconnectParams) ProtoMessage

                                func (*ReconnectParams) ProtoMessage()

                                func (*ReconnectParams) Reset

                                func (m *ReconnectParams) Reset()

                                func (*ReconnectParams) String

                                func (m *ReconnectParams) String() string

                                type ResponseParameters

                                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

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

                                  func (*ResponseParameters) GetIntervalUs

                                  func (m *ResponseParameters) GetIntervalUs() int32

                                  func (*ResponseParameters) GetSize

                                  func (m *ResponseParameters) GetSize() int32

                                  func (*ResponseParameters) ProtoMessage

                                  func (*ResponseParameters) ProtoMessage()

                                  func (*ResponseParameters) Reset

                                  func (m *ResponseParameters) Reset()

                                  func (*ResponseParameters) String

                                  func (m *ResponseParameters) String() string

                                  type RpcType

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

                                  func (RpcType) EnumDescriptor

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

                                  func (RpcType) String

                                  func (x RpcType) String() string

                                  type Scenario

                                  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

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

                                    func (*Scenario) GetBenchmarkSeconds

                                    func (m *Scenario) GetBenchmarkSeconds() int32

                                    func (*Scenario) GetClientConfig

                                    func (m *Scenario) GetClientConfig() *ClientConfig

                                    func (*Scenario) GetName

                                    func (m *Scenario) GetName() string

                                    func (*Scenario) GetNumClients

                                    func (m *Scenario) GetNumClients() int32

                                    func (*Scenario) GetNumServers

                                    func (m *Scenario) GetNumServers() int32

                                    func (*Scenario) GetServerConfig

                                    func (m *Scenario) GetServerConfig() *ServerConfig

                                    func (*Scenario) GetSpawnLocalWorkerCount

                                    func (m *Scenario) GetSpawnLocalWorkerCount() int32

                                    func (*Scenario) GetWarmupSeconds

                                    func (m *Scenario) GetWarmupSeconds() int32

                                    func (*Scenario) ProtoMessage

                                    func (*Scenario) ProtoMessage()

                                    func (*Scenario) Reset

                                    func (m *Scenario) Reset()

                                    func (*Scenario) String

                                    func (m *Scenario) String() string

                                    type Scenarios

                                    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

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

                                      func (*Scenarios) GetScenarios

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

                                      func (*Scenarios) ProtoMessage

                                      func (*Scenarios) ProtoMessage()

                                      func (*Scenarios) Reset

                                      func (m *Scenarios) Reset()

                                      func (*Scenarios) String

                                      func (m *Scenarios) String() string

                                      type SecurityParams

                                      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

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

                                        func (*SecurityParams) GetServerHostOverride

                                        func (m *SecurityParams) GetServerHostOverride() string

                                        func (*SecurityParams) GetUseTestCa

                                        func (m *SecurityParams) GetUseTestCa() bool

                                        func (*SecurityParams) ProtoMessage

                                        func (*SecurityParams) ProtoMessage()

                                        func (*SecurityParams) Reset

                                        func (m *SecurityParams) Reset()

                                        func (*SecurityParams) String

                                        func (m *SecurityParams) String() string

                                        type ServerArgs

                                        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

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

                                        func (*ServerArgs) GetArgtype

                                        func (m *ServerArgs) GetArgtype() isServerArgs_Argtype

                                        func (*ServerArgs) GetMark

                                        func (m *ServerArgs) GetMark() *Mark

                                        func (*ServerArgs) GetSetup

                                        func (m *ServerArgs) GetSetup() *ServerConfig

                                        func (*ServerArgs) ProtoMessage

                                        func (*ServerArgs) ProtoMessage()

                                        func (*ServerArgs) Reset

                                        func (m *ServerArgs) Reset()

                                        func (*ServerArgs) String

                                        func (m *ServerArgs) String() string

                                        func (*ServerArgs) XXX_OneofFuncs

                                        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

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

                                          type ServerArgs_Setup

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

                                          type ServerConfig

                                          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

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

                                          func (*ServerConfig) GetAsyncServerThreads

                                          func (m *ServerConfig) GetAsyncServerThreads() int32

                                          func (*ServerConfig) GetCoreLimit

                                          func (m *ServerConfig) GetCoreLimit() int32

                                          func (*ServerConfig) GetCoreList

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

                                          func (*ServerConfig) GetPayloadConfig

                                          func (m *ServerConfig) GetPayloadConfig() *PayloadConfig

                                          func (*ServerConfig) GetPort

                                          func (m *ServerConfig) GetPort() int32

                                          func (*ServerConfig) GetSecurityParams

                                          func (m *ServerConfig) GetSecurityParams() *SecurityParams

                                          func (*ServerConfig) GetServerType

                                          func (m *ServerConfig) GetServerType() ServerType

                                          func (*ServerConfig) ProtoMessage

                                          func (*ServerConfig) ProtoMessage()

                                          func (*ServerConfig) Reset

                                          func (m *ServerConfig) Reset()

                                          func (*ServerConfig) String

                                          func (m *ServerConfig) String() string

                                          type ServerStats

                                          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

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

                                          func (*ServerStats) GetTimeElapsed

                                          func (m *ServerStats) GetTimeElapsed() float64

                                          func (*ServerStats) GetTimeSystem

                                          func (m *ServerStats) GetTimeSystem() float64

                                          func (*ServerStats) GetTimeUser

                                          func (m *ServerStats) GetTimeUser() float64

                                          func (*ServerStats) ProtoMessage

                                          func (*ServerStats) ProtoMessage()

                                          func (*ServerStats) Reset

                                          func (m *ServerStats) Reset()

                                          func (*ServerStats) String

                                          func (m *ServerStats) String() string

                                          type ServerStatus

                                          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

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

                                          func (*ServerStatus) GetCores

                                          func (m *ServerStatus) GetCores() int32

                                          func (*ServerStatus) GetPort

                                          func (m *ServerStatus) GetPort() int32

                                          func (*ServerStatus) GetStats

                                          func (m *ServerStatus) GetStats() *ServerStats

                                          func (*ServerStatus) ProtoMessage

                                          func (*ServerStatus) ProtoMessage()

                                          func (*ServerStatus) Reset

                                          func (m *ServerStatus) Reset()

                                          func (*ServerStatus) String

                                          func (m *ServerStatus) String() string

                                          type ServerType

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

                                          func (ServerType) EnumDescriptor

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

                                          func (ServerType) String

                                          func (x ServerType) String() string

                                          type SimpleProtoParams

                                          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

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

                                          func (*SimpleProtoParams) GetReqSize

                                          func (m *SimpleProtoParams) GetReqSize() int32

                                          func (*SimpleProtoParams) GetRespSize

                                          func (m *SimpleProtoParams) GetRespSize() int32

                                          func (*SimpleProtoParams) ProtoMessage

                                          func (*SimpleProtoParams) ProtoMessage()

                                          func (*SimpleProtoParams) Reset

                                          func (m *SimpleProtoParams) Reset()

                                          func (*SimpleProtoParams) String

                                          func (m *SimpleProtoParams) String() string

                                          type SimpleRequest

                                          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 `` /* 146-byte string literal not displayed */
                                          	// 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

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

                                            func (*SimpleRequest) GetFillOauthScope

                                            func (m *SimpleRequest) GetFillOauthScope() bool

                                            func (*SimpleRequest) GetFillUsername

                                            func (m *SimpleRequest) GetFillUsername() bool

                                            func (*SimpleRequest) GetPayload

                                            func (m *SimpleRequest) GetPayload() *Payload

                                            func (*SimpleRequest) GetResponseCompression

                                            func (m *SimpleRequest) GetResponseCompression() CompressionType

                                            func (*SimpleRequest) GetResponseSize

                                            func (m *SimpleRequest) GetResponseSize() int32

                                            func (*SimpleRequest) GetResponseStatus

                                            func (m *SimpleRequest) GetResponseStatus() *EchoStatus

                                            func (*SimpleRequest) GetResponseType

                                            func (m *SimpleRequest) GetResponseType() PayloadType

                                            func (*SimpleRequest) ProtoMessage

                                            func (*SimpleRequest) ProtoMessage()

                                            func (*SimpleRequest) Reset

                                            func (m *SimpleRequest) Reset()

                                            func (*SimpleRequest) String

                                            func (m *SimpleRequest) String() string

                                            type SimpleResponse

                                            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

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

                                              func (*SimpleResponse) GetOauthScope

                                              func (m *SimpleResponse) GetOauthScope() string

                                              func (*SimpleResponse) GetPayload

                                              func (m *SimpleResponse) GetPayload() *Payload

                                              func (*SimpleResponse) GetUsername

                                              func (m *SimpleResponse) GetUsername() string

                                              func (*SimpleResponse) ProtoMessage

                                              func (*SimpleResponse) ProtoMessage()

                                              func (*SimpleResponse) Reset

                                              func (m *SimpleResponse) Reset()

                                              func (*SimpleResponse) String

                                              func (m *SimpleResponse) String() string

                                              type StreamingInputCallRequest

                                              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

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

                                                func (*StreamingInputCallRequest) GetPayload

                                                func (m *StreamingInputCallRequest) GetPayload() *Payload

                                                func (*StreamingInputCallRequest) ProtoMessage

                                                func (*StreamingInputCallRequest) ProtoMessage()

                                                func (*StreamingInputCallRequest) Reset

                                                func (m *StreamingInputCallRequest) Reset()

                                                func (*StreamingInputCallRequest) String

                                                func (m *StreamingInputCallRequest) String() string

                                                type StreamingInputCallResponse

                                                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

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

                                                  func (*StreamingInputCallResponse) GetAggregatedPayloadSize

                                                  func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32

                                                  func (*StreamingInputCallResponse) ProtoMessage

                                                  func (*StreamingInputCallResponse) ProtoMessage()

                                                  func (*StreamingInputCallResponse) Reset

                                                  func (m *StreamingInputCallResponse) Reset()

                                                  func (*StreamingInputCallResponse) String

                                                  func (m *StreamingInputCallResponse) String() string

                                                  type StreamingOutputCallRequest

                                                  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 `` /* 146-byte string literal not displayed */
                                                  	// 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

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

                                                    func (*StreamingOutputCallRequest) GetPayload

                                                    func (m *StreamingOutputCallRequest) GetPayload() *Payload

                                                    func (*StreamingOutputCallRequest) GetResponseCompression

                                                    func (m *StreamingOutputCallRequest) GetResponseCompression() CompressionType

                                                    func (*StreamingOutputCallRequest) GetResponseParameters

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

                                                    func (*StreamingOutputCallRequest) GetResponseStatus

                                                    func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

                                                    func (*StreamingOutputCallRequest) GetResponseType

                                                    func (m *StreamingOutputCallRequest) GetResponseType() PayloadType

                                                    func (*StreamingOutputCallRequest) ProtoMessage

                                                    func (*StreamingOutputCallRequest) ProtoMessage()

                                                    func (*StreamingOutputCallRequest) Reset

                                                    func (m *StreamingOutputCallRequest) Reset()

                                                    func (*StreamingOutputCallRequest) String

                                                    func (m *StreamingOutputCallRequest) String() string

                                                    type StreamingOutputCallResponse

                                                    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

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

                                                      func (*StreamingOutputCallResponse) GetPayload

                                                      func (m *StreamingOutputCallResponse) GetPayload() *Payload

                                                      func (*StreamingOutputCallResponse) ProtoMessage

                                                      func (*StreamingOutputCallResponse) ProtoMessage()

                                                      func (*StreamingOutputCallResponse) Reset

                                                      func (m *StreamingOutputCallResponse) Reset()

                                                      func (*StreamingOutputCallResponse) String

                                                      func (m *StreamingOutputCallResponse) String() string

                                                      type UniformParams

                                                      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

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

                                                      func (*UniformParams) GetInterarrivalHi

                                                      func (m *UniformParams) GetInterarrivalHi() float64

                                                      func (*UniformParams) GetInterarrivalLo

                                                      func (m *UniformParams) GetInterarrivalLo() float64

                                                      func (*UniformParams) ProtoMessage

                                                      func (*UniformParams) ProtoMessage()

                                                      func (*UniformParams) Reset

                                                      func (m *UniformParams) Reset()

                                                      func (*UniformParams) String

                                                      func (m *UniformParams) String() string

                                                      type Void

                                                      type Void struct {
                                                      }

                                                      func (*Void) Descriptor

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

                                                      func (*Void) ProtoMessage

                                                      func (*Void) ProtoMessage()

                                                      func (*Void) Reset

                                                      func (m *Void) Reset()

                                                      func (*Void) String

                                                      func (m *Void) String() string

                                                      type WorkerServiceClient

                                                      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

                                                      func NewWorkerServiceClient(cc *grpc.ClientConn) WorkerServiceClient

                                                      type WorkerServiceServer

                                                      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

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

                                                      type WorkerService_RunClientServer

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

                                                      type WorkerService_RunServerClient

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

                                                      type WorkerService_RunServerServer

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