tabletmanagerdata

package
v0.15.10 Latest Latest
Warning

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

 Go to latest Published: Jul 31, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

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 (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_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) CloneMessageVT 

func (m *ApplySchemaRequest) CloneMessageVT() proto.Message

func (*ApplySchemaRequest) CloneVT 

func (m *ApplySchemaRequest) CloneVT() *ApplySchemaRequest

func (*ApplySchemaRequest) Descriptor deprecated 

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

Deprecated: Use ApplySchemaRequest.ProtoReflect.Descriptor instead.

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

func (m *ApplySchemaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ApplySchemaRequest) MarshalToVT 

func (m *ApplySchemaRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ApplySchemaRequest) MarshalVT 

func (m *ApplySchemaRequest) MarshalVT() (dAtA []byte, err error)

func (*ApplySchemaRequest) ProtoMessage 

func (*ApplySchemaRequest) ProtoMessage()

func (*ApplySchemaRequest) ProtoReflect 

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

func (*ApplySchemaRequest) Reset 

func (x *ApplySchemaRequest) Reset()

func (*ApplySchemaRequest) SizeVT 

func (m *ApplySchemaRequest) SizeVT() (n int)

func (*ApplySchemaRequest) String 

func (x *ApplySchemaRequest) String() string

func (*ApplySchemaRequest) UnmarshalVT 

func (m *ApplySchemaRequest) UnmarshalVT(dAtA []byte) error

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

func (m *ApplySchemaResponse) CloneMessageVT() proto.Message

func (*ApplySchemaResponse) CloneVT 

func (m *ApplySchemaResponse) CloneVT() *ApplySchemaResponse

func (*ApplySchemaResponse) Descriptor deprecated 

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

Deprecated: Use ApplySchemaResponse.ProtoReflect.Descriptor instead.

func (*ApplySchemaResponse) GetAfterSchema 

func (x *ApplySchemaResponse) GetAfterSchema() *SchemaDefinition

func (*ApplySchemaResponse) GetBeforeSchema 

func (x *ApplySchemaResponse) GetBeforeSchema() *SchemaDefinition

func (*ApplySchemaResponse) MarshalToSizedBufferVT 

func (m *ApplySchemaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ApplySchemaResponse) MarshalToVT 

func (m *ApplySchemaResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ApplySchemaResponse) MarshalVT 

func (m *ApplySchemaResponse) MarshalVT() (dAtA []byte, err error)

func (*ApplySchemaResponse) ProtoMessage 

func (*ApplySchemaResponse) ProtoMessage()

func (*ApplySchemaResponse) ProtoReflect 

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

func (*ApplySchemaResponse) Reset 

func (x *ApplySchemaResponse) Reset()

func (*ApplySchemaResponse) SizeVT 

func (m *ApplySchemaResponse) SizeVT() (n int)

func (*ApplySchemaResponse) String 

func (x *ApplySchemaResponse) String() string

func (*ApplySchemaResponse) UnmarshalVT 

func (m *ApplySchemaResponse) UnmarshalVT(dAtA []byte) error

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"`
	// contains filtered or unexported fields
}

func (*BackupRequest) CloneMessageVT 

func (m *BackupRequest) CloneMessageVT() proto.Message

func (*BackupRequest) CloneVT 

func (m *BackupRequest) CloneVT() *BackupRequest

func (*BackupRequest) Descriptor deprecated 

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

Deprecated: Use BackupRequest.ProtoReflect.Descriptor instead.

func (*BackupRequest) GetAllowPrimary 

func (x *BackupRequest) GetAllowPrimary() bool

func (*BackupRequest) GetConcurrency 

func (x *BackupRequest) GetConcurrency() int32

func (*BackupRequest) GetIncrementalFromPos 

func (x *BackupRequest) GetIncrementalFromPos() string

func (*BackupRequest) GetUpgradeSafe 

func (x *BackupRequest) GetUpgradeSafe() bool

func (*BackupRequest) MarshalToSizedBufferVT 

func (m *BackupRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BackupRequest) MarshalToVT 

func (m *BackupRequest) MarshalToVT(dAtA []byte) (int, error)

func (*BackupRequest) MarshalVT 

func (m *BackupRequest) MarshalVT() (dAtA []byte, err error)

func (*BackupRequest) ProtoMessage 

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) ProtoReflect 

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

func (*BackupRequest) Reset 

func (x *BackupRequest) Reset()

func (*BackupRequest) SizeVT 

func (m *BackupRequest) SizeVT() (n int)

func (*BackupRequest) String 

func (x *BackupRequest) String() string

func (*BackupRequest) UnmarshalVT 

func (m *BackupRequest) UnmarshalVT(dAtA []byte) error

type BackupResponse 

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

func (*BackupResponse) CloneMessageVT 

func (m *BackupResponse) CloneMessageVT() proto.Message

func (*BackupResponse) CloneVT 

func (m *BackupResponse) CloneVT() *BackupResponse

func (*BackupResponse) Descriptor deprecated 

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

Deprecated: Use BackupResponse.ProtoReflect.Descriptor instead.

func (*BackupResponse) GetEvent 

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

func (*BackupResponse) MarshalToSizedBufferVT 

func (m *BackupResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BackupResponse) MarshalToVT 

func (m *BackupResponse) MarshalToVT(dAtA []byte) (int, error)

func (*BackupResponse) MarshalVT 

func (m *BackupResponse) MarshalVT() (dAtA []byte, err error)

func (*BackupResponse) ProtoMessage 

func (*BackupResponse) ProtoMessage()

func (*BackupResponse) ProtoReflect 

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

func (*BackupResponse) Reset 

func (x *BackupResponse) Reset()

func (*BackupResponse) SizeVT 

func (m *BackupResponse) SizeVT() (n int)

func (*BackupResponse) String 

func (x *BackupResponse) String() string

func (*BackupResponse) UnmarshalVT 

func (m *BackupResponse) UnmarshalVT(dAtA []byte) error

type ChangeTypeRequest 

type ChangeTypeRequest struct {
	TabletType topodata.TabletType `protobuf:"varint,1,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	SemiSync   bool                `protobuf:"varint,2,opt,name=semiSync,proto3" json:"semiSync,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeTypeRequest) CloneMessageVT 

func (m *ChangeTypeRequest) CloneMessageVT() proto.Message

func (*ChangeTypeRequest) CloneVT 

func (m *ChangeTypeRequest) CloneVT() *ChangeTypeRequest

func (*ChangeTypeRequest) Descriptor deprecated 

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

Deprecated: Use ChangeTypeRequest.ProtoReflect.Descriptor instead.

func (*ChangeTypeRequest) GetSemiSync 

func (x *ChangeTypeRequest) GetSemiSync() bool

func (*ChangeTypeRequest) GetTabletType 

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

func (*ChangeTypeRequest) MarshalToSizedBufferVT 

func (m *ChangeTypeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ChangeTypeRequest) MarshalToVT 

func (m *ChangeTypeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ChangeTypeRequest) MarshalVT 

func (m *ChangeTypeRequest) MarshalVT() (dAtA []byte, err error)

func (*ChangeTypeRequest) ProtoMessage 

func (*ChangeTypeRequest) ProtoMessage()

func (*ChangeTypeRequest) ProtoReflect 

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

func (*ChangeTypeRequest) Reset 

func (x *ChangeTypeRequest) Reset()

func (*ChangeTypeRequest) SizeVT 

func (m *ChangeTypeRequest) SizeVT() (n int)

func (*ChangeTypeRequest) String 

func (x *ChangeTypeRequest) String() string

func (*ChangeTypeRequest) UnmarshalVT 

func (m *ChangeTypeRequest) UnmarshalVT(dAtA []byte) error

type ChangeTypeResponse 

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

func (*ChangeTypeResponse) CloneMessageVT 

func (m *ChangeTypeResponse) CloneMessageVT() proto.Message

func (*ChangeTypeResponse) CloneVT 

func (m *ChangeTypeResponse) CloneVT() *ChangeTypeResponse

func (*ChangeTypeResponse) Descriptor deprecated 

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

Deprecated: Use ChangeTypeResponse.ProtoReflect.Descriptor instead.

func (*ChangeTypeResponse) MarshalToSizedBufferVT 

func (m *ChangeTypeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ChangeTypeResponse) MarshalToVT 

func (m *ChangeTypeResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ChangeTypeResponse) MarshalVT 

func (m *ChangeTypeResponse) MarshalVT() (dAtA []byte, err error)

func (*ChangeTypeResponse) ProtoMessage 

func (*ChangeTypeResponse) ProtoMessage()

func (*ChangeTypeResponse) ProtoReflect 

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

func (*ChangeTypeResponse) Reset 

func (x *ChangeTypeResponse) Reset()

func (*ChangeTypeResponse) SizeVT 

func (m *ChangeTypeResponse) SizeVT() (n int)

func (*ChangeTypeResponse) String 

func (x *ChangeTypeResponse) String() string

func (*ChangeTypeResponse) UnmarshalVT 

func (m *ChangeTypeResponse) UnmarshalVT(dAtA []byte) error

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"`
	// MultiMetricsEnabled is always set to "true" and is how a multi-metrics enabled replica
	// throttler knows its being probed by a multi-metrics enabled primary vttablet.
	MultiMetricsEnabled bool `protobuf:"varint,5,opt,name=multi_metrics_enabled,json=multiMetricsEnabled,proto3" json:"multi_metrics_enabled,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckThrottlerRequest) CloneMessageVT 

func (m *CheckThrottlerRequest) CloneMessageVT() proto.Message

func (*CheckThrottlerRequest) CloneVT 

func (m *CheckThrottlerRequest) CloneVT() *CheckThrottlerRequest

func (*CheckThrottlerRequest) Descriptor deprecated 

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

Deprecated: Use CheckThrottlerRequest.ProtoReflect.Descriptor instead.

func (*CheckThrottlerRequest) GetAppName 

func (x *CheckThrottlerRequest) GetAppName() string

func (*CheckThrottlerRequest) GetMultiMetricsEnabled 

func (x *CheckThrottlerRequest) GetMultiMetricsEnabled() bool

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

func (m *CheckThrottlerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CheckThrottlerRequest) MarshalToVT 

func (m *CheckThrottlerRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CheckThrottlerRequest) MarshalVT 

func (m *CheckThrottlerRequest) MarshalVT() (dAtA []byte, err error)

func (*CheckThrottlerRequest) ProtoMessage 

func (*CheckThrottlerRequest) ProtoMessage()

func (*CheckThrottlerRequest) ProtoReflect 

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

func (*CheckThrottlerRequest) Reset 

func (x *CheckThrottlerRequest) Reset()

func (*CheckThrottlerRequest) SizeVT 

func (m *CheckThrottlerRequest) SizeVT() (n int)

func (*CheckThrottlerRequest) String 

func (x *CheckThrottlerRequest) String() string

func (*CheckThrottlerRequest) UnmarshalVT 

func (m *CheckThrottlerRequest) UnmarshalVT(dAtA []byte) error

type CheckThrottlerResponse 

type CheckThrottlerResponse struct {

	// StatusCode is HTTP compliant response code (e.g. 200 for OK)
	StatusCode int32 `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// 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 `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CheckThrottlerResponse) CloneMessageVT 

func (m *CheckThrottlerResponse) CloneMessageVT() proto.Message

func (*CheckThrottlerResponse) CloneVT 

func (m *CheckThrottlerResponse) CloneVT() *CheckThrottlerResponse

func (*CheckThrottlerResponse) Descriptor deprecated 

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

Deprecated: Use CheckThrottlerResponse.ProtoReflect.Descriptor instead.

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

func (x *CheckThrottlerResponse) GetStatusCode() int32

func (*CheckThrottlerResponse) GetThreshold 

func (x *CheckThrottlerResponse) GetThreshold() float64

func (*CheckThrottlerResponse) GetValue 

func (x *CheckThrottlerResponse) GetValue() float64

func (*CheckThrottlerResponse) MarshalToSizedBufferVT 

func (m *CheckThrottlerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CheckThrottlerResponse) MarshalToVT 

func (m *CheckThrottlerResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CheckThrottlerResponse) MarshalVT 

func (m *CheckThrottlerResponse) MarshalVT() (dAtA []byte, err error)

func (*CheckThrottlerResponse) ProtoMessage 

func (*CheckThrottlerResponse) ProtoMessage()

func (*CheckThrottlerResponse) ProtoReflect 

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

func (*CheckThrottlerResponse) Reset 

func (x *CheckThrottlerResponse) Reset()

func (*CheckThrottlerResponse) SizeVT 

func (m *CheckThrottlerResponse) SizeVT() (n int)

func (*CheckThrottlerResponse) String 

func (x *CheckThrottlerResponse) String() string

func (*CheckThrottlerResponse) UnmarshalVT 

func (m *CheckThrottlerResponse) UnmarshalVT(dAtA []byte) error

type CheckThrottlerResponse_Metric 

type CheckThrottlerResponse_Metric struct {

	// Name of the metric
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// StatusCode is HTTP compliant response code (e.g. 200 for OK)
	StatusCode int32 `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,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"`
	// contains filtered or unexported fields
}

func (*CheckThrottlerResponse_Metric) CloneMessageVT 

func (m *CheckThrottlerResponse_Metric) CloneMessageVT() proto.Message

func (*CheckThrottlerResponse_Metric) CloneVT 

func (m *CheckThrottlerResponse_Metric) CloneVT() *CheckThrottlerResponse_Metric

func (*CheckThrottlerResponse_Metric) Descriptor deprecated 

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

Deprecated: Use CheckThrottlerResponse_Metric.ProtoReflect.Descriptor instead.

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

func (x *CheckThrottlerResponse_Metric) GetScope() string

func (*CheckThrottlerResponse_Metric) GetStatusCode 

func (x *CheckThrottlerResponse_Metric) GetStatusCode() int32

func (*CheckThrottlerResponse_Metric) GetThreshold 

func (x *CheckThrottlerResponse_Metric) GetThreshold() float64

func (*CheckThrottlerResponse_Metric) GetValue 

func (x *CheckThrottlerResponse_Metric) GetValue() float64

func (*CheckThrottlerResponse_Metric) MarshalToSizedBufferVT 

func (m *CheckThrottlerResponse_Metric) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CheckThrottlerResponse_Metric) MarshalToVT 

func (m *CheckThrottlerResponse_Metric) MarshalToVT(dAtA []byte) (int, error)

func (*CheckThrottlerResponse_Metric) MarshalVT 

func (m *CheckThrottlerResponse_Metric) MarshalVT() (dAtA []byte, err error)

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

func (m *CheckThrottlerResponse_Metric) SizeVT() (n int)

func (*CheckThrottlerResponse_Metric) String 

func (x *CheckThrottlerResponse_Metric) String() string

func (*CheckThrottlerResponse_Metric) UnmarshalVT 

func (m *CheckThrottlerResponse_Metric) UnmarshalVT(dAtA []byte) error

type CreateVReplicationWorkflowRequest 

type CreateVReplicationWorkflowRequest struct {
	Workflow     string                     `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	BinlogSource []*binlogdata.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               []topodata.TabletType                  `` /* 127-byte string literal not displayed */
	TabletSelectionPreference TabletSelectionPreference              `` /* 188-byte string literal not displayed */
	WorkflowType              binlogdata.VReplicationWorkflowType    `` /* 139-byte string literal not displayed */
	WorkflowSubType           binlogdata.VReplicationWorkflowSubType `` /* 153-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) CloneMessageVT 

func (m *CreateVReplicationWorkflowRequest) CloneMessageVT() proto.Message

func (*CreateVReplicationWorkflowRequest) CloneVT 

func (m *CreateVReplicationWorkflowRequest) CloneVT() *CreateVReplicationWorkflowRequest

func (*CreateVReplicationWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use CreateVReplicationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*CreateVReplicationWorkflowRequest) GetAutoStart 

func (x *CreateVReplicationWorkflowRequest) GetAutoStart() bool

func (*CreateVReplicationWorkflowRequest) GetBinlogSource 

func (x *CreateVReplicationWorkflowRequest) GetBinlogSource() []*binlogdata.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() []topodata.TabletType

func (*CreateVReplicationWorkflowRequest) GetWorkflow 

func (x *CreateVReplicationWorkflowRequest) GetWorkflow() string

func (*CreateVReplicationWorkflowRequest) GetWorkflowSubType 

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

func (*CreateVReplicationWorkflowRequest) GetWorkflowType 

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

func (*CreateVReplicationWorkflowRequest) MarshalToSizedBufferVT 

func (m *CreateVReplicationWorkflowRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateVReplicationWorkflowRequest) MarshalToVT 

func (m *CreateVReplicationWorkflowRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CreateVReplicationWorkflowRequest) MarshalVT 

func (m *CreateVReplicationWorkflowRequest) MarshalVT() (dAtA []byte, err error)

func (*CreateVReplicationWorkflowRequest) ProtoMessage 

func (*CreateVReplicationWorkflowRequest) ProtoMessage()

func (*CreateVReplicationWorkflowRequest) ProtoReflect 

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

func (*CreateVReplicationWorkflowRequest) Reset 

func (x *CreateVReplicationWorkflowRequest) Reset()

func (*CreateVReplicationWorkflowRequest) SizeVT 

func (m *CreateVReplicationWorkflowRequest) SizeVT() (n int)

func (*CreateVReplicationWorkflowRequest) String 

func (x *CreateVReplicationWorkflowRequest) String() string

func (*CreateVReplicationWorkflowRequest) UnmarshalVT 

func (m *CreateVReplicationWorkflowRequest) UnmarshalVT(dAtA []byte) error

type CreateVReplicationWorkflowResponse 

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

func (*CreateVReplicationWorkflowResponse) CloneMessageVT 

func (m *CreateVReplicationWorkflowResponse) CloneMessageVT() proto.Message

func (*CreateVReplicationWorkflowResponse) CloneVT 

func (m *CreateVReplicationWorkflowResponse) CloneVT() *CreateVReplicationWorkflowResponse

func (*CreateVReplicationWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use CreateVReplicationWorkflowResponse.ProtoReflect.Descriptor instead.

func (*CreateVReplicationWorkflowResponse) GetResult 

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

func (*CreateVReplicationWorkflowResponse) MarshalToSizedBufferVT 

func (m *CreateVReplicationWorkflowResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateVReplicationWorkflowResponse) MarshalToVT 

func (m *CreateVReplicationWorkflowResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CreateVReplicationWorkflowResponse) MarshalVT 

func (m *CreateVReplicationWorkflowResponse) MarshalVT() (dAtA []byte, err error)

func (*CreateVReplicationWorkflowResponse) ProtoMessage 

func (*CreateVReplicationWorkflowResponse) ProtoMessage()

func (*CreateVReplicationWorkflowResponse) ProtoReflect 

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

func (*CreateVReplicationWorkflowResponse) Reset 

func (x *CreateVReplicationWorkflowResponse) Reset()

func (*CreateVReplicationWorkflowResponse) SizeVT 

func (m *CreateVReplicationWorkflowResponse) SizeVT() (n int)

func (*CreateVReplicationWorkflowResponse) String 

func (x *CreateVReplicationWorkflowResponse) String() string

func (*CreateVReplicationWorkflowResponse) UnmarshalVT 

func (m *CreateVReplicationWorkflowResponse) UnmarshalVT(dAtA []byte) error

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

func (m *DbPermission) CloneMessageVT() proto.Message

func (*DbPermission) CloneVT 

func (m *DbPermission) CloneVT() *DbPermission

func (*DbPermission) Descriptor deprecated 

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

Deprecated: Use DbPermission.ProtoReflect.Descriptor instead.

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

func (m *DbPermission) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DbPermission) MarshalToVT 

func (m *DbPermission) MarshalToVT(dAtA []byte) (int, error)

func (*DbPermission) MarshalVT 

func (m *DbPermission) MarshalVT() (dAtA []byte, err error)

func (*DbPermission) ProtoMessage 

func (*DbPermission) ProtoMessage()

func (*DbPermission) ProtoReflect 

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

func (*DbPermission) Reset 

func (x *DbPermission) Reset()

func (*DbPermission) SizeVT 

func (m *DbPermission) SizeVT() (n int)

func (*DbPermission) String 

func (x *DbPermission) String() string

func (*DbPermission) UnmarshalVT 

func (m *DbPermission) UnmarshalVT(dAtA []byte) error

type DeleteVReplicationWorkflowRequest 

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

func (*DeleteVReplicationWorkflowRequest) CloneMessageVT 

func (m *DeleteVReplicationWorkflowRequest) CloneMessageVT() proto.Message

func (*DeleteVReplicationWorkflowRequest) CloneVT 

func (m *DeleteVReplicationWorkflowRequest) CloneVT() *DeleteVReplicationWorkflowRequest

func (*DeleteVReplicationWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use DeleteVReplicationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*DeleteVReplicationWorkflowRequest) GetWorkflow 

func (x *DeleteVReplicationWorkflowRequest) GetWorkflow() string

func (*DeleteVReplicationWorkflowRequest) MarshalToSizedBufferVT 

func (m *DeleteVReplicationWorkflowRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteVReplicationWorkflowRequest) MarshalToVT 

func (m *DeleteVReplicationWorkflowRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteVReplicationWorkflowRequest) MarshalVT 

func (m *DeleteVReplicationWorkflowRequest) MarshalVT() (dAtA []byte, err error)

func (*DeleteVReplicationWorkflowRequest) ProtoMessage 

func (*DeleteVReplicationWorkflowRequest) ProtoMessage()

func (*DeleteVReplicationWorkflowRequest) ProtoReflect 

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

func (*DeleteVReplicationWorkflowRequest) Reset 

func (x *DeleteVReplicationWorkflowRequest) Reset()

func (*DeleteVReplicationWorkflowRequest) SizeVT 

func (m *DeleteVReplicationWorkflowRequest) SizeVT() (n int)

func (*DeleteVReplicationWorkflowRequest) String 

func (x *DeleteVReplicationWorkflowRequest) String() string

func (*DeleteVReplicationWorkflowRequest) UnmarshalVT 

func (m *DeleteVReplicationWorkflowRequest) UnmarshalVT(dAtA []byte) error

type DeleteVReplicationWorkflowResponse 

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

func (*DeleteVReplicationWorkflowResponse) CloneMessageVT 

func (m *DeleteVReplicationWorkflowResponse) CloneMessageVT() proto.Message

func (*DeleteVReplicationWorkflowResponse) CloneVT 

func (m *DeleteVReplicationWorkflowResponse) CloneVT() *DeleteVReplicationWorkflowResponse

func (*DeleteVReplicationWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use DeleteVReplicationWorkflowResponse.ProtoReflect.Descriptor instead.

func (*DeleteVReplicationWorkflowResponse) GetResult 

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

func (*DeleteVReplicationWorkflowResponse) MarshalToSizedBufferVT 

func (m *DeleteVReplicationWorkflowResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteVReplicationWorkflowResponse) MarshalToVT 

func (m *DeleteVReplicationWorkflowResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteVReplicationWorkflowResponse) MarshalVT 

func (m *DeleteVReplicationWorkflowResponse) MarshalVT() (dAtA []byte, err error)

func (*DeleteVReplicationWorkflowResponse) ProtoMessage 

func (*DeleteVReplicationWorkflowResponse) ProtoMessage()

func (*DeleteVReplicationWorkflowResponse) ProtoReflect 

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

func (*DeleteVReplicationWorkflowResponse) Reset 

func (x *DeleteVReplicationWorkflowResponse) Reset()

func (*DeleteVReplicationWorkflowResponse) SizeVT 

func (m *DeleteVReplicationWorkflowResponse) SizeVT() (n int)

func (*DeleteVReplicationWorkflowResponse) String 

func (x *DeleteVReplicationWorkflowResponse) String() string

func (*DeleteVReplicationWorkflowResponse) UnmarshalVT 

func (m *DeleteVReplicationWorkflowResponse) UnmarshalVT(dAtA []byte) error

type DemotePrimaryRequest 

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

func (*DemotePrimaryRequest) CloneMessageVT 

func (m *DemotePrimaryRequest) CloneMessageVT() proto.Message

func (*DemotePrimaryRequest) CloneVT 

func (m *DemotePrimaryRequest) CloneVT() *DemotePrimaryRequest

func (*DemotePrimaryRequest) Descriptor deprecated 

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

Deprecated: Use DemotePrimaryRequest.ProtoReflect.Descriptor instead.

func (*DemotePrimaryRequest) MarshalToSizedBufferVT 

func (m *DemotePrimaryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DemotePrimaryRequest) MarshalToVT 

func (m *DemotePrimaryRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DemotePrimaryRequest) MarshalVT 

func (m *DemotePrimaryRequest) MarshalVT() (dAtA []byte, err error)

func (*DemotePrimaryRequest) ProtoMessage 

func (*DemotePrimaryRequest) ProtoMessage()

func (*DemotePrimaryRequest) ProtoReflect 

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

func (*DemotePrimaryRequest) Reset 

func (x *DemotePrimaryRequest) Reset()

func (*DemotePrimaryRequest) SizeVT 

func (m *DemotePrimaryRequest) SizeVT() (n int)

func (*DemotePrimaryRequest) String 

func (x *DemotePrimaryRequest) String() string

func (*DemotePrimaryRequest) UnmarshalVT 

func (m *DemotePrimaryRequest) UnmarshalVT(dAtA []byte) error

type DemotePrimaryResponse 

type DemotePrimaryResponse struct {

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

func (*DemotePrimaryResponse) CloneMessageVT 

func (m *DemotePrimaryResponse) CloneMessageVT() proto.Message

func (*DemotePrimaryResponse) CloneVT 

func (m *DemotePrimaryResponse) CloneVT() *DemotePrimaryResponse

func (*DemotePrimaryResponse) Descriptor deprecated 

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

Deprecated: Use DemotePrimaryResponse.ProtoReflect.Descriptor instead.

func (*DemotePrimaryResponse) GetPrimaryStatus 

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

func (*DemotePrimaryResponse) MarshalToSizedBufferVT 

func (m *DemotePrimaryResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DemotePrimaryResponse) MarshalToVT 

func (m *DemotePrimaryResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DemotePrimaryResponse) MarshalVT 

func (m *DemotePrimaryResponse) MarshalVT() (dAtA []byte, err error)

func (*DemotePrimaryResponse) ProtoMessage 

func (*DemotePrimaryResponse) ProtoMessage()

func (*DemotePrimaryResponse) ProtoReflect 

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

func (*DemotePrimaryResponse) Reset 

func (x *DemotePrimaryResponse) Reset()

func (*DemotePrimaryResponse) SizeVT 

func (m *DemotePrimaryResponse) SizeVT() (n int)

func (*DemotePrimaryResponse) String 

func (x *DemotePrimaryResponse) String() string

func (*DemotePrimaryResponse) UnmarshalVT 

func (m *DemotePrimaryResponse) UnmarshalVT(dAtA []byte) error

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

func (m *ExecuteFetchAsAllPrivsRequest) CloneMessageVT() proto.Message

func (*ExecuteFetchAsAllPrivsRequest) CloneVT 

func (m *ExecuteFetchAsAllPrivsRequest) CloneVT() *ExecuteFetchAsAllPrivsRequest

func (*ExecuteFetchAsAllPrivsRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteFetchAsAllPrivsRequest.ProtoReflect.Descriptor instead.

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

func (m *ExecuteFetchAsAllPrivsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExecuteFetchAsAllPrivsRequest) MarshalToVT 

func (m *ExecuteFetchAsAllPrivsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ExecuteFetchAsAllPrivsRequest) MarshalVT 

func (m *ExecuteFetchAsAllPrivsRequest) MarshalVT() (dAtA []byte, err error)

func (*ExecuteFetchAsAllPrivsRequest) ProtoMessage 

func (*ExecuteFetchAsAllPrivsRequest) ProtoMessage()

func (*ExecuteFetchAsAllPrivsRequest) ProtoReflect 

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

func (*ExecuteFetchAsAllPrivsRequest) Reset 

func (x *ExecuteFetchAsAllPrivsRequest) Reset()

func (*ExecuteFetchAsAllPrivsRequest) SizeVT 

func (m *ExecuteFetchAsAllPrivsRequest) SizeVT() (n int)

func (*ExecuteFetchAsAllPrivsRequest) String 

func (x *ExecuteFetchAsAllPrivsRequest) String() string

func (*ExecuteFetchAsAllPrivsRequest) UnmarshalVT 

func (m *ExecuteFetchAsAllPrivsRequest) UnmarshalVT(dAtA []byte) error

type ExecuteFetchAsAllPrivsResponse 

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

func (*ExecuteFetchAsAllPrivsResponse) CloneMessageVT 

func (m *ExecuteFetchAsAllPrivsResponse) CloneMessageVT() proto.Message

func (*ExecuteFetchAsAllPrivsResponse) CloneVT 

func (m *ExecuteFetchAsAllPrivsResponse) CloneVT() *ExecuteFetchAsAllPrivsResponse

func (*ExecuteFetchAsAllPrivsResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteFetchAsAllPrivsResponse.ProtoReflect.Descriptor instead.

func (*ExecuteFetchAsAllPrivsResponse) GetResult 

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

func (*ExecuteFetchAsAllPrivsResponse) MarshalToSizedBufferVT 

func (m *ExecuteFetchAsAllPrivsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExecuteFetchAsAllPrivsResponse) MarshalToVT 

func (m *ExecuteFetchAsAllPrivsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ExecuteFetchAsAllPrivsResponse) MarshalVT 

func (m *ExecuteFetchAsAllPrivsResponse) MarshalVT() (dAtA []byte, err error)

func (*ExecuteFetchAsAllPrivsResponse) ProtoMessage 

func (*ExecuteFetchAsAllPrivsResponse) ProtoMessage()

func (*ExecuteFetchAsAllPrivsResponse) ProtoReflect 

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

func (*ExecuteFetchAsAllPrivsResponse) Reset 

func (x *ExecuteFetchAsAllPrivsResponse) Reset()

func (*ExecuteFetchAsAllPrivsResponse) SizeVT 

func (m *ExecuteFetchAsAllPrivsResponse) SizeVT() (n int)

func (*ExecuteFetchAsAllPrivsResponse) String 

func (x *ExecuteFetchAsAllPrivsResponse) String() string

func (*ExecuteFetchAsAllPrivsResponse) UnmarshalVT 

func (m *ExecuteFetchAsAllPrivsResponse) UnmarshalVT(dAtA []byte) error

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

func (m *ExecuteFetchAsAppRequest) CloneMessageVT() proto.Message

func (*ExecuteFetchAsAppRequest) CloneVT 

func (m *ExecuteFetchAsAppRequest) CloneVT() *ExecuteFetchAsAppRequest

func (*ExecuteFetchAsAppRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteFetchAsAppRequest.ProtoReflect.Descriptor instead.

func (*ExecuteFetchAsAppRequest) GetMaxRows 

func (x *ExecuteFetchAsAppRequest) GetMaxRows() uint64

func (*ExecuteFetchAsAppRequest) GetQuery 

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

func (*ExecuteFetchAsAppRequest) MarshalToSizedBufferVT 

func (m *ExecuteFetchAsAppRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExecuteFetchAsAppRequest) MarshalToVT 

func (m *ExecuteFetchAsAppRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ExecuteFetchAsAppRequest) MarshalVT 

func (m *ExecuteFetchAsAppRequest) MarshalVT() (dAtA []byte, err error)

func (*ExecuteFetchAsAppRequest) ProtoMessage 

func (*ExecuteFetchAsAppRequest) ProtoMessage()

func (*ExecuteFetchAsAppRequest) ProtoReflect 

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

func (*ExecuteFetchAsAppRequest) Reset 

func (x *ExecuteFetchAsAppRequest) Reset()

func (*ExecuteFetchAsAppRequest) SizeVT 

func (m *ExecuteFetchAsAppRequest) SizeVT() (n int)

func (*ExecuteFetchAsAppRequest) String 

func (x *ExecuteFetchAsAppRequest) String() string

func (*ExecuteFetchAsAppRequest) UnmarshalVT 

func (m *ExecuteFetchAsAppRequest) UnmarshalVT(dAtA []byte) error

type ExecuteFetchAsAppResponse 

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

func (*ExecuteFetchAsAppResponse) CloneMessageVT 

func (m *ExecuteFetchAsAppResponse) CloneMessageVT() proto.Message

func (*ExecuteFetchAsAppResponse) CloneVT 

func (m *ExecuteFetchAsAppResponse) CloneVT() *ExecuteFetchAsAppResponse

func (*ExecuteFetchAsAppResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteFetchAsAppResponse.ProtoReflect.Descriptor instead.

func (*ExecuteFetchAsAppResponse) GetResult 

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

func (*ExecuteFetchAsAppResponse) MarshalToSizedBufferVT 

func (m *ExecuteFetchAsAppResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExecuteFetchAsAppResponse) MarshalToVT 

func (m *ExecuteFetchAsAppResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ExecuteFetchAsAppResponse) MarshalVT 

func (m *ExecuteFetchAsAppResponse) MarshalVT() (dAtA []byte, err error)

func (*ExecuteFetchAsAppResponse) ProtoMessage 

func (*ExecuteFetchAsAppResponse) ProtoMessage()

func (*ExecuteFetchAsAppResponse) ProtoReflect 

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

func (*ExecuteFetchAsAppResponse) Reset 

func (x *ExecuteFetchAsAppResponse) Reset()

func (*ExecuteFetchAsAppResponse) SizeVT 

func (m *ExecuteFetchAsAppResponse) SizeVT() (n int)

func (*ExecuteFetchAsAppResponse) String 

func (x *ExecuteFetchAsAppResponse) String() string

func (*ExecuteFetchAsAppResponse) UnmarshalVT 

func (m *ExecuteFetchAsAppResponse) UnmarshalVT(dAtA []byte) error

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

func (m *ExecuteFetchAsDbaRequest) CloneMessageVT() proto.Message

func (*ExecuteFetchAsDbaRequest) CloneVT 

func (m *ExecuteFetchAsDbaRequest) CloneVT() *ExecuteFetchAsDbaRequest

func (*ExecuteFetchAsDbaRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteFetchAsDbaRequest.ProtoReflect.Descriptor instead.

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

func (m *ExecuteFetchAsDbaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExecuteFetchAsDbaRequest) MarshalToVT 

func (m *ExecuteFetchAsDbaRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ExecuteFetchAsDbaRequest) MarshalVT 

func (m *ExecuteFetchAsDbaRequest) MarshalVT() (dAtA []byte, err error)

func (*ExecuteFetchAsDbaRequest) ProtoMessage 

func (*ExecuteFetchAsDbaRequest) ProtoMessage()

func (*ExecuteFetchAsDbaRequest) ProtoReflect 

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

func (*ExecuteFetchAsDbaRequest) Reset 

func (x *ExecuteFetchAsDbaRequest) Reset()

func (*ExecuteFetchAsDbaRequest) SizeVT 

func (m *ExecuteFetchAsDbaRequest) SizeVT() (n int)

func (*ExecuteFetchAsDbaRequest) String 

func (x *ExecuteFetchAsDbaRequest) String() string

func (*ExecuteFetchAsDbaRequest) UnmarshalVT 

func (m *ExecuteFetchAsDbaRequest) UnmarshalVT(dAtA []byte) error

type ExecuteFetchAsDbaResponse 

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

func (*ExecuteFetchAsDbaResponse) CloneMessageVT 

func (m *ExecuteFetchAsDbaResponse) CloneMessageVT() proto.Message

func (*ExecuteFetchAsDbaResponse) CloneVT 

func (m *ExecuteFetchAsDbaResponse) CloneVT() *ExecuteFetchAsDbaResponse

func (*ExecuteFetchAsDbaResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteFetchAsDbaResponse.ProtoReflect.Descriptor instead.

func (*ExecuteFetchAsDbaResponse) GetResult 

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

func (*ExecuteFetchAsDbaResponse) MarshalToSizedBufferVT 

func (m *ExecuteFetchAsDbaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExecuteFetchAsDbaResponse) MarshalToVT 

func (m *ExecuteFetchAsDbaResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ExecuteFetchAsDbaResponse) MarshalVT 

func (m *ExecuteFetchAsDbaResponse) MarshalVT() (dAtA []byte, err error)

func (*ExecuteFetchAsDbaResponse) ProtoMessage 

func (*ExecuteFetchAsDbaResponse) ProtoMessage()

func (*ExecuteFetchAsDbaResponse) ProtoReflect 

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

func (*ExecuteFetchAsDbaResponse) Reset 

func (x *ExecuteFetchAsDbaResponse) Reset()

func (*ExecuteFetchAsDbaResponse) SizeVT 

func (m *ExecuteFetchAsDbaResponse) SizeVT() (n int)

func (*ExecuteFetchAsDbaResponse) String 

func (x *ExecuteFetchAsDbaResponse) String() string

func (*ExecuteFetchAsDbaResponse) UnmarshalVT 

func (m *ExecuteFetchAsDbaResponse) UnmarshalVT(dAtA []byte) error

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 `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecuteHookRequest) CloneMessageVT 

func (m *ExecuteHookRequest) CloneMessageVT() proto.Message

func (*ExecuteHookRequest) CloneVT 

func (m *ExecuteHookRequest) CloneVT() *ExecuteHookRequest

func (*ExecuteHookRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteHookRequest.ProtoReflect.Descriptor instead.

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

func (m *ExecuteHookRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExecuteHookRequest) MarshalToVT 

func (m *ExecuteHookRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ExecuteHookRequest) MarshalVT 

func (m *ExecuteHookRequest) MarshalVT() (dAtA []byte, err error)

func (*ExecuteHookRequest) ProtoMessage 

func (*ExecuteHookRequest) ProtoMessage()

func (*ExecuteHookRequest) ProtoReflect 

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

func (*ExecuteHookRequest) Reset 

func (x *ExecuteHookRequest) Reset()

func (*ExecuteHookRequest) SizeVT 

func (m *ExecuteHookRequest) SizeVT() (n int)

func (*ExecuteHookRequest) String 

func (x *ExecuteHookRequest) String() string

func (*ExecuteHookRequest) UnmarshalVT 

func (m *ExecuteHookRequest) UnmarshalVT(dAtA []byte) error

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

func (m *ExecuteHookResponse) CloneMessageVT() proto.Message

func (*ExecuteHookResponse) CloneVT 

func (m *ExecuteHookResponse) CloneVT() *ExecuteHookResponse

func (*ExecuteHookResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteHookResponse.ProtoReflect.Descriptor instead.

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

func (m *ExecuteHookResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExecuteHookResponse) MarshalToVT 

func (m *ExecuteHookResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ExecuteHookResponse) MarshalVT 

func (m *ExecuteHookResponse) MarshalVT() (dAtA []byte, err error)

func (*ExecuteHookResponse) ProtoMessage 

func (*ExecuteHookResponse) ProtoMessage()

func (*ExecuteHookResponse) ProtoReflect 

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

func (*ExecuteHookResponse) Reset 

func (x *ExecuteHookResponse) Reset()

func (*ExecuteHookResponse) SizeVT 

func (m *ExecuteHookResponse) SizeVT() (n int)

func (*ExecuteHookResponse) String 

func (x *ExecuteHookResponse) String() string

func (*ExecuteHookResponse) UnmarshalVT 

func (m *ExecuteHookResponse) UnmarshalVT(dAtA []byte) error

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

func (m *ExecuteMultiFetchAsDbaRequest) CloneMessageVT() proto.Message

func (*ExecuteMultiFetchAsDbaRequest) CloneVT 

func (m *ExecuteMultiFetchAsDbaRequest) CloneVT() *ExecuteMultiFetchAsDbaRequest

func (*ExecuteMultiFetchAsDbaRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteMultiFetchAsDbaRequest.ProtoReflect.Descriptor instead.

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

func (m *ExecuteMultiFetchAsDbaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExecuteMultiFetchAsDbaRequest) MarshalToVT 

func (m *ExecuteMultiFetchAsDbaRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ExecuteMultiFetchAsDbaRequest) MarshalVT 

func (m *ExecuteMultiFetchAsDbaRequest) MarshalVT() (dAtA []byte, err error)

func (*ExecuteMultiFetchAsDbaRequest) ProtoMessage 

func (*ExecuteMultiFetchAsDbaRequest) ProtoMessage()

func (*ExecuteMultiFetchAsDbaRequest) ProtoReflect 

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

func (*ExecuteMultiFetchAsDbaRequest) Reset 

func (x *ExecuteMultiFetchAsDbaRequest) Reset()

func (*ExecuteMultiFetchAsDbaRequest) SizeVT 

func (m *ExecuteMultiFetchAsDbaRequest) SizeVT() (n int)

func (*ExecuteMultiFetchAsDbaRequest) String 

func (x *ExecuteMultiFetchAsDbaRequest) String() string

func (*ExecuteMultiFetchAsDbaRequest) UnmarshalVT 

func (m *ExecuteMultiFetchAsDbaRequest) UnmarshalVT(dAtA []byte) error

type ExecuteMultiFetchAsDbaResponse 

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

func (*ExecuteMultiFetchAsDbaResponse) CloneMessageVT 

func (m *ExecuteMultiFetchAsDbaResponse) CloneMessageVT() proto.Message

func (*ExecuteMultiFetchAsDbaResponse) CloneVT 

func (m *ExecuteMultiFetchAsDbaResponse) CloneVT() *ExecuteMultiFetchAsDbaResponse

func (*ExecuteMultiFetchAsDbaResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteMultiFetchAsDbaResponse.ProtoReflect.Descriptor instead.

func (*ExecuteMultiFetchAsDbaResponse) GetResults 

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

func (*ExecuteMultiFetchAsDbaResponse) MarshalToSizedBufferVT 

func (m *ExecuteMultiFetchAsDbaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExecuteMultiFetchAsDbaResponse) MarshalToVT 

func (m *ExecuteMultiFetchAsDbaResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ExecuteMultiFetchAsDbaResponse) MarshalVT 

func (m *ExecuteMultiFetchAsDbaResponse) MarshalVT() (dAtA []byte, err error)

func (*ExecuteMultiFetchAsDbaResponse) ProtoMessage 

func (*ExecuteMultiFetchAsDbaResponse) ProtoMessage()

func (*ExecuteMultiFetchAsDbaResponse) ProtoReflect 

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

func (*ExecuteMultiFetchAsDbaResponse) Reset 

func (x *ExecuteMultiFetchAsDbaResponse) Reset()

func (*ExecuteMultiFetchAsDbaResponse) SizeVT 

func (m *ExecuteMultiFetchAsDbaResponse) SizeVT() (n int)

func (*ExecuteMultiFetchAsDbaResponse) String 

func (x *ExecuteMultiFetchAsDbaResponse) String() string

func (*ExecuteMultiFetchAsDbaResponse) UnmarshalVT 

func (m *ExecuteMultiFetchAsDbaResponse) UnmarshalVT(dAtA []byte) error

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 *vtrpc.CallerID `protobuf:"bytes,4,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteQueryRequest) CloneMessageVT 

func (m *ExecuteQueryRequest) CloneMessageVT() proto.Message

func (*ExecuteQueryRequest) CloneVT 

func (m *ExecuteQueryRequest) CloneVT() *ExecuteQueryRequest

func (*ExecuteQueryRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteQueryRequest.ProtoReflect.Descriptor instead.

func (*ExecuteQueryRequest) GetCallerId 

func (x *ExecuteQueryRequest) GetCallerId() *vtrpc.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) MarshalToSizedBufferVT 

func (m *ExecuteQueryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExecuteQueryRequest) MarshalToVT 

func (m *ExecuteQueryRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ExecuteQueryRequest) MarshalVT 

func (m *ExecuteQueryRequest) MarshalVT() (dAtA []byte, err error)

func (*ExecuteQueryRequest) ProtoMessage 

func (*ExecuteQueryRequest) ProtoMessage()

func (*ExecuteQueryRequest) ProtoReflect 

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

func (*ExecuteQueryRequest) Reset 

func (x *ExecuteQueryRequest) Reset()

func (*ExecuteQueryRequest) SizeVT 

func (m *ExecuteQueryRequest) SizeVT() (n int)

func (*ExecuteQueryRequest) String 

func (x *ExecuteQueryRequest) String() string

func (*ExecuteQueryRequest) UnmarshalVT 

func (m *ExecuteQueryRequest) UnmarshalVT(dAtA []byte) error

type ExecuteQueryResponse 

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

func (*ExecuteQueryResponse) CloneMessageVT 

func (m *ExecuteQueryResponse) CloneMessageVT() proto.Message

func (*ExecuteQueryResponse) CloneVT 

func (m *ExecuteQueryResponse) CloneVT() *ExecuteQueryResponse

func (*ExecuteQueryResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteQueryResponse.ProtoReflect.Descriptor instead.

func (*ExecuteQueryResponse) GetResult 

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

func (*ExecuteQueryResponse) MarshalToSizedBufferVT 

func (m *ExecuteQueryResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExecuteQueryResponse) MarshalToVT 

func (m *ExecuteQueryResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ExecuteQueryResponse) MarshalVT 

func (m *ExecuteQueryResponse) MarshalVT() (dAtA []byte, err error)

func (*ExecuteQueryResponse) ProtoMessage 

func (*ExecuteQueryResponse) ProtoMessage()

func (*ExecuteQueryResponse) ProtoReflect 

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

func (*ExecuteQueryResponse) Reset 

func (x *ExecuteQueryResponse) Reset()

func (*ExecuteQueryResponse) SizeVT 

func (m *ExecuteQueryResponse) SizeVT() (n int)

func (*ExecuteQueryResponse) String 

func (x *ExecuteQueryResponse) String() string

func (*ExecuteQueryResponse) UnmarshalVT 

func (m *ExecuteQueryResponse) UnmarshalVT(dAtA []byte) error

type FullStatusRequest 

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

func (*FullStatusRequest) CloneMessageVT 

func (m *FullStatusRequest) CloneMessageVT() proto.Message

func (*FullStatusRequest) CloneVT 

func (m *FullStatusRequest) CloneVT() *FullStatusRequest

func (*FullStatusRequest) Descriptor deprecated 

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

Deprecated: Use FullStatusRequest.ProtoReflect.Descriptor instead.

func (*FullStatusRequest) MarshalToSizedBufferVT 

func (m *FullStatusRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FullStatusRequest) MarshalToVT 

func (m *FullStatusRequest) MarshalToVT(dAtA []byte) (int, error)

func (*FullStatusRequest) MarshalVT 

func (m *FullStatusRequest) MarshalVT() (dAtA []byte, err error)

func (*FullStatusRequest) ProtoMessage 

func (*FullStatusRequest) ProtoMessage()

func (*FullStatusRequest) ProtoReflect 

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

func (*FullStatusRequest) Reset 

func (x *FullStatusRequest) Reset()

func (*FullStatusRequest) SizeVT 

func (m *FullStatusRequest) SizeVT() (n int)

func (*FullStatusRequest) String 

func (x *FullStatusRequest) String() string

func (*FullStatusRequest) UnmarshalVT 

func (m *FullStatusRequest) UnmarshalVT(dAtA []byte) error

type FullStatusResponse 

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

func (*FullStatusResponse) CloneMessageVT 

func (m *FullStatusResponse) CloneMessageVT() proto.Message

func (*FullStatusResponse) CloneVT 

func (m *FullStatusResponse) CloneVT() *FullStatusResponse

func (*FullStatusResponse) Descriptor deprecated 

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

Deprecated: Use FullStatusResponse.ProtoReflect.Descriptor instead.

func (*FullStatusResponse) GetStatus 

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

func (*FullStatusResponse) MarshalToSizedBufferVT 

func (m *FullStatusResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FullStatusResponse) MarshalToVT 

func (m *FullStatusResponse) MarshalToVT(dAtA []byte) (int, error)

func (*FullStatusResponse) MarshalVT 

func (m *FullStatusResponse) MarshalVT() (dAtA []byte, err error)

func (*FullStatusResponse) ProtoMessage 

func (*FullStatusResponse) ProtoMessage()

func (*FullStatusResponse) ProtoReflect 

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

func (*FullStatusResponse) Reset 

func (x *FullStatusResponse) Reset()

func (*FullStatusResponse) SizeVT 

func (m *FullStatusResponse) SizeVT() (n int)

func (*FullStatusResponse) String 

func (x *FullStatusResponse) String() string

func (*FullStatusResponse) UnmarshalVT 

func (m *FullStatusResponse) UnmarshalVT(dAtA []byte) error

type GetGlobalStatusVarsRequest 

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

func (*GetGlobalStatusVarsRequest) CloneMessageVT 

func (m *GetGlobalStatusVarsRequest) CloneMessageVT() proto.Message

func (*GetGlobalStatusVarsRequest) CloneVT 

func (m *GetGlobalStatusVarsRequest) CloneVT() *GetGlobalStatusVarsRequest

func (*GetGlobalStatusVarsRequest) Descriptor deprecated 

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

Deprecated: Use GetGlobalStatusVarsRequest.ProtoReflect.Descriptor instead.

func (*GetGlobalStatusVarsRequest) GetVariables 

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

func (*GetGlobalStatusVarsRequest) MarshalToSizedBufferVT 

func (m *GetGlobalStatusVarsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetGlobalStatusVarsRequest) MarshalToVT 

func (m *GetGlobalStatusVarsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetGlobalStatusVarsRequest) MarshalVT 

func (m *GetGlobalStatusVarsRequest) MarshalVT() (dAtA []byte, err error)

func (*GetGlobalStatusVarsRequest) ProtoMessage 

func (*GetGlobalStatusVarsRequest) ProtoMessage()

func (*GetGlobalStatusVarsRequest) ProtoReflect 

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

func (*GetGlobalStatusVarsRequest) Reset 

func (x *GetGlobalStatusVarsRequest) Reset()

func (*GetGlobalStatusVarsRequest) SizeVT 

func (m *GetGlobalStatusVarsRequest) SizeVT() (n int)

func (*GetGlobalStatusVarsRequest) String 

func (x *GetGlobalStatusVarsRequest) String() string

func (*GetGlobalStatusVarsRequest) UnmarshalVT 

func (m *GetGlobalStatusVarsRequest) UnmarshalVT(dAtA []byte) error

type GetGlobalStatusVarsResponse 

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

func (*GetGlobalStatusVarsResponse) CloneMessageVT 

func (m *GetGlobalStatusVarsResponse) CloneMessageVT() proto.Message

func (*GetGlobalStatusVarsResponse) CloneVT 

func (m *GetGlobalStatusVarsResponse) CloneVT() *GetGlobalStatusVarsResponse

func (*GetGlobalStatusVarsResponse) Descriptor deprecated 

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

Deprecated: Use GetGlobalStatusVarsResponse.ProtoReflect.Descriptor instead.

func (*GetGlobalStatusVarsResponse) GetStatusValues 

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

func (*GetGlobalStatusVarsResponse) MarshalToSizedBufferVT 

func (m *GetGlobalStatusVarsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetGlobalStatusVarsResponse) MarshalToVT 

func (m *GetGlobalStatusVarsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetGlobalStatusVarsResponse) MarshalVT 

func (m *GetGlobalStatusVarsResponse) MarshalVT() (dAtA []byte, err error)

func (*GetGlobalStatusVarsResponse) ProtoMessage 

func (*GetGlobalStatusVarsResponse) ProtoMessage()

func (*GetGlobalStatusVarsResponse) ProtoReflect 

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

func (*GetGlobalStatusVarsResponse) Reset 

func (x *GetGlobalStatusVarsResponse) Reset()

func (*GetGlobalStatusVarsResponse) SizeVT 

func (m *GetGlobalStatusVarsResponse) SizeVT() (n int)

func (*GetGlobalStatusVarsResponse) String 

func (x *GetGlobalStatusVarsResponse) String() string

func (*GetGlobalStatusVarsResponse) UnmarshalVT 

func (m *GetGlobalStatusVarsResponse) UnmarshalVT(dAtA []byte) error

type GetPermissionsRequest 

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

func (*GetPermissionsRequest) CloneMessageVT 

func (m *GetPermissionsRequest) CloneMessageVT() proto.Message

func (*GetPermissionsRequest) CloneVT 

func (m *GetPermissionsRequest) CloneVT() *GetPermissionsRequest

func (*GetPermissionsRequest) Descriptor deprecated 

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

Deprecated: Use GetPermissionsRequest.ProtoReflect.Descriptor instead.

func (*GetPermissionsRequest) MarshalToSizedBufferVT 

func (m *GetPermissionsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetPermissionsRequest) MarshalToVT 

func (m *GetPermissionsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetPermissionsRequest) MarshalVT 

func (m *GetPermissionsRequest) MarshalVT() (dAtA []byte, err error)

func (*GetPermissionsRequest) ProtoMessage 

func (*GetPermissionsRequest) ProtoMessage()

func (*GetPermissionsRequest) ProtoReflect 

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

func (*GetPermissionsRequest) Reset 

func (x *GetPermissionsRequest) Reset()

func (*GetPermissionsRequest) SizeVT 

func (m *GetPermissionsRequest) SizeVT() (n int)

func (*GetPermissionsRequest) String 

func (x *GetPermissionsRequest) String() string

func (*GetPermissionsRequest) UnmarshalVT 

func (m *GetPermissionsRequest) UnmarshalVT(dAtA []byte) error

type GetPermissionsResponse 

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

func (*GetPermissionsResponse) CloneMessageVT 

func (m *GetPermissionsResponse) CloneMessageVT() proto.Message

func (*GetPermissionsResponse) CloneVT 

func (m *GetPermissionsResponse) CloneVT() *GetPermissionsResponse

func (*GetPermissionsResponse) Descriptor deprecated 

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

Deprecated: Use GetPermissionsResponse.ProtoReflect.Descriptor instead.

func (*GetPermissionsResponse) GetPermissions 

func (x *GetPermissionsResponse) GetPermissions() *Permissions

func (*GetPermissionsResponse) MarshalToSizedBufferVT 

func (m *GetPermissionsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetPermissionsResponse) MarshalToVT 

func (m *GetPermissionsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetPermissionsResponse) MarshalVT 

func (m *GetPermissionsResponse) MarshalVT() (dAtA []byte, err error)

func (*GetPermissionsResponse) ProtoMessage 

func (*GetPermissionsResponse) ProtoMessage()

func (*GetPermissionsResponse) ProtoReflect 

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

func (*GetPermissionsResponse) Reset 

func (x *GetPermissionsResponse) Reset()

func (*GetPermissionsResponse) SizeVT 

func (m *GetPermissionsResponse) SizeVT() (n int)

func (*GetPermissionsResponse) String 

func (x *GetPermissionsResponse) String() string

func (*GetPermissionsResponse) UnmarshalVT 

func (m *GetPermissionsResponse) UnmarshalVT(dAtA []byte) error

type GetReplicasRequest 

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

func (*GetReplicasRequest) CloneMessageVT 

func (m *GetReplicasRequest) CloneMessageVT() proto.Message

func (*GetReplicasRequest) CloneVT 

func (m *GetReplicasRequest) CloneVT() *GetReplicasRequest

func (*GetReplicasRequest) Descriptor deprecated 

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

Deprecated: Use GetReplicasRequest.ProtoReflect.Descriptor instead.

func (*GetReplicasRequest) MarshalToSizedBufferVT 

func (m *GetReplicasRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetReplicasRequest) MarshalToVT 

func (m *GetReplicasRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetReplicasRequest) MarshalVT 

func (m *GetReplicasRequest) MarshalVT() (dAtA []byte, err error)

func (*GetReplicasRequest) ProtoMessage 

func (*GetReplicasRequest) ProtoMessage()

func (*GetReplicasRequest) ProtoReflect 

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

func (*GetReplicasRequest) Reset 

func (x *GetReplicasRequest) Reset()

func (*GetReplicasRequest) SizeVT 

func (m *GetReplicasRequest) SizeVT() (n int)

func (*GetReplicasRequest) String 

func (x *GetReplicasRequest) String() string

func (*GetReplicasRequest) UnmarshalVT 

func (m *GetReplicasRequest) UnmarshalVT(dAtA []byte) error

type GetReplicasResponse 

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

func (*GetReplicasResponse) CloneMessageVT 

func (m *GetReplicasResponse) CloneMessageVT() proto.Message

func (*GetReplicasResponse) CloneVT 

func (m *GetReplicasResponse) CloneVT() *GetReplicasResponse

func (*GetReplicasResponse) Descriptor deprecated 

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

Deprecated: Use GetReplicasResponse.ProtoReflect.Descriptor instead.

func (*GetReplicasResponse) GetAddrs 

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

func (*GetReplicasResponse) MarshalToSizedBufferVT 

func (m *GetReplicasResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetReplicasResponse) MarshalToVT 

func (m *GetReplicasResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetReplicasResponse) MarshalVT 

func (m *GetReplicasResponse) MarshalVT() (dAtA []byte, err error)

func (*GetReplicasResponse) ProtoMessage 

func (*GetReplicasResponse) ProtoMessage()

func (*GetReplicasResponse) ProtoReflect 

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

func (*GetReplicasResponse) Reset 

func (x *GetReplicasResponse) Reset()

func (*GetReplicasResponse) SizeVT 

func (m *GetReplicasResponse) SizeVT() (n int)

func (*GetReplicasResponse) String 

func (x *GetReplicasResponse) String() string

func (*GetReplicasResponse) UnmarshalVT 

func (m *GetReplicasResponse) UnmarshalVT(dAtA []byte) error

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

func (m *GetSchemaRequest) CloneMessageVT() proto.Message

func (*GetSchemaRequest) CloneVT 

func (m *GetSchemaRequest) CloneVT() *GetSchemaRequest

func (*GetSchemaRequest) Descriptor deprecated 

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

Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.

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

func (m *GetSchemaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetSchemaRequest) MarshalToVT 

func (m *GetSchemaRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetSchemaRequest) MarshalVT 

func (m *GetSchemaRequest) MarshalVT() (dAtA []byte, err error)

func (*GetSchemaRequest) ProtoMessage 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) ProtoReflect 

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

func (*GetSchemaRequest) Reset 

func (x *GetSchemaRequest) Reset()

func (*GetSchemaRequest) SizeVT 

func (m *GetSchemaRequest) SizeVT() (n int)

func (*GetSchemaRequest) String 

func (x *GetSchemaRequest) String() string

func (*GetSchemaRequest) UnmarshalVT 

func (m *GetSchemaRequest) UnmarshalVT(dAtA []byte) error

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

func (m *GetSchemaResponse) CloneMessageVT() proto.Message

func (*GetSchemaResponse) CloneVT 

func (m *GetSchemaResponse) CloneVT() *GetSchemaResponse

func (*GetSchemaResponse) Descriptor deprecated 

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

Deprecated: Use GetSchemaResponse.ProtoReflect.Descriptor instead.

func (*GetSchemaResponse) GetSchemaDefinition 

func (x *GetSchemaResponse) GetSchemaDefinition() *SchemaDefinition

func (*GetSchemaResponse) MarshalToSizedBufferVT 

func (m *GetSchemaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetSchemaResponse) MarshalToVT 

func (m *GetSchemaResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetSchemaResponse) MarshalVT 

func (m *GetSchemaResponse) MarshalVT() (dAtA []byte, err error)

func (*GetSchemaResponse) ProtoMessage 

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) ProtoReflect 

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

func (*GetSchemaResponse) Reset 

func (x *GetSchemaResponse) Reset()

func (*GetSchemaResponse) SizeVT 

func (m *GetSchemaResponse) SizeVT() (n int)

func (*GetSchemaResponse) String 

func (x *GetSchemaResponse) String() string

func (*GetSchemaResponse) UnmarshalVT 

func (m *GetSchemaResponse) UnmarshalVT(dAtA []byte) error

type GetThrottlerStatusRequest 

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

func (*GetThrottlerStatusRequest) CloneMessageVT 

func (m *GetThrottlerStatusRequest) CloneMessageVT() proto.Message

func (*GetThrottlerStatusRequest) CloneVT 

func (m *GetThrottlerStatusRequest) CloneVT() *GetThrottlerStatusRequest

func (*GetThrottlerStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetThrottlerStatusRequest.ProtoReflect.Descriptor instead.

func (*GetThrottlerStatusRequest) MarshalToSizedBufferVT 

func (m *GetThrottlerStatusRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetThrottlerStatusRequest) MarshalToVT 

func (m *GetThrottlerStatusRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetThrottlerStatusRequest) MarshalVT 

func (m *GetThrottlerStatusRequest) MarshalVT() (dAtA []byte, err error)

func (*GetThrottlerStatusRequest) ProtoMessage 

func (*GetThrottlerStatusRequest) ProtoMessage()

func (*GetThrottlerStatusRequest) ProtoReflect 

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

func (*GetThrottlerStatusRequest) Reset 

func (x *GetThrottlerStatusRequest) Reset()

func (*GetThrottlerStatusRequest) SizeVT 

func (m *GetThrottlerStatusRequest) SizeVT() (n int)

func (*GetThrottlerStatusRequest) String 

func (x *GetThrottlerStatusRequest) String() string

func (*GetThrottlerStatusRequest) UnmarshalVT 

func (m *GetThrottlerStatusRequest) UnmarshalVT(dAtA []byte) error

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 `` /* 201-byte string literal not displayed */
	// MetricThresholds is a map of metric names to their thresholds.
	MetricThresholds map[string]float64 `` /* 200-byte string literal not displayed */
	// MetricsHealth is a map of metric names to their health status.
	MetricsHealth map[string]*GetThrottlerStatusResponse_MetricHealth `` /* 189-byte string literal not displayed */
	// ThrottledApps is a map of app names to their throttling rules
	ThrottledApps map[string]*topodata.ThrottledAppRule `` /* 189-byte string literal not displayed */
	// AppCheckedMetrics is a map of app names to their assigned metrics
	AppCheckedMetrics map[string]string `` /* 203-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 `` /* 180-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetThrottlerStatusResponse) CloneMessageVT 

func (m *GetThrottlerStatusResponse) CloneMessageVT() proto.Message

func (*GetThrottlerStatusResponse) CloneVT 

func (m *GetThrottlerStatusResponse) CloneVT() *GetThrottlerStatusResponse

func (*GetThrottlerStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetThrottlerStatusResponse.ProtoReflect.Descriptor instead.

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]*topodata.ThrottledAppRule

func (*GetThrottlerStatusResponse) MarshalToSizedBufferVT 

func (m *GetThrottlerStatusResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetThrottlerStatusResponse) MarshalToVT 

func (m *GetThrottlerStatusResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetThrottlerStatusResponse) MarshalVT 

func (m *GetThrottlerStatusResponse) MarshalVT() (dAtA []byte, err error)

func (*GetThrottlerStatusResponse) ProtoMessage 

func (*GetThrottlerStatusResponse) ProtoMessage()

func (*GetThrottlerStatusResponse) ProtoReflect 

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

func (*GetThrottlerStatusResponse) Reset 

func (x *GetThrottlerStatusResponse) Reset()

func (*GetThrottlerStatusResponse) SizeVT 

func (m *GetThrottlerStatusResponse) SizeVT() (n int)

func (*GetThrottlerStatusResponse) String 

func (x *GetThrottlerStatusResponse) String() string

func (*GetThrottlerStatusResponse) UnmarshalVT 

func (m *GetThrottlerStatusResponse) UnmarshalVT(dAtA []byte) error

type GetThrottlerStatusResponse_MetricHealth 

type GetThrottlerStatusResponse_MetricHealth struct {
	LastHealthyAt           *vttime.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) CloneMessageVT 

func (m *GetThrottlerStatusResponse_MetricHealth) CloneMessageVT() proto.Message

func (*GetThrottlerStatusResponse_MetricHealth) CloneVT 

func (m *GetThrottlerStatusResponse_MetricHealth) CloneVT() *GetThrottlerStatusResponse_MetricHealth

func (*GetThrottlerStatusResponse_MetricHealth) Descriptor deprecated 

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

Deprecated: Use GetThrottlerStatusResponse_MetricHealth.ProtoReflect.Descriptor instead.

func (*GetThrottlerStatusResponse_MetricHealth) GetLastHealthyAt 

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

func (*GetThrottlerStatusResponse_MetricHealth) GetSecondsSinceLastHealthy 

func (x *GetThrottlerStatusResponse_MetricHealth) GetSecondsSinceLastHealthy() int64

func (*GetThrottlerStatusResponse_MetricHealth) MarshalToSizedBufferVT 

func (m *GetThrottlerStatusResponse_MetricHealth) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetThrottlerStatusResponse_MetricHealth) MarshalToVT 

func (m *GetThrottlerStatusResponse_MetricHealth) MarshalToVT(dAtA []byte) (int, error)

func (*GetThrottlerStatusResponse_MetricHealth) MarshalVT 

func (m *GetThrottlerStatusResponse_MetricHealth) MarshalVT() (dAtA []byte, err error)

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

func (m *GetThrottlerStatusResponse_MetricHealth) SizeVT() (n int)

func (*GetThrottlerStatusResponse_MetricHealth) String 

func (x *GetThrottlerStatusResponse_MetricHealth) String() string

func (*GetThrottlerStatusResponse_MetricHealth) UnmarshalVT 

func (m *GetThrottlerStatusResponse_MetricHealth) UnmarshalVT(dAtA []byte) error

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

func (m *GetThrottlerStatusResponse_MetricResult) CloneMessageVT() proto.Message

func (*GetThrottlerStatusResponse_MetricResult) CloneVT 

func (m *GetThrottlerStatusResponse_MetricResult) CloneVT() *GetThrottlerStatusResponse_MetricResult

func (*GetThrottlerStatusResponse_MetricResult) Descriptor deprecated 

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

Deprecated: Use GetThrottlerStatusResponse_MetricResult.ProtoReflect.Descriptor instead.

func (*GetThrottlerStatusResponse_MetricResult) GetError 

func (x *GetThrottlerStatusResponse_MetricResult) GetError() string

func (*GetThrottlerStatusResponse_MetricResult) GetValue 

func (x *GetThrottlerStatusResponse_MetricResult) GetValue() float64

func (*GetThrottlerStatusResponse_MetricResult) MarshalToSizedBufferVT 

func (m *GetThrottlerStatusResponse_MetricResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetThrottlerStatusResponse_MetricResult) MarshalToVT 

func (m *GetThrottlerStatusResponse_MetricResult) MarshalToVT(dAtA []byte) (int, error)

func (*GetThrottlerStatusResponse_MetricResult) MarshalVT 

func (m *GetThrottlerStatusResponse_MetricResult) MarshalVT() (dAtA []byte, err error)

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

func (m *GetThrottlerStatusResponse_MetricResult) SizeVT() (n int)

func (*GetThrottlerStatusResponse_MetricResult) String 

func (x *GetThrottlerStatusResponse_MetricResult) String() string

func (*GetThrottlerStatusResponse_MetricResult) UnmarshalVT 

func (m *GetThrottlerStatusResponse_MetricResult) UnmarshalVT(dAtA []byte) error

type GetThrottlerStatusResponse_RecentApp 

type GetThrottlerStatusResponse_RecentApp struct {
	CheckedAt  *vttime.Time `protobuf:"bytes,1,opt,name=checked_at,json=checkedAt,proto3" json:"checked_at,omitempty"`
	StatusCode int32        `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// contains filtered or unexported fields
}

func (*GetThrottlerStatusResponse_RecentApp) CloneMessageVT 

func (m *GetThrottlerStatusResponse_RecentApp) CloneMessageVT() proto.Message

func (*GetThrottlerStatusResponse_RecentApp) CloneVT 

func (m *GetThrottlerStatusResponse_RecentApp) CloneVT() *GetThrottlerStatusResponse_RecentApp

func (*GetThrottlerStatusResponse_RecentApp) Descriptor deprecated 

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

Deprecated: Use GetThrottlerStatusResponse_RecentApp.ProtoReflect.Descriptor instead.

func (*GetThrottlerStatusResponse_RecentApp) GetCheckedAt 

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

func (*GetThrottlerStatusResponse_RecentApp) GetStatusCode 

func (x *GetThrottlerStatusResponse_RecentApp) GetStatusCode() int32

func (*GetThrottlerStatusResponse_RecentApp) MarshalToSizedBufferVT 

func (m *GetThrottlerStatusResponse_RecentApp) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetThrottlerStatusResponse_RecentApp) MarshalToVT 

func (m *GetThrottlerStatusResponse_RecentApp) MarshalToVT(dAtA []byte) (int, error)

func (*GetThrottlerStatusResponse_RecentApp) MarshalVT 

func (m *GetThrottlerStatusResponse_RecentApp) MarshalVT() (dAtA []byte, err error)

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

func (m *GetThrottlerStatusResponse_RecentApp) SizeVT() (n int)

func (*GetThrottlerStatusResponse_RecentApp) String 

func (x *GetThrottlerStatusResponse_RecentApp) String() string

func (*GetThrottlerStatusResponse_RecentApp) UnmarshalVT 

func (m *GetThrottlerStatusResponse_RecentApp) UnmarshalVT(dAtA []byte) error

type HasVReplicationWorkflowsRequest 

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

func (*HasVReplicationWorkflowsRequest) CloneMessageVT 

func (m *HasVReplicationWorkflowsRequest) CloneMessageVT() proto.Message

func (*HasVReplicationWorkflowsRequest) CloneVT 

func (m *HasVReplicationWorkflowsRequest) CloneVT() *HasVReplicationWorkflowsRequest

func (*HasVReplicationWorkflowsRequest) Descriptor deprecated 

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

Deprecated: Use HasVReplicationWorkflowsRequest.ProtoReflect.Descriptor instead.

func (*HasVReplicationWorkflowsRequest) MarshalToSizedBufferVT 

func (m *HasVReplicationWorkflowsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*HasVReplicationWorkflowsRequest) MarshalToVT 

func (m *HasVReplicationWorkflowsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*HasVReplicationWorkflowsRequest) MarshalVT 

func (m *HasVReplicationWorkflowsRequest) MarshalVT() (dAtA []byte, err error)

func (*HasVReplicationWorkflowsRequest) ProtoMessage 

func (*HasVReplicationWorkflowsRequest) ProtoMessage()

func (*HasVReplicationWorkflowsRequest) ProtoReflect 

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

func (*HasVReplicationWorkflowsRequest) Reset 

func (x *HasVReplicationWorkflowsRequest) Reset()

func (*HasVReplicationWorkflowsRequest) SizeVT 

func (m *HasVReplicationWorkflowsRequest) SizeVT() (n int)

func (*HasVReplicationWorkflowsRequest) String 

func (x *HasVReplicationWorkflowsRequest) String() string

func (*HasVReplicationWorkflowsRequest) UnmarshalVT 

func (m *HasVReplicationWorkflowsRequest) UnmarshalVT(dAtA []byte) error

type HasVReplicationWorkflowsResponse 

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

func (*HasVReplicationWorkflowsResponse) CloneMessageVT 

func (m *HasVReplicationWorkflowsResponse) CloneMessageVT() proto.Message

func (*HasVReplicationWorkflowsResponse) CloneVT 

func (m *HasVReplicationWorkflowsResponse) CloneVT() *HasVReplicationWorkflowsResponse

func (*HasVReplicationWorkflowsResponse) Descriptor deprecated 

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

Deprecated: Use HasVReplicationWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*HasVReplicationWorkflowsResponse) GetHas 

func (x *HasVReplicationWorkflowsResponse) GetHas() bool

func (*HasVReplicationWorkflowsResponse) MarshalToSizedBufferVT 

func (m *HasVReplicationWorkflowsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*HasVReplicationWorkflowsResponse) MarshalToVT 

func (m *HasVReplicationWorkflowsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*HasVReplicationWorkflowsResponse) MarshalVT 

func (m *HasVReplicationWorkflowsResponse) MarshalVT() (dAtA []byte, err error)

func (*HasVReplicationWorkflowsResponse) ProtoMessage 

func (*HasVReplicationWorkflowsResponse) ProtoMessage()

func (*HasVReplicationWorkflowsResponse) ProtoReflect 

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

func (*HasVReplicationWorkflowsResponse) Reset 

func (x *HasVReplicationWorkflowsResponse) Reset()

func (*HasVReplicationWorkflowsResponse) SizeVT 

func (m *HasVReplicationWorkflowsResponse) SizeVT() (n int)

func (*HasVReplicationWorkflowsResponse) String 

func (x *HasVReplicationWorkflowsResponse) String() string

func (*HasVReplicationWorkflowsResponse) UnmarshalVT 

func (m *HasVReplicationWorkflowsResponse) UnmarshalVT(dAtA []byte) error

type InitPrimaryRequest 

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

func (*InitPrimaryRequest) CloneMessageVT 

func (m *InitPrimaryRequest) CloneMessageVT() proto.Message

func (*InitPrimaryRequest) CloneVT 

func (m *InitPrimaryRequest) CloneVT() *InitPrimaryRequest

func (*InitPrimaryRequest) Descriptor deprecated 

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

Deprecated: Use InitPrimaryRequest.ProtoReflect.Descriptor instead.

func (*InitPrimaryRequest) GetSemiSync 

func (x *InitPrimaryRequest) GetSemiSync() bool

func (*InitPrimaryRequest) MarshalToSizedBufferVT 

func (m *InitPrimaryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*InitPrimaryRequest) MarshalToVT 

func (m *InitPrimaryRequest) MarshalToVT(dAtA []byte) (int, error)

func (*InitPrimaryRequest) MarshalVT 

func (m *InitPrimaryRequest) MarshalVT() (dAtA []byte, err error)

func (*InitPrimaryRequest) ProtoMessage 

func (*InitPrimaryRequest) ProtoMessage()

func (*InitPrimaryRequest) ProtoReflect 

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

func (*InitPrimaryRequest) Reset 

func (x *InitPrimaryRequest) Reset()

func (*InitPrimaryRequest) SizeVT 

func (m *InitPrimaryRequest) SizeVT() (n int)

func (*InitPrimaryRequest) String 

func (x *InitPrimaryRequest) String() string

func (*InitPrimaryRequest) UnmarshalVT 

func (m *InitPrimaryRequest) UnmarshalVT(dAtA []byte) error

type InitPrimaryResponse 

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

func (*InitPrimaryResponse) CloneMessageVT 

func (m *InitPrimaryResponse) CloneMessageVT() proto.Message

func (*InitPrimaryResponse) CloneVT 

func (m *InitPrimaryResponse) CloneVT() *InitPrimaryResponse

func (*InitPrimaryResponse) Descriptor deprecated 

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

Deprecated: Use InitPrimaryResponse.ProtoReflect.Descriptor instead.

func (*InitPrimaryResponse) GetPosition 

func (x *InitPrimaryResponse) GetPosition() string

func (*InitPrimaryResponse) MarshalToSizedBufferVT 

func (m *InitPrimaryResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*InitPrimaryResponse) MarshalToVT 

func (m *InitPrimaryResponse) MarshalToVT(dAtA []byte) (int, error)

func (*InitPrimaryResponse) MarshalVT 

func (m *InitPrimaryResponse) MarshalVT() (dAtA []byte, err error)

func (*InitPrimaryResponse) ProtoMessage 

func (*InitPrimaryResponse) ProtoMessage()

func (*InitPrimaryResponse) ProtoReflect 

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

func (*InitPrimaryResponse) Reset 

func (x *InitPrimaryResponse) Reset()

func (*InitPrimaryResponse) SizeVT 

func (m *InitPrimaryResponse) SizeVT() (n int)

func (*InitPrimaryResponse) String 

func (x *InitPrimaryResponse) String() string

func (*InitPrimaryResponse) UnmarshalVT 

func (m *InitPrimaryResponse) UnmarshalVT(dAtA []byte) error

type InitReplicaRequest 

type InitReplicaRequest struct {
	Parent              *topodata.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) CloneMessageVT 

func (m *InitReplicaRequest) CloneMessageVT() proto.Message

func (*InitReplicaRequest) CloneVT 

func (m *InitReplicaRequest) CloneVT() *InitReplicaRequest

func (*InitReplicaRequest) Descriptor deprecated 

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

Deprecated: Use InitReplicaRequest.ProtoReflect.Descriptor instead.

func (*InitReplicaRequest) GetParent 

func (x *InitReplicaRequest) GetParent() *topodata.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) MarshalToSizedBufferVT 

func (m *InitReplicaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*InitReplicaRequest) MarshalToVT 

func (m *InitReplicaRequest) MarshalToVT(dAtA []byte) (int, error)

func (*InitReplicaRequest) MarshalVT 

func (m *InitReplicaRequest) MarshalVT() (dAtA []byte, err error)

func (*InitReplicaRequest) ProtoMessage 

func (*InitReplicaRequest) ProtoMessage()

func (*InitReplicaRequest) ProtoReflect 

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

func (*InitReplicaRequest) Reset 

func (x *InitReplicaRequest) Reset()

func (*InitReplicaRequest) SizeVT 

func (m *InitReplicaRequest) SizeVT() (n int)

func (*InitReplicaRequest) String 

func (x *InitReplicaRequest) String() string

func (*InitReplicaRequest) UnmarshalVT 

func (m *InitReplicaRequest) UnmarshalVT(dAtA []byte) error

type InitReplicaResponse 

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

func (*InitReplicaResponse) CloneMessageVT 

func (m *InitReplicaResponse) CloneMessageVT() proto.Message

func (*InitReplicaResponse) CloneVT 

func (m *InitReplicaResponse) CloneVT() *InitReplicaResponse

func (*InitReplicaResponse) Descriptor deprecated 

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

Deprecated: Use InitReplicaResponse.ProtoReflect.Descriptor instead.

func (*InitReplicaResponse) MarshalToSizedBufferVT 

func (m *InitReplicaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*InitReplicaResponse) MarshalToVT 

func (m *InitReplicaResponse) MarshalToVT(dAtA []byte) (int, error)

func (*InitReplicaResponse) MarshalVT 

func (m *InitReplicaResponse) MarshalVT() (dAtA []byte, err error)

func (*InitReplicaResponse) ProtoMessage 

func (*InitReplicaResponse) ProtoMessage()

func (*InitReplicaResponse) ProtoReflect 

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

func (*InitReplicaResponse) Reset 

func (x *InitReplicaResponse) Reset()

func (*InitReplicaResponse) SizeVT 

func (m *InitReplicaResponse) SizeVT() (n int)

func (*InitReplicaResponse) String 

func (x *InitReplicaResponse) String() string

func (*InitReplicaResponse) UnmarshalVT 

func (m *InitReplicaResponse) UnmarshalVT(dAtA []byte) error

type LockTablesRequest 

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

func (*LockTablesRequest) CloneMessageVT 

func (m *LockTablesRequest) CloneMessageVT() proto.Message

func (*LockTablesRequest) CloneVT 

func (m *LockTablesRequest) CloneVT() *LockTablesRequest

func (*LockTablesRequest) Descriptor deprecated 

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

Deprecated: Use LockTablesRequest.ProtoReflect.Descriptor instead.

func (*LockTablesRequest) MarshalToSizedBufferVT 

func (m *LockTablesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LockTablesRequest) MarshalToVT 

func (m *LockTablesRequest) MarshalToVT(dAtA []byte) (int, error)

func (*LockTablesRequest) MarshalVT 

func (m *LockTablesRequest) MarshalVT() (dAtA []byte, err error)

func (*LockTablesRequest) ProtoMessage 

func (*LockTablesRequest) ProtoMessage()

func (*LockTablesRequest) ProtoReflect 

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

func (*LockTablesRequest) Reset 

func (x *LockTablesRequest) Reset()

func (*LockTablesRequest) SizeVT 

func (m *LockTablesRequest) SizeVT() (n int)

func (*LockTablesRequest) String 

func (x *LockTablesRequest) String() string

func (*LockTablesRequest) UnmarshalVT 

func (m *LockTablesRequest) UnmarshalVT(dAtA []byte) error

type LockTablesResponse 

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

func (*LockTablesResponse) CloneMessageVT 

func (m *LockTablesResponse) CloneMessageVT() proto.Message

func (*LockTablesResponse) CloneVT 

func (m *LockTablesResponse) CloneVT() *LockTablesResponse

func (*LockTablesResponse) Descriptor deprecated 

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

Deprecated: Use LockTablesResponse.ProtoReflect.Descriptor instead.

func (*LockTablesResponse) MarshalToSizedBufferVT 

func (m *LockTablesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LockTablesResponse) MarshalToVT 

func (m *LockTablesResponse) MarshalToVT(dAtA []byte) (int, error)

func (*LockTablesResponse) MarshalVT 

func (m *LockTablesResponse) MarshalVT() (dAtA []byte, err error)

func (*LockTablesResponse) ProtoMessage 

func (*LockTablesResponse) ProtoMessage()

func (*LockTablesResponse) ProtoReflect 

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

func (*LockTablesResponse) Reset 

func (x *LockTablesResponse) Reset()

func (*LockTablesResponse) SizeVT 

func (m *LockTablesResponse) SizeVT() (n int)

func (*LockTablesResponse) String 

func (x *LockTablesResponse) String() string

func (*LockTablesResponse) UnmarshalVT 

func (m *LockTablesResponse) UnmarshalVT(dAtA []byte) error

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

func (m *Permissions) CloneMessageVT() proto.Message

func (*Permissions) CloneVT 

func (m *Permissions) CloneVT() *Permissions

func (*Permissions) Descriptor deprecated 

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

Deprecated: Use Permissions.ProtoReflect.Descriptor instead.

func (*Permissions) GetDbPermissions 

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

func (*Permissions) GetUserPermissions 

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

func (*Permissions) MarshalToSizedBufferVT 

func (m *Permissions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Permissions) MarshalToVT 

func (m *Permissions) MarshalToVT(dAtA []byte) (int, error)

func (*Permissions) MarshalVT 

func (m *Permissions) MarshalVT() (dAtA []byte, err error)

func (*Permissions) ProtoMessage 

func (*Permissions) ProtoMessage()

func (*Permissions) ProtoReflect 

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

func (*Permissions) Reset 

func (x *Permissions) Reset()

func (*Permissions) SizeVT 

func (m *Permissions) SizeVT() (n int)

func (*Permissions) String 

func (x *Permissions) String() string

func (*Permissions) UnmarshalVT 

func (m *Permissions) UnmarshalVT(dAtA []byte) error

type PingRequest 

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

func (*PingRequest) CloneMessageVT 

func (m *PingRequest) CloneMessageVT() proto.Message

func (*PingRequest) CloneVT 

func (m *PingRequest) CloneVT() *PingRequest

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) GetPayload 

func (x *PingRequest) GetPayload() string

func (*PingRequest) MarshalToSizedBufferVT 

func (m *PingRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PingRequest) MarshalToVT 

func (m *PingRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PingRequest) MarshalVT 

func (m *PingRequest) MarshalVT() (dAtA []byte, err error)

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) SizeVT 

func (m *PingRequest) SizeVT() (n int)

func (*PingRequest) String 

func (x *PingRequest) String() string

func (*PingRequest) UnmarshalVT 

func (m *PingRequest) UnmarshalVT(dAtA []byte) error

type PingResponse 

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

func (*PingResponse) CloneMessageVT 

func (m *PingResponse) CloneMessageVT() proto.Message

func (*PingResponse) CloneVT 

func (m *PingResponse) CloneVT() *PingResponse

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetPayload 

func (x *PingResponse) GetPayload() string

func (*PingResponse) MarshalToSizedBufferVT 

func (m *PingResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PingResponse) MarshalToVT 

func (m *PingResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PingResponse) MarshalVT 

func (m *PingResponse) MarshalVT() (dAtA []byte, err error)

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) SizeVT 

func (m *PingResponse) SizeVT() (n int)

func (*PingResponse) String 

func (x *PingResponse) String() string

func (*PingResponse) UnmarshalVT 

func (m *PingResponse) UnmarshalVT(dAtA []byte) error

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        *topodata.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) CloneMessageVT 

func (m *PopulateReparentJournalRequest) CloneMessageVT() proto.Message

func (*PopulateReparentJournalRequest) CloneVT 

func (m *PopulateReparentJournalRequest) CloneVT() *PopulateReparentJournalRequest

func (*PopulateReparentJournalRequest) Descriptor deprecated 

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

Deprecated: Use PopulateReparentJournalRequest.ProtoReflect.Descriptor instead.

func (*PopulateReparentJournalRequest) GetActionName 

func (x *PopulateReparentJournalRequest) GetActionName() string

func (*PopulateReparentJournalRequest) GetPrimaryAlias 

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

func (*PopulateReparentJournalRequest) GetReplicationPosition 

func (x *PopulateReparentJournalRequest) GetReplicationPosition() string

func (*PopulateReparentJournalRequest) GetTimeCreatedNs 

func (x *PopulateReparentJournalRequest) GetTimeCreatedNs() int64

func (*PopulateReparentJournalRequest) MarshalToSizedBufferVT 

func (m *PopulateReparentJournalRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PopulateReparentJournalRequest) MarshalToVT 

func (m *PopulateReparentJournalRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PopulateReparentJournalRequest) MarshalVT 

func (m *PopulateReparentJournalRequest) MarshalVT() (dAtA []byte, err error)

func (*PopulateReparentJournalRequest) ProtoMessage 

func (*PopulateReparentJournalRequest) ProtoMessage()

func (*PopulateReparentJournalRequest) ProtoReflect 

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

func (*PopulateReparentJournalRequest) Reset 

func (x *PopulateReparentJournalRequest) Reset()

func (*PopulateReparentJournalRequest) SizeVT 

func (m *PopulateReparentJournalRequest) SizeVT() (n int)

func (*PopulateReparentJournalRequest) String 

func (x *PopulateReparentJournalRequest) String() string

func (*PopulateReparentJournalRequest) UnmarshalVT 

func (m *PopulateReparentJournalRequest) UnmarshalVT(dAtA []byte) error

type PopulateReparentJournalResponse 

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

func (*PopulateReparentJournalResponse) CloneMessageVT 

func (m *PopulateReparentJournalResponse) CloneMessageVT() proto.Message

func (*PopulateReparentJournalResponse) CloneVT 

func (m *PopulateReparentJournalResponse) CloneVT() *PopulateReparentJournalResponse

func (*PopulateReparentJournalResponse) Descriptor deprecated 

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

Deprecated: Use PopulateReparentJournalResponse.ProtoReflect.Descriptor instead.

func (*PopulateReparentJournalResponse) MarshalToSizedBufferVT 

func (m *PopulateReparentJournalResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PopulateReparentJournalResponse) MarshalToVT 

func (m *PopulateReparentJournalResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PopulateReparentJournalResponse) MarshalVT 

func (m *PopulateReparentJournalResponse) MarshalVT() (dAtA []byte, err error)

func (*PopulateReparentJournalResponse) ProtoMessage 

func (*PopulateReparentJournalResponse) ProtoMessage()

func (*PopulateReparentJournalResponse) ProtoReflect 

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

func (*PopulateReparentJournalResponse) Reset 

func (x *PopulateReparentJournalResponse) Reset()

func (*PopulateReparentJournalResponse) SizeVT 

func (m *PopulateReparentJournalResponse) SizeVT() (n int)

func (*PopulateReparentJournalResponse) String 

func (x *PopulateReparentJournalResponse) String() string

func (*PopulateReparentJournalResponse) UnmarshalVT 

func (m *PopulateReparentJournalResponse) UnmarshalVT(dAtA []byte) error

type PreflightSchemaRequest 

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

func (*PreflightSchemaRequest) CloneMessageVT 

func (m *PreflightSchemaRequest) CloneMessageVT() proto.Message

func (*PreflightSchemaRequest) CloneVT 

func (m *PreflightSchemaRequest) CloneVT() *PreflightSchemaRequest

func (*PreflightSchemaRequest) Descriptor deprecated 

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

Deprecated: Use PreflightSchemaRequest.ProtoReflect.Descriptor instead.

func (*PreflightSchemaRequest) GetChanges 

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

func (*PreflightSchemaRequest) MarshalToSizedBufferVT 

func (m *PreflightSchemaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PreflightSchemaRequest) MarshalToVT 

func (m *PreflightSchemaRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PreflightSchemaRequest) MarshalVT 

func (m *PreflightSchemaRequest) MarshalVT() (dAtA []byte, err error)

func (*PreflightSchemaRequest) ProtoMessage 

func (*PreflightSchemaRequest) ProtoMessage()

func (*PreflightSchemaRequest) ProtoReflect 

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

func (*PreflightSchemaRequest) Reset 

func (x *PreflightSchemaRequest) Reset()

func (*PreflightSchemaRequest) SizeVT 

func (m *PreflightSchemaRequest) SizeVT() (n int)

func (*PreflightSchemaRequest) String 

func (x *PreflightSchemaRequest) String() string

func (*PreflightSchemaRequest) UnmarshalVT 

func (m *PreflightSchemaRequest) UnmarshalVT(dAtA []byte) error

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

func (m *PreflightSchemaResponse) CloneMessageVT() proto.Message

func (*PreflightSchemaResponse) CloneVT 

func (m *PreflightSchemaResponse) CloneVT() *PreflightSchemaResponse

func (*PreflightSchemaResponse) Descriptor deprecated 

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

Deprecated: Use PreflightSchemaResponse.ProtoReflect.Descriptor instead.

func (*PreflightSchemaResponse) GetChangeResults 

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

func (*PreflightSchemaResponse) MarshalToSizedBufferVT 

func (m *PreflightSchemaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PreflightSchemaResponse) MarshalToVT 

func (m *PreflightSchemaResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PreflightSchemaResponse) MarshalVT 

func (m *PreflightSchemaResponse) MarshalVT() (dAtA []byte, err error)

func (*PreflightSchemaResponse) ProtoMessage 

func (*PreflightSchemaResponse) ProtoMessage()

func (*PreflightSchemaResponse) ProtoReflect 

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

func (*PreflightSchemaResponse) Reset 

func (x *PreflightSchemaResponse) Reset()

func (*PreflightSchemaResponse) SizeVT 

func (m *PreflightSchemaResponse) SizeVT() (n int)

func (*PreflightSchemaResponse) String 

func (x *PreflightSchemaResponse) String() string

func (*PreflightSchemaResponse) UnmarshalVT 

func (m *PreflightSchemaResponse) UnmarshalVT(dAtA []byte) error

type PrimaryPositionRequest 

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

func (*PrimaryPositionRequest) CloneMessageVT 

func (m *PrimaryPositionRequest) CloneMessageVT() proto.Message

func (*PrimaryPositionRequest) CloneVT 

func (m *PrimaryPositionRequest) CloneVT() *PrimaryPositionRequest

func (*PrimaryPositionRequest) Descriptor deprecated 

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

Deprecated: Use PrimaryPositionRequest.ProtoReflect.Descriptor instead.

func (*PrimaryPositionRequest) MarshalToSizedBufferVT 

func (m *PrimaryPositionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PrimaryPositionRequest) MarshalToVT 

func (m *PrimaryPositionRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PrimaryPositionRequest) MarshalVT 

func (m *PrimaryPositionRequest) MarshalVT() (dAtA []byte, err error)

func (*PrimaryPositionRequest) ProtoMessage 

func (*PrimaryPositionRequest) ProtoMessage()

func (*PrimaryPositionRequest) ProtoReflect 

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

func (*PrimaryPositionRequest) Reset 

func (x *PrimaryPositionRequest) Reset()

func (*PrimaryPositionRequest) SizeVT 

func (m *PrimaryPositionRequest) SizeVT() (n int)

func (*PrimaryPositionRequest) String 

func (x *PrimaryPositionRequest) String() string

func (*PrimaryPositionRequest) UnmarshalVT 

func (m *PrimaryPositionRequest) UnmarshalVT(dAtA []byte) error

type PrimaryPositionResponse 

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

func (*PrimaryPositionResponse) CloneMessageVT 

func (m *PrimaryPositionResponse) CloneMessageVT() proto.Message

func (*PrimaryPositionResponse) CloneVT 

func (m *PrimaryPositionResponse) CloneVT() *PrimaryPositionResponse

func (*PrimaryPositionResponse) Descriptor deprecated 

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

Deprecated: Use PrimaryPositionResponse.ProtoReflect.Descriptor instead.

func (*PrimaryPositionResponse) GetPosition 

func (x *PrimaryPositionResponse) GetPosition() string

func (*PrimaryPositionResponse) MarshalToSizedBufferVT 

func (m *PrimaryPositionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PrimaryPositionResponse) MarshalToVT 

func (m *PrimaryPositionResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PrimaryPositionResponse) MarshalVT 

func (m *PrimaryPositionResponse) MarshalVT() (dAtA []byte, err error)

func (*PrimaryPositionResponse) ProtoMessage 

func (*PrimaryPositionResponse) ProtoMessage()

func (*PrimaryPositionResponse) ProtoReflect 

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

func (*PrimaryPositionResponse) Reset 

func (x *PrimaryPositionResponse) Reset()

func (*PrimaryPositionResponse) SizeVT 

func (m *PrimaryPositionResponse) SizeVT() (n int)

func (*PrimaryPositionResponse) String 

func (x *PrimaryPositionResponse) String() string

func (*PrimaryPositionResponse) UnmarshalVT 

func (m *PrimaryPositionResponse) UnmarshalVT(dAtA []byte) error

type PrimaryStatusRequest 

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

func (*PrimaryStatusRequest) CloneMessageVT 

func (m *PrimaryStatusRequest) CloneMessageVT() proto.Message

func (*PrimaryStatusRequest) CloneVT 

func (m *PrimaryStatusRequest) CloneVT() *PrimaryStatusRequest

func (*PrimaryStatusRequest) Descriptor deprecated 

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

Deprecated: Use PrimaryStatusRequest.ProtoReflect.Descriptor instead.

func (*PrimaryStatusRequest) MarshalToSizedBufferVT 

func (m *PrimaryStatusRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PrimaryStatusRequest) MarshalToVT 

func (m *PrimaryStatusRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PrimaryStatusRequest) MarshalVT 

func (m *PrimaryStatusRequest) MarshalVT() (dAtA []byte, err error)

func (*PrimaryStatusRequest) ProtoMessage 

func (*PrimaryStatusRequest) ProtoMessage()

func (*PrimaryStatusRequest) ProtoReflect 

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

func (*PrimaryStatusRequest) Reset 

func (x *PrimaryStatusRequest) Reset()

func (*PrimaryStatusRequest) SizeVT 

func (m *PrimaryStatusRequest) SizeVT() (n int)

func (*PrimaryStatusRequest) String 

func (x *PrimaryStatusRequest) String() string

func (*PrimaryStatusRequest) UnmarshalVT 

func (m *PrimaryStatusRequest) UnmarshalVT(dAtA []byte) error

type PrimaryStatusResponse 

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

func (*PrimaryStatusResponse) CloneMessageVT 

func (m *PrimaryStatusResponse) CloneMessageVT() proto.Message

func (*PrimaryStatusResponse) CloneVT 

func (m *PrimaryStatusResponse) CloneVT() *PrimaryStatusResponse

func (*PrimaryStatusResponse) Descriptor deprecated 

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

Deprecated: Use PrimaryStatusResponse.ProtoReflect.Descriptor instead.

func (*PrimaryStatusResponse) GetStatus 

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

func (*PrimaryStatusResponse) MarshalToSizedBufferVT 

func (m *PrimaryStatusResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PrimaryStatusResponse) MarshalToVT 

func (m *PrimaryStatusResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PrimaryStatusResponse) MarshalVT 

func (m *PrimaryStatusResponse) MarshalVT() (dAtA []byte, err error)

func (*PrimaryStatusResponse) ProtoMessage 

func (*PrimaryStatusResponse) ProtoMessage()

func (*PrimaryStatusResponse) ProtoReflect 

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

func (*PrimaryStatusResponse) Reset 

func (x *PrimaryStatusResponse) Reset()

func (*PrimaryStatusResponse) SizeVT 

func (m *PrimaryStatusResponse) SizeVT() (n int)

func (*PrimaryStatusResponse) String 

func (x *PrimaryStatusResponse) String() string

func (*PrimaryStatusResponse) UnmarshalVT 

func (m *PrimaryStatusResponse) UnmarshalVT(dAtA []byte) error

type PromoteReplicaRequest 

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

func (*PromoteReplicaRequest) CloneMessageVT 

func (m *PromoteReplicaRequest) CloneMessageVT() proto.Message

func (*PromoteReplicaRequest) CloneVT 

func (m *PromoteReplicaRequest) CloneVT() *PromoteReplicaRequest

func (*PromoteReplicaRequest) Descriptor deprecated 

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

Deprecated: Use PromoteReplicaRequest.ProtoReflect.Descriptor instead.

func (*PromoteReplicaRequest) GetSemiSync 

func (x *PromoteReplicaRequest) GetSemiSync() bool

func (*PromoteReplicaRequest) MarshalToSizedBufferVT 

func (m *PromoteReplicaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PromoteReplicaRequest) MarshalToVT 

func (m *PromoteReplicaRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PromoteReplicaRequest) MarshalVT 

func (m *PromoteReplicaRequest) MarshalVT() (dAtA []byte, err error)

func (*PromoteReplicaRequest) ProtoMessage 

func (*PromoteReplicaRequest) ProtoMessage()

func (*PromoteReplicaRequest) ProtoReflect 

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

func (*PromoteReplicaRequest) Reset 

func (x *PromoteReplicaRequest) Reset()

func (*PromoteReplicaRequest) SizeVT 

func (m *PromoteReplicaRequest) SizeVT() (n int)

func (*PromoteReplicaRequest) String 

func (x *PromoteReplicaRequest) String() string

func (*PromoteReplicaRequest) UnmarshalVT 

func (m *PromoteReplicaRequest) UnmarshalVT(dAtA []byte) error

type PromoteReplicaResponse 

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

func (*PromoteReplicaResponse) CloneMessageVT 

func (m *PromoteReplicaResponse) CloneMessageVT() proto.Message

func (*PromoteReplicaResponse) CloneVT 

func (m *PromoteReplicaResponse) CloneVT() *PromoteReplicaResponse

func (*PromoteReplicaResponse) Descriptor deprecated 

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

Deprecated: Use PromoteReplicaResponse.ProtoReflect.Descriptor instead.

func (*PromoteReplicaResponse) GetPosition 

func (x *PromoteReplicaResponse) GetPosition() string

func (*PromoteReplicaResponse) MarshalToSizedBufferVT 

func (m *PromoteReplicaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PromoteReplicaResponse) MarshalToVT 

func (m *PromoteReplicaResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PromoteReplicaResponse) MarshalVT 

func (m *PromoteReplicaResponse) MarshalVT() (dAtA []byte, err error)

func (*PromoteReplicaResponse) ProtoMessage 

func (*PromoteReplicaResponse) ProtoMessage()

func (*PromoteReplicaResponse) ProtoReflect 

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

func (*PromoteReplicaResponse) Reset 

func (x *PromoteReplicaResponse) Reset()

func (*PromoteReplicaResponse) SizeVT 

func (m *PromoteReplicaResponse) SizeVT() (n int)

func (*PromoteReplicaResponse) String 

func (x *PromoteReplicaResponse) String() string

func (*PromoteReplicaResponse) UnmarshalVT 

func (m *PromoteReplicaResponse) UnmarshalVT(dAtA []byte) error

type ReadVReplicationWorkflowRequest 

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

func (*ReadVReplicationWorkflowRequest) CloneMessageVT 

func (m *ReadVReplicationWorkflowRequest) CloneMessageVT() proto.Message

func (*ReadVReplicationWorkflowRequest) CloneVT 

func (m *ReadVReplicationWorkflowRequest) CloneVT() *ReadVReplicationWorkflowRequest

func (*ReadVReplicationWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use ReadVReplicationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*ReadVReplicationWorkflowRequest) GetWorkflow 

func (x *ReadVReplicationWorkflowRequest) GetWorkflow() string

func (*ReadVReplicationWorkflowRequest) MarshalToSizedBufferVT 

func (m *ReadVReplicationWorkflowRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReadVReplicationWorkflowRequest) MarshalToVT 

func (m *ReadVReplicationWorkflowRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ReadVReplicationWorkflowRequest) MarshalVT 

func (m *ReadVReplicationWorkflowRequest) MarshalVT() (dAtA []byte, err error)

func (*ReadVReplicationWorkflowRequest) ProtoMessage 

func (*ReadVReplicationWorkflowRequest) ProtoMessage()

func (*ReadVReplicationWorkflowRequest) ProtoReflect 

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

func (*ReadVReplicationWorkflowRequest) Reset 

func (x *ReadVReplicationWorkflowRequest) Reset()

func (*ReadVReplicationWorkflowRequest) SizeVT 

func (m *ReadVReplicationWorkflowRequest) SizeVT() (n int)

func (*ReadVReplicationWorkflowRequest) String 

func (x *ReadVReplicationWorkflowRequest) String() string

func (*ReadVReplicationWorkflowRequest) UnmarshalVT 

func (m *ReadVReplicationWorkflowRequest) UnmarshalVT(dAtA []byte) error

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               []topodata.TabletType                      `` /* 127-byte string literal not displayed */
	TabletSelectionPreference TabletSelectionPreference                  `` /* 188-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              binlogdata.VReplicationWorkflowType        `` /* 139-byte string literal not displayed */
	WorkflowSubType           binlogdata.VReplicationWorkflowSubType     `` /* 153-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"`
	// contains filtered or unexported fields
}

func (*ReadVReplicationWorkflowResponse) CloneMessageVT 

func (m *ReadVReplicationWorkflowResponse) CloneMessageVT() proto.Message

func (*ReadVReplicationWorkflowResponse) CloneVT 

func (m *ReadVReplicationWorkflowResponse) CloneVT() *ReadVReplicationWorkflowResponse

func (*ReadVReplicationWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use ReadVReplicationWorkflowResponse.ProtoReflect.Descriptor instead.

func (*ReadVReplicationWorkflowResponse) GetCells 

func (x *ReadVReplicationWorkflowResponse) GetCells() 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() []topodata.TabletType

func (*ReadVReplicationWorkflowResponse) GetTags 

func (x *ReadVReplicationWorkflowResponse) GetTags() string

func (*ReadVReplicationWorkflowResponse) GetWorkflow 

func (x *ReadVReplicationWorkflowResponse) GetWorkflow() string

func (*ReadVReplicationWorkflowResponse) GetWorkflowSubType 

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

func (*ReadVReplicationWorkflowResponse) GetWorkflowType 

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

func (*ReadVReplicationWorkflowResponse) MarshalToSizedBufferVT 

func (m *ReadVReplicationWorkflowResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReadVReplicationWorkflowResponse) MarshalToVT 

func (m *ReadVReplicationWorkflowResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ReadVReplicationWorkflowResponse) MarshalVT 

func (m *ReadVReplicationWorkflowResponse) MarshalVT() (dAtA []byte, err error)

func (*ReadVReplicationWorkflowResponse) ProtoMessage 

func (*ReadVReplicationWorkflowResponse) ProtoMessage()

func (*ReadVReplicationWorkflowResponse) ProtoReflect 

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

func (*ReadVReplicationWorkflowResponse) Reset 

func (x *ReadVReplicationWorkflowResponse) Reset()

func (*ReadVReplicationWorkflowResponse) SizeVT 

func (m *ReadVReplicationWorkflowResponse) SizeVT() (n int)

func (*ReadVReplicationWorkflowResponse) String 

func (x *ReadVReplicationWorkflowResponse) String() string

func (*ReadVReplicationWorkflowResponse) UnmarshalVT 

func (m *ReadVReplicationWorkflowResponse) UnmarshalVT(dAtA []byte) error

type ReadVReplicationWorkflowResponse_Stream 

type ReadVReplicationWorkflowResponse_Stream struct {
	Id                   int32                                `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Bls                  *binlogdata.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          *vttime.Time                         `protobuf:"bytes,7,opt,name=time_updated,json=timeUpdated,proto3" json:"time_updated,omitempty"`
	TransactionTimestamp *vttime.Time                         `protobuf:"bytes,8,opt,name=transaction_timestamp,json=transactionTimestamp,proto3" json:"transaction_timestamp,omitempty"`
	State                binlogdata.VReplicationWorkflowState `protobuf:"varint,9,opt,name=state,proto3,enum=binlogdata.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        *vttime.Time                         `protobuf:"bytes,12,opt,name=time_heartbeat,json=timeHeartbeat,proto3" json:"time_heartbeat,omitempty"`
	TimeThrottled        *vttime.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) CloneMessageVT 

func (m *ReadVReplicationWorkflowResponse_Stream) CloneMessageVT() proto.Message

func (*ReadVReplicationWorkflowResponse_Stream) CloneVT 

func (m *ReadVReplicationWorkflowResponse_Stream) CloneVT() *ReadVReplicationWorkflowResponse_Stream

func (*ReadVReplicationWorkflowResponse_Stream) Descriptor deprecated 

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

Deprecated: Use ReadVReplicationWorkflowResponse_Stream.ProtoReflect.Descriptor instead.

func (*ReadVReplicationWorkflowResponse_Stream) GetBls 

func (x *ReadVReplicationWorkflowResponse_Stream) GetBls() *binlogdata.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() binlogdata.VReplicationWorkflowState

func (*ReadVReplicationWorkflowResponse_Stream) GetStopPos 

func (x *ReadVReplicationWorkflowResponse_Stream) GetStopPos() string

func (*ReadVReplicationWorkflowResponse_Stream) GetTimeHeartbeat 

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

func (*ReadVReplicationWorkflowResponse_Stream) GetTimeThrottled 

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

func (*ReadVReplicationWorkflowResponse_Stream) GetTimeUpdated 

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

func (*ReadVReplicationWorkflowResponse_Stream) GetTransactionTimestamp 

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

func (*ReadVReplicationWorkflowResponse_Stream) MarshalToSizedBufferVT 

func (m *ReadVReplicationWorkflowResponse_Stream) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReadVReplicationWorkflowResponse_Stream) MarshalToVT 

func (m *ReadVReplicationWorkflowResponse_Stream) MarshalToVT(dAtA []byte) (int, error)

func (*ReadVReplicationWorkflowResponse_Stream) MarshalVT 

func (m *ReadVReplicationWorkflowResponse_Stream) MarshalVT() (dAtA []byte, err error)

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

func (m *ReadVReplicationWorkflowResponse_Stream) SizeVT() (n int)

func (*ReadVReplicationWorkflowResponse_Stream) String 

func (x *ReadVReplicationWorkflowResponse_Stream) String() string

func (*ReadVReplicationWorkflowResponse_Stream) UnmarshalVT 

func (m *ReadVReplicationWorkflowResponse_Stream) UnmarshalVT(dAtA []byte) error

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    []binlogdata.VReplicationWorkflowState `` /* 150-byte string literal not displayed */
	ExcludeWorkflows []string                               `protobuf:"bytes,4,rep,name=exclude_workflows,json=excludeWorkflows,proto3" json:"exclude_workflows,omitempty"`
	ExcludeStates    []binlogdata.VReplicationWorkflowState `` /* 150-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) CloneMessageVT 

func (m *ReadVReplicationWorkflowsRequest) CloneMessageVT() proto.Message

func (*ReadVReplicationWorkflowsRequest) CloneVT 

func (m *ReadVReplicationWorkflowsRequest) CloneVT() *ReadVReplicationWorkflowsRequest

func (*ReadVReplicationWorkflowsRequest) Descriptor deprecated 

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

Deprecated: Use ReadVReplicationWorkflowsRequest.ProtoReflect.Descriptor instead.

func (*ReadVReplicationWorkflowsRequest) GetExcludeFrozen 

func (x *ReadVReplicationWorkflowsRequest) GetExcludeFrozen() bool

func (*ReadVReplicationWorkflowsRequest) GetExcludeStates 

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

func (*ReadVReplicationWorkflowsRequest) GetExcludeWorkflows 

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

func (*ReadVReplicationWorkflowsRequest) GetIncludeIds 

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

func (*ReadVReplicationWorkflowsRequest) GetIncludeStates 

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

func (*ReadVReplicationWorkflowsRequest) GetIncludeWorkflows 

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

func (*ReadVReplicationWorkflowsRequest) MarshalToSizedBufferVT 

func (m *ReadVReplicationWorkflowsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReadVReplicationWorkflowsRequest) MarshalToVT 

func (m *ReadVReplicationWorkflowsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ReadVReplicationWorkflowsRequest) MarshalVT 

func (m *ReadVReplicationWorkflowsRequest) MarshalVT() (dAtA []byte, err error)

func (*ReadVReplicationWorkflowsRequest) ProtoMessage 

func (*ReadVReplicationWorkflowsRequest) ProtoMessage()

func (*ReadVReplicationWorkflowsRequest) ProtoReflect 

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

func (*ReadVReplicationWorkflowsRequest) Reset 

func (x *ReadVReplicationWorkflowsRequest) Reset()

func (*ReadVReplicationWorkflowsRequest) SizeVT 

func (m *ReadVReplicationWorkflowsRequest) SizeVT() (n int)

func (*ReadVReplicationWorkflowsRequest) String 

func (x *ReadVReplicationWorkflowsRequest) String() string

func (*ReadVReplicationWorkflowsRequest) UnmarshalVT 

func (m *ReadVReplicationWorkflowsRequest) UnmarshalVT(dAtA []byte) error

type ReadVReplicationWorkflowsResponse 

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

func (*ReadVReplicationWorkflowsResponse) CloneMessageVT 

func (m *ReadVReplicationWorkflowsResponse) CloneMessageVT() proto.Message

func (*ReadVReplicationWorkflowsResponse) CloneVT 

func (m *ReadVReplicationWorkflowsResponse) CloneVT() *ReadVReplicationWorkflowsResponse

func (*ReadVReplicationWorkflowsResponse) Descriptor deprecated 

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

Deprecated: Use ReadVReplicationWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*ReadVReplicationWorkflowsResponse) GetWorkflows 

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

func (*ReadVReplicationWorkflowsResponse) MarshalToSizedBufferVT 

func (m *ReadVReplicationWorkflowsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReadVReplicationWorkflowsResponse) MarshalToVT 

func (m *ReadVReplicationWorkflowsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ReadVReplicationWorkflowsResponse) MarshalVT 

func (m *ReadVReplicationWorkflowsResponse) MarshalVT() (dAtA []byte, err error)

func (*ReadVReplicationWorkflowsResponse) ProtoMessage 

func (*ReadVReplicationWorkflowsResponse) ProtoMessage()

func (*ReadVReplicationWorkflowsResponse) ProtoReflect 

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

func (*ReadVReplicationWorkflowsResponse) Reset 

func (x *ReadVReplicationWorkflowsResponse) Reset()

func (*ReadVReplicationWorkflowsResponse) SizeVT 

func (m *ReadVReplicationWorkflowsResponse) SizeVT() (n int)

func (*ReadVReplicationWorkflowsResponse) String 

func (x *ReadVReplicationWorkflowsResponse) String() string

func (*ReadVReplicationWorkflowsResponse) UnmarshalVT 

func (m *ReadVReplicationWorkflowsResponse) UnmarshalVT(dAtA []byte) error

type RefreshStateRequest 

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

func (*RefreshStateRequest) CloneMessageVT 

func (m *RefreshStateRequest) CloneMessageVT() proto.Message

func (*RefreshStateRequest) CloneVT 

func (m *RefreshStateRequest) CloneVT() *RefreshStateRequest

func (*RefreshStateRequest) Descriptor deprecated 

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

Deprecated: Use RefreshStateRequest.ProtoReflect.Descriptor instead.

func (*RefreshStateRequest) MarshalToSizedBufferVT 

func (m *RefreshStateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RefreshStateRequest) MarshalToVT 

func (m *RefreshStateRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RefreshStateRequest) MarshalVT 

func (m *RefreshStateRequest) MarshalVT() (dAtA []byte, err error)

func (*RefreshStateRequest) ProtoMessage 

func (*RefreshStateRequest) ProtoMessage()

func (*RefreshStateRequest) ProtoReflect 

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

func (*RefreshStateRequest) Reset 

func (x *RefreshStateRequest) Reset()

func (*RefreshStateRequest) SizeVT 

func (m *RefreshStateRequest) SizeVT() (n int)

func (*RefreshStateRequest) String 

func (x *RefreshStateRequest) String() string

func (*RefreshStateRequest) UnmarshalVT 

func (m *RefreshStateRequest) UnmarshalVT(dAtA []byte) error

type RefreshStateResponse 

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

func (*RefreshStateResponse) CloneMessageVT 

func (m *RefreshStateResponse) CloneMessageVT() proto.Message

func (*RefreshStateResponse) CloneVT 

func (m *RefreshStateResponse) CloneVT() *RefreshStateResponse

func (*RefreshStateResponse) Descriptor deprecated 

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

Deprecated: Use RefreshStateResponse.ProtoReflect.Descriptor instead.

func (*RefreshStateResponse) MarshalToSizedBufferVT 

func (m *RefreshStateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RefreshStateResponse) MarshalToVT 

func (m *RefreshStateResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RefreshStateResponse) MarshalVT 

func (m *RefreshStateResponse) MarshalVT() (dAtA []byte, err error)

func (*RefreshStateResponse) ProtoMessage 

func (*RefreshStateResponse) ProtoMessage()

func (*RefreshStateResponse) ProtoReflect 

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

func (*RefreshStateResponse) Reset 

func (x *RefreshStateResponse) Reset()

func (*RefreshStateResponse) SizeVT 

func (m *RefreshStateResponse) SizeVT() (n int)

func (*RefreshStateResponse) String 

func (x *RefreshStateResponse) String() string

func (*RefreshStateResponse) UnmarshalVT 

func (m *RefreshStateResponse) UnmarshalVT(dAtA []byte) error

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

func (m *ReloadSchemaRequest) CloneMessageVT() proto.Message

func (*ReloadSchemaRequest) CloneVT 

func (m *ReloadSchemaRequest) CloneVT() *ReloadSchemaRequest

func (*ReloadSchemaRequest) Descriptor deprecated 

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

Deprecated: Use ReloadSchemaRequest.ProtoReflect.Descriptor instead.

func (*ReloadSchemaRequest) GetWaitPosition 

func (x *ReloadSchemaRequest) GetWaitPosition() string

func (*ReloadSchemaRequest) MarshalToSizedBufferVT 

func (m *ReloadSchemaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReloadSchemaRequest) MarshalToVT 

func (m *ReloadSchemaRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ReloadSchemaRequest) MarshalVT 

func (m *ReloadSchemaRequest) MarshalVT() (dAtA []byte, err error)

func (*ReloadSchemaRequest) ProtoMessage 

func (*ReloadSchemaRequest) ProtoMessage()

func (*ReloadSchemaRequest) ProtoReflect 

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

func (*ReloadSchemaRequest) Reset 

func (x *ReloadSchemaRequest) Reset()

func (*ReloadSchemaRequest) SizeVT 

func (m *ReloadSchemaRequest) SizeVT() (n int)

func (*ReloadSchemaRequest) String 

func (x *ReloadSchemaRequest) String() string

func (*ReloadSchemaRequest) UnmarshalVT 

func (m *ReloadSchemaRequest) UnmarshalVT(dAtA []byte) error

type ReloadSchemaResponse 

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

func (*ReloadSchemaResponse) CloneMessageVT 

func (m *ReloadSchemaResponse) CloneMessageVT() proto.Message

func (*ReloadSchemaResponse) CloneVT 

func (m *ReloadSchemaResponse) CloneVT() *ReloadSchemaResponse

func (*ReloadSchemaResponse) Descriptor deprecated 

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

Deprecated: Use ReloadSchemaResponse.ProtoReflect.Descriptor instead.

func (*ReloadSchemaResponse) MarshalToSizedBufferVT 

func (m *ReloadSchemaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReloadSchemaResponse) MarshalToVT 

func (m *ReloadSchemaResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ReloadSchemaResponse) MarshalVT 

func (m *ReloadSchemaResponse) MarshalVT() (dAtA []byte, err error)

func (*ReloadSchemaResponse) ProtoMessage 

func (*ReloadSchemaResponse) ProtoMessage()

func (*ReloadSchemaResponse) ProtoReflect 

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

func (*ReloadSchemaResponse) Reset 

func (x *ReloadSchemaResponse) Reset()

func (*ReloadSchemaResponse) SizeVT 

func (m *ReloadSchemaResponse) SizeVT() (n int)

func (*ReloadSchemaResponse) String 

func (x *ReloadSchemaResponse) String() string

func (*ReloadSchemaResponse) UnmarshalVT 

func (m *ReloadSchemaResponse) UnmarshalVT(dAtA []byte) error

type ReplicaWasPromotedRequest 

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

func (*ReplicaWasPromotedRequest) CloneMessageVT 

func (m *ReplicaWasPromotedRequest) CloneMessageVT() proto.Message

func (*ReplicaWasPromotedRequest) CloneVT 

func (m *ReplicaWasPromotedRequest) CloneVT() *ReplicaWasPromotedRequest

func (*ReplicaWasPromotedRequest) Descriptor deprecated 

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

Deprecated: Use ReplicaWasPromotedRequest.ProtoReflect.Descriptor instead.

func (*ReplicaWasPromotedRequest) MarshalToSizedBufferVT 

func (m *ReplicaWasPromotedRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReplicaWasPromotedRequest) MarshalToVT 

func (m *ReplicaWasPromotedRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ReplicaWasPromotedRequest) MarshalVT 

func (m *ReplicaWasPromotedRequest) MarshalVT() (dAtA []byte, err error)

func (*ReplicaWasPromotedRequest) ProtoMessage 

func (*ReplicaWasPromotedRequest) ProtoMessage()

func (*ReplicaWasPromotedRequest) ProtoReflect 

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

func (*ReplicaWasPromotedRequest) Reset 

func (x *ReplicaWasPromotedRequest) Reset()

func (*ReplicaWasPromotedRequest) SizeVT 

func (m *ReplicaWasPromotedRequest) SizeVT() (n int)

func (*ReplicaWasPromotedRequest) String 

func (x *ReplicaWasPromotedRequest) String() string

func (*ReplicaWasPromotedRequest) UnmarshalVT 

func (m *ReplicaWasPromotedRequest) UnmarshalVT(dAtA []byte) error

type ReplicaWasPromotedResponse 

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

func (*ReplicaWasPromotedResponse) CloneMessageVT 

func (m *ReplicaWasPromotedResponse) CloneMessageVT() proto.Message

func (*ReplicaWasPromotedResponse) CloneVT 

func (m *ReplicaWasPromotedResponse) CloneVT() *ReplicaWasPromotedResponse

func (*ReplicaWasPromotedResponse) Descriptor deprecated 

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

Deprecated: Use ReplicaWasPromotedResponse.ProtoReflect.Descriptor instead.

func (*ReplicaWasPromotedResponse) MarshalToSizedBufferVT 

func (m *ReplicaWasPromotedResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReplicaWasPromotedResponse) MarshalToVT 

func (m *ReplicaWasPromotedResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ReplicaWasPromotedResponse) MarshalVT 

func (m *ReplicaWasPromotedResponse) MarshalVT() (dAtA []byte, err error)

func (*ReplicaWasPromotedResponse) ProtoMessage 

func (*ReplicaWasPromotedResponse) ProtoMessage()

func (*ReplicaWasPromotedResponse) ProtoReflect 

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

func (*ReplicaWasPromotedResponse) Reset 

func (x *ReplicaWasPromotedResponse) Reset()

func (*ReplicaWasPromotedResponse) SizeVT 

func (m *ReplicaWasPromotedResponse) SizeVT() (n int)

func (*ReplicaWasPromotedResponse) String 

func (x *ReplicaWasPromotedResponse) String() string

func (*ReplicaWasPromotedResponse) UnmarshalVT 

func (m *ReplicaWasPromotedResponse) UnmarshalVT(dAtA []byte) error

type ReplicaWasRestartedRequest 

type ReplicaWasRestartedRequest struct {

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

func (*ReplicaWasRestartedRequest) CloneMessageVT 

func (m *ReplicaWasRestartedRequest) CloneMessageVT() proto.Message

func (*ReplicaWasRestartedRequest) CloneVT 

func (m *ReplicaWasRestartedRequest) CloneVT() *ReplicaWasRestartedRequest

func (*ReplicaWasRestartedRequest) Descriptor deprecated 

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

Deprecated: Use ReplicaWasRestartedRequest.ProtoReflect.Descriptor instead.

func (*ReplicaWasRestartedRequest) GetParent 

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

func (*ReplicaWasRestartedRequest) MarshalToSizedBufferVT 

func (m *ReplicaWasRestartedRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReplicaWasRestartedRequest) MarshalToVT 

func (m *ReplicaWasRestartedRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ReplicaWasRestartedRequest) MarshalVT 

func (m *ReplicaWasRestartedRequest) MarshalVT() (dAtA []byte, err error)

func (*ReplicaWasRestartedRequest) ProtoMessage 

func (*ReplicaWasRestartedRequest) ProtoMessage()

func (*ReplicaWasRestartedRequest) ProtoReflect 

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

func (*ReplicaWasRestartedRequest) Reset 

func (x *ReplicaWasRestartedRequest) Reset()

func (*ReplicaWasRestartedRequest) SizeVT 

func (m *ReplicaWasRestartedRequest) SizeVT() (n int)

func (*ReplicaWasRestartedRequest) String 

func (x *ReplicaWasRestartedRequest) String() string

func (*ReplicaWasRestartedRequest) UnmarshalVT 

func (m *ReplicaWasRestartedRequest) UnmarshalVT(dAtA []byte) error

type ReplicaWasRestartedResponse 

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

func (*ReplicaWasRestartedResponse) CloneMessageVT 

func (m *ReplicaWasRestartedResponse) CloneMessageVT() proto.Message

func (*ReplicaWasRestartedResponse) CloneVT 

func (m *ReplicaWasRestartedResponse) CloneVT() *ReplicaWasRestartedResponse

func (*ReplicaWasRestartedResponse) Descriptor deprecated 

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

Deprecated: Use ReplicaWasRestartedResponse.ProtoReflect.Descriptor instead.

func (*ReplicaWasRestartedResponse) MarshalToSizedBufferVT 

func (m *ReplicaWasRestartedResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReplicaWasRestartedResponse) MarshalToVT 

func (m *ReplicaWasRestartedResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ReplicaWasRestartedResponse) MarshalVT 

func (m *ReplicaWasRestartedResponse) MarshalVT() (dAtA []byte, err error)

func (*ReplicaWasRestartedResponse) ProtoMessage 

func (*ReplicaWasRestartedResponse) ProtoMessage()

func (*ReplicaWasRestartedResponse) ProtoReflect 

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

func (*ReplicaWasRestartedResponse) Reset 

func (x *ReplicaWasRestartedResponse) Reset()

func (*ReplicaWasRestartedResponse) SizeVT 

func (m *ReplicaWasRestartedResponse) SizeVT() (n int)

func (*ReplicaWasRestartedResponse) String 

func (x *ReplicaWasRestartedResponse) String() string

func (*ReplicaWasRestartedResponse) UnmarshalVT 

func (m *ReplicaWasRestartedResponse) UnmarshalVT(dAtA []byte) error

type ReplicationStatusRequest 

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

func (*ReplicationStatusRequest) CloneMessageVT 

func (m *ReplicationStatusRequest) CloneMessageVT() proto.Message

func (*ReplicationStatusRequest) CloneVT 

func (m *ReplicationStatusRequest) CloneVT() *ReplicationStatusRequest

func (*ReplicationStatusRequest) Descriptor deprecated 

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

Deprecated: Use ReplicationStatusRequest.ProtoReflect.Descriptor instead.

func (*ReplicationStatusRequest) MarshalToSizedBufferVT 

func (m *ReplicationStatusRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReplicationStatusRequest) MarshalToVT 

func (m *ReplicationStatusRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ReplicationStatusRequest) MarshalVT 

func (m *ReplicationStatusRequest) MarshalVT() (dAtA []byte, err error)

func (*ReplicationStatusRequest) ProtoMessage 

func (*ReplicationStatusRequest) ProtoMessage()

func (*ReplicationStatusRequest) ProtoReflect 

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

func (*ReplicationStatusRequest) Reset 

func (x *ReplicationStatusRequest) Reset()

func (*ReplicationStatusRequest) SizeVT 

func (m *ReplicationStatusRequest) SizeVT() (n int)

func (*ReplicationStatusRequest) String 

func (x *ReplicationStatusRequest) String() string

func (*ReplicationStatusRequest) UnmarshalVT 

func (m *ReplicationStatusRequest) UnmarshalVT(dAtA []byte) error

type ReplicationStatusResponse 

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

func (*ReplicationStatusResponse) CloneMessageVT 

func (m *ReplicationStatusResponse) CloneMessageVT() proto.Message

func (*ReplicationStatusResponse) CloneVT 

func (m *ReplicationStatusResponse) CloneVT() *ReplicationStatusResponse

func (*ReplicationStatusResponse) Descriptor deprecated 

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

Deprecated: Use ReplicationStatusResponse.ProtoReflect.Descriptor instead.

func (*ReplicationStatusResponse) GetStatus 

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

func (*ReplicationStatusResponse) MarshalToSizedBufferVT 

func (m *ReplicationStatusResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReplicationStatusResponse) MarshalToVT 

func (m *ReplicationStatusResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ReplicationStatusResponse) MarshalVT 

func (m *ReplicationStatusResponse) MarshalVT() (dAtA []byte, err error)

func (*ReplicationStatusResponse) ProtoMessage 

func (*ReplicationStatusResponse) ProtoMessage()

func (*ReplicationStatusResponse) ProtoReflect 

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

func (*ReplicationStatusResponse) Reset 

func (x *ReplicationStatusResponse) Reset()

func (*ReplicationStatusResponse) SizeVT 

func (m *ReplicationStatusResponse) SizeVT() (n int)

func (*ReplicationStatusResponse) String 

func (x *ReplicationStatusResponse) String() string

func (*ReplicationStatusResponse) UnmarshalVT 

func (m *ReplicationStatusResponse) UnmarshalVT(dAtA []byte) error

type ResetReplicationParametersRequest 

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

func (*ResetReplicationParametersRequest) CloneMessageVT 

func (m *ResetReplicationParametersRequest) CloneMessageVT() proto.Message

func (*ResetReplicationParametersRequest) CloneVT 

func (m *ResetReplicationParametersRequest) CloneVT() *ResetReplicationParametersRequest

func (*ResetReplicationParametersRequest) Descriptor deprecated 

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

Deprecated: Use ResetReplicationParametersRequest.ProtoReflect.Descriptor instead.

func (*ResetReplicationParametersRequest) MarshalToSizedBufferVT 

func (m *ResetReplicationParametersRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ResetReplicationParametersRequest) MarshalToVT 

func (m *ResetReplicationParametersRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ResetReplicationParametersRequest) MarshalVT 

func (m *ResetReplicationParametersRequest) MarshalVT() (dAtA []byte, err error)

func (*ResetReplicationParametersRequest) ProtoMessage 

func (*ResetReplicationParametersRequest) ProtoMessage()

func (*ResetReplicationParametersRequest) ProtoReflect 

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

func (*ResetReplicationParametersRequest) Reset 

func (x *ResetReplicationParametersRequest) Reset()

func (*ResetReplicationParametersRequest) SizeVT 

func (m *ResetReplicationParametersRequest) SizeVT() (n int)

func (*ResetReplicationParametersRequest) String 

func (x *ResetReplicationParametersRequest) String() string

func (*ResetReplicationParametersRequest) UnmarshalVT 

func (m *ResetReplicationParametersRequest) UnmarshalVT(dAtA []byte) error

type ResetReplicationParametersResponse 

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

func (*ResetReplicationParametersResponse) CloneMessageVT 

func (m *ResetReplicationParametersResponse) CloneMessageVT() proto.Message

func (*ResetReplicationParametersResponse) CloneVT 

func (m *ResetReplicationParametersResponse) CloneVT() *ResetReplicationParametersResponse

func (*ResetReplicationParametersResponse) Descriptor deprecated 

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

Deprecated: Use ResetReplicationParametersResponse.ProtoReflect.Descriptor instead.

func (*ResetReplicationParametersResponse) MarshalToSizedBufferVT 

func (m *ResetReplicationParametersResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ResetReplicationParametersResponse) MarshalToVT 

func (m *ResetReplicationParametersResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ResetReplicationParametersResponse) MarshalVT 

func (m *ResetReplicationParametersResponse) MarshalVT() (dAtA []byte, err error)

func (*ResetReplicationParametersResponse) ProtoMessage 

func (*ResetReplicationParametersResponse) ProtoMessage()

func (*ResetReplicationParametersResponse) ProtoReflect 

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

func (*ResetReplicationParametersResponse) Reset 

func (x *ResetReplicationParametersResponse) Reset()

func (*ResetReplicationParametersResponse) SizeVT 

func (m *ResetReplicationParametersResponse) SizeVT() (n int)

func (*ResetReplicationParametersResponse) String 

func (x *ResetReplicationParametersResponse) String() string

func (*ResetReplicationParametersResponse) UnmarshalVT 

func (m *ResetReplicationParametersResponse) UnmarshalVT(dAtA []byte) error

type ResetReplicationRequest 

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

func (*ResetReplicationRequest) CloneMessageVT 

func (m *ResetReplicationRequest) CloneMessageVT() proto.Message

func (*ResetReplicationRequest) CloneVT 

func (m *ResetReplicationRequest) CloneVT() *ResetReplicationRequest

func (*ResetReplicationRequest) Descriptor deprecated 

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

Deprecated: Use ResetReplicationRequest.ProtoReflect.Descriptor instead.

func (*ResetReplicationRequest) MarshalToSizedBufferVT 

func (m *ResetReplicationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ResetReplicationRequest) MarshalToVT 

func (m *ResetReplicationRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ResetReplicationRequest) MarshalVT 

func (m *ResetReplicationRequest) MarshalVT() (dAtA []byte, err error)

func (*ResetReplicationRequest) ProtoMessage 

func (*ResetReplicationRequest) ProtoMessage()

func (*ResetReplicationRequest) ProtoReflect 

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

func (*ResetReplicationRequest) Reset 

func (x *ResetReplicationRequest) Reset()

func (*ResetReplicationRequest) SizeVT 

func (m *ResetReplicationRequest) SizeVT() (n int)

func (*ResetReplicationRequest) String 

func (x *ResetReplicationRequest) String() string

func (*ResetReplicationRequest) UnmarshalVT 

func (m *ResetReplicationRequest) UnmarshalVT(dAtA []byte) error

type ResetReplicationResponse 

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

func (*ResetReplicationResponse) CloneMessageVT 

func (m *ResetReplicationResponse) CloneMessageVT() proto.Message

func (*ResetReplicationResponse) CloneVT 

func (m *ResetReplicationResponse) CloneVT() *ResetReplicationResponse

func (*ResetReplicationResponse) Descriptor deprecated 

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

Deprecated: Use ResetReplicationResponse.ProtoReflect.Descriptor instead.

func (*ResetReplicationResponse) MarshalToSizedBufferVT 

func (m *ResetReplicationResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ResetReplicationResponse) MarshalToVT 

func (m *ResetReplicationResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ResetReplicationResponse) MarshalVT 

func (m *ResetReplicationResponse) MarshalVT() (dAtA []byte, err error)

func (*ResetReplicationResponse) ProtoMessage 

func (*ResetReplicationResponse) ProtoMessage()

func (*ResetReplicationResponse) ProtoReflect 

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

func (*ResetReplicationResponse) Reset 

func (x *ResetReplicationResponse) Reset()

func (*ResetReplicationResponse) SizeVT 

func (m *ResetReplicationResponse) SizeVT() (n int)

func (*ResetReplicationResponse) String 

func (x *ResetReplicationResponse) String() string

func (*ResetReplicationResponse) UnmarshalVT 

func (m *ResetReplicationResponse) UnmarshalVT(dAtA []byte) error

type ResetSequencesRequest 

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

func (*ResetSequencesRequest) CloneMessageVT 

func (m *ResetSequencesRequest) CloneMessageVT() proto.Message

func (*ResetSequencesRequest) CloneVT 

func (m *ResetSequencesRequest) CloneVT() *ResetSequencesRequest

func (*ResetSequencesRequest) Descriptor deprecated 

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

Deprecated: Use ResetSequencesRequest.ProtoReflect.Descriptor instead.

func (*ResetSequencesRequest) GetTables 

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

func (*ResetSequencesRequest) MarshalToSizedBufferVT 

func (m *ResetSequencesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ResetSequencesRequest) MarshalToVT 

func (m *ResetSequencesRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ResetSequencesRequest) MarshalVT 

func (m *ResetSequencesRequest) MarshalVT() (dAtA []byte, err error)

func (*ResetSequencesRequest) ProtoMessage 

func (*ResetSequencesRequest) ProtoMessage()

func (*ResetSequencesRequest) ProtoReflect 

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

func (*ResetSequencesRequest) Reset 

func (x *ResetSequencesRequest) Reset()

func (*ResetSequencesRequest) SizeVT 

func (m *ResetSequencesRequest) SizeVT() (n int)

func (*ResetSequencesRequest) String 

func (x *ResetSequencesRequest) String() string

func (*ResetSequencesRequest) UnmarshalVT 

func (m *ResetSequencesRequest) UnmarshalVT(dAtA []byte) error

type ResetSequencesResponse 

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

func (*ResetSequencesResponse) CloneMessageVT 

func (m *ResetSequencesResponse) CloneMessageVT() proto.Message

func (*ResetSequencesResponse) CloneVT 

func (m *ResetSequencesResponse) CloneVT() *ResetSequencesResponse

func (*ResetSequencesResponse) Descriptor deprecated 

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

Deprecated: Use ResetSequencesResponse.ProtoReflect.Descriptor instead.

func (*ResetSequencesResponse) MarshalToSizedBufferVT 

func (m *ResetSequencesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ResetSequencesResponse) MarshalToVT 

func (m *ResetSequencesResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ResetSequencesResponse) MarshalVT 

func (m *ResetSequencesResponse) MarshalVT() (dAtA []byte, err error)

func (*ResetSequencesResponse) ProtoMessage 

func (*ResetSequencesResponse) ProtoMessage()

func (*ResetSequencesResponse) ProtoReflect 

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

func (*ResetSequencesResponse) Reset 

func (x *ResetSequencesResponse) Reset()

func (*ResetSequencesResponse) SizeVT 

func (m *ResetSequencesResponse) SizeVT() (n int)

func (*ResetSequencesResponse) String 

func (x *ResetSequencesResponse) String() string

func (*ResetSequencesResponse) UnmarshalVT 

func (m *ResetSequencesResponse) UnmarshalVT(dAtA []byte) error

type RestoreFromBackupRequest 

type RestoreFromBackupRequest struct {
	BackupTime *vttime.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 *vttime.Time `protobuf:"bytes,4,opt,name=restore_to_timestamp,json=restoreToTimestamp,proto3" json:"restore_to_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreFromBackupRequest) CloneMessageVT 

func (m *RestoreFromBackupRequest) CloneMessageVT() proto.Message

func (*RestoreFromBackupRequest) CloneVT 

func (m *RestoreFromBackupRequest) CloneVT() *RestoreFromBackupRequest

func (*RestoreFromBackupRequest) Descriptor deprecated 

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

Deprecated: Use RestoreFromBackupRequest.ProtoReflect.Descriptor instead.

func (*RestoreFromBackupRequest) GetBackupTime 

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

func (*RestoreFromBackupRequest) GetDryRun 

func (x *RestoreFromBackupRequest) GetDryRun() bool

func (*RestoreFromBackupRequest) GetRestoreToPos 

func (x *RestoreFromBackupRequest) GetRestoreToPos() string

func (*RestoreFromBackupRequest) GetRestoreToTimestamp 

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

func (*RestoreFromBackupRequest) MarshalToSizedBufferVT 

func (m *RestoreFromBackupRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RestoreFromBackupRequest) MarshalToVT 

func (m *RestoreFromBackupRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RestoreFromBackupRequest) MarshalVT 

func (m *RestoreFromBackupRequest) MarshalVT() (dAtA []byte, err error)

func (*RestoreFromBackupRequest) ProtoMessage 

func (*RestoreFromBackupRequest) ProtoMessage()

func (*RestoreFromBackupRequest) ProtoReflect 

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

func (*RestoreFromBackupRequest) Reset 

func (x *RestoreFromBackupRequest) Reset()

func (*RestoreFromBackupRequest) SizeVT 

func (m *RestoreFromBackupRequest) SizeVT() (n int)

func (*RestoreFromBackupRequest) String 

func (x *RestoreFromBackupRequest) String() string

func (*RestoreFromBackupRequest) UnmarshalVT 

func (m *RestoreFromBackupRequest) UnmarshalVT(dAtA []byte) error

type RestoreFromBackupResponse 

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

func (*RestoreFromBackupResponse) CloneMessageVT 

func (m *RestoreFromBackupResponse) CloneMessageVT() proto.Message

func (*RestoreFromBackupResponse) CloneVT 

func (m *RestoreFromBackupResponse) CloneVT() *RestoreFromBackupResponse

func (*RestoreFromBackupResponse) Descriptor deprecated 

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

Deprecated: Use RestoreFromBackupResponse.ProtoReflect.Descriptor instead.

func (*RestoreFromBackupResponse) GetEvent 

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

func (*RestoreFromBackupResponse) MarshalToSizedBufferVT 

func (m *RestoreFromBackupResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RestoreFromBackupResponse) MarshalToVT 

func (m *RestoreFromBackupResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RestoreFromBackupResponse) MarshalVT 

func (m *RestoreFromBackupResponse) MarshalVT() (dAtA []byte, err error)

func (*RestoreFromBackupResponse) ProtoMessage 

func (*RestoreFromBackupResponse) ProtoMessage()

func (*RestoreFromBackupResponse) ProtoReflect 

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

func (*RestoreFromBackupResponse) Reset 

func (x *RestoreFromBackupResponse) Reset()

func (*RestoreFromBackupResponse) SizeVT 

func (m *RestoreFromBackupResponse) SizeVT() (n int)

func (*RestoreFromBackupResponse) String 

func (x *RestoreFromBackupResponse) String() string

func (*RestoreFromBackupResponse) UnmarshalVT 

func (m *RestoreFromBackupResponse) UnmarshalVT(dAtA []byte) error

type RunHealthCheckRequest 

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

func (*RunHealthCheckRequest) CloneMessageVT 

func (m *RunHealthCheckRequest) CloneMessageVT() proto.Message

func (*RunHealthCheckRequest) CloneVT 

func (m *RunHealthCheckRequest) CloneVT() *RunHealthCheckRequest

func (*RunHealthCheckRequest) Descriptor deprecated 

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

Deprecated: Use RunHealthCheckRequest.ProtoReflect.Descriptor instead.

func (*RunHealthCheckRequest) MarshalToSizedBufferVT 

func (m *RunHealthCheckRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RunHealthCheckRequest) MarshalToVT 

func (m *RunHealthCheckRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RunHealthCheckRequest) MarshalVT 

func (m *RunHealthCheckRequest) MarshalVT() (dAtA []byte, err error)

func (*RunHealthCheckRequest) ProtoMessage 

func (*RunHealthCheckRequest) ProtoMessage()

func (*RunHealthCheckRequest) ProtoReflect 

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

func (*RunHealthCheckRequest) Reset 

func (x *RunHealthCheckRequest) Reset()

func (*RunHealthCheckRequest) SizeVT 

func (m *RunHealthCheckRequest) SizeVT() (n int)

func (*RunHealthCheckRequest) String 

func (x *RunHealthCheckRequest) String() string

func (*RunHealthCheckRequest) UnmarshalVT 

func (m *RunHealthCheckRequest) UnmarshalVT(dAtA []byte) error

type RunHealthCheckResponse 

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

func (*RunHealthCheckResponse) CloneMessageVT 

func (m *RunHealthCheckResponse) CloneMessageVT() proto.Message

func (*RunHealthCheckResponse) CloneVT 

func (m *RunHealthCheckResponse) CloneVT() *RunHealthCheckResponse

func (*RunHealthCheckResponse) Descriptor deprecated 

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

Deprecated: Use RunHealthCheckResponse.ProtoReflect.Descriptor instead.

func (*RunHealthCheckResponse) MarshalToSizedBufferVT 

func (m *RunHealthCheckResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RunHealthCheckResponse) MarshalToVT 

func (m *RunHealthCheckResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RunHealthCheckResponse) MarshalVT 

func (m *RunHealthCheckResponse) MarshalVT() (dAtA []byte, err error)

func (*RunHealthCheckResponse) ProtoMessage 

func (*RunHealthCheckResponse) ProtoMessage()

func (*RunHealthCheckResponse) ProtoReflect 

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

func (*RunHealthCheckResponse) Reset 

func (x *RunHealthCheckResponse) Reset()

func (*RunHealthCheckResponse) SizeVT 

func (m *RunHealthCheckResponse) SizeVT() (n int)

func (*RunHealthCheckResponse) String 

func (x *RunHealthCheckResponse) String() string

func (*RunHealthCheckResponse) UnmarshalVT 

func (m *RunHealthCheckResponse) UnmarshalVT(dAtA []byte) error

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

func (m *SchemaChangeResult) CloneMessageVT() proto.Message

func (*SchemaChangeResult) CloneVT 

func (m *SchemaChangeResult) CloneVT() *SchemaChangeResult

func (*SchemaChangeResult) Descriptor deprecated 

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

Deprecated: Use SchemaChangeResult.ProtoReflect.Descriptor instead.

func (*SchemaChangeResult) GetAfterSchema 

func (x *SchemaChangeResult) GetAfterSchema() *SchemaDefinition

func (*SchemaChangeResult) GetBeforeSchema 

func (x *SchemaChangeResult) GetBeforeSchema() *SchemaDefinition

func (*SchemaChangeResult) MarshalToSizedBufferVT 

func (m *SchemaChangeResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SchemaChangeResult) MarshalToVT 

func (m *SchemaChangeResult) MarshalToVT(dAtA []byte) (int, error)

func (*SchemaChangeResult) MarshalVT 

func (m *SchemaChangeResult) MarshalVT() (dAtA []byte, err error)

func (*SchemaChangeResult) ProtoMessage 

func (*SchemaChangeResult) ProtoMessage()

func (*SchemaChangeResult) ProtoReflect 

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

func (*SchemaChangeResult) Reset 

func (x *SchemaChangeResult) Reset()

func (*SchemaChangeResult) SizeVT 

func (m *SchemaChangeResult) SizeVT() (n int)

func (*SchemaChangeResult) String 

func (x *SchemaChangeResult) String() string

func (*SchemaChangeResult) UnmarshalVT 

func (m *SchemaChangeResult) UnmarshalVT(dAtA []byte) error

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

func (m *SchemaDefinition) CloneMessageVT() proto.Message

func (*SchemaDefinition) CloneVT 

func (m *SchemaDefinition) CloneVT() *SchemaDefinition

func (*SchemaDefinition) Descriptor deprecated 

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

Deprecated: Use SchemaDefinition.ProtoReflect.Descriptor instead.

func (*SchemaDefinition) GetDatabaseSchema 

func (x *SchemaDefinition) GetDatabaseSchema() string

func (*SchemaDefinition) GetTableDefinitions 

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

func (*SchemaDefinition) MarshalToSizedBufferVT 

func (m *SchemaDefinition) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SchemaDefinition) MarshalToVT 

func (m *SchemaDefinition) MarshalToVT(dAtA []byte) (int, error)

func (*SchemaDefinition) MarshalVT 

func (m *SchemaDefinition) MarshalVT() (dAtA []byte, err error)

func (*SchemaDefinition) ProtoMessage 

func (*SchemaDefinition) ProtoMessage()

func (*SchemaDefinition) ProtoReflect 

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

func (*SchemaDefinition) Reset 

func (x *SchemaDefinition) Reset()

func (*SchemaDefinition) SizeVT 

func (m *SchemaDefinition) SizeVT() (n int)

func (*SchemaDefinition) String 

func (x *SchemaDefinition) String() string

func (*SchemaDefinition) UnmarshalVT 

func (m *SchemaDefinition) UnmarshalVT(dAtA []byte) error

type SetReadOnlyRequest 

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

func (*SetReadOnlyRequest) CloneMessageVT 

func (m *SetReadOnlyRequest) CloneMessageVT() proto.Message

func (*SetReadOnlyRequest) CloneVT 

func (m *SetReadOnlyRequest) CloneVT() *SetReadOnlyRequest

func (*SetReadOnlyRequest) Descriptor deprecated 

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

Deprecated: Use SetReadOnlyRequest.ProtoReflect.Descriptor instead.

func (*SetReadOnlyRequest) MarshalToSizedBufferVT 

func (m *SetReadOnlyRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetReadOnlyRequest) MarshalToVT 

func (m *SetReadOnlyRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SetReadOnlyRequest) MarshalVT 

func (m *SetReadOnlyRequest) MarshalVT() (dAtA []byte, err error)

func (*SetReadOnlyRequest) ProtoMessage 

func (*SetReadOnlyRequest) ProtoMessage()

func (*SetReadOnlyRequest) ProtoReflect 

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

func (*SetReadOnlyRequest) Reset 

func (x *SetReadOnlyRequest) Reset()

func (*SetReadOnlyRequest) SizeVT 

func (m *SetReadOnlyRequest) SizeVT() (n int)

func (*SetReadOnlyRequest) String 

func (x *SetReadOnlyRequest) String() string

func (*SetReadOnlyRequest) UnmarshalVT 

func (m *SetReadOnlyRequest) UnmarshalVT(dAtA []byte) error

type SetReadOnlyResponse 

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

func (*SetReadOnlyResponse) CloneMessageVT 

func (m *SetReadOnlyResponse) CloneMessageVT() proto.Message

func (*SetReadOnlyResponse) CloneVT 

func (m *SetReadOnlyResponse) CloneVT() *SetReadOnlyResponse

func (*SetReadOnlyResponse) Descriptor deprecated 

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

Deprecated: Use SetReadOnlyResponse.ProtoReflect.Descriptor instead.

func (*SetReadOnlyResponse) MarshalToSizedBufferVT 

func (m *SetReadOnlyResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetReadOnlyResponse) MarshalToVT 

func (m *SetReadOnlyResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SetReadOnlyResponse) MarshalVT 

func (m *SetReadOnlyResponse) MarshalVT() (dAtA []byte, err error)

func (*SetReadOnlyResponse) ProtoMessage 

func (*SetReadOnlyResponse) ProtoMessage()

func (*SetReadOnlyResponse) ProtoReflect 

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

func (*SetReadOnlyResponse) Reset 

func (x *SetReadOnlyResponse) Reset()

func (*SetReadOnlyResponse) SizeVT 

func (m *SetReadOnlyResponse) SizeVT() (n int)

func (*SetReadOnlyResponse) String 

func (x *SetReadOnlyResponse) String() string

func (*SetReadOnlyResponse) UnmarshalVT 

func (m *SetReadOnlyResponse) UnmarshalVT(dAtA []byte) error

type SetReadWriteRequest 

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

func (*SetReadWriteRequest) CloneMessageVT 

func (m *SetReadWriteRequest) CloneMessageVT() proto.Message

func (*SetReadWriteRequest) CloneVT 

func (m *SetReadWriteRequest) CloneVT() *SetReadWriteRequest

func (*SetReadWriteRequest) Descriptor deprecated 

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

Deprecated: Use SetReadWriteRequest.ProtoReflect.Descriptor instead.

func (*SetReadWriteRequest) MarshalToSizedBufferVT 

func (m *SetReadWriteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetReadWriteRequest) MarshalToVT 

func (m *SetReadWriteRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SetReadWriteRequest) MarshalVT 

func (m *SetReadWriteRequest) MarshalVT() (dAtA []byte, err error)

func (*SetReadWriteRequest) ProtoMessage 

func (*SetReadWriteRequest) ProtoMessage()

func (*SetReadWriteRequest) ProtoReflect 

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

func (*SetReadWriteRequest) Reset 

func (x *SetReadWriteRequest) Reset()

func (*SetReadWriteRequest) SizeVT 

func (m *SetReadWriteRequest) SizeVT() (n int)

func (*SetReadWriteRequest) String 

func (x *SetReadWriteRequest) String() string

func (*SetReadWriteRequest) UnmarshalVT 

func (m *SetReadWriteRequest) UnmarshalVT(dAtA []byte) error

type SetReadWriteResponse 

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

func (*SetReadWriteResponse) CloneMessageVT 

func (m *SetReadWriteResponse) CloneMessageVT() proto.Message

func (*SetReadWriteResponse) CloneVT 

func (m *SetReadWriteResponse) CloneVT() *SetReadWriteResponse

func (*SetReadWriteResponse) Descriptor deprecated 

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

Deprecated: Use SetReadWriteResponse.ProtoReflect.Descriptor instead.

func (*SetReadWriteResponse) MarshalToSizedBufferVT 

func (m *SetReadWriteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetReadWriteResponse) MarshalToVT 

func (m *SetReadWriteResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SetReadWriteResponse) MarshalVT 

func (m *SetReadWriteResponse) MarshalVT() (dAtA []byte, err error)

func (*SetReadWriteResponse) ProtoMessage 

func (*SetReadWriteResponse) ProtoMessage()

func (*SetReadWriteResponse) ProtoReflect 

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

func (*SetReadWriteResponse) Reset 

func (x *SetReadWriteResponse) Reset()

func (*SetReadWriteResponse) SizeVT 

func (m *SetReadWriteResponse) SizeVT() (n int)

func (*SetReadWriteResponse) String 

func (x *SetReadWriteResponse) String() string

func (*SetReadWriteResponse) UnmarshalVT 

func (m *SetReadWriteResponse) UnmarshalVT(dAtA []byte) error

type SetReplicationSourceRequest 

type SetReplicationSourceRequest struct {
	Parent                *topodata.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) CloneMessageVT 

func (m *SetReplicationSourceRequest) CloneMessageVT() proto.Message

func (*SetReplicationSourceRequest) CloneVT 

func (m *SetReplicationSourceRequest) CloneVT() *SetReplicationSourceRequest

func (*SetReplicationSourceRequest) Descriptor deprecated 

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

Deprecated: Use SetReplicationSourceRequest.ProtoReflect.Descriptor instead.

func (*SetReplicationSourceRequest) GetForceStartReplication 

func (x *SetReplicationSourceRequest) GetForceStartReplication() bool

func (*SetReplicationSourceRequest) GetHeartbeatInterval 

func (x *SetReplicationSourceRequest) GetHeartbeatInterval() float64

func (*SetReplicationSourceRequest) GetParent 

func (x *SetReplicationSourceRequest) GetParent() *topodata.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) MarshalToSizedBufferVT 

func (m *SetReplicationSourceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetReplicationSourceRequest) MarshalToVT 

func (m *SetReplicationSourceRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SetReplicationSourceRequest) MarshalVT 

func (m *SetReplicationSourceRequest) MarshalVT() (dAtA []byte, err error)

func (*SetReplicationSourceRequest) ProtoMessage 

func (*SetReplicationSourceRequest) ProtoMessage()

func (*SetReplicationSourceRequest) ProtoReflect 

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

func (*SetReplicationSourceRequest) Reset 

func (x *SetReplicationSourceRequest) Reset()

func (*SetReplicationSourceRequest) SizeVT 

func (m *SetReplicationSourceRequest) SizeVT() (n int)

func (*SetReplicationSourceRequest) String 

func (x *SetReplicationSourceRequest) String() string

func (*SetReplicationSourceRequest) UnmarshalVT 

func (m *SetReplicationSourceRequest) UnmarshalVT(dAtA []byte) error

type SetReplicationSourceResponse 

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

func (*SetReplicationSourceResponse) CloneMessageVT 

func (m *SetReplicationSourceResponse) CloneMessageVT() proto.Message

func (*SetReplicationSourceResponse) CloneVT 

func (m *SetReplicationSourceResponse) CloneVT() *SetReplicationSourceResponse

func (*SetReplicationSourceResponse) Descriptor deprecated 

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

Deprecated: Use SetReplicationSourceResponse.ProtoReflect.Descriptor instead.

func (*SetReplicationSourceResponse) MarshalToSizedBufferVT 

func (m *SetReplicationSourceResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetReplicationSourceResponse) MarshalToVT 

func (m *SetReplicationSourceResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SetReplicationSourceResponse) MarshalVT 

func (m *SetReplicationSourceResponse) MarshalVT() (dAtA []byte, err error)

func (*SetReplicationSourceResponse) ProtoMessage 

func (*SetReplicationSourceResponse) ProtoMessage()

func (*SetReplicationSourceResponse) ProtoReflect 

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

func (*SetReplicationSourceResponse) Reset 

func (x *SetReplicationSourceResponse) Reset()

func (*SetReplicationSourceResponse) SizeVT 

func (m *SetReplicationSourceResponse) SizeVT() (n int)

func (*SetReplicationSourceResponse) String 

func (x *SetReplicationSourceResponse) String() string

func (*SetReplicationSourceResponse) UnmarshalVT 

func (m *SetReplicationSourceResponse) UnmarshalVT(dAtA []byte) error

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

func (m *SleepRequest) CloneMessageVT() proto.Message

func (*SleepRequest) CloneVT 

func (m *SleepRequest) CloneVT() *SleepRequest

func (*SleepRequest) Descriptor deprecated 

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

Deprecated: Use SleepRequest.ProtoReflect.Descriptor instead.

func (*SleepRequest) GetDuration 

func (x *SleepRequest) GetDuration() int64

func (*SleepRequest) MarshalToSizedBufferVT 

func (m *SleepRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SleepRequest) MarshalToVT 

func (m *SleepRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SleepRequest) MarshalVT 

func (m *SleepRequest) MarshalVT() (dAtA []byte, err error)

func (*SleepRequest) ProtoMessage 

func (*SleepRequest) ProtoMessage()

func (*SleepRequest) ProtoReflect 

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

func (*SleepRequest) Reset 

func (x *SleepRequest) Reset()

func (*SleepRequest) SizeVT 

func (m *SleepRequest) SizeVT() (n int)

func (*SleepRequest) String 

func (x *SleepRequest) String() string

func (*SleepRequest) UnmarshalVT 

func (m *SleepRequest) UnmarshalVT(dAtA []byte) error

type SleepResponse 

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

func (*SleepResponse) CloneMessageVT 

func (m *SleepResponse) CloneMessageVT() proto.Message

func (*SleepResponse) CloneVT 

func (m *SleepResponse) CloneVT() *SleepResponse

func (*SleepResponse) Descriptor deprecated 

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

Deprecated: Use SleepResponse.ProtoReflect.Descriptor instead.

func (*SleepResponse) MarshalToSizedBufferVT 

func (m *SleepResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SleepResponse) MarshalToVT 

func (m *SleepResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SleepResponse) MarshalVT 

func (m *SleepResponse) MarshalVT() (dAtA []byte, err error)

func (*SleepResponse) ProtoMessage 

func (*SleepResponse) ProtoMessage()

func (*SleepResponse) ProtoReflect 

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

func (*SleepResponse) Reset 

func (x *SleepResponse) Reset()

func (*SleepResponse) SizeVT 

func (m *SleepResponse) SizeVT() (n int)

func (*SleepResponse) String 

func (x *SleepResponse) String() string

func (*SleepResponse) UnmarshalVT 

func (m *SleepResponse) UnmarshalVT(dAtA []byte) error

type StartReplicationRequest 

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

func (*StartReplicationRequest) CloneMessageVT 

func (m *StartReplicationRequest) CloneMessageVT() proto.Message

func (*StartReplicationRequest) CloneVT 

func (m *StartReplicationRequest) CloneVT() *StartReplicationRequest

func (*StartReplicationRequest) Descriptor deprecated 

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

Deprecated: Use StartReplicationRequest.ProtoReflect.Descriptor instead.

func (*StartReplicationRequest) GetSemiSync 

func (x *StartReplicationRequest) GetSemiSync() bool

func (*StartReplicationRequest) MarshalToSizedBufferVT 

func (m *StartReplicationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartReplicationRequest) MarshalToVT 

func (m *StartReplicationRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StartReplicationRequest) MarshalVT 

func (m *StartReplicationRequest) MarshalVT() (dAtA []byte, err error)

func (*StartReplicationRequest) ProtoMessage 

func (*StartReplicationRequest) ProtoMessage()

func (*StartReplicationRequest) ProtoReflect 

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

func (*StartReplicationRequest) Reset 

func (x *StartReplicationRequest) Reset()

func (*StartReplicationRequest) SizeVT 

func (m *StartReplicationRequest) SizeVT() (n int)

func (*StartReplicationRequest) String 

func (x *StartReplicationRequest) String() string

func (*StartReplicationRequest) UnmarshalVT 

func (m *StartReplicationRequest) UnmarshalVT(dAtA []byte) error

type StartReplicationResponse 

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

func (*StartReplicationResponse) CloneMessageVT 

func (m *StartReplicationResponse) CloneMessageVT() proto.Message

func (*StartReplicationResponse) CloneVT 

func (m *StartReplicationResponse) CloneVT() *StartReplicationResponse

func (*StartReplicationResponse) Descriptor deprecated 

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

Deprecated: Use StartReplicationResponse.ProtoReflect.Descriptor instead.

func (*StartReplicationResponse) MarshalToSizedBufferVT 

func (m *StartReplicationResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartReplicationResponse) MarshalToVT 

func (m *StartReplicationResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StartReplicationResponse) MarshalVT 

func (m *StartReplicationResponse) MarshalVT() (dAtA []byte, err error)

func (*StartReplicationResponse) ProtoMessage 

func (*StartReplicationResponse) ProtoMessage()

func (*StartReplicationResponse) ProtoReflect 

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

func (*StartReplicationResponse) Reset 

func (x *StartReplicationResponse) Reset()

func (*StartReplicationResponse) SizeVT 

func (m *StartReplicationResponse) SizeVT() (n int)

func (*StartReplicationResponse) String 

func (x *StartReplicationResponse) String() string

func (*StartReplicationResponse) UnmarshalVT 

func (m *StartReplicationResponse) UnmarshalVT(dAtA []byte) error

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

func (m *StartReplicationUntilAfterRequest) CloneMessageVT() proto.Message

func (*StartReplicationUntilAfterRequest) CloneVT 

func (m *StartReplicationUntilAfterRequest) CloneVT() *StartReplicationUntilAfterRequest

func (*StartReplicationUntilAfterRequest) Descriptor deprecated 

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

Deprecated: Use StartReplicationUntilAfterRequest.ProtoReflect.Descriptor instead.

func (*StartReplicationUntilAfterRequest) GetPosition 

func (x *StartReplicationUntilAfterRequest) GetPosition() string

func (*StartReplicationUntilAfterRequest) GetWaitTimeout 

func (x *StartReplicationUntilAfterRequest) GetWaitTimeout() int64

func (*StartReplicationUntilAfterRequest) MarshalToSizedBufferVT 

func (m *StartReplicationUntilAfterRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartReplicationUntilAfterRequest) MarshalToVT 

func (m *StartReplicationUntilAfterRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StartReplicationUntilAfterRequest) MarshalVT 

func (m *StartReplicationUntilAfterRequest) MarshalVT() (dAtA []byte, err error)

func (*StartReplicationUntilAfterRequest) ProtoMessage 

func (*StartReplicationUntilAfterRequest) ProtoMessage()

func (*StartReplicationUntilAfterRequest) ProtoReflect 

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

func (*StartReplicationUntilAfterRequest) Reset 

func (x *StartReplicationUntilAfterRequest) Reset()

func (*StartReplicationUntilAfterRequest) SizeVT 

func (m *StartReplicationUntilAfterRequest) SizeVT() (n int)

func (*StartReplicationUntilAfterRequest) String 

func (x *StartReplicationUntilAfterRequest) String() string

func (*StartReplicationUntilAfterRequest) UnmarshalVT 

func (m *StartReplicationUntilAfterRequest) UnmarshalVT(dAtA []byte) error

type StartReplicationUntilAfterResponse 

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

func (*StartReplicationUntilAfterResponse) CloneMessageVT 

func (m *StartReplicationUntilAfterResponse) CloneMessageVT() proto.Message

func (*StartReplicationUntilAfterResponse) CloneVT 

func (m *StartReplicationUntilAfterResponse) CloneVT() *StartReplicationUntilAfterResponse

func (*StartReplicationUntilAfterResponse) Descriptor deprecated 

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

Deprecated: Use StartReplicationUntilAfterResponse.ProtoReflect.Descriptor instead.

func (*StartReplicationUntilAfterResponse) MarshalToSizedBufferVT 

func (m *StartReplicationUntilAfterResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartReplicationUntilAfterResponse) MarshalToVT 

func (m *StartReplicationUntilAfterResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StartReplicationUntilAfterResponse) MarshalVT 

func (m *StartReplicationUntilAfterResponse) MarshalVT() (dAtA []byte, err error)

func (*StartReplicationUntilAfterResponse) ProtoMessage 

func (*StartReplicationUntilAfterResponse) ProtoMessage()

func (*StartReplicationUntilAfterResponse) ProtoReflect 

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

func (*StartReplicationUntilAfterResponse) Reset 

func (x *StartReplicationUntilAfterResponse) Reset()

func (*StartReplicationUntilAfterResponse) SizeVT 

func (m *StartReplicationUntilAfterResponse) SizeVT() (n int)

func (*StartReplicationUntilAfterResponse) String 

func (x *StartReplicationUntilAfterResponse) String() string

func (*StartReplicationUntilAfterResponse) UnmarshalVT 

func (m *StartReplicationUntilAfterResponse) UnmarshalVT(dAtA []byte) error

type StopReplicationAndGetStatusRequest 

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

func (*StopReplicationAndGetStatusRequest) CloneMessageVT 

func (m *StopReplicationAndGetStatusRequest) CloneMessageVT() proto.Message

func (*StopReplicationAndGetStatusRequest) CloneVT 

func (m *StopReplicationAndGetStatusRequest) CloneVT() *StopReplicationAndGetStatusRequest

func (*StopReplicationAndGetStatusRequest) Descriptor deprecated 

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

Deprecated: Use StopReplicationAndGetStatusRequest.ProtoReflect.Descriptor instead.

func (*StopReplicationAndGetStatusRequest) GetStopReplicationMode 

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

func (*StopReplicationAndGetStatusRequest) MarshalToSizedBufferVT 

func (m *StopReplicationAndGetStatusRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StopReplicationAndGetStatusRequest) MarshalToVT 

func (m *StopReplicationAndGetStatusRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StopReplicationAndGetStatusRequest) MarshalVT 

func (m *StopReplicationAndGetStatusRequest) MarshalVT() (dAtA []byte, err error)

func (*StopReplicationAndGetStatusRequest) ProtoMessage 

func (*StopReplicationAndGetStatusRequest) ProtoMessage()

func (*StopReplicationAndGetStatusRequest) ProtoReflect 

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

func (*StopReplicationAndGetStatusRequest) Reset 

func (x *StopReplicationAndGetStatusRequest) Reset()

func (*StopReplicationAndGetStatusRequest) SizeVT 

func (m *StopReplicationAndGetStatusRequest) SizeVT() (n int)

func (*StopReplicationAndGetStatusRequest) String 

func (x *StopReplicationAndGetStatusRequest) String() string

func (*StopReplicationAndGetStatusRequest) UnmarshalVT 

func (m *StopReplicationAndGetStatusRequest) UnmarshalVT(dAtA []byte) error

type StopReplicationAndGetStatusResponse 

type StopReplicationAndGetStatusResponse struct {

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

func (*StopReplicationAndGetStatusResponse) CloneMessageVT 

func (m *StopReplicationAndGetStatusResponse) CloneMessageVT() proto.Message

func (*StopReplicationAndGetStatusResponse) CloneVT 

func (m *StopReplicationAndGetStatusResponse) CloneVT() *StopReplicationAndGetStatusResponse

func (*StopReplicationAndGetStatusResponse) Descriptor deprecated 

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

Deprecated: Use StopReplicationAndGetStatusResponse.ProtoReflect.Descriptor instead.

func (*StopReplicationAndGetStatusResponse) GetStatus 

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

func (*StopReplicationAndGetStatusResponse) MarshalToSizedBufferVT 

func (m *StopReplicationAndGetStatusResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StopReplicationAndGetStatusResponse) MarshalToVT 

func (m *StopReplicationAndGetStatusResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StopReplicationAndGetStatusResponse) MarshalVT 

func (m *StopReplicationAndGetStatusResponse) MarshalVT() (dAtA []byte, err error)

func (*StopReplicationAndGetStatusResponse) ProtoMessage 

func (*StopReplicationAndGetStatusResponse) ProtoMessage()

func (*StopReplicationAndGetStatusResponse) ProtoReflect 

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

func (*StopReplicationAndGetStatusResponse) Reset 

func (x *StopReplicationAndGetStatusResponse) Reset()

func (*StopReplicationAndGetStatusResponse) SizeVT 

func (m *StopReplicationAndGetStatusResponse) SizeVT() (n int)

func (*StopReplicationAndGetStatusResponse) String 

func (x *StopReplicationAndGetStatusResponse) String() string

func (*StopReplicationAndGetStatusResponse) UnmarshalVT 

func (m *StopReplicationAndGetStatusResponse) UnmarshalVT(dAtA []byte) error

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

func (m *StopReplicationMinimumRequest) CloneMessageVT() proto.Message

func (*StopReplicationMinimumRequest) CloneVT 

func (m *StopReplicationMinimumRequest) CloneVT() *StopReplicationMinimumRequest

func (*StopReplicationMinimumRequest) Descriptor deprecated 

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

Deprecated: Use StopReplicationMinimumRequest.ProtoReflect.Descriptor instead.

func (*StopReplicationMinimumRequest) GetPosition 

func (x *StopReplicationMinimumRequest) GetPosition() string

func (*StopReplicationMinimumRequest) GetWaitTimeout 

func (x *StopReplicationMinimumRequest) GetWaitTimeout() int64

func (*StopReplicationMinimumRequest) MarshalToSizedBufferVT 

func (m *StopReplicationMinimumRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StopReplicationMinimumRequest) MarshalToVT 

func (m *StopReplicationMinimumRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StopReplicationMinimumRequest) MarshalVT 

func (m *StopReplicationMinimumRequest) MarshalVT() (dAtA []byte, err error)

func (*StopReplicationMinimumRequest) ProtoMessage 

func (*StopReplicationMinimumRequest) ProtoMessage()

func (*StopReplicationMinimumRequest) ProtoReflect 

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

func (*StopReplicationMinimumRequest) Reset 

func (x *StopReplicationMinimumRequest) Reset()

func (*StopReplicationMinimumRequest) SizeVT 

func (m *StopReplicationMinimumRequest) SizeVT() (n int)

func (*StopReplicationMinimumRequest) String 

func (x *StopReplicationMinimumRequest) String() string

func (*StopReplicationMinimumRequest) UnmarshalVT 

func (m *StopReplicationMinimumRequest) UnmarshalVT(dAtA []byte) error

type StopReplicationMinimumResponse 

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

func (*StopReplicationMinimumResponse) CloneMessageVT 

func (m *StopReplicationMinimumResponse) CloneMessageVT() proto.Message

func (*StopReplicationMinimumResponse) CloneVT 

func (m *StopReplicationMinimumResponse) CloneVT() *StopReplicationMinimumResponse

func (*StopReplicationMinimumResponse) Descriptor deprecated 

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

Deprecated: Use StopReplicationMinimumResponse.ProtoReflect.Descriptor instead.

func (*StopReplicationMinimumResponse) GetPosition 

func (x *StopReplicationMinimumResponse) GetPosition() string

func (*StopReplicationMinimumResponse) MarshalToSizedBufferVT 

func (m *StopReplicationMinimumResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StopReplicationMinimumResponse) MarshalToVT 

func (m *StopReplicationMinimumResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StopReplicationMinimumResponse) MarshalVT 

func (m *StopReplicationMinimumResponse) MarshalVT() (dAtA []byte, err error)

func (*StopReplicationMinimumResponse) ProtoMessage 

func (*StopReplicationMinimumResponse) ProtoMessage()

func (*StopReplicationMinimumResponse) ProtoReflect 

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

func (*StopReplicationMinimumResponse) Reset 

func (x *StopReplicationMinimumResponse) Reset()

func (*StopReplicationMinimumResponse) SizeVT 

func (m *StopReplicationMinimumResponse) SizeVT() (n int)

func (*StopReplicationMinimumResponse) String 

func (x *StopReplicationMinimumResponse) String() string

func (*StopReplicationMinimumResponse) UnmarshalVT 

func (m *StopReplicationMinimumResponse) UnmarshalVT(dAtA []byte) error

type StopReplicationRequest 

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

func (*StopReplicationRequest) CloneMessageVT 

func (m *StopReplicationRequest) CloneMessageVT() proto.Message

func (*StopReplicationRequest) CloneVT 

func (m *StopReplicationRequest) CloneVT() *StopReplicationRequest

func (*StopReplicationRequest) Descriptor deprecated 

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

Deprecated: Use StopReplicationRequest.ProtoReflect.Descriptor instead.

func (*StopReplicationRequest) MarshalToSizedBufferVT 

func (m *StopReplicationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StopReplicationRequest) MarshalToVT 

func (m *StopReplicationRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StopReplicationRequest) MarshalVT 

func (m *StopReplicationRequest) MarshalVT() (dAtA []byte, err error)

func (*StopReplicationRequest) ProtoMessage 

func (*StopReplicationRequest) ProtoMessage()

func (*StopReplicationRequest) ProtoReflect 

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

func (*StopReplicationRequest) Reset 

func (x *StopReplicationRequest) Reset()

func (*StopReplicationRequest) SizeVT 

func (m *StopReplicationRequest) SizeVT() (n int)

func (*StopReplicationRequest) String 

func (x *StopReplicationRequest) String() string

func (*StopReplicationRequest) UnmarshalVT 

func (m *StopReplicationRequest) UnmarshalVT(dAtA []byte) error

type StopReplicationResponse 

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

func (*StopReplicationResponse) CloneMessageVT 

func (m *StopReplicationResponse) CloneMessageVT() proto.Message

func (*StopReplicationResponse) CloneVT 

func (m *StopReplicationResponse) CloneVT() *StopReplicationResponse

func (*StopReplicationResponse) Descriptor deprecated 

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

Deprecated: Use StopReplicationResponse.ProtoReflect.Descriptor instead.

func (*StopReplicationResponse) MarshalToSizedBufferVT 

func (m *StopReplicationResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StopReplicationResponse) MarshalToVT 

func (m *StopReplicationResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StopReplicationResponse) MarshalVT 

func (m *StopReplicationResponse) MarshalVT() (dAtA []byte, err error)

func (*StopReplicationResponse) ProtoMessage 

func (*StopReplicationResponse) ProtoMessage()

func (*StopReplicationResponse) ProtoReflect 

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

func (*StopReplicationResponse) Reset 

func (x *StopReplicationResponse) Reset()

func (*StopReplicationResponse) SizeVT 

func (m *StopReplicationResponse) SizeVT() (n int)

func (*StopReplicationResponse) String 

func (x *StopReplicationResponse) String() string

func (*StopReplicationResponse) UnmarshalVT 

func (m *StopReplicationResponse) UnmarshalVT(dAtA []byte) error

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 []*query.Field `protobuf:"bytes,8,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*TableDefinition) CloneMessageVT 

func (m *TableDefinition) CloneMessageVT() proto.Message

func (*TableDefinition) CloneVT 

func (m *TableDefinition) CloneVT() *TableDefinition

func (*TableDefinition) Descriptor deprecated 

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

Deprecated: Use TableDefinition.ProtoReflect.Descriptor instead.

func (*TableDefinition) GetColumns 

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

func (*TableDefinition) GetDataLength 

func (x *TableDefinition) GetDataLength() uint64

func (*TableDefinition) GetFields 

func (x *TableDefinition) GetFields() []*query.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) MarshalToSizedBufferVT 

func (m *TableDefinition) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TableDefinition) MarshalToVT 

func (m *TableDefinition) MarshalToVT(dAtA []byte) (int, error)

func (*TableDefinition) MarshalVT 

func (m *TableDefinition) MarshalVT() (dAtA []byte, err error)

func (*TableDefinition) ProtoMessage 

func (*TableDefinition) ProtoMessage()

func (*TableDefinition) ProtoReflect 

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

func (*TableDefinition) Reset 

func (x *TableDefinition) Reset()

func (*TableDefinition) SizeVT 

func (m *TableDefinition) SizeVT() (n int)

func (*TableDefinition) String 

func (x *TableDefinition) String() string

func (*TableDefinition) UnmarshalVT 

func (m *TableDefinition) UnmarshalVT(dAtA []byte) error

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) EnumDescriptor deprecated 

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

Deprecated: Use TabletSelectionPreference.Descriptor instead.

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

func (m *UndoDemotePrimaryRequest) CloneMessageVT() proto.Message

func (*UndoDemotePrimaryRequest) CloneVT 

func (m *UndoDemotePrimaryRequest) CloneVT() *UndoDemotePrimaryRequest

func (*UndoDemotePrimaryRequest) Descriptor deprecated 

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

Deprecated: Use UndoDemotePrimaryRequest.ProtoReflect.Descriptor instead.

func (*UndoDemotePrimaryRequest) GetSemiSync 

func (x *UndoDemotePrimaryRequest) GetSemiSync() bool

func (*UndoDemotePrimaryRequest) MarshalToSizedBufferVT 

func (m *UndoDemotePrimaryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UndoDemotePrimaryRequest) MarshalToVT 

func (m *UndoDemotePrimaryRequest) MarshalToVT(dAtA []byte) (int, error)

func (*UndoDemotePrimaryRequest) MarshalVT 

func (m *UndoDemotePrimaryRequest) MarshalVT() (dAtA []byte, err error)

func (*UndoDemotePrimaryRequest) ProtoMessage 

func (*UndoDemotePrimaryRequest) ProtoMessage()

func (*UndoDemotePrimaryRequest) ProtoReflect 

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

func (*UndoDemotePrimaryRequest) Reset 

func (x *UndoDemotePrimaryRequest) Reset()

func (*UndoDemotePrimaryRequest) SizeVT 

func (m *UndoDemotePrimaryRequest) SizeVT() (n int)

func (*UndoDemotePrimaryRequest) String 

func (x *UndoDemotePrimaryRequest) String() string

func (*UndoDemotePrimaryRequest) UnmarshalVT 

func (m *UndoDemotePrimaryRequest) UnmarshalVT(dAtA []byte) error

type UndoDemotePrimaryResponse 

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

func (*UndoDemotePrimaryResponse) CloneMessageVT 

func (m *UndoDemotePrimaryResponse) CloneMessageVT() proto.Message

func (*UndoDemotePrimaryResponse) CloneVT 

func (m *UndoDemotePrimaryResponse) CloneVT() *UndoDemotePrimaryResponse

func (*UndoDemotePrimaryResponse) Descriptor deprecated 

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

Deprecated: Use UndoDemotePrimaryResponse.ProtoReflect.Descriptor instead.

func (*UndoDemotePrimaryResponse) MarshalToSizedBufferVT 

func (m *UndoDemotePrimaryResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UndoDemotePrimaryResponse) MarshalToVT 

func (m *UndoDemotePrimaryResponse) MarshalToVT(dAtA []byte) (int, error)

func (*UndoDemotePrimaryResponse) MarshalVT 

func (m *UndoDemotePrimaryResponse) MarshalVT() (dAtA []byte, err error)

func (*UndoDemotePrimaryResponse) ProtoMessage 

func (*UndoDemotePrimaryResponse) ProtoMessage()

func (*UndoDemotePrimaryResponse) ProtoReflect 

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

func (*UndoDemotePrimaryResponse) Reset 

func (x *UndoDemotePrimaryResponse) Reset()

func (*UndoDemotePrimaryResponse) SizeVT 

func (m *UndoDemotePrimaryResponse) SizeVT() (n int)

func (*UndoDemotePrimaryResponse) String 

func (x *UndoDemotePrimaryResponse) String() string

func (*UndoDemotePrimaryResponse) UnmarshalVT 

func (m *UndoDemotePrimaryResponse) UnmarshalVT(dAtA []byte) error

type UnlockTablesRequest 

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

func (*UnlockTablesRequest) CloneMessageVT 

func (m *UnlockTablesRequest) CloneMessageVT() proto.Message

func (*UnlockTablesRequest) CloneVT 

func (m *UnlockTablesRequest) CloneVT() *UnlockTablesRequest

func (*UnlockTablesRequest) Descriptor deprecated 

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

Deprecated: Use UnlockTablesRequest.ProtoReflect.Descriptor instead.

func (*UnlockTablesRequest) MarshalToSizedBufferVT 

func (m *UnlockTablesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UnlockTablesRequest) MarshalToVT 

func (m *UnlockTablesRequest) MarshalToVT(dAtA []byte) (int, error)

func (*UnlockTablesRequest) MarshalVT 

func (m *UnlockTablesRequest) MarshalVT() (dAtA []byte, err error)

func (*UnlockTablesRequest) ProtoMessage 

func (*UnlockTablesRequest) ProtoMessage()

func (*UnlockTablesRequest) ProtoReflect 

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

func (*UnlockTablesRequest) Reset 

func (x *UnlockTablesRequest) Reset()

func (*UnlockTablesRequest) SizeVT 

func (m *UnlockTablesRequest) SizeVT() (n int)

func (*UnlockTablesRequest) String 

func (x *UnlockTablesRequest) String() string

func (*UnlockTablesRequest) UnmarshalVT 

func (m *UnlockTablesRequest) UnmarshalVT(dAtA []byte) error

type UnlockTablesResponse 

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

func (*UnlockTablesResponse) CloneMessageVT 

func (m *UnlockTablesResponse) CloneMessageVT() proto.Message

func (*UnlockTablesResponse) CloneVT 

func (m *UnlockTablesResponse) CloneVT() *UnlockTablesResponse

func (*UnlockTablesResponse) Descriptor deprecated 

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

Deprecated: Use UnlockTablesResponse.ProtoReflect.Descriptor instead.

func (*UnlockTablesResponse) MarshalToSizedBufferVT 

func (m *UnlockTablesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UnlockTablesResponse) MarshalToVT 

func (m *UnlockTablesResponse) MarshalToVT(dAtA []byte) (int, error)

func (*UnlockTablesResponse) MarshalVT 

func (m *UnlockTablesResponse) MarshalVT() (dAtA []byte, err error)

func (*UnlockTablesResponse) ProtoMessage 

func (*UnlockTablesResponse) ProtoMessage()

func (*UnlockTablesResponse) ProtoReflect 

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

func (*UnlockTablesResponse) Reset 

func (x *UnlockTablesResponse) Reset()

func (*UnlockTablesResponse) SizeVT 

func (m *UnlockTablesResponse) SizeVT() (n int)

func (*UnlockTablesResponse) String 

func (x *UnlockTablesResponse) String() string

func (*UnlockTablesResponse) UnmarshalVT 

func (m *UnlockTablesResponse) UnmarshalVT(dAtA []byte) error

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               []topodata.TabletType                `` /* 127-byte string literal not displayed */
	TabletSelectionPreference TabletSelectionPreference            `` /* 188-byte string literal not displayed */
	OnDdl                     binlogdata.OnDDLAction               `protobuf:"varint,5,opt,name=on_ddl,json=onDdl,proto3,enum=binlogdata.OnDDLAction" json:"on_ddl,omitempty"`
	State                     binlogdata.VReplicationWorkflowState `protobuf:"varint,6,opt,name=state,proto3,enum=binlogdata.VReplicationWorkflowState" json:"state,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) CloneMessageVT 

func (m *UpdateVReplicationWorkflowRequest) CloneMessageVT() proto.Message

func (*UpdateVReplicationWorkflowRequest) CloneVT 

func (m *UpdateVReplicationWorkflowRequest) CloneVT() *UpdateVReplicationWorkflowRequest

func (*UpdateVReplicationWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use UpdateVReplicationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*UpdateVReplicationWorkflowRequest) GetCells 

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

func (*UpdateVReplicationWorkflowRequest) GetOnDdl 

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

func (*UpdateVReplicationWorkflowRequest) GetState 

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

func (*UpdateVReplicationWorkflowRequest) GetTabletSelectionPreference 

func (x *UpdateVReplicationWorkflowRequest) GetTabletSelectionPreference() TabletSelectionPreference

func (*UpdateVReplicationWorkflowRequest) GetTabletTypes 

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

func (*UpdateVReplicationWorkflowRequest) GetWorkflow 

func (x *UpdateVReplicationWorkflowRequest) GetWorkflow() string

func (*UpdateVReplicationWorkflowRequest) MarshalToSizedBufferVT 

func (m *UpdateVReplicationWorkflowRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateVReplicationWorkflowRequest) MarshalToVT 

func (m *UpdateVReplicationWorkflowRequest) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateVReplicationWorkflowRequest) MarshalVT 

func (m *UpdateVReplicationWorkflowRequest) MarshalVT() (dAtA []byte, err error)

func (*UpdateVReplicationWorkflowRequest) ProtoMessage 

func (*UpdateVReplicationWorkflowRequest) ProtoMessage()

func (*UpdateVReplicationWorkflowRequest) ProtoReflect 

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

func (*UpdateVReplicationWorkflowRequest) Reset 

func (x *UpdateVReplicationWorkflowRequest) Reset()

func (*UpdateVReplicationWorkflowRequest) SizeVT 

func (m *UpdateVReplicationWorkflowRequest) SizeVT() (n int)

func (*UpdateVReplicationWorkflowRequest) String 

func (x *UpdateVReplicationWorkflowRequest) String() string

func (*UpdateVReplicationWorkflowRequest) UnmarshalVT 

func (m *UpdateVReplicationWorkflowRequest) UnmarshalVT(dAtA []byte) error

type UpdateVReplicationWorkflowResponse 

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

func (*UpdateVReplicationWorkflowResponse) CloneMessageVT 

func (m *UpdateVReplicationWorkflowResponse) CloneMessageVT() proto.Message

func (*UpdateVReplicationWorkflowResponse) CloneVT 

func (m *UpdateVReplicationWorkflowResponse) CloneVT() *UpdateVReplicationWorkflowResponse

func (*UpdateVReplicationWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use UpdateVReplicationWorkflowResponse.ProtoReflect.Descriptor instead.

func (*UpdateVReplicationWorkflowResponse) GetResult 

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

func (*UpdateVReplicationWorkflowResponse) MarshalToSizedBufferVT 

func (m *UpdateVReplicationWorkflowResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateVReplicationWorkflowResponse) MarshalToVT 

func (m *UpdateVReplicationWorkflowResponse) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateVReplicationWorkflowResponse) MarshalVT 

func (m *UpdateVReplicationWorkflowResponse) MarshalVT() (dAtA []byte, err error)

func (*UpdateVReplicationWorkflowResponse) ProtoMessage 

func (*UpdateVReplicationWorkflowResponse) ProtoMessage()

func (*UpdateVReplicationWorkflowResponse) ProtoReflect 

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

func (*UpdateVReplicationWorkflowResponse) Reset 

func (x *UpdateVReplicationWorkflowResponse) Reset()

func (*UpdateVReplicationWorkflowResponse) SizeVT 

func (m *UpdateVReplicationWorkflowResponse) SizeVT() (n int)

func (*UpdateVReplicationWorkflowResponse) String 

func (x *UpdateVReplicationWorkflowResponse) String() string

func (*UpdateVReplicationWorkflowResponse) UnmarshalVT 

func (m *UpdateVReplicationWorkflowResponse) UnmarshalVT(dAtA []byte) error

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            binlogdata.VReplicationWorkflowState `protobuf:"varint,4,opt,name=state,proto3,enum=binlogdata.VReplicationWorkflowState" json:"state,omitempty"`
	Message          string                               `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	StopPosition     string                               `protobuf:"bytes,6,opt,name=stop_position,json=stopPosition,proto3" 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) CloneMessageVT 

func (m *UpdateVReplicationWorkflowsRequest) CloneMessageVT() proto.Message

func (*UpdateVReplicationWorkflowsRequest) CloneVT 

func (m *UpdateVReplicationWorkflowsRequest) CloneVT() *UpdateVReplicationWorkflowsRequest

func (*UpdateVReplicationWorkflowsRequest) Descriptor deprecated 

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

Deprecated: Use UpdateVReplicationWorkflowsRequest.ProtoReflect.Descriptor instead.

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() binlogdata.VReplicationWorkflowState

func (*UpdateVReplicationWorkflowsRequest) GetStopPosition 

func (x *UpdateVReplicationWorkflowsRequest) GetStopPosition() string

func (*UpdateVReplicationWorkflowsRequest) MarshalToSizedBufferVT 

func (m *UpdateVReplicationWorkflowsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateVReplicationWorkflowsRequest) MarshalToVT 

func (m *UpdateVReplicationWorkflowsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateVReplicationWorkflowsRequest) MarshalVT 

func (m *UpdateVReplicationWorkflowsRequest) MarshalVT() (dAtA []byte, err error)

func (*UpdateVReplicationWorkflowsRequest) ProtoMessage 

func (*UpdateVReplicationWorkflowsRequest) ProtoMessage()

func (*UpdateVReplicationWorkflowsRequest) ProtoReflect 

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

func (*UpdateVReplicationWorkflowsRequest) Reset 

func (x *UpdateVReplicationWorkflowsRequest) Reset()

func (*UpdateVReplicationWorkflowsRequest) SizeVT 

func (m *UpdateVReplicationWorkflowsRequest) SizeVT() (n int)

func (*UpdateVReplicationWorkflowsRequest) String 

func (x *UpdateVReplicationWorkflowsRequest) String() string

func (*UpdateVReplicationWorkflowsRequest) UnmarshalVT 

func (m *UpdateVReplicationWorkflowsRequest) UnmarshalVT(dAtA []byte) error

type UpdateVReplicationWorkflowsResponse 

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

func (*UpdateVReplicationWorkflowsResponse) CloneMessageVT 

func (m *UpdateVReplicationWorkflowsResponse) CloneMessageVT() proto.Message

func (*UpdateVReplicationWorkflowsResponse) CloneVT 

func (m *UpdateVReplicationWorkflowsResponse) CloneVT() *UpdateVReplicationWorkflowsResponse

func (*UpdateVReplicationWorkflowsResponse) Descriptor deprecated 

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

Deprecated: Use UpdateVReplicationWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*UpdateVReplicationWorkflowsResponse) GetResult 

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

func (*UpdateVReplicationWorkflowsResponse) MarshalToSizedBufferVT 

func (m *UpdateVReplicationWorkflowsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateVReplicationWorkflowsResponse) MarshalToVT 

func (m *UpdateVReplicationWorkflowsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateVReplicationWorkflowsResponse) MarshalVT 

func (m *UpdateVReplicationWorkflowsResponse) MarshalVT() (dAtA []byte, err error)

func (*UpdateVReplicationWorkflowsResponse) ProtoMessage 

func (*UpdateVReplicationWorkflowsResponse) ProtoMessage()

func (*UpdateVReplicationWorkflowsResponse) ProtoReflect 

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

func (*UpdateVReplicationWorkflowsResponse) Reset 

func (x *UpdateVReplicationWorkflowsResponse) Reset()

func (*UpdateVReplicationWorkflowsResponse) SizeVT 

func (m *UpdateVReplicationWorkflowsResponse) SizeVT() (n int)

func (*UpdateVReplicationWorkflowsResponse) String 

func (x *UpdateVReplicationWorkflowsResponse) String() string

func (*UpdateVReplicationWorkflowsResponse) UnmarshalVT 

func (m *UpdateVReplicationWorkflowsResponse) UnmarshalVT(dAtA []byte) error

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

func (m *UserPermission) CloneMessageVT() proto.Message

func (*UserPermission) CloneVT 

func (m *UserPermission) CloneVT() *UserPermission

func (*UserPermission) Descriptor deprecated 

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

Deprecated: Use UserPermission.ProtoReflect.Descriptor instead.

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

func (m *UserPermission) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UserPermission) MarshalToVT 

func (m *UserPermission) MarshalToVT(dAtA []byte) (int, error)

func (*UserPermission) MarshalVT 

func (m *UserPermission) MarshalVT() (dAtA []byte, err error)

func (*UserPermission) ProtoMessage 

func (*UserPermission) ProtoMessage()

func (*UserPermission) ProtoReflect 

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

func (*UserPermission) Reset 

func (x *UserPermission) Reset()

func (*UserPermission) SizeVT 

func (m *UserPermission) SizeVT() (n int)

func (*UserPermission) String 

func (x *UserPermission) String() string

func (*UserPermission) UnmarshalVT 

func (m *UserPermission) UnmarshalVT(dAtA []byte) error

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"`
	// contains filtered or unexported fields
}

func (*VDiffCoreOptions) CloneMessageVT 

func (m *VDiffCoreOptions) CloneMessageVT() proto.Message

func (*VDiffCoreOptions) CloneVT 

func (m *VDiffCoreOptions) CloneVT() *VDiffCoreOptions

func (*VDiffCoreOptions) Descriptor deprecated 

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

Deprecated: Use VDiffCoreOptions.ProtoReflect.Descriptor instead.

func (*VDiffCoreOptions) GetAutoRetry 

func (x *VDiffCoreOptions) GetAutoRetry() 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) MarshalToSizedBufferVT 

func (m *VDiffCoreOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VDiffCoreOptions) MarshalToVT 

func (m *VDiffCoreOptions) MarshalToVT(dAtA []byte) (int, error)

func (*VDiffCoreOptions) MarshalVT 

func (m *VDiffCoreOptions) MarshalVT() (dAtA []byte, err error)

func (*VDiffCoreOptions) ProtoMessage 

func (*VDiffCoreOptions) ProtoMessage()

func (*VDiffCoreOptions) ProtoReflect 

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

func (*VDiffCoreOptions) Reset 

func (x *VDiffCoreOptions) Reset()

func (*VDiffCoreOptions) SizeVT 

func (m *VDiffCoreOptions) SizeVT() (n int)

func (*VDiffCoreOptions) String 

func (x *VDiffCoreOptions) String() string

func (*VDiffCoreOptions) UnmarshalVT 

func (m *VDiffCoreOptions) UnmarshalVT(dAtA []byte) error

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

func (m *VDiffOptions) CloneMessageVT() proto.Message

func (*VDiffOptions) CloneVT 

func (m *VDiffOptions) CloneVT() *VDiffOptions

func (*VDiffOptions) Descriptor deprecated 

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

Deprecated: Use VDiffOptions.ProtoReflect.Descriptor instead.

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

func (m *VDiffOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VDiffOptions) MarshalToVT 

func (m *VDiffOptions) MarshalToVT(dAtA []byte) (int, error)

func (*VDiffOptions) MarshalVT 

func (m *VDiffOptions) MarshalVT() (dAtA []byte, err error)

func (*VDiffOptions) ProtoMessage 

func (*VDiffOptions) ProtoMessage()

func (*VDiffOptions) ProtoReflect 

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

func (*VDiffOptions) Reset 

func (x *VDiffOptions) Reset()

func (*VDiffOptions) SizeVT 

func (m *VDiffOptions) SizeVT() (n int)

func (*VDiffOptions) String 

func (x *VDiffOptions) String() string

func (*VDiffOptions) UnmarshalVT 

func (m *VDiffOptions) UnmarshalVT(dAtA []byte) error

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

func (m *VDiffPickerOptions) CloneMessageVT() proto.Message

func (*VDiffPickerOptions) CloneVT 

func (m *VDiffPickerOptions) CloneVT() *VDiffPickerOptions

func (*VDiffPickerOptions) Descriptor deprecated 

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

Deprecated: Use VDiffPickerOptions.ProtoReflect.Descriptor instead.

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

func (m *VDiffPickerOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VDiffPickerOptions) MarshalToVT 

func (m *VDiffPickerOptions) MarshalToVT(dAtA []byte) (int, error)

func (*VDiffPickerOptions) MarshalVT 

func (m *VDiffPickerOptions) MarshalVT() (dAtA []byte, err error)

func (*VDiffPickerOptions) ProtoMessage 

func (*VDiffPickerOptions) ProtoMessage()

func (*VDiffPickerOptions) ProtoReflect 

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

func (*VDiffPickerOptions) Reset 

func (x *VDiffPickerOptions) Reset()

func (*VDiffPickerOptions) SizeVT 

func (m *VDiffPickerOptions) SizeVT() (n int)

func (*VDiffPickerOptions) String 

func (x *VDiffPickerOptions) String() string

func (*VDiffPickerOptions) UnmarshalVT 

func (m *VDiffPickerOptions) UnmarshalVT(dAtA []byte) error

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"`
	// contains filtered or unexported fields
}

options that only influence how vdiff differences are reported

func (*VDiffReportOptions) CloneMessageVT 

func (m *VDiffReportOptions) CloneMessageVT() proto.Message

func (*VDiffReportOptions) CloneVT 

func (m *VDiffReportOptions) CloneVT() *VDiffReportOptions

func (*VDiffReportOptions) Descriptor deprecated 

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

Deprecated: Use VDiffReportOptions.ProtoReflect.Descriptor instead.

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

func (m *VDiffReportOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VDiffReportOptions) MarshalToVT 

func (m *VDiffReportOptions) MarshalToVT(dAtA []byte) (int, error)

func (*VDiffReportOptions) MarshalVT 

func (m *VDiffReportOptions) MarshalVT() (dAtA []byte, err error)

func (*VDiffReportOptions) ProtoMessage 

func (*VDiffReportOptions) ProtoMessage()

func (*VDiffReportOptions) ProtoReflect 

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

func (*VDiffReportOptions) Reset 

func (x *VDiffReportOptions) Reset()

func (*VDiffReportOptions) SizeVT 

func (m *VDiffReportOptions) SizeVT() (n int)

func (*VDiffReportOptions) String 

func (x *VDiffReportOptions) String() string

func (*VDiffReportOptions) UnmarshalVT 

func (m *VDiffReportOptions) UnmarshalVT(dAtA []byte) error

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

func (m *VDiffRequest) CloneMessageVT() proto.Message

func (*VDiffRequest) CloneVT 

func (m *VDiffRequest) CloneVT() *VDiffRequest

func (*VDiffRequest) Descriptor deprecated 

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

Deprecated: Use VDiffRequest.ProtoReflect.Descriptor instead.

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

func (m *VDiffRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VDiffRequest) MarshalToVT 

func (m *VDiffRequest) MarshalToVT(dAtA []byte) (int, error)

func (*VDiffRequest) MarshalVT 

func (m *VDiffRequest) MarshalVT() (dAtA []byte, err error)

func (*VDiffRequest) ProtoMessage 

func (*VDiffRequest) ProtoMessage()

func (*VDiffRequest) ProtoReflect 

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

func (*VDiffRequest) Reset 

func (x *VDiffRequest) Reset()

func (*VDiffRequest) SizeVT 

func (m *VDiffRequest) SizeVT() (n int)

func (*VDiffRequest) String 

func (x *VDiffRequest) String() string

func (*VDiffRequest) UnmarshalVT 

func (m *VDiffRequest) UnmarshalVT(dAtA []byte) error

type VDiffResponse 

type VDiffResponse struct {
	Id        int64              `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Output    *query.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) CloneMessageVT 

func (m *VDiffResponse) CloneMessageVT() proto.Message

func (*VDiffResponse) CloneVT 

func (m *VDiffResponse) CloneVT() *VDiffResponse

func (*VDiffResponse) Descriptor deprecated 

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

Deprecated: Use VDiffResponse.ProtoReflect.Descriptor instead.

func (*VDiffResponse) GetId 

func (x *VDiffResponse) GetId() int64

func (*VDiffResponse) GetOutput 

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

func (*VDiffResponse) GetVdiffUuid 

func (x *VDiffResponse) GetVdiffUuid() string

func (*VDiffResponse) MarshalToSizedBufferVT 

func (m *VDiffResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VDiffResponse) MarshalToVT 

func (m *VDiffResponse) MarshalToVT(dAtA []byte) (int, error)

func (*VDiffResponse) MarshalVT 

func (m *VDiffResponse) MarshalVT() (dAtA []byte, err error)

func (*VDiffResponse) ProtoMessage 

func (*VDiffResponse) ProtoMessage()

func (*VDiffResponse) ProtoReflect 

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

func (*VDiffResponse) Reset 

func (x *VDiffResponse) Reset()

func (*VDiffResponse) SizeVT 

func (m *VDiffResponse) SizeVT() (n int)

func (*VDiffResponse) String 

func (x *VDiffResponse) String() string

func (*VDiffResponse) UnmarshalVT 

func (m *VDiffResponse) UnmarshalVT(dAtA []byte) error

type VReplicationExecRequest 

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

func (*VReplicationExecRequest) CloneMessageVT 

func (m *VReplicationExecRequest) CloneMessageVT() proto.Message

func (*VReplicationExecRequest) CloneVT 

func (m *VReplicationExecRequest) CloneVT() *VReplicationExecRequest

func (*VReplicationExecRequest) Descriptor deprecated 

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

Deprecated: Use VReplicationExecRequest.ProtoReflect.Descriptor instead.

func (*VReplicationExecRequest) GetQuery 

func (x *VReplicationExecRequest) GetQuery() string

func (*VReplicationExecRequest) MarshalToSizedBufferVT 

func (m *VReplicationExecRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VReplicationExecRequest) MarshalToVT 

func (m *VReplicationExecRequest) MarshalToVT(dAtA []byte) (int, error)

func (*VReplicationExecRequest) MarshalVT 

func (m *VReplicationExecRequest) MarshalVT() (dAtA []byte, err error)

func (*VReplicationExecRequest) ProtoMessage 

func (*VReplicationExecRequest) ProtoMessage()

func (*VReplicationExecRequest) ProtoReflect 

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

func (*VReplicationExecRequest) Reset 

func (x *VReplicationExecRequest) Reset()

func (*VReplicationExecRequest) SizeVT 

func (m *VReplicationExecRequest) SizeVT() (n int)

func (*VReplicationExecRequest) String 

func (x *VReplicationExecRequest) String() string

func (*VReplicationExecRequest) UnmarshalVT 

func (m *VReplicationExecRequest) UnmarshalVT(dAtA []byte) error

type VReplicationExecResponse 

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

func (*VReplicationExecResponse) CloneMessageVT 

func (m *VReplicationExecResponse) CloneMessageVT() proto.Message

func (*VReplicationExecResponse) CloneVT 

func (m *VReplicationExecResponse) CloneVT() *VReplicationExecResponse

func (*VReplicationExecResponse) Descriptor deprecated 

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

Deprecated: Use VReplicationExecResponse.ProtoReflect.Descriptor instead.

func (*VReplicationExecResponse) GetResult 

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

func (*VReplicationExecResponse) MarshalToSizedBufferVT 

func (m *VReplicationExecResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VReplicationExecResponse) MarshalToVT 

func (m *VReplicationExecResponse) MarshalToVT(dAtA []byte) (int, error)

func (*VReplicationExecResponse) MarshalVT 

func (m *VReplicationExecResponse) MarshalVT() (dAtA []byte, err error)

func (*VReplicationExecResponse) ProtoMessage 

func (*VReplicationExecResponse) ProtoMessage()

func (*VReplicationExecResponse) ProtoReflect 

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

func (*VReplicationExecResponse) Reset 

func (x *VReplicationExecResponse) Reset()

func (*VReplicationExecResponse) SizeVT 

func (m *VReplicationExecResponse) SizeVT() (n int)

func (*VReplicationExecResponse) String 

func (x *VReplicationExecResponse) String() string

func (*VReplicationExecResponse) UnmarshalVT 

func (m *VReplicationExecResponse) UnmarshalVT(dAtA []byte) error

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

func (m *VReplicationWaitForPosRequest) CloneMessageVT() proto.Message

func (*VReplicationWaitForPosRequest) CloneVT 

func (m *VReplicationWaitForPosRequest) CloneVT() *VReplicationWaitForPosRequest

func (*VReplicationWaitForPosRequest) Descriptor deprecated 

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

Deprecated: Use VReplicationWaitForPosRequest.ProtoReflect.Descriptor instead.

func (*VReplicationWaitForPosRequest) GetId 

func (x *VReplicationWaitForPosRequest) GetId() int32

func (*VReplicationWaitForPosRequest) GetPosition 

func (x *VReplicationWaitForPosRequest) GetPosition() string

func (*VReplicationWaitForPosRequest) MarshalToSizedBufferVT 

func (m *VReplicationWaitForPosRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VReplicationWaitForPosRequest) MarshalToVT 

func (m *VReplicationWaitForPosRequest) MarshalToVT(dAtA []byte) (int, error)

func (*VReplicationWaitForPosRequest) MarshalVT 

func (m *VReplicationWaitForPosRequest) MarshalVT() (dAtA []byte, err error)

func (*VReplicationWaitForPosRequest) ProtoMessage 

func (*VReplicationWaitForPosRequest) ProtoMessage()

func (*VReplicationWaitForPosRequest) ProtoReflect 

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

func (*VReplicationWaitForPosRequest) Reset 

func (x *VReplicationWaitForPosRequest) Reset()

func (*VReplicationWaitForPosRequest) SizeVT 

func (m *VReplicationWaitForPosRequest) SizeVT() (n int)

func (*VReplicationWaitForPosRequest) String 

func (x *VReplicationWaitForPosRequest) String() string

func (*VReplicationWaitForPosRequest) UnmarshalVT 

func (m *VReplicationWaitForPosRequest) UnmarshalVT(dAtA []byte) error

type VReplicationWaitForPosResponse 

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

func (*VReplicationWaitForPosResponse) CloneMessageVT 

func (m *VReplicationWaitForPosResponse) CloneMessageVT() proto.Message

func (*VReplicationWaitForPosResponse) CloneVT 

func (m *VReplicationWaitForPosResponse) CloneVT() *VReplicationWaitForPosResponse

func (*VReplicationWaitForPosResponse) Descriptor deprecated 

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

Deprecated: Use VReplicationWaitForPosResponse.ProtoReflect.Descriptor instead.

func (*VReplicationWaitForPosResponse) MarshalToSizedBufferVT 

func (m *VReplicationWaitForPosResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VReplicationWaitForPosResponse) MarshalToVT 

func (m *VReplicationWaitForPosResponse) MarshalToVT(dAtA []byte) (int, error)

func (*VReplicationWaitForPosResponse) MarshalVT 

func (m *VReplicationWaitForPosResponse) MarshalVT() (dAtA []byte, err error)

func (*VReplicationWaitForPosResponse) ProtoMessage 

func (*VReplicationWaitForPosResponse) ProtoMessage()

func (*VReplicationWaitForPosResponse) ProtoReflect 

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

func (*VReplicationWaitForPosResponse) Reset 

func (x *VReplicationWaitForPosResponse) Reset()

func (*VReplicationWaitForPosResponse) SizeVT 

func (m *VReplicationWaitForPosResponse) SizeVT() (n int)

func (*VReplicationWaitForPosResponse) String 

func (x *VReplicationWaitForPosResponse) String() string

func (*VReplicationWaitForPosResponse) UnmarshalVT 

func (m *VReplicationWaitForPosResponse) UnmarshalVT(dAtA []byte) error

type WaitForPositionRequest 

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

func (*WaitForPositionRequest) CloneMessageVT 

func (m *WaitForPositionRequest) CloneMessageVT() proto.Message

func (*WaitForPositionRequest) CloneVT 

func (m *WaitForPositionRequest) CloneVT() *WaitForPositionRequest

func (*WaitForPositionRequest) Descriptor deprecated 

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

Deprecated: Use WaitForPositionRequest.ProtoReflect.Descriptor instead.

func (*WaitForPositionRequest) GetPosition 

func (x *WaitForPositionRequest) GetPosition() string

func (*WaitForPositionRequest) MarshalToSizedBufferVT 

func (m *WaitForPositionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WaitForPositionRequest) MarshalToVT 

func (m *WaitForPositionRequest) MarshalToVT(dAtA []byte) (int, error)

func (*WaitForPositionRequest) MarshalVT 

func (m *WaitForPositionRequest) MarshalVT() (dAtA []byte, err error)

func (*WaitForPositionRequest) ProtoMessage 

func (*WaitForPositionRequest) ProtoMessage()

func (*WaitForPositionRequest) ProtoReflect 

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

func (*WaitForPositionRequest) Reset 

func (x *WaitForPositionRequest) Reset()

func (*WaitForPositionRequest) SizeVT 

func (m *WaitForPositionRequest) SizeVT() (n int)

func (*WaitForPositionRequest) String 

func (x *WaitForPositionRequest) String() string

func (*WaitForPositionRequest) UnmarshalVT 

func (m *WaitForPositionRequest) UnmarshalVT(dAtA []byte) error

type WaitForPositionResponse 

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

func (*WaitForPositionResponse) CloneMessageVT 

func (m *WaitForPositionResponse) CloneMessageVT() proto.Message

func (*WaitForPositionResponse) CloneVT 

func (m *WaitForPositionResponse) CloneVT() *WaitForPositionResponse

func (*WaitForPositionResponse) Descriptor deprecated 

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

Deprecated: Use WaitForPositionResponse.ProtoReflect.Descriptor instead.

func (*WaitForPositionResponse) MarshalToSizedBufferVT 

func (m *WaitForPositionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WaitForPositionResponse) MarshalToVT 

func (m *WaitForPositionResponse) MarshalToVT(dAtA []byte) (int, error)

func (*WaitForPositionResponse) MarshalVT 

func (m *WaitForPositionResponse) MarshalVT() (dAtA []byte, err error)

func (*WaitForPositionResponse) ProtoMessage 

func (*WaitForPositionResponse) ProtoMessage()

func (*WaitForPositionResponse) ProtoReflect 

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

func (*WaitForPositionResponse) Reset 

func (x *WaitForPositionResponse) Reset()

func (*WaitForPositionResponse) SizeVT 

func (m *WaitForPositionResponse) SizeVT() (n int)

func (*WaitForPositionResponse) String 

func (x *WaitForPositionResponse) String() string

func (*WaitForPositionResponse) UnmarshalVT 

func (m *WaitForPositionResponse) UnmarshalVT(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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