Documentation

Overview

    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

    Constants

    This section is empty.

    Variables

    View Source
    var (
    	ErrInvalidLengthConfigAnalyzeMachine = fmt.Errorf("proto: negative length found during unmarshaling")
    	ErrIntOverflowConfigAnalyzeMachine   = fmt.Errorf("proto: integer overflow")
    )
    View Source
    var (
    	ErrInvalidLengthConfigClientMachine = fmt.Errorf("proto: negative length found during unmarshaling")
    	ErrIntOverflowConfigClientMachine   = fmt.Errorf("proto: integer overflow")
    )
    View Source
    var (
    	ErrInvalidLengthFlagCetcd = fmt.Errorf("proto: negative length found during unmarshaling")
    	ErrIntOverflowFlagCetcd   = fmt.Errorf("proto: integer overflow")
    )
    View Source
    var (
    	ErrInvalidLengthFlagConsul = fmt.Errorf("proto: negative length found during unmarshaling")
    	ErrIntOverflowFlagConsul   = fmt.Errorf("proto: integer overflow")
    )
    View Source
    var (
    	ErrInvalidLengthFlagEtcd = fmt.Errorf("proto: negative length found during unmarshaling")
    	ErrIntOverflowFlagEtcd   = fmt.Errorf("proto: integer overflow")
    )
    View Source
    var (
    	ErrInvalidLengthFlagZetcd = fmt.Errorf("proto: negative length found during unmarshaling")
    	ErrIntOverflowFlagZetcd   = fmt.Errorf("proto: integer overflow")
    )
    View Source
    var (
    	ErrInvalidLengthFlagZookeeper = fmt.Errorf("proto: negative length found during unmarshaling")
    	ErrIntOverflowFlagZookeeper   = fmt.Errorf("proto: integer overflow")
    )
    View Source
    var (
    	ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling")
    	ErrIntOverflowMessage   = fmt.Errorf("proto: integer overflow")
    )
    View Source
    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",
    }
    View Source
    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,
    }
    View Source
    var Operation_name = map[int32]string{
    	0: "Start",
    	1: "Stop",
    	2: "Heartbeat",
    }
    View Source
    var Operation_value = map[string]int32{
    	"Start":     0,
    	"Stop":      1,
    	"Heartbeat": 2,
    }

    Functions

    func GetAllDatabaseIDs

    func GetAllDatabaseIDs() []string

      GetAllDatabaseIDs returns all database ids.

      func GetRGBI

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

      func GetRGBII

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

      func GetRGBIII

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

      func IsValidDatabaseID

      func IsValidDatabaseID(id string) bool

        IsValidDatabaseID returns false if the database id is not supported.

        func RegisterTransporterServer

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

        Types

        type ConfigAnalyzeMachineAllAggregatedOutput

        type ConfigAnalyzeMachineAllAggregatedOutput struct {
        	AllAggregatedOutputPathCSV string `` /* 143-byte string literal not displayed */
        	AllAggregatedOutputPathTXT string `` /* 143-byte string literal not displayed */
        }

        func (*ConfigAnalyzeMachineAllAggregatedOutput) Descriptor

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

        func (*ConfigAnalyzeMachineAllAggregatedOutput) Marshal

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

        func (*ConfigAnalyzeMachineAllAggregatedOutput) MarshalTo

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

        func (*ConfigAnalyzeMachineAllAggregatedOutput) ProtoMessage

        func (*ConfigAnalyzeMachineAllAggregatedOutput) Reset

        func (*ConfigAnalyzeMachineAllAggregatedOutput) Size

        func (*ConfigAnalyzeMachineAllAggregatedOutput) String

        func (*ConfigAnalyzeMachineAllAggregatedOutput) Unmarshal

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

        type ConfigAnalyzeMachineImage

        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

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

          func (*ConfigAnalyzeMachineImage) Marshal

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

          func (*ConfigAnalyzeMachineImage) MarshalTo

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

          func (*ConfigAnalyzeMachineImage) ProtoMessage

          func (*ConfigAnalyzeMachineImage) ProtoMessage()

          func (*ConfigAnalyzeMachineImage) Reset

          func (m *ConfigAnalyzeMachineImage) Reset()

          func (*ConfigAnalyzeMachineImage) Size

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

          func (*ConfigAnalyzeMachineImage) String

          func (m *ConfigAnalyzeMachineImage) String() string

          func (*ConfigAnalyzeMachineImage) Unmarshal

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

          type ConfigAnalyzeMachineInitial

          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   `` /* 170-byte string literal not displayed */
          	ClientLatencyThroughputTimeseriesPath   string   `` /* 176-byte string literal not displayed */
          	ClientLatencyDistributionAllPath        string   `` /* 161-byte string literal not displayed */
          	ClientLatencyDistributionPercentilePath string   `` /* 182-byte string literal not displayed */
          	ClientLatencyDistributionSummaryPath    string   `` /* 173-byte string literal not displayed */
          	ClientLatencyByKeyNumberPath            string   `` /* 151-byte string literal not displayed */
          	ServerDiskSpaceUsageSummaryPath         string   `` /* 160-byte string literal not displayed */
          	ServerMemoryByKeyNumberPath             string   `` /* 148-byte string literal not displayed */
          	ServerReadBytesDeltaByKeyNumberPath     string   `` /* 174-byte string literal not displayed */
          	ServerWriteBytesDeltaByKeyNumberPath    string   `` /* 177-byte string literal not displayed */
          	ServerSystemMetricsInterpolatedPathList []string `` /* 177-byte string literal not displayed */
          	AllAggregatedOutputPath                 string   `` /* 134-byte string literal not displayed */
          }

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

            func (*ConfigAnalyzeMachineInitial) Descriptor

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

            func (*ConfigAnalyzeMachineInitial) Marshal

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

            func (*ConfigAnalyzeMachineInitial) MarshalTo

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

            func (*ConfigAnalyzeMachineInitial) ProtoMessage

            func (*ConfigAnalyzeMachineInitial) ProtoMessage()

            func (*ConfigAnalyzeMachineInitial) Reset

            func (m *ConfigAnalyzeMachineInitial) Reset()

            func (*ConfigAnalyzeMachineInitial) Size

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

            func (*ConfigAnalyzeMachineInitial) String

            func (m *ConfigAnalyzeMachineInitial) String() string

            func (*ConfigAnalyzeMachineInitial) Unmarshal

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

            type ConfigAnalyzeMachinePlot

            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

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

              func (*ConfigAnalyzeMachinePlot) Marshal

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

              func (*ConfigAnalyzeMachinePlot) MarshalTo

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

              func (*ConfigAnalyzeMachinePlot) ProtoMessage

              func (*ConfigAnalyzeMachinePlot) ProtoMessage()

              func (*ConfigAnalyzeMachinePlot) Reset

              func (m *ConfigAnalyzeMachinePlot) Reset()

              func (*ConfigAnalyzeMachinePlot) Size

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

              func (*ConfigAnalyzeMachinePlot) String

              func (m *ConfigAnalyzeMachinePlot) String() string

              func (*ConfigAnalyzeMachinePlot) Unmarshal

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

              type ConfigAnalyzeMachineREADME

              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

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

                func (*ConfigAnalyzeMachineREADME) Marshal

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

                func (*ConfigAnalyzeMachineREADME) MarshalTo

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

                func (*ConfigAnalyzeMachineREADME) ProtoMessage

                func (*ConfigAnalyzeMachineREADME) ProtoMessage()

                func (*ConfigAnalyzeMachineREADME) Reset

                func (m *ConfigAnalyzeMachineREADME) Reset()

                func (*ConfigAnalyzeMachineREADME) Size

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

                func (*ConfigAnalyzeMachineREADME) String

                func (m *ConfigAnalyzeMachineREADME) String() string

                func (*ConfigAnalyzeMachineREADME) Unmarshal

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

                type ConfigClientMachineAgentControl

                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                                `` /* 128-byte string literal not displayed */
                	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           `` /* 161-byte string literal not displayed */
                	Flag_Consul_V1_0_2                  *Flag_Consul_V1_0_2                  `` /* 130-byte string literal not displayed */
                	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 `` /* 144-byte string literal not displayed */
                	ConfigClientMachineBenchmarkSteps   *ConfigClientMachineBenchmarkSteps   `` /* 138-byte string literal not displayed */
                }

                  ConfigClientMachineAgentControl represents control options on client machine.

                  func (*ConfigClientMachineAgentControl) Descriptor

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

                  func (*ConfigClientMachineAgentControl) Marshal

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

                  func (*ConfigClientMachineAgentControl) MarshalTo

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

                  func (*ConfigClientMachineAgentControl) ProtoMessage

                  func (*ConfigClientMachineAgentControl) ProtoMessage()

                  func (*ConfigClientMachineAgentControl) Reset

                  func (*ConfigClientMachineAgentControl) Size

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

                  func (*ConfigClientMachineAgentControl) String

                  func (*ConfigClientMachineAgentControl) Unmarshal

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

                  type ConfigClientMachineBenchmarkOptions

                  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 `` /* 133-byte string literal not displayed */
                  	RateLimitRequestsPerSecond int64   `` /* 144-byte string literal not displayed */
                  	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

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

                    func (*ConfigClientMachineBenchmarkOptions) Marshal

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

                    func (*ConfigClientMachineBenchmarkOptions) MarshalTo

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

                    func (*ConfigClientMachineBenchmarkOptions) ProtoMessage

                    func (*ConfigClientMachineBenchmarkOptions) ProtoMessage()

                    func (*ConfigClientMachineBenchmarkOptions) Reset

                    func (*ConfigClientMachineBenchmarkOptions) Size

                    func (*ConfigClientMachineBenchmarkOptions) String

                    func (*ConfigClientMachineBenchmarkOptions) Unmarshal

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

                    type ConfigClientMachineBenchmarkSteps

                    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

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

                      func (*ConfigClientMachineBenchmarkSteps) Marshal

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

                      func (*ConfigClientMachineBenchmarkSteps) MarshalTo

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

                      func (*ConfigClientMachineBenchmarkSteps) ProtoMessage

                      func (*ConfigClientMachineBenchmarkSteps) ProtoMessage()

                      func (*ConfigClientMachineBenchmarkSteps) Reset

                      func (*ConfigClientMachineBenchmarkSteps) Size

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

                      func (*ConfigClientMachineBenchmarkSteps) String

                      func (*ConfigClientMachineBenchmarkSteps) Unmarshal

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

                      type ConfigClientMachineInitial

                      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 `` /* 133-byte string literal not displayed */
                      	ClientSystemMetricsInterpolatedPath     string `` /* 170-byte string literal not displayed */
                      	ClientLatencyThroughputTimeseriesPath   string `` /* 176-byte string literal not displayed */
                      	ClientLatencyDistributionAllPath        string `` /* 161-byte string literal not displayed */
                      	ClientLatencyDistributionPercentilePath string `` /* 182-byte string literal not displayed */
                      	ClientLatencyDistributionSummaryPath    string `` /* 173-byte string literal not displayed */
                      	ClientLatencyByKeyNumberPath            string `` /* 150-byte string literal not displayed */
                      	ServerDiskSpaceUsageSummaryPath         string `` /* 160-byte string literal not displayed */
                      	GoogleCloudProjectName                  string `` /* 132-byte string literal not displayed */
                      	GoogleCloudStorageKeyPath               string `` /* 142-byte string literal not displayed */
                      	GoogleCloudStorageKey                   string `protobuf:"bytes,102,opt,name=GoogleCloudStorageKey,proto3" json:"GoogleCloudStorageKey,omitempty"`
                      	GoogleCloudStorageBucketName            string `` /* 151-byte string literal not displayed */
                      	GoogleCloudStorageSubDirectory          string `` /* 157-byte string literal not displayed */
                      }

                        ConfigClientMachineInitial represents common control options on client machine.

                        func (*ConfigClientMachineInitial) Descriptor

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

                        func (*ConfigClientMachineInitial) Marshal

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

                        func (*ConfigClientMachineInitial) MarshalTo

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

                        func (*ConfigClientMachineInitial) ProtoMessage

                        func (*ConfigClientMachineInitial) ProtoMessage()

                        func (*ConfigClientMachineInitial) Reset

                        func (m *ConfigClientMachineInitial) Reset()

                        func (*ConfigClientMachineInitial) Size

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

                        func (*ConfigClientMachineInitial) String

                        func (m *ConfigClientMachineInitial) String() string

                        func (*ConfigClientMachineInitial) Unmarshal

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

                        type DatabaseID

                        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

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

                          func (DatabaseID) String

                          func (x DatabaseID) String() string

                          type Flag_Cetcd_Beta

                          type Flag_Cetcd_Beta struct {
                          }

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

                            func (*Flag_Cetcd_Beta) Descriptor

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

                            func (*Flag_Cetcd_Beta) Marshal

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

                            func (*Flag_Cetcd_Beta) MarshalTo

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

                            func (*Flag_Cetcd_Beta) ProtoMessage

                            func (*Flag_Cetcd_Beta) ProtoMessage()

                            func (*Flag_Cetcd_Beta) Reset

                            func (m *Flag_Cetcd_Beta) Reset()

                            func (*Flag_Cetcd_Beta) Size

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

                            func (*Flag_Cetcd_Beta) String

                            func (m *Flag_Cetcd_Beta) String() string

                            func (*Flag_Cetcd_Beta) Unmarshal

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

                            type Flag_Consul_V1_0_2

                            type Flag_Consul_V1_0_2 struct {
                            }

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

                              func (*Flag_Consul_V1_0_2) Descriptor

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

                              func (*Flag_Consul_V1_0_2) Marshal

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

                              func (*Flag_Consul_V1_0_2) MarshalTo

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

                              func (*Flag_Consul_V1_0_2) ProtoMessage

                              func (*Flag_Consul_V1_0_2) ProtoMessage()

                              func (*Flag_Consul_V1_0_2) Reset

                              func (m *Flag_Consul_V1_0_2) Reset()

                              func (*Flag_Consul_V1_0_2) Size

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

                              func (*Flag_Consul_V1_0_2) String

                              func (m *Flag_Consul_V1_0_2) String() string

                              func (*Flag_Consul_V1_0_2) Unmarshal

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

                              type Flag_Etcd_Other

                              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

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

                                func (*Flag_Etcd_Other) Marshal

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

                                func (*Flag_Etcd_Other) MarshalTo

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

                                func (*Flag_Etcd_Other) ProtoMessage

                                func (*Flag_Etcd_Other) ProtoMessage()

                                func (*Flag_Etcd_Other) Reset

                                func (m *Flag_Etcd_Other) Reset()

                                func (*Flag_Etcd_Other) Size

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

                                func (*Flag_Etcd_Other) String

                                func (m *Flag_Etcd_Other) String() string

                                func (*Flag_Etcd_Other) Unmarshal

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

                                type Flag_Etcd_Tip

                                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

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

                                  func (*Flag_Etcd_Tip) Marshal

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

                                  func (*Flag_Etcd_Tip) MarshalTo

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

                                  func (*Flag_Etcd_Tip) ProtoMessage

                                  func (*Flag_Etcd_Tip) ProtoMessage()

                                  func (*Flag_Etcd_Tip) Reset

                                  func (m *Flag_Etcd_Tip) Reset()

                                  func (*Flag_Etcd_Tip) Size

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

                                  func (*Flag_Etcd_Tip) String

                                  func (m *Flag_Etcd_Tip) String() string

                                  func (*Flag_Etcd_Tip) Unmarshal

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

                                  type Flag_Etcd_V3_2

                                  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

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

                                    func (*Flag_Etcd_V3_2) Marshal

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

                                    func (*Flag_Etcd_V3_2) MarshalTo

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

                                    func (*Flag_Etcd_V3_2) ProtoMessage

                                    func (*Flag_Etcd_V3_2) ProtoMessage()

                                    func (*Flag_Etcd_V3_2) Reset

                                    func (m *Flag_Etcd_V3_2) Reset()

                                    func (*Flag_Etcd_V3_2) Size

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

                                    func (*Flag_Etcd_V3_2) String

                                    func (m *Flag_Etcd_V3_2) String() string

                                    func (*Flag_Etcd_V3_2) Unmarshal

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

                                    type Flag_Etcd_V3_3

                                    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

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

                                      func (*Flag_Etcd_V3_3) Marshal

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

                                      func (*Flag_Etcd_V3_3) MarshalTo

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

                                      func (*Flag_Etcd_V3_3) ProtoMessage

                                      func (*Flag_Etcd_V3_3) ProtoMessage()

                                      func (*Flag_Etcd_V3_3) Reset

                                      func (m *Flag_Etcd_V3_3) Reset()

                                      func (*Flag_Etcd_V3_3) Size

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

                                      func (*Flag_Etcd_V3_3) String

                                      func (m *Flag_Etcd_V3_3) String() string

                                      func (*Flag_Etcd_V3_3) Unmarshal

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

                                      type Flag_Zetcd_Beta

                                      type Flag_Zetcd_Beta struct {
                                      }

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

                                        func (*Flag_Zetcd_Beta) Descriptor

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

                                        func (*Flag_Zetcd_Beta) Marshal

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

                                        func (*Flag_Zetcd_Beta) MarshalTo

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

                                        func (*Flag_Zetcd_Beta) ProtoMessage

                                        func (*Flag_Zetcd_Beta) ProtoMessage()

                                        func (*Flag_Zetcd_Beta) Reset

                                        func (m *Flag_Zetcd_Beta) Reset()

                                        func (*Flag_Zetcd_Beta) Size

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

                                        func (*Flag_Zetcd_Beta) String

                                        func (m *Flag_Zetcd_Beta) String() string

                                        func (*Flag_Zetcd_Beta) Unmarshal

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

                                        type Flag_Zookeeper_R3_5_3Beta

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

                                        func (*Flag_Zookeeper_R3_5_3Beta) Descriptor

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

                                        func (*Flag_Zookeeper_R3_5_3Beta) Marshal

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

                                        func (*Flag_Zookeeper_R3_5_3Beta) MarshalTo

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

                                        func (*Flag_Zookeeper_R3_5_3Beta) ProtoMessage

                                        func (*Flag_Zookeeper_R3_5_3Beta) ProtoMessage()

                                        func (*Flag_Zookeeper_R3_5_3Beta) Reset

                                        func (m *Flag_Zookeeper_R3_5_3Beta) Reset()

                                        func (*Flag_Zookeeper_R3_5_3Beta) Size

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

                                        func (*Flag_Zookeeper_R3_5_3Beta) String

                                        func (m *Flag_Zookeeper_R3_5_3Beta) String() string

                                        func (*Flag_Zookeeper_R3_5_3Beta) Unmarshal

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

                                        type Operation

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

                                        func (Operation) EnumDescriptor

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

                                        func (Operation) String

                                        func (x Operation) String() string

                                        type Request

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

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

                                        func (*Request) Marshal

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

                                        func (*Request) MarshalTo

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

                                        func (*Request) ProtoMessage

                                        func (*Request) ProtoMessage()

                                        func (*Request) Reset

                                        func (m *Request) Reset()

                                        func (*Request) Size

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

                                        func (*Request) String

                                        func (m *Request) String() string

                                        func (*Request) Unmarshal

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

                                        type Response

                                        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

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

                                        func (*Response) Marshal

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

                                        func (*Response) MarshalTo

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

                                        func (*Response) ProtoMessage

                                        func (*Response) ProtoMessage()

                                        func (*Response) Reset

                                        func (m *Response) Reset()

                                        func (*Response) Size

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

                                        func (*Response) String

                                        func (m *Response) String() string

                                        func (*Response) Unmarshal

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

                                        type TransporterClient

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

                                        func NewTransporterClient

                                        func NewTransporterClient(cc *grpc.ClientConn) TransporterClient

                                        type TransporterServer

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