dbtester: github.com/etcd-io/dbtester/dbtesterpb Index | Files

package dbtesterpb

import "github.com/etcd-io/dbtester/dbtesterpb"

Package dbtesterpb is a generated protocol buffer package.

It is generated from these files:

dbtesterpb/config_analyze_machine.proto
dbtesterpb/config_client_machine.proto
dbtesterpb/database_id.proto
dbtesterpb/flag_cetcd.proto
dbtesterpb/flag_consul.proto
dbtesterpb/flag_etcd.proto
dbtesterpb/flag_zetcd.proto
dbtesterpb/flag_zookeeper.proto
dbtesterpb/message.proto

It has these top-level messages:

ConfigAnalyzeMachineInitial
ConfigAnalyzeMachineAllAggregatedOutput
ConfigAnalyzeMachinePlot
ConfigAnalyzeMachineImage
ConfigAnalyzeMachineREADME
ConfigClientMachineInitial
ConfigClientMachineBenchmarkOptions
ConfigClientMachineBenchmarkSteps
ConfigClientMachineAgentControl
Flag_Cetcd_Beta
Flag_Consul_V1_0_2
Flag_Etcd_Other
Flag_Etcd_Tip
Flag_Etcd_V3_2
Flag_Etcd_V3_3
Flag_Zetcd_Beta
Flag_Zookeeper_R3_5_3Beta
Request
Response

Index

Package Files

config_analyze_machine.pb.go config_client_machine.pb.go database_id.pb.go flag_cetcd.pb.go flag_consul.pb.go flag_etcd.pb.go flag_zetcd.pb.go flag_zookeeper.pb.go message.pb.go util.go

Variables

var (
    ErrInvalidLengthConfigAnalyzeMachine = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowConfigAnalyzeMachine   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthConfigClientMachine = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowConfigClientMachine   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthFlagCetcd = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowFlagCetcd   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthFlagConsul = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowFlagConsul   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthFlagEtcd = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowFlagEtcd   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthFlagZetcd = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowFlagZetcd   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthFlagZookeeper = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowFlagZookeeper   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowMessage   = fmt.Errorf("proto: integer overflow")
)
var DatabaseID_name = map[int32]string{
    0:   "etcd__other",
    1:   "etcd__tip",
    2:   "etcd__v3_2",
    3:   "etcd__v3_3",
    100: "zookeeper__r3_5_3_beta",
    200: "consul__v1_0_2",
    300: "zetcd__beta",
    400: "cetcd__beta",
}
var DatabaseID_value = map[string]int32{
    "etcd__other":            0,
    "etcd__tip":              1,
    "etcd__v3_2":             2,
    "etcd__v3_3":             3,
    "zookeeper__r3_5_3_beta": 100,
    "consul__v1_0_2":         200,
    "zetcd__beta":            300,
    "cetcd__beta":            400,
}
var Operation_name = map[int32]string{
    0:  "Start",
    1:  "Stop",
    2:  "Heartbeat",
}
var Operation_value = map[string]int32{
    "Start":     0,
    "Stop":      1,
    "Heartbeat": 2,
}

func GetAllDatabaseIDs Uses

func GetAllDatabaseIDs() []string

GetAllDatabaseIDs returns all database ids.

func GetRGBI Uses

func GetRGBI(databaseID string, i int) color.Color

func GetRGBII Uses

func GetRGBII(databaseID string, i int) color.Color

func GetRGBIII Uses

func GetRGBIII(databaseID string, i int) color.Color

func IsValidDatabaseID Uses

func IsValidDatabaseID(id string) bool

IsValidDatabaseID returns false if the database id is not supported.

func RegisterTransporterServer Uses

func RegisterTransporterServer(s *grpc.Server, srv TransporterServer)

type ConfigAnalyzeMachineAllAggregatedOutput Uses

type ConfigAnalyzeMachineAllAggregatedOutput struct {
    AllAggregatedOutputPathCSV string `protobuf:"bytes,1,opt,name=AllAggregatedOutputPathCSV,proto3" json:"AllAggregatedOutputPathCSV,omitempty" yaml:"all_aggregated_output_path_csv"`
    AllAggregatedOutputPathTXT string `protobuf:"bytes,2,opt,name=AllAggregatedOutputPathTXT,proto3" json:"AllAggregatedOutputPathTXT,omitempty" yaml:"all_aggregated_output_path_txt"`
}

func (*ConfigAnalyzeMachineAllAggregatedOutput) Descriptor Uses

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

func (*ConfigAnalyzeMachineAllAggregatedOutput) Marshal Uses

func (m *ConfigAnalyzeMachineAllAggregatedOutput) Marshal() (dAtA []byte, err error)

func (*ConfigAnalyzeMachineAllAggregatedOutput) MarshalTo Uses

func (m *ConfigAnalyzeMachineAllAggregatedOutput) MarshalTo(dAtA []byte) (int, error)

func (*ConfigAnalyzeMachineAllAggregatedOutput) ProtoMessage Uses

func (*ConfigAnalyzeMachineAllAggregatedOutput) ProtoMessage()

func (*ConfigAnalyzeMachineAllAggregatedOutput) Reset Uses

func (m *ConfigAnalyzeMachineAllAggregatedOutput) Reset()

func (*ConfigAnalyzeMachineAllAggregatedOutput) Size Uses

func (m *ConfigAnalyzeMachineAllAggregatedOutput) Size() (n int)

func (*ConfigAnalyzeMachineAllAggregatedOutput) String Uses

func (m *ConfigAnalyzeMachineAllAggregatedOutput) String() string

func (*ConfigAnalyzeMachineAllAggregatedOutput) Unmarshal Uses

func (m *ConfigAnalyzeMachineAllAggregatedOutput) Unmarshal(dAtA []byte) error

type ConfigAnalyzeMachineImage Uses

type ConfigAnalyzeMachineImage struct {
    Title string `protobuf:"bytes,1,opt,name=Title,proto3" json:"Title,omitempty" yaml:"title"`
    Path  string `protobuf:"bytes,2,opt,name=Path,proto3" json:"Path,omitempty" yaml:"path"`
    Type  string `protobuf:"bytes,3,opt,name=Type,proto3" json:"Type,omitempty" yaml:"type"`
}

ConfigAnalyzeMachineImage defines image configuration.

func (*ConfigAnalyzeMachineImage) Descriptor Uses

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

func (*ConfigAnalyzeMachineImage) Marshal Uses

func (m *ConfigAnalyzeMachineImage) Marshal() (dAtA []byte, err error)

func (*ConfigAnalyzeMachineImage) MarshalTo Uses

func (m *ConfigAnalyzeMachineImage) MarshalTo(dAtA []byte) (int, error)

func (*ConfigAnalyzeMachineImage) ProtoMessage Uses

func (*ConfigAnalyzeMachineImage) ProtoMessage()

func (*ConfigAnalyzeMachineImage) Reset Uses

func (m *ConfigAnalyzeMachineImage) Reset()

func (*ConfigAnalyzeMachineImage) Size Uses

func (m *ConfigAnalyzeMachineImage) Size() (n int)

func (*ConfigAnalyzeMachineImage) String Uses

func (m *ConfigAnalyzeMachineImage) String() string

func (*ConfigAnalyzeMachineImage) Unmarshal Uses

func (m *ConfigAnalyzeMachineImage) Unmarshal(dAtA []byte) error

type ConfigAnalyzeMachineInitial Uses

type ConfigAnalyzeMachineInitial struct {
    DatabaseID                              string   `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
    DatabaseTag                             string   `protobuf:"bytes,2,opt,name=DatabaseTag,proto3" json:"DatabaseTag,omitempty"`
    DatabaseDescription                     string   `protobuf:"bytes,3,opt,name=DatabaseDescription,proto3" json:"DatabaseDescription,omitempty"`
    PathPrefix                              string   `protobuf:"bytes,4,opt,name=PathPrefix,proto3" json:"PathPrefix,omitempty" yaml:"path_prefix"`
    ClientSystemMetricsInterpolatedPath     string   `protobuf:"bytes,5,opt,name=ClientSystemMetricsInterpolatedPath,proto3" json:"ClientSystemMetricsInterpolatedPath,omitempty" yaml:"client_system_metrics_interpolated_path"`
    ClientLatencyThroughputTimeseriesPath   string   `protobuf:"bytes,6,opt,name=ClientLatencyThroughputTimeseriesPath,proto3" json:"ClientLatencyThroughputTimeseriesPath,omitempty" yaml:"client_latency_throughput_timeseries_path"`
    ClientLatencyDistributionAllPath        string   `protobuf:"bytes,7,opt,name=ClientLatencyDistributionAllPath,proto3" json:"ClientLatencyDistributionAllPath,omitempty" yaml:"client_latency_distribution_all_path"`
    ClientLatencyDistributionPercentilePath string   `protobuf:"bytes,8,opt,name=ClientLatencyDistributionPercentilePath,proto3" json:"ClientLatencyDistributionPercentilePath,omitempty" yaml:"client_latency_distribution_percentile_path"`
    ClientLatencyDistributionSummaryPath    string   `protobuf:"bytes,9,opt,name=ClientLatencyDistributionSummaryPath,proto3" json:"ClientLatencyDistributionSummaryPath,omitempty" yaml:"client_latency_distribution_summary_path"`
    ClientLatencyByKeyNumberPath            string   `protobuf:"bytes,10,opt,name=ClientLatencyByKeyNumberPath,proto3" json:"ClientLatencyByKeyNumberPath,omitempty" yaml:"client_latency_by_key_number_path"`
    ServerDiskSpaceUsageSummaryPath         string   `protobuf:"bytes,11,opt,name=ServerDiskSpaceUsageSummaryPath,proto3" json:"ServerDiskSpaceUsageSummaryPath,omitempty" yaml:"server_disk_space_usage_summary_path"`
    ServerMemoryByKeyNumberPath             string   `protobuf:"bytes,12,opt,name=ServerMemoryByKeyNumberPath,proto3" json:"ServerMemoryByKeyNumberPath,omitempty" yaml:"server_memory_by_key_number_path"`
    ServerReadBytesDeltaByKeyNumberPath     string   `protobuf:"bytes,13,opt,name=ServerReadBytesDeltaByKeyNumberPath,proto3" json:"ServerReadBytesDeltaByKeyNumberPath,omitempty" yaml:"server_read_bytes_delta_by_key_number_path"`
    ServerWriteBytesDeltaByKeyNumberPath    string   `protobuf:"bytes,14,opt,name=ServerWriteBytesDeltaByKeyNumberPath,proto3" json:"ServerWriteBytesDeltaByKeyNumberPath,omitempty" yaml:"server_write_bytes_delta_by_key_number_path"`
    ServerSystemMetricsInterpolatedPathList []string `protobuf:"bytes,15,rep,name=ServerSystemMetricsInterpolatedPathList" json:"ServerSystemMetricsInterpolatedPathList,omitempty" yaml:"server_system_metrics_interpolated_path_list"`
    AllAggregatedOutputPath                 string   `protobuf:"bytes,16,opt,name=AllAggregatedOutputPath,proto3" json:"AllAggregatedOutputPath,omitempty" yaml:"all_aggregated_output_path"`
}

ConfigAnalyzeMachineInitial represents common control options and test data information for analyzer machine.

func (*ConfigAnalyzeMachineInitial) Descriptor Uses

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

func (*ConfigAnalyzeMachineInitial) Marshal Uses

func (m *ConfigAnalyzeMachineInitial) Marshal() (dAtA []byte, err error)

func (*ConfigAnalyzeMachineInitial) MarshalTo Uses

func (m *ConfigAnalyzeMachineInitial) MarshalTo(dAtA []byte) (int, error)

func (*ConfigAnalyzeMachineInitial) ProtoMessage Uses

func (*ConfigAnalyzeMachineInitial) ProtoMessage()

func (*ConfigAnalyzeMachineInitial) Reset Uses

func (m *ConfigAnalyzeMachineInitial) Reset()

func (*ConfigAnalyzeMachineInitial) Size Uses

func (m *ConfigAnalyzeMachineInitial) Size() (n int)

func (*ConfigAnalyzeMachineInitial) String Uses

func (m *ConfigAnalyzeMachineInitial) String() string

func (*ConfigAnalyzeMachineInitial) Unmarshal Uses

func (m *ConfigAnalyzeMachineInitial) Unmarshal(dAtA []byte) error

type ConfigAnalyzeMachinePlot Uses

type ConfigAnalyzeMachinePlot struct {
    Column         string   `protobuf:"bytes,1,opt,name=Column,proto3" json:"Column,omitempty" yaml:"column"`
    XAxis          string   `protobuf:"bytes,2,opt,name=XAxis,proto3" json:"XAxis,omitempty" yaml:"x_axis"`
    YAxis          string   `protobuf:"bytes,3,opt,name=YAxis,proto3" json:"YAxis,omitempty" yaml:"y_axis"`
    OutputPathCSV  string   `protobuf:"bytes,4,opt,name=OutputPathCSV,proto3" json:"OutputPathCSV,omitempty" yaml:"output_path_csv"`
    OutputPathList []string `protobuf:"bytes,5,rep,name=OutputPathList" json:"OutputPathList,omitempty" yaml:"output_path_list"`
}

ConfigAnalyzeMachinePlot defines plot configuration.

func (*ConfigAnalyzeMachinePlot) Descriptor Uses

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

func (*ConfigAnalyzeMachinePlot) Marshal Uses

func (m *ConfigAnalyzeMachinePlot) Marshal() (dAtA []byte, err error)

func (*ConfigAnalyzeMachinePlot) MarshalTo Uses

func (m *ConfigAnalyzeMachinePlot) MarshalTo(dAtA []byte) (int, error)

func (*ConfigAnalyzeMachinePlot) ProtoMessage Uses

func (*ConfigAnalyzeMachinePlot) ProtoMessage()

func (*ConfigAnalyzeMachinePlot) Reset Uses

func (m *ConfigAnalyzeMachinePlot) Reset()

func (*ConfigAnalyzeMachinePlot) Size Uses

func (m *ConfigAnalyzeMachinePlot) Size() (n int)

func (*ConfigAnalyzeMachinePlot) String Uses

func (m *ConfigAnalyzeMachinePlot) String() string

func (*ConfigAnalyzeMachinePlot) Unmarshal Uses

func (m *ConfigAnalyzeMachinePlot) Unmarshal(dAtA []byte) error

type ConfigAnalyzeMachineREADME Uses

type ConfigAnalyzeMachineREADME struct {
    OutputPath string                       `protobuf:"bytes,1,opt,name=OutputPath,proto3" json:"OutputPath,omitempty" yaml:"output_path"`
    Images     []*ConfigAnalyzeMachineImage `protobuf:"bytes,2,rep,name=Images" json:"Images,omitempty" yaml:"images"`
}

ConfigAnalyzeMachineREADME defines read configuration.

func (*ConfigAnalyzeMachineREADME) Descriptor Uses

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

func (*ConfigAnalyzeMachineREADME) Marshal Uses

func (m *ConfigAnalyzeMachineREADME) Marshal() (dAtA []byte, err error)

func (*ConfigAnalyzeMachineREADME) MarshalTo Uses

func (m *ConfigAnalyzeMachineREADME) MarshalTo(dAtA []byte) (int, error)

func (*ConfigAnalyzeMachineREADME) ProtoMessage Uses

func (*ConfigAnalyzeMachineREADME) ProtoMessage()

func (*ConfigAnalyzeMachineREADME) Reset Uses

func (m *ConfigAnalyzeMachineREADME) Reset()

func (*ConfigAnalyzeMachineREADME) Size Uses

func (m *ConfigAnalyzeMachineREADME) Size() (n int)

func (*ConfigAnalyzeMachineREADME) String Uses

func (m *ConfigAnalyzeMachineREADME) String() string

func (*ConfigAnalyzeMachineREADME) Unmarshal Uses

func (m *ConfigAnalyzeMachineREADME) Unmarshal(dAtA []byte) error

type ConfigClientMachineAgentControl Uses

type ConfigClientMachineAgentControl struct {
    DatabaseID                          string                               `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty" yaml:"database_id"`
    DatabaseDescription                 string                               `protobuf:"bytes,2,opt,name=DatabaseDescription,proto3" json:"DatabaseDescription,omitempty" yaml:"database_description"`
    DatabaseTag                         string                               `protobuf:"bytes,3,opt,name=DatabaseTag,proto3" json:"DatabaseTag,omitempty" yaml:"database_tag"`
    PeerIPs                             []string                             `protobuf:"bytes,4,rep,name=PeerIPs" json:"PeerIPs,omitempty" yaml:"peer_ips"`
    PeerIPsString                       string                               `protobuf:"bytes,5,opt,name=PeerIPsString,proto3" json:"PeerIPsString,omitempty" yaml:"peer_ips_string"`
    AgentPortToConnect                  int64                                `protobuf:"varint,6,opt,name=AgentPortToConnect,proto3" json:"AgentPortToConnect,omitempty" yaml:"agent_port_to_connect"`
    AgentEndpoints                      []string                             `protobuf:"bytes,7,rep,name=AgentEndpoints" json:"AgentEndpoints,omitempty" yaml:"agent_endpoints"`
    DatabasePortToConnect               int64                                `protobuf:"varint,8,opt,name=DatabasePortToConnect,proto3" json:"DatabasePortToConnect,omitempty" yaml:"database_port_to_connect"`
    DatabaseEndpoints                   []string                             `protobuf:"bytes,9,rep,name=DatabaseEndpoints" json:"DatabaseEndpoints,omitempty" yaml:"database_endpoints"`
    Flag_Etcd_Other                     *Flag_Etcd_Other                     `protobuf:"bytes,100,opt,name=flag__etcd__other,json=flagEtcdOther" json:"flag__etcd__other,omitempty" yaml:"etcd__other"`
    Flag_Etcd_Tip                       *Flag_Etcd_Tip                       `protobuf:"bytes,101,opt,name=flag__etcd__tip,json=flagEtcdTip" json:"flag__etcd__tip,omitempty" yaml:"etcd__tip"`
    Flag_Etcd_V3_2                      *Flag_Etcd_V3_2                      `protobuf:"bytes,102,opt,name=flag__etcd__v3_2,json=flagEtcdV32" json:"flag__etcd__v3_2,omitempty" yaml:"etcd__v3_2"`
    Flag_Etcd_V3_3                      *Flag_Etcd_V3_3                      `protobuf:"bytes,103,opt,name=flag__etcd__v3_3,json=flagEtcdV33" json:"flag__etcd__v3_3,omitempty" yaml:"etcd__v3_3"`
    Flag_Zookeeper_R3_5_3Beta           *Flag_Zookeeper_R3_5_3Beta           `protobuf:"bytes,200,opt,name=flag__zookeeper__r3_5_3_beta,json=flagZookeeperR353Beta" json:"flag__zookeeper__r3_5_3_beta,omitempty" yaml:"zookeeper__r3_5_3_beta"`
    Flag_Consul_V1_0_2                  *Flag_Consul_V1_0_2                  `protobuf:"bytes,300,opt,name=flag__consul__v1_0_2,json=flagConsulV102" json:"flag__consul__v1_0_2,omitempty" yaml:"consul__v1_0_2"`
    Flag_Cetcd_Beta                     *Flag_Cetcd_Beta                     `protobuf:"bytes,400,opt,name=flag__cetcd__beta,json=flagCetcdBeta" json:"flag__cetcd__beta,omitempty" yaml:"cetcd__beta"`
    Flag_Zetcd_Beta                     *Flag_Zetcd_Beta                     `protobuf:"bytes,500,opt,name=flag__zetcd__beta,json=flagZetcdBeta" json:"flag__zetcd__beta,omitempty" yaml:"zetcd__beta"`
    ConfigClientMachineBenchmarkOptions *ConfigClientMachineBenchmarkOptions `protobuf:"bytes,1000,opt,name=ConfigClientMachineBenchmarkOptions" json:"ConfigClientMachineBenchmarkOptions,omitempty" yaml:"benchmark_options"`
    ConfigClientMachineBenchmarkSteps   *ConfigClientMachineBenchmarkSteps   `protobuf:"bytes,1001,opt,name=ConfigClientMachineBenchmarkSteps" json:"ConfigClientMachineBenchmarkSteps,omitempty" yaml:"benchmark_steps"`
}

ConfigClientMachineAgentControl represents control options on client machine.

func (*ConfigClientMachineAgentControl) Descriptor Uses

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

func (*ConfigClientMachineAgentControl) Marshal Uses

func (m *ConfigClientMachineAgentControl) Marshal() (dAtA []byte, err error)

func (*ConfigClientMachineAgentControl) MarshalTo Uses

func (m *ConfigClientMachineAgentControl) MarshalTo(dAtA []byte) (int, error)

func (*ConfigClientMachineAgentControl) ProtoMessage Uses

func (*ConfigClientMachineAgentControl) ProtoMessage()

func (*ConfigClientMachineAgentControl) Reset Uses

func (m *ConfigClientMachineAgentControl) Reset()

func (*ConfigClientMachineAgentControl) Size Uses

func (m *ConfigClientMachineAgentControl) Size() (n int)

func (*ConfigClientMachineAgentControl) String Uses

func (m *ConfigClientMachineAgentControl) String() string

func (*ConfigClientMachineAgentControl) Unmarshal Uses

func (m *ConfigClientMachineAgentControl) Unmarshal(dAtA []byte) error

type ConfigClientMachineBenchmarkOptions Uses

type ConfigClientMachineBenchmarkOptions struct {
    Type                       string  `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty" yaml:"type"`
    RequestNumber              int64   `protobuf:"varint,2,opt,name=RequestNumber,proto3" json:"RequestNumber,omitempty" yaml:"request_number"`
    ConnectionNumber           int64   `protobuf:"varint,3,opt,name=ConnectionNumber,proto3" json:"ConnectionNumber,omitempty" yaml:"connection_number"`
    ClientNumber               int64   `protobuf:"varint,4,opt,name=ClientNumber,proto3" json:"ClientNumber,omitempty" yaml:"client_number"`
    ConnectionClientNumbers    []int64 `protobuf:"varint,5,rep,packed,name=ConnectionClientNumbers" json:"ConnectionClientNumbers,omitempty" yaml:"connection_client_numbers"`
    RateLimitRequestsPerSecond int64   `protobuf:"varint,6,opt,name=RateLimitRequestsPerSecond,proto3" json:"RateLimitRequestsPerSecond,omitempty" yaml:"rate_limit_requests_per_second"`
    SameKey                    bool    `protobuf:"varint,7,opt,name=SameKey,proto3" json:"SameKey,omitempty" yaml:"same_key"`
    KeySizeBytes               int64   `protobuf:"varint,8,opt,name=KeySizeBytes,proto3" json:"KeySizeBytes,omitempty" yaml:"key_size_bytes"`
    ValueSizeBytes             int64   `protobuf:"varint,9,opt,name=ValueSizeBytes,proto3" json:"ValueSizeBytes,omitempty" yaml:"value_size_bytes"`
    StaleRead                  bool    `protobuf:"varint,10,opt,name=StaleRead,proto3" json:"StaleRead,omitempty" yaml:"stale_read"`
}

ConfigClientMachineBenchmarkOptions represents benchmark options.

func (*ConfigClientMachineBenchmarkOptions) Descriptor Uses

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

func (*ConfigClientMachineBenchmarkOptions) Marshal Uses

func (m *ConfigClientMachineBenchmarkOptions) Marshal() (dAtA []byte, err error)

func (*ConfigClientMachineBenchmarkOptions) MarshalTo Uses

func (m *ConfigClientMachineBenchmarkOptions) MarshalTo(dAtA []byte) (int, error)

func (*ConfigClientMachineBenchmarkOptions) ProtoMessage Uses

func (*ConfigClientMachineBenchmarkOptions) ProtoMessage()

func (*ConfigClientMachineBenchmarkOptions) Reset Uses

func (m *ConfigClientMachineBenchmarkOptions) Reset()

func (*ConfigClientMachineBenchmarkOptions) Size Uses

func (m *ConfigClientMachineBenchmarkOptions) Size() (n int)

func (*ConfigClientMachineBenchmarkOptions) String Uses

func (m *ConfigClientMachineBenchmarkOptions) String() string

func (*ConfigClientMachineBenchmarkOptions) Unmarshal Uses

func (m *ConfigClientMachineBenchmarkOptions) Unmarshal(dAtA []byte) error

type ConfigClientMachineBenchmarkSteps Uses

type ConfigClientMachineBenchmarkSteps struct {
    Step1StartDatabase  bool `protobuf:"varint,1,opt,name=Step1StartDatabase,proto3" json:"Step1StartDatabase,omitempty" yaml:"step1_start_database"`
    Step2StressDatabase bool `protobuf:"varint,2,opt,name=Step2StressDatabase,proto3" json:"Step2StressDatabase,omitempty" yaml:"step2_stress_database"`
    Step3StopDatabase   bool `protobuf:"varint,3,opt,name=Step3StopDatabase,proto3" json:"Step3StopDatabase,omitempty" yaml:"step3_stop_database"`
    Step4UploadLogs     bool `protobuf:"varint,4,opt,name=Step4UploadLogs,proto3" json:"Step4UploadLogs,omitempty" yaml:"step4_upload_logs"`
}

ConfigClientMachineBenchmarkSteps represents benchmark steps.

func (*ConfigClientMachineBenchmarkSteps) Descriptor Uses

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

func (*ConfigClientMachineBenchmarkSteps) Marshal Uses

func (m *ConfigClientMachineBenchmarkSteps) Marshal() (dAtA []byte, err error)

func (*ConfigClientMachineBenchmarkSteps) MarshalTo Uses

func (m *ConfigClientMachineBenchmarkSteps) MarshalTo(dAtA []byte) (int, error)

func (*ConfigClientMachineBenchmarkSteps) ProtoMessage Uses

func (*ConfigClientMachineBenchmarkSteps) ProtoMessage()

func (*ConfigClientMachineBenchmarkSteps) Reset Uses

func (m *ConfigClientMachineBenchmarkSteps) Reset()

func (*ConfigClientMachineBenchmarkSteps) Size Uses

func (m *ConfigClientMachineBenchmarkSteps) Size() (n int)

func (*ConfigClientMachineBenchmarkSteps) String Uses

func (m *ConfigClientMachineBenchmarkSteps) String() string

func (*ConfigClientMachineBenchmarkSteps) Unmarshal Uses

func (m *ConfigClientMachineBenchmarkSteps) Unmarshal(dAtA []byte) error

type ConfigClientMachineInitial Uses

type ConfigClientMachineInitial struct {
    PathPrefix                              string `protobuf:"bytes,1,opt,name=PathPrefix,proto3" json:"PathPrefix,omitempty" yaml:"path_prefix"`
    LogPath                                 string `protobuf:"bytes,2,opt,name=LogPath,proto3" json:"LogPath,omitempty" yaml:"log_path"`
    ClientSystemMetricsPath                 string `protobuf:"bytes,3,opt,name=ClientSystemMetricsPath,proto3" json:"ClientSystemMetricsPath,omitempty" yaml:"client_system_metrics_path"`
    ClientSystemMetricsInterpolatedPath     string `protobuf:"bytes,4,opt,name=ClientSystemMetricsInterpolatedPath,proto3" json:"ClientSystemMetricsInterpolatedPath,omitempty" yaml:"client_system_metrics_interpolated_path"`
    ClientLatencyThroughputTimeseriesPath   string `protobuf:"bytes,5,opt,name=ClientLatencyThroughputTimeseriesPath,proto3" json:"ClientLatencyThroughputTimeseriesPath,omitempty" yaml:"client_latency_throughput_timeseries_path"`
    ClientLatencyDistributionAllPath        string `protobuf:"bytes,6,opt,name=ClientLatencyDistributionAllPath,proto3" json:"ClientLatencyDistributionAllPath,omitempty" yaml:"client_latency_distribution_all_path"`
    ClientLatencyDistributionPercentilePath string `protobuf:"bytes,7,opt,name=ClientLatencyDistributionPercentilePath,proto3" json:"ClientLatencyDistributionPercentilePath,omitempty" yaml:"client_latency_distribution_percentile_path"`
    ClientLatencyDistributionSummaryPath    string `protobuf:"bytes,8,opt,name=ClientLatencyDistributionSummaryPath,proto3" json:"ClientLatencyDistributionSummaryPath,omitempty" yaml:"client_latency_distribution_summary_path"`
    ClientLatencyByKeyNumberPath            string `protobuf:"bytes,9,opt,name=ClientLatencyByKeyNumberPath,proto3" json:"ClientLatencyByKeyNumberPath,omitempty" yaml:"client_latency_by_key_number_path"`
    ServerDiskSpaceUsageSummaryPath         string `protobuf:"bytes,10,opt,name=ServerDiskSpaceUsageSummaryPath,proto3" json:"ServerDiskSpaceUsageSummaryPath,omitempty" yaml:"server_disk_space_usage_summary_path"`
    GoogleCloudProjectName                  string `protobuf:"bytes,100,opt,name=GoogleCloudProjectName,proto3" json:"GoogleCloudProjectName,omitempty" yaml:"google_cloud_project_name"`
    GoogleCloudStorageKeyPath               string `protobuf:"bytes,101,opt,name=GoogleCloudStorageKeyPath,proto3" json:"GoogleCloudStorageKeyPath,omitempty" yaml:"google_cloud_storage_key_path"`
    GoogleCloudStorageKey                   string `protobuf:"bytes,102,opt,name=GoogleCloudStorageKey,proto3" json:"GoogleCloudStorageKey,omitempty"`
    GoogleCloudStorageBucketName            string `protobuf:"bytes,103,opt,name=GoogleCloudStorageBucketName,proto3" json:"GoogleCloudStorageBucketName,omitempty" yaml:"google_cloud_storage_bucket_name"`
    GoogleCloudStorageSubDirectory          string `protobuf:"bytes,104,opt,name=GoogleCloudStorageSubDirectory,proto3" json:"GoogleCloudStorageSubDirectory,omitempty" yaml:"google_cloud_storage_sub_directory"`
}

ConfigClientMachineInitial represents common control options on client machine.

func (*ConfigClientMachineInitial) Descriptor Uses

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

func (*ConfigClientMachineInitial) Marshal Uses

func (m *ConfigClientMachineInitial) Marshal() (dAtA []byte, err error)

func (*ConfigClientMachineInitial) MarshalTo Uses

func (m *ConfigClientMachineInitial) MarshalTo(dAtA []byte) (int, error)

func (*ConfigClientMachineInitial) ProtoMessage Uses

func (*ConfigClientMachineInitial) ProtoMessage()

func (*ConfigClientMachineInitial) Reset Uses

func (m *ConfigClientMachineInitial) Reset()

func (*ConfigClientMachineInitial) Size Uses

func (m *ConfigClientMachineInitial) Size() (n int)

func (*ConfigClientMachineInitial) String Uses

func (m *ConfigClientMachineInitial) String() string

func (*ConfigClientMachineInitial) Unmarshal Uses

func (m *ConfigClientMachineInitial) Unmarshal(dAtA []byte) error

type DatabaseID Uses

type DatabaseID int32

DatabaseID differentiates between major or minor releases (possibly different APIs) of each database. Make sure to make accordingn changes in 'flag_*' whenever an ID is added/removed.

const (
    // https://github.com/coreos/etcd/releases
    DatabaseID_etcd__other DatabaseID = 0
    DatabaseID_etcd__tip   DatabaseID = 1
    DatabaseID_etcd__v3_2  DatabaseID = 2
    DatabaseID_etcd__v3_3  DatabaseID = 3
    // https://zookeeper.apache.org/releases.html
    DatabaseID_zookeeper__r3_5_3_beta DatabaseID = 100
    // https://github.com/hashicorp/consul/releases
    DatabaseID_consul__v1_0_2 DatabaseID = 200
    // https://github.com/coreos/zetcd/releases
    DatabaseID_zetcd__beta DatabaseID = 300
    // https://github.com/coreos/cetcd/releases
    DatabaseID_cetcd__beta DatabaseID = 400
)

func (DatabaseID) EnumDescriptor Uses

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

func (DatabaseID) String Uses

func (x DatabaseID) String() string

type Flag_Cetcd_Beta Uses

type Flag_Cetcd_Beta struct {
}

Flag_Cetcd_Beta is cetcd-specific flags (https://github.com/coreos/cetcd).

func (*Flag_Cetcd_Beta) Descriptor Uses

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

func (*Flag_Cetcd_Beta) Marshal Uses

func (m *Flag_Cetcd_Beta) Marshal() (dAtA []byte, err error)

func (*Flag_Cetcd_Beta) MarshalTo Uses

func (m *Flag_Cetcd_Beta) MarshalTo(dAtA []byte) (int, error)

func (*Flag_Cetcd_Beta) ProtoMessage Uses

func (*Flag_Cetcd_Beta) ProtoMessage()

func (*Flag_Cetcd_Beta) Reset Uses

func (m *Flag_Cetcd_Beta) Reset()

func (*Flag_Cetcd_Beta) Size Uses

func (m *Flag_Cetcd_Beta) Size() (n int)

func (*Flag_Cetcd_Beta) String Uses

func (m *Flag_Cetcd_Beta) String() string

func (*Flag_Cetcd_Beta) Unmarshal Uses

func (m *Flag_Cetcd_Beta) Unmarshal(dAtA []byte) error

type Flag_Consul_V1_0_2 Uses

type Flag_Consul_V1_0_2 struct {
}

See https://github.com/hashicorp/consul for more.

func (*Flag_Consul_V1_0_2) Descriptor Uses

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

func (*Flag_Consul_V1_0_2) Marshal Uses

func (m *Flag_Consul_V1_0_2) Marshal() (dAtA []byte, err error)

func (*Flag_Consul_V1_0_2) MarshalTo Uses

func (m *Flag_Consul_V1_0_2) MarshalTo(dAtA []byte) (int, error)

func (*Flag_Consul_V1_0_2) ProtoMessage Uses

func (*Flag_Consul_V1_0_2) ProtoMessage()

func (*Flag_Consul_V1_0_2) Reset Uses

func (m *Flag_Consul_V1_0_2) Reset()

func (*Flag_Consul_V1_0_2) Size Uses

func (m *Flag_Consul_V1_0_2) Size() (n int)

func (*Flag_Consul_V1_0_2) String Uses

func (m *Flag_Consul_V1_0_2) String() string

func (*Flag_Consul_V1_0_2) Unmarshal Uses

func (m *Flag_Consul_V1_0_2) Unmarshal(dAtA []byte) error

type Flag_Etcd_Other Uses

type Flag_Etcd_Other struct {
    SnapshotCount  int64 `protobuf:"varint,1,opt,name=SnapshotCount,proto3" json:"SnapshotCount,omitempty" yaml:"snapshot_count"`
    QuotaSizeBytes int64 `protobuf:"varint,2,opt,name=QuotaSizeBytes,proto3" json:"QuotaSizeBytes,omitempty" yaml:"quota_size_bytes"`
}

See https://github.com/coreos/etcd/blob/master/etcdmain/help.go for more.

func (*Flag_Etcd_Other) Descriptor Uses

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

func (*Flag_Etcd_Other) Marshal Uses

func (m *Flag_Etcd_Other) Marshal() (dAtA []byte, err error)

func (*Flag_Etcd_Other) MarshalTo Uses

func (m *Flag_Etcd_Other) MarshalTo(dAtA []byte) (int, error)

func (*Flag_Etcd_Other) ProtoMessage Uses

func (*Flag_Etcd_Other) ProtoMessage()

func (*Flag_Etcd_Other) Reset Uses

func (m *Flag_Etcd_Other) Reset()

func (*Flag_Etcd_Other) Size Uses

func (m *Flag_Etcd_Other) Size() (n int)

func (*Flag_Etcd_Other) String Uses

func (m *Flag_Etcd_Other) String() string

func (*Flag_Etcd_Other) Unmarshal Uses

func (m *Flag_Etcd_Other) Unmarshal(dAtA []byte) error

type Flag_Etcd_Tip Uses

type Flag_Etcd_Tip struct {
    SnapshotCount  int64 `protobuf:"varint,1,opt,name=SnapshotCount,proto3" json:"SnapshotCount,omitempty" yaml:"snapshot_count"`
    QuotaSizeBytes int64 `protobuf:"varint,2,opt,name=QuotaSizeBytes,proto3" json:"QuotaSizeBytes,omitempty" yaml:"quota_size_bytes"`
}

See https://github.com/coreos/etcd/blob/master/etcdmain/help.go for more.

func (*Flag_Etcd_Tip) Descriptor Uses

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

func (*Flag_Etcd_Tip) Marshal Uses

func (m *Flag_Etcd_Tip) Marshal() (dAtA []byte, err error)

func (*Flag_Etcd_Tip) MarshalTo Uses

func (m *Flag_Etcd_Tip) MarshalTo(dAtA []byte) (int, error)

func (*Flag_Etcd_Tip) ProtoMessage Uses

func (*Flag_Etcd_Tip) ProtoMessage()

func (*Flag_Etcd_Tip) Reset Uses

func (m *Flag_Etcd_Tip) Reset()

func (*Flag_Etcd_Tip) Size Uses

func (m *Flag_Etcd_Tip) Size() (n int)

func (*Flag_Etcd_Tip) String Uses

func (m *Flag_Etcd_Tip) String() string

func (*Flag_Etcd_Tip) Unmarshal Uses

func (m *Flag_Etcd_Tip) Unmarshal(dAtA []byte) error

type Flag_Etcd_V3_2 Uses

type Flag_Etcd_V3_2 struct {
    SnapshotCount  int64 `protobuf:"varint,1,opt,name=SnapshotCount,proto3" json:"SnapshotCount,omitempty" yaml:"snapshot_count"`
    QuotaSizeBytes int64 `protobuf:"varint,2,opt,name=QuotaSizeBytes,proto3" json:"QuotaSizeBytes,omitempty" yaml:"quota_size_bytes"`
}

See https://github.com/coreos/etcd/blob/master/etcdmain/help.go for more.

func (*Flag_Etcd_V3_2) Descriptor Uses

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

func (*Flag_Etcd_V3_2) Marshal Uses

func (m *Flag_Etcd_V3_2) Marshal() (dAtA []byte, err error)

func (*Flag_Etcd_V3_2) MarshalTo Uses

func (m *Flag_Etcd_V3_2) MarshalTo(dAtA []byte) (int, error)

func (*Flag_Etcd_V3_2) ProtoMessage Uses

func (*Flag_Etcd_V3_2) ProtoMessage()

func (*Flag_Etcd_V3_2) Reset Uses

func (m *Flag_Etcd_V3_2) Reset()

func (*Flag_Etcd_V3_2) Size Uses

func (m *Flag_Etcd_V3_2) Size() (n int)

func (*Flag_Etcd_V3_2) String Uses

func (m *Flag_Etcd_V3_2) String() string

func (*Flag_Etcd_V3_2) Unmarshal Uses

func (m *Flag_Etcd_V3_2) Unmarshal(dAtA []byte) error

type Flag_Etcd_V3_3 Uses

type Flag_Etcd_V3_3 struct {
    SnapshotCount  int64 `protobuf:"varint,1,opt,name=SnapshotCount,proto3" json:"SnapshotCount,omitempty" yaml:"snapshot_count"`
    QuotaSizeBytes int64 `protobuf:"varint,2,opt,name=QuotaSizeBytes,proto3" json:"QuotaSizeBytes,omitempty" yaml:"quota_size_bytes"`
}

See https://github.com/coreos/etcd/blob/master/etcdmain/help.go for more.

func (*Flag_Etcd_V3_3) Descriptor Uses

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

func (*Flag_Etcd_V3_3) Marshal Uses

func (m *Flag_Etcd_V3_3) Marshal() (dAtA []byte, err error)

func (*Flag_Etcd_V3_3) MarshalTo Uses

func (m *Flag_Etcd_V3_3) MarshalTo(dAtA []byte) (int, error)

func (*Flag_Etcd_V3_3) ProtoMessage Uses

func (*Flag_Etcd_V3_3) ProtoMessage()

func (*Flag_Etcd_V3_3) Reset Uses

func (m *Flag_Etcd_V3_3) Reset()

func (*Flag_Etcd_V3_3) Size Uses

func (m *Flag_Etcd_V3_3) Size() (n int)

func (*Flag_Etcd_V3_3) String Uses

func (m *Flag_Etcd_V3_3) String() string

func (*Flag_Etcd_V3_3) Unmarshal Uses

func (m *Flag_Etcd_V3_3) Unmarshal(dAtA []byte) error

type Flag_Zetcd_Beta Uses

type Flag_Zetcd_Beta struct {
}

Flag_Zetcd_Beta is zetcd-specific flags (https://github.com/coreos/zetcd).

func (*Flag_Zetcd_Beta) Descriptor Uses

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

func (*Flag_Zetcd_Beta) Marshal Uses

func (m *Flag_Zetcd_Beta) Marshal() (dAtA []byte, err error)

func (*Flag_Zetcd_Beta) MarshalTo Uses

func (m *Flag_Zetcd_Beta) MarshalTo(dAtA []byte) (int, error)

func (*Flag_Zetcd_Beta) ProtoMessage Uses

func (*Flag_Zetcd_Beta) ProtoMessage()

func (*Flag_Zetcd_Beta) Reset Uses

func (m *Flag_Zetcd_Beta) Reset()

func (*Flag_Zetcd_Beta) Size Uses

func (m *Flag_Zetcd_Beta) Size() (n int)

func (*Flag_Zetcd_Beta) String Uses

func (m *Flag_Zetcd_Beta) String() string

func (*Flag_Zetcd_Beta) Unmarshal Uses

func (m *Flag_Zetcd_Beta) Unmarshal(dAtA []byte) error

type Flag_Zookeeper_R3_5_3Beta Uses

type Flag_Zookeeper_R3_5_3Beta struct {
    // JavaDJuteMaxBuffer is for '-Djute.maxbuffer' flag.
    // It is the maximum size, in bytes, of a request or response.
    // See http://zookeeper.apache.org/doc/trunk/zookeeperAdmin.html#Unsafe+Options for more.
    JavaDJuteMaxBuffer uint64 `protobuf:"varint,1,opt,name=JavaDJuteMaxBuffer,proto3" json:"JavaDJuteMaxBuffer,omitempty" yaml:"java_d_jute_max_buffer"`
    // JavaXms is for '-Xms' flag (minimum Java heap size).
    // See https://docs.oracle.com/cd/E13150_01/jrockit_jvm/jrockit/jrdocs/refman/optionX.html for more.
    JavaXms string `protobuf:"bytes,2,opt,name=JavaXms,proto3" json:"JavaXms,omitempty" yaml:"java_xms"`
    // JavaXmx is for '-Xmx' flag (maximum Java heap size).
    // See https://docs.oracle.com/cd/E13150_01/jrockit_jvm/jrockit/jrdocs/refman/optionX.html for more.
    JavaXmx string `protobuf:"bytes,3,opt,name=JavaXmx,proto3" json:"JavaXmx,omitempty" yaml:"java_xmx"`
    // MyID contains a single integer in human readable ASCII text that represents the server id.
    // Each ZooKeeper server has a unique id. This id is used in two places: the myid file and the
    // configuration file. The myid file identifies the server that corresponds to the given data directory.
    // See http://zookeeper.apache.org/doc/trunk/zookeeperAdmin.html#sc_dataFileManagement for more.
    MyID uint32 `protobuf:"varint,100,opt,name=MyID,proto3" json:"MyID,omitempty"`
    // ClientPort is by default '2181'.
    // No need to set manually. Inherited from 'database_port_to_connect'.
    ClientPort int64 `protobuf:"varint,101,opt,name=ClientPort,proto3" json:"ClientPort,omitempty"`
    // See http://zookeeper.apache.org/doc/trunk/zookeeperAdmin.html for more.
    TickTime             int64 `protobuf:"varint,102,opt,name=TickTime,proto3" json:"TickTime,omitempty" yaml:"tick_time"`
    InitLimit            int64 `protobuf:"varint,103,opt,name=InitLimit,proto3" json:"InitLimit,omitempty" yaml:"init_limit"`
    SyncLimit            int64 `protobuf:"varint,104,opt,name=SyncLimit,proto3" json:"SyncLimit,omitempty" yaml:"sync_limit"`
    SnapCount            int64 `protobuf:"varint,105,opt,name=SnapCount,proto3" json:"SnapCount,omitempty" yaml:"snap_count"`
    MaxClientConnections int64 `protobuf:"varint,106,opt,name=MaxClientConnections,proto3" json:"MaxClientConnections,omitempty" yaml:"max_client_connections"`
}

func (*Flag_Zookeeper_R3_5_3Beta) Descriptor Uses

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

func (*Flag_Zookeeper_R3_5_3Beta) Marshal Uses

func (m *Flag_Zookeeper_R3_5_3Beta) Marshal() (dAtA []byte, err error)

func (*Flag_Zookeeper_R3_5_3Beta) MarshalTo Uses

func (m *Flag_Zookeeper_R3_5_3Beta) MarshalTo(dAtA []byte) (int, error)

func (*Flag_Zookeeper_R3_5_3Beta) ProtoMessage Uses

func (*Flag_Zookeeper_R3_5_3Beta) ProtoMessage()

func (*Flag_Zookeeper_R3_5_3Beta) Reset Uses

func (m *Flag_Zookeeper_R3_5_3Beta) Reset()

func (*Flag_Zookeeper_R3_5_3Beta) Size Uses

func (m *Flag_Zookeeper_R3_5_3Beta) Size() (n int)

func (*Flag_Zookeeper_R3_5_3Beta) String Uses

func (m *Flag_Zookeeper_R3_5_3Beta) String() string

func (*Flag_Zookeeper_R3_5_3Beta) Unmarshal Uses

func (m *Flag_Zookeeper_R3_5_3Beta) Unmarshal(dAtA []byte) error

type Operation Uses

type Operation int32
const (
    Operation_Start     Operation = 0
    Operation_Stop      Operation = 1
    Operation_Heartbeat Operation = 2
)

func (Operation) EnumDescriptor Uses

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

func (Operation) String Uses

func (x Operation) String() string

type Request Uses

type Request struct {
    Operation        Operation  `protobuf:"varint,1,opt,name=Operation,proto3,enum=dbtesterpb.Operation" json:"Operation,omitempty"`
    TriggerLogUpload bool       `protobuf:"varint,2,opt,name=TriggerLogUpload,proto3" json:"TriggerLogUpload,omitempty"`
    DatabaseID       DatabaseID `protobuf:"varint,3,opt,name=DatabaseID,proto3,enum=dbtesterpb.DatabaseID" json:"DatabaseID,omitempty"`
    DatabaseTag      string     `protobuf:"bytes,4,opt,name=DatabaseTag,proto3" json:"DatabaseTag,omitempty"`
    // PeerIPsString encodes a list of endpoints in string
    // because Protocol Buffer does not have a list or array datatype
    // which is ordered. 'repeated' does not guarantee the ordering.
    PeerIPsString              string                      `protobuf:"bytes,5,opt,name=PeerIPsString,proto3" json:"PeerIPsString,omitempty"`
    IPIndex                    uint32                      `protobuf:"varint,6,opt,name=IPIndex,proto3" json:"IPIndex,omitempty"`
    CurrentClientNumber        int64                       `protobuf:"varint,7,opt,name=CurrentClientNumber,proto3" json:"CurrentClientNumber,omitempty"`
    ConfigClientMachineInitial *ConfigClientMachineInitial `protobuf:"bytes,8,opt,name=ConfigClientMachineInitial" json:"ConfigClientMachineInitial,omitempty"`
    Flag_Etcd_Other            *Flag_Etcd_Other            `protobuf:"bytes,100,opt,name=flag__etcd__other,json=flagEtcdOther" json:"flag__etcd__other,omitempty"`
    Flag_Etcd_Tip              *Flag_Etcd_Tip              `protobuf:"bytes,101,opt,name=flag__etcd__tip,json=flagEtcdTip" json:"flag__etcd__tip,omitempty"`
    Flag_Etcd_V3_2             *Flag_Etcd_V3_2             `protobuf:"bytes,102,opt,name=flag__etcd__v3_2,json=flagEtcdV32" json:"flag__etcd__v3_2,omitempty"`
    Flag_Etcd_V3_3             *Flag_Etcd_V3_3             `protobuf:"bytes,103,opt,name=flag__etcd__v3_3,json=flagEtcdV33" json:"flag__etcd__v3_3,omitempty"`
    Flag_Zookeeper_R3_5_3Beta  *Flag_Zookeeper_R3_5_3Beta  `protobuf:"bytes,200,opt,name=flag__zookeeper__r3_5_3_beta,json=flagZookeeperR353Beta" json:"flag__zookeeper__r3_5_3_beta,omitempty"`
    Flag_Consul_V1_0_2         *Flag_Consul_V1_0_2         `protobuf:"bytes,300,opt,name=flag__consul__v1_0_2,json=flagConsulV102" json:"flag__consul__v1_0_2,omitempty"`
    Flag_Cetcd_Beta            *Flag_Cetcd_Beta            `protobuf:"bytes,400,opt,name=flag__cetcd__beta,json=flagCetcdBeta" json:"flag__cetcd__beta,omitempty"`
    Flag_Zetcd_Beta            *Flag_Zetcd_Beta            `protobuf:"bytes,500,opt,name=flag__zetcd__beta,json=flagZetcdBeta" json:"flag__zetcd__beta,omitempty"`
}

func (*Request) Descriptor Uses

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

func (*Request) Marshal Uses

func (m *Request) Marshal() (dAtA []byte, err error)

func (*Request) MarshalTo Uses

func (m *Request) MarshalTo(dAtA []byte) (int, error)

func (*Request) ProtoMessage Uses

func (*Request) ProtoMessage()

func (*Request) Reset Uses

func (m *Request) Reset()

func (*Request) Size Uses

func (m *Request) Size() (n int)

func (*Request) String Uses

func (m *Request) String() string

func (*Request) Unmarshal Uses

func (m *Request) Unmarshal(dAtA []byte) error

type Response Uses

type Response struct {
    Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
    // DiskSpaceUsageBytes is the data size of the database on disk in bytes.
    // It measures after database is requested to stop.
    DiskSpaceUsageBytes int64 `protobuf:"varint,2,opt,name=DiskSpaceUsageBytes,proto3" json:"DiskSpaceUsageBytes,omitempty"`
}

func (*Response) Descriptor Uses

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

func (*Response) Marshal Uses

func (m *Response) Marshal() (dAtA []byte, err error)

func (*Response) MarshalTo Uses

func (m *Response) MarshalTo(dAtA []byte) (int, error)

func (*Response) ProtoMessage Uses

func (*Response) ProtoMessage()

func (*Response) Reset Uses

func (m *Response) Reset()

func (*Response) Size Uses

func (m *Response) Size() (n int)

func (*Response) String Uses

func (m *Response) String() string

func (*Response) Unmarshal Uses

func (m *Response) Unmarshal(dAtA []byte) error

type TransporterClient Uses

type TransporterClient interface {
    Transfer(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
}

func NewTransporterClient Uses

func NewTransporterClient(cc *grpc.ClientConn) TransporterClient

type TransporterServer Uses

type TransporterServer interface {
    Transfer(context.Context, *Request) (*Response, error)
}

Package dbtesterpb imports 10 packages (graph) and is imported by 6 packages. Updated 2018-08-07. Refresh now. Tools for package owners.