Back to godoc.org

Package dbtesterpb

v0.0.0-...-c34a5e7
Latest Go to latest

The latest major version is .

Published: Feb 25, 2020 | License: Apache-2.0 | Module: github.com/etcd-io/dbtester

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

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

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)

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) ProtoMessage()

func (*ConfigAnalyzeMachineAllAggregatedOutput) Reset

func (m *ConfigAnalyzeMachineAllAggregatedOutput) Reset()

func (*ConfigAnalyzeMachineAllAggregatedOutput) Size

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

func (*ConfigAnalyzeMachineAllAggregatedOutput) String

func (m *ConfigAnalyzeMachineAllAggregatedOutput) String() 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 (m *ConfigClientMachineAgentControl) Reset()

func (*ConfigClientMachineAgentControl) Size

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

func (*ConfigClientMachineAgentControl) String

func (m *ConfigClientMachineAgentControl) String() 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 (m *ConfigClientMachineBenchmarkOptions) Reset()

func (*ConfigClientMachineBenchmarkOptions) Size

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

func (*ConfigClientMachineBenchmarkOptions) String

func (m *ConfigClientMachineBenchmarkOptions) String() 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 (m *ConfigClientMachineBenchmarkSteps) Reset()

func (*ConfigClientMachineBenchmarkSteps) Size

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

func (*ConfigClientMachineBenchmarkSteps) String

func (m *ConfigClientMachineBenchmarkSteps) String() 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 `protobuf:"varint,106,opt,name=MaxClientConnections,proto3" json:"MaxClientConnections,omitempty" yaml:"max_client_connections"`
}

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

Package Files

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier