tabletmanagerdata

package
v0.17.4 Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2023 License: Apache-2.0 Imports: 14 Imported by: 28

Documentation

Index

Constants

This section is empty.

Variables

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

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

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

func (*BackupRequest) GetIncrementalFromPos added in v0.16.0 

func (x *BackupRequest) GetIncrementalFromPos() string

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

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

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

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

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

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

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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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 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) 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) 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) 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) 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 UpdateVRWorkflowRequest added in v0.17.0 

type UpdateVRWorkflowRequest 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 []string               `protobuf:"bytes,3,rep,name=tablet_types,json=tabletTypes,proto3" json:"tablet_types,omitempty"`
	OnDdl       binlogdata.OnDDLAction `protobuf:"varint,4,opt,name=on_ddl,json=onDdl,proto3,enum=binlogdata.OnDDLAction" json:"on_ddl,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateVRWorkflowRequest) Descriptor deprecated added in v0.17.0 

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

Deprecated: Use UpdateVRWorkflowRequest.ProtoReflect.Descriptor instead.

func (*UpdateVRWorkflowRequest) GetCells added in v0.17.0 

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

func (*UpdateVRWorkflowRequest) GetOnDdl added in v0.17.0 

func (x *UpdateVRWorkflowRequest) GetOnDdl() binlogdata.OnDDLAction

func (*UpdateVRWorkflowRequest) GetTabletTypes added in v0.17.0 

func (x *UpdateVRWorkflowRequest) GetTabletTypes() []string

func (*UpdateVRWorkflowRequest) GetWorkflow added in v0.17.0 

func (x *UpdateVRWorkflowRequest) GetWorkflow() string

func (*UpdateVRWorkflowRequest) MarshalToSizedBufferVT added in v0.17.0 

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

func (*UpdateVRWorkflowRequest) MarshalToVT added in v0.17.0 

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

func (*UpdateVRWorkflowRequest) MarshalVT added in v0.17.0 

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

func (*UpdateVRWorkflowRequest) ProtoMessage added in v0.17.0 

func (*UpdateVRWorkflowRequest) ProtoMessage()

func (*UpdateVRWorkflowRequest) ProtoReflect added in v0.17.0 

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

func (*UpdateVRWorkflowRequest) Reset added in v0.17.0 

func (x *UpdateVRWorkflowRequest) Reset()

func (*UpdateVRWorkflowRequest) SizeVT added in v0.17.0 

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

func (*UpdateVRWorkflowRequest) String added in v0.17.0 

func (x *UpdateVRWorkflowRequest) String() string

func (*UpdateVRWorkflowRequest) UnmarshalVT added in v0.17.0 

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

type UpdateVRWorkflowResponse added in v0.17.0 

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

func (*UpdateVRWorkflowResponse) Descriptor deprecated added in v0.17.0 

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

Deprecated: Use UpdateVRWorkflowResponse.ProtoReflect.Descriptor instead.

func (*UpdateVRWorkflowResponse) GetResult added in v0.17.0 

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

func (*UpdateVRWorkflowResponse) MarshalToSizedBufferVT added in v0.17.0 

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

func (*UpdateVRWorkflowResponse) MarshalToVT added in v0.17.0 

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

func (*UpdateVRWorkflowResponse) MarshalVT added in v0.17.0 

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

func (*UpdateVRWorkflowResponse) ProtoMessage added in v0.17.0 

func (*UpdateVRWorkflowResponse) ProtoMessage()

func (*UpdateVRWorkflowResponse) ProtoReflect added in v0.17.0 

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

func (*UpdateVRWorkflowResponse) Reset added in v0.17.0 

func (x *UpdateVRWorkflowResponse) Reset()

func (*UpdateVRWorkflowResponse) SizeVT added in v0.17.0 

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

func (*UpdateVRWorkflowResponse) String added in v0.17.0 

func (x *UpdateVRWorkflowResponse) String() string

func (*UpdateVRWorkflowResponse) UnmarshalVT added in v0.17.0 

func (m *UpdateVRWorkflowResponse) 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) 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"`
	// contains filtered or unexported fields
}

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

options that only influence how vdiff differences are reported

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