dev

package
v1.36.11-2025072813344... Latest Latest
Warning

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

 Go to latest Published: unknown License: Apache-2.0 Imports: 12 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TabletSelectionPreference_name = map[int32]string{
		0: "ANY",
		1: "INORDER",
		3: "UNKNOWN",
	}
	TabletSelectionPreference_value = map[string]int32{
		"ANY":     0,
		"INORDER": 1,
		"UNKNOWN": 3,
	}
)

Enum value maps for TabletSelectionPreference.

View Source 
var (
	CheckThrottlerResponseCode_name = map[int32]string{
		0: "UNDEFINED",
		1: "OK",
		2: "THRESHOLD_EXCEEDED",
		3: "APP_DENIED",
		4: "UNKNOWN_METRIC",
		5: "INTERNAL_ERROR",
	}
	CheckThrottlerResponseCode_value = map[string]int32{
		"UNDEFINED":          0,
		"OK":                 1,
		"THRESHOLD_EXCEEDED": 2,
		"APP_DENIED":         3,
		"UNKNOWN_METRIC":     4,
		"INTERNAL_ERROR":     5,
	}
)

Enum value maps for CheckThrottlerResponseCode.

View Source 
var File_vitess_tabletmanagerdata_dev_tabletmanagerdata_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ApplySchemaRequest 

type ApplySchemaRequest struct {
	Sql              string            `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	Force            bool              `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	AllowReplication bool              `protobuf:"varint,3,opt,name=allow_replication,json=allowReplication,proto3" json:"allow_replication,omitempty"`
	BeforeSchema     *SchemaDefinition `protobuf:"bytes,4,opt,name=before_schema,json=beforeSchema,proto3" json:"before_schema,omitempty"`
	AfterSchema      *SchemaDefinition `protobuf:"bytes,5,opt,name=after_schema,json=afterSchema,proto3" json:"after_schema,omitempty"`
	SqlMode          string            `protobuf:"bytes,6,opt,name=sql_mode,json=sqlMode,proto3" json:"sql_mode,omitempty"`
	// BatchSize indicates how many queries to apply together.
	BatchSize int64 `protobuf:"varint,7,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// DisableForeignKeyChecks will result in setting foreign_key_checks to off before applying the schema.
	DisableForeignKeyChecks bool `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ApplySchemaRequest) ClearAfterSchema 

func (x *ApplySchemaRequest) ClearAfterSchema()

func (*ApplySchemaRequest) ClearBeforeSchema 

func (x *ApplySchemaRequest) ClearBeforeSchema()

func (*ApplySchemaRequest) GetAfterSchema 

func (x *ApplySchemaRequest) GetAfterSchema() *SchemaDefinition

func (*ApplySchemaRequest) GetAllowReplication 

func (x *ApplySchemaRequest) GetAllowReplication() bool

func (*ApplySchemaRequest) GetBatchSize 

func (x *ApplySchemaRequest) GetBatchSize() int64

func (*ApplySchemaRequest) GetBeforeSchema 

func (x *ApplySchemaRequest) GetBeforeSchema() *SchemaDefinition

func (*ApplySchemaRequest) GetDisableForeignKeyChecks 

func (x *ApplySchemaRequest) GetDisableForeignKeyChecks() bool

func (*ApplySchemaRequest) GetForce 

func (x *ApplySchemaRequest) GetForce() bool

func (*ApplySchemaRequest) GetSql 

func (x *ApplySchemaRequest) GetSql() string

func (*ApplySchemaRequest) GetSqlMode 

func (x *ApplySchemaRequest) GetSqlMode() string

func (*ApplySchemaRequest) HasAfterSchema 

func (x *ApplySchemaRequest) HasAfterSchema() bool

func (*ApplySchemaRequest) HasBeforeSchema 

func (x *ApplySchemaRequest) HasBeforeSchema() bool

func (*ApplySchemaRequest) ProtoMessage 

func (*ApplySchemaRequest) ProtoMessage()

func (*ApplySchemaRequest) ProtoReflect 

func (x *ApplySchemaRequest) ProtoReflect() protoreflect.Message

func (*ApplySchemaRequest) Reset 

func (x *ApplySchemaRequest) Reset()

func (*ApplySchemaRequest) SetAfterSchema 

func (x *ApplySchemaRequest) SetAfterSchema(v *SchemaDefinition)

func (*ApplySchemaRequest) SetAllowReplication 

func (x *ApplySchemaRequest) SetAllowReplication(v bool)

func (*ApplySchemaRequest) SetBatchSize 

func (x *ApplySchemaRequest) SetBatchSize(v int64)

func (*ApplySchemaRequest) SetBeforeSchema 

func (x *ApplySchemaRequest) SetBeforeSchema(v *SchemaDefinition)

func (*ApplySchemaRequest) SetDisableForeignKeyChecks 

func (x *ApplySchemaRequest) SetDisableForeignKeyChecks(v bool)

func (*ApplySchemaRequest) SetForce 

func (x *ApplySchemaRequest) SetForce(v bool)

func (*ApplySchemaRequest) SetSql 

func (x *ApplySchemaRequest) SetSql(v string)

func (*ApplySchemaRequest) SetSqlMode 

func (x *ApplySchemaRequest) SetSqlMode(v string)

func (*ApplySchemaRequest) String 

func (x *ApplySchemaRequest) String() string

type ApplySchemaRequest_builder 

type ApplySchemaRequest_builder struct {
	Sql              string
	Force            bool
	AllowReplication bool
	BeforeSchema     *SchemaDefinition
	AfterSchema      *SchemaDefinition
	SqlMode          string
	// BatchSize indicates how many queries to apply together.
	BatchSize int64
	// DisableForeignKeyChecks will result in setting foreign_key_checks to off before applying the schema.
	DisableForeignKeyChecks bool
	// contains filtered or unexported fields
}

func (ApplySchemaRequest_builder) Build 

func (b0 ApplySchemaRequest_builder) Build() *ApplySchemaRequest

type ApplySchemaResponse 

type ApplySchemaResponse struct {
	BeforeSchema *SchemaDefinition `protobuf:"bytes,1,opt,name=before_schema,json=beforeSchema,proto3" json:"before_schema,omitempty"`
	AfterSchema  *SchemaDefinition `protobuf:"bytes,2,opt,name=after_schema,json=afterSchema,proto3" json:"after_schema,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplySchemaResponse) ClearAfterSchema 

func (x *ApplySchemaResponse) ClearAfterSchema()

func (*ApplySchemaResponse) ClearBeforeSchema 

func (x *ApplySchemaResponse) ClearBeforeSchema()

func (*ApplySchemaResponse) GetAfterSchema 

func (x *ApplySchemaResponse) GetAfterSchema() *SchemaDefinition

func (*ApplySchemaResponse) GetBeforeSchema 

func (x *ApplySchemaResponse) GetBeforeSchema() *SchemaDefinition

func (*ApplySchemaResponse) HasAfterSchema 

func (x *ApplySchemaResponse) HasAfterSchema() bool

func (*ApplySchemaResponse) HasBeforeSchema 

func (x *ApplySchemaResponse) HasBeforeSchema() bool

func (*ApplySchemaResponse) ProtoMessage 

func (*ApplySchemaResponse) ProtoMessage()

func (*ApplySchemaResponse) ProtoReflect 

func (x *ApplySchemaResponse) ProtoReflect() protoreflect.Message

func (*ApplySchemaResponse) Reset 

func (x *ApplySchemaResponse) Reset()

func (*ApplySchemaResponse) SetAfterSchema 

func (x *ApplySchemaResponse) SetAfterSchema(v *SchemaDefinition)

func (*ApplySchemaResponse) SetBeforeSchema 

func (x *ApplySchemaResponse) SetBeforeSchema(v *SchemaDefinition)

func (*ApplySchemaResponse) String 

func (x *ApplySchemaResponse) String() string

type ApplySchemaResponse_builder 

type ApplySchemaResponse_builder struct {
	BeforeSchema *SchemaDefinition
	AfterSchema  *SchemaDefinition
	// contains filtered or unexported fields
}

func (ApplySchemaResponse_builder) Build 

func (b0 ApplySchemaResponse_builder) Build() *ApplySchemaResponse

type BackupRequest 

type BackupRequest struct {
	Concurrency  int32 `protobuf:"varint,1,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	AllowPrimary bool  `protobuf:"varint,2,opt,name=allow_primary,json=allowPrimary,proto3" json:"allow_primary,omitempty"`
	// IncrementalFromPos indicates a position of a previous backup. When this value is non-empty
	// then the backup becomes incremental and applies as of given position.
	IncrementalFromPos string `protobuf:"bytes,3,opt,name=incremental_from_pos,json=incrementalFromPos,proto3" json:"incremental_from_pos,omitempty"`
	// UpgradeSafe indicates if the backup should be taken with innodb_fast_shutdown=0
	// so that it's a backup that can be used for an upgrade.
	UpgradeSafe bool `protobuf:"varint,4,opt,name=upgrade_safe,json=upgradeSafe,proto3" json:"upgrade_safe,omitempty"`
	// BackupEngine specifies if we want to use a particular backup engine for this backup request
	BackupEngine *string `protobuf:"bytes,5,opt,name=backup_engine,json=backupEngine,proto3,oneof" json:"backup_engine,omitempty"`
	// MysqlShutdownTimeout is the timeout in seconds to wait for MySQL to shutdown
	// before taking the backup. If not set, the default value is used.
	MysqlShutdownTimeout *dev5.Duration `protobuf:"bytes,6,opt,name=mysql_shutdown_timeout,json=mysqlShutdownTimeout,proto3" json:"mysql_shutdown_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupRequest) ClearBackupEngine 

func (x *BackupRequest) ClearBackupEngine()

func (*BackupRequest) ClearMysqlShutdownTimeout 

func (x *BackupRequest) ClearMysqlShutdownTimeout()

func (*BackupRequest) GetAllowPrimary 

func (x *BackupRequest) GetAllowPrimary() bool

func (*BackupRequest) GetBackupEngine 

func (x *BackupRequest) GetBackupEngine() string

func (*BackupRequest) GetConcurrency 

func (x *BackupRequest) GetConcurrency() int32

func (*BackupRequest) GetIncrementalFromPos 

func (x *BackupRequest) GetIncrementalFromPos() string

func (*BackupRequest) GetMysqlShutdownTimeout 

func (x *BackupRequest) GetMysqlShutdownTimeout() *dev5.Duration

func (*BackupRequest) GetUpgradeSafe 

func (x *BackupRequest) GetUpgradeSafe() bool

func (*BackupRequest) HasBackupEngine 

func (x *BackupRequest) HasBackupEngine() bool

func (*BackupRequest) HasMysqlShutdownTimeout 

func (x *BackupRequest) HasMysqlShutdownTimeout() bool

func (*BackupRequest) ProtoMessage 

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) ProtoReflect 

func (x *BackupRequest) ProtoReflect() protoreflect.Message

func (*BackupRequest) Reset 

func (x *BackupRequest) Reset()

func (*BackupRequest) SetAllowPrimary 

func (x *BackupRequest) SetAllowPrimary(v bool)

func (*BackupRequest) SetBackupEngine 

func (x *BackupRequest) SetBackupEngine(v string)

func (*BackupRequest) SetConcurrency 

func (x *BackupRequest) SetConcurrency(v int32)

func (*BackupRequest) SetIncrementalFromPos 

func (x *BackupRequest) SetIncrementalFromPos(v string)

func (*BackupRequest) SetMysqlShutdownTimeout 

func (x *BackupRequest) SetMysqlShutdownTimeout(v *dev5.Duration)

func (*BackupRequest) SetUpgradeSafe 

func (x *BackupRequest) SetUpgradeSafe(v bool)

func (*BackupRequest) String 

func (x *BackupRequest) String() string

type BackupRequest_builder 

type BackupRequest_builder struct {
	Concurrency  int32
	AllowPrimary bool
	// IncrementalFromPos indicates a position of a previous backup. When this value is non-empty
	// then the backup becomes incremental and applies as of given position.
	IncrementalFromPos string
	// UpgradeSafe indicates if the backup should be taken with innodb_fast_shutdown=0
	// so that it's a backup that can be used for an upgrade.
	UpgradeSafe bool
	// BackupEngine specifies if we want to use a particular backup engine for this backup request
	BackupEngine *string
	// MysqlShutdownTimeout is the timeout in seconds to wait for MySQL to shutdown
	// before taking the backup. If not set, the default value is used.
	MysqlShutdownTimeout *dev5.Duration
	// contains filtered or unexported fields
}

func (BackupRequest_builder) Build 

func (b0 BackupRequest_builder) Build() *BackupRequest

type BackupResponse 

type BackupResponse struct {
	Event *dev6.Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupResponse) ClearEvent 

func (x *BackupResponse) ClearEvent()

func (*BackupResponse) GetEvent 

func (x *BackupResponse) GetEvent() *dev6.Event

func (*BackupResponse) HasEvent 

func (x *BackupResponse) HasEvent() bool

func (*BackupResponse) ProtoMessage 

func (*BackupResponse) ProtoMessage()

func (*BackupResponse) ProtoReflect 

func (x *BackupResponse) ProtoReflect() protoreflect.Message

func (*BackupResponse) Reset 

func (x *BackupResponse) Reset()

func (*BackupResponse) SetEvent 

func (x *BackupResponse) SetEvent(v *dev6.Event)

func (*BackupResponse) String 

func (x *BackupResponse) String() string

type BackupResponse_builder 

type BackupResponse_builder struct {
	Event *dev6.Event
	// contains filtered or unexported fields
}

func (BackupResponse_builder) Build 

func (b0 BackupResponse_builder) Build() *BackupResponse

type ChangeTagsRequest 

type ChangeTagsRequest struct {
	Tags    map[string]string `` /* 135-byte string literal not displayed */
	Replace bool              `protobuf:"varint,2,opt,name=replace,proto3" json:"replace,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeTagsRequest) GetReplace 

func (x *ChangeTagsRequest) GetReplace() bool

func (*ChangeTagsRequest) GetTags 

func (x *ChangeTagsRequest) GetTags() map[string]string

func (*ChangeTagsRequest) ProtoMessage 

func (*ChangeTagsRequest) ProtoMessage()

func (*ChangeTagsRequest) ProtoReflect 

func (x *ChangeTagsRequest) ProtoReflect() protoreflect.Message

func (*ChangeTagsRequest) Reset 

func (x *ChangeTagsRequest) Reset()

func (*ChangeTagsRequest) SetReplace 

func (x *ChangeTagsRequest) SetReplace(v bool)

func (*ChangeTagsRequest) SetTags 

func (x *ChangeTagsRequest) SetTags(v map[string]string)

func (*ChangeTagsRequest) String 

func (x *ChangeTagsRequest) String() string

type ChangeTagsRequest_builder 

type ChangeTagsRequest_builder struct {
	Tags    map[string]string
	Replace bool
	// contains filtered or unexported fields
}

func (ChangeTagsRequest_builder) Build 

func (b0 ChangeTagsRequest_builder) Build() *ChangeTagsRequest

type ChangeTagsResponse 

type ChangeTagsResponse struct {
	Tags map[string]string `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ChangeTagsResponse) GetTags 

func (x *ChangeTagsResponse) GetTags() map[string]string

func (*ChangeTagsResponse) ProtoMessage 

func (*ChangeTagsResponse) ProtoMessage()

func (*ChangeTagsResponse) ProtoReflect 

func (x *ChangeTagsResponse) ProtoReflect() protoreflect.Message

func (*ChangeTagsResponse) Reset 

func (x *ChangeTagsResponse) Reset()

func (*ChangeTagsResponse) SetTags 

func (x *ChangeTagsResponse) SetTags(v map[string]string)

func (*ChangeTagsResponse) String 

func (x *ChangeTagsResponse) String() string

type ChangeTagsResponse_builder 

type ChangeTagsResponse_builder struct {
	Tags map[string]string
	// contains filtered or unexported fields
}

func (ChangeTagsResponse_builder) Build 

func (b0 ChangeTagsResponse_builder) Build() *ChangeTagsResponse

type ChangeTypeRequest 

type ChangeTypeRequest struct {
	TabletType dev1.TabletType `` /* 128-byte string literal not displayed */
	SemiSync   bool            `protobuf:"varint,2,opt,name=semiSync,proto3" json:"semiSync,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeTypeRequest) GetSemiSync 

func (x *ChangeTypeRequest) GetSemiSync() bool

func (*ChangeTypeRequest) GetTabletType 

func (x *ChangeTypeRequest) GetTabletType() dev1.TabletType

func (*ChangeTypeRequest) ProtoMessage 

func (*ChangeTypeRequest) ProtoMessage()

func (*ChangeTypeRequest) ProtoReflect 

func (x *ChangeTypeRequest) ProtoReflect() protoreflect.Message

func (*ChangeTypeRequest) Reset 

func (x *ChangeTypeRequest) Reset()

func (*ChangeTypeRequest) SetSemiSync 

func (x *ChangeTypeRequest) SetSemiSync(v bool)

func (*ChangeTypeRequest) SetTabletType 

func (x *ChangeTypeRequest) SetTabletType(v dev1.TabletType)

func (*ChangeTypeRequest) String 

func (x *ChangeTypeRequest) String() string

type ChangeTypeRequest_builder 

type ChangeTypeRequest_builder struct {
	TabletType dev1.TabletType
	SemiSync   bool
	// contains filtered or unexported fields
}

func (ChangeTypeRequest_builder) Build 

func (b0 ChangeTypeRequest_builder) Build() *ChangeTypeRequest

type ChangeTypeResponse 

type ChangeTypeResponse struct {
	// contains filtered or unexported fields
}

func (*ChangeTypeResponse) ProtoMessage 

func (*ChangeTypeResponse) ProtoMessage()

func (*ChangeTypeResponse) ProtoReflect 

func (x *ChangeTypeResponse) ProtoReflect() protoreflect.Message

func (*ChangeTypeResponse) Reset 

func (x *ChangeTypeResponse) Reset()

func (*ChangeTypeResponse) String 

func (x *ChangeTypeResponse) String() string

type ChangeTypeResponse_builder 

type ChangeTypeResponse_builder struct {
	// contains filtered or unexported fields
}

func (ChangeTypeResponse_builder) Build 

func (b0 ChangeTypeResponse_builder) Build() *ChangeTypeResponse

type CheckThrottlerRequest 

type CheckThrottlerRequest struct {
	AppName string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	Scope   string `protobuf:"bytes,2,opt,name=scope,proto3" json:"scope,omitempty"`
	// SkipRequestHeartbeats ensures this check does not renew heartbeat lease
	SkipRequestHeartbeats bool `` /* 127-byte string literal not displayed */
	// OKIfNotExists asks the throttler to return OK even if the metric does not exist
	OkIfNotExists bool `protobuf:"varint,4,opt,name=ok_if_not_exists,json=okIfNotExists,proto3" json:"ok_if_not_exists,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckThrottlerRequest) GetAppName 

func (x *CheckThrottlerRequest) GetAppName() string

func (*CheckThrottlerRequest) GetOkIfNotExists 

func (x *CheckThrottlerRequest) GetOkIfNotExists() bool

func (*CheckThrottlerRequest) GetScope 

func (x *CheckThrottlerRequest) GetScope() string

func (*CheckThrottlerRequest) GetSkipRequestHeartbeats 

func (x *CheckThrottlerRequest) GetSkipRequestHeartbeats() bool

func (*CheckThrottlerRequest) ProtoMessage 

func (*CheckThrottlerRequest) ProtoMessage()

func (*CheckThrottlerRequest) ProtoReflect 

func (x *CheckThrottlerRequest) ProtoReflect() protoreflect.Message

func (*CheckThrottlerRequest) Reset 

func (x *CheckThrottlerRequest) Reset()

func (*CheckThrottlerRequest) SetAppName 

func (x *CheckThrottlerRequest) SetAppName(v string)

func (*CheckThrottlerRequest) SetOkIfNotExists 

func (x *CheckThrottlerRequest) SetOkIfNotExists(v bool)

func (*CheckThrottlerRequest) SetScope 

func (x *CheckThrottlerRequest) SetScope(v string)

func (*CheckThrottlerRequest) SetSkipRequestHeartbeats 

func (x *CheckThrottlerRequest) SetSkipRequestHeartbeats(v bool)

func (*CheckThrottlerRequest) String 

func (x *CheckThrottlerRequest) String() string

type CheckThrottlerRequest_builder 

type CheckThrottlerRequest_builder struct {
	AppName string
	Scope   string
	// SkipRequestHeartbeats ensures this check does not renew heartbeat lease
	SkipRequestHeartbeats bool
	// OKIfNotExists asks the throttler to return OK even if the metric does not exist
	OkIfNotExists bool
	// contains filtered or unexported fields
}

func (CheckThrottlerRequest_builder) Build 

func (b0 CheckThrottlerRequest_builder) Build() *CheckThrottlerRequest

type CheckThrottlerResponse 

type CheckThrottlerResponse struct {

	// Value is the metric value collected by the tablet
	Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	// Threshold is the throttling threshold the table was comparing the value with
	Threshold float64 `protobuf:"fixed64,3,opt,name=threshold,proto3" json:"threshold,omitempty"`
	// Error indicates an error retrieving the value
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// Message
	Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// RecentlyChecked indicates that the tablet has been hit with a user-facing check, which can then imply
	// that heartbeats lease should be renwed.
	RecentlyChecked bool `protobuf:"varint,6,opt,name=recently_checked,json=recentlyChecked,proto3" json:"recently_checked,omitempty"`
	// Metrics is a map (metric name -> metric value/error) so that the client has as much
	// information as possible about all the checked metrics.
	Metrics map[string]*CheckThrottlerResponse_Metric `` /* 141-byte string literal not displayed */
	// AppName is the name of app that was matched by the throttler
	AppName string `protobuf:"bytes,8,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	// Summary is a human readable analysis of the result
	Summary string `protobuf:"bytes,9,opt,name=summary,proto3" json:"summary,omitempty"`
	// ResponseCode is the enum representation of the response
	ResponseCode CheckThrottlerResponseCode `` /* 160-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CheckThrottlerResponse) GetAppName 

func (x *CheckThrottlerResponse) GetAppName() string

func (*CheckThrottlerResponse) GetError 

func (x *CheckThrottlerResponse) GetError() string

func (*CheckThrottlerResponse) GetMessage 

func (x *CheckThrottlerResponse) GetMessage() string

func (*CheckThrottlerResponse) GetMetrics 

func (x *CheckThrottlerResponse) GetMetrics() map[string]*CheckThrottlerResponse_Metric

func (*CheckThrottlerResponse) GetRecentlyChecked 

func (x *CheckThrottlerResponse) GetRecentlyChecked() bool

func (*CheckThrottlerResponse) GetResponseCode 

func (x *CheckThrottlerResponse) GetResponseCode() CheckThrottlerResponseCode

func (*CheckThrottlerResponse) GetSummary 

func (x *CheckThrottlerResponse) GetSummary() string

func (*CheckThrottlerResponse) GetThreshold 

func (x *CheckThrottlerResponse) GetThreshold() float64

func (*CheckThrottlerResponse) GetValue 

func (x *CheckThrottlerResponse) GetValue() float64

func (*CheckThrottlerResponse) ProtoMessage 

func (*CheckThrottlerResponse) ProtoMessage()

func (*CheckThrottlerResponse) ProtoReflect 

func (x *CheckThrottlerResponse) ProtoReflect() protoreflect.Message

func (*CheckThrottlerResponse) Reset 

func (x *CheckThrottlerResponse) Reset()

func (*CheckThrottlerResponse) SetAppName 

func (x *CheckThrottlerResponse) SetAppName(v string)

func (*CheckThrottlerResponse) SetError 

func (x *CheckThrottlerResponse) SetError(v string)

func (*CheckThrottlerResponse) SetMessage 

func (x *CheckThrottlerResponse) SetMessage(v string)

func (*CheckThrottlerResponse) SetMetrics 

func (x *CheckThrottlerResponse) SetMetrics(v map[string]*CheckThrottlerResponse_Metric)

func (*CheckThrottlerResponse) SetRecentlyChecked 

func (x *CheckThrottlerResponse) SetRecentlyChecked(v bool)

func (*CheckThrottlerResponse) SetResponseCode 

func (x *CheckThrottlerResponse) SetResponseCode(v CheckThrottlerResponseCode)

func (*CheckThrottlerResponse) SetSummary 

func (x *CheckThrottlerResponse) SetSummary(v string)

func (*CheckThrottlerResponse) SetThreshold 

func (x *CheckThrottlerResponse) SetThreshold(v float64)

func (*CheckThrottlerResponse) SetValue 

func (x *CheckThrottlerResponse) SetValue(v float64)

func (*CheckThrottlerResponse) String 

func (x *CheckThrottlerResponse) String() string

type CheckThrottlerResponseCode 

type CheckThrottlerResponseCode int32
const (
	CheckThrottlerResponseCode_UNDEFINED          CheckThrottlerResponseCode = 0
	CheckThrottlerResponseCode_OK                 CheckThrottlerResponseCode = 1
	CheckThrottlerResponseCode_THRESHOLD_EXCEEDED CheckThrottlerResponseCode = 2
	CheckThrottlerResponseCode_APP_DENIED         CheckThrottlerResponseCode = 3
	CheckThrottlerResponseCode_UNKNOWN_METRIC     CheckThrottlerResponseCode = 4
	CheckThrottlerResponseCode_INTERNAL_ERROR     CheckThrottlerResponseCode = 5
)

func (CheckThrottlerResponseCode) Descriptor 

func (CheckThrottlerResponseCode) Descriptor() protoreflect.EnumDescriptor

func (CheckThrottlerResponseCode) Enum 

func (x CheckThrottlerResponseCode) Enum() *CheckThrottlerResponseCode

func (CheckThrottlerResponseCode) Number 

func (x CheckThrottlerResponseCode) Number() protoreflect.EnumNumber

func (CheckThrottlerResponseCode) String 

func (x CheckThrottlerResponseCode) String() string

func (CheckThrottlerResponseCode) Type 

func (CheckThrottlerResponseCode) Type() protoreflect.EnumType

type CheckThrottlerResponse_Metric 

type CheckThrottlerResponse_Metric struct {

	// Name of the metric
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Value is the metric value collected by the tablet
	Value float64 `protobuf:"fixed64,3,opt,name=value,proto3" json:"value,omitempty"`
	// Threshold is the throttling threshold the table was comparing the value with
	Threshold float64 `protobuf:"fixed64,4,opt,name=threshold,proto3" json:"threshold,omitempty"`
	// Error indicates an error retrieving the value
	Error string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// Message
	Message string `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
	// Scope used in this check
	Scope string `protobuf:"bytes,7,opt,name=scope,proto3" json:"scope,omitempty"`
	// ResponseCode is the enum representation of the response
	ResponseCode CheckThrottlerResponseCode `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CheckThrottlerResponse_Metric) GetError 

func (x *CheckThrottlerResponse_Metric) GetError() string

func (*CheckThrottlerResponse_Metric) GetMessage 

func (x *CheckThrottlerResponse_Metric) GetMessage() string

func (*CheckThrottlerResponse_Metric) GetName 

func (x *CheckThrottlerResponse_Metric) GetName() string

func (*CheckThrottlerResponse_Metric) GetResponseCode 

func (x *CheckThrottlerResponse_Metric) GetResponseCode() CheckThrottlerResponseCode

func (*CheckThrottlerResponse_Metric) GetScope 

func (x *CheckThrottlerResponse_Metric) GetScope() string

func (*CheckThrottlerResponse_Metric) GetThreshold 

func (x *CheckThrottlerResponse_Metric) GetThreshold() float64

func (*CheckThrottlerResponse_Metric) GetValue 

func (x *CheckThrottlerResponse_Metric) GetValue() float64

func (*CheckThrottlerResponse_Metric) ProtoMessage 

func (*CheckThrottlerResponse_Metric) ProtoMessage()

func (*CheckThrottlerResponse_Metric) ProtoReflect 

func (x *CheckThrottlerResponse_Metric) ProtoReflect() protoreflect.Message

func (*CheckThrottlerResponse_Metric) Reset 

func (x *CheckThrottlerResponse_Metric) Reset()

func (*CheckThrottlerResponse_Metric) SetError 

func (x *CheckThrottlerResponse_Metric) SetError(v string)

func (*CheckThrottlerResponse_Metric) SetMessage 

func (x *CheckThrottlerResponse_Metric) SetMessage(v string)

func (*CheckThrottlerResponse_Metric) SetName 

func (x *CheckThrottlerResponse_Metric) SetName(v string)

func (*CheckThrottlerResponse_Metric) SetResponseCode 

func (x *CheckThrottlerResponse_Metric) SetResponseCode(v CheckThrottlerResponseCode)

func (*CheckThrottlerResponse_Metric) SetScope 

func (x *CheckThrottlerResponse_Metric) SetScope(v string)

func (*CheckThrottlerResponse_Metric) SetThreshold 

func (x *CheckThrottlerResponse_Metric) SetThreshold(v float64)

func (*CheckThrottlerResponse_Metric) SetValue 

func (x *CheckThrottlerResponse_Metric) SetValue(v float64)

func (*CheckThrottlerResponse_Metric) String 

func (x *CheckThrottlerResponse_Metric) String() string

type CheckThrottlerResponse_Metric_builder 

type CheckThrottlerResponse_Metric_builder struct {

	// Name of the metric
	Name string
	// Value is the metric value collected by the tablet
	Value float64
	// Threshold is the throttling threshold the table was comparing the value with
	Threshold float64
	// Error indicates an error retrieving the value
	Error string
	// Message
	Message string
	// Scope used in this check
	Scope string
	// ResponseCode is the enum representation of the response
	ResponseCode CheckThrottlerResponseCode
	// contains filtered or unexported fields
}

func (CheckThrottlerResponse_Metric_builder) Build 

func (b0 CheckThrottlerResponse_Metric_builder) Build() *CheckThrottlerResponse_Metric

type CheckThrottlerResponse_builder 

type CheckThrottlerResponse_builder struct {

	// Value is the metric value collected by the tablet
	Value float64
	// Threshold is the throttling threshold the table was comparing the value with
	Threshold float64
	// Error indicates an error retrieving the value
	Error string
	// Message
	Message string
	// RecentlyChecked indicates that the tablet has been hit with a user-facing check, which can then imply
	// that heartbeats lease should be renwed.
	RecentlyChecked bool
	// Metrics is a map (metric name -> metric value/error) so that the client has as much
	// information as possible about all the checked metrics.
	Metrics map[string]*CheckThrottlerResponse_Metric
	// AppName is the name of app that was matched by the throttler
	AppName string
	// Summary is a human readable analysis of the result
	Summary string
	// ResponseCode is the enum representation of the response
	ResponseCode CheckThrottlerResponseCode
	// contains filtered or unexported fields
}

func (CheckThrottlerResponse_builder) Build 

func (b0 CheckThrottlerResponse_builder) Build() *CheckThrottlerResponse

type ConcludeTransactionRequest 

type ConcludeTransactionRequest struct {
	Dtid string `protobuf:"bytes,1,opt,name=dtid,proto3" json:"dtid,omitempty"`
	Mm   bool   `protobuf:"varint,2,opt,name=mm,proto3" json:"mm,omitempty"`
	// contains filtered or unexported fields
}

func (*ConcludeTransactionRequest) GetDtid 

func (x *ConcludeTransactionRequest) GetDtid() string

func (*ConcludeTransactionRequest) GetMm 

func (x *ConcludeTransactionRequest) GetMm() bool

func (*ConcludeTransactionRequest) ProtoMessage 

func (*ConcludeTransactionRequest) ProtoMessage()

func (*ConcludeTransactionRequest) ProtoReflect 

func (x *ConcludeTransactionRequest) ProtoReflect() protoreflect.Message

func (*ConcludeTransactionRequest) Reset 

func (x *ConcludeTransactionRequest) Reset()

func (*ConcludeTransactionRequest) SetDtid 

func (x *ConcludeTransactionRequest) SetDtid(v string)

func (*ConcludeTransactionRequest) SetMm 

func (x *ConcludeTransactionRequest) SetMm(v bool)

func (*ConcludeTransactionRequest) String 

func (x *ConcludeTransactionRequest) String() string

type ConcludeTransactionRequest_builder 

type ConcludeTransactionRequest_builder struct {
	Dtid string
	Mm   bool
	// contains filtered or unexported fields
}

func (ConcludeTransactionRequest_builder) Build 

func (b0 ConcludeTransactionRequest_builder) Build() *ConcludeTransactionRequest

type ConcludeTransactionResponse 

type ConcludeTransactionResponse struct {
	// contains filtered or unexported fields
}

func (*ConcludeTransactionResponse) ProtoMessage 

func (*ConcludeTransactionResponse) ProtoMessage()

func (*ConcludeTransactionResponse) ProtoReflect 

func (x *ConcludeTransactionResponse) ProtoReflect() protoreflect.Message

func (*ConcludeTransactionResponse) Reset 

func (x *ConcludeTransactionResponse) Reset()

func (*ConcludeTransactionResponse) String 

func (x *ConcludeTransactionResponse) String() string

type ConcludeTransactionResponse_builder 

type ConcludeTransactionResponse_builder struct {
	// contains filtered or unexported fields
}

func (ConcludeTransactionResponse_builder) Build 

func (b0 ConcludeTransactionResponse_builder) Build() *ConcludeTransactionResponse

type CreateVReplicationWorkflowRequest 

type CreateVReplicationWorkflowRequest struct {
	Workflow     string               `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	BinlogSource []*dev7.BinlogSource `protobuf:"bytes,2,rep,name=binlog_source,json=binlogSource,proto3" json:"binlog_source,omitempty"`
	// Optional parameters.
	Cells []string `protobuf:"bytes,3,rep,name=cells,proto3" json:"cells,omitempty"`
	// TabletTypes is the list of tablet types to use when selecting source tablets.
	TabletTypes               []dev1.TabletType                `` /* 138-byte string literal not displayed */
	TabletSelectionPreference TabletSelectionPreference        `` /* 199-byte string literal not displayed */
	WorkflowType              dev7.VReplicationWorkflowType    `` /* 150-byte string literal not displayed */
	WorkflowSubType           dev7.VReplicationWorkflowSubType `` /* 164-byte string literal not displayed */
	// DeferSecondaryKeys specifies if secondary keys should be created in one shot after table
	// copy finishes.
	DeferSecondaryKeys bool `protobuf:"varint,8,opt,name=defer_secondary_keys,json=deferSecondaryKeys,proto3" json:"defer_secondary_keys,omitempty"`
	// AutoStart specifies if the workflow should be started when created.
	AutoStart bool `protobuf:"varint,9,opt,name=auto_start,json=autoStart,proto3" json:"auto_start,omitempty"`
	// Should the workflow stop after the copy phase.
	StopAfterCopy bool   `protobuf:"varint,10,opt,name=stop_after_copy,json=stopAfterCopy,proto3" json:"stop_after_copy,omitempty"`
	Options       string `protobuf:"bytes,11,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateVReplicationWorkflowRequest) GetAutoStart 

func (x *CreateVReplicationWorkflowRequest) GetAutoStart() bool

func (*CreateVReplicationWorkflowRequest) GetBinlogSource 

func (x *CreateVReplicationWorkflowRequest) GetBinlogSource() []*dev7.BinlogSource

func (*CreateVReplicationWorkflowRequest) GetCells 

func (x *CreateVReplicationWorkflowRequest) GetCells() []string

func (*CreateVReplicationWorkflowRequest) GetDeferSecondaryKeys 

func (x *CreateVReplicationWorkflowRequest) GetDeferSecondaryKeys() bool

func (*CreateVReplicationWorkflowRequest) GetOptions 

func (x *CreateVReplicationWorkflowRequest) GetOptions() string

func (*CreateVReplicationWorkflowRequest) GetStopAfterCopy 

func (x *CreateVReplicationWorkflowRequest) GetStopAfterCopy() bool

func (*CreateVReplicationWorkflowRequest) GetTabletSelectionPreference 

func (x *CreateVReplicationWorkflowRequest) GetTabletSelectionPreference() TabletSelectionPreference

func (*CreateVReplicationWorkflowRequest) GetTabletTypes 

func (x *CreateVReplicationWorkflowRequest) GetTabletTypes() []dev1.TabletType

func (*CreateVReplicationWorkflowRequest) GetWorkflow 

func (x *CreateVReplicationWorkflowRequest) GetWorkflow() string

func (*CreateVReplicationWorkflowRequest) GetWorkflowSubType 

func (x *CreateVReplicationWorkflowRequest) GetWorkflowSubType() dev7.VReplicationWorkflowSubType

func (*CreateVReplicationWorkflowRequest) GetWorkflowType 

func (x *CreateVReplicationWorkflowRequest) GetWorkflowType() dev7.VReplicationWorkflowType

func (*CreateVReplicationWorkflowRequest) ProtoMessage 

func (*CreateVReplicationWorkflowRequest) ProtoMessage()

func (*CreateVReplicationWorkflowRequest) ProtoReflect 

func (x *CreateVReplicationWorkflowRequest) ProtoReflect() protoreflect.Message

func (*CreateVReplicationWorkflowRequest) Reset 

func (x *CreateVReplicationWorkflowRequest) Reset()

func (*CreateVReplicationWorkflowRequest) SetAutoStart 

func (x *CreateVReplicationWorkflowRequest) SetAutoStart(v bool)

func (*CreateVReplicationWorkflowRequest) SetBinlogSource 

func (x *CreateVReplicationWorkflowRequest) SetBinlogSource(v []*dev7.BinlogSource)

func (*CreateVReplicationWorkflowRequest) SetCells 

func (x *CreateVReplicationWorkflowRequest) SetCells(v []string)

func (*CreateVReplicationWorkflowRequest) SetDeferSecondaryKeys 

func (x *CreateVReplicationWorkflowRequest) SetDeferSecondaryKeys(v bool)

func (*CreateVReplicationWorkflowRequest) SetOptions 

func (x *CreateVReplicationWorkflowRequest) SetOptions(v string)

func (*CreateVReplicationWorkflowRequest) SetStopAfterCopy 

func (x *CreateVReplicationWorkflowRequest) SetStopAfterCopy(v bool)

func (*CreateVReplicationWorkflowRequest) SetTabletSelectionPreference 

func (x *CreateVReplicationWorkflowRequest) SetTabletSelectionPreference(v TabletSelectionPreference)

func (*CreateVReplicationWorkflowRequest) SetTabletTypes 

func (x *CreateVReplicationWorkflowRequest) SetTabletTypes(v []dev1.TabletType)

func (*CreateVReplicationWorkflowRequest) SetWorkflow 

func (x *CreateVReplicationWorkflowRequest) SetWorkflow(v string)

func (*CreateVReplicationWorkflowRequest) SetWorkflowSubType 

func (x *CreateVReplicationWorkflowRequest) SetWorkflowSubType(v dev7.VReplicationWorkflowSubType)

func (*CreateVReplicationWorkflowRequest) SetWorkflowType 

func (x *CreateVReplicationWorkflowRequest) SetWorkflowType(v dev7.VReplicationWorkflowType)

func (*CreateVReplicationWorkflowRequest) String 

func (x *CreateVReplicationWorkflowRequest) String() string

type CreateVReplicationWorkflowRequest_builder 

type CreateVReplicationWorkflowRequest_builder struct {
	Workflow     string
	BinlogSource []*dev7.BinlogSource
	// Optional parameters.
	Cells []string
	// TabletTypes is the list of tablet types to use when selecting source tablets.
	TabletTypes               []dev1.TabletType
	TabletSelectionPreference TabletSelectionPreference
	WorkflowType              dev7.VReplicationWorkflowType
	WorkflowSubType           dev7.VReplicationWorkflowSubType
	// DeferSecondaryKeys specifies if secondary keys should be created in one shot after table
	// copy finishes.
	DeferSecondaryKeys bool
	// AutoStart specifies if the workflow should be started when created.
	AutoStart bool
	// Should the workflow stop after the copy phase.
	StopAfterCopy bool
	Options       string
	// contains filtered or unexported fields
}

func (CreateVReplicationWorkflowRequest_builder) Build 

func (b0 CreateVReplicationWorkflowRequest_builder) Build() *CreateVReplicationWorkflowRequest

type CreateVReplicationWorkflowResponse 

type CreateVReplicationWorkflowResponse struct {
	Result *dev.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateVReplicationWorkflowResponse) ClearResult 

func (x *CreateVReplicationWorkflowResponse) ClearResult()

func (*CreateVReplicationWorkflowResponse) GetResult 

func (x *CreateVReplicationWorkflowResponse) GetResult() *dev.QueryResult

func (*CreateVReplicationWorkflowResponse) HasResult 

func (x *CreateVReplicationWorkflowResponse) HasResult() bool

func (*CreateVReplicationWorkflowResponse) ProtoMessage 

func (*CreateVReplicationWorkflowResponse) ProtoMessage()

func (*CreateVReplicationWorkflowResponse) ProtoReflect 

func (x *CreateVReplicationWorkflowResponse) ProtoReflect() protoreflect.Message

func (*CreateVReplicationWorkflowResponse) Reset 

func (x *CreateVReplicationWorkflowResponse) Reset()

func (*CreateVReplicationWorkflowResponse) SetResult 

func (x *CreateVReplicationWorkflowResponse) SetResult(v *dev.QueryResult)

func (*CreateVReplicationWorkflowResponse) String 

func (x *CreateVReplicationWorkflowResponse) String() string

type CreateVReplicationWorkflowResponse_builder 

type CreateVReplicationWorkflowResponse_builder struct {
	Result *dev.QueryResult
	// contains filtered or unexported fields
}

func (CreateVReplicationWorkflowResponse_builder) Build 

func (b0 CreateVReplicationWorkflowResponse_builder) Build() *CreateVReplicationWorkflowResponse

type DbPermission 

type DbPermission struct {
	Host       string            `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Db         string            `protobuf:"bytes,2,opt,name=db,proto3" json:"db,omitempty"`
	User       string            `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	Privileges map[string]string `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

DbPermission describes a single row in the mysql.db table Primary key is Host+Db+User

func (*DbPermission) GetDb 

func (x *DbPermission) GetDb() string

func (*DbPermission) GetHost 

func (x *DbPermission) GetHost() string

func (*DbPermission) GetPrivileges 

func (x *DbPermission) GetPrivileges() map[string]string

func (*DbPermission) GetUser 

func (x *DbPermission) GetUser() string

func (*DbPermission) ProtoMessage 

func (*DbPermission) ProtoMessage()

func (*DbPermission) ProtoReflect 

func (x *DbPermission) ProtoReflect() protoreflect.Message

func (*DbPermission) Reset 

func (x *DbPermission) Reset()

func (*DbPermission) SetDb 

func (x *DbPermission) SetDb(v string)

func (*DbPermission) SetHost 

func (x *DbPermission) SetHost(v string)

func (*DbPermission) SetPrivileges 

func (x *DbPermission) SetPrivileges(v map[string]string)

func (*DbPermission) SetUser 

func (x *DbPermission) SetUser(v string)

func (*DbPermission) String 

func (x *DbPermission) String() string

type DbPermission_builder 

type DbPermission_builder struct {
	Host       string
	Db         string
	User       string
	Privileges map[string]string
	// contains filtered or unexported fields
}

func (DbPermission_builder) Build 

func (b0 DbPermission_builder) Build() *DbPermission

type DeleteTableDataRequest 

type DeleteTableDataRequest struct {

	// The key is the table that we want to delete data from.
	// The value is the filter or WHERE clause to use when deleting
	// data in the table.
	TableFilters map[string]string `` /* 171-byte string literal not displayed */
	// BatchSize is the number of rows to delete in a single batch.
	BatchSize int64 `protobuf:"varint,2,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTableDataRequest) GetBatchSize 

func (x *DeleteTableDataRequest) GetBatchSize() int64

func (*DeleteTableDataRequest) GetTableFilters 

func (x *DeleteTableDataRequest) GetTableFilters() map[string]string

func (*DeleteTableDataRequest) ProtoMessage 

func (*DeleteTableDataRequest) ProtoMessage()

func (*DeleteTableDataRequest) ProtoReflect 

func (x *DeleteTableDataRequest) ProtoReflect() protoreflect.Message

func (*DeleteTableDataRequest) Reset 

func (x *DeleteTableDataRequest) Reset()

func (*DeleteTableDataRequest) SetBatchSize 

func (x *DeleteTableDataRequest) SetBatchSize(v int64)

func (*DeleteTableDataRequest) SetTableFilters 

func (x *DeleteTableDataRequest) SetTableFilters(v map[string]string)

func (*DeleteTableDataRequest) String 

func (x *DeleteTableDataRequest) String() string

type DeleteTableDataRequest_builder 

type DeleteTableDataRequest_builder struct {

	// The key is the table that we want to delete data from.
	// The value is the filter or WHERE clause to use when deleting
	// data in the table.
	TableFilters map[string]string
	// BatchSize is the number of rows to delete in a single batch.
	BatchSize int64
	// contains filtered or unexported fields
}

func (DeleteTableDataRequest_builder) Build 

func (b0 DeleteTableDataRequest_builder) Build() *DeleteTableDataRequest

type DeleteTableDataResponse 

type DeleteTableDataResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteTableDataResponse) ProtoMessage 

func (*DeleteTableDataResponse) ProtoMessage()

func (*DeleteTableDataResponse) ProtoReflect 

func (x *DeleteTableDataResponse) ProtoReflect() protoreflect.Message

func (*DeleteTableDataResponse) Reset 

func (x *DeleteTableDataResponse) Reset()

func (*DeleteTableDataResponse) String 

func (x *DeleteTableDataResponse) String() string

type DeleteTableDataResponse_builder 

type DeleteTableDataResponse_builder struct {
	// contains filtered or unexported fields
}

func (DeleteTableDataResponse_builder) Build 

func (b0 DeleteTableDataResponse_builder) Build() *DeleteTableDataResponse

type DeleteVReplicationWorkflowRequest 

type DeleteVReplicationWorkflowRequest struct {
	Workflow string `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteVReplicationWorkflowRequest) GetWorkflow 

func (x *DeleteVReplicationWorkflowRequest) GetWorkflow() string

func (*DeleteVReplicationWorkflowRequest) ProtoMessage 

func (*DeleteVReplicationWorkflowRequest) ProtoMessage()

func (*DeleteVReplicationWorkflowRequest) ProtoReflect 

func (x *DeleteVReplicationWorkflowRequest) ProtoReflect() protoreflect.Message

func (*DeleteVReplicationWorkflowRequest) Reset 

func (x *DeleteVReplicationWorkflowRequest) Reset()

func (*DeleteVReplicationWorkflowRequest) SetWorkflow 

func (x *DeleteVReplicationWorkflowRequest) SetWorkflow(v string)

func (*DeleteVReplicationWorkflowRequest) String 

func (x *DeleteVReplicationWorkflowRequest) String() string

type DeleteVReplicationWorkflowRequest_builder 

type DeleteVReplicationWorkflowRequest_builder struct {
	Workflow string
	// contains filtered or unexported fields
}

func (DeleteVReplicationWorkflowRequest_builder) Build 

func (b0 DeleteVReplicationWorkflowRequest_builder) Build() *DeleteVReplicationWorkflowRequest

type DeleteVReplicationWorkflowResponse 

type DeleteVReplicationWorkflowResponse struct {
	Result *dev.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteVReplicationWorkflowResponse) ClearResult 

func (x *DeleteVReplicationWorkflowResponse) ClearResult()

func (*DeleteVReplicationWorkflowResponse) GetResult 

func (x *DeleteVReplicationWorkflowResponse) GetResult() *dev.QueryResult

func (*DeleteVReplicationWorkflowResponse) HasResult 

func (x *DeleteVReplicationWorkflowResponse) HasResult() bool

func (*DeleteVReplicationWorkflowResponse) ProtoMessage 

func (*DeleteVReplicationWorkflowResponse) ProtoMessage()

func (*DeleteVReplicationWorkflowResponse) ProtoReflect 

func (x *DeleteVReplicationWorkflowResponse) ProtoReflect() protoreflect.Message

func (*DeleteVReplicationWorkflowResponse) Reset 

func (x *DeleteVReplicationWorkflowResponse) Reset()

func (*DeleteVReplicationWorkflowResponse) SetResult 

func (x *DeleteVReplicationWorkflowResponse) SetResult(v *dev.QueryResult)

func (*DeleteVReplicationWorkflowResponse) String 

func (x *DeleteVReplicationWorkflowResponse) String() string

type DeleteVReplicationWorkflowResponse_builder 

type DeleteVReplicationWorkflowResponse_builder struct {
	Result *dev.QueryResult
	// contains filtered or unexported fields
}

func (DeleteVReplicationWorkflowResponse_builder) Build 

func (b0 DeleteVReplicationWorkflowResponse_builder) Build() *DeleteVReplicationWorkflowResponse

type DemotePrimaryRequest 

type DemotePrimaryRequest struct {
	// contains filtered or unexported fields
}

func (*DemotePrimaryRequest) ProtoMessage 

func (*DemotePrimaryRequest) ProtoMessage()

func (*DemotePrimaryRequest) ProtoReflect 

func (x *DemotePrimaryRequest) ProtoReflect() protoreflect.Message

func (*DemotePrimaryRequest) Reset 

func (x *DemotePrimaryRequest) Reset()

func (*DemotePrimaryRequest) String 

func (x *DemotePrimaryRequest) String() string

type DemotePrimaryRequest_builder 

type DemotePrimaryRequest_builder struct {
	// contains filtered or unexported fields
}

func (DemotePrimaryRequest_builder) Build 

func (b0 DemotePrimaryRequest_builder) Build() *DemotePrimaryRequest

type DemotePrimaryResponse 

type DemotePrimaryResponse struct {

	// PrimaryStatus represents the response from calling `SHOW BINARY LOG STATUS` on a primary that has been demoted.
	PrimaryStatus *dev4.PrimaryStatus `protobuf:"bytes,2,opt,name=primary_status,json=primaryStatus,proto3" json:"primary_status,omitempty"`
	// contains filtered or unexported fields
}

func (*DemotePrimaryResponse) ClearPrimaryStatus 

func (x *DemotePrimaryResponse) ClearPrimaryStatus()

func (*DemotePrimaryResponse) GetPrimaryStatus 

func (x *DemotePrimaryResponse) GetPrimaryStatus() *dev4.PrimaryStatus

func (*DemotePrimaryResponse) HasPrimaryStatus 

func (x *DemotePrimaryResponse) HasPrimaryStatus() bool

func (*DemotePrimaryResponse) ProtoMessage 

func (*DemotePrimaryResponse) ProtoMessage()

func (*DemotePrimaryResponse) ProtoReflect 

func (x *DemotePrimaryResponse) ProtoReflect() protoreflect.Message

func (*DemotePrimaryResponse) Reset 

func (x *DemotePrimaryResponse) Reset()

func (*DemotePrimaryResponse) SetPrimaryStatus 

func (x *DemotePrimaryResponse) SetPrimaryStatus(v *dev4.PrimaryStatus)

func (*DemotePrimaryResponse) String 

func (x *DemotePrimaryResponse) String() string

type DemotePrimaryResponse_builder 

type DemotePrimaryResponse_builder struct {

	// PrimaryStatus represents the response from calling `SHOW BINARY LOG STATUS` on a primary that has been demoted.
	PrimaryStatus *dev4.PrimaryStatus
	// contains filtered or unexported fields
}

func (DemotePrimaryResponse_builder) Build 

func (b0 DemotePrimaryResponse_builder) Build() *DemotePrimaryResponse

type ExecuteFetchAsAllPrivsRequest 

type ExecuteFetchAsAllPrivsRequest struct {
	Query        []byte `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	DbName       string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	MaxRows      uint64 `protobuf:"varint,3,opt,name=max_rows,json=maxRows,proto3" json:"max_rows,omitempty"`
	ReloadSchema bool   `protobuf:"varint,4,opt,name=reload_schema,json=reloadSchema,proto3" json:"reload_schema,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteFetchAsAllPrivsRequest) GetDbName 

func (x *ExecuteFetchAsAllPrivsRequest) GetDbName() string

func (*ExecuteFetchAsAllPrivsRequest) GetMaxRows 

func (x *ExecuteFetchAsAllPrivsRequest) GetMaxRows() uint64

func (*ExecuteFetchAsAllPrivsRequest) GetQuery 

func (x *ExecuteFetchAsAllPrivsRequest) GetQuery() []byte

func (*ExecuteFetchAsAllPrivsRequest) GetReloadSchema 

func (x *ExecuteFetchAsAllPrivsRequest) GetReloadSchema() bool

func (*ExecuteFetchAsAllPrivsRequest) ProtoMessage 

func (*ExecuteFetchAsAllPrivsRequest) ProtoMessage()

func (*ExecuteFetchAsAllPrivsRequest) ProtoReflect 

func (x *ExecuteFetchAsAllPrivsRequest) ProtoReflect() protoreflect.Message

func (*ExecuteFetchAsAllPrivsRequest) Reset 

func (x *ExecuteFetchAsAllPrivsRequest) Reset()

func (*ExecuteFetchAsAllPrivsRequest) SetDbName 

func (x *ExecuteFetchAsAllPrivsRequest) SetDbName(v string)

func (*ExecuteFetchAsAllPrivsRequest) SetMaxRows 

func (x *ExecuteFetchAsAllPrivsRequest) SetMaxRows(v uint64)

func (*ExecuteFetchAsAllPrivsRequest) SetQuery 

func (x *ExecuteFetchAsAllPrivsRequest) SetQuery(v []byte)

func (*ExecuteFetchAsAllPrivsRequest) SetReloadSchema 

func (x *ExecuteFetchAsAllPrivsRequest) SetReloadSchema(v bool)

func (*ExecuteFetchAsAllPrivsRequest) String 

func (x *ExecuteFetchAsAllPrivsRequest) String() string

type ExecuteFetchAsAllPrivsRequest_builder 

type ExecuteFetchAsAllPrivsRequest_builder struct {
	Query        []byte
	DbName       string
	MaxRows      uint64
	ReloadSchema bool
	// contains filtered or unexported fields
}

func (ExecuteFetchAsAllPrivsRequest_builder) Build 

func (b0 ExecuteFetchAsAllPrivsRequest_builder) Build() *ExecuteFetchAsAllPrivsRequest

type ExecuteFetchAsAllPrivsResponse 

type ExecuteFetchAsAllPrivsResponse struct {
	Result *dev.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteFetchAsAllPrivsResponse) ClearResult 

func (x *ExecuteFetchAsAllPrivsResponse) ClearResult()

func (*ExecuteFetchAsAllPrivsResponse) GetResult 

func (x *ExecuteFetchAsAllPrivsResponse) GetResult() *dev.QueryResult

func (*ExecuteFetchAsAllPrivsResponse) HasResult 

func (x *ExecuteFetchAsAllPrivsResponse) HasResult() bool

func (*ExecuteFetchAsAllPrivsResponse) ProtoMessage 

func (*ExecuteFetchAsAllPrivsResponse) ProtoMessage()

func (*ExecuteFetchAsAllPrivsResponse) ProtoReflect 

func (x *ExecuteFetchAsAllPrivsResponse) ProtoReflect() protoreflect.Message

func (*ExecuteFetchAsAllPrivsResponse) Reset 

func (x *ExecuteFetchAsAllPrivsResponse) Reset()

func (*ExecuteFetchAsAllPrivsResponse) SetResult 

func (x *ExecuteFetchAsAllPrivsResponse) SetResult(v *dev.QueryResult)

func (*ExecuteFetchAsAllPrivsResponse) String 

func (x *ExecuteFetchAsAllPrivsResponse) String() string

type ExecuteFetchAsAllPrivsResponse_builder 

type ExecuteFetchAsAllPrivsResponse_builder struct {
	Result *dev.QueryResult
	// contains filtered or unexported fields
}

func (ExecuteFetchAsAllPrivsResponse_builder) Build 

func (b0 ExecuteFetchAsAllPrivsResponse_builder) Build() *ExecuteFetchAsAllPrivsResponse

type ExecuteFetchAsAppRequest 

type ExecuteFetchAsAppRequest struct {
	Query   []byte `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	MaxRows uint64 `protobuf:"varint,2,opt,name=max_rows,json=maxRows,proto3" json:"max_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteFetchAsAppRequest) GetMaxRows 

func (x *ExecuteFetchAsAppRequest) GetMaxRows() uint64

func (*ExecuteFetchAsAppRequest) GetQuery 

func (x *ExecuteFetchAsAppRequest) GetQuery() []byte

func (*ExecuteFetchAsAppRequest) ProtoMessage 

func (*ExecuteFetchAsAppRequest) ProtoMessage()

func (*ExecuteFetchAsAppRequest) ProtoReflect 

func (x *ExecuteFetchAsAppRequest) ProtoReflect() protoreflect.Message

func (*ExecuteFetchAsAppRequest) Reset 

func (x *ExecuteFetchAsAppRequest) Reset()

func (*ExecuteFetchAsAppRequest) SetMaxRows 

func (x *ExecuteFetchAsAppRequest) SetMaxRows(v uint64)

func (*ExecuteFetchAsAppRequest) SetQuery 

func (x *ExecuteFetchAsAppRequest) SetQuery(v []byte)

func (*ExecuteFetchAsAppRequest) String 

func (x *ExecuteFetchAsAppRequest) String() string

type ExecuteFetchAsAppRequest_builder 

type ExecuteFetchAsAppRequest_builder struct {
	Query   []byte
	MaxRows uint64
	// contains filtered or unexported fields
}

func (ExecuteFetchAsAppRequest_builder) Build 

func (b0 ExecuteFetchAsAppRequest_builder) Build() *ExecuteFetchAsAppRequest

type ExecuteFetchAsAppResponse 

type ExecuteFetchAsAppResponse struct {
	Result *dev.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteFetchAsAppResponse) ClearResult 

func (x *ExecuteFetchAsAppResponse) ClearResult()

func (*ExecuteFetchAsAppResponse) GetResult 

func (x *ExecuteFetchAsAppResponse) GetResult() *dev.QueryResult

func (*ExecuteFetchAsAppResponse) HasResult 

func (x *ExecuteFetchAsAppResponse) HasResult() bool

func (*ExecuteFetchAsAppResponse) ProtoMessage 

func (*ExecuteFetchAsAppResponse) ProtoMessage()

func (*ExecuteFetchAsAppResponse) ProtoReflect 

func (x *ExecuteFetchAsAppResponse) ProtoReflect() protoreflect.Message

func (*ExecuteFetchAsAppResponse) Reset 

func (x *ExecuteFetchAsAppResponse) Reset()

func (*ExecuteFetchAsAppResponse) SetResult 

func (x *ExecuteFetchAsAppResponse) SetResult(v *dev.QueryResult)

func (*ExecuteFetchAsAppResponse) String 

func (x *ExecuteFetchAsAppResponse) String() string

type ExecuteFetchAsAppResponse_builder 

type ExecuteFetchAsAppResponse_builder struct {
	Result *dev.QueryResult
	// contains filtered or unexported fields
}

func (ExecuteFetchAsAppResponse_builder) Build 

func (b0 ExecuteFetchAsAppResponse_builder) Build() *ExecuteFetchAsAppResponse

type ExecuteFetchAsDbaRequest 

type ExecuteFetchAsDbaRequest struct {
	Query                   []byte `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	DbName                  string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	MaxRows                 uint64 `protobuf:"varint,3,opt,name=max_rows,json=maxRows,proto3" json:"max_rows,omitempty"`
	DisableBinlogs          bool   `protobuf:"varint,4,opt,name=disable_binlogs,json=disableBinlogs,proto3" json:"disable_binlogs,omitempty"`
	ReloadSchema            bool   `protobuf:"varint,5,opt,name=reload_schema,json=reloadSchema,proto3" json:"reload_schema,omitempty"`
	DisableForeignKeyChecks bool   `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecuteFetchAsDbaRequest) GetDbName 

func (x *ExecuteFetchAsDbaRequest) GetDbName() string

func (*ExecuteFetchAsDbaRequest) GetDisableBinlogs 

func (x *ExecuteFetchAsDbaRequest) GetDisableBinlogs() bool

func (*ExecuteFetchAsDbaRequest) GetDisableForeignKeyChecks 

func (x *ExecuteFetchAsDbaRequest) GetDisableForeignKeyChecks() bool

func (*ExecuteFetchAsDbaRequest) GetMaxRows 

func (x *ExecuteFetchAsDbaRequest) GetMaxRows() uint64

func (*ExecuteFetchAsDbaRequest) GetQuery 

func (x *ExecuteFetchAsDbaRequest) GetQuery() []byte

func (*ExecuteFetchAsDbaRequest) GetReloadSchema 

func (x *ExecuteFetchAsDbaRequest) GetReloadSchema() bool

func (*ExecuteFetchAsDbaRequest) ProtoMessage 

func (*ExecuteFetchAsDbaRequest) ProtoMessage()

func (*ExecuteFetchAsDbaRequest) ProtoReflect 

func (x *ExecuteFetchAsDbaRequest) ProtoReflect() protoreflect.Message

func (*ExecuteFetchAsDbaRequest) Reset 

func (x *ExecuteFetchAsDbaRequest) Reset()

func (*ExecuteFetchAsDbaRequest) SetDbName 

func (x *ExecuteFetchAsDbaRequest) SetDbName(v string)

func (*ExecuteFetchAsDbaRequest) SetDisableBinlogs 

func (x *ExecuteFetchAsDbaRequest) SetDisableBinlogs(v bool)

func (*ExecuteFetchAsDbaRequest) SetDisableForeignKeyChecks 

func (x *ExecuteFetchAsDbaRequest) SetDisableForeignKeyChecks(v bool)

func (*ExecuteFetchAsDbaRequest) SetMaxRows 

func (x *ExecuteFetchAsDbaRequest) SetMaxRows(v uint64)

func (*ExecuteFetchAsDbaRequest) SetQuery 

func (x *ExecuteFetchAsDbaRequest) SetQuery(v []byte)

func (*ExecuteFetchAsDbaRequest) SetReloadSchema 

func (x *ExecuteFetchAsDbaRequest) SetReloadSchema(v bool)

func (*ExecuteFetchAsDbaRequest) String 

func (x *ExecuteFetchAsDbaRequest) String() string

type ExecuteFetchAsDbaRequest_builder 

type ExecuteFetchAsDbaRequest_builder struct {
	Query                   []byte
	DbName                  string
	MaxRows                 uint64
	DisableBinlogs          bool
	ReloadSchema            bool
	DisableForeignKeyChecks bool
	// contains filtered or unexported fields
}

func (ExecuteFetchAsDbaRequest_builder) Build 

func (b0 ExecuteFetchAsDbaRequest_builder) Build() *ExecuteFetchAsDbaRequest

type ExecuteFetchAsDbaResponse 

type ExecuteFetchAsDbaResponse struct {
	Result *dev.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteFetchAsDbaResponse) ClearResult 

func (x *ExecuteFetchAsDbaResponse) ClearResult()

func (*ExecuteFetchAsDbaResponse) GetResult 

func (x *ExecuteFetchAsDbaResponse) GetResult() *dev.QueryResult

func (*ExecuteFetchAsDbaResponse) HasResult 

func (x *ExecuteFetchAsDbaResponse) HasResult() bool

func (*ExecuteFetchAsDbaResponse) ProtoMessage 

func (*ExecuteFetchAsDbaResponse) ProtoMessage()

func (*ExecuteFetchAsDbaResponse) ProtoReflect 

func (x *ExecuteFetchAsDbaResponse) ProtoReflect() protoreflect.Message

func (*ExecuteFetchAsDbaResponse) Reset 

func (x *ExecuteFetchAsDbaResponse) Reset()

func (*ExecuteFetchAsDbaResponse) SetResult 

func (x *ExecuteFetchAsDbaResponse) SetResult(v *dev.QueryResult)

func (*ExecuteFetchAsDbaResponse) String 

func (x *ExecuteFetchAsDbaResponse) String() string

type ExecuteFetchAsDbaResponse_builder 

type ExecuteFetchAsDbaResponse_builder struct {
	Result *dev.QueryResult
	// contains filtered or unexported fields
}

func (ExecuteFetchAsDbaResponse_builder) Build 

func (b0 ExecuteFetchAsDbaResponse_builder) Build() *ExecuteFetchAsDbaResponse

type ExecuteHookRequest 

type ExecuteHookRequest struct {
	Name       string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Parameters []string          `protobuf:"bytes,2,rep,name=parameters,proto3" json:"parameters,omitempty"`
	ExtraEnv   map[string]string `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecuteHookRequest) GetExtraEnv 

func (x *ExecuteHookRequest) GetExtraEnv() map[string]string

func (*ExecuteHookRequest) GetName 

func (x *ExecuteHookRequest) GetName() string

func (*ExecuteHookRequest) GetParameters 

func (x *ExecuteHookRequest) GetParameters() []string

func (*ExecuteHookRequest) ProtoMessage 

func (*ExecuteHookRequest) ProtoMessage()

func (*ExecuteHookRequest) ProtoReflect 

func (x *ExecuteHookRequest) ProtoReflect() protoreflect.Message

func (*ExecuteHookRequest) Reset 

func (x *ExecuteHookRequest) Reset()

func (*ExecuteHookRequest) SetExtraEnv 

func (x *ExecuteHookRequest) SetExtraEnv(v map[string]string)

func (*ExecuteHookRequest) SetName 

func (x *ExecuteHookRequest) SetName(v string)

func (*ExecuteHookRequest) SetParameters 

func (x *ExecuteHookRequest) SetParameters(v []string)

func (*ExecuteHookRequest) String 

func (x *ExecuteHookRequest) String() string

type ExecuteHookRequest_builder 

type ExecuteHookRequest_builder struct {
	Name       string
	Parameters []string
	ExtraEnv   map[string]string
	// contains filtered or unexported fields
}

func (ExecuteHookRequest_builder) Build 

func (b0 ExecuteHookRequest_builder) Build() *ExecuteHookRequest

type ExecuteHookResponse 

type ExecuteHookResponse struct {
	ExitStatus int64  `protobuf:"varint,1,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	Stdout     string `protobuf:"bytes,2,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr     string `protobuf:"bytes,3,opt,name=stderr,proto3" json:"stderr,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteHookResponse) GetExitStatus 

func (x *ExecuteHookResponse) GetExitStatus() int64

func (*ExecuteHookResponse) GetStderr 

func (x *ExecuteHookResponse) GetStderr() string

func (*ExecuteHookResponse) GetStdout 

func (x *ExecuteHookResponse) GetStdout() string

func (*ExecuteHookResponse) ProtoMessage 

func (*ExecuteHookResponse) ProtoMessage()

func (*ExecuteHookResponse) ProtoReflect 

func (x *ExecuteHookResponse) ProtoReflect() protoreflect.Message

func (*ExecuteHookResponse) Reset 

func (x *ExecuteHookResponse) Reset()

func (*ExecuteHookResponse) SetExitStatus 

func (x *ExecuteHookResponse) SetExitStatus(v int64)

func (*ExecuteHookResponse) SetStderr 

func (x *ExecuteHookResponse) SetStderr(v string)

func (*ExecuteHookResponse) SetStdout 

func (x *ExecuteHookResponse) SetStdout(v string)

func (*ExecuteHookResponse) String 

func (x *ExecuteHookResponse) String() string

type ExecuteHookResponse_builder 

type ExecuteHookResponse_builder struct {
	ExitStatus int64
	Stdout     string
	Stderr     string
	// contains filtered or unexported fields
}

func (ExecuteHookResponse_builder) Build 

func (b0 ExecuteHookResponse_builder) Build() *ExecuteHookResponse

type ExecuteMultiFetchAsDbaRequest 

type ExecuteMultiFetchAsDbaRequest struct {
	Sql                     []byte `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	DbName                  string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	MaxRows                 uint64 `protobuf:"varint,3,opt,name=max_rows,json=maxRows,proto3" json:"max_rows,omitempty"`
	DisableBinlogs          bool   `protobuf:"varint,4,opt,name=disable_binlogs,json=disableBinlogs,proto3" json:"disable_binlogs,omitempty"`
	ReloadSchema            bool   `protobuf:"varint,5,opt,name=reload_schema,json=reloadSchema,proto3" json:"reload_schema,omitempty"`
	DisableForeignKeyChecks bool   `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecuteMultiFetchAsDbaRequest) GetDbName 

func (x *ExecuteMultiFetchAsDbaRequest) GetDbName() string

func (*ExecuteMultiFetchAsDbaRequest) GetDisableBinlogs 

func (x *ExecuteMultiFetchAsDbaRequest) GetDisableBinlogs() bool

func (*ExecuteMultiFetchAsDbaRequest) GetDisableForeignKeyChecks 

func (x *ExecuteMultiFetchAsDbaRequest) GetDisableForeignKeyChecks() bool

func (*ExecuteMultiFetchAsDbaRequest) GetMaxRows 

func (x *ExecuteMultiFetchAsDbaRequest) GetMaxRows() uint64

func (*ExecuteMultiFetchAsDbaRequest) GetReloadSchema 

func (x *ExecuteMultiFetchAsDbaRequest) GetReloadSchema() bool

func (*ExecuteMultiFetchAsDbaRequest) GetSql 

func (x *ExecuteMultiFetchAsDbaRequest) GetSql() []byte

func (*ExecuteMultiFetchAsDbaRequest) ProtoMessage 

func (*ExecuteMultiFetchAsDbaRequest) ProtoMessage()

func (*ExecuteMultiFetchAsDbaRequest) ProtoReflect 

func (x *ExecuteMultiFetchAsDbaRequest) ProtoReflect() protoreflect.Message

func (*ExecuteMultiFetchAsDbaRequest) Reset 

func (x *ExecuteMultiFetchAsDbaRequest) Reset()

func (*ExecuteMultiFetchAsDbaRequest) SetDbName 

func (x *ExecuteMultiFetchAsDbaRequest) SetDbName(v string)

func (*ExecuteMultiFetchAsDbaRequest) SetDisableBinlogs 

func (x *ExecuteMultiFetchAsDbaRequest) SetDisableBinlogs(v bool)

func (*ExecuteMultiFetchAsDbaRequest) SetDisableForeignKeyChecks 

func (x *ExecuteMultiFetchAsDbaRequest) SetDisableForeignKeyChecks(v bool)

func (*ExecuteMultiFetchAsDbaRequest) SetMaxRows 

func (x *ExecuteMultiFetchAsDbaRequest) SetMaxRows(v uint64)

func (*ExecuteMultiFetchAsDbaRequest) SetReloadSchema 

func (x *ExecuteMultiFetchAsDbaRequest) SetReloadSchema(v bool)

func (*ExecuteMultiFetchAsDbaRequest) SetSql 

func (x *ExecuteMultiFetchAsDbaRequest) SetSql(v []byte)

func (*ExecuteMultiFetchAsDbaRequest) String 

func (x *ExecuteMultiFetchAsDbaRequest) String() string

type ExecuteMultiFetchAsDbaRequest_builder 

type ExecuteMultiFetchAsDbaRequest_builder struct {
	Sql                     []byte
	DbName                  string
	MaxRows                 uint64
	DisableBinlogs          bool
	ReloadSchema            bool
	DisableForeignKeyChecks bool
	// contains filtered or unexported fields
}

func (ExecuteMultiFetchAsDbaRequest_builder) Build 

func (b0 ExecuteMultiFetchAsDbaRequest_builder) Build() *ExecuteMultiFetchAsDbaRequest

type ExecuteMultiFetchAsDbaResponse 

type ExecuteMultiFetchAsDbaResponse struct {
	Results []*dev.QueryResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteMultiFetchAsDbaResponse) GetResults 

func (x *ExecuteMultiFetchAsDbaResponse) GetResults() []*dev.QueryResult

func (*ExecuteMultiFetchAsDbaResponse) ProtoMessage 

func (*ExecuteMultiFetchAsDbaResponse) ProtoMessage()

func (*ExecuteMultiFetchAsDbaResponse) ProtoReflect 

func (x *ExecuteMultiFetchAsDbaResponse) ProtoReflect() protoreflect.Message

func (*ExecuteMultiFetchAsDbaResponse) Reset 

func (x *ExecuteMultiFetchAsDbaResponse) Reset()

func (*ExecuteMultiFetchAsDbaResponse) SetResults 

func (x *ExecuteMultiFetchAsDbaResponse) SetResults(v []*dev.QueryResult)

func (*ExecuteMultiFetchAsDbaResponse) String 

func (x *ExecuteMultiFetchAsDbaResponse) String() string

type ExecuteMultiFetchAsDbaResponse_builder 

type ExecuteMultiFetchAsDbaResponse_builder struct {
	Results []*dev.QueryResult
	// contains filtered or unexported fields
}

func (ExecuteMultiFetchAsDbaResponse_builder) Build 

func (b0 ExecuteMultiFetchAsDbaResponse_builder) Build() *ExecuteMultiFetchAsDbaResponse

type ExecuteQueryRequest 

type ExecuteQueryRequest struct {
	Query   []byte `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	DbName  string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	MaxRows uint64 `protobuf:"varint,3,opt,name=max_rows,json=maxRows,proto3" json:"max_rows,omitempty"`
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *dev2.CallerID `protobuf:"bytes,4,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteQueryRequest) ClearCallerId 

func (x *ExecuteQueryRequest) ClearCallerId()

func (*ExecuteQueryRequest) GetCallerId 

func (x *ExecuteQueryRequest) GetCallerId() *dev2.CallerID

func (*ExecuteQueryRequest) GetDbName 

func (x *ExecuteQueryRequest) GetDbName() string

func (*ExecuteQueryRequest) GetMaxRows 

func (x *ExecuteQueryRequest) GetMaxRows() uint64

func (*ExecuteQueryRequest) GetQuery 

func (x *ExecuteQueryRequest) GetQuery() []byte

func (*ExecuteQueryRequest) HasCallerId 

func (x *ExecuteQueryRequest) HasCallerId() bool

func (*ExecuteQueryRequest) ProtoMessage 

func (*ExecuteQueryRequest) ProtoMessage()

func (*ExecuteQueryRequest) ProtoReflect 

func (x *ExecuteQueryRequest) ProtoReflect() protoreflect.Message

func (*ExecuteQueryRequest) Reset 

func (x *ExecuteQueryRequest) Reset()

func (*ExecuteQueryRequest) SetCallerId 

func (x *ExecuteQueryRequest) SetCallerId(v *dev2.CallerID)

func (*ExecuteQueryRequest) SetDbName 

func (x *ExecuteQueryRequest) SetDbName(v string)

func (*ExecuteQueryRequest) SetMaxRows 

func (x *ExecuteQueryRequest) SetMaxRows(v uint64)

func (*ExecuteQueryRequest) SetQuery 

func (x *ExecuteQueryRequest) SetQuery(v []byte)

func (*ExecuteQueryRequest) String 

func (x *ExecuteQueryRequest) String() string

type ExecuteQueryRequest_builder 

type ExecuteQueryRequest_builder struct {
	Query   []byte
	DbName  string
	MaxRows uint64
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *dev2.CallerID
	// contains filtered or unexported fields
}

func (ExecuteQueryRequest_builder) Build 

func (b0 ExecuteQueryRequest_builder) Build() *ExecuteQueryRequest

type ExecuteQueryResponse 

type ExecuteQueryResponse struct {
	Result *dev.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteQueryResponse) ClearResult 

func (x *ExecuteQueryResponse) ClearResult()

func (*ExecuteQueryResponse) GetResult 

func (x *ExecuteQueryResponse) GetResult() *dev.QueryResult

func (*ExecuteQueryResponse) HasResult 

func (x *ExecuteQueryResponse) HasResult() bool

func (*ExecuteQueryResponse) ProtoMessage 

func (*ExecuteQueryResponse) ProtoMessage()

func (*ExecuteQueryResponse) ProtoReflect 

func (x *ExecuteQueryResponse) ProtoReflect() protoreflect.Message

func (*ExecuteQueryResponse) Reset 

func (x *ExecuteQueryResponse) Reset()

func (*ExecuteQueryResponse) SetResult 

func (x *ExecuteQueryResponse) SetResult(v *dev.QueryResult)

func (*ExecuteQueryResponse) String 

func (x *ExecuteQueryResponse) String() string

type ExecuteQueryResponse_builder 

type ExecuteQueryResponse_builder struct {
	Result *dev.QueryResult
	// contains filtered or unexported fields
}

func (ExecuteQueryResponse_builder) Build 

func (b0 ExecuteQueryResponse_builder) Build() *ExecuteQueryResponse

type FullStatusRequest 

type FullStatusRequest struct {
	// contains filtered or unexported fields
}

func (*FullStatusRequest) ProtoMessage 

func (*FullStatusRequest) ProtoMessage()

func (*FullStatusRequest) ProtoReflect 

func (x *FullStatusRequest) ProtoReflect() protoreflect.Message

func (*FullStatusRequest) Reset 

func (x *FullStatusRequest) Reset()

func (*FullStatusRequest) String 

func (x *FullStatusRequest) String() string

type FullStatusRequest_builder 

type FullStatusRequest_builder struct {
	// contains filtered or unexported fields
}

func (FullStatusRequest_builder) Build 

func (b0 FullStatusRequest_builder) Build() *FullStatusRequest

type FullStatusResponse 

type FullStatusResponse struct {
	Status *dev4.FullStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*FullStatusResponse) ClearStatus 

func (x *FullStatusResponse) ClearStatus()

func (*FullStatusResponse) GetStatus 

func (x *FullStatusResponse) GetStatus() *dev4.FullStatus

func (*FullStatusResponse) HasStatus 

func (x *FullStatusResponse) HasStatus() bool

func (*FullStatusResponse) ProtoMessage 

func (*FullStatusResponse) ProtoMessage()

func (*FullStatusResponse) ProtoReflect 

func (x *FullStatusResponse) ProtoReflect() protoreflect.Message

func (*FullStatusResponse) Reset 

func (x *FullStatusResponse) Reset()

func (*FullStatusResponse) SetStatus 

func (x *FullStatusResponse) SetStatus(v *dev4.FullStatus)

func (*FullStatusResponse) String 

func (x *FullStatusResponse) String() string

type FullStatusResponse_builder 

type FullStatusResponse_builder struct {
	Status *dev4.FullStatus
	// contains filtered or unexported fields
}

func (FullStatusResponse_builder) Build 

func (b0 FullStatusResponse_builder) Build() *FullStatusResponse

type GetGlobalStatusVarsRequest 

type GetGlobalStatusVarsRequest struct {
	Variables []string `protobuf:"bytes,1,rep,name=variables,proto3" json:"variables,omitempty"`
	// contains filtered or unexported fields
}

func (*GetGlobalStatusVarsRequest) GetVariables 

func (x *GetGlobalStatusVarsRequest) GetVariables() []string

func (*GetGlobalStatusVarsRequest) ProtoMessage 

func (*GetGlobalStatusVarsRequest) ProtoMessage()

func (*GetGlobalStatusVarsRequest) ProtoReflect 

func (x *GetGlobalStatusVarsRequest) ProtoReflect() protoreflect.Message

func (*GetGlobalStatusVarsRequest) Reset 

func (x *GetGlobalStatusVarsRequest) Reset()

func (*GetGlobalStatusVarsRequest) SetVariables 

func (x *GetGlobalStatusVarsRequest) SetVariables(v []string)

func (*GetGlobalStatusVarsRequest) String 

func (x *GetGlobalStatusVarsRequest) String() string

type GetGlobalStatusVarsRequest_builder 

type GetGlobalStatusVarsRequest_builder struct {
	Variables []string
	// contains filtered or unexported fields
}

func (GetGlobalStatusVarsRequest_builder) Build 

func (b0 GetGlobalStatusVarsRequest_builder) Build() *GetGlobalStatusVarsRequest

type GetGlobalStatusVarsResponse 

type GetGlobalStatusVarsResponse struct {
	StatusValues map[string]string `` /* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetGlobalStatusVarsResponse) GetStatusValues 

func (x *GetGlobalStatusVarsResponse) GetStatusValues() map[string]string

func (*GetGlobalStatusVarsResponse) ProtoMessage 

func (*GetGlobalStatusVarsResponse) ProtoMessage()

func (*GetGlobalStatusVarsResponse) ProtoReflect 

func (x *GetGlobalStatusVarsResponse) ProtoReflect() protoreflect.Message

func (*GetGlobalStatusVarsResponse) Reset 

func (x *GetGlobalStatusVarsResponse) Reset()

func (*GetGlobalStatusVarsResponse) SetStatusValues 

func (x *GetGlobalStatusVarsResponse) SetStatusValues(v map[string]string)

func (*GetGlobalStatusVarsResponse) String 

func (x *GetGlobalStatusVarsResponse) String() string

type GetGlobalStatusVarsResponse_builder 

type GetGlobalStatusVarsResponse_builder struct {
	StatusValues map[string]string
	// contains filtered or unexported fields
}

func (GetGlobalStatusVarsResponse_builder) Build 

func (b0 GetGlobalStatusVarsResponse_builder) Build() *GetGlobalStatusVarsResponse

type GetMaxValueForSequencesRequest 

type GetMaxValueForSequencesRequest struct {
	Sequences []*GetMaxValueForSequencesRequest_SequenceMetadata `protobuf:"bytes,1,rep,name=sequences,proto3" json:"sequences,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMaxValueForSequencesRequest) GetSequences 

func (x *GetMaxValueForSequencesRequest) GetSequences() []*GetMaxValueForSequencesRequest_SequenceMetadata

func (*GetMaxValueForSequencesRequest) ProtoMessage 

func (*GetMaxValueForSequencesRequest) ProtoMessage()

func (*GetMaxValueForSequencesRequest) ProtoReflect 

func (x *GetMaxValueForSequencesRequest) ProtoReflect() protoreflect.Message

func (*GetMaxValueForSequencesRequest) Reset 

func (x *GetMaxValueForSequencesRequest) Reset()

func (*GetMaxValueForSequencesRequest) SetSequences 

func (x *GetMaxValueForSequencesRequest) SetSequences(v []*GetMaxValueForSequencesRequest_SequenceMetadata)

func (*GetMaxValueForSequencesRequest) String 

func (x *GetMaxValueForSequencesRequest) String() string

type GetMaxValueForSequencesRequest_SequenceMetadata 

type GetMaxValueForSequencesRequest_SequenceMetadata struct {

	// The name of the sequence table. This will be used for mapping max value
	// with table in the response.
	BackingTableName string `protobuf:"bytes,1,opt,name=backing_table_name,json=backingTableName,proto3" json:"backing_table_name,omitempty"`
	// Escaped column name specified for sequence in table.
	UsingColEscaped string `protobuf:"bytes,2,opt,name=using_col_escaped,json=usingColEscaped,proto3" json:"using_col_escaped,omitempty"`
	// Escaped name of the table using the sequence.
	UsingTableNameEscaped string `` /* 128-byte string literal not displayed */
	// Escaped db name in use by the keyspace where the using table lives.
	UsingTableDbNameEscaped string `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetMaxValueForSequencesRequest_SequenceMetadata) GetBackingTableName 

func (x *GetMaxValueForSequencesRequest_SequenceMetadata) GetBackingTableName() string

func (*GetMaxValueForSequencesRequest_SequenceMetadata) GetUsingColEscaped 

func (x *GetMaxValueForSequencesRequest_SequenceMetadata) GetUsingColEscaped() string

func (*GetMaxValueForSequencesRequest_SequenceMetadata) GetUsingTableDbNameEscaped 

func (x *GetMaxValueForSequencesRequest_SequenceMetadata) GetUsingTableDbNameEscaped() string

func (*GetMaxValueForSequencesRequest_SequenceMetadata) GetUsingTableNameEscaped 

func (x *GetMaxValueForSequencesRequest_SequenceMetadata) GetUsingTableNameEscaped() string

func (*GetMaxValueForSequencesRequest_SequenceMetadata) ProtoMessage 

func (*GetMaxValueForSequencesRequest_SequenceMetadata) ProtoMessage()

func (*GetMaxValueForSequencesRequest_SequenceMetadata) ProtoReflect 

func (x *GetMaxValueForSequencesRequest_SequenceMetadata) ProtoReflect() protoreflect.Message

func (*GetMaxValueForSequencesRequest_SequenceMetadata) Reset 

func (x *GetMaxValueForSequencesRequest_SequenceMetadata) Reset()

func (*GetMaxValueForSequencesRequest_SequenceMetadata) SetBackingTableName 

func (x *GetMaxValueForSequencesRequest_SequenceMetadata) SetBackingTableName(v string)

func (*GetMaxValueForSequencesRequest_SequenceMetadata) SetUsingColEscaped 

func (x *GetMaxValueForSequencesRequest_SequenceMetadata) SetUsingColEscaped(v string)

func (*GetMaxValueForSequencesRequest_SequenceMetadata) SetUsingTableDbNameEscaped 

func (x *GetMaxValueForSequencesRequest_SequenceMetadata) SetUsingTableDbNameEscaped(v string)

func (*GetMaxValueForSequencesRequest_SequenceMetadata) SetUsingTableNameEscaped 

func (x *GetMaxValueForSequencesRequest_SequenceMetadata) SetUsingTableNameEscaped(v string)

func (*GetMaxValueForSequencesRequest_SequenceMetadata) String 

func (x *GetMaxValueForSequencesRequest_SequenceMetadata) String() string

type GetMaxValueForSequencesRequest_SequenceMetadata_builder 

type GetMaxValueForSequencesRequest_SequenceMetadata_builder struct {

	// The name of the sequence table. This will be used for mapping max value
	// with table in the response.
	BackingTableName string
	// Escaped column name specified for sequence in table.
	UsingColEscaped string
	// Escaped name of the table using the sequence.
	UsingTableNameEscaped string
	// Escaped db name in use by the keyspace where the using table lives.
	UsingTableDbNameEscaped string
	// contains filtered or unexported fields
}

func (GetMaxValueForSequencesRequest_SequenceMetadata_builder) Build 

func (b0 GetMaxValueForSequencesRequest_SequenceMetadata_builder) Build() *GetMaxValueForSequencesRequest_SequenceMetadata

type GetMaxValueForSequencesRequest_builder 

type GetMaxValueForSequencesRequest_builder struct {
	Sequences []*GetMaxValueForSequencesRequest_SequenceMetadata
	// contains filtered or unexported fields
}

func (GetMaxValueForSequencesRequest_builder) Build 

func (b0 GetMaxValueForSequencesRequest_builder) Build() *GetMaxValueForSequencesRequest

type GetMaxValueForSequencesResponse 

type GetMaxValueForSequencesResponse struct {

	// Max used sequence value mapped with the backing sequence table.
	MaxValuesBySequenceTable map[string]int64 `` /* 214-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetMaxValueForSequencesResponse) GetMaxValuesBySequenceTable 

func (x *GetMaxValueForSequencesResponse) GetMaxValuesBySequenceTable() map[string]int64

func (*GetMaxValueForSequencesResponse) ProtoMessage 

func (*GetMaxValueForSequencesResponse) ProtoMessage()

func (*GetMaxValueForSequencesResponse) ProtoReflect 

func (x *GetMaxValueForSequencesResponse) ProtoReflect() protoreflect.Message

func (*GetMaxValueForSequencesResponse) Reset 

func (x *GetMaxValueForSequencesResponse) Reset()

func (*GetMaxValueForSequencesResponse) SetMaxValuesBySequenceTable 

func (x *GetMaxValueForSequencesResponse) SetMaxValuesBySequenceTable(v map[string]int64)

func (*GetMaxValueForSequencesResponse) String 

func (x *GetMaxValueForSequencesResponse) String() string

type GetMaxValueForSequencesResponse_builder 

type GetMaxValueForSequencesResponse_builder struct {

	// Max used sequence value mapped with the backing sequence table.
	MaxValuesBySequenceTable map[string]int64
	// contains filtered or unexported fields
}

func (GetMaxValueForSequencesResponse_builder) Build 

func (b0 GetMaxValueForSequencesResponse_builder) Build() *GetMaxValueForSequencesResponse

type GetPermissionsRequest 

type GetPermissionsRequest struct {
	// contains filtered or unexported fields
}

func (*GetPermissionsRequest) ProtoMessage 

func (*GetPermissionsRequest) ProtoMessage()

func (*GetPermissionsRequest) ProtoReflect 

func (x *GetPermissionsRequest) ProtoReflect() protoreflect.Message

func (*GetPermissionsRequest) Reset 

func (x *GetPermissionsRequest) Reset()

func (*GetPermissionsRequest) String 

func (x *GetPermissionsRequest) String() string

type GetPermissionsRequest_builder 

type GetPermissionsRequest_builder struct {
	// contains filtered or unexported fields
}

func (GetPermissionsRequest_builder) Build 

func (b0 GetPermissionsRequest_builder) Build() *GetPermissionsRequest

type GetPermissionsResponse 

type GetPermissionsResponse struct {
	Permissions *Permissions `protobuf:"bytes,1,opt,name=permissions,proto3" json:"permissions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPermissionsResponse) ClearPermissions 

func (x *GetPermissionsResponse) ClearPermissions()

func (*GetPermissionsResponse) GetPermissions 

func (x *GetPermissionsResponse) GetPermissions() *Permissions

func (*GetPermissionsResponse) HasPermissions 

func (x *GetPermissionsResponse) HasPermissions() bool

func (*GetPermissionsResponse) ProtoMessage 

func (*GetPermissionsResponse) ProtoMessage()

func (*GetPermissionsResponse) ProtoReflect 

func (x *GetPermissionsResponse) ProtoReflect() protoreflect.Message

func (*GetPermissionsResponse) Reset 

func (x *GetPermissionsResponse) Reset()

func (*GetPermissionsResponse) SetPermissions 

func (x *GetPermissionsResponse) SetPermissions(v *Permissions)

func (*GetPermissionsResponse) String 

func (x *GetPermissionsResponse) String() string

type GetPermissionsResponse_builder 

type GetPermissionsResponse_builder struct {
	Permissions *Permissions
	// contains filtered or unexported fields
}

func (GetPermissionsResponse_builder) Build 

func (b0 GetPermissionsResponse_builder) Build() *GetPermissionsResponse

type GetReplicasRequest 

type GetReplicasRequest struct {
	// contains filtered or unexported fields
}

func (*GetReplicasRequest) ProtoMessage 

func (*GetReplicasRequest) ProtoMessage()

func (*GetReplicasRequest) ProtoReflect 

func (x *GetReplicasRequest) ProtoReflect() protoreflect.Message

func (*GetReplicasRequest) Reset 

func (x *GetReplicasRequest) Reset()

func (*GetReplicasRequest) String 

func (x *GetReplicasRequest) String() string

type GetReplicasRequest_builder 

type GetReplicasRequest_builder struct {
	// contains filtered or unexported fields
}

func (GetReplicasRequest_builder) Build 

func (b0 GetReplicasRequest_builder) Build() *GetReplicasRequest

type GetReplicasResponse 

type GetReplicasResponse struct {
	Addrs []string `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetReplicasResponse) GetAddrs 

func (x *GetReplicasResponse) GetAddrs() []string

func (*GetReplicasResponse) ProtoMessage 

func (*GetReplicasResponse) ProtoMessage()

func (*GetReplicasResponse) ProtoReflect 

func (x *GetReplicasResponse) ProtoReflect() protoreflect.Message

func (*GetReplicasResponse) Reset 

func (x *GetReplicasResponse) Reset()

func (*GetReplicasResponse) SetAddrs 

func (x *GetReplicasResponse) SetAddrs(v []string)

func (*GetReplicasResponse) String 

func (x *GetReplicasResponse) String() string

type GetReplicasResponse_builder 

type GetReplicasResponse_builder struct {
	Addrs []string
	// contains filtered or unexported fields
}

func (GetReplicasResponse_builder) Build 

func (b0 GetReplicasResponse_builder) Build() *GetReplicasResponse

type GetSchemaRequest 

type GetSchemaRequest struct {
	Tables        []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	IncludeViews  bool     `protobuf:"varint,2,opt,name=include_views,json=includeViews,proto3" json:"include_views,omitempty"`
	ExcludeTables []string `protobuf:"bytes,3,rep,name=exclude_tables,json=excludeTables,proto3" json:"exclude_tables,omitempty"`
	// TableSchemaOnly specifies whether to limit the results to just table/view
	// schema definition (CREATE TABLE/VIEW statements) and skip column/field information
	TableSchemaOnly bool `protobuf:"varint,4,opt,name=table_schema_only,json=tableSchemaOnly,proto3" json:"table_schema_only,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaRequest) GetExcludeTables 

func (x *GetSchemaRequest) GetExcludeTables() []string

func (*GetSchemaRequest) GetIncludeViews 

func (x *GetSchemaRequest) GetIncludeViews() bool

func (*GetSchemaRequest) GetTableSchemaOnly 

func (x *GetSchemaRequest) GetTableSchemaOnly() bool

func (*GetSchemaRequest) GetTables 

func (x *GetSchemaRequest) GetTables() []string

func (*GetSchemaRequest) ProtoMessage 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) ProtoReflect 

func (x *GetSchemaRequest) ProtoReflect() protoreflect.Message

func (*GetSchemaRequest) Reset 

func (x *GetSchemaRequest) Reset()

func (*GetSchemaRequest) SetExcludeTables 

func (x *GetSchemaRequest) SetExcludeTables(v []string)

func (*GetSchemaRequest) SetIncludeViews 

func (x *GetSchemaRequest) SetIncludeViews(v bool)

func (*GetSchemaRequest) SetTableSchemaOnly 

func (x *GetSchemaRequest) SetTableSchemaOnly(v bool)

func (*GetSchemaRequest) SetTables 

func (x *GetSchemaRequest) SetTables(v []string)

func (*GetSchemaRequest) String 

func (x *GetSchemaRequest) String() string

type GetSchemaRequest_builder 

type GetSchemaRequest_builder struct {
	Tables        []string
	IncludeViews  bool
	ExcludeTables []string
	// TableSchemaOnly specifies whether to limit the results to just table/view
	// schema definition (CREATE TABLE/VIEW statements) and skip column/field information
	TableSchemaOnly bool
	// contains filtered or unexported fields
}

func (GetSchemaRequest_builder) Build 

func (b0 GetSchemaRequest_builder) Build() *GetSchemaRequest

type GetSchemaResponse 

type GetSchemaResponse struct {
	SchemaDefinition *SchemaDefinition `protobuf:"bytes,1,opt,name=schema_definition,json=schemaDefinition,proto3" json:"schema_definition,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaResponse) ClearSchemaDefinition 

func (x *GetSchemaResponse) ClearSchemaDefinition()

func (*GetSchemaResponse) GetSchemaDefinition 

func (x *GetSchemaResponse) GetSchemaDefinition() *SchemaDefinition

func (*GetSchemaResponse) HasSchemaDefinition 

func (x *GetSchemaResponse) HasSchemaDefinition() bool

func (*GetSchemaResponse) ProtoMessage 

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) ProtoReflect 

func (x *GetSchemaResponse) ProtoReflect() protoreflect.Message

func (*GetSchemaResponse) Reset 

func (x *GetSchemaResponse) Reset()

func (*GetSchemaResponse) SetSchemaDefinition 

func (x *GetSchemaResponse) SetSchemaDefinition(v *SchemaDefinition)

func (*GetSchemaResponse) String 

func (x *GetSchemaResponse) String() string

type GetSchemaResponse_builder 

type GetSchemaResponse_builder struct {
	SchemaDefinition *SchemaDefinition
	// contains filtered or unexported fields
}

func (GetSchemaResponse_builder) Build 

func (b0 GetSchemaResponse_builder) Build() *GetSchemaResponse

type GetThrottlerStatusRequest 

type GetThrottlerStatusRequest struct {
	// contains filtered or unexported fields
}

func (*GetThrottlerStatusRequest) ProtoMessage 

func (*GetThrottlerStatusRequest) ProtoMessage()

func (*GetThrottlerStatusRequest) ProtoReflect 

func (x *GetThrottlerStatusRequest) ProtoReflect() protoreflect.Message

func (*GetThrottlerStatusRequest) Reset 

func (x *GetThrottlerStatusRequest) Reset()

func (*GetThrottlerStatusRequest) String 

func (x *GetThrottlerStatusRequest) String() string

type GetThrottlerStatusRequest_builder 

type GetThrottlerStatusRequest_builder struct {
	// contains filtered or unexported fields
}

func (GetThrottlerStatusRequest_builder) Build 

func (b0 GetThrottlerStatusRequest_builder) Build() *GetThrottlerStatusRequest

type GetThrottlerStatusResponse 

type GetThrottlerStatusResponse struct {

	// TabletAlias of probed tablet
	TabletAlias string `protobuf:"bytes,1,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	Keyspace    string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard       string `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	// IsLeader indicates if the tablet is the leader of the shard, ie. the primary
	IsLeader bool `protobuf:"varint,4,opt,name=is_leader,json=isLeader,proto3" json:"is_leader,omitempty"`
	// IsOpen per stateManager
	IsOpen bool `protobuf:"varint,5,opt,name=is_open,json=isOpen,proto3" json:"is_open,omitempty"`
	// IsEnabled per throttler configuration
	IsEnabled bool `protobuf:"varint,6,opt,name=is_enabled,json=isEnabled,proto3" json:"is_enabled,omitempty"`
	// IsDormant: whether the throttler is dormant, ie has not received any checks in a while
	// and goes into low-frequency probing mode.
	IsDormant bool `protobuf:"varint,7,opt,name=is_dormant,json=isDormant,proto3" json:"is_dormant,omitempty"`
	// LagMetricQuery is the query used to check the lag metric, a constant used by the throttler.
	LagMetricQuery string `protobuf:"bytes,8,opt,name=lag_metric_query,json=lagMetricQuery,proto3" json:"lag_metric_query,omitempty"`
	// CustomMetricQuery is the query used to check the custom metric, supplied by the user.
	CustomMetricQuery string `protobuf:"bytes,9,opt,name=custom_metric_query,json=customMetricQuery,proto3" json:"custom_metric_query,omitempty"`
	// DefaultThreshold is the threshold used by the throttler for the default metric (lag or custom in single-metric throttlers)
	DefaultThreshold float64 `protobuf:"fixed64,10,opt,name=default_threshold,json=defaultThreshold,proto3" json:"default_threshold,omitempty"`
	// MetricNameUsedAsDefault is the name of the metric used as the default metric: "lag" or "custom", for backwards compatibility
	// with single-metric throttlers
	MetricNameUsedAsDefault string `` /* 137-byte string literal not displayed */
	// AggregatedMetrics is a map of metric names to their values/errors
	// Names are, for example, "self", "self/lag", "shard/lag", "shard/loadavg", etc.
	AggregatedMetrics map[string]*GetThrottlerStatusResponse_MetricResult `` /* 187-byte string literal not displayed */
	// MetricThresholds is a map of metric names to their thresholds.
	MetricThresholds map[string]float64 `` /* 186-byte string literal not displayed */
	// MetricsHealth is a map of metric names to their health status.
	MetricsHealth map[string]*GetThrottlerStatusResponse_MetricHealth `` /* 175-byte string literal not displayed */
	// ThrottledApps is a map of app names to their throttling rules
	ThrottledApps map[string]*dev1.ThrottledAppRule `` /* 175-byte string literal not displayed */
	// AppCheckedMetrics is a map of app names to their assigned metrics
	AppCheckedMetrics map[string]string `` /* 189-byte string literal not displayed */
	RecentlyChecked   bool              `protobuf:"varint,17,opt,name=recently_checked,json=recentlyChecked,proto3" json:"recently_checked,omitempty"`
	// RecentApps is a map of app names to their recent check status
	RecentApps map[string]*GetThrottlerStatusResponse_RecentApp `` /* 166-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetThrottlerStatusResponse) GetAggregatedMetrics 

func (x *GetThrottlerStatusResponse) GetAggregatedMetrics() map[string]*GetThrottlerStatusResponse_MetricResult

func (*GetThrottlerStatusResponse) GetAppCheckedMetrics 

func (x *GetThrottlerStatusResponse) GetAppCheckedMetrics() map[string]string

func (*GetThrottlerStatusResponse) GetCustomMetricQuery 

func (x *GetThrottlerStatusResponse) GetCustomMetricQuery() string

func (*GetThrottlerStatusResponse) GetDefaultThreshold 

func (x *GetThrottlerStatusResponse) GetDefaultThreshold() float64

func (*GetThrottlerStatusResponse) GetIsDormant 

func (x *GetThrottlerStatusResponse) GetIsDormant() bool

func (*GetThrottlerStatusResponse) GetIsEnabled 

func (x *GetThrottlerStatusResponse) GetIsEnabled() bool

func (*GetThrottlerStatusResponse) GetIsLeader 

func (x *GetThrottlerStatusResponse) GetIsLeader() bool

func (*GetThrottlerStatusResponse) GetIsOpen 

func (x *GetThrottlerStatusResponse) GetIsOpen() bool

func (*GetThrottlerStatusResponse) GetKeyspace 

func (x *GetThrottlerStatusResponse) GetKeyspace() string

func (*GetThrottlerStatusResponse) GetLagMetricQuery 

func (x *GetThrottlerStatusResponse) GetLagMetricQuery() string

func (*GetThrottlerStatusResponse) GetMetricNameUsedAsDefault 

func (x *GetThrottlerStatusResponse) GetMetricNameUsedAsDefault() string

func (*GetThrottlerStatusResponse) GetMetricThresholds 

func (x *GetThrottlerStatusResponse) GetMetricThresholds() map[string]float64

func (*GetThrottlerStatusResponse) GetMetricsHealth 

func (x *GetThrottlerStatusResponse) GetMetricsHealth() map[string]*GetThrottlerStatusResponse_MetricHealth

func (*GetThrottlerStatusResponse) GetRecentApps 

func (x *GetThrottlerStatusResponse) GetRecentApps() map[string]*GetThrottlerStatusResponse_RecentApp

func (*GetThrottlerStatusResponse) GetRecentlyChecked 

func (x *GetThrottlerStatusResponse) GetRecentlyChecked() bool

func (*GetThrottlerStatusResponse) GetShard 

func (x *GetThrottlerStatusResponse) GetShard() string

func (*GetThrottlerStatusResponse) GetTabletAlias 

func (x *GetThrottlerStatusResponse) GetTabletAlias() string

func (*GetThrottlerStatusResponse) GetThrottledApps 

func (x *GetThrottlerStatusResponse) GetThrottledApps() map[string]*dev1.ThrottledAppRule

func (*GetThrottlerStatusResponse) ProtoMessage 

func (*GetThrottlerStatusResponse) ProtoMessage()

func (*GetThrottlerStatusResponse) ProtoReflect 

func (x *GetThrottlerStatusResponse) ProtoReflect() protoreflect.Message

func (*GetThrottlerStatusResponse) Reset 

func (x *GetThrottlerStatusResponse) Reset()

func (*GetThrottlerStatusResponse) SetAggregatedMetrics 

func (x *GetThrottlerStatusResponse) SetAggregatedMetrics(v map[string]*GetThrottlerStatusResponse_MetricResult)

func (*GetThrottlerStatusResponse) SetAppCheckedMetrics 

func (x *GetThrottlerStatusResponse) SetAppCheckedMetrics(v map[string]string)

func (*GetThrottlerStatusResponse) SetCustomMetricQuery 

func (x *GetThrottlerStatusResponse) SetCustomMetricQuery(v string)

func (*GetThrottlerStatusResponse) SetDefaultThreshold 

func (x *GetThrottlerStatusResponse) SetDefaultThreshold(v float64)

func (*GetThrottlerStatusResponse) SetIsDormant 

func (x *GetThrottlerStatusResponse) SetIsDormant(v bool)

func (*GetThrottlerStatusResponse) SetIsEnabled 

func (x *GetThrottlerStatusResponse) SetIsEnabled(v bool)

func (*GetThrottlerStatusResponse) SetIsLeader 

func (x *GetThrottlerStatusResponse) SetIsLeader(v bool)

func (*GetThrottlerStatusResponse) SetIsOpen 

func (x *GetThrottlerStatusResponse) SetIsOpen(v bool)

func (*GetThrottlerStatusResponse) SetKeyspace 

func (x *GetThrottlerStatusResponse) SetKeyspace(v string)

func (*GetThrottlerStatusResponse) SetLagMetricQuery 

func (x *GetThrottlerStatusResponse) SetLagMetricQuery(v string)

func (*GetThrottlerStatusResponse) SetMetricNameUsedAsDefault 

func (x *GetThrottlerStatusResponse) SetMetricNameUsedAsDefault(v string)

func (*GetThrottlerStatusResponse) SetMetricThresholds 

func (x *GetThrottlerStatusResponse) SetMetricThresholds(v map[string]float64)

func (*GetThrottlerStatusResponse) SetMetricsHealth 

func (x *GetThrottlerStatusResponse) SetMetricsHealth(v map[string]*GetThrottlerStatusResponse_MetricHealth)

func (*GetThrottlerStatusResponse) SetRecentApps 

func (x *GetThrottlerStatusResponse) SetRecentApps(v map[string]*GetThrottlerStatusResponse_RecentApp)

func (*GetThrottlerStatusResponse) SetRecentlyChecked 

func (x *GetThrottlerStatusResponse) SetRecentlyChecked(v bool)

func (*GetThrottlerStatusResponse) SetShard 

func (x *GetThrottlerStatusResponse) SetShard(v string)

func (*GetThrottlerStatusResponse) SetTabletAlias 

func (x *GetThrottlerStatusResponse) SetTabletAlias(v string)

func (*GetThrottlerStatusResponse) SetThrottledApps 

func (x *GetThrottlerStatusResponse) SetThrottledApps(v map[string]*dev1.ThrottledAppRule)

func (*GetThrottlerStatusResponse) String 

func (x *GetThrottlerStatusResponse) String() string

type GetThrottlerStatusResponse_MetricHealth 

type GetThrottlerStatusResponse_MetricHealth struct {
	LastHealthyAt           *dev5.Time `protobuf:"bytes,1,opt,name=last_healthy_at,json=lastHealthyAt,proto3" json:"last_healthy_at,omitempty"`
	SecondsSinceLastHealthy int64      `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetThrottlerStatusResponse_MetricHealth) ClearLastHealthyAt 

func (x *GetThrottlerStatusResponse_MetricHealth) ClearLastHealthyAt()

func (*GetThrottlerStatusResponse_MetricHealth) GetLastHealthyAt 

func (x *GetThrottlerStatusResponse_MetricHealth) GetLastHealthyAt() *dev5.Time

func (*GetThrottlerStatusResponse_MetricHealth) GetSecondsSinceLastHealthy 

func (x *GetThrottlerStatusResponse_MetricHealth) GetSecondsSinceLastHealthy() int64

func (*GetThrottlerStatusResponse_MetricHealth) HasLastHealthyAt 

func (x *GetThrottlerStatusResponse_MetricHealth) HasLastHealthyAt() bool

func (*GetThrottlerStatusResponse_MetricHealth) ProtoMessage 

func (*GetThrottlerStatusResponse_MetricHealth) ProtoMessage()

func (*GetThrottlerStatusResponse_MetricHealth) ProtoReflect 

func (x *GetThrottlerStatusResponse_MetricHealth) ProtoReflect() protoreflect.Message

func (*GetThrottlerStatusResponse_MetricHealth) Reset 

func (x *GetThrottlerStatusResponse_MetricHealth) Reset()

func (*GetThrottlerStatusResponse_MetricHealth) SetLastHealthyAt 

func (x *GetThrottlerStatusResponse_MetricHealth) SetLastHealthyAt(v *dev5.Time)

func (*GetThrottlerStatusResponse_MetricHealth) SetSecondsSinceLastHealthy 

func (x *GetThrottlerStatusResponse_MetricHealth) SetSecondsSinceLastHealthy(v int64)

func (*GetThrottlerStatusResponse_MetricHealth) String 

func (x *GetThrottlerStatusResponse_MetricHealth) String() string

type GetThrottlerStatusResponse_MetricHealth_builder 

type GetThrottlerStatusResponse_MetricHealth_builder struct {
	LastHealthyAt           *dev5.Time
	SecondsSinceLastHealthy int64
	// contains filtered or unexported fields
}

func (GetThrottlerStatusResponse_MetricHealth_builder) Build 

func (b0 GetThrottlerStatusResponse_MetricHealth_builder) Build() *GetThrottlerStatusResponse_MetricHealth

type GetThrottlerStatusResponse_MetricResult 

type GetThrottlerStatusResponse_MetricResult struct {
	Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	Error string  `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*GetThrottlerStatusResponse_MetricResult) GetError 

func (x *GetThrottlerStatusResponse_MetricResult) GetError() string

func (*GetThrottlerStatusResponse_MetricResult) GetValue 

func (x *GetThrottlerStatusResponse_MetricResult) GetValue() float64

func (*GetThrottlerStatusResponse_MetricResult) ProtoMessage 

func (*GetThrottlerStatusResponse_MetricResult) ProtoMessage()

func (*GetThrottlerStatusResponse_MetricResult) ProtoReflect 

func (x *GetThrottlerStatusResponse_MetricResult) ProtoReflect() protoreflect.Message

func (*GetThrottlerStatusResponse_MetricResult) Reset 

func (x *GetThrottlerStatusResponse_MetricResult) Reset()

func (*GetThrottlerStatusResponse_MetricResult) SetError 

func (x *GetThrottlerStatusResponse_MetricResult) SetError(v string)

func (*GetThrottlerStatusResponse_MetricResult) SetValue 

func (x *GetThrottlerStatusResponse_MetricResult) SetValue(v float64)

func (*GetThrottlerStatusResponse_MetricResult) String 

func (x *GetThrottlerStatusResponse_MetricResult) String() string

type GetThrottlerStatusResponse_MetricResult_builder 

type GetThrottlerStatusResponse_MetricResult_builder struct {
	Value float64
	Error string
	// contains filtered or unexported fields
}

func (GetThrottlerStatusResponse_MetricResult_builder) Build 

func (b0 GetThrottlerStatusResponse_MetricResult_builder) Build() *GetThrottlerStatusResponse_MetricResult

type GetThrottlerStatusResponse_RecentApp 

type GetThrottlerStatusResponse_RecentApp struct {
	CheckedAt *dev5.Time `protobuf:"bytes,1,opt,name=checked_at,json=checkedAt,proto3" json:"checked_at,omitempty"`
	// ResponseCode is the enum representation of the response
	ResponseCode CheckThrottlerResponseCode `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetThrottlerStatusResponse_RecentApp) ClearCheckedAt 

func (x *GetThrottlerStatusResponse_RecentApp) ClearCheckedAt()

func (*GetThrottlerStatusResponse_RecentApp) GetCheckedAt 

func (x *GetThrottlerStatusResponse_RecentApp) GetCheckedAt() *dev5.Time

func (*GetThrottlerStatusResponse_RecentApp) GetResponseCode 

func (x *GetThrottlerStatusResponse_RecentApp) GetResponseCode() CheckThrottlerResponseCode

func (*GetThrottlerStatusResponse_RecentApp) HasCheckedAt 

func (x *GetThrottlerStatusResponse_RecentApp) HasCheckedAt() bool

func (*GetThrottlerStatusResponse_RecentApp) ProtoMessage 

func (*GetThrottlerStatusResponse_RecentApp) ProtoMessage()

func (*GetThrottlerStatusResponse_RecentApp) ProtoReflect 

func (x *GetThrottlerStatusResponse_RecentApp) ProtoReflect() protoreflect.Message

func (*GetThrottlerStatusResponse_RecentApp) Reset 

func (x *GetThrottlerStatusResponse_RecentApp) Reset()

func (*GetThrottlerStatusResponse_RecentApp) SetCheckedAt 

func (x *GetThrottlerStatusResponse_RecentApp) SetCheckedAt(v *dev5.Time)

func (*GetThrottlerStatusResponse_RecentApp) SetResponseCode 

func (x *GetThrottlerStatusResponse_RecentApp) SetResponseCode(v CheckThrottlerResponseCode)

func (*GetThrottlerStatusResponse_RecentApp) String 

func (x *GetThrottlerStatusResponse_RecentApp) String() string

type GetThrottlerStatusResponse_RecentApp_builder 

type GetThrottlerStatusResponse_RecentApp_builder struct {
	CheckedAt *dev5.Time
	// ResponseCode is the enum representation of the response
	ResponseCode CheckThrottlerResponseCode
	// contains filtered or unexported fields
}

func (GetThrottlerStatusResponse_RecentApp_builder) Build 

func (b0 GetThrottlerStatusResponse_RecentApp_builder) Build() *GetThrottlerStatusResponse_RecentApp

type GetThrottlerStatusResponse_builder 

type GetThrottlerStatusResponse_builder struct {

	// TabletAlias of probed tablet
	TabletAlias string
	Keyspace    string
	Shard       string
	// IsLeader indicates if the tablet is the leader of the shard, ie. the primary
	IsLeader bool
	// IsOpen per stateManager
	IsOpen bool
	// IsEnabled per throttler configuration
	IsEnabled bool
	// IsDormant: whether the throttler is dormant, ie has not received any checks in a while
	// and goes into low-frequency probing mode.
	IsDormant bool
	// LagMetricQuery is the query used to check the lag metric, a constant used by the throttler.
	LagMetricQuery string
	// CustomMetricQuery is the query used to check the custom metric, supplied by the user.
	CustomMetricQuery string
	// DefaultThreshold is the threshold used by the throttler for the default metric (lag or custom in single-metric throttlers)
	DefaultThreshold float64
	// MetricNameUsedAsDefault is the name of the metric used as the default metric: "lag" or "custom", for backwards compatibility
	// with single-metric throttlers
	MetricNameUsedAsDefault string
	// AggregatedMetrics is a map of metric names to their values/errors
	// Names are, for example, "self", "self/lag", "shard/lag", "shard/loadavg", etc.
	AggregatedMetrics map[string]*GetThrottlerStatusResponse_MetricResult
	// MetricThresholds is a map of metric names to their thresholds.
	MetricThresholds map[string]float64
	// MetricsHealth is a map of metric names to their health status.
	MetricsHealth map[string]*GetThrottlerStatusResponse_MetricHealth
	// ThrottledApps is a map of app names to their throttling rules
	ThrottledApps map[string]*dev1.ThrottledAppRule
	// AppCheckedMetrics is a map of app names to their assigned metrics
	AppCheckedMetrics map[string]string
	RecentlyChecked   bool
	// RecentApps is a map of app names to their recent check status
	RecentApps map[string]*GetThrottlerStatusResponse_RecentApp
	// contains filtered or unexported fields
}

func (GetThrottlerStatusResponse_builder) Build 

func (b0 GetThrottlerStatusResponse_builder) Build() *GetThrottlerStatusResponse

type GetTransactionInfoRequest 

type GetTransactionInfoRequest struct {
	Dtid string `protobuf:"bytes,1,opt,name=dtid,proto3" json:"dtid,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTransactionInfoRequest) GetDtid 

func (x *GetTransactionInfoRequest) GetDtid() string

func (*GetTransactionInfoRequest) ProtoMessage 

func (*GetTransactionInfoRequest) ProtoMessage()

func (*GetTransactionInfoRequest) ProtoReflect 

func (x *GetTransactionInfoRequest) ProtoReflect() protoreflect.Message

func (*GetTransactionInfoRequest) Reset 

func (x *GetTransactionInfoRequest) Reset()

func (*GetTransactionInfoRequest) SetDtid 

func (x *GetTransactionInfoRequest) SetDtid(v string)

func (*GetTransactionInfoRequest) String 

func (x *GetTransactionInfoRequest) String() string

type GetTransactionInfoRequest_builder 

type GetTransactionInfoRequest_builder struct {
	Dtid string
	// contains filtered or unexported fields
}

func (GetTransactionInfoRequest_builder) Build 

func (b0 GetTransactionInfoRequest_builder) Build() *GetTransactionInfoRequest

type GetTransactionInfoResponse 

type GetTransactionInfoResponse struct {
	State       string   `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Message     string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	TimeCreated int64    `protobuf:"varint,3,opt,name=time_created,json=timeCreated,proto3" json:"time_created,omitempty"`
	Statements  []string `protobuf:"bytes,4,rep,name=statements,proto3" json:"statements,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTransactionInfoResponse) GetMessage 

func (x *GetTransactionInfoResponse) GetMessage() string

func (*GetTransactionInfoResponse) GetState 

func (x *GetTransactionInfoResponse) GetState() string

func (*GetTransactionInfoResponse) GetStatements 

func (x *GetTransactionInfoResponse) GetStatements() []string

func (*GetTransactionInfoResponse) GetTimeCreated 

func (x *GetTransactionInfoResponse) GetTimeCreated() int64

func (*GetTransactionInfoResponse) ProtoMessage 

func (*GetTransactionInfoResponse) ProtoMessage()

func (*GetTransactionInfoResponse) ProtoReflect 

func (x *GetTransactionInfoResponse) ProtoReflect() protoreflect.Message

func (*GetTransactionInfoResponse) Reset 

func (x *GetTransactionInfoResponse) Reset()

func (*GetTransactionInfoResponse) SetMessage 

func (x *GetTransactionInfoResponse) SetMessage(v string)

func (*GetTransactionInfoResponse) SetState 

func (x *GetTransactionInfoResponse) SetState(v string)

func (*GetTransactionInfoResponse) SetStatements 

func (x *GetTransactionInfoResponse) SetStatements(v []string)

func (*GetTransactionInfoResponse) SetTimeCreated 

func (x *GetTransactionInfoResponse) SetTimeCreated(v int64)

func (*GetTransactionInfoResponse) String 

func (x *GetTransactionInfoResponse) String() string

type GetTransactionInfoResponse_builder 

type GetTransactionInfoResponse_builder struct {
	State       string
	Message     string
	TimeCreated int64
	Statements  []string
	// contains filtered or unexported fields
}

func (GetTransactionInfoResponse_builder) Build 

func (b0 GetTransactionInfoResponse_builder) Build() *GetTransactionInfoResponse

type GetUnresolvedTransactionsRequest 

type GetUnresolvedTransactionsRequest struct {
	AbandonAge int64 `protobuf:"varint,1,opt,name=abandon_age,json=abandonAge,proto3" json:"abandon_age,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUnresolvedTransactionsRequest) GetAbandonAge 

func (x *GetUnresolvedTransactionsRequest) GetAbandonAge() int64

func (*GetUnresolvedTransactionsRequest) ProtoMessage 

func (*GetUnresolvedTransactionsRequest) ProtoMessage()

func (*GetUnresolvedTransactionsRequest) ProtoReflect 

func (x *GetUnresolvedTransactionsRequest) ProtoReflect() protoreflect.Message

func (*GetUnresolvedTransactionsRequest) Reset 

func (x *GetUnresolvedTransactionsRequest) Reset()

func (*GetUnresolvedTransactionsRequest) SetAbandonAge 

func (x *GetUnresolvedTransactionsRequest) SetAbandonAge(v int64)

func (*GetUnresolvedTransactionsRequest) String 

func (x *GetUnresolvedTransactionsRequest) String() string

type GetUnresolvedTransactionsRequest_builder 

type GetUnresolvedTransactionsRequest_builder struct {
	AbandonAge int64
	// contains filtered or unexported fields
}

func (GetUnresolvedTransactionsRequest_builder) Build 

func (b0 GetUnresolvedTransactionsRequest_builder) Build() *GetUnresolvedTransactionsRequest

type GetUnresolvedTransactionsResponse 

type GetUnresolvedTransactionsResponse struct {
	Transactions []*dev.TransactionMetadata `protobuf:"bytes,1,rep,name=transactions,proto3" json:"transactions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUnresolvedTransactionsResponse) GetTransactions 

func (x *GetUnresolvedTransactionsResponse) GetTransactions() []*dev.TransactionMetadata

func (*GetUnresolvedTransactionsResponse) ProtoMessage 

func (*GetUnresolvedTransactionsResponse) ProtoMessage()

func (*GetUnresolvedTransactionsResponse) ProtoReflect 

func (x *GetUnresolvedTransactionsResponse) ProtoReflect() protoreflect.Message

func (*GetUnresolvedTransactionsResponse) Reset 

func (x *GetUnresolvedTransactionsResponse) Reset()

func (*GetUnresolvedTransactionsResponse) SetTransactions 

func (x *GetUnresolvedTransactionsResponse) SetTransactions(v []*dev.TransactionMetadata)

func (*GetUnresolvedTransactionsResponse) String 

func (x *GetUnresolvedTransactionsResponse) String() string

type GetUnresolvedTransactionsResponse_builder 

type GetUnresolvedTransactionsResponse_builder struct {
	Transactions []*dev.TransactionMetadata
	// contains filtered or unexported fields
}

func (GetUnresolvedTransactionsResponse_builder) Build 

func (b0 GetUnresolvedTransactionsResponse_builder) Build() *GetUnresolvedTransactionsResponse

type HasVReplicationWorkflowsRequest 

type HasVReplicationWorkflowsRequest struct {
	// contains filtered or unexported fields
}

func (*HasVReplicationWorkflowsRequest) ProtoMessage 

func (*HasVReplicationWorkflowsRequest) ProtoMessage()

func (*HasVReplicationWorkflowsRequest) ProtoReflect 

func (x *HasVReplicationWorkflowsRequest) ProtoReflect() protoreflect.Message

func (*HasVReplicationWorkflowsRequest) Reset 

func (x *HasVReplicationWorkflowsRequest) Reset()

func (*HasVReplicationWorkflowsRequest) String 

func (x *HasVReplicationWorkflowsRequest) String() string

type HasVReplicationWorkflowsRequest_builder 

type HasVReplicationWorkflowsRequest_builder struct {
	// contains filtered or unexported fields
}

func (HasVReplicationWorkflowsRequest_builder) Build 

func (b0 HasVReplicationWorkflowsRequest_builder) Build() *HasVReplicationWorkflowsRequest

type HasVReplicationWorkflowsResponse 

type HasVReplicationWorkflowsResponse struct {
	Has bool `protobuf:"varint,1,opt,name=has,proto3" json:"has,omitempty"`
	// contains filtered or unexported fields
}

func (*HasVReplicationWorkflowsResponse) GetHas 

func (x *HasVReplicationWorkflowsResponse) GetHas() bool

func (*HasVReplicationWorkflowsResponse) ProtoMessage 

func (*HasVReplicationWorkflowsResponse) ProtoMessage()

func (*HasVReplicationWorkflowsResponse) ProtoReflect 

func (x *HasVReplicationWorkflowsResponse) ProtoReflect() protoreflect.Message

func (*HasVReplicationWorkflowsResponse) Reset 

func (x *HasVReplicationWorkflowsResponse) Reset()

func (*HasVReplicationWorkflowsResponse) SetHas 

func (x *HasVReplicationWorkflowsResponse) SetHas(v bool)

func (*HasVReplicationWorkflowsResponse) String 

func (x *HasVReplicationWorkflowsResponse) String() string

type HasVReplicationWorkflowsResponse_builder 

type HasVReplicationWorkflowsResponse_builder struct {
	Has bool
	// contains filtered or unexported fields
}

func (HasVReplicationWorkflowsResponse_builder) Build 

func (b0 HasVReplicationWorkflowsResponse_builder) Build() *HasVReplicationWorkflowsResponse

type InitPrimaryRequest 

type InitPrimaryRequest struct {
	SemiSync bool `protobuf:"varint,1,opt,name=semiSync,proto3" json:"semiSync,omitempty"`
	// contains filtered or unexported fields
}

func (*InitPrimaryRequest) GetSemiSync 

func (x *InitPrimaryRequest) GetSemiSync() bool

func (*InitPrimaryRequest) ProtoMessage 

func (*InitPrimaryRequest) ProtoMessage()

func (*InitPrimaryRequest) ProtoReflect 

func (x *InitPrimaryRequest) ProtoReflect() protoreflect.Message

func (*InitPrimaryRequest) Reset 

func (x *InitPrimaryRequest) Reset()

func (*InitPrimaryRequest) SetSemiSync 

func (x *InitPrimaryRequest) SetSemiSync(v bool)

func (*InitPrimaryRequest) String 

func (x *InitPrimaryRequest) String() string

type InitPrimaryRequest_builder 

type InitPrimaryRequest_builder struct {
	SemiSync bool
	// contains filtered or unexported fields
}

func (InitPrimaryRequest_builder) Build 

func (b0 InitPrimaryRequest_builder) Build() *InitPrimaryRequest

type InitPrimaryResponse 

type InitPrimaryResponse struct {
	Position string `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

func (*InitPrimaryResponse) GetPosition 

func (x *InitPrimaryResponse) GetPosition() string

func (*InitPrimaryResponse) ProtoMessage 

func (*InitPrimaryResponse) ProtoMessage()

func (*InitPrimaryResponse) ProtoReflect 

func (x *InitPrimaryResponse) ProtoReflect() protoreflect.Message

func (*InitPrimaryResponse) Reset 

func (x *InitPrimaryResponse) Reset()

func (*InitPrimaryResponse) SetPosition 

func (x *InitPrimaryResponse) SetPosition(v string)

func (*InitPrimaryResponse) String 

func (x *InitPrimaryResponse) String() string

type InitPrimaryResponse_builder 

type InitPrimaryResponse_builder struct {
	Position string
	// contains filtered or unexported fields
}

func (InitPrimaryResponse_builder) Build 

func (b0 InitPrimaryResponse_builder) Build() *InitPrimaryResponse

type InitReplicaRequest 

type InitReplicaRequest struct {
	Parent              *dev1.TabletAlias `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	ReplicationPosition string            `protobuf:"bytes,2,opt,name=replication_position,json=replicationPosition,proto3" json:"replication_position,omitempty"`
	TimeCreatedNs       int64             `protobuf:"varint,3,opt,name=time_created_ns,json=timeCreatedNs,proto3" json:"time_created_ns,omitempty"`
	SemiSync            bool              `protobuf:"varint,4,opt,name=semiSync,proto3" json:"semiSync,omitempty"`
	// contains filtered or unexported fields
}

func (*InitReplicaRequest) ClearParent 

func (x *InitReplicaRequest) ClearParent()

func (*InitReplicaRequest) GetParent 

func (x *InitReplicaRequest) GetParent() *dev1.TabletAlias

func (*InitReplicaRequest) GetReplicationPosition 

func (x *InitReplicaRequest) GetReplicationPosition() string

func (*InitReplicaRequest) GetSemiSync 

func (x *InitReplicaRequest) GetSemiSync() bool

func (*InitReplicaRequest) GetTimeCreatedNs 

func (x *InitReplicaRequest) GetTimeCreatedNs() int64

func (*InitReplicaRequest) HasParent 

func (x *InitReplicaRequest) HasParent() bool

func (*InitReplicaRequest) ProtoMessage 

func (*InitReplicaRequest) ProtoMessage()

func (*InitReplicaRequest) ProtoReflect 

func (x *InitReplicaRequest) ProtoReflect() protoreflect.Message

func (*InitReplicaRequest) Reset 

func (x *InitReplicaRequest) Reset()

func (*InitReplicaRequest) SetParent 

func (x *InitReplicaRequest) SetParent(v *dev1.TabletAlias)

func (*InitReplicaRequest) SetReplicationPosition 

func (x *InitReplicaRequest) SetReplicationPosition(v string)

func (*InitReplicaRequest) SetSemiSync 

func (x *InitReplicaRequest) SetSemiSync(v bool)

func (*InitReplicaRequest) SetTimeCreatedNs 

func (x *InitReplicaRequest) SetTimeCreatedNs(v int64)

func (*InitReplicaRequest) String 

func (x *InitReplicaRequest) String() string

type InitReplicaRequest_builder 

type InitReplicaRequest_builder struct {
	Parent              *dev1.TabletAlias
	ReplicationPosition string
	TimeCreatedNs       int64
	SemiSync            bool
	// contains filtered or unexported fields
}

func (InitReplicaRequest_builder) Build 

func (b0 InitReplicaRequest_builder) Build() *InitReplicaRequest

type InitReplicaResponse 

type InitReplicaResponse struct {
	// contains filtered or unexported fields
}

func (*InitReplicaResponse) ProtoMessage 

func (*InitReplicaResponse) ProtoMessage()

func (*InitReplicaResponse) ProtoReflect 

func (x *InitReplicaResponse) ProtoReflect() protoreflect.Message

func (*InitReplicaResponse) Reset 

func (x *InitReplicaResponse) Reset()

func (*InitReplicaResponse) String 

func (x *InitReplicaResponse) String() string

type InitReplicaResponse_builder 

type InitReplicaResponse_builder struct {
	// contains filtered or unexported fields
}

func (InitReplicaResponse_builder) Build 

func (b0 InitReplicaResponse_builder) Build() *InitReplicaResponse

type LockTablesRequest 

type LockTablesRequest struct {
	// contains filtered or unexported fields
}

func (*LockTablesRequest) ProtoMessage 

func (*LockTablesRequest) ProtoMessage()

func (*LockTablesRequest) ProtoReflect 

func (x *LockTablesRequest) ProtoReflect() protoreflect.Message

func (*LockTablesRequest) Reset 

func (x *LockTablesRequest) Reset()

func (*LockTablesRequest) String 

func (x *LockTablesRequest) String() string

type LockTablesRequest_builder 

type LockTablesRequest_builder struct {
	// contains filtered or unexported fields
}

func (LockTablesRequest_builder) Build 

func (b0 LockTablesRequest_builder) Build() *LockTablesRequest

type LockTablesResponse 

type LockTablesResponse struct {
	// contains filtered or unexported fields
}

func (*LockTablesResponse) ProtoMessage 

func (*LockTablesResponse) ProtoMessage()

func (*LockTablesResponse) ProtoReflect 

func (x *LockTablesResponse) ProtoReflect() protoreflect.Message

func (*LockTablesResponse) Reset 

func (x *LockTablesResponse) Reset()

func (*LockTablesResponse) String 

func (x *LockTablesResponse) String() string

type LockTablesResponse_builder 

type LockTablesResponse_builder struct {
	// contains filtered or unexported fields
}

func (LockTablesResponse_builder) Build 

func (b0 LockTablesResponse_builder) Build() *LockTablesResponse

type MysqlHostMetricsRequest 

type MysqlHostMetricsRequest struct {
	// contains filtered or unexported fields
}

func (*MysqlHostMetricsRequest) ProtoMessage 

func (*MysqlHostMetricsRequest) ProtoMessage()

func (*MysqlHostMetricsRequest) ProtoReflect 

func (x *MysqlHostMetricsRequest) ProtoReflect() protoreflect.Message

func (*MysqlHostMetricsRequest) Reset 

func (x *MysqlHostMetricsRequest) Reset()

func (*MysqlHostMetricsRequest) String 

func (x *MysqlHostMetricsRequest) String() string

type MysqlHostMetricsRequest_builder 

type MysqlHostMetricsRequest_builder struct {
	// contains filtered or unexported fields
}

func (MysqlHostMetricsRequest_builder) Build 

func (b0 MysqlHostMetricsRequest_builder) Build() *MysqlHostMetricsRequest

type MysqlHostMetricsResponse 

type MysqlHostMetricsResponse struct {
	HostMetrics *dev3.HostMetricsResponse `protobuf:"bytes,1,opt,name=HostMetrics,proto3" json:"HostMetrics,omitempty"`
	// contains filtered or unexported fields
}

func (*MysqlHostMetricsResponse) ClearHostMetrics 

func (x *MysqlHostMetricsResponse) ClearHostMetrics()

func (*MysqlHostMetricsResponse) GetHostMetrics 

func (x *MysqlHostMetricsResponse) GetHostMetrics() *dev3.HostMetricsResponse

func (*MysqlHostMetricsResponse) HasHostMetrics 

func (x *MysqlHostMetricsResponse) HasHostMetrics() bool

func (*MysqlHostMetricsResponse) ProtoMessage 

func (*MysqlHostMetricsResponse) ProtoMessage()

func (*MysqlHostMetricsResponse) ProtoReflect 

func (x *MysqlHostMetricsResponse) ProtoReflect() protoreflect.Message

func (*MysqlHostMetricsResponse) Reset 

func (x *MysqlHostMetricsResponse) Reset()

func (*MysqlHostMetricsResponse) SetHostMetrics 

func (x *MysqlHostMetricsResponse) SetHostMetrics(v *dev3.HostMetricsResponse)

func (*MysqlHostMetricsResponse) String 

func (x *MysqlHostMetricsResponse) String() string

type MysqlHostMetricsResponse_builder 

type MysqlHostMetricsResponse_builder struct {
	HostMetrics *dev3.HostMetricsResponse
	// contains filtered or unexported fields
}

func (MysqlHostMetricsResponse_builder) Build 

func (b0 MysqlHostMetricsResponse_builder) Build() *MysqlHostMetricsResponse

type Permissions 

type Permissions struct {
	UserPermissions []*UserPermission `protobuf:"bytes,1,rep,name=user_permissions,json=userPermissions,proto3" json:"user_permissions,omitempty"`
	DbPermissions   []*DbPermission   `protobuf:"bytes,2,rep,name=db_permissions,json=dbPermissions,proto3" json:"db_permissions,omitempty"`
	// contains filtered or unexported fields
}

Permissions have all the rows in mysql.{user,db} tables, (all rows are sorted by primary key)

func (*Permissions) GetDbPermissions 

func (x *Permissions) GetDbPermissions() []*DbPermission

func (*Permissions) GetUserPermissions 

func (x *Permissions) GetUserPermissions() []*UserPermission

func (*Permissions) ProtoMessage 

func (*Permissions) ProtoMessage()

func (*Permissions) ProtoReflect 

func (x *Permissions) ProtoReflect() protoreflect.Message

func (*Permissions) Reset 

func (x *Permissions) Reset()

func (*Permissions) SetDbPermissions 

func (x *Permissions) SetDbPermissions(v []*DbPermission)

func (*Permissions) SetUserPermissions 

func (x *Permissions) SetUserPermissions(v []*UserPermission)

func (*Permissions) String 

func (x *Permissions) String() string

type Permissions_builder 

type Permissions_builder struct {
	UserPermissions []*UserPermission
	DbPermissions   []*DbPermission
	// contains filtered or unexported fields
}

func (Permissions_builder) Build 

func (b0 Permissions_builder) Build() *Permissions

type PingRequest 

type PingRequest struct {
	Payload string `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*PingRequest) GetPayload 

func (x *PingRequest) GetPayload() string

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

func (x *PingRequest) ProtoReflect() protoreflect.Message

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) SetPayload 

func (x *PingRequest) SetPayload(v string)

func (*PingRequest) String 

func (x *PingRequest) String() string

type PingRequest_builder 

type PingRequest_builder struct {
	Payload string
	// contains filtered or unexported fields
}

func (PingRequest_builder) Build 

func (b0 PingRequest_builder) Build() *PingRequest

type PingResponse 

type PingResponse struct {
	Payload string `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) GetPayload 

func (x *PingResponse) GetPayload() string

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

func (x *PingResponse) ProtoReflect() protoreflect.Message

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) SetPayload 

func (x *PingResponse) SetPayload(v string)

func (*PingResponse) String 

func (x *PingResponse) String() string

type PingResponse_builder 

type PingResponse_builder struct {
	Payload string
	// contains filtered or unexported fields
}

func (PingResponse_builder) Build 

func (b0 PingResponse_builder) Build() *PingResponse

type PopulateReparentJournalRequest 

type PopulateReparentJournalRequest struct {
	TimeCreatedNs       int64             `protobuf:"varint,1,opt,name=time_created_ns,json=timeCreatedNs,proto3" json:"time_created_ns,omitempty"`
	ActionName          string            `protobuf:"bytes,2,opt,name=action_name,json=actionName,proto3" json:"action_name,omitempty"`
	PrimaryAlias        *dev1.TabletAlias `protobuf:"bytes,3,opt,name=primary_alias,json=primaryAlias,proto3" json:"primary_alias,omitempty"`
	ReplicationPosition string            `protobuf:"bytes,4,opt,name=replication_position,json=replicationPosition,proto3" json:"replication_position,omitempty"`
	// contains filtered or unexported fields
}

func (*PopulateReparentJournalRequest) ClearPrimaryAlias 

func (x *PopulateReparentJournalRequest) ClearPrimaryAlias()

func (*PopulateReparentJournalRequest) GetActionName 

func (x *PopulateReparentJournalRequest) GetActionName() string

func (*PopulateReparentJournalRequest) GetPrimaryAlias 

func (x *PopulateReparentJournalRequest) GetPrimaryAlias() *dev1.TabletAlias

func (*PopulateReparentJournalRequest) GetReplicationPosition 

func (x *PopulateReparentJournalRequest) GetReplicationPosition() string

func (*PopulateReparentJournalRequest) GetTimeCreatedNs 

func (x *PopulateReparentJournalRequest) GetTimeCreatedNs() int64

func (*PopulateReparentJournalRequest) HasPrimaryAlias 

func (x *PopulateReparentJournalRequest) HasPrimaryAlias() bool

func (*PopulateReparentJournalRequest) ProtoMessage 

func (*PopulateReparentJournalRequest) ProtoMessage()

func (*PopulateReparentJournalRequest) ProtoReflect 

func (x *PopulateReparentJournalRequest) ProtoReflect() protoreflect.Message

func (*PopulateReparentJournalRequest) Reset 

func (x *PopulateReparentJournalRequest) Reset()

func (*PopulateReparentJournalRequest) SetActionName 

func (x *PopulateReparentJournalRequest) SetActionName(v string)

func (*PopulateReparentJournalRequest) SetPrimaryAlias 

func (x *PopulateReparentJournalRequest) SetPrimaryAlias(v *dev1.TabletAlias)

func (*PopulateReparentJournalRequest) SetReplicationPosition 

func (x *PopulateReparentJournalRequest) SetReplicationPosition(v string)

func (*PopulateReparentJournalRequest) SetTimeCreatedNs 

func (x *PopulateReparentJournalRequest) SetTimeCreatedNs(v int64)

func (*PopulateReparentJournalRequest) String 

func (x *PopulateReparentJournalRequest) String() string

type PopulateReparentJournalRequest_builder 

type PopulateReparentJournalRequest_builder struct {
	TimeCreatedNs       int64
	ActionName          string
	PrimaryAlias        *dev1.TabletAlias
	ReplicationPosition string
	// contains filtered or unexported fields
}

func (PopulateReparentJournalRequest_builder) Build 

func (b0 PopulateReparentJournalRequest_builder) Build() *PopulateReparentJournalRequest

type PopulateReparentJournalResponse 

type PopulateReparentJournalResponse struct {
	// contains filtered or unexported fields
}

func (*PopulateReparentJournalResponse) ProtoMessage 

func (*PopulateReparentJournalResponse) ProtoMessage()

func (*PopulateReparentJournalResponse) ProtoReflect 

func (x *PopulateReparentJournalResponse) ProtoReflect() protoreflect.Message

func (*PopulateReparentJournalResponse) Reset 

func (x *PopulateReparentJournalResponse) Reset()

func (*PopulateReparentJournalResponse) String 

func (x *PopulateReparentJournalResponse) String() string

type PopulateReparentJournalResponse_builder 

type PopulateReparentJournalResponse_builder struct {
	// contains filtered or unexported fields
}

func (PopulateReparentJournalResponse_builder) Build 

func (b0 PopulateReparentJournalResponse_builder) Build() *PopulateReparentJournalResponse

type PreflightSchemaRequest 

type PreflightSchemaRequest struct {
	Changes []string `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes,omitempty"`
	// contains filtered or unexported fields
}

func (*PreflightSchemaRequest) GetChanges 

func (x *PreflightSchemaRequest) GetChanges() []string

func (*PreflightSchemaRequest) ProtoMessage 

func (*PreflightSchemaRequest) ProtoMessage()

func (*PreflightSchemaRequest) ProtoReflect 

func (x *PreflightSchemaRequest) ProtoReflect() protoreflect.Message

func (*PreflightSchemaRequest) Reset 

func (x *PreflightSchemaRequest) Reset()

func (*PreflightSchemaRequest) SetChanges 

func (x *PreflightSchemaRequest) SetChanges(v []string)

func (*PreflightSchemaRequest) String 

func (x *PreflightSchemaRequest) String() string

type PreflightSchemaRequest_builder 

type PreflightSchemaRequest_builder struct {
	Changes []string
	// contains filtered or unexported fields
}

func (PreflightSchemaRequest_builder) Build 

func (b0 PreflightSchemaRequest_builder) Build() *PreflightSchemaRequest

type PreflightSchemaResponse 

type PreflightSchemaResponse struct {

	// change_results has for each change the schema before and after it.
	// The number of elements is identical to the length of "changes" in the request.
	ChangeResults []*SchemaChangeResult `protobuf:"bytes,1,rep,name=change_results,json=changeResults,proto3" json:"change_results,omitempty"`
	// contains filtered or unexported fields
}

func (*PreflightSchemaResponse) GetChangeResults 

func (x *PreflightSchemaResponse) GetChangeResults() []*SchemaChangeResult

func (*PreflightSchemaResponse) ProtoMessage 

func (*PreflightSchemaResponse) ProtoMessage()

func (*PreflightSchemaResponse) ProtoReflect 

func (x *PreflightSchemaResponse) ProtoReflect() protoreflect.Message

func (*PreflightSchemaResponse) Reset 

func (x *PreflightSchemaResponse) Reset()

func (*PreflightSchemaResponse) SetChangeResults 

func (x *PreflightSchemaResponse) SetChangeResults(v []*SchemaChangeResult)

func (*PreflightSchemaResponse) String 

func (x *PreflightSchemaResponse) String() string

type PreflightSchemaResponse_builder 

type PreflightSchemaResponse_builder struct {

	// change_results has for each change the schema before and after it.
	// The number of elements is identical to the length of "changes" in the request.
	ChangeResults []*SchemaChangeResult
	// contains filtered or unexported fields
}

func (PreflightSchemaResponse_builder) Build 

func (b0 PreflightSchemaResponse_builder) Build() *PreflightSchemaResponse

type PrimaryPositionRequest 

type PrimaryPositionRequest struct {
	// contains filtered or unexported fields
}

func (*PrimaryPositionRequest) ProtoMessage 

func (*PrimaryPositionRequest) ProtoMessage()

func (*PrimaryPositionRequest) ProtoReflect 

func (x *PrimaryPositionRequest) ProtoReflect() protoreflect.Message

func (*PrimaryPositionRequest) Reset 

func (x *PrimaryPositionRequest) Reset()

func (*PrimaryPositionRequest) String 

func (x *PrimaryPositionRequest) String() string

type PrimaryPositionRequest_builder 

type PrimaryPositionRequest_builder struct {
	// contains filtered or unexported fields
}

func (PrimaryPositionRequest_builder) Build 

func (b0 PrimaryPositionRequest_builder) Build() *PrimaryPositionRequest

type PrimaryPositionResponse 

type PrimaryPositionResponse struct {
	Position string `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

func (*PrimaryPositionResponse) GetPosition 

func (x *PrimaryPositionResponse) GetPosition() string

func (*PrimaryPositionResponse) ProtoMessage 

func (*PrimaryPositionResponse) ProtoMessage()

func (*PrimaryPositionResponse) ProtoReflect 

func (x *PrimaryPositionResponse) ProtoReflect() protoreflect.Message

func (*PrimaryPositionResponse) Reset 

func (x *PrimaryPositionResponse) Reset()

func (*PrimaryPositionResponse) SetPosition 

func (x *PrimaryPositionResponse) SetPosition(v string)

func (*PrimaryPositionResponse) String 

func (x *PrimaryPositionResponse) String() string

type PrimaryPositionResponse_builder 

type PrimaryPositionResponse_builder struct {
	Position string
	// contains filtered or unexported fields
}

func (PrimaryPositionResponse_builder) Build 

func (b0 PrimaryPositionResponse_builder) Build() *PrimaryPositionResponse

type PrimaryStatusRequest 

type PrimaryStatusRequest struct {
	// contains filtered or unexported fields
}

func (*PrimaryStatusRequest) ProtoMessage 

func (*PrimaryStatusRequest) ProtoMessage()

func (*PrimaryStatusRequest) ProtoReflect 

func (x *PrimaryStatusRequest) ProtoReflect() protoreflect.Message

func (*PrimaryStatusRequest) Reset 

func (x *PrimaryStatusRequest) Reset()

func (*PrimaryStatusRequest) String 

func (x *PrimaryStatusRequest) String() string

type PrimaryStatusRequest_builder 

type PrimaryStatusRequest_builder struct {
	// contains filtered or unexported fields
}

func (PrimaryStatusRequest_builder) Build 

func (b0 PrimaryStatusRequest_builder) Build() *PrimaryStatusRequest

type PrimaryStatusResponse 

type PrimaryStatusResponse struct {
	Status *dev4.PrimaryStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*PrimaryStatusResponse) ClearStatus 

func (x *PrimaryStatusResponse) ClearStatus()

func (*PrimaryStatusResponse) GetStatus 

func (x *PrimaryStatusResponse) GetStatus() *dev4.PrimaryStatus

func (*PrimaryStatusResponse) HasStatus 

func (x *PrimaryStatusResponse) HasStatus() bool

func (*PrimaryStatusResponse) ProtoMessage 

func (*PrimaryStatusResponse) ProtoMessage()

func (*PrimaryStatusResponse) ProtoReflect 

func (x *PrimaryStatusResponse) ProtoReflect() protoreflect.Message

func (*PrimaryStatusResponse) Reset 

func (x *PrimaryStatusResponse) Reset()

func (*PrimaryStatusResponse) SetStatus 

func (x *PrimaryStatusResponse) SetStatus(v *dev4.PrimaryStatus)

func (*PrimaryStatusResponse) String 

func (x *PrimaryStatusResponse) String() string

type PrimaryStatusResponse_builder 

type PrimaryStatusResponse_builder struct {
	Status *dev4.PrimaryStatus
	// contains filtered or unexported fields
}

func (PrimaryStatusResponse_builder) Build 

func (b0 PrimaryStatusResponse_builder) Build() *PrimaryStatusResponse

type PromoteReplicaRequest 

type PromoteReplicaRequest struct {
	SemiSync bool `protobuf:"varint,1,opt,name=semiSync,proto3" json:"semiSync,omitempty"`
	// contains filtered or unexported fields
}

func (*PromoteReplicaRequest) GetSemiSync 

func (x *PromoteReplicaRequest) GetSemiSync() bool

func (*PromoteReplicaRequest) ProtoMessage 

func (*PromoteReplicaRequest) ProtoMessage()

func (*PromoteReplicaRequest) ProtoReflect 

func (x *PromoteReplicaRequest) ProtoReflect() protoreflect.Message

func (*PromoteReplicaRequest) Reset 

func (x *PromoteReplicaRequest) Reset()

func (*PromoteReplicaRequest) SetSemiSync 

func (x *PromoteReplicaRequest) SetSemiSync(v bool)

func (*PromoteReplicaRequest) String 

func (x *PromoteReplicaRequest) String() string

type PromoteReplicaRequest_builder 

type PromoteReplicaRequest_builder struct {
	SemiSync bool
	// contains filtered or unexported fields
}

func (PromoteReplicaRequest_builder) Build 

func (b0 PromoteReplicaRequest_builder) Build() *PromoteReplicaRequest

type PromoteReplicaResponse 

type PromoteReplicaResponse struct {
	Position string `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

func (*PromoteReplicaResponse) GetPosition 

func (x *PromoteReplicaResponse) GetPosition() string

func (*PromoteReplicaResponse) ProtoMessage 

func (*PromoteReplicaResponse) ProtoMessage()

func (*PromoteReplicaResponse) ProtoReflect 

func (x *PromoteReplicaResponse) ProtoReflect() protoreflect.Message

func (*PromoteReplicaResponse) Reset 

func (x *PromoteReplicaResponse) Reset()

func (*PromoteReplicaResponse) SetPosition 

func (x *PromoteReplicaResponse) SetPosition(v string)

func (*PromoteReplicaResponse) String 

func (x *PromoteReplicaResponse) String() string

type PromoteReplicaResponse_builder 

type PromoteReplicaResponse_builder struct {
	Position string
	// contains filtered or unexported fields
}

func (PromoteReplicaResponse_builder) Build 

func (b0 PromoteReplicaResponse_builder) Build() *PromoteReplicaResponse

type ReadReparentJournalInfoRequest 

type ReadReparentJournalInfoRequest struct {
	// contains filtered or unexported fields
}

func (*ReadReparentJournalInfoRequest) ProtoMessage 

func (*ReadReparentJournalInfoRequest) ProtoMessage()

func (*ReadReparentJournalInfoRequest) ProtoReflect 

func (x *ReadReparentJournalInfoRequest) ProtoReflect() protoreflect.Message

func (*ReadReparentJournalInfoRequest) Reset 

func (x *ReadReparentJournalInfoRequest) Reset()

func (*ReadReparentJournalInfoRequest) String 

func (x *ReadReparentJournalInfoRequest) String() string

type ReadReparentJournalInfoRequest_builder 

type ReadReparentJournalInfoRequest_builder struct {
	// contains filtered or unexported fields
}

func (ReadReparentJournalInfoRequest_builder) Build 

func (b0 ReadReparentJournalInfoRequest_builder) Build() *ReadReparentJournalInfoRequest

type ReadReparentJournalInfoResponse 

type ReadReparentJournalInfoResponse struct {
	Length int32 `protobuf:"varint,1,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadReparentJournalInfoResponse) GetLength 

func (x *ReadReparentJournalInfoResponse) GetLength() int32

func (*ReadReparentJournalInfoResponse) ProtoMessage 

func (*ReadReparentJournalInfoResponse) ProtoMessage()

func (*ReadReparentJournalInfoResponse) ProtoReflect 

func (x *ReadReparentJournalInfoResponse) ProtoReflect() protoreflect.Message

func (*ReadReparentJournalInfoResponse) Reset 

func (x *ReadReparentJournalInfoResponse) Reset()

func (*ReadReparentJournalInfoResponse) SetLength 

func (x *ReadReparentJournalInfoResponse) SetLength(v int32)

func (*ReadReparentJournalInfoResponse) String 

func (x *ReadReparentJournalInfoResponse) String() string

type ReadReparentJournalInfoResponse_builder 

type ReadReparentJournalInfoResponse_builder struct {
	Length int32
	// contains filtered or unexported fields
}

func (ReadReparentJournalInfoResponse_builder) Build 

func (b0 ReadReparentJournalInfoResponse_builder) Build() *ReadReparentJournalInfoResponse

type ReadTransactionRequest 

type ReadTransactionRequest struct {
	Dtid string `protobuf:"bytes,1,opt,name=dtid,proto3" json:"dtid,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadTransactionRequest) GetDtid 

func (x *ReadTransactionRequest) GetDtid() string

func (*ReadTransactionRequest) ProtoMessage 

func (*ReadTransactionRequest) ProtoMessage()

func (*ReadTransactionRequest) ProtoReflect 

func (x *ReadTransactionRequest) ProtoReflect() protoreflect.Message

func (*ReadTransactionRequest) Reset 

func (x *ReadTransactionRequest) Reset()

func (*ReadTransactionRequest) SetDtid 

func (x *ReadTransactionRequest) SetDtid(v string)

func (*ReadTransactionRequest) String 

func (x *ReadTransactionRequest) String() string

type ReadTransactionRequest_builder 

type ReadTransactionRequest_builder struct {
	Dtid string
	// contains filtered or unexported fields
}

func (ReadTransactionRequest_builder) Build 

func (b0 ReadTransactionRequest_builder) Build() *ReadTransactionRequest

type ReadTransactionResponse 

type ReadTransactionResponse struct {
	Transaction *dev.TransactionMetadata `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadTransactionResponse) ClearTransaction 

func (x *ReadTransactionResponse) ClearTransaction()

func (*ReadTransactionResponse) GetTransaction 

func (x *ReadTransactionResponse) GetTransaction() *dev.TransactionMetadata

func (*ReadTransactionResponse) HasTransaction 

func (x *ReadTransactionResponse) HasTransaction() bool

func (*ReadTransactionResponse) ProtoMessage 

func (*ReadTransactionResponse) ProtoMessage()

func (*ReadTransactionResponse) ProtoReflect 

func (x *ReadTransactionResponse) ProtoReflect() protoreflect.Message

func (*ReadTransactionResponse) Reset 

func (x *ReadTransactionResponse) Reset()

func (*ReadTransactionResponse) SetTransaction 

func (x *ReadTransactionResponse) SetTransaction(v *dev.TransactionMetadata)

func (*ReadTransactionResponse) String 

func (x *ReadTransactionResponse) String() string

type ReadTransactionResponse_builder 

type ReadTransactionResponse_builder struct {
	Transaction *dev.TransactionMetadata
	// contains filtered or unexported fields
}

func (ReadTransactionResponse_builder) Build 

func (b0 ReadTransactionResponse_builder) Build() *ReadTransactionResponse

type ReadVReplicationWorkflowRequest 

type ReadVReplicationWorkflowRequest struct {
	Workflow string `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadVReplicationWorkflowRequest) GetWorkflow 

func (x *ReadVReplicationWorkflowRequest) GetWorkflow() string

func (*ReadVReplicationWorkflowRequest) ProtoMessage 

func (*ReadVReplicationWorkflowRequest) ProtoMessage()

func (*ReadVReplicationWorkflowRequest) ProtoReflect 

func (x *ReadVReplicationWorkflowRequest) ProtoReflect() protoreflect.Message

func (*ReadVReplicationWorkflowRequest) Reset 

func (x *ReadVReplicationWorkflowRequest) Reset()

func (*ReadVReplicationWorkflowRequest) SetWorkflow 

func (x *ReadVReplicationWorkflowRequest) SetWorkflow(v string)

func (*ReadVReplicationWorkflowRequest) String 

func (x *ReadVReplicationWorkflowRequest) String() string

type ReadVReplicationWorkflowRequest_builder 

type ReadVReplicationWorkflowRequest_builder struct {
	Workflow string
	// contains filtered or unexported fields
}

func (ReadVReplicationWorkflowRequest_builder) Build 

func (b0 ReadVReplicationWorkflowRequest_builder) Build() *ReadVReplicationWorkflowRequest

type ReadVReplicationWorkflowResponse 

type ReadVReplicationWorkflowResponse struct {
	Workflow                  string                                     `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"`
	Cells                     string                                     `protobuf:"bytes,3,opt,name=cells,proto3" json:"cells,omitempty"`
	TabletTypes               []dev1.TabletType                          `` /* 138-byte string literal not displayed */
	TabletSelectionPreference TabletSelectionPreference                  `` /* 199-byte string literal not displayed */
	DbName                    string                                     `protobuf:"bytes,6,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	Tags                      string                                     `protobuf:"bytes,7,opt,name=tags,proto3" json:"tags,omitempty"`
	WorkflowType              dev7.VReplicationWorkflowType              `` /* 150-byte string literal not displayed */
	WorkflowSubType           dev7.VReplicationWorkflowSubType           `` /* 164-byte string literal not displayed */
	DeferSecondaryKeys        bool                                       `protobuf:"varint,10,opt,name=defer_secondary_keys,json=deferSecondaryKeys,proto3" json:"defer_secondary_keys,omitempty"`
	Streams                   []*ReadVReplicationWorkflowResponse_Stream `protobuf:"bytes,11,rep,name=streams,proto3" json:"streams,omitempty"`
	Options                   string                                     `protobuf:"bytes,12,opt,name=options,proto3" json:"options,omitempty"`
	ConfigOverrides           map[string]string                          `` /* 181-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ReadVReplicationWorkflowResponse) GetCells 

func (x *ReadVReplicationWorkflowResponse) GetCells() string

func (*ReadVReplicationWorkflowResponse) GetConfigOverrides 

func (x *ReadVReplicationWorkflowResponse) GetConfigOverrides() map[string]string

func (*ReadVReplicationWorkflowResponse) GetDbName 

func (x *ReadVReplicationWorkflowResponse) GetDbName() string

func (*ReadVReplicationWorkflowResponse) GetDeferSecondaryKeys 

func (x *ReadVReplicationWorkflowResponse) GetDeferSecondaryKeys() bool

func (*ReadVReplicationWorkflowResponse) GetOptions 

func (x *ReadVReplicationWorkflowResponse) GetOptions() string

func (*ReadVReplicationWorkflowResponse) GetStreams 

func (x *ReadVReplicationWorkflowResponse) GetStreams() []*ReadVReplicationWorkflowResponse_Stream

func (*ReadVReplicationWorkflowResponse) GetTabletSelectionPreference 

func (x *ReadVReplicationWorkflowResponse) GetTabletSelectionPreference() TabletSelectionPreference

func (*ReadVReplicationWorkflowResponse) GetTabletTypes 

func (x *ReadVReplicationWorkflowResponse) GetTabletTypes() []dev1.TabletType

func (*ReadVReplicationWorkflowResponse) GetTags 

func (x *ReadVReplicationWorkflowResponse) GetTags() string

func (*ReadVReplicationWorkflowResponse) GetWorkflow 

func (x *ReadVReplicationWorkflowResponse) GetWorkflow() string

func (*ReadVReplicationWorkflowResponse) GetWorkflowSubType 

func (x *ReadVReplicationWorkflowResponse) GetWorkflowSubType() dev7.VReplicationWorkflowSubType

func (*ReadVReplicationWorkflowResponse) GetWorkflowType 

func (x *ReadVReplicationWorkflowResponse) GetWorkflowType() dev7.VReplicationWorkflowType

func (*ReadVReplicationWorkflowResponse) ProtoMessage 

func (*ReadVReplicationWorkflowResponse) ProtoMessage()

func (*ReadVReplicationWorkflowResponse) ProtoReflect 

func (x *ReadVReplicationWorkflowResponse) ProtoReflect() protoreflect.Message

func (*ReadVReplicationWorkflowResponse) Reset 

func (x *ReadVReplicationWorkflowResponse) Reset()

func (*ReadVReplicationWorkflowResponse) SetCells 

func (x *ReadVReplicationWorkflowResponse) SetCells(v string)

func (*ReadVReplicationWorkflowResponse) SetConfigOverrides 

func (x *ReadVReplicationWorkflowResponse) SetConfigOverrides(v map[string]string)

func (*ReadVReplicationWorkflowResponse) SetDbName 

func (x *ReadVReplicationWorkflowResponse) SetDbName(v string)

func (*ReadVReplicationWorkflowResponse) SetDeferSecondaryKeys 

func (x *ReadVReplicationWorkflowResponse) SetDeferSecondaryKeys(v bool)

func (*ReadVReplicationWorkflowResponse) SetOptions 

func (x *ReadVReplicationWorkflowResponse) SetOptions(v string)

func (*ReadVReplicationWorkflowResponse) SetStreams 

func (x *ReadVReplicationWorkflowResponse) SetStreams(v []*ReadVReplicationWorkflowResponse_Stream)

func (*ReadVReplicationWorkflowResponse) SetTabletSelectionPreference 

func (x *ReadVReplicationWorkflowResponse) SetTabletSelectionPreference(v TabletSelectionPreference)

func (*ReadVReplicationWorkflowResponse) SetTabletTypes 

func (x *ReadVReplicationWorkflowResponse) SetTabletTypes(v []dev1.TabletType)

func (*ReadVReplicationWorkflowResponse) SetTags 

func (x *ReadVReplicationWorkflowResponse) SetTags(v string)

func (*ReadVReplicationWorkflowResponse) SetWorkflow 

func (x *ReadVReplicationWorkflowResponse) SetWorkflow(v string)

func (*ReadVReplicationWorkflowResponse) SetWorkflowSubType 

func (x *ReadVReplicationWorkflowResponse) SetWorkflowSubType(v dev7.VReplicationWorkflowSubType)

func (*ReadVReplicationWorkflowResponse) SetWorkflowType 

func (x *ReadVReplicationWorkflowResponse) SetWorkflowType(v dev7.VReplicationWorkflowType)

func (*ReadVReplicationWorkflowResponse) String 

func (x *ReadVReplicationWorkflowResponse) String() string

type ReadVReplicationWorkflowResponse_Stream 

type ReadVReplicationWorkflowResponse_Stream struct {
	Id                   int32                          `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Bls                  *dev7.BinlogSource             `protobuf:"bytes,2,opt,name=bls,proto3" json:"bls,omitempty"`
	Pos                  string                         `protobuf:"bytes,3,opt,name=pos,proto3" json:"pos,omitempty"`
	StopPos              string                         `protobuf:"bytes,4,opt,name=stop_pos,json=stopPos,proto3" json:"stop_pos,omitempty"`
	MaxTps               int64                          `protobuf:"varint,5,opt,name=max_tps,json=maxTps,proto3" json:"max_tps,omitempty"`
	MaxReplicationLag    int64                          `protobuf:"varint,6,opt,name=max_replication_lag,json=maxReplicationLag,proto3" json:"max_replication_lag,omitempty"`
	TimeUpdated          *dev5.Time                     `protobuf:"bytes,7,opt,name=time_updated,json=timeUpdated,proto3" json:"time_updated,omitempty"`
	TransactionTimestamp *dev5.Time                     `protobuf:"bytes,8,opt,name=transaction_timestamp,json=transactionTimestamp,proto3" json:"transaction_timestamp,omitempty"`
	State                dev7.VReplicationWorkflowState `protobuf:"varint,9,opt,name=state,proto3,enum=vitess.binlogdata.dev.VReplicationWorkflowState" json:"state,omitempty"`
	Message              string                         `protobuf:"bytes,10,opt,name=message,proto3" json:"message,omitempty"`
	RowsCopied           int64                          `protobuf:"varint,11,opt,name=rows_copied,json=rowsCopied,proto3" json:"rows_copied,omitempty"`
	TimeHeartbeat        *dev5.Time                     `protobuf:"bytes,12,opt,name=time_heartbeat,json=timeHeartbeat,proto3" json:"time_heartbeat,omitempty"`
	TimeThrottled        *dev5.Time                     `protobuf:"bytes,13,opt,name=time_throttled,json=timeThrottled,proto3" json:"time_throttled,omitempty"`
	ComponentThrottled   string                         `protobuf:"bytes,14,opt,name=component_throttled,json=componentThrottled,proto3" json:"component_throttled,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadVReplicationWorkflowResponse_Stream) ClearBls 

func (x *ReadVReplicationWorkflowResponse_Stream) ClearBls()

func (*ReadVReplicationWorkflowResponse_Stream) ClearTimeHeartbeat 

func (x *ReadVReplicationWorkflowResponse_Stream) ClearTimeHeartbeat()

func (*ReadVReplicationWorkflowResponse_Stream) ClearTimeThrottled 

func (x *ReadVReplicationWorkflowResponse_Stream) ClearTimeThrottled()

func (*ReadVReplicationWorkflowResponse_Stream) ClearTimeUpdated 

func (x *ReadVReplicationWorkflowResponse_Stream) ClearTimeUpdated()

func (*ReadVReplicationWorkflowResponse_Stream) ClearTransactionTimestamp 

func (x *ReadVReplicationWorkflowResponse_Stream) ClearTransactionTimestamp()

func (*ReadVReplicationWorkflowResponse_Stream) GetBls 

func (x *ReadVReplicationWorkflowResponse_Stream) GetBls() *dev7.BinlogSource

func (*ReadVReplicationWorkflowResponse_Stream) GetComponentThrottled 

func (x *ReadVReplicationWorkflowResponse_Stream) GetComponentThrottled() string

func (*ReadVReplicationWorkflowResponse_Stream) GetId 

func (x *ReadVReplicationWorkflowResponse_Stream) GetId() int32

func (*ReadVReplicationWorkflowResponse_Stream) GetMaxReplicationLag 

func (x *ReadVReplicationWorkflowResponse_Stream) GetMaxReplicationLag() int64

func (*ReadVReplicationWorkflowResponse_Stream) GetMaxTps 

func (x *ReadVReplicationWorkflowResponse_Stream) GetMaxTps() int64

func (*ReadVReplicationWorkflowResponse_Stream) GetMessage 

func (x *ReadVReplicationWorkflowResponse_Stream) GetMessage() string

func (*ReadVReplicationWorkflowResponse_Stream) GetPos 

func (x *ReadVReplicationWorkflowResponse_Stream) GetPos() string

func (*ReadVReplicationWorkflowResponse_Stream) GetRowsCopied 

func (x *ReadVReplicationWorkflowResponse_Stream) GetRowsCopied() int64

func (*ReadVReplicationWorkflowResponse_Stream) GetState 

func (x *ReadVReplicationWorkflowResponse_Stream) GetState() dev7.VReplicationWorkflowState

func (*ReadVReplicationWorkflowResponse_Stream) GetStopPos 

func (x *ReadVReplicationWorkflowResponse_Stream) GetStopPos() string

func (*ReadVReplicationWorkflowResponse_Stream) GetTimeHeartbeat 

func (x *ReadVReplicationWorkflowResponse_Stream) GetTimeHeartbeat() *dev5.Time

func (*ReadVReplicationWorkflowResponse_Stream) GetTimeThrottled 

func (x *ReadVReplicationWorkflowResponse_Stream) GetTimeThrottled() *dev5.Time

func (*ReadVReplicationWorkflowResponse_Stream) GetTimeUpdated 

func (x *ReadVReplicationWorkflowResponse_Stream) GetTimeUpdated() *dev5.Time

func (*ReadVReplicationWorkflowResponse_Stream) GetTransactionTimestamp 

func (x *ReadVReplicationWorkflowResponse_Stream) GetTransactionTimestamp() *dev5.Time

func (*ReadVReplicationWorkflowResponse_Stream) HasBls 

func (x *ReadVReplicationWorkflowResponse_Stream) HasBls() bool

func (*ReadVReplicationWorkflowResponse_Stream) HasTimeHeartbeat 

func (x *ReadVReplicationWorkflowResponse_Stream) HasTimeHeartbeat() bool

func (*ReadVReplicationWorkflowResponse_Stream) HasTimeThrottled 

func (x *ReadVReplicationWorkflowResponse_Stream) HasTimeThrottled() bool

func (*ReadVReplicationWorkflowResponse_Stream) HasTimeUpdated 

func (x *ReadVReplicationWorkflowResponse_Stream) HasTimeUpdated() bool

func (*ReadVReplicationWorkflowResponse_Stream) HasTransactionTimestamp 

func (x *ReadVReplicationWorkflowResponse_Stream) HasTransactionTimestamp() bool

func (*ReadVReplicationWorkflowResponse_Stream) ProtoMessage 

func (*ReadVReplicationWorkflowResponse_Stream) ProtoMessage()

func (*ReadVReplicationWorkflowResponse_Stream) ProtoReflect 

func (x *ReadVReplicationWorkflowResponse_Stream) ProtoReflect() protoreflect.Message

func (*ReadVReplicationWorkflowResponse_Stream) Reset 

func (x *ReadVReplicationWorkflowResponse_Stream) Reset()

func (*ReadVReplicationWorkflowResponse_Stream) SetBls 

func (x *ReadVReplicationWorkflowResponse_Stream) SetBls(v *dev7.BinlogSource)

func (*ReadVReplicationWorkflowResponse_Stream) SetComponentThrottled 

func (x *ReadVReplicationWorkflowResponse_Stream) SetComponentThrottled(v string)

func (*ReadVReplicationWorkflowResponse_Stream) SetId 

func (x *ReadVReplicationWorkflowResponse_Stream) SetId(v int32)

func (*ReadVReplicationWorkflowResponse_Stream) SetMaxReplicationLag 

func (x *ReadVReplicationWorkflowResponse_Stream) SetMaxReplicationLag(v int64)

func (*ReadVReplicationWorkflowResponse_Stream) SetMaxTps 

func (x *ReadVReplicationWorkflowResponse_Stream) SetMaxTps(v int64)

func (*ReadVReplicationWorkflowResponse_Stream) SetMessage 

func (x *ReadVReplicationWorkflowResponse_Stream) SetMessage(v string)

func (*ReadVReplicationWorkflowResponse_Stream) SetPos 

func (x *ReadVReplicationWorkflowResponse_Stream) SetPos(v string)

func (*ReadVReplicationWorkflowResponse_Stream) SetRowsCopied 

func (x *ReadVReplicationWorkflowResponse_Stream) SetRowsCopied(v int64)

func (*ReadVReplicationWorkflowResponse_Stream) SetState 

func (x *ReadVReplicationWorkflowResponse_Stream) SetState(v dev7.VReplicationWorkflowState)

func (*ReadVReplicationWorkflowResponse_Stream) SetStopPos 

func (x *ReadVReplicationWorkflowResponse_Stream) SetStopPos(v string)

func (*ReadVReplicationWorkflowResponse_Stream) SetTimeHeartbeat 

func (x *ReadVReplicationWorkflowResponse_Stream) SetTimeHeartbeat(v *dev5.Time)

func (*ReadVReplicationWorkflowResponse_Stream) SetTimeThrottled 

func (x *ReadVReplicationWorkflowResponse_Stream) SetTimeThrottled(v *dev5.Time)

func (*ReadVReplicationWorkflowResponse_Stream) SetTimeUpdated 

func (x *ReadVReplicationWorkflowResponse_Stream) SetTimeUpdated(v *dev5.Time)

func (*ReadVReplicationWorkflowResponse_Stream) SetTransactionTimestamp 

func (x *ReadVReplicationWorkflowResponse_Stream) SetTransactionTimestamp(v *dev5.Time)

func (*ReadVReplicationWorkflowResponse_Stream) String 

func (x *ReadVReplicationWorkflowResponse_Stream) String() string

type ReadVReplicationWorkflowResponse_Stream_builder 

type ReadVReplicationWorkflowResponse_Stream_builder struct {
	Id                   int32
	Bls                  *dev7.BinlogSource
	Pos                  string
	StopPos              string
	MaxTps               int64
	MaxReplicationLag    int64
	TimeUpdated          *dev5.Time
	TransactionTimestamp *dev5.Time
	State                dev7.VReplicationWorkflowState
	Message              string
	RowsCopied           int64
	TimeHeartbeat        *dev5.Time
	TimeThrottled        *dev5.Time
	ComponentThrottled   string
	// contains filtered or unexported fields
}

func (ReadVReplicationWorkflowResponse_Stream_builder) Build 

func (b0 ReadVReplicationWorkflowResponse_Stream_builder) Build() *ReadVReplicationWorkflowResponse_Stream

type ReadVReplicationWorkflowResponse_builder 

type ReadVReplicationWorkflowResponse_builder struct {
	Workflow                  string
	Cells                     string
	TabletTypes               []dev1.TabletType
	TabletSelectionPreference TabletSelectionPreference
	DbName                    string
	Tags                      string
	WorkflowType              dev7.VReplicationWorkflowType
	WorkflowSubType           dev7.VReplicationWorkflowSubType
	DeferSecondaryKeys        bool
	Streams                   []*ReadVReplicationWorkflowResponse_Stream
	Options                   string
	ConfigOverrides           map[string]string
	// contains filtered or unexported fields
}

func (ReadVReplicationWorkflowResponse_builder) Build 

func (b0 ReadVReplicationWorkflowResponse_builder) Build() *ReadVReplicationWorkflowResponse

type ReadVReplicationWorkflowsRequest 

type ReadVReplicationWorkflowsRequest struct {
	IncludeIds       []int32                          `protobuf:"varint,1,rep,packed,name=include_ids,json=includeIds,proto3" json:"include_ids,omitempty"`
	IncludeWorkflows []string                         `protobuf:"bytes,2,rep,name=include_workflows,json=includeWorkflows,proto3" json:"include_workflows,omitempty"`
	IncludeStates    []dev7.VReplicationWorkflowState `` /* 161-byte string literal not displayed */
	ExcludeWorkflows []string                         `protobuf:"bytes,4,rep,name=exclude_workflows,json=excludeWorkflows,proto3" json:"exclude_workflows,omitempty"`
	ExcludeStates    []dev7.VReplicationWorkflowState `` /* 161-byte string literal not displayed */
	ExcludeFrozen    bool                             `protobuf:"varint,6,opt,name=exclude_frozen,json=excludeFrozen,proto3" json:"exclude_frozen,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadVReplicationWorkflowsRequest) GetExcludeFrozen 

func (x *ReadVReplicationWorkflowsRequest) GetExcludeFrozen() bool

func (*ReadVReplicationWorkflowsRequest) GetExcludeStates 

func (x *ReadVReplicationWorkflowsRequest) GetExcludeStates() []dev7.VReplicationWorkflowState

func (*ReadVReplicationWorkflowsRequest) GetExcludeWorkflows 

func (x *ReadVReplicationWorkflowsRequest) GetExcludeWorkflows() []string

func (*ReadVReplicationWorkflowsRequest) GetIncludeIds 

func (x *ReadVReplicationWorkflowsRequest) GetIncludeIds() []int32

func (*ReadVReplicationWorkflowsRequest) GetIncludeStates 

func (x *ReadVReplicationWorkflowsRequest) GetIncludeStates() []dev7.VReplicationWorkflowState

func (*ReadVReplicationWorkflowsRequest) GetIncludeWorkflows 

func (x *ReadVReplicationWorkflowsRequest) GetIncludeWorkflows() []string

func (*ReadVReplicationWorkflowsRequest) ProtoMessage 

func (*ReadVReplicationWorkflowsRequest) ProtoMessage()

func (*ReadVReplicationWorkflowsRequest) ProtoReflect 

func (x *ReadVReplicationWorkflowsRequest) ProtoReflect() protoreflect.Message

func (*ReadVReplicationWorkflowsRequest) Reset 

func (x *ReadVReplicationWorkflowsRequest) Reset()

func (*ReadVReplicationWorkflowsRequest) SetExcludeFrozen 

func (x *ReadVReplicationWorkflowsRequest) SetExcludeFrozen(v bool)

func (*ReadVReplicationWorkflowsRequest) SetExcludeStates 

func (x *ReadVReplicationWorkflowsRequest) SetExcludeStates(v []dev7.VReplicationWorkflowState)

func (*ReadVReplicationWorkflowsRequest) SetExcludeWorkflows 

func (x *ReadVReplicationWorkflowsRequest) SetExcludeWorkflows(v []string)

func (*ReadVReplicationWorkflowsRequest) SetIncludeIds 

func (x *ReadVReplicationWorkflowsRequest) SetIncludeIds(v []int32)

func (*ReadVReplicationWorkflowsRequest) SetIncludeStates 

func (x *ReadVReplicationWorkflowsRequest) SetIncludeStates(v []dev7.VReplicationWorkflowState)

func (*ReadVReplicationWorkflowsRequest) SetIncludeWorkflows 

func (x *ReadVReplicationWorkflowsRequest) SetIncludeWorkflows(v []string)

func (*ReadVReplicationWorkflowsRequest) String 

func (x *ReadVReplicationWorkflowsRequest) String() string

type ReadVReplicationWorkflowsRequest_builder 

type ReadVReplicationWorkflowsRequest_builder struct {
	IncludeIds       []int32
	IncludeWorkflows []string
	IncludeStates    []dev7.VReplicationWorkflowState
	ExcludeWorkflows []string
	ExcludeStates    []dev7.VReplicationWorkflowState
	ExcludeFrozen    bool
	// contains filtered or unexported fields
}

func (ReadVReplicationWorkflowsRequest_builder) Build 

func (b0 ReadVReplicationWorkflowsRequest_builder) Build() *ReadVReplicationWorkflowsRequest

type ReadVReplicationWorkflowsResponse 

type ReadVReplicationWorkflowsResponse struct {
	Workflows []*ReadVReplicationWorkflowResponse `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadVReplicationWorkflowsResponse) GetWorkflows 

func (x *ReadVReplicationWorkflowsResponse) GetWorkflows() []*ReadVReplicationWorkflowResponse

func (*ReadVReplicationWorkflowsResponse) ProtoMessage 

func (*ReadVReplicationWorkflowsResponse) ProtoMessage()

func (*ReadVReplicationWorkflowsResponse) ProtoReflect 

func (x *ReadVReplicationWorkflowsResponse) ProtoReflect() protoreflect.Message

func (*ReadVReplicationWorkflowsResponse) Reset 

func (x *ReadVReplicationWorkflowsResponse) Reset()

func (*ReadVReplicationWorkflowsResponse) SetWorkflows 

func (x *ReadVReplicationWorkflowsResponse) SetWorkflows(v []*ReadVReplicationWorkflowResponse)

func (*ReadVReplicationWorkflowsResponse) String 

func (x *ReadVReplicationWorkflowsResponse) String() string

type ReadVReplicationWorkflowsResponse_builder 

type ReadVReplicationWorkflowsResponse_builder struct {
	Workflows []*ReadVReplicationWorkflowResponse
	// contains filtered or unexported fields
}

func (ReadVReplicationWorkflowsResponse_builder) Build 

func (b0 ReadVReplicationWorkflowsResponse_builder) Build() *ReadVReplicationWorkflowsResponse

type RefreshStateRequest 

type RefreshStateRequest struct {
	// contains filtered or unexported fields
}

func (*RefreshStateRequest) ProtoMessage 

func (*RefreshStateRequest) ProtoMessage()

func (*RefreshStateRequest) ProtoReflect 

func (x *RefreshStateRequest) ProtoReflect() protoreflect.Message

func (*RefreshStateRequest) Reset 

func (x *RefreshStateRequest) Reset()

func (*RefreshStateRequest) String 

func (x *RefreshStateRequest) String() string

type RefreshStateRequest_builder 

type RefreshStateRequest_builder struct {
	// contains filtered or unexported fields
}

func (RefreshStateRequest_builder) Build 

func (b0 RefreshStateRequest_builder) Build() *RefreshStateRequest

type RefreshStateResponse 

type RefreshStateResponse struct {
	// contains filtered or unexported fields
}

func (*RefreshStateResponse) ProtoMessage 

func (*RefreshStateResponse) ProtoMessage()

func (*RefreshStateResponse) ProtoReflect 

func (x *RefreshStateResponse) ProtoReflect() protoreflect.Message

func (*RefreshStateResponse) Reset 

func (x *RefreshStateResponse) Reset()

func (*RefreshStateResponse) String 

func (x *RefreshStateResponse) String() string

type RefreshStateResponse_builder 

type RefreshStateResponse_builder struct {
	// contains filtered or unexported fields
}

func (RefreshStateResponse_builder) Build 

func (b0 RefreshStateResponse_builder) Build() *RefreshStateResponse

type ReloadSchemaRequest 

type ReloadSchemaRequest struct {

	// wait_position allows scheduling a schema reload to occur after a
	// given DDL has replicated to this server, by specifying a replication
	// position to wait for. Leave empty to trigger the reload immediately.
	WaitPosition string `protobuf:"bytes,1,opt,name=wait_position,json=waitPosition,proto3" json:"wait_position,omitempty"`
	// contains filtered or unexported fields
}

func (*ReloadSchemaRequest) GetWaitPosition 

func (x *ReloadSchemaRequest) GetWaitPosition() string

func (*ReloadSchemaRequest) ProtoMessage 

func (*ReloadSchemaRequest) ProtoMessage()

func (*ReloadSchemaRequest) ProtoReflect 

func (x *ReloadSchemaRequest) ProtoReflect() protoreflect.Message

func (*ReloadSchemaRequest) Reset 

func (x *ReloadSchemaRequest) Reset()

func (*ReloadSchemaRequest) SetWaitPosition 

func (x *ReloadSchemaRequest) SetWaitPosition(v string)

func (*ReloadSchemaRequest) String 

func (x *ReloadSchemaRequest) String() string

type ReloadSchemaRequest_builder 

type ReloadSchemaRequest_builder struct {

	// wait_position allows scheduling a schema reload to occur after a
	// given DDL has replicated to this server, by specifying a replication
	// position to wait for. Leave empty to trigger the reload immediately.
	WaitPosition string
	// contains filtered or unexported fields
}

func (ReloadSchemaRequest_builder) Build 

func (b0 ReloadSchemaRequest_builder) Build() *ReloadSchemaRequest

type ReloadSchemaResponse 

type ReloadSchemaResponse struct {
	// contains filtered or unexported fields
}

func (*ReloadSchemaResponse) ProtoMessage 

func (*ReloadSchemaResponse) ProtoMessage()

func (*ReloadSchemaResponse) ProtoReflect 

func (x *ReloadSchemaResponse) ProtoReflect() protoreflect.Message

func (*ReloadSchemaResponse) Reset 

func (x *ReloadSchemaResponse) Reset()

func (*ReloadSchemaResponse) String 

func (x *ReloadSchemaResponse) String() string

type ReloadSchemaResponse_builder 

type ReloadSchemaResponse_builder struct {
	// contains filtered or unexported fields
}

func (ReloadSchemaResponse_builder) Build 

func (b0 ReloadSchemaResponse_builder) Build() *ReloadSchemaResponse

type ReplicaWasPromotedRequest 

type ReplicaWasPromotedRequest struct {
	// contains filtered or unexported fields
}

func (*ReplicaWasPromotedRequest) ProtoMessage 

func (*ReplicaWasPromotedRequest) ProtoMessage()

func (*ReplicaWasPromotedRequest) ProtoReflect 

func (x *ReplicaWasPromotedRequest) ProtoReflect() protoreflect.Message

func (*ReplicaWasPromotedRequest) Reset 

func (x *ReplicaWasPromotedRequest) Reset()

func (*ReplicaWasPromotedRequest) String 

func (x *ReplicaWasPromotedRequest) String() string

type ReplicaWasPromotedRequest_builder 

type ReplicaWasPromotedRequest_builder struct {
	// contains filtered or unexported fields
}

func (ReplicaWasPromotedRequest_builder) Build 

func (b0 ReplicaWasPromotedRequest_builder) Build() *ReplicaWasPromotedRequest

type ReplicaWasPromotedResponse 

type ReplicaWasPromotedResponse struct {
	// contains filtered or unexported fields
}

func (*ReplicaWasPromotedResponse) ProtoMessage 

func (*ReplicaWasPromotedResponse) ProtoMessage()

func (*ReplicaWasPromotedResponse) ProtoReflect 

func (x *ReplicaWasPromotedResponse) ProtoReflect() protoreflect.Message

func (*ReplicaWasPromotedResponse) Reset 

func (x *ReplicaWasPromotedResponse) Reset()

func (*ReplicaWasPromotedResponse) String 

func (x *ReplicaWasPromotedResponse) String() string

type ReplicaWasPromotedResponse_builder 

type ReplicaWasPromotedResponse_builder struct {
	// contains filtered or unexported fields
}

func (ReplicaWasPromotedResponse_builder) Build 

func (b0 ReplicaWasPromotedResponse_builder) Build() *ReplicaWasPromotedResponse

type ReplicaWasRestartedRequest 

type ReplicaWasRestartedRequest struct {

	// the parent alias the tablet should have
	Parent *dev1.TabletAlias `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaWasRestartedRequest) ClearParent 

func (x *ReplicaWasRestartedRequest) ClearParent()

func (*ReplicaWasRestartedRequest) GetParent 

func (x *ReplicaWasRestartedRequest) GetParent() *dev1.TabletAlias

func (*ReplicaWasRestartedRequest) HasParent 

func (x *ReplicaWasRestartedRequest) HasParent() bool

func (*ReplicaWasRestartedRequest) ProtoMessage 

func (*ReplicaWasRestartedRequest) ProtoMessage()

func (*ReplicaWasRestartedRequest) ProtoReflect 

func (x *ReplicaWasRestartedRequest) ProtoReflect() protoreflect.Message

func (*ReplicaWasRestartedRequest) Reset 

func (x *ReplicaWasRestartedRequest) Reset()

func (*ReplicaWasRestartedRequest) SetParent 

func (x *ReplicaWasRestartedRequest) SetParent(v *dev1.TabletAlias)

func (*ReplicaWasRestartedRequest) String 

func (x *ReplicaWasRestartedRequest) String() string

type ReplicaWasRestartedRequest_builder 

type ReplicaWasRestartedRequest_builder struct {

	// the parent alias the tablet should have
	Parent *dev1.TabletAlias
	// contains filtered or unexported fields
}

func (ReplicaWasRestartedRequest_builder) Build 

func (b0 ReplicaWasRestartedRequest_builder) Build() *ReplicaWasRestartedRequest

type ReplicaWasRestartedResponse 

type ReplicaWasRestartedResponse struct {
	// contains filtered or unexported fields
}

func (*ReplicaWasRestartedResponse) ProtoMessage 

func (*ReplicaWasRestartedResponse) ProtoMessage()

func (*ReplicaWasRestartedResponse) ProtoReflect 

func (x *ReplicaWasRestartedResponse) ProtoReflect() protoreflect.Message

func (*ReplicaWasRestartedResponse) Reset 

func (x *ReplicaWasRestartedResponse) Reset()

func (*ReplicaWasRestartedResponse) String 

func (x *ReplicaWasRestartedResponse) String() string

type ReplicaWasRestartedResponse_builder 

type ReplicaWasRestartedResponse_builder struct {
	// contains filtered or unexported fields
}

func (ReplicaWasRestartedResponse_builder) Build 

func (b0 ReplicaWasRestartedResponse_builder) Build() *ReplicaWasRestartedResponse

type ReplicationStatusRequest 

type ReplicationStatusRequest struct {
	// contains filtered or unexported fields
}

func (*ReplicationStatusRequest) ProtoMessage 

func (*ReplicationStatusRequest) ProtoMessage()

func (*ReplicationStatusRequest) ProtoReflect 

func (x *ReplicationStatusRequest) ProtoReflect() protoreflect.Message

func (*ReplicationStatusRequest) Reset 

func (x *ReplicationStatusRequest) Reset()

func (*ReplicationStatusRequest) String 

func (x *ReplicationStatusRequest) String() string

type ReplicationStatusRequest_builder 

type ReplicationStatusRequest_builder struct {
	// contains filtered or unexported fields
}

func (ReplicationStatusRequest_builder) Build 

func (b0 ReplicationStatusRequest_builder) Build() *ReplicationStatusRequest

type ReplicationStatusResponse 

type ReplicationStatusResponse struct {
	Status *dev4.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicationStatusResponse) ClearStatus 

func (x *ReplicationStatusResponse) ClearStatus()

func (*ReplicationStatusResponse) GetStatus 

func (x *ReplicationStatusResponse) GetStatus() *dev4.Status

func (*ReplicationStatusResponse) HasStatus 

func (x *ReplicationStatusResponse) HasStatus() bool

func (*ReplicationStatusResponse) ProtoMessage 

func (*ReplicationStatusResponse) ProtoMessage()

func (*ReplicationStatusResponse) ProtoReflect 

func (x *ReplicationStatusResponse) ProtoReflect() protoreflect.Message

func (*ReplicationStatusResponse) Reset 

func (x *ReplicationStatusResponse) Reset()

func (*ReplicationStatusResponse) SetStatus 

func (x *ReplicationStatusResponse) SetStatus(v *dev4.Status)

func (*ReplicationStatusResponse) String 

func (x *ReplicationStatusResponse) String() string

type ReplicationStatusResponse_builder 

type ReplicationStatusResponse_builder struct {
	Status *dev4.Status
	// contains filtered or unexported fields
}

func (ReplicationStatusResponse_builder) Build 

func (b0 ReplicationStatusResponse_builder) Build() *ReplicationStatusResponse

type ResetReplicationParametersRequest 

type ResetReplicationParametersRequest struct {
	// contains filtered or unexported fields
}

func (*ResetReplicationParametersRequest) ProtoMessage 

func (*ResetReplicationParametersRequest) ProtoMessage()

func (*ResetReplicationParametersRequest) ProtoReflect 

func (x *ResetReplicationParametersRequest) ProtoReflect() protoreflect.Message

func (*ResetReplicationParametersRequest) Reset 

func (x *ResetReplicationParametersRequest) Reset()

func (*ResetReplicationParametersRequest) String 

func (x *ResetReplicationParametersRequest) String() string

type ResetReplicationParametersRequest_builder 

type ResetReplicationParametersRequest_builder struct {
	// contains filtered or unexported fields
}

func (ResetReplicationParametersRequest_builder) Build 

func (b0 ResetReplicationParametersRequest_builder) Build() *ResetReplicationParametersRequest

type ResetReplicationParametersResponse 

type ResetReplicationParametersResponse struct {
	// contains filtered or unexported fields
}

func (*ResetReplicationParametersResponse) ProtoMessage 

func (*ResetReplicationParametersResponse) ProtoMessage()

func (*ResetReplicationParametersResponse) ProtoReflect 

func (x *ResetReplicationParametersResponse) ProtoReflect() protoreflect.Message

func (*ResetReplicationParametersResponse) Reset 

func (x *ResetReplicationParametersResponse) Reset()

func (*ResetReplicationParametersResponse) String 

func (x *ResetReplicationParametersResponse) String() string

type ResetReplicationParametersResponse_builder 

type ResetReplicationParametersResponse_builder struct {
	// contains filtered or unexported fields
}

func (ResetReplicationParametersResponse_builder) Build 

func (b0 ResetReplicationParametersResponse_builder) Build() *ResetReplicationParametersResponse

type ResetReplicationRequest 

type ResetReplicationRequest struct {
	// contains filtered or unexported fields
}

func (*ResetReplicationRequest) ProtoMessage 

func (*ResetReplicationRequest) ProtoMessage()

func (*ResetReplicationRequest) ProtoReflect 

func (x *ResetReplicationRequest) ProtoReflect() protoreflect.Message

func (*ResetReplicationRequest) Reset 

func (x *ResetReplicationRequest) Reset()

func (*ResetReplicationRequest) String 

func (x *ResetReplicationRequest) String() string

type ResetReplicationRequest_builder 

type ResetReplicationRequest_builder struct {
	// contains filtered or unexported fields
}

func (ResetReplicationRequest_builder) Build 

func (b0 ResetReplicationRequest_builder) Build() *ResetReplicationRequest

type ResetReplicationResponse 

type ResetReplicationResponse struct {
	// contains filtered or unexported fields
}

func (*ResetReplicationResponse) ProtoMessage 

func (*ResetReplicationResponse) ProtoMessage()

func (*ResetReplicationResponse) ProtoReflect 

func (x *ResetReplicationResponse) ProtoReflect() protoreflect.Message

func (*ResetReplicationResponse) Reset 

func (x *ResetReplicationResponse) Reset()

func (*ResetReplicationResponse) String 

func (x *ResetReplicationResponse) String() string

type ResetReplicationResponse_builder 

type ResetReplicationResponse_builder struct {
	// contains filtered or unexported fields
}

func (ResetReplicationResponse_builder) Build 

func (b0 ResetReplicationResponse_builder) Build() *ResetReplicationResponse

type ResetSequencesRequest 

type ResetSequencesRequest struct {
	Tables []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*ResetSequencesRequest) GetTables 

func (x *ResetSequencesRequest) GetTables() []string

func (*ResetSequencesRequest) ProtoMessage 

func (*ResetSequencesRequest) ProtoMessage()

func (*ResetSequencesRequest) ProtoReflect 

func (x *ResetSequencesRequest) ProtoReflect() protoreflect.Message

func (*ResetSequencesRequest) Reset 

func (x *ResetSequencesRequest) Reset()

func (*ResetSequencesRequest) SetTables 

func (x *ResetSequencesRequest) SetTables(v []string)

func (*ResetSequencesRequest) String 

func (x *ResetSequencesRequest) String() string

type ResetSequencesRequest_builder 

type ResetSequencesRequest_builder struct {
	Tables []string
	// contains filtered or unexported fields
}

func (ResetSequencesRequest_builder) Build 

func (b0 ResetSequencesRequest_builder) Build() *ResetSequencesRequest

type ResetSequencesResponse 

type ResetSequencesResponse struct {
	// contains filtered or unexported fields
}

func (*ResetSequencesResponse) ProtoMessage 

func (*ResetSequencesResponse) ProtoMessage()

func (*ResetSequencesResponse) ProtoReflect 

func (x *ResetSequencesResponse) ProtoReflect() protoreflect.Message

func (*ResetSequencesResponse) Reset 

func (x *ResetSequencesResponse) Reset()

func (*ResetSequencesResponse) String 

func (x *ResetSequencesResponse) String() string

type ResetSequencesResponse_builder 

type ResetSequencesResponse_builder struct {
	// contains filtered or unexported fields
}

func (ResetSequencesResponse_builder) Build 

func (b0 ResetSequencesResponse_builder) Build() *ResetSequencesResponse

type RestoreFromBackupRequest 

type RestoreFromBackupRequest struct {
	BackupTime *dev5.Time `protobuf:"bytes,1,opt,name=backup_time,json=backupTime,proto3" json:"backup_time,omitempty"`
	// RestoreToPos indicates a position for a point-in-time recovery. The recovery
	// is expected to utilize one full backup, followed by zero or more incremental backups,
	// that reach the precise desired position
	RestoreToPos string `protobuf:"bytes,2,opt,name=restore_to_pos,json=restoreToPos,proto3" json:"restore_to_pos,omitempty"`
	// Dry run does not actually performs the restore, but validates the steps and availability of backups
	DryRun bool `protobuf:"varint,3,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// RestoreToTimestamp, if given, requested an inremental restore up to (and excluding) the given timestamp.
	// RestoreToTimestamp and RestoreToPos are mutually exclusive.
	RestoreToTimestamp *dev5.Time `protobuf:"bytes,4,opt,name=restore_to_timestamp,json=restoreToTimestamp,proto3" json:"restore_to_timestamp,omitempty"`
	// AllowedBackupEngines, if present will filter out any backups taken with engines not included in the list
	AllowedBackupEngines []string `protobuf:"bytes,5,rep,name=allowed_backup_engines,json=allowedBackupEngines,proto3" json:"allowed_backup_engines,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreFromBackupRequest) ClearBackupTime 

func (x *RestoreFromBackupRequest) ClearBackupTime()

func (*RestoreFromBackupRequest) ClearRestoreToTimestamp 

func (x *RestoreFromBackupRequest) ClearRestoreToTimestamp()

func (*RestoreFromBackupRequest) GetAllowedBackupEngines 

func (x *RestoreFromBackupRequest) GetAllowedBackupEngines() []string

func (*RestoreFromBackupRequest) GetBackupTime 

func (x *RestoreFromBackupRequest) GetBackupTime() *dev5.Time

func (*RestoreFromBackupRequest) GetDryRun 

func (x *RestoreFromBackupRequest) GetDryRun() bool

func (*RestoreFromBackupRequest) GetRestoreToPos 

func (x *RestoreFromBackupRequest) GetRestoreToPos() string

func (*RestoreFromBackupRequest) GetRestoreToTimestamp 

func (x *RestoreFromBackupRequest) GetRestoreToTimestamp() *dev5.Time

func (*RestoreFromBackupRequest) HasBackupTime 

func (x *RestoreFromBackupRequest) HasBackupTime() bool

func (*RestoreFromBackupRequest) HasRestoreToTimestamp 

func (x *RestoreFromBackupRequest) HasRestoreToTimestamp() bool

func (*RestoreFromBackupRequest) ProtoMessage 

func (*RestoreFromBackupRequest) ProtoMessage()

func (*RestoreFromBackupRequest) ProtoReflect 

func (x *RestoreFromBackupRequest) ProtoReflect() protoreflect.Message

func (*RestoreFromBackupRequest) Reset 

func (x *RestoreFromBackupRequest) Reset()

func (*RestoreFromBackupRequest) SetAllowedBackupEngines 

func (x *RestoreFromBackupRequest) SetAllowedBackupEngines(v []string)

func (*RestoreFromBackupRequest) SetBackupTime 

func (x *RestoreFromBackupRequest) SetBackupTime(v *dev5.Time)

func (*RestoreFromBackupRequest) SetDryRun 

func (x *RestoreFromBackupRequest) SetDryRun(v bool)

func (*RestoreFromBackupRequest) SetRestoreToPos 

func (x *RestoreFromBackupRequest) SetRestoreToPos(v string)

func (*RestoreFromBackupRequest) SetRestoreToTimestamp 

func (x *RestoreFromBackupRequest) SetRestoreToTimestamp(v *dev5.Time)

func (*RestoreFromBackupRequest) String 

func (x *RestoreFromBackupRequest) String() string

type RestoreFromBackupRequest_builder 

type RestoreFromBackupRequest_builder struct {
	BackupTime *dev5.Time
	// RestoreToPos indicates a position for a point-in-time recovery. The recovery
	// is expected to utilize one full backup, followed by zero or more incremental backups,
	// that reach the precise desired position
	RestoreToPos string
	// Dry run does not actually performs the restore, but validates the steps and availability of backups
	DryRun bool
	// RestoreToTimestamp, if given, requested an inremental restore up to (and excluding) the given timestamp.
	// RestoreToTimestamp and RestoreToPos are mutually exclusive.
	RestoreToTimestamp *dev5.Time
	// AllowedBackupEngines, if present will filter out any backups taken with engines not included in the list
	AllowedBackupEngines []string
	// contains filtered or unexported fields
}

func (RestoreFromBackupRequest_builder) Build 

func (b0 RestoreFromBackupRequest_builder) Build() *RestoreFromBackupRequest

type RestoreFromBackupResponse 

type RestoreFromBackupResponse struct {
	Event *dev6.Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreFromBackupResponse) ClearEvent 

func (x *RestoreFromBackupResponse) ClearEvent()

func (*RestoreFromBackupResponse) GetEvent 

func (x *RestoreFromBackupResponse) GetEvent() *dev6.Event

func (*RestoreFromBackupResponse) HasEvent 

func (x *RestoreFromBackupResponse) HasEvent() bool

func (*RestoreFromBackupResponse) ProtoMessage 

func (*RestoreFromBackupResponse) ProtoMessage()

func (*RestoreFromBackupResponse) ProtoReflect 

func (x *RestoreFromBackupResponse) ProtoReflect() protoreflect.Message

func (*RestoreFromBackupResponse) Reset 

func (x *RestoreFromBackupResponse) Reset()

func (*RestoreFromBackupResponse) SetEvent 

func (x *RestoreFromBackupResponse) SetEvent(v *dev6.Event)

func (*RestoreFromBackupResponse) String 

func (x *RestoreFromBackupResponse) String() string

type RestoreFromBackupResponse_builder 

type RestoreFromBackupResponse_builder struct {
	Event *dev6.Event
	// contains filtered or unexported fields
}

func (RestoreFromBackupResponse_builder) Build 

func (b0 RestoreFromBackupResponse_builder) Build() *RestoreFromBackupResponse

type RunHealthCheckRequest 

type RunHealthCheckRequest struct {
	// contains filtered or unexported fields
}

func (*RunHealthCheckRequest) ProtoMessage 

func (*RunHealthCheckRequest) ProtoMessage()

func (*RunHealthCheckRequest) ProtoReflect 

func (x *RunHealthCheckRequest) ProtoReflect() protoreflect.Message

func (*RunHealthCheckRequest) Reset 

func (x *RunHealthCheckRequest) Reset()

func (*RunHealthCheckRequest) String 

func (x *RunHealthCheckRequest) String() string

type RunHealthCheckRequest_builder 

type RunHealthCheckRequest_builder struct {
	// contains filtered or unexported fields
}

func (RunHealthCheckRequest_builder) Build 

func (b0 RunHealthCheckRequest_builder) Build() *RunHealthCheckRequest

type RunHealthCheckResponse 

type RunHealthCheckResponse struct {
	// contains filtered or unexported fields
}

func (*RunHealthCheckResponse) ProtoMessage 

func (*RunHealthCheckResponse) ProtoMessage()

func (*RunHealthCheckResponse) ProtoReflect 

func (x *RunHealthCheckResponse) ProtoReflect() protoreflect.Message

func (*RunHealthCheckResponse) Reset 

func (x *RunHealthCheckResponse) Reset()

func (*RunHealthCheckResponse) String 

func (x *RunHealthCheckResponse) String() string

type RunHealthCheckResponse_builder 

type RunHealthCheckResponse_builder struct {
	// contains filtered or unexported fields
}

func (RunHealthCheckResponse_builder) Build 

func (b0 RunHealthCheckResponse_builder) Build() *RunHealthCheckResponse

type SchemaChangeResult 

type SchemaChangeResult struct {

	// before_schema holds the schema before each change.
	BeforeSchema *SchemaDefinition `protobuf:"bytes,1,opt,name=before_schema,json=beforeSchema,proto3" json:"before_schema,omitempty"`
	// after_schema holds the schema after each change.
	AfterSchema *SchemaDefinition `protobuf:"bytes,2,opt,name=after_schema,json=afterSchema,proto3" json:"after_schema,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaChangeResult) ClearAfterSchema 

func (x *SchemaChangeResult) ClearAfterSchema()

func (*SchemaChangeResult) ClearBeforeSchema 

func (x *SchemaChangeResult) ClearBeforeSchema()

func (*SchemaChangeResult) GetAfterSchema 

func (x *SchemaChangeResult) GetAfterSchema() *SchemaDefinition

func (*SchemaChangeResult) GetBeforeSchema 

func (x *SchemaChangeResult) GetBeforeSchema() *SchemaDefinition

func (*SchemaChangeResult) HasAfterSchema 

func (x *SchemaChangeResult) HasAfterSchema() bool

func (*SchemaChangeResult) HasBeforeSchema 

func (x *SchemaChangeResult) HasBeforeSchema() bool

func (*SchemaChangeResult) ProtoMessage 

func (*SchemaChangeResult) ProtoMessage()

func (*SchemaChangeResult) ProtoReflect 

func (x *SchemaChangeResult) ProtoReflect() protoreflect.Message

func (*SchemaChangeResult) Reset 

func (x *SchemaChangeResult) Reset()

func (*SchemaChangeResult) SetAfterSchema 

func (x *SchemaChangeResult) SetAfterSchema(v *SchemaDefinition)

func (*SchemaChangeResult) SetBeforeSchema 

func (x *SchemaChangeResult) SetBeforeSchema(v *SchemaDefinition)

func (*SchemaChangeResult) String 

func (x *SchemaChangeResult) String() string

type SchemaChangeResult_builder 

type SchemaChangeResult_builder struct {

	// before_schema holds the schema before each change.
	BeforeSchema *SchemaDefinition
	// after_schema holds the schema after each change.
	AfterSchema *SchemaDefinition
	// contains filtered or unexported fields
}

func (SchemaChangeResult_builder) Build 

func (b0 SchemaChangeResult_builder) Build() *SchemaChangeResult

type SchemaDefinition 

type SchemaDefinition struct {
	DatabaseSchema   string             `protobuf:"bytes,1,opt,name=database_schema,json=databaseSchema,proto3" json:"database_schema,omitempty"`
	TableDefinitions []*TableDefinition `protobuf:"bytes,2,rep,name=table_definitions,json=tableDefinitions,proto3" json:"table_definitions,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaDefinition) GetDatabaseSchema 

func (x *SchemaDefinition) GetDatabaseSchema() string

func (*SchemaDefinition) GetTableDefinitions 

func (x *SchemaDefinition) GetTableDefinitions() []*TableDefinition

func (*SchemaDefinition) ProtoMessage 

func (*SchemaDefinition) ProtoMessage()

func (*SchemaDefinition) ProtoReflect 

func (x *SchemaDefinition) ProtoReflect() protoreflect.Message

func (*SchemaDefinition) Reset 

func (x *SchemaDefinition) Reset()

func (*SchemaDefinition) SetDatabaseSchema 

func (x *SchemaDefinition) SetDatabaseSchema(v string)

func (*SchemaDefinition) SetTableDefinitions 

func (x *SchemaDefinition) SetTableDefinitions(v []*TableDefinition)

func (*SchemaDefinition) String 

func (x *SchemaDefinition) String() string

type SchemaDefinition_builder 

type SchemaDefinition_builder struct {
	DatabaseSchema   string
	TableDefinitions []*TableDefinition
	// contains filtered or unexported fields
}

func (SchemaDefinition_builder) Build 

func (b0 SchemaDefinition_builder) Build() *SchemaDefinition

type SetReadOnlyRequest 

type SetReadOnlyRequest struct {
	// contains filtered or unexported fields
}

func (*SetReadOnlyRequest) ProtoMessage 

func (*SetReadOnlyRequest) ProtoMessage()

func (*SetReadOnlyRequest) ProtoReflect 

func (x *SetReadOnlyRequest) ProtoReflect() protoreflect.Message

func (*SetReadOnlyRequest) Reset 

func (x *SetReadOnlyRequest) Reset()

func (*SetReadOnlyRequest) String 

func (x *SetReadOnlyRequest) String() string

type SetReadOnlyRequest_builder 

type SetReadOnlyRequest_builder struct {
	// contains filtered or unexported fields
}

func (SetReadOnlyRequest_builder) Build 

func (b0 SetReadOnlyRequest_builder) Build() *SetReadOnlyRequest

type SetReadOnlyResponse 

type SetReadOnlyResponse struct {
	// contains filtered or unexported fields
}

func (*SetReadOnlyResponse) ProtoMessage 

func (*SetReadOnlyResponse) ProtoMessage()

func (*SetReadOnlyResponse) ProtoReflect 

func (x *SetReadOnlyResponse) ProtoReflect() protoreflect.Message

func (*SetReadOnlyResponse) Reset 

func (x *SetReadOnlyResponse) Reset()

func (*SetReadOnlyResponse) String 

func (x *SetReadOnlyResponse) String() string

type SetReadOnlyResponse_builder 

type SetReadOnlyResponse_builder struct {
	// contains filtered or unexported fields
}

func (SetReadOnlyResponse_builder) Build 

func (b0 SetReadOnlyResponse_builder) Build() *SetReadOnlyResponse

type SetReadWriteRequest 

type SetReadWriteRequest struct {
	// contains filtered or unexported fields
}

func (*SetReadWriteRequest) ProtoMessage 

func (*SetReadWriteRequest) ProtoMessage()

func (*SetReadWriteRequest) ProtoReflect 

func (x *SetReadWriteRequest) ProtoReflect() protoreflect.Message

func (*SetReadWriteRequest) Reset 

func (x *SetReadWriteRequest) Reset()

func (*SetReadWriteRequest) String 

func (x *SetReadWriteRequest) String() string

type SetReadWriteRequest_builder 

type SetReadWriteRequest_builder struct {
	// contains filtered or unexported fields
}

func (SetReadWriteRequest_builder) Build 

func (b0 SetReadWriteRequest_builder) Build() *SetReadWriteRequest

type SetReadWriteResponse 

type SetReadWriteResponse struct {
	// contains filtered or unexported fields
}

func (*SetReadWriteResponse) ProtoMessage 

func (*SetReadWriteResponse) ProtoMessage()

func (*SetReadWriteResponse) ProtoReflect 

func (x *SetReadWriteResponse) ProtoReflect() protoreflect.Message

func (*SetReadWriteResponse) Reset 

func (x *SetReadWriteResponse) Reset()

func (*SetReadWriteResponse) String 

func (x *SetReadWriteResponse) String() string

type SetReadWriteResponse_builder 

type SetReadWriteResponse_builder struct {
	// contains filtered or unexported fields
}

func (SetReadWriteResponse_builder) Build 

func (b0 SetReadWriteResponse_builder) Build() *SetReadWriteResponse

type SetReplicationSourceRequest 

type SetReplicationSourceRequest struct {
	Parent                *dev1.TabletAlias `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	TimeCreatedNs         int64             `protobuf:"varint,2,opt,name=time_created_ns,json=timeCreatedNs,proto3" json:"time_created_ns,omitempty"`
	ForceStartReplication bool              `` /* 127-byte string literal not displayed */
	WaitPosition          string            `protobuf:"bytes,4,opt,name=wait_position,json=waitPosition,proto3" json:"wait_position,omitempty"`
	SemiSync              bool              `protobuf:"varint,5,opt,name=semiSync,proto3" json:"semiSync,omitempty"`
	HeartbeatInterval     float64           `protobuf:"fixed64,6,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
	// contains filtered or unexported fields
}

func (*SetReplicationSourceRequest) ClearParent 

func (x *SetReplicationSourceRequest) ClearParent()

func (*SetReplicationSourceRequest) GetForceStartReplication 

func (x *SetReplicationSourceRequest) GetForceStartReplication() bool

func (*SetReplicationSourceRequest) GetHeartbeatInterval 

func (x *SetReplicationSourceRequest) GetHeartbeatInterval() float64

func (*SetReplicationSourceRequest) GetParent 

func (x *SetReplicationSourceRequest) GetParent() *dev1.TabletAlias

func (*SetReplicationSourceRequest) GetSemiSync 

func (x *SetReplicationSourceRequest) GetSemiSync() bool

func (*SetReplicationSourceRequest) GetTimeCreatedNs 

func (x *SetReplicationSourceRequest) GetTimeCreatedNs() int64

func (*SetReplicationSourceRequest) GetWaitPosition 

func (x *SetReplicationSourceRequest) GetWaitPosition() string

func (*SetReplicationSourceRequest) HasParent 

func (x *SetReplicationSourceRequest) HasParent() bool

func (*SetReplicationSourceRequest) ProtoMessage 

func (*SetReplicationSourceRequest) ProtoMessage()

func (*SetReplicationSourceRequest) ProtoReflect 

func (x *SetReplicationSourceRequest) ProtoReflect() protoreflect.Message

func (*SetReplicationSourceRequest) Reset 

func (x *SetReplicationSourceRequest) Reset()

func (*SetReplicationSourceRequest) SetForceStartReplication 

func (x *SetReplicationSourceRequest) SetForceStartReplication(v bool)

func (*SetReplicationSourceRequest) SetHeartbeatInterval 

func (x *SetReplicationSourceRequest) SetHeartbeatInterval(v float64)

func (*SetReplicationSourceRequest) SetParent 

func (x *SetReplicationSourceRequest) SetParent(v *dev1.TabletAlias)

func (*SetReplicationSourceRequest) SetSemiSync 

func (x *SetReplicationSourceRequest) SetSemiSync(v bool)

func (*SetReplicationSourceRequest) SetTimeCreatedNs 

func (x *SetReplicationSourceRequest) SetTimeCreatedNs(v int64)

func (*SetReplicationSourceRequest) SetWaitPosition 

func (x *SetReplicationSourceRequest) SetWaitPosition(v string)

func (*SetReplicationSourceRequest) String 

func (x *SetReplicationSourceRequest) String() string

type SetReplicationSourceRequest_builder 

type SetReplicationSourceRequest_builder struct {
	Parent                *dev1.TabletAlias
	TimeCreatedNs         int64
	ForceStartReplication bool
	WaitPosition          string
	SemiSync              bool
	HeartbeatInterval     float64
	// contains filtered or unexported fields
}

func (SetReplicationSourceRequest_builder) Build 

func (b0 SetReplicationSourceRequest_builder) Build() *SetReplicationSourceRequest

type SetReplicationSourceResponse 

type SetReplicationSourceResponse struct {
	// contains filtered or unexported fields
}

func (*SetReplicationSourceResponse) ProtoMessage 

func (*SetReplicationSourceResponse) ProtoMessage()

func (*SetReplicationSourceResponse) ProtoReflect 

func (x *SetReplicationSourceResponse) ProtoReflect() protoreflect.Message

func (*SetReplicationSourceResponse) Reset 

func (x *SetReplicationSourceResponse) Reset()

func (*SetReplicationSourceResponse) String 

func (x *SetReplicationSourceResponse) String() string

type SetReplicationSourceResponse_builder 

type SetReplicationSourceResponse_builder struct {
	// contains filtered or unexported fields
}

func (SetReplicationSourceResponse_builder) Build 

func (b0 SetReplicationSourceResponse_builder) Build() *SetReplicationSourceResponse

type SleepRequest 

type SleepRequest struct {

	// duration is in nanoseconds
	Duration int64 `protobuf:"varint,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

func (*SleepRequest) GetDuration 

func (x *SleepRequest) GetDuration() int64

func (*SleepRequest) ProtoMessage 

func (*SleepRequest) ProtoMessage()

func (*SleepRequest) ProtoReflect 

func (x *SleepRequest) ProtoReflect() protoreflect.Message

func (*SleepRequest) Reset 

func (x *SleepRequest) Reset()

func (*SleepRequest) SetDuration 

func (x *SleepRequest) SetDuration(v int64)

func (*SleepRequest) String 

func (x *SleepRequest) String() string

type SleepRequest_builder 

type SleepRequest_builder struct {

	// duration is in nanoseconds
	Duration int64
	// contains filtered or unexported fields
}

func (SleepRequest_builder) Build 

func (b0 SleepRequest_builder) Build() *SleepRequest

type SleepResponse 

type SleepResponse struct {
	// contains filtered or unexported fields
}

func (*SleepResponse) ProtoMessage 

func (*SleepResponse) ProtoMessage()

func (*SleepResponse) ProtoReflect 

func (x *SleepResponse) ProtoReflect() protoreflect.Message

func (*SleepResponse) Reset 

func (x *SleepResponse) Reset()

func (*SleepResponse) String 

func (x *SleepResponse) String() string

type SleepResponse_builder 

type SleepResponse_builder struct {
	// contains filtered or unexported fields
}

func (SleepResponse_builder) Build 

func (b0 SleepResponse_builder) Build() *SleepResponse

type StartReplicationRequest 

type StartReplicationRequest struct {
	SemiSync bool `protobuf:"varint,1,opt,name=semiSync,proto3" json:"semiSync,omitempty"`
	// contains filtered or unexported fields
}

func (*StartReplicationRequest) GetSemiSync 

func (x *StartReplicationRequest) GetSemiSync() bool

func (*StartReplicationRequest) ProtoMessage 

func (*StartReplicationRequest) ProtoMessage()

func (*StartReplicationRequest) ProtoReflect 

func (x *StartReplicationRequest) ProtoReflect() protoreflect.Message

func (*StartReplicationRequest) Reset 

func (x *StartReplicationRequest) Reset()

func (*StartReplicationRequest) SetSemiSync 

func (x *StartReplicationRequest) SetSemiSync(v bool)

func (*StartReplicationRequest) String 

func (x *StartReplicationRequest) String() string

type StartReplicationRequest_builder 

type StartReplicationRequest_builder struct {
	SemiSync bool
	// contains filtered or unexported fields
}

func (StartReplicationRequest_builder) Build 

func (b0 StartReplicationRequest_builder) Build() *StartReplicationRequest

type StartReplicationResponse 

type StartReplicationResponse struct {
	// contains filtered or unexported fields
}

func (*StartReplicationResponse) ProtoMessage 

func (*StartReplicationResponse) ProtoMessage()

func (*StartReplicationResponse) ProtoReflect 

func (x *StartReplicationResponse) ProtoReflect() protoreflect.Message

func (*StartReplicationResponse) Reset 

func (x *StartReplicationResponse) Reset()

func (*StartReplicationResponse) String 

func (x *StartReplicationResponse) String() string

type StartReplicationResponse_builder 

type StartReplicationResponse_builder struct {
	// contains filtered or unexported fields
}

func (StartReplicationResponse_builder) Build 

func (b0 StartReplicationResponse_builder) Build() *StartReplicationResponse

type StartReplicationUntilAfterRequest 

type StartReplicationUntilAfterRequest struct {
	Position    string `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	WaitTimeout int64  `protobuf:"varint,2,opt,name=wait_timeout,json=waitTimeout,proto3" json:"wait_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*StartReplicationUntilAfterRequest) GetPosition 

func (x *StartReplicationUntilAfterRequest) GetPosition() string

func (*StartReplicationUntilAfterRequest) GetWaitTimeout 

func (x *StartReplicationUntilAfterRequest) GetWaitTimeout() int64

func (*StartReplicationUntilAfterRequest) ProtoMessage 

func (*StartReplicationUntilAfterRequest) ProtoMessage()

func (*StartReplicationUntilAfterRequest) ProtoReflect 

func (x *StartReplicationUntilAfterRequest) ProtoReflect() protoreflect.Message

func (*StartReplicationUntilAfterRequest) Reset 

func (x *StartReplicationUntilAfterRequest) Reset()

func (*StartReplicationUntilAfterRequest) SetPosition 

func (x *StartReplicationUntilAfterRequest) SetPosition(v string)

func (*StartReplicationUntilAfterRequest) SetWaitTimeout 

func (x *StartReplicationUntilAfterRequest) SetWaitTimeout(v int64)

func (*StartReplicationUntilAfterRequest) String 

func (x *StartReplicationUntilAfterRequest) String() string

type StartReplicationUntilAfterRequest_builder 

type StartReplicationUntilAfterRequest_builder struct {
	Position    string
	WaitTimeout int64
	// contains filtered or unexported fields
}

func (StartReplicationUntilAfterRequest_builder) Build 

func (b0 StartReplicationUntilAfterRequest_builder) Build() *StartReplicationUntilAfterRequest

type StartReplicationUntilAfterResponse 

type StartReplicationUntilAfterResponse struct {
	// contains filtered or unexported fields
}

func (*StartReplicationUntilAfterResponse) ProtoMessage 

func (*StartReplicationUntilAfterResponse) ProtoMessage()

func (*StartReplicationUntilAfterResponse) ProtoReflect 

func (x *StartReplicationUntilAfterResponse) ProtoReflect() protoreflect.Message

func (*StartReplicationUntilAfterResponse) Reset 

func (x *StartReplicationUntilAfterResponse) Reset()

func (*StartReplicationUntilAfterResponse) String 

func (x *StartReplicationUntilAfterResponse) String() string

type StartReplicationUntilAfterResponse_builder 

type StartReplicationUntilAfterResponse_builder struct {
	// contains filtered or unexported fields
}

func (StartReplicationUntilAfterResponse_builder) Build 

func (b0 StartReplicationUntilAfterResponse_builder) Build() *StartReplicationUntilAfterResponse

type StopReplicationAndGetStatusRequest 

type StopReplicationAndGetStatusRequest struct {
	StopReplicationMode dev4.StopReplicationMode `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StopReplicationAndGetStatusRequest) GetStopReplicationMode 

func (x *StopReplicationAndGetStatusRequest) GetStopReplicationMode() dev4.StopReplicationMode

func (*StopReplicationAndGetStatusRequest) ProtoMessage 

func (*StopReplicationAndGetStatusRequest) ProtoMessage()

func (*StopReplicationAndGetStatusRequest) ProtoReflect 

func (x *StopReplicationAndGetStatusRequest) ProtoReflect() protoreflect.Message

func (*StopReplicationAndGetStatusRequest) Reset 

func (x *StopReplicationAndGetStatusRequest) Reset()

func (*StopReplicationAndGetStatusRequest) SetStopReplicationMode 

func (x *StopReplicationAndGetStatusRequest) SetStopReplicationMode(v dev4.StopReplicationMode)

func (*StopReplicationAndGetStatusRequest) String 

func (x *StopReplicationAndGetStatusRequest) String() string

type StopReplicationAndGetStatusRequest_builder 

type StopReplicationAndGetStatusRequest_builder struct {
	StopReplicationMode dev4.StopReplicationMode
	// contains filtered or unexported fields
}

func (StopReplicationAndGetStatusRequest_builder) Build 

func (b0 StopReplicationAndGetStatusRequest_builder) Build() *StopReplicationAndGetStatusRequest

type StopReplicationAndGetStatusResponse 

type StopReplicationAndGetStatusResponse struct {

	// Status represents the replication status call right before, and right after telling the replica to stop.
	Status *dev4.StopReplicationStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*StopReplicationAndGetStatusResponse) ClearStatus 

func (x *StopReplicationAndGetStatusResponse) ClearStatus()

func (*StopReplicationAndGetStatusResponse) GetStatus 

func (x *StopReplicationAndGetStatusResponse) GetStatus() *dev4.StopReplicationStatus

func (*StopReplicationAndGetStatusResponse) HasStatus 

func (x *StopReplicationAndGetStatusResponse) HasStatus() bool

func (*StopReplicationAndGetStatusResponse) ProtoMessage 

func (*StopReplicationAndGetStatusResponse) ProtoMessage()

func (*StopReplicationAndGetStatusResponse) ProtoReflect 

func (x *StopReplicationAndGetStatusResponse) ProtoReflect() protoreflect.Message

func (*StopReplicationAndGetStatusResponse) Reset 

func (x *StopReplicationAndGetStatusResponse) Reset()

func (*StopReplicationAndGetStatusResponse) SetStatus 

func (x *StopReplicationAndGetStatusResponse) SetStatus(v *dev4.StopReplicationStatus)

func (*StopReplicationAndGetStatusResponse) String 

func (x *StopReplicationAndGetStatusResponse) String() string

type StopReplicationAndGetStatusResponse_builder 

type StopReplicationAndGetStatusResponse_builder struct {

	// Status represents the replication status call right before, and right after telling the replica to stop.
	Status *dev4.StopReplicationStatus
	// contains filtered or unexported fields
}

func (StopReplicationAndGetStatusResponse_builder) Build 

func (b0 StopReplicationAndGetStatusResponse_builder) Build() *StopReplicationAndGetStatusResponse

type StopReplicationMinimumRequest 

type StopReplicationMinimumRequest struct {
	Position    string `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	WaitTimeout int64  `protobuf:"varint,2,opt,name=wait_timeout,json=waitTimeout,proto3" json:"wait_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*StopReplicationMinimumRequest) GetPosition 

func (x *StopReplicationMinimumRequest) GetPosition() string

func (*StopReplicationMinimumRequest) GetWaitTimeout 

func (x *StopReplicationMinimumRequest) GetWaitTimeout() int64

func (*StopReplicationMinimumRequest) ProtoMessage 

func (*StopReplicationMinimumRequest) ProtoMessage()

func (*StopReplicationMinimumRequest) ProtoReflect 

func (x *StopReplicationMinimumRequest) ProtoReflect() protoreflect.Message

func (*StopReplicationMinimumRequest) Reset 

func (x *StopReplicationMinimumRequest) Reset()

func (*StopReplicationMinimumRequest) SetPosition 

func (x *StopReplicationMinimumRequest) SetPosition(v string)

func (*StopReplicationMinimumRequest) SetWaitTimeout 

func (x *StopReplicationMinimumRequest) SetWaitTimeout(v int64)

func (*StopReplicationMinimumRequest) String 

func (x *StopReplicationMinimumRequest) String() string

type StopReplicationMinimumRequest_builder 

type StopReplicationMinimumRequest_builder struct {
	Position    string
	WaitTimeout int64
	// contains filtered or unexported fields
}

func (StopReplicationMinimumRequest_builder) Build 

func (b0 StopReplicationMinimumRequest_builder) Build() *StopReplicationMinimumRequest

type StopReplicationMinimumResponse 

type StopReplicationMinimumResponse struct {
	Position string `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

func (*StopReplicationMinimumResponse) GetPosition 

func (x *StopReplicationMinimumResponse) GetPosition() string

func (*StopReplicationMinimumResponse) ProtoMessage 

func (*StopReplicationMinimumResponse) ProtoMessage()

func (*StopReplicationMinimumResponse) ProtoReflect 

func (x *StopReplicationMinimumResponse) ProtoReflect() protoreflect.Message

func (*StopReplicationMinimumResponse) Reset 

func (x *StopReplicationMinimumResponse) Reset()

func (*StopReplicationMinimumResponse) SetPosition 

func (x *StopReplicationMinimumResponse) SetPosition(v string)

func (*StopReplicationMinimumResponse) String 

func (x *StopReplicationMinimumResponse) String() string

type StopReplicationMinimumResponse_builder 

type StopReplicationMinimumResponse_builder struct {
	Position string
	// contains filtered or unexported fields
}

func (StopReplicationMinimumResponse_builder) Build 

func (b0 StopReplicationMinimumResponse_builder) Build() *StopReplicationMinimumResponse

type StopReplicationRequest 

type StopReplicationRequest struct {
	// contains filtered or unexported fields
}

func (*StopReplicationRequest) ProtoMessage 

func (*StopReplicationRequest) ProtoMessage()

func (*StopReplicationRequest) ProtoReflect 

func (x *StopReplicationRequest) ProtoReflect() protoreflect.Message

func (*StopReplicationRequest) Reset 

func (x *StopReplicationRequest) Reset()

func (*StopReplicationRequest) String 

func (x *StopReplicationRequest) String() string

type StopReplicationRequest_builder 

type StopReplicationRequest_builder struct {
	// contains filtered or unexported fields
}

func (StopReplicationRequest_builder) Build 

func (b0 StopReplicationRequest_builder) Build() *StopReplicationRequest

type StopReplicationResponse 

type StopReplicationResponse struct {
	// contains filtered or unexported fields
}

func (*StopReplicationResponse) ProtoMessage 

func (*StopReplicationResponse) ProtoMessage()

func (*StopReplicationResponse) ProtoReflect 

func (x *StopReplicationResponse) ProtoReflect() protoreflect.Message

func (*StopReplicationResponse) Reset 

func (x *StopReplicationResponse) Reset()

func (*StopReplicationResponse) String 

func (x *StopReplicationResponse) String() string

type StopReplicationResponse_builder 

type StopReplicationResponse_builder struct {
	// contains filtered or unexported fields
}

func (StopReplicationResponse_builder) Build 

func (b0 StopReplicationResponse_builder) Build() *StopReplicationResponse

type TableDefinition 

type TableDefinition struct {

	// the table name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// the SQL to run to create the table
	Schema string `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// the columns in the order that will be used to dump and load the data
	Columns []string `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"`
	// the primary key columns in the primary key order
	PrimaryKeyColumns []string `protobuf:"bytes,4,rep,name=primary_key_columns,json=primaryKeyColumns,proto3" json:"primary_key_columns,omitempty"`
	// type is either mysqlctl.TableBaseTable or mysqlctl.TableView
	Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	// how much space the data file takes.
	DataLength uint64 `protobuf:"varint,6,opt,name=data_length,json=dataLength,proto3" json:"data_length,omitempty"`
	// approximate number of rows
	RowCount uint64 `protobuf:"varint,7,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	// column names along with their types.
	// NOTE: this is a superset of columns.
	Fields []*dev.Field `protobuf:"bytes,8,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*TableDefinition) GetColumns 

func (x *TableDefinition) GetColumns() []string

func (*TableDefinition) GetDataLength 

func (x *TableDefinition) GetDataLength() uint64

func (*TableDefinition) GetFields 

func (x *TableDefinition) GetFields() []*dev.Field

func (*TableDefinition) GetName 

func (x *TableDefinition) GetName() string

func (*TableDefinition) GetPrimaryKeyColumns 

func (x *TableDefinition) GetPrimaryKeyColumns() []string

func (*TableDefinition) GetRowCount 

func (x *TableDefinition) GetRowCount() uint64

func (*TableDefinition) GetSchema 

func (x *TableDefinition) GetSchema() string

func (*TableDefinition) GetType 

func (x *TableDefinition) GetType() string

func (*TableDefinition) ProtoMessage 

func (*TableDefinition) ProtoMessage()

func (*TableDefinition) ProtoReflect 

func (x *TableDefinition) ProtoReflect() protoreflect.Message

func (*TableDefinition) Reset 

func (x *TableDefinition) Reset()

func (*TableDefinition) SetColumns 

func (x *TableDefinition) SetColumns(v []string)

func (*TableDefinition) SetDataLength 

func (x *TableDefinition) SetDataLength(v uint64)

func (*TableDefinition) SetFields 

func (x *TableDefinition) SetFields(v []*dev.Field)

func (*TableDefinition) SetName 

func (x *TableDefinition) SetName(v string)

func (*TableDefinition) SetPrimaryKeyColumns 

func (x *TableDefinition) SetPrimaryKeyColumns(v []string)

func (*TableDefinition) SetRowCount 

func (x *TableDefinition) SetRowCount(v uint64)

func (*TableDefinition) SetSchema 

func (x *TableDefinition) SetSchema(v string)

func (*TableDefinition) SetType 

func (x *TableDefinition) SetType(v string)

func (*TableDefinition) String 

func (x *TableDefinition) String() string

type TableDefinition_builder 

type TableDefinition_builder struct {

	// the table name
	Name string
	// the SQL to run to create the table
	Schema string
	// the columns in the order that will be used to dump and load the data
	Columns []string
	// the primary key columns in the primary key order
	PrimaryKeyColumns []string
	// type is either mysqlctl.TableBaseTable or mysqlctl.TableView
	Type string
	// how much space the data file takes.
	DataLength uint64
	// approximate number of rows
	RowCount uint64
	// column names along with their types.
	// NOTE: this is a superset of columns.
	Fields []*dev.Field
	// contains filtered or unexported fields
}

func (TableDefinition_builder) Build 

func (b0 TableDefinition_builder) Build() *TableDefinition

type TabletSelectionPreference 

type TabletSelectionPreference int32

This structure allows us to manage tablet selection preferences which are eventually passed to a TabletPicker. 

const (
	TabletSelectionPreference_ANY     TabletSelectionPreference = 0
	TabletSelectionPreference_INORDER TabletSelectionPreference = 1
	TabletSelectionPreference_UNKNOWN TabletSelectionPreference = 3 // Don't change any existing value
)

func (TabletSelectionPreference) Descriptor 

func (TabletSelectionPreference) Descriptor() protoreflect.EnumDescriptor

func (TabletSelectionPreference) Enum 

func (x TabletSelectionPreference) Enum() *TabletSelectionPreference

func (TabletSelectionPreference) Number 

func (x TabletSelectionPreference) Number() protoreflect.EnumNumber

func (TabletSelectionPreference) String 

func (x TabletSelectionPreference) String() string

func (TabletSelectionPreference) Type 

func (TabletSelectionPreference) Type() protoreflect.EnumType

type UndoDemotePrimaryRequest 

type UndoDemotePrimaryRequest struct {
	SemiSync bool `protobuf:"varint,1,opt,name=semiSync,proto3" json:"semiSync,omitempty"`
	// contains filtered or unexported fields
}

func (*UndoDemotePrimaryRequest) GetSemiSync 

func (x *UndoDemotePrimaryRequest) GetSemiSync() bool

func (*UndoDemotePrimaryRequest) ProtoMessage 

func (*UndoDemotePrimaryRequest) ProtoMessage()

func (*UndoDemotePrimaryRequest) ProtoReflect 

func (x *UndoDemotePrimaryRequest) ProtoReflect() protoreflect.Message

func (*UndoDemotePrimaryRequest) Reset 

func (x *UndoDemotePrimaryRequest) Reset()

func (*UndoDemotePrimaryRequest) SetSemiSync 

func (x *UndoDemotePrimaryRequest) SetSemiSync(v bool)

func (*UndoDemotePrimaryRequest) String 

func (x *UndoDemotePrimaryRequest) String() string

type UndoDemotePrimaryRequest_builder 

type UndoDemotePrimaryRequest_builder struct {
	SemiSync bool
	// contains filtered or unexported fields
}

func (UndoDemotePrimaryRequest_builder) Build 

func (b0 UndoDemotePrimaryRequest_builder) Build() *UndoDemotePrimaryRequest

type UndoDemotePrimaryResponse 

type UndoDemotePrimaryResponse struct {
	// contains filtered or unexported fields
}

func (*UndoDemotePrimaryResponse) ProtoMessage 

func (*UndoDemotePrimaryResponse) ProtoMessage()

func (*UndoDemotePrimaryResponse) ProtoReflect 

func (x *UndoDemotePrimaryResponse) ProtoReflect() protoreflect.Message

func (*UndoDemotePrimaryResponse) Reset 

func (x *UndoDemotePrimaryResponse) Reset()

func (*UndoDemotePrimaryResponse) String 

func (x *UndoDemotePrimaryResponse) String() string

type UndoDemotePrimaryResponse_builder 

type UndoDemotePrimaryResponse_builder struct {
	// contains filtered or unexported fields
}

func (UndoDemotePrimaryResponse_builder) Build 

func (b0 UndoDemotePrimaryResponse_builder) Build() *UndoDemotePrimaryResponse

type UnlockTablesRequest 

type UnlockTablesRequest struct {
	// contains filtered or unexported fields
}

func (*UnlockTablesRequest) ProtoMessage 

func (*UnlockTablesRequest) ProtoMessage()

func (*UnlockTablesRequest) ProtoReflect 

func (x *UnlockTablesRequest) ProtoReflect() protoreflect.Message

func (*UnlockTablesRequest) Reset 

func (x *UnlockTablesRequest) Reset()

func (*UnlockTablesRequest) String 

func (x *UnlockTablesRequest) String() string

type UnlockTablesRequest_builder 

type UnlockTablesRequest_builder struct {
	// contains filtered or unexported fields
}

func (UnlockTablesRequest_builder) Build 

func (b0 UnlockTablesRequest_builder) Build() *UnlockTablesRequest

type UnlockTablesResponse 

type UnlockTablesResponse struct {
	// contains filtered or unexported fields
}

func (*UnlockTablesResponse) ProtoMessage 

func (*UnlockTablesResponse) ProtoMessage()

func (*UnlockTablesResponse) ProtoReflect 

func (x *UnlockTablesResponse) ProtoReflect() protoreflect.Message

func (*UnlockTablesResponse) Reset 

func (x *UnlockTablesResponse) Reset()

func (*UnlockTablesResponse) String 

func (x *UnlockTablesResponse) String() string

type UnlockTablesResponse_builder 

type UnlockTablesResponse_builder struct {
	// contains filtered or unexported fields
}

func (UnlockTablesResponse_builder) Build 

func (b0 UnlockTablesResponse_builder) Build() *UnlockTablesResponse

type UpdateSequenceTablesRequest 

type UpdateSequenceTablesRequest struct {
	Sequences []*UpdateSequenceTablesRequest_SequenceMetadata `protobuf:"bytes,1,rep,name=sequences,proto3" json:"sequences,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSequenceTablesRequest) GetSequences 

func (x *UpdateSequenceTablesRequest) GetSequences() []*UpdateSequenceTablesRequest_SequenceMetadata

func (*UpdateSequenceTablesRequest) ProtoMessage 

func (*UpdateSequenceTablesRequest) ProtoMessage()

func (*UpdateSequenceTablesRequest) ProtoReflect 

func (x *UpdateSequenceTablesRequest) ProtoReflect() protoreflect.Message

func (*UpdateSequenceTablesRequest) Reset 

func (x *UpdateSequenceTablesRequest) Reset()

func (*UpdateSequenceTablesRequest) SetSequences 

func (x *UpdateSequenceTablesRequest) SetSequences(v []*UpdateSequenceTablesRequest_SequenceMetadata)

func (*UpdateSequenceTablesRequest) String 

func (x *UpdateSequenceTablesRequest) String() string

type UpdateSequenceTablesRequest_SequenceMetadata 

type UpdateSequenceTablesRequest_SequenceMetadata struct {

	// The name of the sequence table.
	BackingTableName string `protobuf:"bytes,1,opt,name=backing_table_name,json=backingTableName,proto3" json:"backing_table_name,omitempty"`
	// The dbName in use by the keyspace where the backing table lives.
	BackingTableDbName string `protobuf:"bytes,2,opt,name=backing_table_db_name,json=backingTableDbName,proto3" json:"backing_table_db_name,omitempty"`
	// The maximum used sequence value.
	MaxValue int64 `protobuf:"varint,3,opt,name=max_value,json=maxValue,proto3" json:"max_value,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSequenceTablesRequest_SequenceMetadata) GetBackingTableDbName 

func (x *UpdateSequenceTablesRequest_SequenceMetadata) GetBackingTableDbName() string

func (*UpdateSequenceTablesRequest_SequenceMetadata) GetBackingTableName 

func (x *UpdateSequenceTablesRequest_SequenceMetadata) GetBackingTableName() string

func (*UpdateSequenceTablesRequest_SequenceMetadata) GetMaxValue 

func (x *UpdateSequenceTablesRequest_SequenceMetadata) GetMaxValue() int64

func (*UpdateSequenceTablesRequest_SequenceMetadata) ProtoMessage 

func (*UpdateSequenceTablesRequest_SequenceMetadata) ProtoMessage()

func (*UpdateSequenceTablesRequest_SequenceMetadata) ProtoReflect 

func (x *UpdateSequenceTablesRequest_SequenceMetadata) ProtoReflect() protoreflect.Message

func (*UpdateSequenceTablesRequest_SequenceMetadata) Reset 

func (x *UpdateSequenceTablesRequest_SequenceMetadata) Reset()

func (*UpdateSequenceTablesRequest_SequenceMetadata) SetBackingTableDbName 

func (x *UpdateSequenceTablesRequest_SequenceMetadata) SetBackingTableDbName(v string)

func (*UpdateSequenceTablesRequest_SequenceMetadata) SetBackingTableName 

func (x *UpdateSequenceTablesRequest_SequenceMetadata) SetBackingTableName(v string)

func (*UpdateSequenceTablesRequest_SequenceMetadata) SetMaxValue 

func (x *UpdateSequenceTablesRequest_SequenceMetadata) SetMaxValue(v int64)

func (*UpdateSequenceTablesRequest_SequenceMetadata) String 

func (x *UpdateSequenceTablesRequest_SequenceMetadata) String() string

type UpdateSequenceTablesRequest_SequenceMetadata_builder 

type UpdateSequenceTablesRequest_SequenceMetadata_builder struct {

	// The name of the sequence table.
	BackingTableName string
	// The dbName in use by the keyspace where the backing table lives.
	BackingTableDbName string
	// The maximum used sequence value.
	MaxValue int64
	// contains filtered or unexported fields
}

func (UpdateSequenceTablesRequest_SequenceMetadata_builder) Build 

func (b0 UpdateSequenceTablesRequest_SequenceMetadata_builder) Build() *UpdateSequenceTablesRequest_SequenceMetadata

type UpdateSequenceTablesRequest_builder 

type UpdateSequenceTablesRequest_builder struct {
	Sequences []*UpdateSequenceTablesRequest_SequenceMetadata
	// contains filtered or unexported fields
}

func (UpdateSequenceTablesRequest_builder) Build 

func (b0 UpdateSequenceTablesRequest_builder) Build() *UpdateSequenceTablesRequest

type UpdateSequenceTablesResponse 

type UpdateSequenceTablesResponse struct {
	// contains filtered or unexported fields
}

func (*UpdateSequenceTablesResponse) ProtoMessage 

func (*UpdateSequenceTablesResponse) ProtoMessage()

func (*UpdateSequenceTablesResponse) ProtoReflect 

func (x *UpdateSequenceTablesResponse) ProtoReflect() protoreflect.Message

func (*UpdateSequenceTablesResponse) Reset 

func (x *UpdateSequenceTablesResponse) Reset()

func (*UpdateSequenceTablesResponse) String 

func (x *UpdateSequenceTablesResponse) String() string

type UpdateSequenceTablesResponse_builder 

type UpdateSequenceTablesResponse_builder struct {
	// contains filtered or unexported fields
}

func (UpdateSequenceTablesResponse_builder) Build 

func (b0 UpdateSequenceTablesResponse_builder) Build() *UpdateSequenceTablesResponse

type UpdateVReplicationWorkflowRequest 

type UpdateVReplicationWorkflowRequest struct {
	Workflow                  string                          `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	Cells                     []string                        `protobuf:"bytes,2,rep,name=cells,proto3" json:"cells,omitempty"`
	TabletTypes               []dev1.TabletType               `` /* 138-byte string literal not displayed */
	TabletSelectionPreference *TabletSelectionPreference      `` /* 205-byte string literal not displayed */
	OnDdl                     *dev7.OnDDLAction               `protobuf:"varint,5,opt,name=on_ddl,json=onDdl,proto3,enum=vitess.binlogdata.dev.OnDDLAction,oneof" json:"on_ddl,omitempty"`
	State                     *dev7.VReplicationWorkflowState `protobuf:"varint,6,opt,name=state,proto3,enum=vitess.binlogdata.dev.VReplicationWorkflowState,oneof" json:"state,omitempty"`
	Shards                    []string                        `protobuf:"bytes,7,rep,name=shards,proto3" json:"shards,omitempty"`
	ConfigOverrides           map[string]string               `` /* 180-byte string literal not displayed */
	Message                   *string                         `protobuf:"bytes,9,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// Specify filter rules which need to be appended in the existing binlogsource filter rules.
	FilterRules []*dev7.Rule `protobuf:"bytes,10,rep,name=filter_rules,json=filterRules,proto3" json:"filter_rules,omitempty"`
	// contains filtered or unexported fields
}

UpdateVReplicationWorkflowRequest is used to update an existing VReplication workflow. Note that the following fields MUST have an explicit value provided if you do NOT wish to update the existing value to the given type's ZeroValue: cells, tablet_types, on_ddl, and state. TODO: leverage the optional modifier for these fields rather than using SimulatedNull values: https://github.com/vitessio/vitess/issues/15627

func (*UpdateVReplicationWorkflowRequest) ClearMessage 

func (x *UpdateVReplicationWorkflowRequest) ClearMessage()

func (*UpdateVReplicationWorkflowRequest) ClearOnDdl 

func (x *UpdateVReplicationWorkflowRequest) ClearOnDdl()

func (*UpdateVReplicationWorkflowRequest) ClearState 

func (x *UpdateVReplicationWorkflowRequest) ClearState()

func (*UpdateVReplicationWorkflowRequest) ClearTabletSelectionPreference 

func (x *UpdateVReplicationWorkflowRequest) ClearTabletSelectionPreference()

func (*UpdateVReplicationWorkflowRequest) GetCells 

func (x *UpdateVReplicationWorkflowRequest) GetCells() []string

func (*UpdateVReplicationWorkflowRequest) GetConfigOverrides 

func (x *UpdateVReplicationWorkflowRequest) GetConfigOverrides() map[string]string

func (*UpdateVReplicationWorkflowRequest) GetFilterRules 

func (x *UpdateVReplicationWorkflowRequest) GetFilterRules() []*dev7.Rule

func (*UpdateVReplicationWorkflowRequest) GetMessage 

func (x *UpdateVReplicationWorkflowRequest) GetMessage() string

func (*UpdateVReplicationWorkflowRequest) GetOnDdl 

func (x *UpdateVReplicationWorkflowRequest) GetOnDdl() dev7.OnDDLAction

func (*UpdateVReplicationWorkflowRequest) GetShards 

func (x *UpdateVReplicationWorkflowRequest) GetShards() []string

func (*UpdateVReplicationWorkflowRequest) GetState 

func (x *UpdateVReplicationWorkflowRequest) GetState() dev7.VReplicationWorkflowState

func (*UpdateVReplicationWorkflowRequest) GetTabletSelectionPreference 

func (x *UpdateVReplicationWorkflowRequest) GetTabletSelectionPreference() TabletSelectionPreference

func (*UpdateVReplicationWorkflowRequest) GetTabletTypes 

func (x *UpdateVReplicationWorkflowRequest) GetTabletTypes() []dev1.TabletType

func (*UpdateVReplicationWorkflowRequest) GetWorkflow 

func (x *UpdateVReplicationWorkflowRequest) GetWorkflow() string

func (*UpdateVReplicationWorkflowRequest) HasMessage 

func (x *UpdateVReplicationWorkflowRequest) HasMessage() bool

func (*UpdateVReplicationWorkflowRequest) HasOnDdl 

func (x *UpdateVReplicationWorkflowRequest) HasOnDdl() bool

func (*UpdateVReplicationWorkflowRequest) HasState 

func (x *UpdateVReplicationWorkflowRequest) HasState() bool

func (*UpdateVReplicationWorkflowRequest) HasTabletSelectionPreference 

func (x *UpdateVReplicationWorkflowRequest) HasTabletSelectionPreference() bool

func (*UpdateVReplicationWorkflowRequest) ProtoMessage 

func (*UpdateVReplicationWorkflowRequest) ProtoMessage()

func (*UpdateVReplicationWorkflowRequest) ProtoReflect 

func (x *UpdateVReplicationWorkflowRequest) ProtoReflect() protoreflect.Message

func (*UpdateVReplicationWorkflowRequest) Reset 

func (x *UpdateVReplicationWorkflowRequest) Reset()

func (*UpdateVReplicationWorkflowRequest) SetCells 

func (x *UpdateVReplicationWorkflowRequest) SetCells(v []string)

func (*UpdateVReplicationWorkflowRequest) SetConfigOverrides 

func (x *UpdateVReplicationWorkflowRequest) SetConfigOverrides(v map[string]string)

func (*UpdateVReplicationWorkflowRequest) SetFilterRules 

func (x *UpdateVReplicationWorkflowRequest) SetFilterRules(v []*dev7.Rule)

func (*UpdateVReplicationWorkflowRequest) SetMessage 

func (x *UpdateVReplicationWorkflowRequest) SetMessage(v string)

func (*UpdateVReplicationWorkflowRequest) SetOnDdl 

func (x *UpdateVReplicationWorkflowRequest) SetOnDdl(v dev7.OnDDLAction)

func (*UpdateVReplicationWorkflowRequest) SetShards 

func (x *UpdateVReplicationWorkflowRequest) SetShards(v []string)

func (*UpdateVReplicationWorkflowRequest) SetState 

func (x *UpdateVReplicationWorkflowRequest) SetState(v dev7.VReplicationWorkflowState)

func (*UpdateVReplicationWorkflowRequest) SetTabletSelectionPreference 

func (x *UpdateVReplicationWorkflowRequest) SetTabletSelectionPreference(v TabletSelectionPreference)

func (*UpdateVReplicationWorkflowRequest) SetTabletTypes 

func (x *UpdateVReplicationWorkflowRequest) SetTabletTypes(v []dev1.TabletType)

func (*UpdateVReplicationWorkflowRequest) SetWorkflow 

func (x *UpdateVReplicationWorkflowRequest) SetWorkflow(v string)

func (*UpdateVReplicationWorkflowRequest) String 

func (x *UpdateVReplicationWorkflowRequest) String() string

type UpdateVReplicationWorkflowRequest_builder 

type UpdateVReplicationWorkflowRequest_builder struct {
	Workflow                  string
	Cells                     []string
	TabletTypes               []dev1.TabletType
	TabletSelectionPreference *TabletSelectionPreference
	OnDdl                     *dev7.OnDDLAction
	State                     *dev7.VReplicationWorkflowState
	Shards                    []string
	ConfigOverrides           map[string]string
	Message                   *string
	// Specify filter rules which need to be appended in the existing binlogsource filter rules.
	FilterRules []*dev7.Rule
	// contains filtered or unexported fields
}

func (UpdateVReplicationWorkflowRequest_builder) Build 

func (b0 UpdateVReplicationWorkflowRequest_builder) Build() *UpdateVReplicationWorkflowRequest

type UpdateVReplicationWorkflowResponse 

type UpdateVReplicationWorkflowResponse struct {
	Result *dev.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateVReplicationWorkflowResponse) ClearResult 

func (x *UpdateVReplicationWorkflowResponse) ClearResult()

func (*UpdateVReplicationWorkflowResponse) GetResult 

func (x *UpdateVReplicationWorkflowResponse) GetResult() *dev.QueryResult

func (*UpdateVReplicationWorkflowResponse) HasResult 

func (x *UpdateVReplicationWorkflowResponse) HasResult() bool

func (*UpdateVReplicationWorkflowResponse) ProtoMessage 

func (*UpdateVReplicationWorkflowResponse) ProtoMessage()

func (*UpdateVReplicationWorkflowResponse) ProtoReflect 

func (x *UpdateVReplicationWorkflowResponse) ProtoReflect() protoreflect.Message

func (*UpdateVReplicationWorkflowResponse) Reset 

func (x *UpdateVReplicationWorkflowResponse) Reset()

func (*UpdateVReplicationWorkflowResponse) SetResult 

func (x *UpdateVReplicationWorkflowResponse) SetResult(v *dev.QueryResult)

func (*UpdateVReplicationWorkflowResponse) String 

func (x *UpdateVReplicationWorkflowResponse) String() string

type UpdateVReplicationWorkflowResponse_builder 

type UpdateVReplicationWorkflowResponse_builder struct {
	Result *dev.QueryResult
	// contains filtered or unexported fields
}

func (UpdateVReplicationWorkflowResponse_builder) Build 

func (b0 UpdateVReplicationWorkflowResponse_builder) Build() *UpdateVReplicationWorkflowResponse

type UpdateVReplicationWorkflowsRequest 

type UpdateVReplicationWorkflowsRequest struct {
	AllWorkflows     bool                            `protobuf:"varint,1,opt,name=all_workflows,json=allWorkflows,proto3" json:"all_workflows,omitempty"`
	IncludeWorkflows []string                        `protobuf:"bytes,2,rep,name=include_workflows,json=includeWorkflows,proto3" json:"include_workflows,omitempty"`
	ExcludeWorkflows []string                        `protobuf:"bytes,3,rep,name=exclude_workflows,json=excludeWorkflows,proto3" json:"exclude_workflows,omitempty"`
	State            *dev7.VReplicationWorkflowState `protobuf:"varint,4,opt,name=state,proto3,enum=vitess.binlogdata.dev.VReplicationWorkflowState,oneof" json:"state,omitempty"`
	Message          *string                         `protobuf:"bytes,5,opt,name=message,proto3,oneof" json:"message,omitempty"`
	StopPosition     *string                         `protobuf:"bytes,6,opt,name=stop_position,json=stopPosition,proto3,oneof" json:"stop_position,omitempty"`
	// contains filtered or unexported fields
}

UpdateVReplicationWorkflowsRequest is used to update multiple existing VReplication workflows. Note that the following fields MUST have an explicit value provided if you do NOT wish to update the existing values to the given type's ZeroValue: state, message, and stop_position. TODO: leverage the optional modifier for these fields rather than using SimulatedNull values: https://github.com/vitessio/vitess/issues/15627

func (*UpdateVReplicationWorkflowsRequest) ClearMessage 

func (x *UpdateVReplicationWorkflowsRequest) ClearMessage()

func (*UpdateVReplicationWorkflowsRequest) ClearState 

func (x *UpdateVReplicationWorkflowsRequest) ClearState()

func (*UpdateVReplicationWorkflowsRequest) ClearStopPosition 

func (x *UpdateVReplicationWorkflowsRequest) ClearStopPosition()

func (*UpdateVReplicationWorkflowsRequest) GetAllWorkflows 

func (x *UpdateVReplicationWorkflowsRequest) GetAllWorkflows() bool

func (*UpdateVReplicationWorkflowsRequest) GetExcludeWorkflows 

func (x *UpdateVReplicationWorkflowsRequest) GetExcludeWorkflows() []string

func (*UpdateVReplicationWorkflowsRequest) GetIncludeWorkflows 

func (x *UpdateVReplicationWorkflowsRequest) GetIncludeWorkflows() []string

func (*UpdateVReplicationWorkflowsRequest) GetMessage 

func (x *UpdateVReplicationWorkflowsRequest) GetMessage() string

func (*UpdateVReplicationWorkflowsRequest) GetState 

func (x *UpdateVReplicationWorkflowsRequest) GetState() dev7.VReplicationWorkflowState

func (*UpdateVReplicationWorkflowsRequest) GetStopPosition 

func (x *UpdateVReplicationWorkflowsRequest) GetStopPosition() string

func (*UpdateVReplicationWorkflowsRequest) HasMessage 

func (x *UpdateVReplicationWorkflowsRequest) HasMessage() bool

func (*UpdateVReplicationWorkflowsRequest) HasState 

func (x *UpdateVReplicationWorkflowsRequest) HasState() bool

func (*UpdateVReplicationWorkflowsRequest) HasStopPosition 

func (x *UpdateVReplicationWorkflowsRequest) HasStopPosition() bool

func (*UpdateVReplicationWorkflowsRequest) ProtoMessage 

func (*UpdateVReplicationWorkflowsRequest) ProtoMessage()

func (*UpdateVReplicationWorkflowsRequest) ProtoReflect 

func (x *UpdateVReplicationWorkflowsRequest) ProtoReflect() protoreflect.Message

func (*UpdateVReplicationWorkflowsRequest) Reset 

func (x *UpdateVReplicationWorkflowsRequest) Reset()

func (*UpdateVReplicationWorkflowsRequest) SetAllWorkflows 

func (x *UpdateVReplicationWorkflowsRequest) SetAllWorkflows(v bool)

func (*UpdateVReplicationWorkflowsRequest) SetExcludeWorkflows 

func (x *UpdateVReplicationWorkflowsRequest) SetExcludeWorkflows(v []string)

func (*UpdateVReplicationWorkflowsRequest) SetIncludeWorkflows 

func (x *UpdateVReplicationWorkflowsRequest) SetIncludeWorkflows(v []string)

func (*UpdateVReplicationWorkflowsRequest) SetMessage 

func (x *UpdateVReplicationWorkflowsRequest) SetMessage(v string)

func (*UpdateVReplicationWorkflowsRequest) SetState 

func (x *UpdateVReplicationWorkflowsRequest) SetState(v dev7.VReplicationWorkflowState)

func (*UpdateVReplicationWorkflowsRequest) SetStopPosition 

func (x *UpdateVReplicationWorkflowsRequest) SetStopPosition(v string)

func (*UpdateVReplicationWorkflowsRequest) String 

func (x *UpdateVReplicationWorkflowsRequest) String() string

type UpdateVReplicationWorkflowsRequest_builder 

type UpdateVReplicationWorkflowsRequest_builder struct {
	AllWorkflows     bool
	IncludeWorkflows []string
	ExcludeWorkflows []string
	State            *dev7.VReplicationWorkflowState
	Message          *string
	StopPosition     *string
	// contains filtered or unexported fields
}

func (UpdateVReplicationWorkflowsRequest_builder) Build 

func (b0 UpdateVReplicationWorkflowsRequest_builder) Build() *UpdateVReplicationWorkflowsRequest

type UpdateVReplicationWorkflowsResponse 

type UpdateVReplicationWorkflowsResponse struct {
	Result *dev.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateVReplicationWorkflowsResponse) ClearResult 

func (x *UpdateVReplicationWorkflowsResponse) ClearResult()

func (*UpdateVReplicationWorkflowsResponse) GetResult 

func (x *UpdateVReplicationWorkflowsResponse) GetResult() *dev.QueryResult

func (*UpdateVReplicationWorkflowsResponse) HasResult 

func (x *UpdateVReplicationWorkflowsResponse) HasResult() bool

func (*UpdateVReplicationWorkflowsResponse) ProtoMessage 

func (*UpdateVReplicationWorkflowsResponse) ProtoMessage()

func (*UpdateVReplicationWorkflowsResponse) ProtoReflect 

func (x *UpdateVReplicationWorkflowsResponse) ProtoReflect() protoreflect.Message

func (*UpdateVReplicationWorkflowsResponse) Reset 

func (x *UpdateVReplicationWorkflowsResponse) Reset()

func (*UpdateVReplicationWorkflowsResponse) SetResult 

func (x *UpdateVReplicationWorkflowsResponse) SetResult(v *dev.QueryResult)

func (*UpdateVReplicationWorkflowsResponse) String 

func (x *UpdateVReplicationWorkflowsResponse) String() string

type UpdateVReplicationWorkflowsResponse_builder 

type UpdateVReplicationWorkflowsResponse_builder struct {
	Result *dev.QueryResult
	// contains filtered or unexported fields
}

func (UpdateVReplicationWorkflowsResponse_builder) Build 

func (b0 UpdateVReplicationWorkflowsResponse_builder) Build() *UpdateVReplicationWorkflowsResponse

type UserPermission 

type UserPermission struct {
	Host             string            `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	User             string            `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	PasswordChecksum uint64            `protobuf:"varint,3,opt,name=password_checksum,json=passwordChecksum,proto3" json:"password_checksum,omitempty"`
	Privileges       map[string]string `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

UserPermission describes a single row in the mysql.user table Primary key is Host+User PasswordChecksum is the crc64 of the password, for security reasons

func (*UserPermission) GetHost 

func (x *UserPermission) GetHost() string

func (*UserPermission) GetPasswordChecksum 

func (x *UserPermission) GetPasswordChecksum() uint64

func (*UserPermission) GetPrivileges 

func (x *UserPermission) GetPrivileges() map[string]string

func (*UserPermission) GetUser 

func (x *UserPermission) GetUser() string

func (*UserPermission) ProtoMessage 

func (*UserPermission) ProtoMessage()

func (*UserPermission) ProtoReflect 

func (x *UserPermission) ProtoReflect() protoreflect.Message

func (*UserPermission) Reset 

func (x *UserPermission) Reset()

func (*UserPermission) SetHost 

func (x *UserPermission) SetHost(v string)

func (*UserPermission) SetPasswordChecksum 

func (x *UserPermission) SetPasswordChecksum(v uint64)

func (*UserPermission) SetPrivileges 

func (x *UserPermission) SetPrivileges(v map[string]string)

func (*UserPermission) SetUser 

func (x *UserPermission) SetUser(v string)

func (*UserPermission) String 

func (x *UserPermission) String() string

type UserPermission_builder 

type UserPermission_builder struct {
	Host             string
	User             string
	PasswordChecksum uint64
	Privileges       map[string]string
	// contains filtered or unexported fields
}

func (UserPermission_builder) Build 

func (b0 UserPermission_builder) Build() *UserPermission

type VDiffCoreOptions 

type VDiffCoreOptions struct {
	Tables                string `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"`
	AutoRetry             bool   `protobuf:"varint,2,opt,name=auto_retry,json=autoRetry,proto3" json:"auto_retry,omitempty"`
	MaxRows               int64  `protobuf:"varint,3,opt,name=max_rows,json=maxRows,proto3" json:"max_rows,omitempty"`
	Checksum              bool   `protobuf:"varint,4,opt,name=checksum,proto3" json:"checksum,omitempty"`
	SamplePct             int64  `protobuf:"varint,5,opt,name=sample_pct,json=samplePct,proto3" json:"sample_pct,omitempty"`
	TimeoutSeconds        int64  `protobuf:"varint,6,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	MaxExtraRowsToCompare int64  `` /* 131-byte string literal not displayed */
	UpdateTableStats      bool   `protobuf:"varint,8,opt,name=update_table_stats,json=updateTableStats,proto3" json:"update_table_stats,omitempty"`
	MaxDiffSeconds        int64  `protobuf:"varint,9,opt,name=max_diff_seconds,json=maxDiffSeconds,proto3" json:"max_diff_seconds,omitempty"`
	AutoStart             *bool  `protobuf:"varint,10,opt,name=auto_start,json=autoStart,proto3,oneof" json:"auto_start,omitempty"`
	// contains filtered or unexported fields
}

func (*VDiffCoreOptions) ClearAutoStart 

func (x *VDiffCoreOptions) ClearAutoStart()

func (*VDiffCoreOptions) GetAutoRetry 

func (x *VDiffCoreOptions) GetAutoRetry() bool

func (*VDiffCoreOptions) GetAutoStart 

func (x *VDiffCoreOptions) GetAutoStart() bool

func (*VDiffCoreOptions) GetChecksum 

func (x *VDiffCoreOptions) GetChecksum() bool

func (*VDiffCoreOptions) GetMaxDiffSeconds 

func (x *VDiffCoreOptions) GetMaxDiffSeconds() int64

func (*VDiffCoreOptions) GetMaxExtraRowsToCompare 

func (x *VDiffCoreOptions) GetMaxExtraRowsToCompare() int64

func (*VDiffCoreOptions) GetMaxRows 

func (x *VDiffCoreOptions) GetMaxRows() int64

func (*VDiffCoreOptions) GetSamplePct 

func (x *VDiffCoreOptions) GetSamplePct() int64

func (*VDiffCoreOptions) GetTables 

func (x *VDiffCoreOptions) GetTables() string

func (*VDiffCoreOptions) GetTimeoutSeconds 

func (x *VDiffCoreOptions) GetTimeoutSeconds() int64

func (*VDiffCoreOptions) GetUpdateTableStats 

func (x *VDiffCoreOptions) GetUpdateTableStats() bool

func (*VDiffCoreOptions) HasAutoStart 

func (x *VDiffCoreOptions) HasAutoStart() bool

func (*VDiffCoreOptions) ProtoMessage 

func (*VDiffCoreOptions) ProtoMessage()

func (*VDiffCoreOptions) ProtoReflect 

func (x *VDiffCoreOptions) ProtoReflect() protoreflect.Message

func (*VDiffCoreOptions) Reset 

func (x *VDiffCoreOptions) Reset()

func (*VDiffCoreOptions) SetAutoRetry 

func (x *VDiffCoreOptions) SetAutoRetry(v bool)

func (*VDiffCoreOptions) SetAutoStart 

func (x *VDiffCoreOptions) SetAutoStart(v bool)

func (*VDiffCoreOptions) SetChecksum 

func (x *VDiffCoreOptions) SetChecksum(v bool)

func (*VDiffCoreOptions) SetMaxDiffSeconds 

func (x *VDiffCoreOptions) SetMaxDiffSeconds(v int64)

func (*VDiffCoreOptions) SetMaxExtraRowsToCompare 

func (x *VDiffCoreOptions) SetMaxExtraRowsToCompare(v int64)

func (*VDiffCoreOptions) SetMaxRows 

func (x *VDiffCoreOptions) SetMaxRows(v int64)

func (*VDiffCoreOptions) SetSamplePct 

func (x *VDiffCoreOptions) SetSamplePct(v int64)

func (*VDiffCoreOptions) SetTables 

func (x *VDiffCoreOptions) SetTables(v string)

func (*VDiffCoreOptions) SetTimeoutSeconds 

func (x *VDiffCoreOptions) SetTimeoutSeconds(v int64)

func (*VDiffCoreOptions) SetUpdateTableStats 

func (x *VDiffCoreOptions) SetUpdateTableStats(v bool)

func (*VDiffCoreOptions) String 

func (x *VDiffCoreOptions) String() string

type VDiffCoreOptions_builder 

type VDiffCoreOptions_builder struct {
	Tables                string
	AutoRetry             bool
	MaxRows               int64
	Checksum              bool
	SamplePct             int64
	TimeoutSeconds        int64
	MaxExtraRowsToCompare int64
	UpdateTableStats      bool
	MaxDiffSeconds        int64
	AutoStart             *bool
	// contains filtered or unexported fields
}

func (VDiffCoreOptions_builder) Build 

func (b0 VDiffCoreOptions_builder) Build() *VDiffCoreOptions

type VDiffOptions 

type VDiffOptions struct {
	PickerOptions *VDiffPickerOptions `protobuf:"bytes,1,opt,name=picker_options,json=pickerOptions,proto3" json:"picker_options,omitempty"`
	CoreOptions   *VDiffCoreOptions   `protobuf:"bytes,2,opt,name=core_options,json=coreOptions,proto3" json:"core_options,omitempty"`
	ReportOptions *VDiffReportOptions `protobuf:"bytes,3,opt,name=report_options,json=reportOptions,proto3" json:"report_options,omitempty"`
	// contains filtered or unexported fields
}

func (*VDiffOptions) ClearCoreOptions 

func (x *VDiffOptions) ClearCoreOptions()

func (*VDiffOptions) ClearPickerOptions 

func (x *VDiffOptions) ClearPickerOptions()

func (*VDiffOptions) ClearReportOptions 

func (x *VDiffOptions) ClearReportOptions()

func (*VDiffOptions) GetCoreOptions 

func (x *VDiffOptions) GetCoreOptions() *VDiffCoreOptions

func (*VDiffOptions) GetPickerOptions 

func (x *VDiffOptions) GetPickerOptions() *VDiffPickerOptions

func (*VDiffOptions) GetReportOptions 

func (x *VDiffOptions) GetReportOptions() *VDiffReportOptions

func (*VDiffOptions) HasCoreOptions 

func (x *VDiffOptions) HasCoreOptions() bool

func (*VDiffOptions) HasPickerOptions 

func (x *VDiffOptions) HasPickerOptions() bool

func (*VDiffOptions) HasReportOptions 

func (x *VDiffOptions) HasReportOptions() bool

func (*VDiffOptions) ProtoMessage 

func (*VDiffOptions) ProtoMessage()

func (*VDiffOptions) ProtoReflect 

func (x *VDiffOptions) ProtoReflect() protoreflect.Message

func (*VDiffOptions) Reset 

func (x *VDiffOptions) Reset()

func (*VDiffOptions) SetCoreOptions 

func (x *VDiffOptions) SetCoreOptions(v *VDiffCoreOptions)

func (*VDiffOptions) SetPickerOptions 

func (x *VDiffOptions) SetPickerOptions(v *VDiffPickerOptions)

func (*VDiffOptions) SetReportOptions 

func (x *VDiffOptions) SetReportOptions(v *VDiffReportOptions)

func (*VDiffOptions) String 

func (x *VDiffOptions) String() string

type VDiffOptions_builder 

type VDiffOptions_builder struct {
	PickerOptions *VDiffPickerOptions
	CoreOptions   *VDiffCoreOptions
	ReportOptions *VDiffReportOptions
	// contains filtered or unexported fields
}

func (VDiffOptions_builder) Build 

func (b0 VDiffOptions_builder) Build() *VDiffOptions

type VDiffPickerOptions 

type VDiffPickerOptions struct {
	TabletTypes string `protobuf:"bytes,1,opt,name=tablet_types,json=tabletTypes,proto3" json:"tablet_types,omitempty"`
	SourceCell  string `protobuf:"bytes,2,opt,name=source_cell,json=sourceCell,proto3" json:"source_cell,omitempty"`
	TargetCell  string `protobuf:"bytes,3,opt,name=target_cell,json=targetCell,proto3" json:"target_cell,omitempty"`
	// contains filtered or unexported fields
}

options that influence the tablet selected by the picker for streaming data from

func (*VDiffPickerOptions) GetSourceCell 

func (x *VDiffPickerOptions) GetSourceCell() string

func (*VDiffPickerOptions) GetTabletTypes 

func (x *VDiffPickerOptions) GetTabletTypes() string

func (*VDiffPickerOptions) GetTargetCell 

func (x *VDiffPickerOptions) GetTargetCell() string

func (*VDiffPickerOptions) ProtoMessage 

func (*VDiffPickerOptions) ProtoMessage()

func (*VDiffPickerOptions) ProtoReflect 

func (x *VDiffPickerOptions) ProtoReflect() protoreflect.Message

func (*VDiffPickerOptions) Reset 

func (x *VDiffPickerOptions) Reset()

func (*VDiffPickerOptions) SetSourceCell 

func (x *VDiffPickerOptions) SetSourceCell(v string)

func (*VDiffPickerOptions) SetTabletTypes 

func (x *VDiffPickerOptions) SetTabletTypes(v string)

func (*VDiffPickerOptions) SetTargetCell 

func (x *VDiffPickerOptions) SetTargetCell(v string)

func (*VDiffPickerOptions) String 

func (x *VDiffPickerOptions) String() string

type VDiffPickerOptions_builder 

type VDiffPickerOptions_builder struct {
	TabletTypes string
	SourceCell  string
	TargetCell  string
	// contains filtered or unexported fields
}

func (VDiffPickerOptions_builder) Build 

func (b0 VDiffPickerOptions_builder) Build() *VDiffPickerOptions

type VDiffReportOptions 

type VDiffReportOptions struct {
	OnlyPks                 bool   `protobuf:"varint,1,opt,name=only_pks,json=onlyPks,proto3" json:"only_pks,omitempty"`
	DebugQuery              bool   `protobuf:"varint,2,opt,name=debug_query,json=debugQuery,proto3" json:"debug_query,omitempty"`
	Format                  string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	MaxSampleRows           int64  `protobuf:"varint,4,opt,name=max_sample_rows,json=maxSampleRows,proto3" json:"max_sample_rows,omitempty"`
	RowDiffColumnTruncateAt int64  `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

options that only influence how vdiff differences are reported

func (*VDiffReportOptions) GetDebugQuery 

func (x *VDiffReportOptions) GetDebugQuery() bool

func (*VDiffReportOptions) GetFormat 

func (x *VDiffReportOptions) GetFormat() string

func (*VDiffReportOptions) GetMaxSampleRows 

func (x *VDiffReportOptions) GetMaxSampleRows() int64

func (*VDiffReportOptions) GetOnlyPks 

func (x *VDiffReportOptions) GetOnlyPks() bool

func (*VDiffReportOptions) GetRowDiffColumnTruncateAt 

func (x *VDiffReportOptions) GetRowDiffColumnTruncateAt() int64

func (*VDiffReportOptions) ProtoMessage 

func (*VDiffReportOptions) ProtoMessage()

func (*VDiffReportOptions) ProtoReflect 

func (x *VDiffReportOptions) ProtoReflect() protoreflect.Message

func (*VDiffReportOptions) Reset 

func (x *VDiffReportOptions) Reset()

func (*VDiffReportOptions) SetDebugQuery 

func (x *VDiffReportOptions) SetDebugQuery(v bool)

func (*VDiffReportOptions) SetFormat 

func (x *VDiffReportOptions) SetFormat(v string)

func (*VDiffReportOptions) SetMaxSampleRows 

func (x *VDiffReportOptions) SetMaxSampleRows(v int64)

func (*VDiffReportOptions) SetOnlyPks 

func (x *VDiffReportOptions) SetOnlyPks(v bool)

func (*VDiffReportOptions) SetRowDiffColumnTruncateAt 

func (x *VDiffReportOptions) SetRowDiffColumnTruncateAt(v int64)

func (*VDiffReportOptions) String 

func (x *VDiffReportOptions) String() string

type VDiffReportOptions_builder 

type VDiffReportOptions_builder struct {
	OnlyPks                 bool
	DebugQuery              bool
	Format                  string
	MaxSampleRows           int64
	RowDiffColumnTruncateAt int64
	// contains filtered or unexported fields
}

func (VDiffReportOptions_builder) Build 

func (b0 VDiffReportOptions_builder) Build() *VDiffReportOptions

type VDiffRequest 

type VDiffRequest struct {
	Keyspace  string        `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Workflow  string        `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"`
	Action    string        `protobuf:"bytes,3,opt,name=action,proto3" json:"action,omitempty"`
	ActionArg string        `protobuf:"bytes,4,opt,name=action_arg,json=actionArg,proto3" json:"action_arg,omitempty"`
	VdiffUuid string        `protobuf:"bytes,5,opt,name=vdiff_uuid,json=vdiffUuid,proto3" json:"vdiff_uuid,omitempty"`
	Options   *VDiffOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*VDiffRequest) ClearOptions 

func (x *VDiffRequest) ClearOptions()

func (*VDiffRequest) GetAction 

func (x *VDiffRequest) GetAction() string

func (*VDiffRequest) GetActionArg 

func (x *VDiffRequest) GetActionArg() string

func (*VDiffRequest) GetKeyspace 

func (x *VDiffRequest) GetKeyspace() string

func (*VDiffRequest) GetOptions 

func (x *VDiffRequest) GetOptions() *VDiffOptions

func (*VDiffRequest) GetVdiffUuid 

func (x *VDiffRequest) GetVdiffUuid() string

func (*VDiffRequest) GetWorkflow 

func (x *VDiffRequest) GetWorkflow() string

func (*VDiffRequest) HasOptions 

func (x *VDiffRequest) HasOptions() bool

func (*VDiffRequest) ProtoMessage 

func (*VDiffRequest) ProtoMessage()

func (*VDiffRequest) ProtoReflect 

func (x *VDiffRequest) ProtoReflect() protoreflect.Message

func (*VDiffRequest) Reset 

func (x *VDiffRequest) Reset()

func (*VDiffRequest) SetAction 

func (x *VDiffRequest) SetAction(v string)

func (*VDiffRequest) SetActionArg 

func (x *VDiffRequest) SetActionArg(v string)

func (*VDiffRequest) SetKeyspace 

func (x *VDiffRequest) SetKeyspace(v string)

func (*VDiffRequest) SetOptions 

func (x *VDiffRequest) SetOptions(v *VDiffOptions)

func (*VDiffRequest) SetVdiffUuid 

func (x *VDiffRequest) SetVdiffUuid(v string)

func (*VDiffRequest) SetWorkflow 

func (x *VDiffRequest) SetWorkflow(v string)

func (*VDiffRequest) String 

func (x *VDiffRequest) String() string

type VDiffRequest_builder 

type VDiffRequest_builder struct {
	Keyspace  string
	Workflow  string
	Action    string
	ActionArg string
	VdiffUuid string
	Options   *VDiffOptions
	// contains filtered or unexported fields
}

func (VDiffRequest_builder) Build 

func (b0 VDiffRequest_builder) Build() *VDiffRequest

type VDiffResponse 

type VDiffResponse struct {
	Id        int64            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Output    *dev.QueryResult `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
	VdiffUuid string           `protobuf:"bytes,3,opt,name=vdiff_uuid,json=vdiffUuid,proto3" json:"vdiff_uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*VDiffResponse) ClearOutput 

func (x *VDiffResponse) ClearOutput()

func (*VDiffResponse) GetId 

func (x *VDiffResponse) GetId() int64

func (*VDiffResponse) GetOutput 

func (x *VDiffResponse) GetOutput() *dev.QueryResult

func (*VDiffResponse) GetVdiffUuid 

func (x *VDiffResponse) GetVdiffUuid() string

func (*VDiffResponse) HasOutput 

func (x *VDiffResponse) HasOutput() bool

func (*VDiffResponse) ProtoMessage 

func (*VDiffResponse) ProtoMessage()

func (*VDiffResponse) ProtoReflect 

func (x *VDiffResponse) ProtoReflect() protoreflect.Message

func (*VDiffResponse) Reset 

func (x *VDiffResponse) Reset()

func (*VDiffResponse) SetId 

func (x *VDiffResponse) SetId(v int64)

func (*VDiffResponse) SetOutput 

func (x *VDiffResponse) SetOutput(v *dev.QueryResult)

func (*VDiffResponse) SetVdiffUuid 

func (x *VDiffResponse) SetVdiffUuid(v string)

func (*VDiffResponse) String 

func (x *VDiffResponse) String() string

type VDiffResponse_builder 

type VDiffResponse_builder struct {
	Id        int64
	Output    *dev.QueryResult
	VdiffUuid string
	// contains filtered or unexported fields
}

func (VDiffResponse_builder) Build 

func (b0 VDiffResponse_builder) Build() *VDiffResponse

type VDiffTableLastPK 

type VDiffTableLastPK struct {
	Target *dev.QueryResult `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// If the source value is nil then it's the same as the target
	// and the target value should be used for both.
	Source *dev.QueryResult `protobuf:"bytes,2,opt,name=source,proto3,oneof" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*VDiffTableLastPK) ClearSource 

func (x *VDiffTableLastPK) ClearSource()

func (*VDiffTableLastPK) ClearTarget 

func (x *VDiffTableLastPK) ClearTarget()

func (*VDiffTableLastPK) GetSource 

func (x *VDiffTableLastPK) GetSource() *dev.QueryResult

func (*VDiffTableLastPK) GetTarget 

func (x *VDiffTableLastPK) GetTarget() *dev.QueryResult

func (*VDiffTableLastPK) HasSource 

func (x *VDiffTableLastPK) HasSource() bool

func (*VDiffTableLastPK) HasTarget 

func (x *VDiffTableLastPK) HasTarget() bool

func (*VDiffTableLastPK) ProtoMessage 

func (*VDiffTableLastPK) ProtoMessage()

func (*VDiffTableLastPK) ProtoReflect 

func (x *VDiffTableLastPK) ProtoReflect() protoreflect.Message

func (*VDiffTableLastPK) Reset 

func (x *VDiffTableLastPK) Reset()

func (*VDiffTableLastPK) SetSource 

func (x *VDiffTableLastPK) SetSource(v *dev.QueryResult)

func (*VDiffTableLastPK) SetTarget 

func (x *VDiffTableLastPK) SetTarget(v *dev.QueryResult)

func (*VDiffTableLastPK) String 

func (x *VDiffTableLastPK) String() string

type VDiffTableLastPK_builder 

type VDiffTableLastPK_builder struct {
	Target *dev.QueryResult
	// If the source value is nil then it's the same as the target
	// and the target value should be used for both.
	Source *dev.QueryResult
	// contains filtered or unexported fields
}

func (VDiffTableLastPK_builder) Build 

func (b0 VDiffTableLastPK_builder) Build() *VDiffTableLastPK

type VReplicationExecRequest 

type VReplicationExecRequest struct {
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*VReplicationExecRequest) GetQuery 

func (x *VReplicationExecRequest) GetQuery() string

func (*VReplicationExecRequest) ProtoMessage 

func (*VReplicationExecRequest) ProtoMessage()

func (*VReplicationExecRequest) ProtoReflect 

func (x *VReplicationExecRequest) ProtoReflect() protoreflect.Message

func (*VReplicationExecRequest) Reset 

func (x *VReplicationExecRequest) Reset()

func (*VReplicationExecRequest) SetQuery 

func (x *VReplicationExecRequest) SetQuery(v string)

func (*VReplicationExecRequest) String 

func (x *VReplicationExecRequest) String() string

type VReplicationExecRequest_builder 

type VReplicationExecRequest_builder struct {
	Query string
	// contains filtered or unexported fields
}

func (VReplicationExecRequest_builder) Build 

func (b0 VReplicationExecRequest_builder) Build() *VReplicationExecRequest

type VReplicationExecResponse 

type VReplicationExecResponse struct {
	Result *dev.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*VReplicationExecResponse) ClearResult 

func (x *VReplicationExecResponse) ClearResult()

func (*VReplicationExecResponse) GetResult 

func (x *VReplicationExecResponse) GetResult() *dev.QueryResult

func (*VReplicationExecResponse) HasResult 

func (x *VReplicationExecResponse) HasResult() bool

func (*VReplicationExecResponse) ProtoMessage 

func (*VReplicationExecResponse) ProtoMessage()

func (*VReplicationExecResponse) ProtoReflect 

func (x *VReplicationExecResponse) ProtoReflect() protoreflect.Message

func (*VReplicationExecResponse) Reset 

func (x *VReplicationExecResponse) Reset()

func (*VReplicationExecResponse) SetResult 

func (x *VReplicationExecResponse) SetResult(v *dev.QueryResult)

func (*VReplicationExecResponse) String 

func (x *VReplicationExecResponse) String() string

type VReplicationExecResponse_builder 

type VReplicationExecResponse_builder struct {
	Result *dev.QueryResult
	// contains filtered or unexported fields
}

func (VReplicationExecResponse_builder) Build 

func (b0 VReplicationExecResponse_builder) Build() *VReplicationExecResponse

type VReplicationWaitForPosRequest 

type VReplicationWaitForPosRequest struct {
	Id       int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Position string `protobuf:"bytes,2,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

func (*VReplicationWaitForPosRequest) GetId 

func (x *VReplicationWaitForPosRequest) GetId() int32

func (*VReplicationWaitForPosRequest) GetPosition 

func (x *VReplicationWaitForPosRequest) GetPosition() string

func (*VReplicationWaitForPosRequest) ProtoMessage 

func (*VReplicationWaitForPosRequest) ProtoMessage()

func (*VReplicationWaitForPosRequest) ProtoReflect 

func (x *VReplicationWaitForPosRequest) ProtoReflect() protoreflect.Message

func (*VReplicationWaitForPosRequest) Reset 

func (x *VReplicationWaitForPosRequest) Reset()

func (*VReplicationWaitForPosRequest) SetId 

func (x *VReplicationWaitForPosRequest) SetId(v int32)

func (*VReplicationWaitForPosRequest) SetPosition 

func (x *VReplicationWaitForPosRequest) SetPosition(v string)

func (*VReplicationWaitForPosRequest) String 

func (x *VReplicationWaitForPosRequest) String() string

type VReplicationWaitForPosRequest_builder 

type VReplicationWaitForPosRequest_builder struct {
	Id       int32
	Position string
	// contains filtered or unexported fields
}

func (VReplicationWaitForPosRequest_builder) Build 

func (b0 VReplicationWaitForPosRequest_builder) Build() *VReplicationWaitForPosRequest

type VReplicationWaitForPosResponse 

type VReplicationWaitForPosResponse struct {
	// contains filtered or unexported fields
}

func (*VReplicationWaitForPosResponse) ProtoMessage 

func (*VReplicationWaitForPosResponse) ProtoMessage()

func (*VReplicationWaitForPosResponse) ProtoReflect 

func (x *VReplicationWaitForPosResponse) ProtoReflect() protoreflect.Message

func (*VReplicationWaitForPosResponse) Reset 

func (x *VReplicationWaitForPosResponse) Reset()

func (*VReplicationWaitForPosResponse) String 

func (x *VReplicationWaitForPosResponse) String() string

type VReplicationWaitForPosResponse_builder 

type VReplicationWaitForPosResponse_builder struct {
	// contains filtered or unexported fields
}

func (VReplicationWaitForPosResponse_builder) Build 

func (b0 VReplicationWaitForPosResponse_builder) Build() *VReplicationWaitForPosResponse

type ValidateVReplicationPermissionsRequest 

type ValidateVReplicationPermissionsRequest struct {
	// contains filtered or unexported fields
}

func (*ValidateVReplicationPermissionsRequest) ProtoMessage 

func (*ValidateVReplicationPermissionsRequest) ProtoMessage()

func (*ValidateVReplicationPermissionsRequest) ProtoReflect 

func (x *ValidateVReplicationPermissionsRequest) ProtoReflect() protoreflect.Message

func (*ValidateVReplicationPermissionsRequest) Reset 

func (x *ValidateVReplicationPermissionsRequest) Reset()

func (*ValidateVReplicationPermissionsRequest) String 

func (x *ValidateVReplicationPermissionsRequest) String() string

type ValidateVReplicationPermissionsRequest_builder 

type ValidateVReplicationPermissionsRequest_builder struct {
	// contains filtered or unexported fields
}

func (ValidateVReplicationPermissionsRequest_builder) Build 

func (b0 ValidateVReplicationPermissionsRequest_builder) Build() *ValidateVReplicationPermissionsRequest

type ValidateVReplicationPermissionsResponse 

type ValidateVReplicationPermissionsResponse struct {

	// The --db_filtered_user on the tablet.
	User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// Does the user have the minimum privileges needed to manage
	// vreplication metadata.
	Ok bool `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	// The error has to be passed from the tablet since the sidecar name is tablet-specific
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateVReplicationPermissionsResponse) GetError 

func (x *ValidateVReplicationPermissionsResponse) GetError() string

func (*ValidateVReplicationPermissionsResponse) GetOk 

func (x *ValidateVReplicationPermissionsResponse) GetOk() bool

func (*ValidateVReplicationPermissionsResponse) GetUser 

func (x *ValidateVReplicationPermissionsResponse) GetUser() string

func (*ValidateVReplicationPermissionsResponse) ProtoMessage 

func (*ValidateVReplicationPermissionsResponse) ProtoMessage()

func (*ValidateVReplicationPermissionsResponse) ProtoReflect 

func (x *ValidateVReplicationPermissionsResponse) ProtoReflect() protoreflect.Message

func (*ValidateVReplicationPermissionsResponse) Reset 

func (x *ValidateVReplicationPermissionsResponse) Reset()

func (*ValidateVReplicationPermissionsResponse) SetError 

func (x *ValidateVReplicationPermissionsResponse) SetError(v string)

func (*ValidateVReplicationPermissionsResponse) SetOk 

func (x *ValidateVReplicationPermissionsResponse) SetOk(v bool)

func (*ValidateVReplicationPermissionsResponse) SetUser 

func (x *ValidateVReplicationPermissionsResponse) SetUser(v string)

func (*ValidateVReplicationPermissionsResponse) String 

func (x *ValidateVReplicationPermissionsResponse) String() string

type ValidateVReplicationPermissionsResponse_builder 

type ValidateVReplicationPermissionsResponse_builder struct {

	// The --db_filtered_user on the tablet.
	User string
	// Does the user have the minimum privileges needed to manage
	// vreplication metadata.
	Ok bool
	// The error has to be passed from the tablet since the sidecar name is tablet-specific
	Error string
	// contains filtered or unexported fields
}

func (ValidateVReplicationPermissionsResponse_builder) Build 

func (b0 ValidateVReplicationPermissionsResponse_builder) Build() *ValidateVReplicationPermissionsResponse

type WaitForPositionRequest 

type WaitForPositionRequest struct {
	Position string `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitForPositionRequest) GetPosition 

func (x *WaitForPositionRequest) GetPosition() string

func (*WaitForPositionRequest) ProtoMessage 

func (*WaitForPositionRequest) ProtoMessage()

func (*WaitForPositionRequest) ProtoReflect 

func (x *WaitForPositionRequest) ProtoReflect() protoreflect.Message

func (*WaitForPositionRequest) Reset 

func (x *WaitForPositionRequest) Reset()

func (*WaitForPositionRequest) SetPosition 

func (x *WaitForPositionRequest) SetPosition(v string)

func (*WaitForPositionRequest) String 

func (x *WaitForPositionRequest) String() string

type WaitForPositionRequest_builder 

type WaitForPositionRequest_builder struct {
	Position string
	// contains filtered or unexported fields
}

func (WaitForPositionRequest_builder) Build 

func (b0 WaitForPositionRequest_builder) Build() *WaitForPositionRequest

type WaitForPositionResponse 

type WaitForPositionResponse struct {
	// contains filtered or unexported fields
}

func (*WaitForPositionResponse) ProtoMessage 

func (*WaitForPositionResponse) ProtoMessage()

func (*WaitForPositionResponse) ProtoReflect 

func (x *WaitForPositionResponse) ProtoReflect() protoreflect.Message

func (*WaitForPositionResponse) Reset 

func (x *WaitForPositionResponse) Reset()

func (*WaitForPositionResponse) String 

func (x *WaitForPositionResponse) String() string

type WaitForPositionResponse_builder 

type WaitForPositionResponse_builder struct {
	// contains filtered or unexported fields
}

func (WaitForPositionResponse_builder) Build 

func (b0 WaitForPositionResponse_builder) Build() *WaitForPositionResponse

Source Files

  • tabletmanagerdata.pb.go

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.