dbtesterpb

package
v0.0.0-...-4c8e30b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 25, 2023 License: Apache-2.0 Imports: 10 Imported by: 8

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) 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 `` /* 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)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.