tabletmanagerdata

package
v0.19.6 Latest Latest
Warning

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

 Go to latest Published: Sep 11, 2024 License: Apache-2.0 Imports: 17 Imported by: 28

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

func (*ApplySchemaRequest) CloneMessageVT added in v0.18.0 

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

func (*ApplySchemaRequest) CloneVT added in v0.18.0 

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 added in v0.18.0 

func (x *ApplySchemaRequest) GetBatchSize() int64

func (*ApplySchemaRequest) GetBeforeSchema 

func (x *ApplySchemaRequest) GetBeforeSchema() *SchemaDefinition

func (*ApplySchemaRequest) GetForce 

func (x *ApplySchemaRequest) GetForce() bool

func (*ApplySchemaRequest) GetSql 

func (x *ApplySchemaRequest) GetSql() string

func (*ApplySchemaRequest) GetSqlMode added in v0.13.0 

func (x *ApplySchemaRequest) GetSqlMode() string

func (*ApplySchemaRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ApplySchemaRequest) MarshalToVT added in v0.11.0 

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

func (*ApplySchemaRequest) MarshalVT added in v0.11.0 

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

func (*ApplySchemaRequest) ProtoMessage 

func (*ApplySchemaRequest) ProtoMessage()

func (*ApplySchemaRequest) ProtoReflect added in v0.11.0 

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

func (*ApplySchemaRequest) Reset 

func (x *ApplySchemaRequest) Reset()

func (*ApplySchemaRequest) SizeVT added in v0.11.0 

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

func (*ApplySchemaRequest) String 

func (x *ApplySchemaRequest) String() string

func (*ApplySchemaRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*ApplySchemaResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*ApplySchemaResponse) MarshalToVT added in v0.11.0 

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

func (*ApplySchemaResponse) MarshalVT added in v0.11.0 

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

func (*ApplySchemaResponse) ProtoMessage 

func (*ApplySchemaResponse) ProtoMessage()

func (*ApplySchemaResponse) ProtoReflect added in v0.11.0 

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

func (*ApplySchemaResponse) Reset 

func (x *ApplySchemaResponse) Reset()

func (*ApplySchemaResponse) SizeVT added in v0.11.0 

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

func (*ApplySchemaResponse) String 

func (x *ApplySchemaResponse) String() string

func (*ApplySchemaResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*BackupRequest) CloneVT added in v0.18.0 

func (m *BackupRequest) CloneVT() *BackupRequest

func (*BackupRequest) Descriptor deprecated 

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

Deprecated: Use BackupRequest.ProtoReflect.Descriptor instead.

func (*BackupRequest) GetAllowPrimary added in v0.12.0 

func (x *BackupRequest) GetAllowPrimary() bool

func (*BackupRequest) GetConcurrency 

func (x *BackupRequest) GetConcurrency() int32

func (*BackupRequest) GetIncrementalFromPos added in v0.16.0 

func (x *BackupRequest) GetIncrementalFromPos() string

func (*BackupRequest) GetUpgradeSafe added in v0.18.0 

func (x *BackupRequest) GetUpgradeSafe() bool

func (*BackupRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*BackupRequest) MarshalToVT added in v0.11.0 

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

func (*BackupRequest) MarshalVT added in v0.11.0 

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

func (*BackupRequest) ProtoMessage 

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) ProtoReflect added in v0.11.0 

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

func (*BackupRequest) Reset 

func (x *BackupRequest) Reset()

func (*BackupRequest) SizeVT added in v0.11.0 

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

func (*BackupRequest) String 

func (x *BackupRequest) String() string

func (*BackupRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*BackupResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*BackupResponse) MarshalToVT added in v0.11.0 

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

func (*BackupResponse) MarshalVT added in v0.11.0 

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

func (*BackupResponse) ProtoMessage 

func (*BackupResponse) ProtoMessage()

func (*BackupResponse) ProtoReflect added in v0.11.0 

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

func (*BackupResponse) Reset 

func (x *BackupResponse) Reset()

func (*BackupResponse) SizeVT added in v0.11.0 

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

func (*BackupResponse) String 

func (x *BackupResponse) String() string

func (*BackupResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*ChangeTypeRequest) CloneVT added in v0.18.0 

func (m *ChangeTypeRequest) CloneVT() *ChangeTypeRequest

func (*ChangeTypeRequest) Descriptor deprecated 

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

Deprecated: Use ChangeTypeRequest.ProtoReflect.Descriptor instead.

func (*ChangeTypeRequest) GetSemiSync added in v0.13.0 

func (x *ChangeTypeRequest) GetSemiSync() bool

func (*ChangeTypeRequest) GetTabletType 

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

func (*ChangeTypeRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ChangeTypeRequest) MarshalToVT added in v0.11.0 

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

func (*ChangeTypeRequest) MarshalVT added in v0.11.0 

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

func (*ChangeTypeRequest) ProtoMessage 

func (*ChangeTypeRequest) ProtoMessage()

func (*ChangeTypeRequest) ProtoReflect added in v0.11.0 

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

func (*ChangeTypeRequest) Reset 

func (x *ChangeTypeRequest) Reset()

func (*ChangeTypeRequest) SizeVT added in v0.11.0 

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

func (*ChangeTypeRequest) String 

func (x *ChangeTypeRequest) String() string

func (*ChangeTypeRequest) UnmarshalVT added in v0.11.0 

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

type ChangeTypeResponse 

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

func (*ChangeTypeResponse) CloneMessageVT added in v0.18.0 

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

func (*ChangeTypeResponse) CloneVT added in v0.18.0 

func (m *ChangeTypeResponse) CloneVT() *ChangeTypeResponse

func (*ChangeTypeResponse) Descriptor deprecated 

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

Deprecated: Use ChangeTypeResponse.ProtoReflect.Descriptor instead.

func (*ChangeTypeResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ChangeTypeResponse) MarshalToVT added in v0.11.0 

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

func (*ChangeTypeResponse) MarshalVT added in v0.11.0 

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

func (*ChangeTypeResponse) ProtoMessage 

func (*ChangeTypeResponse) ProtoMessage()

func (*ChangeTypeResponse) ProtoReflect added in v0.11.0 

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

func (*ChangeTypeResponse) Reset 

func (x *ChangeTypeResponse) Reset()

func (*ChangeTypeResponse) SizeVT added in v0.11.0 

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

func (*ChangeTypeResponse) String 

func (x *ChangeTypeResponse) String() string

func (*ChangeTypeResponse) UnmarshalVT added in v0.11.0 

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

type CheckThrottlerRequest added in v0.18.0 

type CheckThrottlerRequest struct {
	AppName string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckThrottlerRequest) CloneMessageVT added in v0.18.0 

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

func (*CheckThrottlerRequest) CloneVT added in v0.18.0 

func (m *CheckThrottlerRequest) CloneVT() *CheckThrottlerRequest

func (*CheckThrottlerRequest) Descriptor deprecated added in v0.18.0 

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

Deprecated: Use CheckThrottlerRequest.ProtoReflect.Descriptor instead.

func (*CheckThrottlerRequest) GetAppName added in v0.18.0 

func (x *CheckThrottlerRequest) GetAppName() string

func (*CheckThrottlerRequest) MarshalToSizedBufferVT added in v0.18.0 

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

func (*CheckThrottlerRequest) MarshalToVT added in v0.18.0 

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

func (*CheckThrottlerRequest) MarshalVT added in v0.18.0 

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

func (*CheckThrottlerRequest) ProtoMessage added in v0.18.0 

func (*CheckThrottlerRequest) ProtoMessage()

func (*CheckThrottlerRequest) ProtoReflect added in v0.18.0 

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

func (*CheckThrottlerRequest) Reset added in v0.18.0 

func (x *CheckThrottlerRequest) Reset()

func (*CheckThrottlerRequest) SizeVT added in v0.18.0 

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

func (*CheckThrottlerRequest) String added in v0.18.0 

func (x *CheckThrottlerRequest) String() string

func (*CheckThrottlerRequest) UnmarshalVT added in v0.18.0 

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

type CheckThrottlerResponse added in v0.18.0 

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

func (*CheckThrottlerResponse) CloneMessageVT added in v0.18.0 

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

func (*CheckThrottlerResponse) CloneVT added in v0.18.0 

func (m *CheckThrottlerResponse) CloneVT() *CheckThrottlerResponse

func (*CheckThrottlerResponse) Descriptor deprecated added in v0.18.0 

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

Deprecated: Use CheckThrottlerResponse.ProtoReflect.Descriptor instead.

func (*CheckThrottlerResponse) GetError added in v0.18.0 

func (x *CheckThrottlerResponse) GetError() string

func (*CheckThrottlerResponse) GetMessage added in v0.18.0 

func (x *CheckThrottlerResponse) GetMessage() string

func (*CheckThrottlerResponse) GetRecentlyChecked added in v0.18.0 

func (x *CheckThrottlerResponse) GetRecentlyChecked() bool

func (*CheckThrottlerResponse) GetStatusCode added in v0.18.0 

func (x *CheckThrottlerResponse) GetStatusCode() int32

func (*CheckThrottlerResponse) GetThreshold added in v0.18.0 

func (x *CheckThrottlerResponse) GetThreshold() float64

func (*CheckThrottlerResponse) GetValue added in v0.18.0 

func (x *CheckThrottlerResponse) GetValue() float64

func (*CheckThrottlerResponse) MarshalToSizedBufferVT added in v0.18.0 

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

func (*CheckThrottlerResponse) MarshalToVT added in v0.18.0 

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

func (*CheckThrottlerResponse) MarshalVT added in v0.18.0 

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

func (*CheckThrottlerResponse) ProtoMessage added in v0.18.0 

func (*CheckThrottlerResponse) ProtoMessage()

func (*CheckThrottlerResponse) ProtoReflect added in v0.18.0 

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

func (*CheckThrottlerResponse) Reset added in v0.18.0 

func (x *CheckThrottlerResponse) Reset()

func (*CheckThrottlerResponse) SizeVT added in v0.18.0 

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

func (*CheckThrottlerResponse) String added in v0.18.0 

func (x *CheckThrottlerResponse) String() string

func (*CheckThrottlerResponse) UnmarshalVT added in v0.18.0 

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

type CreateVReplicationWorkflowRequest added in v0.18.0 

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

func (*CreateVReplicationWorkflowRequest) CloneMessageVT added in v0.18.0 

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

func (*CreateVReplicationWorkflowRequest) CloneVT added in v0.18.0 

func (m *CreateVReplicationWorkflowRequest) CloneVT() *CreateVReplicationWorkflowRequest

func (*CreateVReplicationWorkflowRequest) Descriptor deprecated added in v0.18.0 

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

Deprecated: Use CreateVReplicationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*CreateVReplicationWorkflowRequest) GetAutoStart added in v0.18.0 

func (x *CreateVReplicationWorkflowRequest) GetAutoStart() bool

func (*CreateVReplicationWorkflowRequest) GetBinlogSource added in v0.18.0 

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

func (*CreateVReplicationWorkflowRequest) GetCells added in v0.18.0 

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

func (*CreateVReplicationWorkflowRequest) GetDeferSecondaryKeys added in v0.18.0 

func (x *CreateVReplicationWorkflowRequest) GetDeferSecondaryKeys() bool

func (*CreateVReplicationWorkflowRequest) GetStopAfterCopy added in v0.18.0 

func (x *CreateVReplicationWorkflowRequest) GetStopAfterCopy() bool

func (*CreateVReplicationWorkflowRequest) GetTabletSelectionPreference added in v0.18.0 

func (x *CreateVReplicationWorkflowRequest) GetTabletSelectionPreference() TabletSelectionPreference

func (*CreateVReplicationWorkflowRequest) GetTabletTypes added in v0.18.0 

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

func (*CreateVReplicationWorkflowRequest) GetWorkflow added in v0.18.0 

func (x *CreateVReplicationWorkflowRequest) GetWorkflow() string

func (*CreateVReplicationWorkflowRequest) GetWorkflowSubType added in v0.18.0 

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

func (*CreateVReplicationWorkflowRequest) GetWorkflowType added in v0.18.0 

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

func (*CreateVReplicationWorkflowRequest) MarshalToSizedBufferVT added in v0.18.0 

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

func (*CreateVReplicationWorkflowRequest) MarshalToVT added in v0.18.0 

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

func (*CreateVReplicationWorkflowRequest) MarshalVT added in v0.18.0 

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

func (*CreateVReplicationWorkflowRequest) ProtoMessage added in v0.18.0 

func (*CreateVReplicationWorkflowRequest) ProtoMessage()

func (*CreateVReplicationWorkflowRequest) ProtoReflect added in v0.18.0 

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

func (*CreateVReplicationWorkflowRequest) Reset added in v0.18.0 

func (x *CreateVReplicationWorkflowRequest) Reset()

func (*CreateVReplicationWorkflowRequest) SizeVT added in v0.18.0 

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

func (*CreateVReplicationWorkflowRequest) String added in v0.18.0 

func (x *CreateVReplicationWorkflowRequest) String() string

func (*CreateVReplicationWorkflowRequest) UnmarshalVT added in v0.18.0 

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

type CreateVReplicationWorkflowResponse added in v0.18.0 

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

func (*CreateVReplicationWorkflowResponse) CloneMessageVT added in v0.18.0 

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

func (*CreateVReplicationWorkflowResponse) CloneVT added in v0.18.0 

func (m *CreateVReplicationWorkflowResponse) CloneVT() *CreateVReplicationWorkflowResponse

func (*CreateVReplicationWorkflowResponse) Descriptor deprecated added in v0.18.0 

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

Deprecated: Use CreateVReplicationWorkflowResponse.ProtoReflect.Descriptor instead.

func (*CreateVReplicationWorkflowResponse) GetResult added in v0.18.0 

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

func (*CreateVReplicationWorkflowResponse) MarshalToSizedBufferVT added in v0.18.0 

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

func (*CreateVReplicationWorkflowResponse) MarshalToVT added in v0.18.0 

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

func (*CreateVReplicationWorkflowResponse) MarshalVT added in v0.18.0 

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

func (*CreateVReplicationWorkflowResponse) ProtoMessage added in v0.18.0 

func (*CreateVReplicationWorkflowResponse) ProtoMessage()

func (*CreateVReplicationWorkflowResponse) ProtoReflect added in v0.18.0 

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

func (*CreateVReplicationWorkflowResponse) Reset added in v0.18.0 

func (x *CreateVReplicationWorkflowResponse) Reset()

func (*CreateVReplicationWorkflowResponse) SizeVT added in v0.18.0 

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

func (*CreateVReplicationWorkflowResponse) String added in v0.18.0 

func (x *CreateVReplicationWorkflowResponse) String() string

func (*CreateVReplicationWorkflowResponse) UnmarshalVT added in v0.18.0 

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 added in v0.18.0 

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

func (*DbPermission) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*DbPermission) MarshalToVT added in v0.11.0 

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

func (*DbPermission) MarshalVT added in v0.11.0 

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

func (*DbPermission) ProtoMessage 

func (*DbPermission) ProtoMessage()

func (*DbPermission) ProtoReflect added in v0.11.0 

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

func (*DbPermission) Reset 

func (x *DbPermission) Reset()

func (*DbPermission) SizeVT added in v0.11.0 

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

func (*DbPermission) String 

func (x *DbPermission) String() string

func (*DbPermission) UnmarshalVT added in v0.11.0 

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

type DeleteVReplicationWorkflowRequest added in v0.18.0 

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

func (*DeleteVReplicationWorkflowRequest) CloneMessageVT added in v0.18.0 

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

func (*DeleteVReplicationWorkflowRequest) CloneVT added in v0.18.0 

func (m *DeleteVReplicationWorkflowRequest) CloneVT() *DeleteVReplicationWorkflowRequest

func (*DeleteVReplicationWorkflowRequest) Descriptor deprecated added in v0.18.0 

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

Deprecated: Use DeleteVReplicationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*DeleteVReplicationWorkflowRequest) GetWorkflow added in v0.18.0 

func (x *DeleteVReplicationWorkflowRequest) GetWorkflow() string

func (*DeleteVReplicationWorkflowRequest) MarshalToSizedBufferVT added in v0.18.0 

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

func (*DeleteVReplicationWorkflowRequest) MarshalToVT added in v0.18.0 

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

func (*DeleteVReplicationWorkflowRequest) MarshalVT added in v0.18.0 

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

func (*DeleteVReplicationWorkflowRequest) ProtoMessage added in v0.18.0 

func (*DeleteVReplicationWorkflowRequest) ProtoMessage()

func (*DeleteVReplicationWorkflowRequest) ProtoReflect added in v0.18.0 

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

func (*DeleteVReplicationWorkflowRequest) Reset added in v0.18.0 

func (x *DeleteVReplicationWorkflowRequest) Reset()

func (*DeleteVReplicationWorkflowRequest) SizeVT added in v0.18.0 

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

func (*DeleteVReplicationWorkflowRequest) String added in v0.18.0 

func (x *DeleteVReplicationWorkflowRequest) String() string

func (*DeleteVReplicationWorkflowRequest) UnmarshalVT added in v0.18.0 

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

type DeleteVReplicationWorkflowResponse added in v0.18.0 

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

func (*DeleteVReplicationWorkflowResponse) CloneMessageVT added in v0.18.0 

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

func (*DeleteVReplicationWorkflowResponse) CloneVT added in v0.18.0 

func (m *DeleteVReplicationWorkflowResponse) CloneVT() *DeleteVReplicationWorkflowResponse

func (*DeleteVReplicationWorkflowResponse) Descriptor deprecated added in v0.18.0 

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

Deprecated: Use DeleteVReplicationWorkflowResponse.ProtoReflect.Descriptor instead.

func (*DeleteVReplicationWorkflowResponse) GetResult added in v0.18.0 

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

func (*DeleteVReplicationWorkflowResponse) MarshalToSizedBufferVT added in v0.18.0 

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

func (*DeleteVReplicationWorkflowResponse) MarshalToVT added in v0.18.0 

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

func (*DeleteVReplicationWorkflowResponse) MarshalVT added in v0.18.0 

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

func (*DeleteVReplicationWorkflowResponse) ProtoMessage added in v0.18.0 

func (*DeleteVReplicationWorkflowResponse) ProtoMessage()

func (*DeleteVReplicationWorkflowResponse) ProtoReflect added in v0.18.0 

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

func (*DeleteVReplicationWorkflowResponse) Reset added in v0.18.0 

func (x *DeleteVReplicationWorkflowResponse) Reset()

func (*DeleteVReplicationWorkflowResponse) SizeVT added in v0.18.0 

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

func (*DeleteVReplicationWorkflowResponse) String added in v0.18.0 

func (x *DeleteVReplicationWorkflowResponse) String() string

func (*DeleteVReplicationWorkflowResponse) UnmarshalVT added in v0.18.0 

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

type DemotePrimaryRequest added in v0.12.0 

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

func (*DemotePrimaryRequest) CloneMessageVT added in v0.18.0 

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

func (*DemotePrimaryRequest) CloneVT added in v0.18.0 

func (m *DemotePrimaryRequest) CloneVT() *DemotePrimaryRequest

func (*DemotePrimaryRequest) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use DemotePrimaryRequest.ProtoReflect.Descriptor instead.

func (*DemotePrimaryRequest) MarshalToSizedBufferVT added in v0.12.0 

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

func (*DemotePrimaryRequest) MarshalToVT added in v0.12.0 

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

func (*DemotePrimaryRequest) MarshalVT added in v0.12.0 

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

func (*DemotePrimaryRequest) ProtoMessage added in v0.12.0 

func (*DemotePrimaryRequest) ProtoMessage()

func (*DemotePrimaryRequest) ProtoReflect added in v0.12.0 

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

func (*DemotePrimaryRequest) Reset added in v0.12.0 

func (x *DemotePrimaryRequest) Reset()

func (*DemotePrimaryRequest) SizeVT added in v0.12.0 

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

func (*DemotePrimaryRequest) String added in v0.12.0 

func (x *DemotePrimaryRequest) String() string

func (*DemotePrimaryRequest) UnmarshalVT added in v0.12.0 

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

type DemotePrimaryResponse added in v0.12.0 

type DemotePrimaryResponse struct {

	// PrimaryStatus represents the response from calling `SHOW MASTER 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 added in v0.18.0 

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

func (*DemotePrimaryResponse) CloneVT added in v0.18.0 

func (m *DemotePrimaryResponse) CloneVT() *DemotePrimaryResponse

func (*DemotePrimaryResponse) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use DemotePrimaryResponse.ProtoReflect.Descriptor instead.

func (*DemotePrimaryResponse) GetPrimaryStatus added in v0.12.0 

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

func (*DemotePrimaryResponse) MarshalToSizedBufferVT added in v0.12.0 

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

func (*DemotePrimaryResponse) MarshalToVT added in v0.12.0 

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

func (*DemotePrimaryResponse) MarshalVT added in v0.12.0 

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

func (*DemotePrimaryResponse) ProtoMessage added in v0.12.0 

func (*DemotePrimaryResponse) ProtoMessage()

func (*DemotePrimaryResponse) ProtoReflect added in v0.12.0 

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

func (*DemotePrimaryResponse) Reset added in v0.12.0 

func (x *DemotePrimaryResponse) Reset()

func (*DemotePrimaryResponse) SizeVT added in v0.12.0 

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

func (*DemotePrimaryResponse) String added in v0.12.0 

func (x *DemotePrimaryResponse) String() string

func (*DemotePrimaryResponse) UnmarshalVT added in v0.12.0 

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 added in v0.18.0 

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

func (*ExecuteFetchAsAllPrivsRequest) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*ExecuteFetchAsAllPrivsRequest) MarshalToVT added in v0.11.0 

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

func (*ExecuteFetchAsAllPrivsRequest) MarshalVT added in v0.11.0 

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

func (*ExecuteFetchAsAllPrivsRequest) ProtoMessage 

func (*ExecuteFetchAsAllPrivsRequest) ProtoMessage()

func (*ExecuteFetchAsAllPrivsRequest) ProtoReflect added in v0.11.0 

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

func (*ExecuteFetchAsAllPrivsRequest) Reset 

func (x *ExecuteFetchAsAllPrivsRequest) Reset()

func (*ExecuteFetchAsAllPrivsRequest) SizeVT added in v0.11.0 

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

func (*ExecuteFetchAsAllPrivsRequest) String 

func (x *ExecuteFetchAsAllPrivsRequest) String() string

func (*ExecuteFetchAsAllPrivsRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*ExecuteFetchAsAllPrivsResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*ExecuteFetchAsAllPrivsResponse) MarshalToVT added in v0.11.0 

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

func (*ExecuteFetchAsAllPrivsResponse) MarshalVT added in v0.11.0 

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

func (*ExecuteFetchAsAllPrivsResponse) ProtoMessage 

func (*ExecuteFetchAsAllPrivsResponse) ProtoMessage()

func (*ExecuteFetchAsAllPrivsResponse) ProtoReflect added in v0.11.0 

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

func (*ExecuteFetchAsAllPrivsResponse) Reset 

func (x *ExecuteFetchAsAllPrivsResponse) Reset()

func (*ExecuteFetchAsAllPrivsResponse) SizeVT added in v0.11.0 

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

func (*ExecuteFetchAsAllPrivsResponse) String 

func (x *ExecuteFetchAsAllPrivsResponse) String() string

func (*ExecuteFetchAsAllPrivsResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*ExecuteFetchAsAppRequest) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*ExecuteFetchAsAppRequest) MarshalToVT added in v0.11.0 

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

func (*ExecuteFetchAsAppRequest) MarshalVT added in v0.11.0 

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

func (*ExecuteFetchAsAppRequest) ProtoMessage 

func (*ExecuteFetchAsAppRequest) ProtoMessage()

func (*ExecuteFetchAsAppRequest) ProtoReflect added in v0.11.0 

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

func (*ExecuteFetchAsAppRequest) Reset 

func (x *ExecuteFetchAsAppRequest) Reset()

func (*ExecuteFetchAsAppRequest) SizeVT added in v0.11.0 

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

func (*ExecuteFetchAsAppRequest) String 

func (x *ExecuteFetchAsAppRequest) String() string

func (*ExecuteFetchAsAppRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*ExecuteFetchAsAppResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*ExecuteFetchAsAppResponse) MarshalToVT added in v0.11.0 

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

func (*ExecuteFetchAsAppResponse) MarshalVT added in v0.11.0 

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

func (*ExecuteFetchAsAppResponse) ProtoMessage 

func (*ExecuteFetchAsAppResponse) ProtoMessage()

func (*ExecuteFetchAsAppResponse) ProtoReflect added in v0.11.0 

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

func (*ExecuteFetchAsAppResponse) Reset 

func (x *ExecuteFetchAsAppResponse) Reset()

func (*ExecuteFetchAsAppResponse) SizeVT added in v0.11.0 

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

func (*ExecuteFetchAsAppResponse) String 

func (x *ExecuteFetchAsAppResponse) String() string

func (*ExecuteFetchAsAppResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*ExecuteFetchAsDbaRequest) CloneVT added in v0.18.0 

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 added in v0.19.0 

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 added in v0.11.0 

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

func (*ExecuteFetchAsDbaRequest) MarshalToVT added in v0.11.0 

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

func (*ExecuteFetchAsDbaRequest) MarshalVT added in v0.11.0 

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

func (*ExecuteFetchAsDbaRequest) ProtoMessage 

func (*ExecuteFetchAsDbaRequest) ProtoMessage()

func (*ExecuteFetchAsDbaRequest) ProtoReflect added in v0.11.0 

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

func (*ExecuteFetchAsDbaRequest) Reset 

func (x *ExecuteFetchAsDbaRequest) Reset()

func (*ExecuteFetchAsDbaRequest) SizeVT added in v0.11.0 

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

func (*ExecuteFetchAsDbaRequest) String 

func (x *ExecuteFetchAsDbaRequest) String() string

func (*ExecuteFetchAsDbaRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*ExecuteFetchAsDbaResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*ExecuteFetchAsDbaResponse) MarshalToVT added in v0.11.0 

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

func (*ExecuteFetchAsDbaResponse) MarshalVT added in v0.11.0 

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

func (*ExecuteFetchAsDbaResponse) ProtoMessage 

func (*ExecuteFetchAsDbaResponse) ProtoMessage()

func (*ExecuteFetchAsDbaResponse) ProtoReflect added in v0.11.0 

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

func (*ExecuteFetchAsDbaResponse) Reset 

func (x *ExecuteFetchAsDbaResponse) Reset()

func (*ExecuteFetchAsDbaResponse) SizeVT added in v0.11.0 

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

func (*ExecuteFetchAsDbaResponse) String 

func (x *ExecuteFetchAsDbaResponse) String() string

func (*ExecuteFetchAsDbaResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*ExecuteHookRequest) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*ExecuteHookRequest) MarshalToVT added in v0.11.0 

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

func (*ExecuteHookRequest) MarshalVT added in v0.11.0 

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

func (*ExecuteHookRequest) ProtoMessage 

func (*ExecuteHookRequest) ProtoMessage()

func (*ExecuteHookRequest) ProtoReflect added in v0.11.0 

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

func (*ExecuteHookRequest) Reset 

func (x *ExecuteHookRequest) Reset()

func (*ExecuteHookRequest) SizeVT added in v0.11.0 

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

func (*ExecuteHookRequest) String 

func (x *ExecuteHookRequest) String() string

func (*ExecuteHookRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*ExecuteHookResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*ExecuteHookResponse) MarshalToVT added in v0.11.0 

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

func (*ExecuteHookResponse) MarshalVT added in v0.11.0 

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

func (*ExecuteHookResponse) ProtoMessage 

func (*ExecuteHookResponse) ProtoMessage()

func (*ExecuteHookResponse) ProtoReflect added in v0.11.0 

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

func (*ExecuteHookResponse) Reset 

func (x *ExecuteHookResponse) Reset()

func (*ExecuteHookResponse) SizeVT added in v0.11.0 

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

func (*ExecuteHookResponse) String 

func (x *ExecuteHookResponse) String() string

func (*ExecuteHookResponse) UnmarshalVT added in v0.11.0 

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

type ExecuteQueryRequest added in v0.11.0 

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 added in v0.18.0 

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

func (*ExecuteQueryRequest) CloneVT added in v0.18.0 

func (m *ExecuteQueryRequest) CloneVT() *ExecuteQueryRequest

func (*ExecuteQueryRequest) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use ExecuteQueryRequest.ProtoReflect.Descriptor instead.

func (*ExecuteQueryRequest) GetCallerId added in v0.13.0 

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

func (*ExecuteQueryRequest) GetDbName added in v0.11.0 

func (x *ExecuteQueryRequest) GetDbName() string

func (*ExecuteQueryRequest) GetMaxRows added in v0.11.0 

func (x *ExecuteQueryRequest) GetMaxRows() uint64

func (*ExecuteQueryRequest) GetQuery added in v0.11.0 

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

func (*ExecuteQueryRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ExecuteQueryRequest) MarshalToVT added in v0.11.0 

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

func (*ExecuteQueryRequest) MarshalVT added in v0.11.0 

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

func (*ExecuteQueryRequest) ProtoMessage added in v0.11.0 

func (*ExecuteQueryRequest) ProtoMessage()

func (*ExecuteQueryRequest) ProtoReflect added in v0.11.0 

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

func (*ExecuteQueryRequest) Reset added in v0.11.0 

func (x *ExecuteQueryRequest) Reset()

func (*ExecuteQueryRequest) SizeVT added in v0.11.0 

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

func (*ExecuteQueryRequest) String added in v0.11.0 

func (x *ExecuteQueryRequest) String() string

func (*ExecuteQueryRequest) UnmarshalVT added in v0.11.0 

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

type ExecuteQueryResponse added in v0.11.0 

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

func (*ExecuteQueryResponse) CloneMessageVT added in v0.18.0 

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

func (*ExecuteQueryResponse) CloneVT added in v0.18.0 

func (m *ExecuteQueryResponse) CloneVT() *ExecuteQueryResponse

func (*ExecuteQueryResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use ExecuteQueryResponse.ProtoReflect.Descriptor instead.

func (*ExecuteQueryResponse) GetResult added in v0.11.0 

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

func (*ExecuteQueryResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ExecuteQueryResponse) MarshalToVT added in v0.11.0 

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

func (*ExecuteQueryResponse) MarshalVT added in v0.11.0 

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

func (*ExecuteQueryResponse) ProtoMessage added in v0.11.0 

func (*ExecuteQueryResponse) ProtoMessage()

func (*ExecuteQueryResponse) ProtoReflect added in v0.11.0 

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

func (*ExecuteQueryResponse) Reset added in v0.11.0 

func (x *ExecuteQueryResponse) Reset()

func (*ExecuteQueryResponse) SizeVT added in v0.11.0 

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

func (*ExecuteQueryResponse) String added in v0.11.0 

func (x *ExecuteQueryResponse) String() string

func (*ExecuteQueryResponse) UnmarshalVT added in v0.11.0 

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

type FullStatusRequest added in v0.14.0 

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

func (*FullStatusRequest) CloneMessageVT added in v0.18.0 

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

func (*FullStatusRequest) CloneVT added in v0.18.0 

func (m *FullStatusRequest) CloneVT() *FullStatusRequest

func (*FullStatusRequest) Descriptor deprecated added in v0.14.0 

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

Deprecated: Use FullStatusRequest.ProtoReflect.Descriptor instead.

func (*FullStatusRequest) MarshalToSizedBufferVT added in v0.14.0 

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

func (*FullStatusRequest) MarshalToVT added in v0.14.0 

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

func (*FullStatusRequest) MarshalVT added in v0.14.0 

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

func (*FullStatusRequest) ProtoMessage added in v0.14.0 

func (*FullStatusRequest) ProtoMessage()

func (*FullStatusRequest) ProtoReflect added in v0.14.0 

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

func (*FullStatusRequest) Reset added in v0.14.0 

func (x *FullStatusRequest) Reset()

func (*FullStatusRequest) SizeVT added in v0.14.0 

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

func (*FullStatusRequest) String added in v0.14.0 

func (x *FullStatusRequest) String() string

func (*FullStatusRequest) UnmarshalVT added in v0.14.0 

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

type FullStatusResponse added in v0.14.0 

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

func (*FullStatusResponse) CloneMessageVT added in v0.18.0 

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

func (*FullStatusResponse) CloneVT added in v0.18.0 

func (m *FullStatusResponse) CloneVT() *FullStatusResponse

func (*FullStatusResponse) Descriptor deprecated added in v0.14.0 

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

Deprecated: Use FullStatusResponse.ProtoReflect.Descriptor instead.

func (*FullStatusResponse) GetStatus added in v0.14.0 

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

func (*FullStatusResponse) MarshalToSizedBufferVT added in v0.14.0 

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

func (*FullStatusResponse) MarshalToVT added in v0.14.0 

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

func (*FullStatusResponse) MarshalVT added in v0.14.0 

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

func (*FullStatusResponse) ProtoMessage added in v0.14.0 

func (*FullStatusResponse) ProtoMessage()

func (*FullStatusResponse) ProtoReflect added in v0.14.0 

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

func (*FullStatusResponse) Reset added in v0.14.0 

func (x *FullStatusResponse) Reset()

func (*FullStatusResponse) SizeVT added in v0.14.0 

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

func (*FullStatusResponse) String added in v0.14.0 

func (x *FullStatusResponse) String() string

func (*FullStatusResponse) UnmarshalVT added in v0.14.0 

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

type GetPermissionsRequest 

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

func (*GetPermissionsRequest) CloneMessageVT added in v0.18.0 

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

func (*GetPermissionsRequest) CloneVT added in v0.18.0 

func (m *GetPermissionsRequest) CloneVT() *GetPermissionsRequest

func (*GetPermissionsRequest) Descriptor deprecated 

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

Deprecated: Use GetPermissionsRequest.ProtoReflect.Descriptor instead.

func (*GetPermissionsRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetPermissionsRequest) MarshalToVT added in v0.11.0 

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

func (*GetPermissionsRequest) MarshalVT added in v0.11.0 

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

func (*GetPermissionsRequest) ProtoMessage 

func (*GetPermissionsRequest) ProtoMessage()

func (*GetPermissionsRequest) ProtoReflect added in v0.11.0 

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

func (*GetPermissionsRequest) Reset 

func (x *GetPermissionsRequest) Reset()

func (*GetPermissionsRequest) SizeVT added in v0.11.0 

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

func (*GetPermissionsRequest) String 

func (x *GetPermissionsRequest) String() string

func (*GetPermissionsRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*GetPermissionsResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*GetPermissionsResponse) MarshalToVT added in v0.11.0 

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

func (*GetPermissionsResponse) MarshalVT added in v0.11.0 

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

func (*GetPermissionsResponse) ProtoMessage 

func (*GetPermissionsResponse) ProtoMessage()

func (*GetPermissionsResponse) ProtoReflect added in v0.11.0 

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

func (*GetPermissionsResponse) Reset 

func (x *GetPermissionsResponse) Reset()

func (*GetPermissionsResponse) SizeVT added in v0.11.0 

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

func (*GetPermissionsResponse) String 

func (x *GetPermissionsResponse) String() string

func (*GetPermissionsResponse) UnmarshalVT added in v0.11.0 

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

type GetReplicasRequest 

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

func (*GetReplicasRequest) CloneMessageVT added in v0.18.0 

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

func (*GetReplicasRequest) CloneVT added in v0.18.0 

func (m *GetReplicasRequest) CloneVT() *GetReplicasRequest

func (*GetReplicasRequest) Descriptor deprecated 

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

Deprecated: Use GetReplicasRequest.ProtoReflect.Descriptor instead.

func (*GetReplicasRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetReplicasRequest) MarshalToVT added in v0.11.0 

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

func (*GetReplicasRequest) MarshalVT added in v0.11.0 

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

func (*GetReplicasRequest) ProtoMessage 

func (*GetReplicasRequest) ProtoMessage()

func (*GetReplicasRequest) ProtoReflect added in v0.11.0 

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

func (*GetReplicasRequest) Reset 

func (x *GetReplicasRequest) Reset()

func (*GetReplicasRequest) SizeVT added in v0.11.0 

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

func (*GetReplicasRequest) String 

func (x *GetReplicasRequest) String() string

func (*GetReplicasRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*GetReplicasResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*GetReplicasResponse) MarshalToVT added in v0.11.0 

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

func (*GetReplicasResponse) MarshalVT added in v0.11.0 

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

func (*GetReplicasResponse) ProtoMessage 

func (*GetReplicasResponse) ProtoMessage()

func (*GetReplicasResponse) ProtoReflect added in v0.11.0 

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

func (*GetReplicasResponse) Reset 

func (x *GetReplicasResponse) Reset()

func (*GetReplicasResponse) SizeVT added in v0.11.0 

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

func (*GetReplicasResponse) String 

func (x *GetReplicasResponse) String() string

func (*GetReplicasResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*GetSchemaRequest) CloneVT added in v0.18.0 

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 added in v0.15.0 

func (x *GetSchemaRequest) GetTableSchemaOnly() bool

func (*GetSchemaRequest) GetTables 

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

func (*GetSchemaRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSchemaRequest) MarshalToVT added in v0.11.0 

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

func (*GetSchemaRequest) MarshalVT added in v0.11.0 

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

func (*GetSchemaRequest) ProtoMessage 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) ProtoReflect added in v0.11.0 

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

func (*GetSchemaRequest) Reset 

func (x *GetSchemaRequest) Reset()

func (*GetSchemaRequest) SizeVT added in v0.11.0 

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

func (*GetSchemaRequest) String 

func (x *GetSchemaRequest) String() string

func (*GetSchemaRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*GetSchemaResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*GetSchemaResponse) MarshalToVT added in v0.11.0 

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

func (*GetSchemaResponse) MarshalVT added in v0.11.0 

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

func (*GetSchemaResponse) ProtoMessage 

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) ProtoReflect added in v0.11.0 

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

func (*GetSchemaResponse) Reset 

func (x *GetSchemaResponse) Reset()

func (*GetSchemaResponse) SizeVT added in v0.11.0 

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

func (*GetSchemaResponse) String 

func (x *GetSchemaResponse) String() string

func (*GetSchemaResponse) UnmarshalVT added in v0.11.0 

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

type InitPrimaryRequest added in v0.12.0 

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

func (*InitPrimaryRequest) CloneMessageVT added in v0.18.0 

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

func (*InitPrimaryRequest) CloneVT added in v0.18.0 

func (m *InitPrimaryRequest) CloneVT() *InitPrimaryRequest

func (*InitPrimaryRequest) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use InitPrimaryRequest.ProtoReflect.Descriptor instead.

func (*InitPrimaryRequest) GetSemiSync added in v0.13.0 

func (x *InitPrimaryRequest) GetSemiSync() bool

func (*InitPrimaryRequest) MarshalToSizedBufferVT added in v0.12.0 

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

func (*InitPrimaryRequest) MarshalToVT added in v0.12.0 

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

func (*InitPrimaryRequest) MarshalVT added in v0.12.0 

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

func (*InitPrimaryRequest) ProtoMessage added in v0.12.0 

func (*InitPrimaryRequest) ProtoMessage()

func (*InitPrimaryRequest) ProtoReflect added in v0.12.0 

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

func (*InitPrimaryRequest) Reset added in v0.12.0 

func (x *InitPrimaryRequest) Reset()

func (*InitPrimaryRequest) SizeVT added in v0.12.0 

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

func (*InitPrimaryRequest) String added in v0.12.0 

func (x *InitPrimaryRequest) String() string

func (*InitPrimaryRequest) UnmarshalVT added in v0.12.0 

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

type InitPrimaryResponse added in v0.12.0 

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

func (*InitPrimaryResponse) CloneMessageVT added in v0.18.0 

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

func (*InitPrimaryResponse) CloneVT added in v0.18.0 

func (m *InitPrimaryResponse) CloneVT() *InitPrimaryResponse

func (*InitPrimaryResponse) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use InitPrimaryResponse.ProtoReflect.Descriptor instead.

func (*InitPrimaryResponse) GetPosition added in v0.12.0 

func (x *InitPrimaryResponse) GetPosition() string

func (*InitPrimaryResponse) MarshalToSizedBufferVT added in v0.12.0 

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

func (*InitPrimaryResponse) MarshalToVT added in v0.12.0 

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

func (*InitPrimaryResponse) MarshalVT added in v0.12.0 

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

func (*InitPrimaryResponse) ProtoMessage added in v0.12.0 

func (*InitPrimaryResponse) ProtoMessage()

func (*InitPrimaryResponse) ProtoReflect added in v0.12.0 

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

func (*InitPrimaryResponse) Reset added in v0.12.0 

func (x *InitPrimaryResponse) Reset()

func (*InitPrimaryResponse) SizeVT added in v0.12.0 

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

func (*InitPrimaryResponse) String added in v0.12.0 

func (x *InitPrimaryResponse) String() string

func (*InitPrimaryResponse) UnmarshalVT added in v0.12.0 

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 added in v0.18.0 

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

func (*InitReplicaRequest) CloneVT added in v0.18.0 

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 added in v0.13.0 

func (x *InitReplicaRequest) GetSemiSync() bool

func (*InitReplicaRequest) GetTimeCreatedNs 

func (x *InitReplicaRequest) GetTimeCreatedNs() int64

func (*InitReplicaRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*InitReplicaRequest) MarshalToVT added in v0.11.0 

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

func (*InitReplicaRequest) MarshalVT added in v0.11.0 

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

func (*InitReplicaRequest) ProtoMessage 

func (*InitReplicaRequest) ProtoMessage()

func (*InitReplicaRequest) ProtoReflect added in v0.11.0 

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

func (*InitReplicaRequest) Reset 

func (x *InitReplicaRequest) Reset()

func (*InitReplicaRequest) SizeVT added in v0.11.0 

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

func (*InitReplicaRequest) String 

func (x *InitReplicaRequest) String() string

func (*InitReplicaRequest) UnmarshalVT added in v0.11.0 

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

type InitReplicaResponse 

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

func (*InitReplicaResponse) CloneMessageVT added in v0.18.0 

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

func (*InitReplicaResponse) CloneVT added in v0.18.0 

func (m *InitReplicaResponse) CloneVT() *InitReplicaResponse

func (*InitReplicaResponse) Descriptor deprecated 

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

Deprecated: Use InitReplicaResponse.ProtoReflect.Descriptor instead.

func (*InitReplicaResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*InitReplicaResponse) MarshalToVT added in v0.11.0 

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

func (*InitReplicaResponse) MarshalVT added in v0.11.0 

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

func (*InitReplicaResponse) ProtoMessage 

func (*InitReplicaResponse) ProtoMessage()

func (*InitReplicaResponse) ProtoReflect added in v0.11.0 

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

func (*InitReplicaResponse) Reset 

func (x *InitReplicaResponse) Reset()

func (*InitReplicaResponse) SizeVT added in v0.11.0 

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

func (*InitReplicaResponse) String 

func (x *InitReplicaResponse) String() string

func (*InitReplicaResponse) UnmarshalVT added in v0.11.0 

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

type LockTablesRequest 

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

func (*LockTablesRequest) CloneMessageVT added in v0.18.0 

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

func (*LockTablesRequest) CloneVT added in v0.18.0 

func (m *LockTablesRequest) CloneVT() *LockTablesRequest

func (*LockTablesRequest) Descriptor deprecated 

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

Deprecated: Use LockTablesRequest.ProtoReflect.Descriptor instead.

func (*LockTablesRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*LockTablesRequest) MarshalToVT added in v0.11.0 

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

func (*LockTablesRequest) MarshalVT added in v0.11.0 

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

func (*LockTablesRequest) ProtoMessage 

func (*LockTablesRequest) ProtoMessage()

func (*LockTablesRequest) ProtoReflect added in v0.11.0 

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

func (*LockTablesRequest) Reset 

func (x *LockTablesRequest) Reset()

func (*LockTablesRequest) SizeVT added in v0.11.0 

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

func (*LockTablesRequest) String 

func (x *LockTablesRequest) String() string

func (*LockTablesRequest) UnmarshalVT added in v0.11.0 

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

type LockTablesResponse 

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

func (*LockTablesResponse) CloneMessageVT added in v0.18.0 

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

func (*LockTablesResponse) CloneVT added in v0.18.0 

func (m *LockTablesResponse) CloneVT() *LockTablesResponse

func (*LockTablesResponse) Descriptor deprecated 

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

Deprecated: Use LockTablesResponse.ProtoReflect.Descriptor instead.

func (*LockTablesResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*LockTablesResponse) MarshalToVT added in v0.11.0 

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

func (*LockTablesResponse) MarshalVT added in v0.11.0 

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

func (*LockTablesResponse) ProtoMessage 

func (*LockTablesResponse) ProtoMessage()

func (*LockTablesResponse) ProtoReflect added in v0.11.0 

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

func (*LockTablesResponse) Reset 

func (x *LockTablesResponse) Reset()

func (*LockTablesResponse) SizeVT added in v0.11.0 

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

func (*LockTablesResponse) String 

func (x *LockTablesResponse) String() string

func (*LockTablesResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*Permissions) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*Permissions) MarshalToVT added in v0.11.0 

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

func (*Permissions) MarshalVT added in v0.11.0 

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

func (*Permissions) ProtoMessage 

func (*Permissions) ProtoMessage()

func (*Permissions) ProtoReflect added in v0.11.0 

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

func (*Permissions) Reset 

func (x *Permissions) Reset()

func (*Permissions) SizeVT added in v0.11.0 

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

func (*Permissions) String 

func (x *Permissions) String() string

func (*Permissions) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*PingRequest) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*PingRequest) MarshalToVT added in v0.11.0 

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

func (*PingRequest) MarshalVT added in v0.11.0 

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

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect added in v0.11.0 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) SizeVT added in v0.11.0 

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

func (*PingRequest) String 

func (x *PingRequest) String() string

func (*PingRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*PingResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*PingResponse) MarshalToVT added in v0.11.0 

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

func (*PingResponse) MarshalVT added in v0.11.0 

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

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect added in v0.11.0 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) SizeVT added in v0.11.0 

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

func (*PingResponse) String 

func (x *PingResponse) String() string

func (*PingResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*PopulateReparentJournalRequest) CloneVT added in v0.18.0 

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 added in v0.12.0 

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 added in v0.11.0 

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

func (*PopulateReparentJournalRequest) MarshalToVT added in v0.11.0 

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

func (*PopulateReparentJournalRequest) MarshalVT added in v0.11.0 

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

func (*PopulateReparentJournalRequest) ProtoMessage 

func (*PopulateReparentJournalRequest) ProtoMessage()

func (*PopulateReparentJournalRequest) ProtoReflect added in v0.11.0 

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

func (*PopulateReparentJournalRequest) Reset 

func (x *PopulateReparentJournalRequest) Reset()

func (*PopulateReparentJournalRequest) SizeVT added in v0.11.0 

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

func (*PopulateReparentJournalRequest) String 

func (x *PopulateReparentJournalRequest) String() string

func (*PopulateReparentJournalRequest) UnmarshalVT added in v0.11.0 

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

type PopulateReparentJournalResponse 

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

func (*PopulateReparentJournalResponse) CloneMessageVT added in v0.18.0 

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

func (*PopulateReparentJournalResponse) CloneVT added in v0.18.0 

func (m *PopulateReparentJournalResponse) CloneVT() *PopulateReparentJournalResponse

func (*PopulateReparentJournalResponse) Descriptor deprecated 

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

Deprecated: Use PopulateReparentJournalResponse.ProtoReflect.Descriptor instead.

func (*PopulateReparentJournalResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*PopulateReparentJournalResponse) MarshalToVT added in v0.11.0 

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

func (*PopulateReparentJournalResponse) MarshalVT added in v0.11.0 

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

func (*PopulateReparentJournalResponse) ProtoMessage 

func (*PopulateReparentJournalResponse) ProtoMessage()

func (*PopulateReparentJournalResponse) ProtoReflect added in v0.11.0 

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

func (*PopulateReparentJournalResponse) Reset 

func (x *PopulateReparentJournalResponse) Reset()

func (*PopulateReparentJournalResponse) SizeVT added in v0.11.0 

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

func (*PopulateReparentJournalResponse) String 

func (x *PopulateReparentJournalResponse) String() string

func (*PopulateReparentJournalResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*PreflightSchemaRequest) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*PreflightSchemaRequest) MarshalToVT added in v0.11.0 

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

func (*PreflightSchemaRequest) MarshalVT added in v0.11.0 

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

func (*PreflightSchemaRequest) ProtoMessage 

func (*PreflightSchemaRequest) ProtoMessage()

func (*PreflightSchemaRequest) ProtoReflect added in v0.11.0 

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

func (*PreflightSchemaRequest) Reset 

func (x *PreflightSchemaRequest) Reset()

func (*PreflightSchemaRequest) SizeVT added in v0.11.0 

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

func (*PreflightSchemaRequest) String 

func (x *PreflightSchemaRequest) String() string

func (*PreflightSchemaRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*PreflightSchemaResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*PreflightSchemaResponse) MarshalToVT added in v0.11.0 

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

func (*PreflightSchemaResponse) MarshalVT added in v0.11.0 

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

func (*PreflightSchemaResponse) ProtoMessage 

func (*PreflightSchemaResponse) ProtoMessage()

func (*PreflightSchemaResponse) ProtoReflect added in v0.11.0 

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

func (*PreflightSchemaResponse) Reset 

func (x *PreflightSchemaResponse) Reset()

func (*PreflightSchemaResponse) SizeVT added in v0.11.0 

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

func (*PreflightSchemaResponse) String 

func (x *PreflightSchemaResponse) String() string

func (*PreflightSchemaResponse) UnmarshalVT added in v0.11.0 

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

type PrimaryPositionRequest added in v0.12.0 

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

func (*PrimaryPositionRequest) CloneMessageVT added in v0.18.0 

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

func (*PrimaryPositionRequest) CloneVT added in v0.18.0 

func (m *PrimaryPositionRequest) CloneVT() *PrimaryPositionRequest

func (*PrimaryPositionRequest) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use PrimaryPositionRequest.ProtoReflect.Descriptor instead.

func (*PrimaryPositionRequest) MarshalToSizedBufferVT added in v0.12.0 

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

func (*PrimaryPositionRequest) MarshalToVT added in v0.12.0 

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

func (*PrimaryPositionRequest) MarshalVT added in v0.12.0 

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

func (*PrimaryPositionRequest) ProtoMessage added in v0.12.0 

func (*PrimaryPositionRequest) ProtoMessage()

func (*PrimaryPositionRequest) ProtoReflect added in v0.12.0 

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

func (*PrimaryPositionRequest) Reset added in v0.12.0 

func (x *PrimaryPositionRequest) Reset()

func (*PrimaryPositionRequest) SizeVT added in v0.12.0 

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

func (*PrimaryPositionRequest) String added in v0.12.0 

func (x *PrimaryPositionRequest) String() string

func (*PrimaryPositionRequest) UnmarshalVT added in v0.12.0 

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

type PrimaryPositionResponse added in v0.12.0 

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

func (*PrimaryPositionResponse) CloneMessageVT added in v0.18.0 

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

func (*PrimaryPositionResponse) CloneVT added in v0.18.0 

func (m *PrimaryPositionResponse) CloneVT() *PrimaryPositionResponse

func (*PrimaryPositionResponse) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use PrimaryPositionResponse.ProtoReflect.Descriptor instead.

func (*PrimaryPositionResponse) GetPosition added in v0.12.0 

func (x *PrimaryPositionResponse) GetPosition() string

func (*PrimaryPositionResponse) MarshalToSizedBufferVT added in v0.12.0 

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

func (*PrimaryPositionResponse) MarshalToVT added in v0.12.0 

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

func (*PrimaryPositionResponse) MarshalVT added in v0.12.0 

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

func (*PrimaryPositionResponse) ProtoMessage added in v0.12.0 

func (*PrimaryPositionResponse) ProtoMessage()

func (*PrimaryPositionResponse) ProtoReflect added in v0.12.0 

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

func (*PrimaryPositionResponse) Reset added in v0.12.0 

func (x *PrimaryPositionResponse) Reset()

func (*PrimaryPositionResponse) SizeVT added in v0.12.0 

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

func (*PrimaryPositionResponse) String added in v0.12.0 

func (x *PrimaryPositionResponse) String() string

func (*PrimaryPositionResponse) UnmarshalVT added in v0.12.0 

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

type PrimaryStatusRequest added in v0.12.0 

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

func (*PrimaryStatusRequest) CloneMessageVT added in v0.18.0 

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

func (*PrimaryStatusRequest) CloneVT added in v0.18.0 

func (m *PrimaryStatusRequest) CloneVT() *PrimaryStatusRequest

func (*PrimaryStatusRequest) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use PrimaryStatusRequest.ProtoReflect.Descriptor instead.

func (*PrimaryStatusRequest) MarshalToSizedBufferVT added in v0.12.0 

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

func (*PrimaryStatusRequest) MarshalToVT added in v0.12.0 

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

func (*PrimaryStatusRequest) MarshalVT added in v0.12.0 

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

func (*PrimaryStatusRequest) ProtoMessage added in v0.12.0 

func (*PrimaryStatusRequest) ProtoMessage()

func (*PrimaryStatusRequest) ProtoReflect added in v0.12.0 

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

func (*PrimaryStatusRequest) Reset added in v0.12.0 

func (x *PrimaryStatusRequest) Reset()

func (*PrimaryStatusRequest) SizeVT added in v0.12.0 

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

func (*PrimaryStatusRequest) String added in v0.12.0 

func (x *PrimaryStatusRequest) String() string

func (*PrimaryStatusRequest) UnmarshalVT added in v0.12.0 

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

type PrimaryStatusResponse added in v0.12.0 

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

func (*PrimaryStatusResponse) CloneMessageVT added in v0.18.0 

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

func (*PrimaryStatusResponse) CloneVT added in v0.18.0 

func (m *PrimaryStatusResponse) CloneVT() *PrimaryStatusResponse

func (*PrimaryStatusResponse) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use PrimaryStatusResponse.ProtoReflect.Descriptor instead.

func (*PrimaryStatusResponse) GetStatus added in v0.12.0 

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

func (*PrimaryStatusResponse) MarshalToSizedBufferVT added in v0.12.0 

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

func (*PrimaryStatusResponse) MarshalToVT added in v0.12.0 

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

func (*PrimaryStatusResponse) MarshalVT added in v0.12.0 

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

func (*PrimaryStatusResponse) ProtoMessage added in v0.12.0 

func (*PrimaryStatusResponse) ProtoMessage()

func (*PrimaryStatusResponse) ProtoReflect added in v0.12.0 

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

func (*PrimaryStatusResponse) Reset added in v0.12.0 

func (x *PrimaryStatusResponse) Reset()

func (*PrimaryStatusResponse) SizeVT added in v0.12.0 

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

func (*PrimaryStatusResponse) String added in v0.12.0 

func (x *PrimaryStatusResponse) String() string

func (*PrimaryStatusResponse) UnmarshalVT added in v0.12.0 

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 added in v0.18.0 

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

func (*PromoteReplicaRequest) CloneVT added in v0.18.0 

func (m *PromoteReplicaRequest) CloneVT() *PromoteReplicaRequest

func (*PromoteReplicaRequest) Descriptor deprecated 

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

Deprecated: Use PromoteReplicaRequest.ProtoReflect.Descriptor instead.

func (*PromoteReplicaRequest) GetSemiSync added in v0.13.0 

func (x *PromoteReplicaRequest) GetSemiSync() bool

func (*PromoteReplicaRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*PromoteReplicaRequest) MarshalToVT added in v0.11.0 

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

func (*PromoteReplicaRequest) MarshalVT added in v0.11.0 

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

func (*PromoteReplicaRequest) ProtoMessage 

func (*PromoteReplicaRequest) ProtoMessage()

func (*PromoteReplicaRequest) ProtoReflect added in v0.11.0 

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

func (*PromoteReplicaRequest) Reset 

func (x *PromoteReplicaRequest) Reset()

func (*PromoteReplicaRequest) SizeVT added in v0.11.0 

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

func (*PromoteReplicaRequest) String 

func (x *PromoteReplicaRequest) String() string

func (*PromoteReplicaRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*PromoteReplicaResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*PromoteReplicaResponse) MarshalToVT added in v0.11.0 

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

func (*PromoteReplicaResponse) MarshalVT added in v0.11.0 

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

func (*PromoteReplicaResponse) ProtoMessage 

func (*PromoteReplicaResponse) ProtoMessage()

func (*PromoteReplicaResponse) ProtoReflect added in v0.11.0 

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

func (*PromoteReplicaResponse) Reset 

func (x *PromoteReplicaResponse) Reset()

func (*PromoteReplicaResponse) SizeVT added in v0.11.0 

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

func (*PromoteReplicaResponse) String 

func (x *PromoteReplicaResponse) String() string

func (*PromoteReplicaResponse) UnmarshalVT added in v0.11.0 

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

type ReadVReplicationWorkflowRequest added in v0.18.0 

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

func (*ReadVReplicationWorkflowRequest) CloneMessageVT added in v0.18.0 

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

func (*ReadVReplicationWorkflowRequest) CloneVT added in v0.18.0 

func (m *ReadVReplicationWorkflowRequest) CloneVT() *ReadVReplicationWorkflowRequest

func (*ReadVReplicationWorkflowRequest) Descriptor deprecated added in v0.18.0 

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

Deprecated: Use ReadVReplicationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*ReadVReplicationWorkflowRequest) GetWorkflow added in v0.18.0 

func (x *ReadVReplicationWorkflowRequest) GetWorkflow() string

func (*ReadVReplicationWorkflowRequest) MarshalToSizedBufferVT added in v0.18.0 

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

func (*ReadVReplicationWorkflowRequest) MarshalToVT added in v0.18.0 

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

func (*ReadVReplicationWorkflowRequest) MarshalVT added in v0.18.0 

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

func (*ReadVReplicationWorkflowRequest) ProtoMessage added in v0.18.0 

func (*ReadVReplicationWorkflowRequest) ProtoMessage()

func (*ReadVReplicationWorkflowRequest) ProtoReflect added in v0.18.0 

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

func (*ReadVReplicationWorkflowRequest) Reset added in v0.18.0 

func (x *ReadVReplicationWorkflowRequest) Reset()

func (*ReadVReplicationWorkflowRequest) SizeVT added in v0.18.0 

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

func (*ReadVReplicationWorkflowRequest) String added in v0.18.0 

func (x *ReadVReplicationWorkflowRequest) String() string

func (*ReadVReplicationWorkflowRequest) UnmarshalVT added in v0.18.0 

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

type ReadVReplicationWorkflowResponse added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse) CloneMessageVT added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse) CloneVT added in v0.18.0 

func (m *ReadVReplicationWorkflowResponse) CloneVT() *ReadVReplicationWorkflowResponse

func (*ReadVReplicationWorkflowResponse) Descriptor deprecated added in v0.18.0 

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

Deprecated: Use ReadVReplicationWorkflowResponse.ProtoReflect.Descriptor instead.

func (*ReadVReplicationWorkflowResponse) GetCells added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse) GetCells() string

func (*ReadVReplicationWorkflowResponse) GetDbName added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse) GetDbName() string

func (*ReadVReplicationWorkflowResponse) GetDeferSecondaryKeys added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse) GetDeferSecondaryKeys() bool

func (*ReadVReplicationWorkflowResponse) GetStreams added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse) GetTabletSelectionPreference added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse) GetTabletSelectionPreference() TabletSelectionPreference

func (*ReadVReplicationWorkflowResponse) GetTabletTypes added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse) GetTags added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse) GetTags() string

func (*ReadVReplicationWorkflowResponse) GetWorkflow added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse) GetWorkflow() string

func (*ReadVReplicationWorkflowResponse) GetWorkflowSubType added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse) GetWorkflowType added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse) MarshalToSizedBufferVT added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse) MarshalToVT added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse) MarshalVT added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse) ProtoMessage added in v0.18.0 

func (*ReadVReplicationWorkflowResponse) ProtoMessage()

func (*ReadVReplicationWorkflowResponse) ProtoReflect added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse) Reset added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse) Reset()

func (*ReadVReplicationWorkflowResponse) SizeVT added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse) String added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse) String() string

func (*ReadVReplicationWorkflowResponse) UnmarshalVT added in v0.18.0 

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

type ReadVReplicationWorkflowResponse_Stream added in v0.18.0 

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 added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse_Stream) CloneVT added in v0.18.0 

func (m *ReadVReplicationWorkflowResponse_Stream) CloneVT() *ReadVReplicationWorkflowResponse_Stream

func (*ReadVReplicationWorkflowResponse_Stream) Descriptor deprecated added in v0.18.0 

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

Deprecated: Use ReadVReplicationWorkflowResponse_Stream.ProtoReflect.Descriptor instead.

func (*ReadVReplicationWorkflowResponse_Stream) GetBls added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse_Stream) GetComponentThrottled added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse_Stream) GetComponentThrottled() string

func (*ReadVReplicationWorkflowResponse_Stream) GetId added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse_Stream) GetId() int32

func (*ReadVReplicationWorkflowResponse_Stream) GetMaxReplicationLag added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse_Stream) GetMaxReplicationLag() int64

func (*ReadVReplicationWorkflowResponse_Stream) GetMaxTps added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse_Stream) GetMaxTps() int64

func (*ReadVReplicationWorkflowResponse_Stream) GetMessage added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse_Stream) GetMessage() string

func (*ReadVReplicationWorkflowResponse_Stream) GetPos added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse_Stream) GetPos() string

func (*ReadVReplicationWorkflowResponse_Stream) GetRowsCopied added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse_Stream) GetRowsCopied() int64

func (*ReadVReplicationWorkflowResponse_Stream) GetState added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse_Stream) GetStopPos added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse_Stream) GetStopPos() string

func (*ReadVReplicationWorkflowResponse_Stream) GetTimeHeartbeat added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse_Stream) GetTimeThrottled added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse_Stream) GetTimeUpdated added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse_Stream) GetTransactionTimestamp added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse_Stream) MarshalToSizedBufferVT added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse_Stream) MarshalToVT added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse_Stream) MarshalVT added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse_Stream) ProtoMessage added in v0.18.0 

func (*ReadVReplicationWorkflowResponse_Stream) ProtoMessage()

func (*ReadVReplicationWorkflowResponse_Stream) ProtoReflect added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse_Stream) Reset added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse_Stream) Reset()

func (*ReadVReplicationWorkflowResponse_Stream) SizeVT added in v0.18.0 

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

func (*ReadVReplicationWorkflowResponse_Stream) String added in v0.18.0 

func (x *ReadVReplicationWorkflowResponse_Stream) String() string

func (*ReadVReplicationWorkflowResponse_Stream) UnmarshalVT added in v0.18.0 

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

type RefreshStateRequest 

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

func (*RefreshStateRequest) CloneMessageVT added in v0.18.0 

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

func (*RefreshStateRequest) CloneVT added in v0.18.0 

func (m *RefreshStateRequest) CloneVT() *RefreshStateRequest

func (*RefreshStateRequest) Descriptor deprecated 

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

Deprecated: Use RefreshStateRequest.ProtoReflect.Descriptor instead.

func (*RefreshStateRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*RefreshStateRequest) MarshalToVT added in v0.11.0 

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

func (*RefreshStateRequest) MarshalVT added in v0.11.0 

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

func (*RefreshStateRequest) ProtoMessage 

func (*RefreshStateRequest) ProtoMessage()

func (*RefreshStateRequest) ProtoReflect added in v0.11.0 

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

func (*RefreshStateRequest) Reset 

func (x *RefreshStateRequest) Reset()

func (*RefreshStateRequest) SizeVT added in v0.11.0 

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

func (*RefreshStateRequest) String 

func (x *RefreshStateRequest) String() string

func (*RefreshStateRequest) UnmarshalVT added in v0.11.0 

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

type RefreshStateResponse 

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

func (*RefreshStateResponse) CloneMessageVT added in v0.18.0 

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

func (*RefreshStateResponse) CloneVT added in v0.18.0 

func (m *RefreshStateResponse) CloneVT() *RefreshStateResponse

func (*RefreshStateResponse) Descriptor deprecated 

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

Deprecated: Use RefreshStateResponse.ProtoReflect.Descriptor instead.

func (*RefreshStateResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*RefreshStateResponse) MarshalToVT added in v0.11.0 

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

func (*RefreshStateResponse) MarshalVT added in v0.11.0 

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

func (*RefreshStateResponse) ProtoMessage 

func (*RefreshStateResponse) ProtoMessage()

func (*RefreshStateResponse) ProtoReflect added in v0.11.0 

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

func (*RefreshStateResponse) Reset 

func (x *RefreshStateResponse) Reset()

func (*RefreshStateResponse) SizeVT added in v0.11.0 

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

func (*RefreshStateResponse) String 

func (x *RefreshStateResponse) String() string

func (*RefreshStateResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*ReloadSchemaRequest) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*ReloadSchemaRequest) MarshalToVT added in v0.11.0 

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

func (*ReloadSchemaRequest) MarshalVT added in v0.11.0 

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

func (*ReloadSchemaRequest) ProtoMessage 

func (*ReloadSchemaRequest) ProtoMessage()

func (*ReloadSchemaRequest) ProtoReflect added in v0.11.0 

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

func (*ReloadSchemaRequest) Reset 

func (x *ReloadSchemaRequest) Reset()

func (*ReloadSchemaRequest) SizeVT added in v0.11.0 

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

func (*ReloadSchemaRequest) String 

func (x *ReloadSchemaRequest) String() string

func (*ReloadSchemaRequest) UnmarshalVT added in v0.11.0 

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

type ReloadSchemaResponse 

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

func (*ReloadSchemaResponse) CloneMessageVT added in v0.18.0 

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

func (*ReloadSchemaResponse) CloneVT added in v0.18.0 

func (m *ReloadSchemaResponse) CloneVT() *ReloadSchemaResponse

func (*ReloadSchemaResponse) Descriptor deprecated 

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

Deprecated: Use ReloadSchemaResponse.ProtoReflect.Descriptor instead.

func (*ReloadSchemaResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ReloadSchemaResponse) MarshalToVT added in v0.11.0 

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

func (*ReloadSchemaResponse) MarshalVT added in v0.11.0 

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

func (*ReloadSchemaResponse) ProtoMessage 

func (*ReloadSchemaResponse) ProtoMessage()

func (*ReloadSchemaResponse) ProtoReflect added in v0.11.0 

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

func (*ReloadSchemaResponse) Reset 

func (x *ReloadSchemaResponse) Reset()

func (*ReloadSchemaResponse) SizeVT added in v0.11.0 

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

func (*ReloadSchemaResponse) String 

func (x *ReloadSchemaResponse) String() string

func (*ReloadSchemaResponse) UnmarshalVT added in v0.11.0 

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

type ReplicaWasPromotedRequest 

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

func (*ReplicaWasPromotedRequest) CloneMessageVT added in v0.18.0 

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

func (*ReplicaWasPromotedRequest) CloneVT added in v0.18.0 

func (m *ReplicaWasPromotedRequest) CloneVT() *ReplicaWasPromotedRequest

func (*ReplicaWasPromotedRequest) Descriptor deprecated 

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

Deprecated: Use ReplicaWasPromotedRequest.ProtoReflect.Descriptor instead.

func (*ReplicaWasPromotedRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ReplicaWasPromotedRequest) MarshalToVT added in v0.11.0 

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

func (*ReplicaWasPromotedRequest) MarshalVT added in v0.11.0 

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

func (*ReplicaWasPromotedRequest) ProtoMessage 

func (*ReplicaWasPromotedRequest) ProtoMessage()

func (*ReplicaWasPromotedRequest) ProtoReflect added in v0.11.0 

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

func (*ReplicaWasPromotedRequest) Reset 

func (x *ReplicaWasPromotedRequest) Reset()

func (*ReplicaWasPromotedRequest) SizeVT added in v0.11.0 

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

func (*ReplicaWasPromotedRequest) String 

func (x *ReplicaWasPromotedRequest) String() string

func (*ReplicaWasPromotedRequest) UnmarshalVT added in v0.11.0 

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

type ReplicaWasPromotedResponse 

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

func (*ReplicaWasPromotedResponse) CloneMessageVT added in v0.18.0 

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

func (*ReplicaWasPromotedResponse) CloneVT added in v0.18.0 

func (m *ReplicaWasPromotedResponse) CloneVT() *ReplicaWasPromotedResponse

func (*ReplicaWasPromotedResponse) Descriptor deprecated 

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

Deprecated: Use ReplicaWasPromotedResponse.ProtoReflect.Descriptor instead.

func (*ReplicaWasPromotedResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ReplicaWasPromotedResponse) MarshalToVT added in v0.11.0 

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

func (*ReplicaWasPromotedResponse) MarshalVT added in v0.11.0 

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

func (*ReplicaWasPromotedResponse) ProtoMessage 

func (*ReplicaWasPromotedResponse) ProtoMessage()

func (*ReplicaWasPromotedResponse) ProtoReflect added in v0.11.0 

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

func (*ReplicaWasPromotedResponse) Reset 

func (x *ReplicaWasPromotedResponse) Reset()

func (*ReplicaWasPromotedResponse) SizeVT added in v0.11.0 

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

func (*ReplicaWasPromotedResponse) String 

func (x *ReplicaWasPromotedResponse) String() string

func (*ReplicaWasPromotedResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*ReplicaWasRestartedRequest) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*ReplicaWasRestartedRequest) MarshalToVT added in v0.11.0 

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

func (*ReplicaWasRestartedRequest) MarshalVT added in v0.11.0 

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

func (*ReplicaWasRestartedRequest) ProtoMessage 

func (*ReplicaWasRestartedRequest) ProtoMessage()

func (*ReplicaWasRestartedRequest) ProtoReflect added in v0.11.0 

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

func (*ReplicaWasRestartedRequest) Reset 

func (x *ReplicaWasRestartedRequest) Reset()

func (*ReplicaWasRestartedRequest) SizeVT added in v0.11.0 

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

func (*ReplicaWasRestartedRequest) String 

func (x *ReplicaWasRestartedRequest) String() string

func (*ReplicaWasRestartedRequest) UnmarshalVT added in v0.11.0 

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

type ReplicaWasRestartedResponse 

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

func (*ReplicaWasRestartedResponse) CloneMessageVT added in v0.18.0 

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

func (*ReplicaWasRestartedResponse) CloneVT added in v0.18.0 

func (m *ReplicaWasRestartedResponse) CloneVT() *ReplicaWasRestartedResponse

func (*ReplicaWasRestartedResponse) Descriptor deprecated 

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

Deprecated: Use ReplicaWasRestartedResponse.ProtoReflect.Descriptor instead.

func (*ReplicaWasRestartedResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ReplicaWasRestartedResponse) MarshalToVT added in v0.11.0 

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

func (*ReplicaWasRestartedResponse) MarshalVT added in v0.11.0 

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

func (*ReplicaWasRestartedResponse) ProtoMessage 

func (*ReplicaWasRestartedResponse) ProtoMessage()

func (*ReplicaWasRestartedResponse) ProtoReflect added in v0.11.0 

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

func (*ReplicaWasRestartedResponse) Reset 

func (x *ReplicaWasRestartedResponse) Reset()

func (*ReplicaWasRestartedResponse) SizeVT added in v0.11.0 

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

func (*ReplicaWasRestartedResponse) String 

func (x *ReplicaWasRestartedResponse) String() string

func (*ReplicaWasRestartedResponse) UnmarshalVT added in v0.11.0 

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

type ReplicationStatusRequest 

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

func (*ReplicationStatusRequest) CloneMessageVT added in v0.18.0 

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

func (*ReplicationStatusRequest) CloneVT added in v0.18.0 

func (m *ReplicationStatusRequest) CloneVT() *ReplicationStatusRequest

func (*ReplicationStatusRequest) Descriptor deprecated 

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

Deprecated: Use ReplicationStatusRequest.ProtoReflect.Descriptor instead.

func (*ReplicationStatusRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ReplicationStatusRequest) MarshalToVT added in v0.11.0 

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

func (*ReplicationStatusRequest) MarshalVT added in v0.11.0 

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

func (*ReplicationStatusRequest) ProtoMessage 

func (*ReplicationStatusRequest) ProtoMessage()

func (*ReplicationStatusRequest) ProtoReflect added in v0.11.0 

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

func (*ReplicationStatusRequest) Reset 

func (x *ReplicationStatusRequest) Reset()

func (*ReplicationStatusRequest) SizeVT added in v0.11.0 

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

func (*ReplicationStatusRequest) String 

func (x *ReplicationStatusRequest) String() string

func (*ReplicationStatusRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*ReplicationStatusResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*ReplicationStatusResponse) MarshalToVT added in v0.11.0 

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

func (*ReplicationStatusResponse) MarshalVT added in v0.11.0 

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

func (*ReplicationStatusResponse) ProtoMessage 

func (*ReplicationStatusResponse) ProtoMessage()

func (*ReplicationStatusResponse) ProtoReflect added in v0.11.0 

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

func (*ReplicationStatusResponse) Reset 

func (x *ReplicationStatusResponse) Reset()

func (*ReplicationStatusResponse) SizeVT added in v0.11.0 

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

func (*ReplicationStatusResponse) String 

func (x *ReplicationStatusResponse) String() string

func (*ReplicationStatusResponse) UnmarshalVT added in v0.11.0 

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

type ResetReplicationParametersRequest added in v0.14.0 

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

func (*ResetReplicationParametersRequest) CloneMessageVT added in v0.18.0 

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

func (*ResetReplicationParametersRequest) CloneVT added in v0.18.0 

func (m *ResetReplicationParametersRequest) CloneVT() *ResetReplicationParametersRequest

func (*ResetReplicationParametersRequest) Descriptor deprecated added in v0.14.0 

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

Deprecated: Use ResetReplicationParametersRequest.ProtoReflect.Descriptor instead.

func (*ResetReplicationParametersRequest) MarshalToSizedBufferVT added in v0.14.0 

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

func (*ResetReplicationParametersRequest) MarshalToVT added in v0.14.0 

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

func (*ResetReplicationParametersRequest) MarshalVT added in v0.14.0 

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

func (*ResetReplicationParametersRequest) ProtoMessage added in v0.14.0 

func (*ResetReplicationParametersRequest) ProtoMessage()

func (*ResetReplicationParametersRequest) ProtoReflect added in v0.14.0 

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

func (*ResetReplicationParametersRequest) Reset added in v0.14.0 

func (x *ResetReplicationParametersRequest) Reset()

func (*ResetReplicationParametersRequest) SizeVT added in v0.14.0 

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

func (*ResetReplicationParametersRequest) String added in v0.14.0 

func (x *ResetReplicationParametersRequest) String() string

func (*ResetReplicationParametersRequest) UnmarshalVT added in v0.14.0 

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

type ResetReplicationParametersResponse added in v0.14.0 

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

func (*ResetReplicationParametersResponse) CloneMessageVT added in v0.18.0 

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

func (*ResetReplicationParametersResponse) CloneVT added in v0.18.0 

func (m *ResetReplicationParametersResponse) CloneVT() *ResetReplicationParametersResponse

func (*ResetReplicationParametersResponse) Descriptor deprecated added in v0.14.0 

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

Deprecated: Use ResetReplicationParametersResponse.ProtoReflect.Descriptor instead.

func (*ResetReplicationParametersResponse) MarshalToSizedBufferVT added in v0.14.0 

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

func (*ResetReplicationParametersResponse) MarshalToVT added in v0.14.0 

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

func (*ResetReplicationParametersResponse) MarshalVT added in v0.14.0 

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

func (*ResetReplicationParametersResponse) ProtoMessage added in v0.14.0 

func (*ResetReplicationParametersResponse) ProtoMessage()

func (*ResetReplicationParametersResponse) ProtoReflect added in v0.14.0 

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

func (*ResetReplicationParametersResponse) Reset added in v0.14.0 

func (x *ResetReplicationParametersResponse) Reset()

func (*ResetReplicationParametersResponse) SizeVT added in v0.14.0 

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

func (*ResetReplicationParametersResponse) String added in v0.14.0 

func (x *ResetReplicationParametersResponse) String() string

func (*ResetReplicationParametersResponse) UnmarshalVT added in v0.14.0 

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

type ResetReplicationRequest 

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

func (*ResetReplicationRequest) CloneMessageVT added in v0.18.0 

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

func (*ResetReplicationRequest) CloneVT added in v0.18.0 

func (m *ResetReplicationRequest) CloneVT() *ResetReplicationRequest

func (*ResetReplicationRequest) Descriptor deprecated 

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

Deprecated: Use ResetReplicationRequest.ProtoReflect.Descriptor instead.

func (*ResetReplicationRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ResetReplicationRequest) MarshalToVT added in v0.11.0 

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

func (*ResetReplicationRequest) MarshalVT added in v0.11.0 

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

func (*ResetReplicationRequest) ProtoMessage 

func (*ResetReplicationRequest) ProtoMessage()

func (*ResetReplicationRequest) ProtoReflect added in v0.11.0 

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

func (*ResetReplicationRequest) Reset 

func (x *ResetReplicationRequest) Reset()

func (*ResetReplicationRequest) SizeVT added in v0.11.0 

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

func (*ResetReplicationRequest) String 

func (x *ResetReplicationRequest) String() string

func (*ResetReplicationRequest) UnmarshalVT added in v0.11.0 

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

type ResetReplicationResponse 

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

func (*ResetReplicationResponse) CloneMessageVT added in v0.18.0 

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

func (*ResetReplicationResponse) CloneVT added in v0.18.0 

func (m *ResetReplicationResponse) CloneVT() *ResetReplicationResponse

func (*ResetReplicationResponse) Descriptor deprecated 

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

Deprecated: Use ResetReplicationResponse.ProtoReflect.Descriptor instead.

func (*ResetReplicationResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ResetReplicationResponse) MarshalToVT added in v0.11.0 

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

func (*ResetReplicationResponse) MarshalVT added in v0.11.0 

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

func (*ResetReplicationResponse) ProtoMessage 

func (*ResetReplicationResponse) ProtoMessage()

func (*ResetReplicationResponse) ProtoReflect added in v0.11.0 

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

func (*ResetReplicationResponse) Reset 

func (x *ResetReplicationResponse) Reset()

func (*ResetReplicationResponse) SizeVT added in v0.11.0 

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

func (*ResetReplicationResponse) String 

func (x *ResetReplicationResponse) String() string

func (*ResetReplicationResponse) UnmarshalVT added in v0.11.0 

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

type ResetSequencesRequest added in v0.18.0 

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

func (*ResetSequencesRequest) CloneMessageVT added in v0.18.0 

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

func (*ResetSequencesRequest) CloneVT added in v0.18.0 

func (m *ResetSequencesRequest) CloneVT() *ResetSequencesRequest

func (*ResetSequencesRequest) Descriptor deprecated added in v0.18.0 

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

Deprecated: Use ResetSequencesRequest.ProtoReflect.Descriptor instead.

func (*ResetSequencesRequest) GetTables added in v0.18.0 

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

func (*ResetSequencesRequest) MarshalToSizedBufferVT added in v0.18.0 

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

func (*ResetSequencesRequest) MarshalToVT added in v0.18.0 

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

func (*ResetSequencesRequest) MarshalVT added in v0.18.0 

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

func (*ResetSequencesRequest) ProtoMessage added in v0.18.0 

func (*ResetSequencesRequest) ProtoMessage()

func (*ResetSequencesRequest) ProtoReflect added in v0.18.0 

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

func (*ResetSequencesRequest) Reset added in v0.18.0 

func (x *ResetSequencesRequest) Reset()

func (*ResetSequencesRequest) SizeVT added in v0.18.0 

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

func (*ResetSequencesRequest) String added in v0.18.0 

func (x *ResetSequencesRequest) String() string

func (*ResetSequencesRequest) UnmarshalVT added in v0.18.0 

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

type ResetSequencesResponse added in v0.18.0 

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

func (*ResetSequencesResponse) CloneMessageVT added in v0.18.0 

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

func (*ResetSequencesResponse) CloneVT added in v0.18.0 

func (m *ResetSequencesResponse) CloneVT() *ResetSequencesResponse

func (*ResetSequencesResponse) Descriptor deprecated added in v0.18.0 

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

Deprecated: Use ResetSequencesResponse.ProtoReflect.Descriptor instead.

func (*ResetSequencesResponse) MarshalToSizedBufferVT added in v0.18.0 

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

func (*ResetSequencesResponse) MarshalToVT added in v0.18.0 

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

func (*ResetSequencesResponse) MarshalVT added in v0.18.0 

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

func (*ResetSequencesResponse) ProtoMessage added in v0.18.0 

func (*ResetSequencesResponse) ProtoMessage()

func (*ResetSequencesResponse) ProtoReflect added in v0.18.0 

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

func (*ResetSequencesResponse) Reset added in v0.18.0 

func (x *ResetSequencesResponse) Reset()

func (*ResetSequencesResponse) SizeVT added in v0.18.0 

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

func (*ResetSequencesResponse) String added in v0.18.0 

func (x *ResetSequencesResponse) String() string

func (*ResetSequencesResponse) UnmarshalVT added in v0.18.0 

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 added in v0.18.0 

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

func (*RestoreFromBackupRequest) CloneVT added in v0.18.0 

func (m *RestoreFromBackupRequest) CloneVT() *RestoreFromBackupRequest

func (*RestoreFromBackupRequest) Descriptor deprecated 

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

Deprecated: Use RestoreFromBackupRequest.ProtoReflect.Descriptor instead.

func (*RestoreFromBackupRequest) GetBackupTime added in v0.12.0 

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

func (*RestoreFromBackupRequest) GetDryRun added in v0.16.0 

func (x *RestoreFromBackupRequest) GetDryRun() bool

func (*RestoreFromBackupRequest) GetRestoreToPos added in v0.16.0 

func (x *RestoreFromBackupRequest) GetRestoreToPos() string

func (*RestoreFromBackupRequest) GetRestoreToTimestamp added in v0.18.0 

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

func (*RestoreFromBackupRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*RestoreFromBackupRequest) MarshalToVT added in v0.11.0 

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

func (*RestoreFromBackupRequest) MarshalVT added in v0.11.0 

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

func (*RestoreFromBackupRequest) ProtoMessage 

func (*RestoreFromBackupRequest) ProtoMessage()

func (*RestoreFromBackupRequest) ProtoReflect added in v0.11.0 

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

func (*RestoreFromBackupRequest) Reset 

func (x *RestoreFromBackupRequest) Reset()

func (*RestoreFromBackupRequest) SizeVT added in v0.11.0 

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

func (*RestoreFromBackupRequest) String 

func (x *RestoreFromBackupRequest) String() string

func (*RestoreFromBackupRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*RestoreFromBackupResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*RestoreFromBackupResponse) MarshalToVT added in v0.11.0 

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

func (*RestoreFromBackupResponse) MarshalVT added in v0.11.0 

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

func (*RestoreFromBackupResponse) ProtoMessage 

func (*RestoreFromBackupResponse) ProtoMessage()

func (*RestoreFromBackupResponse) ProtoReflect added in v0.11.0 

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

func (*RestoreFromBackupResponse) Reset 

func (x *RestoreFromBackupResponse) Reset()

func (*RestoreFromBackupResponse) SizeVT added in v0.11.0 

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

func (*RestoreFromBackupResponse) String 

func (x *RestoreFromBackupResponse) String() string

func (*RestoreFromBackupResponse) UnmarshalVT added in v0.11.0 

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

type RunHealthCheckRequest 

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

func (*RunHealthCheckRequest) CloneMessageVT added in v0.18.0 

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

func (*RunHealthCheckRequest) CloneVT added in v0.18.0 

func (m *RunHealthCheckRequest) CloneVT() *RunHealthCheckRequest

func (*RunHealthCheckRequest) Descriptor deprecated 

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

Deprecated: Use RunHealthCheckRequest.ProtoReflect.Descriptor instead.

func (*RunHealthCheckRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*RunHealthCheckRequest) MarshalToVT added in v0.11.0 

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

func (*RunHealthCheckRequest) MarshalVT added in v0.11.0 

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

func (*RunHealthCheckRequest) ProtoMessage 

func (*RunHealthCheckRequest) ProtoMessage()

func (*RunHealthCheckRequest) ProtoReflect added in v0.11.0 

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

func (*RunHealthCheckRequest) Reset 

func (x *RunHealthCheckRequest) Reset()

func (*RunHealthCheckRequest) SizeVT added in v0.11.0 

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

func (*RunHealthCheckRequest) String 

func (x *RunHealthCheckRequest) String() string

func (*RunHealthCheckRequest) UnmarshalVT added in v0.11.0 

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

type RunHealthCheckResponse 

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

func (*RunHealthCheckResponse) CloneMessageVT added in v0.18.0 

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

func (*RunHealthCheckResponse) CloneVT added in v0.18.0 

func (m *RunHealthCheckResponse) CloneVT() *RunHealthCheckResponse

func (*RunHealthCheckResponse) Descriptor deprecated 

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

Deprecated: Use RunHealthCheckResponse.ProtoReflect.Descriptor instead.

func (*RunHealthCheckResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*RunHealthCheckResponse) MarshalToVT added in v0.11.0 

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

func (*RunHealthCheckResponse) MarshalVT added in v0.11.0 

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

func (*RunHealthCheckResponse) ProtoMessage 

func (*RunHealthCheckResponse) ProtoMessage()

func (*RunHealthCheckResponse) ProtoReflect added in v0.11.0 

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

func (*RunHealthCheckResponse) Reset 

func (x *RunHealthCheckResponse) Reset()

func (*RunHealthCheckResponse) SizeVT added in v0.11.0 

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

func (*RunHealthCheckResponse) String 

func (x *RunHealthCheckResponse) String() string

func (*RunHealthCheckResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*SchemaChangeResult) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*SchemaChangeResult) MarshalToVT added in v0.11.0 

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

func (*SchemaChangeResult) MarshalVT added in v0.11.0 

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

func (*SchemaChangeResult) ProtoMessage 

func (*SchemaChangeResult) ProtoMessage()

func (*SchemaChangeResult) ProtoReflect added in v0.11.0 

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

func (*SchemaChangeResult) Reset 

func (x *SchemaChangeResult) Reset()

func (*SchemaChangeResult) SizeVT added in v0.11.0 

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

func (*SchemaChangeResult) String 

func (x *SchemaChangeResult) String() string

func (*SchemaChangeResult) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*SchemaDefinition) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*SchemaDefinition) MarshalToVT added in v0.11.0 

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

func (*SchemaDefinition) MarshalVT added in v0.11.0 

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

func (*SchemaDefinition) ProtoMessage 

func (*SchemaDefinition) ProtoMessage()

func (*SchemaDefinition) ProtoReflect added in v0.11.0 

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

func (*SchemaDefinition) Reset 

func (x *SchemaDefinition) Reset()

func (*SchemaDefinition) SizeVT added in v0.11.0 

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

func (*SchemaDefinition) String 

func (x *SchemaDefinition) String() string

func (*SchemaDefinition) UnmarshalVT added in v0.11.0 

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

type SetReadOnlyRequest 

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

func (*SetReadOnlyRequest) CloneMessageVT added in v0.18.0 

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

func (*SetReadOnlyRequest) CloneVT added in v0.18.0 

func (m *SetReadOnlyRequest) CloneVT() *SetReadOnlyRequest

func (*SetReadOnlyRequest) Descriptor deprecated 

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

Deprecated: Use SetReadOnlyRequest.ProtoReflect.Descriptor instead.

func (*SetReadOnlyRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*SetReadOnlyRequest) MarshalToVT added in v0.11.0 

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

func (*SetReadOnlyRequest) MarshalVT added in v0.11.0 

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

func (*SetReadOnlyRequest) ProtoMessage 

func (*SetReadOnlyRequest) ProtoMessage()

func (*SetReadOnlyRequest) ProtoReflect added in v0.11.0 

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

func (*SetReadOnlyRequest) Reset 

func (x *SetReadOnlyRequest) Reset()

func (*SetReadOnlyRequest) SizeVT added in v0.11.0 

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

func (*SetReadOnlyRequest) String 

func (x *SetReadOnlyRequest) String() string

func (*SetReadOnlyRequest) UnmarshalVT added in v0.11.0 

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

type SetReadOnlyResponse 

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

func (*SetReadOnlyResponse) CloneMessageVT added in v0.18.0 

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

func (*SetReadOnlyResponse) CloneVT added in v0.18.0 

func (m *SetReadOnlyResponse) CloneVT() *SetReadOnlyResponse

func (*SetReadOnlyResponse) Descriptor deprecated 

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

Deprecated: Use SetReadOnlyResponse.ProtoReflect.Descriptor instead.

func (*SetReadOnlyResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*SetReadOnlyResponse) MarshalToVT added in v0.11.0 

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

func (*SetReadOnlyResponse) MarshalVT added in v0.11.0 

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

func (*SetReadOnlyResponse) ProtoMessage 

func (*SetReadOnlyResponse) ProtoMessage()

func (*SetReadOnlyResponse) ProtoReflect added in v0.11.0 

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

func (*SetReadOnlyResponse) Reset 

func (x *SetReadOnlyResponse) Reset()

func (*SetReadOnlyResponse) SizeVT added in v0.11.0 

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

func (*SetReadOnlyResponse) String 

func (x *SetReadOnlyResponse) String() string

func (*SetReadOnlyResponse) UnmarshalVT added in v0.11.0 

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

type SetReadWriteRequest 

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

func (*SetReadWriteRequest) CloneMessageVT added in v0.18.0 

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

func (*SetReadWriteRequest) CloneVT added in v0.18.0 

func (m *SetReadWriteRequest) CloneVT() *SetReadWriteRequest

func (*SetReadWriteRequest) Descriptor deprecated 

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

Deprecated: Use SetReadWriteRequest.ProtoReflect.Descriptor instead.

func (*SetReadWriteRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*SetReadWriteRequest) MarshalToVT added in v0.11.0 

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

func (*SetReadWriteRequest) MarshalVT added in v0.11.0 

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

func (*SetReadWriteRequest) ProtoMessage 

func (*SetReadWriteRequest) ProtoMessage()

func (*SetReadWriteRequest) ProtoReflect added in v0.11.0 

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

func (*SetReadWriteRequest) Reset 

func (x *SetReadWriteRequest) Reset()

func (*SetReadWriteRequest) SizeVT added in v0.11.0 

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

func (*SetReadWriteRequest) String 

func (x *SetReadWriteRequest) String() string

func (*SetReadWriteRequest) UnmarshalVT added in v0.11.0 

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

type SetReadWriteResponse 

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

func (*SetReadWriteResponse) CloneMessageVT added in v0.18.0 

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

func (*SetReadWriteResponse) CloneVT added in v0.18.0 

func (m *SetReadWriteResponse) CloneVT() *SetReadWriteResponse

func (*SetReadWriteResponse) Descriptor deprecated 

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

Deprecated: Use SetReadWriteResponse.ProtoReflect.Descriptor instead.

func (*SetReadWriteResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*SetReadWriteResponse) MarshalToVT added in v0.11.0 

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

func (*SetReadWriteResponse) MarshalVT added in v0.11.0 

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

func (*SetReadWriteResponse) ProtoMessage 

func (*SetReadWriteResponse) ProtoMessage()

func (*SetReadWriteResponse) ProtoReflect added in v0.11.0 

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

func (*SetReadWriteResponse) Reset 

func (x *SetReadWriteResponse) Reset()

func (*SetReadWriteResponse) SizeVT added in v0.11.0 

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

func (*SetReadWriteResponse) String 

func (x *SetReadWriteResponse) String() string

func (*SetReadWriteResponse) UnmarshalVT added in v0.11.0 

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

type SetReplicationSourceRequest added in v0.12.0 

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

func (*SetReplicationSourceRequest) CloneMessageVT added in v0.18.0 

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

func (*SetReplicationSourceRequest) CloneVT added in v0.18.0 

func (m *SetReplicationSourceRequest) CloneVT() *SetReplicationSourceRequest

func (*SetReplicationSourceRequest) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use SetReplicationSourceRequest.ProtoReflect.Descriptor instead.

func (*SetReplicationSourceRequest) GetForceStartReplication added in v0.12.0 

func (x *SetReplicationSourceRequest) GetForceStartReplication() bool

func (*SetReplicationSourceRequest) GetParent added in v0.12.0 

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

func (*SetReplicationSourceRequest) GetSemiSync added in v0.13.0 

func (x *SetReplicationSourceRequest) GetSemiSync() bool

func (*SetReplicationSourceRequest) GetTimeCreatedNs added in v0.12.0 

func (x *SetReplicationSourceRequest) GetTimeCreatedNs() int64

func (*SetReplicationSourceRequest) GetWaitPosition added in v0.12.0 

func (x *SetReplicationSourceRequest) GetWaitPosition() string

func (*SetReplicationSourceRequest) MarshalToSizedBufferVT added in v0.12.0 

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

func (*SetReplicationSourceRequest) MarshalToVT added in v0.12.0 

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

func (*SetReplicationSourceRequest) MarshalVT added in v0.12.0 

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

func (*SetReplicationSourceRequest) ProtoMessage added in v0.12.0 

func (*SetReplicationSourceRequest) ProtoMessage()

func (*SetReplicationSourceRequest) ProtoReflect added in v0.12.0 

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

func (*SetReplicationSourceRequest) Reset added in v0.12.0 

func (x *SetReplicationSourceRequest) Reset()

func (*SetReplicationSourceRequest) SizeVT added in v0.12.0 

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

func (*SetReplicationSourceRequest) String added in v0.12.0 

func (x *SetReplicationSourceRequest) String() string

func (*SetReplicationSourceRequest) UnmarshalVT added in v0.12.0 

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

type SetReplicationSourceResponse added in v0.12.0 

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

func (*SetReplicationSourceResponse) CloneMessageVT added in v0.18.0 

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

func (*SetReplicationSourceResponse) CloneVT added in v0.18.0 

func (m *SetReplicationSourceResponse) CloneVT() *SetReplicationSourceResponse

func (*SetReplicationSourceResponse) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use SetReplicationSourceResponse.ProtoReflect.Descriptor instead.

func (*SetReplicationSourceResponse) MarshalToSizedBufferVT added in v0.12.0 

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

func (*SetReplicationSourceResponse) MarshalToVT added in v0.12.0 

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

func (*SetReplicationSourceResponse) MarshalVT added in v0.12.0 

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

func (*SetReplicationSourceResponse) ProtoMessage added in v0.12.0 

func (*SetReplicationSourceResponse) ProtoMessage()

func (*SetReplicationSourceResponse) ProtoReflect added in v0.12.0 

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

func (*SetReplicationSourceResponse) Reset added in v0.12.0 

func (x *SetReplicationSourceResponse) Reset()

func (*SetReplicationSourceResponse) SizeVT added in v0.12.0 

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

func (*SetReplicationSourceResponse) String added in v0.12.0 

func (x *SetReplicationSourceResponse) String() string

func (*SetReplicationSourceResponse) UnmarshalVT added in v0.12.0 

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 added in v0.18.0 

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

func (*SleepRequest) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*SleepRequest) MarshalToVT added in v0.11.0 

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

func (*SleepRequest) MarshalVT added in v0.11.0 

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

func (*SleepRequest) ProtoMessage 

func (*SleepRequest) ProtoMessage()

func (*SleepRequest) ProtoReflect added in v0.11.0 

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

func (*SleepRequest) Reset 

func (x *SleepRequest) Reset()

func (*SleepRequest) SizeVT added in v0.11.0 

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

func (*SleepRequest) String 

func (x *SleepRequest) String() string

func (*SleepRequest) UnmarshalVT added in v0.11.0 

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

type SleepResponse 

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

func (*SleepResponse) CloneMessageVT added in v0.18.0 

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

func (*SleepResponse) CloneVT added in v0.18.0 

func (m *SleepResponse) CloneVT() *SleepResponse

func (*SleepResponse) Descriptor deprecated 

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

Deprecated: Use SleepResponse.ProtoReflect.Descriptor instead.

func (*SleepResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*SleepResponse) MarshalToVT added in v0.11.0 

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

func (*SleepResponse) MarshalVT added in v0.11.0 

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

func (*SleepResponse) ProtoMessage 

func (*SleepResponse) ProtoMessage()

func (*SleepResponse) ProtoReflect added in v0.11.0 

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

func (*SleepResponse) Reset 

func (x *SleepResponse) Reset()

func (*SleepResponse) SizeVT added in v0.11.0 

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

func (*SleepResponse) String 

func (x *SleepResponse) String() string

func (*SleepResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*StartReplicationRequest) CloneVT added in v0.18.0 

func (m *StartReplicationRequest) CloneVT() *StartReplicationRequest

func (*StartReplicationRequest) Descriptor deprecated 

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

Deprecated: Use StartReplicationRequest.ProtoReflect.Descriptor instead.

func (*StartReplicationRequest) GetSemiSync added in v0.13.0 

func (x *StartReplicationRequest) GetSemiSync() bool

func (*StartReplicationRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*StartReplicationRequest) MarshalToVT added in v0.11.0 

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

func (*StartReplicationRequest) MarshalVT added in v0.11.0 

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

func (*StartReplicationRequest) ProtoMessage 

func (*StartReplicationRequest) ProtoMessage()

func (*StartReplicationRequest) ProtoReflect added in v0.11.0 

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

func (*StartReplicationRequest) Reset 

func (x *StartReplicationRequest) Reset()

func (*StartReplicationRequest) SizeVT added in v0.11.0 

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

func (*StartReplicationRequest) String 

func (x *StartReplicationRequest) String() string

func (*StartReplicationRequest) UnmarshalVT added in v0.11.0 

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

type StartReplicationResponse 

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

func (*StartReplicationResponse) CloneMessageVT added in v0.18.0 

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

func (*StartReplicationResponse) CloneVT added in v0.18.0 

func (m *StartReplicationResponse) CloneVT() *StartReplicationResponse

func (*StartReplicationResponse) Descriptor deprecated 

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

Deprecated: Use StartReplicationResponse.ProtoReflect.Descriptor instead.

func (*StartReplicationResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*StartReplicationResponse) MarshalToVT added in v0.11.0 

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

func (*StartReplicationResponse) MarshalVT added in v0.11.0 

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

func (*StartReplicationResponse) ProtoMessage 

func (*StartReplicationResponse) ProtoMessage()

func (*StartReplicationResponse) ProtoReflect added in v0.11.0 

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

func (*StartReplicationResponse) Reset 

func (x *StartReplicationResponse) Reset()

func (*StartReplicationResponse) SizeVT added in v0.11.0 

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

func (*StartReplicationResponse) String 

func (x *StartReplicationResponse) String() string

func (*StartReplicationResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*StartReplicationUntilAfterRequest) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*StartReplicationUntilAfterRequest) MarshalToVT added in v0.11.0 

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

func (*StartReplicationUntilAfterRequest) MarshalVT added in v0.11.0 

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

func (*StartReplicationUntilAfterRequest) ProtoMessage 

func (*StartReplicationUntilAfterRequest) ProtoMessage()

func (*StartReplicationUntilAfterRequest) ProtoReflect added in v0.11.0 

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

func (*StartReplicationUntilAfterRequest) Reset 

func (x *StartReplicationUntilAfterRequest) Reset()

func (*StartReplicationUntilAfterRequest) SizeVT added in v0.11.0 

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

func (*StartReplicationUntilAfterRequest) String 

func (x *StartReplicationUntilAfterRequest) String() string

func (*StartReplicationUntilAfterRequest) UnmarshalVT added in v0.11.0 

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

type StartReplicationUntilAfterResponse 

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

func (*StartReplicationUntilAfterResponse) CloneMessageVT added in v0.18.0 

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

func (*StartReplicationUntilAfterResponse) CloneVT added in v0.18.0 

func (m *StartReplicationUntilAfterResponse) CloneVT() *StartReplicationUntilAfterResponse

func (*StartReplicationUntilAfterResponse) Descriptor deprecated 

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

Deprecated: Use StartReplicationUntilAfterResponse.ProtoReflect.Descriptor instead.

func (*StartReplicationUntilAfterResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*StartReplicationUntilAfterResponse) MarshalToVT added in v0.11.0 

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

func (*StartReplicationUntilAfterResponse) MarshalVT added in v0.11.0 

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

func (*StartReplicationUntilAfterResponse) ProtoMessage 

func (*StartReplicationUntilAfterResponse) ProtoMessage()

func (*StartReplicationUntilAfterResponse) ProtoReflect added in v0.11.0 

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

func (*StartReplicationUntilAfterResponse) Reset 

func (x *StartReplicationUntilAfterResponse) Reset()

func (*StartReplicationUntilAfterResponse) SizeVT added in v0.11.0 

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

func (*StartReplicationUntilAfterResponse) String 

func (x *StartReplicationUntilAfterResponse) String() string

func (*StartReplicationUntilAfterResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*StopReplicationAndGetStatusRequest) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*StopReplicationAndGetStatusRequest) MarshalToVT added in v0.11.0 

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

func (*StopReplicationAndGetStatusRequest) MarshalVT added in v0.11.0 

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

func (*StopReplicationAndGetStatusRequest) ProtoMessage 

func (*StopReplicationAndGetStatusRequest) ProtoMessage()

func (*StopReplicationAndGetStatusRequest) ProtoReflect added in v0.11.0 

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

func (*StopReplicationAndGetStatusRequest) Reset 

func (x *StopReplicationAndGetStatusRequest) Reset()

func (*StopReplicationAndGetStatusRequest) SizeVT added in v0.11.0 

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

func (*StopReplicationAndGetStatusRequest) String 

func (x *StopReplicationAndGetStatusRequest) String() string

func (*StopReplicationAndGetStatusRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*StopReplicationAndGetStatusResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*StopReplicationAndGetStatusResponse) MarshalToVT added in v0.11.0 

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

func (*StopReplicationAndGetStatusResponse) MarshalVT added in v0.11.0 

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

func (*StopReplicationAndGetStatusResponse) ProtoMessage 

func (*StopReplicationAndGetStatusResponse) ProtoMessage()

func (*StopReplicationAndGetStatusResponse) ProtoReflect added in v0.11.0 

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

func (*StopReplicationAndGetStatusResponse) Reset 

func (x *StopReplicationAndGetStatusResponse) Reset()

func (*StopReplicationAndGetStatusResponse) SizeVT added in v0.11.0 

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

func (*StopReplicationAndGetStatusResponse) String 

func (x *StopReplicationAndGetStatusResponse) String() string

func (*StopReplicationAndGetStatusResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*StopReplicationMinimumRequest) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*StopReplicationMinimumRequest) MarshalToVT added in v0.11.0 

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

func (*StopReplicationMinimumRequest) MarshalVT added in v0.11.0 

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

func (*StopReplicationMinimumRequest) ProtoMessage 

func (*StopReplicationMinimumRequest) ProtoMessage()

func (*StopReplicationMinimumRequest) ProtoReflect added in v0.11.0 

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

func (*StopReplicationMinimumRequest) Reset 

func (x *StopReplicationMinimumRequest) Reset()

func (*StopReplicationMinimumRequest) SizeVT added in v0.11.0 

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

func (*StopReplicationMinimumRequest) String 

func (x *StopReplicationMinimumRequest) String() string

func (*StopReplicationMinimumRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*StopReplicationMinimumResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*StopReplicationMinimumResponse) MarshalToVT added in v0.11.0 

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

func (*StopReplicationMinimumResponse) MarshalVT added in v0.11.0 

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

func (*StopReplicationMinimumResponse) ProtoMessage 

func (*StopReplicationMinimumResponse) ProtoMessage()

func (*StopReplicationMinimumResponse) ProtoReflect added in v0.11.0 

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

func (*StopReplicationMinimumResponse) Reset 

func (x *StopReplicationMinimumResponse) Reset()

func (*StopReplicationMinimumResponse) SizeVT added in v0.11.0 

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

func (*StopReplicationMinimumResponse) String 

func (x *StopReplicationMinimumResponse) String() string

func (*StopReplicationMinimumResponse) UnmarshalVT added in v0.11.0 

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

type StopReplicationRequest 

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

func (*StopReplicationRequest) CloneMessageVT added in v0.18.0 

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

func (*StopReplicationRequest) CloneVT added in v0.18.0 

func (m *StopReplicationRequest) CloneVT() *StopReplicationRequest

func (*StopReplicationRequest) Descriptor deprecated 

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

Deprecated: Use StopReplicationRequest.ProtoReflect.Descriptor instead.

func (*StopReplicationRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*StopReplicationRequest) MarshalToVT added in v0.11.0 

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

func (*StopReplicationRequest) MarshalVT added in v0.11.0 

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

func (*StopReplicationRequest) ProtoMessage 

func (*StopReplicationRequest) ProtoMessage()

func (*StopReplicationRequest) ProtoReflect added in v0.11.0 

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

func (*StopReplicationRequest) Reset 

func (x *StopReplicationRequest) Reset()

func (*StopReplicationRequest) SizeVT added in v0.11.0 

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

func (*StopReplicationRequest) String 

func (x *StopReplicationRequest) String() string

func (*StopReplicationRequest) UnmarshalVT added in v0.11.0 

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

type StopReplicationResponse 

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

func (*StopReplicationResponse) CloneMessageVT added in v0.18.0 

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

func (*StopReplicationResponse) CloneVT added in v0.18.0 

func (m *StopReplicationResponse) CloneVT() *StopReplicationResponse

func (*StopReplicationResponse) Descriptor deprecated 

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

Deprecated: Use StopReplicationResponse.ProtoReflect.Descriptor instead.

func (*StopReplicationResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*StopReplicationResponse) MarshalToVT added in v0.11.0 

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

func (*StopReplicationResponse) MarshalVT added in v0.11.0 

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

func (*StopReplicationResponse) ProtoMessage 

func (*StopReplicationResponse) ProtoMessage()

func (*StopReplicationResponse) ProtoReflect added in v0.11.0 

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

func (*StopReplicationResponse) Reset 

func (x *StopReplicationResponse) Reset()

func (*StopReplicationResponse) SizeVT added in v0.11.0 

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

func (*StopReplicationResponse) String 

func (x *StopReplicationResponse) String() string

func (*StopReplicationResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

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

func (*TableDefinition) CloneVT added in v0.18.0 

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 added in v0.11.0 

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

func (*TableDefinition) MarshalToVT added in v0.11.0 

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

func (*TableDefinition) MarshalVT added in v0.11.0 

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

func (*TableDefinition) ProtoMessage 

func (*TableDefinition) ProtoMessage()

func (*TableDefinition) ProtoReflect added in v0.11.0 

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

func (*TableDefinition) Reset 

func (x *TableDefinition) Reset()

func (*TableDefinition) SizeVT added in v0.11.0 

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

func (*TableDefinition) String 

func (x *TableDefinition) String() string

func (*TableDefinition) UnmarshalVT added in v0.11.0 

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

type TabletSelectionPreference added in v0.18.0 

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 added in v0.18.0 

func (TabletSelectionPreference) Descriptor() protoreflect.EnumDescriptor

func (TabletSelectionPreference) Enum added in v0.18.0 

func (x TabletSelectionPreference) Enum() *TabletSelectionPreference

func (TabletSelectionPreference) EnumDescriptor deprecated added in v0.18.0 

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

Deprecated: Use TabletSelectionPreference.Descriptor instead.

func (TabletSelectionPreference) Number added in v0.18.0 

func (x TabletSelectionPreference) Number() protoreflect.EnumNumber

func (TabletSelectionPreference) String added in v0.18.0 

func (x TabletSelectionPreference) String() string

func (TabletSelectionPreference) Type added in v0.18.0 

func (TabletSelectionPreference) Type() protoreflect.EnumType

type UndoDemotePrimaryRequest added in v0.12.0 

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

func (*UndoDemotePrimaryRequest) CloneMessageVT added in v0.18.0 

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

func (*UndoDemotePrimaryRequest) CloneVT added in v0.18.0 

func (m *UndoDemotePrimaryRequest) CloneVT() *UndoDemotePrimaryRequest

func (*UndoDemotePrimaryRequest) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use UndoDemotePrimaryRequest.ProtoReflect.Descriptor instead.

func (*UndoDemotePrimaryRequest) GetSemiSync added in v0.13.0 

func (x *UndoDemotePrimaryRequest) GetSemiSync() bool

func (*UndoDemotePrimaryRequest) MarshalToSizedBufferVT added in v0.12.0 

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

func (*UndoDemotePrimaryRequest) MarshalToVT added in v0.12.0 

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

func (*UndoDemotePrimaryRequest) MarshalVT added in v0.12.0 

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

func (*UndoDemotePrimaryRequest) ProtoMessage added in v0.12.0 

func (*UndoDemotePrimaryRequest) ProtoMessage()

func (*UndoDemotePrimaryRequest) ProtoReflect added in v0.12.0 

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

func (*UndoDemotePrimaryRequest) Reset added in v0.12.0 

func (x *UndoDemotePrimaryRequest) Reset()

func (*UndoDemotePrimaryRequest) SizeVT added in v0.12.0 

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

func (*UndoDemotePrimaryRequest) String added in v0.12.0 

func (x *UndoDemotePrimaryRequest) String() string

func (*UndoDemotePrimaryRequest) UnmarshalVT added in v0.12.0 

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

type UndoDemotePrimaryResponse added in v0.12.0 

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

func (*UndoDemotePrimaryResponse) CloneMessageVT added in v0.18.0 

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

func (*UndoDemotePrimaryResponse) CloneVT added in v0.18.0 

func (m *UndoDemotePrimaryResponse) CloneVT() *UndoDemotePrimaryResponse

func (*UndoDemotePrimaryResponse) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use UndoDemotePrimaryResponse.ProtoReflect.Descriptor instead.

func (*UndoDemotePrimaryResponse) MarshalToSizedBufferVT added in v0.12.0 

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

func (*UndoDemotePrimaryResponse) MarshalToVT added in v0.12.0 

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

func (*UndoDemotePrimaryResponse) MarshalVT added in v0.12.0 

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

func (*UndoDemotePrimaryResponse) ProtoMessage added in v0.12.0 

func (*UndoDemotePrimaryResponse) ProtoMessage()

func (*UndoDemotePrimaryResponse) ProtoReflect added in v0.12.0 

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

func (*UndoDemotePrimaryResponse) Reset added in v0.12.0 

func (x *UndoDemotePrimaryResponse) Reset()

func (*UndoDemotePrimaryResponse) SizeVT added in v0.12.0 

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

func (*UndoDemotePrimaryResponse) String added in v0.12.0 

func (x *UndoDemotePrimaryResponse) String() string

func (*UndoDemotePrimaryResponse) UnmarshalVT added in v0.12.0 

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

type UnlockTablesRequest 

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

func (*UnlockTablesRequest) CloneMessageVT added in v0.18.0 

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

func (*UnlockTablesRequest) CloneVT added in v0.18.0 

func (m *UnlockTablesRequest) CloneVT() *UnlockTablesRequest

func (*UnlockTablesRequest) Descriptor deprecated 

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

Deprecated: Use UnlockTablesRequest.ProtoReflect.Descriptor instead.

func (*UnlockTablesRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*UnlockTablesRequest) MarshalToVT added in v0.11.0 

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

func (*UnlockTablesRequest) MarshalVT added in v0.11.0 

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

func (*UnlockTablesRequest) ProtoMessage 

func (*UnlockTablesRequest) ProtoMessage()

func (*UnlockTablesRequest) ProtoReflect added in v0.11.0 

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

func (*UnlockTablesRequest) Reset 

func (x *UnlockTablesRequest) Reset()

func (*UnlockTablesRequest) SizeVT added in v0.11.0 

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

func (*UnlockTablesRequest) String 

func (x *UnlockTablesRequest) String() string

func (*UnlockTablesRequest) UnmarshalVT added in v0.11.0 

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

type UnlockTablesResponse 

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

func (*UnlockTablesResponse) CloneMessageVT added in v0.18.0 

func (m *UnlockTablesResponse) CloneMessageVT() proto.Message

func (*UnlockTablesResponse) CloneVT added in v0.18.0 

func (m *UnlockTablesResponse) CloneVT() *UnlockTablesResponse

func (*UnlockTablesResponse) Descriptor deprecated 

func (*UnlockTablesResponse) Descriptor() ([]byte, []int)

Deprecated: Use UnlockTablesResponse.ProtoReflect.Descriptor instead.

func (*UnlockTablesResponse) MarshalToSizedBufferVT added in v0.11.0 

func (m *UnlockTablesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UnlockTablesResponse) MarshalToVT added in v0.11.0 

func (m *UnlockTablesResponse) MarshalToVT(dAtA []byte) (int, error)

func (*UnlockTablesResponse) MarshalVT added in v0.11.0 

func (m *UnlockTablesResponse) MarshalVT() (dAtA []byte, err error)

func (*UnlockTablesResponse) ProtoMessage 

func (*UnlockTablesResponse) ProtoMessage()

func (*UnlockTablesResponse) ProtoReflect added in v0.11.0 

func (x *UnlockTablesResponse) ProtoReflect() protoreflect.Message

func (*UnlockTablesResponse) Reset 

func (x *UnlockTablesResponse) Reset()

func (*UnlockTablesResponse) SizeVT added in v0.11.0 

func (m *UnlockTablesResponse) SizeVT() (n int)

func (*UnlockTablesResponse) String 

func (x *UnlockTablesResponse) String() string

func (*UnlockTablesResponse) UnmarshalVT added in v0.11.0 

func (m *UnlockTablesResponse) UnmarshalVT(dAtA []byte) error

type UpdateVReplicationWorkflowRequest added in v0.18.0 

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 added in v0.18.0 

func (m *UpdateVReplicationWorkflowRequest) CloneMessageVT() proto.Message

func (*UpdateVReplicationWorkflowRequest) CloneVT added in v0.18.0 

func (m *UpdateVReplicationWorkflowRequest) CloneVT() *UpdateVReplicationWorkflowRequest

func (*UpdateVReplicationWorkflowRequest) Descriptor deprecated added in v0.18.0 

func (*UpdateVReplicationWorkflowRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateVReplicationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*UpdateVReplicationWorkflowRequest) GetCells added in v0.18.0 

func (x *UpdateVReplicationWorkflowRequest) GetCells() []string

func (*UpdateVReplicationWorkflowRequest) GetOnDdl added in v0.18.0 

func (x *UpdateVReplicationWorkflowRequest) GetOnDdl() binlogdata.OnDDLAction

func (*UpdateVReplicationWorkflowRequest) GetState added in v0.18.0 

func (x *UpdateVReplicationWorkflowRequest) GetState() binlogdata.VReplicationWorkflowState

func (*UpdateVReplicationWorkflowRequest) GetTabletSelectionPreference added in v0.18.0 

func (x *UpdateVReplicationWorkflowRequest) GetTabletSelectionPreference() TabletSelectionPreference

func (*UpdateVReplicationWorkflowRequest) GetTabletTypes added in v0.18.0 

func (x *UpdateVReplicationWorkflowRequest) GetTabletTypes() []topodata.TabletType

func (*UpdateVReplicationWorkflowRequest) GetWorkflow added in v0.18.0 

func (x *UpdateVReplicationWorkflowRequest) GetWorkflow() string

func (*UpdateVReplicationWorkflowRequest) MarshalToSizedBufferVT added in v0.18.0 

func (m *UpdateVReplicationWorkflowRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateVReplicationWorkflowRequest) MarshalToVT added in v0.18.0 

func (m *UpdateVReplicationWorkflowRequest) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateVReplicationWorkflowRequest) MarshalVT added in v0.18.0 

func (m *UpdateVReplicationWorkflowRequest) MarshalVT() (dAtA []byte, err error)

func (*UpdateVReplicationWorkflowRequest) ProtoMessage added in v0.18.0 

func (*UpdateVReplicationWorkflowRequest) ProtoMessage()

func (*UpdateVReplicationWorkflowRequest) ProtoReflect added in v0.18.0 

func (x *UpdateVReplicationWorkflowRequest) ProtoReflect() protoreflect.Message

func (*UpdateVReplicationWorkflowRequest) Reset added in v0.18.0 

func (x *UpdateVReplicationWorkflowRequest) Reset()

func (*UpdateVReplicationWorkflowRequest) SizeVT added in v0.18.0 

func (m *UpdateVReplicationWorkflowRequest) SizeVT() (n int)

func (*UpdateVReplicationWorkflowRequest) String added in v0.18.0 

func (x *UpdateVReplicationWorkflowRequest) String() string

func (*UpdateVReplicationWorkflowRequest) UnmarshalVT added in v0.18.0 

func (m *UpdateVReplicationWorkflowRequest) UnmarshalVT(dAtA []byte) error

type UpdateVReplicationWorkflowResponse added in v0.18.0 

type UpdateVReplicationWorkflowResponse struct {
	Result *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateVReplicationWorkflowResponse) CloneMessageVT added in v0.18.0 

func (m *UpdateVReplicationWorkflowResponse) CloneMessageVT() proto.Message

func (*UpdateVReplicationWorkflowResponse) CloneVT added in v0.18.0 

func (m *UpdateVReplicationWorkflowResponse) CloneVT() *UpdateVReplicationWorkflowResponse

func (*UpdateVReplicationWorkflowResponse) Descriptor deprecated added in v0.18.0 

func (*UpdateVReplicationWorkflowResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateVReplicationWorkflowResponse.ProtoReflect.Descriptor instead.

func (*UpdateVReplicationWorkflowResponse) GetResult added in v0.18.0 

func (x *UpdateVReplicationWorkflowResponse) GetResult() *query.QueryResult

func (*UpdateVReplicationWorkflowResponse) MarshalToSizedBufferVT added in v0.18.0 

func (m *UpdateVReplicationWorkflowResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateVReplicationWorkflowResponse) MarshalToVT added in v0.18.0 

func (m *UpdateVReplicationWorkflowResponse) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateVReplicationWorkflowResponse) MarshalVT added in v0.18.0 

func (m *UpdateVReplicationWorkflowResponse) MarshalVT() (dAtA []byte, err error)

func (*UpdateVReplicationWorkflowResponse) ProtoMessage added in v0.18.0 

func (*UpdateVReplicationWorkflowResponse) ProtoMessage()

func (*UpdateVReplicationWorkflowResponse) ProtoReflect added in v0.18.0 

func (x *UpdateVReplicationWorkflowResponse) ProtoReflect() protoreflect.Message

func (*UpdateVReplicationWorkflowResponse) Reset added in v0.18.0 

func (x *UpdateVReplicationWorkflowResponse) Reset()

func (*UpdateVReplicationWorkflowResponse) SizeVT added in v0.18.0 

func (m *UpdateVReplicationWorkflowResponse) SizeVT() (n int)

func (*UpdateVReplicationWorkflowResponse) String added in v0.18.0 

func (x *UpdateVReplicationWorkflowResponse) String() string

func (*UpdateVReplicationWorkflowResponse) UnmarshalVT added in v0.18.0 

func (m *UpdateVReplicationWorkflowResponse) 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 added in v0.18.0 

func (m *UserPermission) CloneMessageVT() proto.Message

func (*UserPermission) CloneVT added in v0.18.0 

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 added in v0.11.0 

func (m *UserPermission) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UserPermission) MarshalToVT added in v0.11.0 

func (m *UserPermission) MarshalToVT(dAtA []byte) (int, error)

func (*UserPermission) MarshalVT added in v0.11.0 

func (m *UserPermission) MarshalVT() (dAtA []byte, err error)

func (*UserPermission) ProtoMessage 

func (*UserPermission) ProtoMessage()

func (*UserPermission) ProtoReflect added in v0.11.0 

func (x *UserPermission) ProtoReflect() protoreflect.Message

func (*UserPermission) Reset 

func (x *UserPermission) Reset()

func (*UserPermission) SizeVT added in v0.11.0 

func (m *UserPermission) SizeVT() (n int)

func (*UserPermission) String 

func (x *UserPermission) String() string

func (*UserPermission) UnmarshalVT added in v0.11.0 

func (m *UserPermission) UnmarshalVT(dAtA []byte) error

type VDiffCoreOptions added in v0.14.0 

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 added in v0.18.0 

func (m *VDiffCoreOptions) CloneMessageVT() proto.Message

func (*VDiffCoreOptions) CloneVT added in v0.18.0 

func (m *VDiffCoreOptions) CloneVT() *VDiffCoreOptions

func (*VDiffCoreOptions) Descriptor deprecated added in v0.14.0 

func (*VDiffCoreOptions) Descriptor() ([]byte, []int)

Deprecated: Use VDiffCoreOptions.ProtoReflect.Descriptor instead.

func (*VDiffCoreOptions) GetAutoRetry added in v0.15.0 

func (x *VDiffCoreOptions) GetAutoRetry() bool

func (*VDiffCoreOptions) GetChecksum added in v0.14.0 

func (x *VDiffCoreOptions) GetChecksum() bool

func (*VDiffCoreOptions) GetMaxDiffSeconds added in v0.19.0 

func (x *VDiffCoreOptions) GetMaxDiffSeconds() int64

func (*VDiffCoreOptions) GetMaxExtraRowsToCompare added in v0.14.0 

func (x *VDiffCoreOptions) GetMaxExtraRowsToCompare() int64

func (*VDiffCoreOptions) GetMaxRows added in v0.14.0 

func (x *VDiffCoreOptions) GetMaxRows() int64

func (*VDiffCoreOptions) GetSamplePct added in v0.14.0 

func (x *VDiffCoreOptions) GetSamplePct() int64

func (*VDiffCoreOptions) GetTables added in v0.14.0 

func (x *VDiffCoreOptions) GetTables() string

func (*VDiffCoreOptions) GetTimeoutSeconds added in v0.14.0 

func (x *VDiffCoreOptions) GetTimeoutSeconds() int64

func (*VDiffCoreOptions) GetUpdateTableStats added in v0.17.0 

func (x *VDiffCoreOptions) GetUpdateTableStats() bool

func (*VDiffCoreOptions) MarshalToSizedBufferVT added in v0.14.0 

func (m *VDiffCoreOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VDiffCoreOptions) MarshalToVT added in v0.14.0 

func (m *VDiffCoreOptions) MarshalToVT(dAtA []byte) (int, error)

func (*VDiffCoreOptions) MarshalVT added in v0.14.0 

func (m *VDiffCoreOptions) MarshalVT() (dAtA []byte, err error)

func (*VDiffCoreOptions) ProtoMessage added in v0.14.0 

func (*VDiffCoreOptions) ProtoMessage()

func (*VDiffCoreOptions) ProtoReflect added in v0.14.0 

func (x *VDiffCoreOptions) ProtoReflect() protoreflect.Message

func (*VDiffCoreOptions) Reset added in v0.14.0 

func (x *VDiffCoreOptions) Reset()

func (*VDiffCoreOptions) SizeVT added in v0.14.0 

func (m *VDiffCoreOptions) SizeVT() (n int)

func (*VDiffCoreOptions) String added in v0.14.0 

func (x *VDiffCoreOptions) String() string

func (*VDiffCoreOptions) UnmarshalVT added in v0.14.0 

func (m *VDiffCoreOptions) UnmarshalVT(dAtA []byte) error

type VDiffOptions added in v0.14.0 

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 added in v0.18.0 

func (m *VDiffOptions) CloneMessageVT() proto.Message

func (*VDiffOptions) CloneVT added in v0.18.0 

func (m *VDiffOptions) CloneVT() *VDiffOptions

func (*VDiffOptions) Descriptor deprecated added in v0.14.0 

func (*VDiffOptions) Descriptor() ([]byte, []int)

Deprecated: Use VDiffOptions.ProtoReflect.Descriptor instead.

func (*VDiffOptions) GetCoreOptions added in v0.14.0 

func (x *VDiffOptions) GetCoreOptions() *VDiffCoreOptions

func (*VDiffOptions) GetPickerOptions added in v0.14.0 

func (x *VDiffOptions) GetPickerOptions() *VDiffPickerOptions

func (*VDiffOptions) GetReportOptions added in v0.14.0 

func (x *VDiffOptions) GetReportOptions() *VDiffReportOptions

func (*VDiffOptions) MarshalToSizedBufferVT added in v0.14.0 

func (m *VDiffOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VDiffOptions) MarshalToVT added in v0.14.0 

func (m *VDiffOptions) MarshalToVT(dAtA []byte) (int, error)

func (*VDiffOptions) MarshalVT added in v0.14.0 

func (m *VDiffOptions) MarshalVT() (dAtA []byte, err error)

func (*VDiffOptions) ProtoMessage added in v0.14.0 

func (*VDiffOptions) ProtoMessage()

func (*VDiffOptions) ProtoReflect added in v0.14.0 

func (x *VDiffOptions) ProtoReflect() protoreflect.Message

func (*VDiffOptions) Reset added in v0.14.0 

func (x *VDiffOptions) Reset()

func (*VDiffOptions) SizeVT added in v0.14.0 

func (m *VDiffOptions) SizeVT() (n int)

func (*VDiffOptions) String added in v0.14.0 

func (x *VDiffOptions) String() string

func (*VDiffOptions) UnmarshalVT added in v0.14.0 

func (m *VDiffOptions) UnmarshalVT(dAtA []byte) error

type VDiffPickerOptions added in v0.14.0 

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 added in v0.18.0 

func (m *VDiffPickerOptions) CloneMessageVT() proto.Message

func (*VDiffPickerOptions) CloneVT added in v0.18.0 

func (m *VDiffPickerOptions) CloneVT() *VDiffPickerOptions

func (*VDiffPickerOptions) Descriptor deprecated added in v0.14.0 

func (*VDiffPickerOptions) Descriptor() ([]byte, []int)

Deprecated: Use VDiffPickerOptions.ProtoReflect.Descriptor instead.

func (*VDiffPickerOptions) GetSourceCell added in v0.14.0 

func (x *VDiffPickerOptions) GetSourceCell() string

func (*VDiffPickerOptions) GetTabletTypes added in v0.14.0 

func (x *VDiffPickerOptions) GetTabletTypes() string

func (*VDiffPickerOptions) GetTargetCell added in v0.14.0 

func (x *VDiffPickerOptions) GetTargetCell() string

func (*VDiffPickerOptions) MarshalToSizedBufferVT added in v0.14.0 

func (m *VDiffPickerOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VDiffPickerOptions) MarshalToVT added in v0.14.0 

func (m *VDiffPickerOptions) MarshalToVT(dAtA []byte) (int, error)

func (*VDiffPickerOptions) MarshalVT added in v0.14.0 

func (m *VDiffPickerOptions) MarshalVT() (dAtA []byte, err error)

func (*VDiffPickerOptions) ProtoMessage added in v0.14.0 

func (*VDiffPickerOptions) ProtoMessage()

func (*VDiffPickerOptions) ProtoReflect added in v0.14.0 

func (x *VDiffPickerOptions) ProtoReflect() protoreflect.Message

func (*VDiffPickerOptions) Reset added in v0.14.0 

func (x *VDiffPickerOptions) Reset()

func (*VDiffPickerOptions) SizeVT added in v0.14.0 

func (m *VDiffPickerOptions) SizeVT() (n int)

func (*VDiffPickerOptions) String added in v0.14.0 

func (x *VDiffPickerOptions) String() string

func (*VDiffPickerOptions) UnmarshalVT added in v0.14.0 

func (m *VDiffPickerOptions) UnmarshalVT(dAtA []byte) error

type VDiffReportOptions added in v0.14.0 

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 added in v0.18.0 

func (m *VDiffReportOptions) CloneMessageVT() proto.Message

func (*VDiffReportOptions) CloneVT added in v0.18.0 

func (m *VDiffReportOptions) CloneVT() *VDiffReportOptions

func (*VDiffReportOptions) Descriptor deprecated added in v0.14.0 

func (*VDiffReportOptions) Descriptor() ([]byte, []int)

Deprecated: Use VDiffReportOptions.ProtoReflect.Descriptor instead.

func (*VDiffReportOptions) GetDebugQuery added in v0.14.0 

func (x *VDiffReportOptions) GetDebugQuery() bool

func (*VDiffReportOptions) GetFormat added in v0.14.0 

func (x *VDiffReportOptions) GetFormat() string

func (*VDiffReportOptions) GetMaxSampleRows added in v0.19.0 

func (x *VDiffReportOptions) GetMaxSampleRows() int64

func (*VDiffReportOptions) GetOnlyPks added in v0.16.0 

func (x *VDiffReportOptions) GetOnlyPks() bool

func (*VDiffReportOptions) MarshalToSizedBufferVT added in v0.14.0 

func (m *VDiffReportOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VDiffReportOptions) MarshalToVT added in v0.14.0 

func (m *VDiffReportOptions) MarshalToVT(dAtA []byte) (int, error)

func (*VDiffReportOptions) MarshalVT added in v0.14.0 

func (m *VDiffReportOptions) MarshalVT() (dAtA []byte, err error)

func (*VDiffReportOptions) ProtoMessage added in v0.14.0 

func (*VDiffReportOptions) ProtoMessage()

func (*VDiffReportOptions) ProtoReflect added in v0.14.0 

func (x *VDiffReportOptions) ProtoReflect() protoreflect.Message

func (*VDiffReportOptions) Reset added in v0.14.0 

func (x *VDiffReportOptions) Reset()

func (*VDiffReportOptions) SizeVT added in v0.14.0 

func (m *VDiffReportOptions) SizeVT() (n int)

func (*VDiffReportOptions) String added in v0.14.0 

func (x *VDiffReportOptions) String() string

func (*VDiffReportOptions) UnmarshalVT added in v0.14.0 

func (m *VDiffReportOptions) UnmarshalVT(dAtA []byte) error

type VDiffRequest added in v0.14.0 

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 added in v0.18.0 

func (m *VDiffRequest) CloneMessageVT() proto.Message

func (*VDiffRequest) CloneVT added in v0.18.0 

func (m *VDiffRequest) CloneVT() *VDiffRequest

func (*VDiffRequest) Descriptor deprecated added in v0.14.0 

func (*VDiffRequest) Descriptor() ([]byte, []int)

Deprecated: Use VDiffRequest.ProtoReflect.Descriptor instead.

func (*VDiffRequest) GetAction added in v0.15.0 

func (x *VDiffRequest) GetAction() string

func (*VDiffRequest) GetActionArg added in v0.15.0 

func (x *VDiffRequest) GetActionArg() string

func (*VDiffRequest) GetKeyspace added in v0.14.0 

func (x *VDiffRequest) GetKeyspace() string

func (*VDiffRequest) GetOptions added in v0.14.0 

func (x *VDiffRequest) GetOptions() *VDiffOptions

func (*VDiffRequest) GetVdiffUuid added in v0.14.0 

func (x *VDiffRequest) GetVdiffUuid() string

func (*VDiffRequest) GetWorkflow added in v0.14.0 

func (x *VDiffRequest) GetWorkflow() string

func (*VDiffRequest) MarshalToSizedBufferVT added in v0.14.0 

func (m *VDiffRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VDiffRequest) MarshalToVT added in v0.14.0 

func (m *VDiffRequest) MarshalToVT(dAtA []byte) (int, error)

func (*VDiffRequest) MarshalVT added in v0.14.0 

func (m *VDiffRequest) MarshalVT() (dAtA []byte, err error)

func (*VDiffRequest) ProtoMessage added in v0.14.0 

func (*VDiffRequest) ProtoMessage()

func (*VDiffRequest) ProtoReflect added in v0.14.0 

func (x *VDiffRequest) ProtoReflect() protoreflect.Message

func (*VDiffRequest) Reset added in v0.14.0 

func (x *VDiffRequest) Reset()

func (*VDiffRequest) SizeVT added in v0.14.0 

func (m *VDiffRequest) SizeVT() (n int)

func (*VDiffRequest) String added in v0.14.0 

func (x *VDiffRequest) String() string

func (*VDiffRequest) UnmarshalVT added in v0.14.0 

func (m *VDiffRequest) UnmarshalVT(dAtA []byte) error

type VDiffResponse added in v0.14.0 

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 added in v0.18.0 

func (m *VDiffResponse) CloneMessageVT() proto.Message

func (*VDiffResponse) CloneVT added in v0.18.0 

func (m *VDiffResponse) CloneVT() *VDiffResponse

func (*VDiffResponse) Descriptor deprecated added in v0.14.0 

func (*VDiffResponse) Descriptor() ([]byte, []int)

Deprecated: Use VDiffResponse.ProtoReflect.Descriptor instead.

func (*VDiffResponse) GetId added in v0.14.0 

func (x *VDiffResponse) GetId() int64

func (*VDiffResponse) GetOutput added in v0.14.0 

func (x *VDiffResponse) GetOutput() *query.QueryResult

func (*VDiffResponse) GetVdiffUuid added in v0.14.0 

func (x *VDiffResponse) GetVdiffUuid() string

func (*VDiffResponse) MarshalToSizedBufferVT added in v0.14.0 

func (m *VDiffResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VDiffResponse) MarshalToVT added in v0.14.0 

func (m *VDiffResponse) MarshalToVT(dAtA []byte) (int, error)

func (*VDiffResponse) MarshalVT added in v0.14.0 

func (m *VDiffResponse) MarshalVT() (dAtA []byte, err error)

func (*VDiffResponse) ProtoMessage added in v0.14.0 

func (*VDiffResponse) ProtoMessage()

func (*VDiffResponse) ProtoReflect added in v0.14.0 

func (x *VDiffResponse) ProtoReflect() protoreflect.Message

func (*VDiffResponse) Reset added in v0.14.0 

func (x *VDiffResponse) Reset()

func (*VDiffResponse) SizeVT added in v0.14.0 

func (m *VDiffResponse) SizeVT() (n int)

func (*VDiffResponse) String added in v0.14.0 

func (x *VDiffResponse) String() string

func (*VDiffResponse) UnmarshalVT added in v0.14.0 

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 added in v0.18.0 

func (m *VReplicationExecRequest) CloneMessageVT() proto.Message

func (*VReplicationExecRequest) CloneVT added in v0.18.0 

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 added in v0.11.0 

func (m *VReplicationExecRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VReplicationExecRequest) MarshalToVT added in v0.11.0 

func (m *VReplicationExecRequest) MarshalToVT(dAtA []byte) (int, error)

func (*VReplicationExecRequest) MarshalVT added in v0.11.0 

func (m *VReplicationExecRequest) MarshalVT() (dAtA []byte, err error)

func (*VReplicationExecRequest) ProtoMessage 

func (*VReplicationExecRequest) ProtoMessage()

func (*VReplicationExecRequest) ProtoReflect added in v0.11.0 

func (x *VReplicationExecRequest) ProtoReflect() protoreflect.Message

func (*VReplicationExecRequest) Reset 

func (x *VReplicationExecRequest) Reset()

func (*VReplicationExecRequest) SizeVT added in v0.11.0 

func (m *VReplicationExecRequest) SizeVT() (n int)

func (*VReplicationExecRequest) String 

func (x *VReplicationExecRequest) String() string

func (*VReplicationExecRequest) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

func (m *VReplicationExecResponse) CloneMessageVT() proto.Message

func (*VReplicationExecResponse) CloneVT added in v0.18.0 

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 added in v0.11.0 

func (m *VReplicationExecResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VReplicationExecResponse) MarshalToVT added in v0.11.0 

func (m *VReplicationExecResponse) MarshalToVT(dAtA []byte) (int, error)

func (*VReplicationExecResponse) MarshalVT added in v0.11.0 

func (m *VReplicationExecResponse) MarshalVT() (dAtA []byte, err error)

func (*VReplicationExecResponse) ProtoMessage 

func (*VReplicationExecResponse) ProtoMessage()

func (*VReplicationExecResponse) ProtoReflect added in v0.11.0 

func (x *VReplicationExecResponse) ProtoReflect() protoreflect.Message

func (*VReplicationExecResponse) Reset 

func (x *VReplicationExecResponse) Reset()

func (*VReplicationExecResponse) SizeVT added in v0.11.0 

func (m *VReplicationExecResponse) SizeVT() (n int)

func (*VReplicationExecResponse) String 

func (x *VReplicationExecResponse) String() string

func (*VReplicationExecResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

func (m *VReplicationWaitForPosRequest) CloneMessageVT() proto.Message

func (*VReplicationWaitForPosRequest) CloneVT added in v0.18.0 

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 added in v0.11.0 

func (m *VReplicationWaitForPosRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VReplicationWaitForPosRequest) MarshalToVT added in v0.11.0 

func (m *VReplicationWaitForPosRequest) MarshalToVT(dAtA []byte) (int, error)

func (*VReplicationWaitForPosRequest) MarshalVT added in v0.11.0 

func (m *VReplicationWaitForPosRequest) MarshalVT() (dAtA []byte, err error)

func (*VReplicationWaitForPosRequest) ProtoMessage 

func (*VReplicationWaitForPosRequest) ProtoMessage()

func (*VReplicationWaitForPosRequest) ProtoReflect added in v0.11.0 

func (x *VReplicationWaitForPosRequest) ProtoReflect() protoreflect.Message

func (*VReplicationWaitForPosRequest) Reset 

func (x *VReplicationWaitForPosRequest) Reset()

func (*VReplicationWaitForPosRequest) SizeVT added in v0.11.0 

func (m *VReplicationWaitForPosRequest) SizeVT() (n int)

func (*VReplicationWaitForPosRequest) String 

func (x *VReplicationWaitForPosRequest) String() string

func (*VReplicationWaitForPosRequest) UnmarshalVT added in v0.11.0 

func (m *VReplicationWaitForPosRequest) UnmarshalVT(dAtA []byte) error

type VReplicationWaitForPosResponse 

type VReplicationWaitForPosResponse struct {
	// contains filtered or unexported fields
}

func (*VReplicationWaitForPosResponse) CloneMessageVT added in v0.18.0 

func (m *VReplicationWaitForPosResponse) CloneMessageVT() proto.Message

func (*VReplicationWaitForPosResponse) CloneVT added in v0.18.0 

func (m *VReplicationWaitForPosResponse) CloneVT() *VReplicationWaitForPosResponse

func (*VReplicationWaitForPosResponse) Descriptor deprecated 

func (*VReplicationWaitForPosResponse) Descriptor() ([]byte, []int)

Deprecated: Use VReplicationWaitForPosResponse.ProtoReflect.Descriptor instead.

func (*VReplicationWaitForPosResponse) MarshalToSizedBufferVT added in v0.11.0 

func (m *VReplicationWaitForPosResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VReplicationWaitForPosResponse) MarshalToVT added in v0.11.0 

func (m *VReplicationWaitForPosResponse) MarshalToVT(dAtA []byte) (int, error)

func (*VReplicationWaitForPosResponse) MarshalVT added in v0.11.0 

func (m *VReplicationWaitForPosResponse) MarshalVT() (dAtA []byte, err error)

func (*VReplicationWaitForPosResponse) ProtoMessage 

func (*VReplicationWaitForPosResponse) ProtoMessage()

func (*VReplicationWaitForPosResponse) ProtoReflect added in v0.11.0 

func (x *VReplicationWaitForPosResponse) ProtoReflect() protoreflect.Message

func (*VReplicationWaitForPosResponse) Reset 

func (x *VReplicationWaitForPosResponse) Reset()

func (*VReplicationWaitForPosResponse) SizeVT added in v0.11.0 

func (m *VReplicationWaitForPosResponse) SizeVT() (n int)

func (*VReplicationWaitForPosResponse) String 

func (x *VReplicationWaitForPosResponse) String() string

func (*VReplicationWaitForPosResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

func (m *WaitForPositionRequest) CloneMessageVT() proto.Message

func (*WaitForPositionRequest) CloneVT added in v0.18.0 

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 added in v0.11.0 

func (m *WaitForPositionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WaitForPositionRequest) MarshalToVT added in v0.11.0 

func (m *WaitForPositionRequest) MarshalToVT(dAtA []byte) (int, error)

func (*WaitForPositionRequest) MarshalVT added in v0.11.0 

func (m *WaitForPositionRequest) MarshalVT() (dAtA []byte, err error)

func (*WaitForPositionRequest) ProtoMessage 

func (*WaitForPositionRequest) ProtoMessage()

func (*WaitForPositionRequest) ProtoReflect added in v0.11.0 

func (x *WaitForPositionRequest) ProtoReflect() protoreflect.Message

func (*WaitForPositionRequest) Reset 

func (x *WaitForPositionRequest) Reset()

func (*WaitForPositionRequest) SizeVT added in v0.11.0 

func (m *WaitForPositionRequest) SizeVT() (n int)

func (*WaitForPositionRequest) String 

func (x *WaitForPositionRequest) String() string

func (*WaitForPositionRequest) UnmarshalVT added in v0.11.0 

func (m *WaitForPositionRequest) UnmarshalVT(dAtA []byte) error

type WaitForPositionResponse 

type WaitForPositionResponse struct {
	// contains filtered or unexported fields
}

func (*WaitForPositionResponse) CloneMessageVT added in v0.18.0 

func (m *WaitForPositionResponse) CloneMessageVT() proto.Message

func (*WaitForPositionResponse) CloneVT added in v0.18.0 

func (m *WaitForPositionResponse) CloneVT() *WaitForPositionResponse

func (*WaitForPositionResponse) Descriptor deprecated 

func (*WaitForPositionResponse) Descriptor() ([]byte, []int)

Deprecated: Use WaitForPositionResponse.ProtoReflect.Descriptor instead.

func (*WaitForPositionResponse) MarshalToSizedBufferVT added in v0.11.0 

func (m *WaitForPositionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WaitForPositionResponse) MarshalToVT added in v0.11.0 

func (m *WaitForPositionResponse) MarshalToVT(dAtA []byte) (int, error)

func (*WaitForPositionResponse) MarshalVT added in v0.11.0 

func (m *WaitForPositionResponse) MarshalVT() (dAtA []byte, err error)

func (*WaitForPositionResponse) ProtoMessage 

func (*WaitForPositionResponse) ProtoMessage()

func (*WaitForPositionResponse) ProtoReflect added in v0.11.0 

func (x *WaitForPositionResponse) ProtoReflect() protoreflect.Message

func (*WaitForPositionResponse) Reset 

func (x *WaitForPositionResponse) Reset()

func (*WaitForPositionResponse) SizeVT added in v0.11.0 

func (m *WaitForPositionResponse) SizeVT() (n int)

func (*WaitForPositionResponse) String 

func (x *WaitForPositionResponse) String() string

func (*WaitForPositionResponse) UnmarshalVT added in v0.11.0 

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.