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

package grpc_testing

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

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)
}

BenchmarkServiceClient is the client API for BenchmarkService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

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
}

BenchmarkServiceServer is the server API for BenchmarkService service.

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,proto3" json:"req_size,omitempty"`
    RespSize             int32    `protobuf:"varint,2,opt,name=resp_size,json=respSize,proto3" json:"resp_size,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*ByteBufferParams) XXX_DiscardUnknown Uses

func (m *ByteBufferParams) XXX_DiscardUnknown()

func (*ByteBufferParams) XXX_Marshal Uses

func (m *ByteBufferParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ByteBufferParams) XXX_Merge Uses

func (dst *ByteBufferParams) XXX_Merge(src proto.Message)

func (*ByteBufferParams) XXX_Size Uses

func (m *ByteBufferParams) XXX_Size() int

func (*ByteBufferParams) XXX_Unmarshal Uses

func (m *ByteBufferParams) XXX_Unmarshal(b []byte) error

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"`
    XXX_NoUnkeyedLiteral struct{}             `json:"-"`
    XXX_unrecognized     []byte               `json:"-"`
    XXX_sizecache        int32                `json:"-"`
}

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_DiscardUnknown Uses

func (m *ClientArgs) XXX_DiscardUnknown()

func (*ClientArgs) XXX_Marshal Uses

func (m *ClientArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientArgs) XXX_Merge Uses

func (dst *ClientArgs) XXX_Merge(src proto.Message)

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.

func (*ClientArgs) XXX_Size Uses

func (m *ClientArgs) XXX_Size() int

func (*ClientArgs) XXX_Unmarshal Uses

func (m *ClientArgs) XXX_Unmarshal(b []byte) error

type ClientArgs_Mark Uses

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

type ClientArgs_Setup Uses

type ClientArgs_Setup struct {
    Setup *ClientConfig `protobuf:"bytes,1,opt,name=setup,proto3,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,proto3" json:"server_targets,omitempty"`
    ClientType     ClientType      `protobuf:"varint,2,opt,name=client_type,json=clientType,proto3,enum=grpc.testing.ClientType" json:"client_type,omitempty"`
    SecurityParams *SecurityParams `protobuf:"bytes,3,opt,name=security_params,json=securityParams,proto3" 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,proto3" 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,proto3" 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,proto3" json:"async_client_threads,omitempty"`
    RpcType            RpcType `protobuf:"varint,8,opt,name=rpc_type,json=rpcType,proto3,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,proto3" json:"load_params,omitempty"`
    PayloadConfig   *PayloadConfig   `protobuf:"bytes,11,opt,name=payload_config,json=payloadConfig,proto3" json:"payload_config,omitempty"`
    HistogramParams *HistogramParams `protobuf:"bytes,12,opt,name=histogram_params,json=histogramParams,proto3" 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,proto3" json:"core_list,omitempty"`
    CoreLimit            int32    `protobuf:"varint,14,opt,name=core_limit,json=coreLimit,proto3" json:"core_limit,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*ClientConfig) XXX_DiscardUnknown Uses

func (m *ClientConfig) XXX_DiscardUnknown()

func (*ClientConfig) XXX_Marshal Uses

func (m *ClientConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientConfig) XXX_Merge Uses

func (dst *ClientConfig) XXX_Merge(src proto.Message)

func (*ClientConfig) XXX_Size Uses

func (m *ClientConfig) XXX_Size() int

func (*ClientConfig) XXX_Unmarshal Uses

func (m *ClientConfig) XXX_Unmarshal(b []byte) error

type ClientStats Uses

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

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

func (*ClientStats) XXX_DiscardUnknown Uses

func (m *ClientStats) XXX_DiscardUnknown()

func (*ClientStats) XXX_Marshal Uses

func (m *ClientStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientStats) XXX_Merge Uses

func (dst *ClientStats) XXX_Merge(src proto.Message)

func (*ClientStats) XXX_Size Uses

func (m *ClientStats) XXX_Size() int

func (*ClientStats) XXX_Unmarshal Uses

func (m *ClientStats) XXX_Unmarshal(b []byte) error

type ClientStatus Uses

type ClientStatus struct {
    Stats                *ClientStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
    XXX_NoUnkeyedLiteral struct{}     `json:"-"`
    XXX_unrecognized     []byte       `json:"-"`
    XXX_sizecache        int32        `json:"-"`
}

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

func (*ClientStatus) XXX_DiscardUnknown Uses

func (m *ClientStatus) XXX_DiscardUnknown()

func (*ClientStatus) XXX_Marshal Uses

func (m *ClientStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientStatus) XXX_Merge Uses

func (dst *ClientStatus) XXX_Merge(src proto.Message)

func (*ClientStatus) XXX_Size Uses

func (m *ClientStatus) XXX_Size() int

func (*ClientStatus) XXX_Unmarshal Uses

func (m *ClientStatus) XXX_Unmarshal(b []byte) error

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 {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*ClosedLoopParams) XXX_DiscardUnknown Uses

func (m *ClosedLoopParams) XXX_DiscardUnknown()

func (*ClosedLoopParams) XXX_Marshal Uses

func (m *ClosedLoopParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClosedLoopParams) XXX_Merge Uses

func (dst *ClosedLoopParams) XXX_Merge(src proto.Message)

func (*ClosedLoopParams) XXX_Size Uses

func (m *ClosedLoopParams) XXX_Size() int

func (*ClosedLoopParams) XXX_Unmarshal Uses

func (m *ClosedLoopParams) XXX_Unmarshal(b []byte) error

type ComplexProtoParams Uses

type ComplexProtoParams struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*ComplexProtoParams) XXX_DiscardUnknown Uses

func (m *ComplexProtoParams) XXX_DiscardUnknown()

func (*ComplexProtoParams) XXX_Marshal Uses

func (m *ComplexProtoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ComplexProtoParams) XXX_Merge Uses

func (dst *ComplexProtoParams) XXX_Merge(src proto.Message)

func (*ComplexProtoParams) XXX_Size Uses

func (m *ComplexProtoParams) XXX_Size() int

func (*ComplexProtoParams) XXX_Unmarshal Uses

func (m *ComplexProtoParams) XXX_Unmarshal(b []byte) error

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 {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*CoreRequest) XXX_DiscardUnknown Uses

func (m *CoreRequest) XXX_DiscardUnknown()

func (*CoreRequest) XXX_Marshal Uses

func (m *CoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CoreRequest) XXX_Merge Uses

func (dst *CoreRequest) XXX_Merge(src proto.Message)

func (*CoreRequest) XXX_Size Uses

func (m *CoreRequest) XXX_Size() int

func (*CoreRequest) XXX_Unmarshal Uses

func (m *CoreRequest) XXX_Unmarshal(b []byte) error

type CoreResponse Uses

type CoreResponse struct {
    // Number of cores available on the server
    Cores                int32    `protobuf:"varint,1,opt,name=cores,proto3" json:"cores,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*CoreResponse) XXX_DiscardUnknown Uses

func (m *CoreResponse) XXX_DiscardUnknown()

func (*CoreResponse) XXX_Marshal Uses

func (m *CoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CoreResponse) XXX_Merge Uses

func (dst *CoreResponse) XXX_Merge(src proto.Message)

func (*CoreResponse) XXX_Size Uses

func (m *CoreResponse) XXX_Size() int

func (*CoreResponse) XXX_Unmarshal Uses

func (m *CoreResponse) XXX_Unmarshal(b []byte) error

type DeterministicParams Uses

type DeterministicParams struct {
    OfferedLoad          float64  `protobuf:"fixed64,1,opt,name=offered_load,json=offeredLoad,proto3" json:"offered_load,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*DeterministicParams) XXX_DiscardUnknown Uses

func (m *DeterministicParams) XXX_DiscardUnknown()

func (*DeterministicParams) XXX_Marshal Uses

func (m *DeterministicParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeterministicParams) XXX_Merge Uses

func (dst *DeterministicParams) XXX_Merge(src proto.Message)

func (*DeterministicParams) XXX_Size Uses

func (m *DeterministicParams) XXX_Size() int

func (*DeterministicParams) XXX_Unmarshal Uses

func (m *DeterministicParams) XXX_Unmarshal(b []byte) error

type EchoStatus Uses

type EchoStatus struct {
    Code                 int32    `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
    Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*EchoStatus) XXX_DiscardUnknown Uses

func (m *EchoStatus) XXX_DiscardUnknown()

func (*EchoStatus) XXX_Marshal Uses

func (m *EchoStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoStatus) XXX_Merge Uses

func (dst *EchoStatus) XXX_Merge(src proto.Message)

func (*EchoStatus) XXX_Size Uses

func (m *EchoStatus) XXX_Size() int

func (*EchoStatus) XXX_Unmarshal Uses

func (m *EchoStatus) XXX_Unmarshal(b []byte) error

type HistogramData Uses

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

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

func (*HistogramData) XXX_DiscardUnknown Uses

func (m *HistogramData) XXX_DiscardUnknown()

func (*HistogramData) XXX_Marshal Uses

func (m *HistogramData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HistogramData) XXX_Merge Uses

func (dst *HistogramData) XXX_Merge(src proto.Message)

func (*HistogramData) XXX_Size Uses

func (m *HistogramData) XXX_Size() int

func (*HistogramData) XXX_Unmarshal Uses

func (m *HistogramData) XXX_Unmarshal(b []byte) error

type HistogramParams Uses

type HistogramParams struct {
    Resolution           float64  `protobuf:"fixed64,1,opt,name=resolution,proto3" json:"resolution,omitempty"`
    MaxPossible          float64  `protobuf:"fixed64,2,opt,name=max_possible,json=maxPossible,proto3" json:"max_possible,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*HistogramParams) XXX_DiscardUnknown Uses

func (m *HistogramParams) XXX_DiscardUnknown()

func (*HistogramParams) XXX_Marshal Uses

func (m *HistogramParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HistogramParams) XXX_Merge Uses

func (dst *HistogramParams) XXX_Merge(src proto.Message)

func (*HistogramParams) XXX_Size Uses

func (m *HistogramParams) XXX_Size() int

func (*HistogramParams) XXX_Unmarshal Uses

func (m *HistogramParams) XXX_Unmarshal(b []byte) error

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"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

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_DiscardUnknown Uses

func (m *LoadParams) XXX_DiscardUnknown()

func (*LoadParams) XXX_Marshal Uses

func (m *LoadParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadParams) XXX_Merge Uses

func (dst *LoadParams) XXX_Merge(src proto.Message)

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.

func (*LoadParams) XXX_Size Uses

func (m *LoadParams) XXX_Size() int

func (*LoadParams) XXX_Unmarshal Uses

func (m *LoadParams) XXX_Unmarshal(b []byte) error

type LoadParams_ClosedLoop Uses

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

type LoadParams_Determ Uses

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

type LoadParams_Pareto Uses

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

type LoadParams_Poisson Uses

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

type LoadParams_Uniform Uses

type LoadParams_Uniform struct {
    Uniform *UniformParams `protobuf:"bytes,3,opt,name=uniform,proto3,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,proto3" json:"reset,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*Mark) XXX_DiscardUnknown Uses

func (m *Mark) XXX_DiscardUnknown()

func (*Mark) XXX_Marshal Uses

func (m *Mark) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Mark) XXX_Merge Uses

func (dst *Mark) XXX_Merge(src proto.Message)

func (*Mark) XXX_Size Uses

func (m *Mark) XXX_Size() int

func (*Mark) XXX_Unmarshal Uses

func (m *Mark) XXX_Unmarshal(b []byte) error

type ParetoParams Uses

type ParetoParams struct {
    InterarrivalBase     float64  `protobuf:"fixed64,1,opt,name=interarrival_base,json=interarrivalBase,proto3" json:"interarrival_base,omitempty"`
    Alpha                float64  `protobuf:"fixed64,2,opt,name=alpha,proto3" json:"alpha,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*ParetoParams) XXX_DiscardUnknown Uses

func (m *ParetoParams) XXX_DiscardUnknown()

func (*ParetoParams) XXX_Marshal Uses

func (m *ParetoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ParetoParams) XXX_Merge Uses

func (dst *ParetoParams) XXX_Merge(src proto.Message)

func (*ParetoParams) XXX_Size Uses

func (m *ParetoParams) XXX_Size() int

func (*ParetoParams) XXX_Unmarshal Uses

func (m *ParetoParams) XXX_Unmarshal(b []byte) error

type Payload Uses

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

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

func (*Payload) XXX_DiscardUnknown Uses

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal Uses

func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Payload) XXX_Merge Uses

func (dst *Payload) XXX_Merge(src proto.Message)

func (*Payload) XXX_Size Uses

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal Uses

func (m *Payload) XXX_Unmarshal(b []byte) error

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"`
    XXX_NoUnkeyedLiteral struct{}                `json:"-"`
    XXX_unrecognized     []byte                  `json:"-"`
    XXX_sizecache        int32                   `json:"-"`
}

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_DiscardUnknown Uses

func (m *PayloadConfig) XXX_DiscardUnknown()

func (*PayloadConfig) XXX_Marshal Uses

func (m *PayloadConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PayloadConfig) XXX_Merge Uses

func (dst *PayloadConfig) XXX_Merge(src proto.Message)

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.

func (*PayloadConfig) XXX_Size Uses

func (m *PayloadConfig) XXX_Size() int

func (*PayloadConfig) XXX_Unmarshal Uses

func (m *PayloadConfig) XXX_Unmarshal(b []byte) error

type PayloadConfig_BytebufParams Uses

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

type PayloadConfig_ComplexParams Uses

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

type PayloadConfig_SimpleParams Uses

type PayloadConfig_SimpleParams struct {
    SimpleParams *SimpleProtoParams `protobuf:"bytes,2,opt,name=simple_params,json=simpleParams,proto3,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,proto3" json:"offered_load,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*PoissonParams) XXX_DiscardUnknown Uses

func (m *PoissonParams) XXX_DiscardUnknown()

func (*PoissonParams) XXX_Marshal Uses

func (m *PoissonParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PoissonParams) XXX_Merge Uses

func (dst *PoissonParams) XXX_Merge(src proto.Message)

func (*PoissonParams) XXX_Size Uses

func (m *PoissonParams) XXX_Size() int

func (*PoissonParams) XXX_Unmarshal Uses

func (m *PoissonParams) XXX_Unmarshal(b []byte) error

type ReconnectInfo Uses

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

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

func (*ReconnectInfo) XXX_DiscardUnknown Uses

func (m *ReconnectInfo) XXX_DiscardUnknown()

func (*ReconnectInfo) XXX_Marshal Uses

func (m *ReconnectInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReconnectInfo) XXX_Merge Uses

func (dst *ReconnectInfo) XXX_Merge(src proto.Message)

func (*ReconnectInfo) XXX_Size Uses

func (m *ReconnectInfo) XXX_Size() int

func (*ReconnectInfo) XXX_Unmarshal Uses

func (m *ReconnectInfo) XXX_Unmarshal(b []byte) error

type ReconnectParams Uses

type ReconnectParams struct {
    MaxReconnectBackoffMs int32    `protobuf:"varint,1,opt,name=max_reconnect_backoff_ms,json=maxReconnectBackoffMs,proto3" json:"max_reconnect_backoff_ms,omitempty"`
    XXX_NoUnkeyedLiteral  struct{} `json:"-"`
    XXX_unrecognized      []byte   `json:"-"`
    XXX_sizecache         int32    `json:"-"`
}

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

func (*ReconnectParams) XXX_DiscardUnknown Uses

func (m *ReconnectParams) XXX_DiscardUnknown()

func (*ReconnectParams) XXX_Marshal Uses

func (m *ReconnectParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReconnectParams) XXX_Merge Uses

func (dst *ReconnectParams) XXX_Merge(src proto.Message)

func (*ReconnectParams) XXX_Size Uses

func (m *ReconnectParams) XXX_Size() int

func (*ReconnectParams) XXX_Unmarshal Uses

func (m *ReconnectParams) XXX_Unmarshal(b []byte) error

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,proto3" 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,proto3" json:"interval_us,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*ResponseParameters) XXX_DiscardUnknown Uses

func (m *ResponseParameters) XXX_DiscardUnknown()

func (*ResponseParameters) XXX_Marshal Uses

func (m *ResponseParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResponseParameters) XXX_Merge Uses

func (dst *ResponseParameters) XXX_Merge(src proto.Message)

func (*ResponseParameters) XXX_Size Uses

func (m *ResponseParameters) XXX_Size() int

func (*ResponseParameters) XXX_Unmarshal Uses

func (m *ResponseParameters) XXX_Unmarshal(b []byte) error

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,proto3" json:"name,omitempty"`
    // Client configuration
    ClientConfig *ClientConfig `protobuf:"bytes,2,opt,name=client_config,json=clientConfig,proto3" json:"client_config,omitempty"`
    // Number of clients to start for the test
    NumClients int32 `protobuf:"varint,3,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"`
    // Server configuration
    ServerConfig *ServerConfig `protobuf:"bytes,4,opt,name=server_config,json=serverConfig,proto3" json:"server_config,omitempty"`
    // Number of servers to start for the test
    NumServers int32 `protobuf:"varint,5,opt,name=num_servers,json=numServers,proto3" json:"num_servers,omitempty"`
    // Warmup period, in seconds
    WarmupSeconds int32 `protobuf:"varint,6,opt,name=warmup_seconds,json=warmupSeconds,proto3" json:"warmup_seconds,omitempty"`
    // Benchmark time, in seconds
    BenchmarkSeconds int32 `protobuf:"varint,7,opt,name=benchmark_seconds,json=benchmarkSeconds,proto3" 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,proto3" json:"spawn_local_worker_count,omitempty"`
    XXX_NoUnkeyedLiteral  struct{} `json:"-"`
    XXX_unrecognized      []byte   `json:"-"`
    XXX_sizecache         int32    `json:"-"`
}

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

func (*Scenario) XXX_DiscardUnknown Uses

func (m *Scenario) XXX_DiscardUnknown()

func (*Scenario) XXX_Marshal Uses

func (m *Scenario) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Scenario) XXX_Merge Uses

func (dst *Scenario) XXX_Merge(src proto.Message)

func (*Scenario) XXX_Size Uses

func (m *Scenario) XXX_Size() int

func (*Scenario) XXX_Unmarshal Uses

func (m *Scenario) XXX_Unmarshal(b []byte) error

type Scenarios Uses

type Scenarios struct {
    Scenarios            []*Scenario `protobuf:"bytes,1,rep,name=scenarios,proto3" json:"scenarios,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

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

func (*Scenarios) XXX_DiscardUnknown Uses

func (m *Scenarios) XXX_DiscardUnknown()

func (*Scenarios) XXX_Marshal Uses

func (m *Scenarios) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Scenarios) XXX_Merge Uses

func (dst *Scenarios) XXX_Merge(src proto.Message)

func (*Scenarios) XXX_Size Uses

func (m *Scenarios) XXX_Size() int

func (*Scenarios) XXX_Unmarshal Uses

func (m *Scenarios) XXX_Unmarshal(b []byte) error

type SecurityParams Uses

type SecurityParams struct {
    UseTestCa            bool     `protobuf:"varint,1,opt,name=use_test_ca,json=useTestCa,proto3" json:"use_test_ca,omitempty"`
    ServerHostOverride   string   `protobuf:"bytes,2,opt,name=server_host_override,json=serverHostOverride,proto3" json:"server_host_override,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*SecurityParams) XXX_DiscardUnknown Uses

func (m *SecurityParams) XXX_DiscardUnknown()

func (*SecurityParams) XXX_Marshal Uses

func (m *SecurityParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SecurityParams) XXX_Merge Uses

func (dst *SecurityParams) XXX_Merge(src proto.Message)

func (*SecurityParams) XXX_Size Uses

func (m *SecurityParams) XXX_Size() int

func (*SecurityParams) XXX_Unmarshal Uses

func (m *SecurityParams) XXX_Unmarshal(b []byte) error

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"`
    XXX_NoUnkeyedLiteral struct{}             `json:"-"`
    XXX_unrecognized     []byte               `json:"-"`
    XXX_sizecache        int32                `json:"-"`
}

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_DiscardUnknown Uses

func (m *ServerArgs) XXX_DiscardUnknown()

func (*ServerArgs) XXX_Marshal Uses

func (m *ServerArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerArgs) XXX_Merge Uses

func (dst *ServerArgs) XXX_Merge(src proto.Message)

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.

func (*ServerArgs) XXX_Size Uses

func (m *ServerArgs) XXX_Size() int

func (*ServerArgs) XXX_Unmarshal Uses

func (m *ServerArgs) XXX_Unmarshal(b []byte) error

type ServerArgs_Mark Uses

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

type ServerArgs_Setup Uses

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

type ServerConfig Uses

type ServerConfig struct {
    ServerType     ServerType      `protobuf:"varint,1,opt,name=server_type,json=serverType,proto3,enum=grpc.testing.ServerType" json:"server_type,omitempty"`
    SecurityParams *SecurityParams `protobuf:"bytes,2,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"`
    // Port on which to listen. Zero means pick unused port.
    Port int32 `protobuf:"varint,4,opt,name=port,proto3" 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,proto3" 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,proto3" json:"core_limit,omitempty"`
    // payload config, used in generic server
    PayloadConfig *PayloadConfig `protobuf:"bytes,9,opt,name=payload_config,json=payloadConfig,proto3" 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,proto3" json:"core_list,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*ServerConfig) XXX_DiscardUnknown Uses

func (m *ServerConfig) XXX_DiscardUnknown()

func (*ServerConfig) XXX_Marshal Uses

func (m *ServerConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerConfig) XXX_Merge Uses

func (dst *ServerConfig) XXX_Merge(src proto.Message)

func (*ServerConfig) XXX_Size Uses

func (m *ServerConfig) XXX_Size() int

func (*ServerConfig) XXX_Unmarshal Uses

func (m *ServerConfig) XXX_Unmarshal(b []byte) error

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,proto3" 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,proto3" 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,proto3" json:"time_system,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*ServerStats) XXX_DiscardUnknown Uses

func (m *ServerStats) XXX_DiscardUnknown()

func (*ServerStats) XXX_Marshal Uses

func (m *ServerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerStats) XXX_Merge Uses

func (dst *ServerStats) XXX_Merge(src proto.Message)

func (*ServerStats) XXX_Size Uses

func (m *ServerStats) XXX_Size() int

func (*ServerStats) XXX_Unmarshal Uses

func (m *ServerStats) XXX_Unmarshal(b []byte) error

type ServerStatus Uses

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

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

func (*ServerStatus) XXX_DiscardUnknown Uses

func (m *ServerStatus) XXX_DiscardUnknown()

func (*ServerStatus) XXX_Marshal Uses

func (m *ServerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerStatus) XXX_Merge Uses

func (dst *ServerStatus) XXX_Merge(src proto.Message)

func (*ServerStatus) XXX_Size Uses

func (m *ServerStatus) XXX_Size() int

func (*ServerStatus) XXX_Unmarshal Uses

func (m *ServerStatus) XXX_Unmarshal(b []byte) error

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,proto3" json:"req_size,omitempty"`
    RespSize             int32    `protobuf:"varint,2,opt,name=resp_size,json=respSize,proto3" json:"resp_size,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*SimpleProtoParams) XXX_DiscardUnknown Uses

func (m *SimpleProtoParams) XXX_DiscardUnknown()

func (*SimpleProtoParams) XXX_Marshal Uses

func (m *SimpleProtoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SimpleProtoParams) XXX_Merge Uses

func (dst *SimpleProtoParams) XXX_Merge(src proto.Message)

func (*SimpleProtoParams) XXX_Size Uses

func (m *SimpleProtoParams) XXX_Size() int

func (*SimpleProtoParams) XXX_Unmarshal Uses

func (m *SimpleProtoParams) XXX_Unmarshal(b []byte) error

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,proto3,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,proto3" json:"response_size,omitempty"`
    // Optional input payload sent along with the request.
    Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
    // Whether SimpleResponse should include username.
    FillUsername bool `protobuf:"varint,4,opt,name=fill_username,json=fillUsername,proto3" json:"fill_username,omitempty"`
    // Whether SimpleResponse should include OAuth scope.
    FillOauthScope bool `protobuf:"varint,5,opt,name=fill_oauth_scope,json=fillOauthScope,proto3" 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,proto3,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,proto3" json:"response_status,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

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

func (*SimpleRequest) XXX_DiscardUnknown Uses

func (m *SimpleRequest) XXX_DiscardUnknown()

func (*SimpleRequest) XXX_Marshal Uses

func (m *SimpleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SimpleRequest) XXX_Merge Uses

func (dst *SimpleRequest) XXX_Merge(src proto.Message)

func (*SimpleRequest) XXX_Size Uses

func (m *SimpleRequest) XXX_Size() int

func (*SimpleRequest) XXX_Unmarshal Uses

func (m *SimpleRequest) XXX_Unmarshal(b []byte) error

type SimpleResponse Uses

type SimpleResponse struct {
    // Payload to increase message size.
    Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" 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,proto3" json:"username,omitempty"`
    // OAuth scope.
    OauthScope           string   `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope,proto3" json:"oauth_scope,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*SimpleResponse) XXX_DiscardUnknown Uses

func (m *SimpleResponse) XXX_DiscardUnknown()

func (*SimpleResponse) XXX_Marshal Uses

func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SimpleResponse) XXX_Merge Uses

func (dst *SimpleResponse) XXX_Merge(src proto.Message)

func (*SimpleResponse) XXX_Size Uses

func (m *SimpleResponse) XXX_Size() int

func (*SimpleResponse) XXX_Unmarshal Uses

func (m *SimpleResponse) XXX_Unmarshal(b []byte) error

type StreamingInputCallRequest Uses

type StreamingInputCallRequest struct {
    // Optional input payload sent along with the request.
    Payload              *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*StreamingInputCallRequest) XXX_DiscardUnknown Uses

func (m *StreamingInputCallRequest) XXX_DiscardUnknown()

func (*StreamingInputCallRequest) XXX_Marshal Uses

func (m *StreamingInputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingInputCallRequest) XXX_Merge Uses

func (dst *StreamingInputCallRequest) XXX_Merge(src proto.Message)

func (*StreamingInputCallRequest) XXX_Size Uses

func (m *StreamingInputCallRequest) XXX_Size() int

func (*StreamingInputCallRequest) XXX_Unmarshal Uses

func (m *StreamingInputCallRequest) XXX_Unmarshal(b []byte) error

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,proto3" json:"aggregated_payload_size,omitempty"`
    XXX_NoUnkeyedLiteral  struct{} `json:"-"`
    XXX_unrecognized      []byte   `json:"-"`
    XXX_sizecache         int32    `json:"-"`
}

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

func (*StreamingInputCallResponse) XXX_DiscardUnknown Uses

func (m *StreamingInputCallResponse) XXX_DiscardUnknown()

func (*StreamingInputCallResponse) XXX_Marshal Uses

func (m *StreamingInputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingInputCallResponse) XXX_Merge Uses

func (dst *StreamingInputCallResponse) XXX_Merge(src proto.Message)

func (*StreamingInputCallResponse) XXX_Size Uses

func (m *StreamingInputCallResponse) XXX_Size() int

func (*StreamingInputCallResponse) XXX_Unmarshal Uses

func (m *StreamingInputCallResponse) XXX_Unmarshal(b []byte) error

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,proto3,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,proto3" json:"response_parameters,omitempty"`
    // Optional input payload sent along with the request.
    Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" 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,proto3,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,proto3" json:"response_status,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

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

func (*StreamingOutputCallRequest) XXX_DiscardUnknown Uses

func (m *StreamingOutputCallRequest) XXX_DiscardUnknown()

func (*StreamingOutputCallRequest) XXX_Marshal Uses

func (m *StreamingOutputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingOutputCallRequest) XXX_Merge Uses

func (dst *StreamingOutputCallRequest) XXX_Merge(src proto.Message)

func (*StreamingOutputCallRequest) XXX_Size Uses

func (m *StreamingOutputCallRequest) XXX_Size() int

func (*StreamingOutputCallRequest) XXX_Unmarshal Uses

func (m *StreamingOutputCallRequest) XXX_Unmarshal(b []byte) error

type StreamingOutputCallResponse Uses

type StreamingOutputCallResponse struct {
    // Payload to increase response size.
    Payload              *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*StreamingOutputCallResponse) XXX_DiscardUnknown Uses

func (m *StreamingOutputCallResponse) XXX_DiscardUnknown()

func (*StreamingOutputCallResponse) XXX_Marshal Uses

func (m *StreamingOutputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingOutputCallResponse) XXX_Merge Uses

func (dst *StreamingOutputCallResponse) XXX_Merge(src proto.Message)

func (*StreamingOutputCallResponse) XXX_Size Uses

func (m *StreamingOutputCallResponse) XXX_Size() int

func (*StreamingOutputCallResponse) XXX_Unmarshal Uses

func (m *StreamingOutputCallResponse) XXX_Unmarshal(b []byte) error

type UniformParams Uses

type UniformParams struct {
    InterarrivalLo       float64  `protobuf:"fixed64,1,opt,name=interarrival_lo,json=interarrivalLo,proto3" json:"interarrival_lo,omitempty"`
    InterarrivalHi       float64  `protobuf:"fixed64,2,opt,name=interarrival_hi,json=interarrivalHi,proto3" json:"interarrival_hi,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*UniformParams) XXX_DiscardUnknown Uses

func (m *UniformParams) XXX_DiscardUnknown()

func (*UniformParams) XXX_Marshal Uses

func (m *UniformParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UniformParams) XXX_Merge Uses

func (dst *UniformParams) XXX_Merge(src proto.Message)

func (*UniformParams) XXX_Size Uses

func (m *UniformParams) XXX_Size() int

func (*UniformParams) XXX_Unmarshal Uses

func (m *UniformParams) XXX_Unmarshal(b []byte) error

type Void Uses

type Void struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*Void) XXX_DiscardUnknown Uses

func (m *Void) XXX_DiscardUnknown()

func (*Void) XXX_Marshal Uses

func (m *Void) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Void) XXX_Merge Uses

func (dst *Void) XXX_Merge(src proto.Message)

func (*Void) XXX_Size Uses

func (m *Void) XXX_Size() int

func (*Void) XXX_Unmarshal Uses

func (m *Void) XXX_Unmarshal(b []byte) error

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)
}

WorkerServiceClient is the client API for WorkerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

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)
}

WorkerServiceServer is the server API for WorkerService service.

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 52 packages. Updated 2018-06-09. Refresh now. Tools for package owners.