tabletmanagerdata

package
v0.12.1 Latest Latest
Warning

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

 Go to latest Published: Dec 14, 2021 License: Apache-2.0 Imports: 12 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"`
	// 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) 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"`
	// 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) 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"`
	// contains filtered or unexported fields
}

func (*ChangeTypeRequest) Descriptor deprecated 

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

Deprecated: Use ChangeTypeRequest.ProtoReflect.Descriptor instead.

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 {

	// Position is deprecated, and is a string representation of a demoted primaries executed position.
	//
	// Deprecated: Do not use.
	DeprecatedPosition string `protobuf:"bytes,1,opt,name=deprecated_position,json=deprecatedPosition,proto3" json:"deprecated_position,omitempty"`
	// 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) GetDeprecatedPosition deprecated added in v0.12.0 

func (x *DemotePrimaryResponse) GetDeprecatedPosition() string

Deprecated: Do not use.

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"`
	// 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) 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 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"`
	// 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) 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 IgnoreHealthErrorRequest 

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

func (*IgnoreHealthErrorRequest) Descriptor deprecated 

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

Deprecated: Use IgnoreHealthErrorRequest.ProtoReflect.Descriptor instead.

func (*IgnoreHealthErrorRequest) GetPattern 

func (x *IgnoreHealthErrorRequest) GetPattern() string

func (*IgnoreHealthErrorRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*IgnoreHealthErrorRequest) MarshalToVT added in v0.11.0 

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

func (*IgnoreHealthErrorRequest) MarshalVT added in v0.11.0 

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

func (*IgnoreHealthErrorRequest) ProtoMessage 

func (*IgnoreHealthErrorRequest) ProtoMessage()

func (*IgnoreHealthErrorRequest) ProtoReflect added in v0.11.0 

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

func (*IgnoreHealthErrorRequest) Reset 

func (x *IgnoreHealthErrorRequest) Reset()

func (*IgnoreHealthErrorRequest) SizeVT added in v0.11.0 

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

func (*IgnoreHealthErrorRequest) String 

func (x *IgnoreHealthErrorRequest) String() string

func (*IgnoreHealthErrorRequest) UnmarshalVT added in v0.11.0 

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

type IgnoreHealthErrorResponse 

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

func (*IgnoreHealthErrorResponse) Descriptor deprecated 

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

Deprecated: Use IgnoreHealthErrorResponse.ProtoReflect.Descriptor instead.

func (*IgnoreHealthErrorResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*IgnoreHealthErrorResponse) MarshalToVT added in v0.11.0 

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

func (*IgnoreHealthErrorResponse) MarshalVT added in v0.11.0 

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

func (*IgnoreHealthErrorResponse) ProtoMessage 

func (*IgnoreHealthErrorResponse) ProtoMessage()

func (*IgnoreHealthErrorResponse) ProtoReflect added in v0.11.0 

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

func (*IgnoreHealthErrorResponse) Reset 

func (x *IgnoreHealthErrorResponse) Reset()

func (*IgnoreHealthErrorResponse) SizeVT added in v0.11.0 

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

func (*IgnoreHealthErrorResponse) String 

func (x *IgnoreHealthErrorResponse) String() string

func (*IgnoreHealthErrorResponse) UnmarshalVT added in v0.11.0 

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

type InitPrimaryRequest added in v0.12.0 

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

func (*PromoteReplicaRequest) Descriptor deprecated 

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

Deprecated: Use PromoteReplicaRequest.ProtoReflect.Descriptor instead.

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 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"`
	// 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) 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"`
	Version          string             `protobuf:"bytes,3,opt,name=version,proto3" json:"version,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) GetVersion 

func (x *SchemaDefinition) GetVersion() string

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

func (*StartReplicationRequest) Descriptor deprecated 

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

Deprecated: Use StartReplicationRequest.ProtoReflect.Descriptor instead.

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 {

	// HybridStatus is deprecated. It currently represents a hybrid struct where all data represents the before state,
	// except for all position related data which comes from the after state. Please use status instead, which holds
	// discrete replication status calls before and after stopping the replica, or stopping the replica's io_thread.
	//
	// Deprecated: Do not use.
	HybridStatus *replicationdata.Status `protobuf:"bytes,1,opt,name=hybrid_status,json=hybridStatus,proto3" json:"hybrid_status,omitempty"`
	// 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) GetHybridStatus deprecated 

func (x *StopReplicationAndGetStatusResponse) GetHybridStatus() *replicationdata.Status

Deprecated: Do not use.

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 {
	// 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) 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 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 VExecRequest added in v0.8.0 

type VExecRequest struct {
	Query    string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Workflow string `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"`
	Keyspace string `protobuf:"bytes,3,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*VExecRequest) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use VExecRequest.ProtoReflect.Descriptor instead.

func (*VExecRequest) GetKeyspace added in v0.8.0 

func (x *VExecRequest) GetKeyspace() string

func (*VExecRequest) GetQuery added in v0.8.0 

func (x *VExecRequest) GetQuery() string

func (*VExecRequest) GetWorkflow added in v0.8.0 

func (x *VExecRequest) GetWorkflow() string

func (*VExecRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*VExecRequest) MarshalToVT added in v0.11.0 

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

func (*VExecRequest) MarshalVT added in v0.11.0 

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

func (*VExecRequest) ProtoMessage added in v0.8.0 

func (*VExecRequest) ProtoMessage()

func (*VExecRequest) ProtoReflect added in v0.11.0 

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

func (*VExecRequest) Reset added in v0.8.0 

func (x *VExecRequest) Reset()

func (*VExecRequest) SizeVT added in v0.11.0 

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

func (*VExecRequest) String added in v0.8.0 

func (x *VExecRequest) String() string

func (*VExecRequest) UnmarshalVT added in v0.11.0 

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

type VExecResponse added in v0.8.0 

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

func (*VExecResponse) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use VExecResponse.ProtoReflect.Descriptor instead.

func (*VExecResponse) GetResult added in v0.8.0 

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

func (*VExecResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*VExecResponse) MarshalToVT added in v0.11.0 

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

func (*VExecResponse) MarshalVT added in v0.11.0 

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

func (*VExecResponse) ProtoMessage added in v0.8.0 

func (*VExecResponse) ProtoMessage()

func (*VExecResponse) ProtoReflect added in v0.11.0 

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

func (*VExecResponse) Reset added in v0.8.0 

func (x *VExecResponse) Reset()

func (*VExecResponse) SizeVT added in v0.11.0 

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

func (*VExecResponse) String added in v0.8.0 

func (x *VExecResponse) String() string

func (*VExecResponse) UnmarshalVT added in v0.11.0 

func (m *VExecResponse) 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       int64  `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() int64

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.