tabletmanagerdata

Documentation

Index

• Variables
• type ApplySchemaRequest
  • func (*ApplySchemaRequest) Descriptor() ([]byte, []int)
  • func (x *ApplySchemaRequest) GetAfterSchema() *SchemaDefinition
  • func (x *ApplySchemaRequest) GetAllowReplication() bool
  • func (x *ApplySchemaRequest) GetBeforeSchema() *SchemaDefinition
  • func (x *ApplySchemaRequest) GetForce() bool
  • func (x *ApplySchemaRequest) GetSql() string
  • func (x *ApplySchemaRequest) GetSqlMode() string
  • func (m *ApplySchemaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ApplySchemaRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ApplySchemaRequest) MarshalVT() (dAtA []byte, err error)
  • func (*ApplySchemaRequest) ProtoMessage()
  • func (x *ApplySchemaRequest) ProtoReflect() protoreflect.Message
  • func (x *ApplySchemaRequest) Reset()
  • func (m *ApplySchemaRequest) SizeVT() (n int)
  • func (x *ApplySchemaRequest) String() string
  • func (m *ApplySchemaRequest) UnmarshalVT(dAtA []byte) error
• type ApplySchemaResponse
  • func (*ApplySchemaResponse) Descriptor() ([]byte, []int)
  • func (x *ApplySchemaResponse) GetAfterSchema() *SchemaDefinition
  • func (x *ApplySchemaResponse) GetBeforeSchema() *SchemaDefinition
  • func (m *ApplySchemaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ApplySchemaResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ApplySchemaResponse) MarshalVT() (dAtA []byte, err error)
  • func (*ApplySchemaResponse) ProtoMessage()
  • func (x *ApplySchemaResponse) ProtoReflect() protoreflect.Message
  • func (x *ApplySchemaResponse) Reset()
  • func (m *ApplySchemaResponse) SizeVT() (n int)
  • func (x *ApplySchemaResponse) String() string
  • func (m *ApplySchemaResponse) UnmarshalVT(dAtA []byte) error
• type BackupRequest
  • func (*BackupRequest) Descriptor() ([]byte, []int)
  • func (x *BackupRequest) GetAllowPrimary() bool
  • func (x *BackupRequest) GetConcurrency() int64
  • func (m *BackupRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *BackupRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *BackupRequest) MarshalVT() (dAtA []byte, err error)
  • func (*BackupRequest) ProtoMessage()
  • func (x *BackupRequest) ProtoReflect() protoreflect.Message
  • func (x *BackupRequest) Reset()
  • func (m *BackupRequest) SizeVT() (n int)
  • func (x *BackupRequest) String() string
  • func (m *BackupRequest) UnmarshalVT(dAtA []byte) error
• type BackupResponse
  • func (*BackupResponse) Descriptor() ([]byte, []int)
  • func (x *BackupResponse) GetEvent() *logutil.Event
  • func (m *BackupResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *BackupResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *BackupResponse) MarshalVT() (dAtA []byte, err error)
  • func (*BackupResponse) ProtoMessage()
  • func (x *BackupResponse) ProtoReflect() protoreflect.Message
  • func (x *BackupResponse) Reset()
  • func (m *BackupResponse) SizeVT() (n int)
  • func (x *BackupResponse) String() string
  • func (m *BackupResponse) UnmarshalVT(dAtA []byte) error
• type ChangeTypeRequest
  • func (*ChangeTypeRequest) Descriptor() ([]byte, []int)
  • func (x *ChangeTypeRequest) GetSemiSync() bool
  • func (x *ChangeTypeRequest) GetTabletType() topodata.TabletType
  • func (m *ChangeTypeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ChangeTypeRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ChangeTypeRequest) MarshalVT() (dAtA []byte, err error)
  • func (*ChangeTypeRequest) ProtoMessage()
  • func (x *ChangeTypeRequest) ProtoReflect() protoreflect.Message
  • func (x *ChangeTypeRequest) Reset()
  • func (m *ChangeTypeRequest) SizeVT() (n int)
  • func (x *ChangeTypeRequest) String() string
  • func (m *ChangeTypeRequest) UnmarshalVT(dAtA []byte) error
• type ChangeTypeResponse
  • func (*ChangeTypeResponse) Descriptor() ([]byte, []int)
  • func (m *ChangeTypeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ChangeTypeResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ChangeTypeResponse) MarshalVT() (dAtA []byte, err error)
  • func (*ChangeTypeResponse) ProtoMessage()
  • func (x *ChangeTypeResponse) ProtoReflect() protoreflect.Message
  • func (x *ChangeTypeResponse) Reset()
  • func (m *ChangeTypeResponse) SizeVT() (n int)
  • func (x *ChangeTypeResponse) String() string
  • func (m *ChangeTypeResponse) UnmarshalVT(dAtA []byte) error
• type DbPermission
  • func (*DbPermission) Descriptor() ([]byte, []int)
  • func (x *DbPermission) GetDb() string
  • func (x *DbPermission) GetHost() string
  • func (x *DbPermission) GetPrivileges() map[string]string
  • func (x *DbPermission) GetUser() string
  • func (m *DbPermission) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *DbPermission) MarshalToVT(dAtA []byte) (int, error)
  • func (m *DbPermission) MarshalVT() (dAtA []byte, err error)
  • func (*DbPermission) ProtoMessage()
  • func (x *DbPermission) ProtoReflect() protoreflect.Message
  • func (x *DbPermission) Reset()
  • func (m *DbPermission) SizeVT() (n int)
  • func (x *DbPermission) String() string
  • func (m *DbPermission) UnmarshalVT(dAtA []byte) error
• type DemotePrimaryRequest
  • func (*DemotePrimaryRequest) Descriptor() ([]byte, []int)
  • func (m *DemotePrimaryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *DemotePrimaryRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *DemotePrimaryRequest) MarshalVT() (dAtA []byte, err error)
  • func (*DemotePrimaryRequest) ProtoMessage()
  • func (x *DemotePrimaryRequest) ProtoReflect() protoreflect.Message
  • func (x *DemotePrimaryRequest) Reset()
  • func (m *DemotePrimaryRequest) SizeVT() (n int)
  • func (x *DemotePrimaryRequest) String() string
  • func (m *DemotePrimaryRequest) UnmarshalVT(dAtA []byte) error
• type DemotePrimaryResponse
  • func (*DemotePrimaryResponse) Descriptor() ([]byte, []int)
  • func (x *DemotePrimaryResponse) GetPrimaryStatus() *replicationdata.PrimaryStatus
  • func (m *DemotePrimaryResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *DemotePrimaryResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *DemotePrimaryResponse) MarshalVT() (dAtA []byte, err error)
  • func (*DemotePrimaryResponse) ProtoMessage()
  • func (x *DemotePrimaryResponse) ProtoReflect() protoreflect.Message
  • func (x *DemotePrimaryResponse) Reset()
  • func (m *DemotePrimaryResponse) SizeVT() (n int)
  • func (x *DemotePrimaryResponse) String() string
  • func (m *DemotePrimaryResponse) UnmarshalVT(dAtA []byte) error
• type ExecuteFetchAsAllPrivsRequest
  • func (*ExecuteFetchAsAllPrivsRequest) Descriptor() ([]byte, []int)
  • func (x *ExecuteFetchAsAllPrivsRequest) GetDbName() string
  • func (x *ExecuteFetchAsAllPrivsRequest) GetMaxRows() uint64
  • func (x *ExecuteFetchAsAllPrivsRequest) GetQuery() []byte
  • func (x *ExecuteFetchAsAllPrivsRequest) GetReloadSchema() bool
  • func (m *ExecuteFetchAsAllPrivsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ExecuteFetchAsAllPrivsRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ExecuteFetchAsAllPrivsRequest) MarshalVT() (dAtA []byte, err error)
  • func (*ExecuteFetchAsAllPrivsRequest) ProtoMessage()
  • func (x *ExecuteFetchAsAllPrivsRequest) ProtoReflect() protoreflect.Message
  • func (x *ExecuteFetchAsAllPrivsRequest) Reset()
  • func (m *ExecuteFetchAsAllPrivsRequest) SizeVT() (n int)
  • func (x *ExecuteFetchAsAllPrivsRequest) String() string
  • func (m *ExecuteFetchAsAllPrivsRequest) UnmarshalVT(dAtA []byte) error
• type ExecuteFetchAsAllPrivsResponse
  • func (*ExecuteFetchAsAllPrivsResponse) Descriptor() ([]byte, []int)
  • func (x *ExecuteFetchAsAllPrivsResponse) GetResult() *query.QueryResult
  • func (m *ExecuteFetchAsAllPrivsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ExecuteFetchAsAllPrivsResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ExecuteFetchAsAllPrivsResponse) MarshalVT() (dAtA []byte, err error)
  • func (*ExecuteFetchAsAllPrivsResponse) ProtoMessage()
  • func (x *ExecuteFetchAsAllPrivsResponse) ProtoReflect() protoreflect.Message
  • func (x *ExecuteFetchAsAllPrivsResponse) Reset()
  • func (m *ExecuteFetchAsAllPrivsResponse) SizeVT() (n int)
  • func (x *ExecuteFetchAsAllPrivsResponse) String() string
  • func (m *ExecuteFetchAsAllPrivsResponse) UnmarshalVT(dAtA []byte) error
• type ExecuteFetchAsAppRequest
  • func (*ExecuteFetchAsAppRequest) Descriptor() ([]byte, []int)
  • func (x *ExecuteFetchAsAppRequest) GetMaxRows() uint64
  • func (x *ExecuteFetchAsAppRequest) GetQuery() []byte
  • func (m *ExecuteFetchAsAppRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ExecuteFetchAsAppRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ExecuteFetchAsAppRequest) MarshalVT() (dAtA []byte, err error)
  • func (*ExecuteFetchAsAppRequest) ProtoMessage()
  • func (x *ExecuteFetchAsAppRequest) ProtoReflect() protoreflect.Message
  • func (x *ExecuteFetchAsAppRequest) Reset()
  • func (m *ExecuteFetchAsAppRequest) SizeVT() (n int)
  • func (x *ExecuteFetchAsAppRequest) String() string
  • func (m *ExecuteFetchAsAppRequest) UnmarshalVT(dAtA []byte) error
• type ExecuteFetchAsAppResponse
  • func (*ExecuteFetchAsAppResponse) Descriptor() ([]byte, []int)
  • func (x *ExecuteFetchAsAppResponse) GetResult() *query.QueryResult
  • func (m *ExecuteFetchAsAppResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ExecuteFetchAsAppResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ExecuteFetchAsAppResponse) MarshalVT() (dAtA []byte, err error)
  • func (*ExecuteFetchAsAppResponse) ProtoMessage()
  • func (x *ExecuteFetchAsAppResponse) ProtoReflect() protoreflect.Message
  • func (x *ExecuteFetchAsAppResponse) Reset()
  • func (m *ExecuteFetchAsAppResponse) SizeVT() (n int)
  • func (x *ExecuteFetchAsAppResponse) String() string
  • func (m *ExecuteFetchAsAppResponse) UnmarshalVT(dAtA []byte) error
• type ExecuteFetchAsDbaRequest
  • func (*ExecuteFetchAsDbaRequest) Descriptor() ([]byte, []int)
  • func (x *ExecuteFetchAsDbaRequest) GetDbName() string
  • func (x *ExecuteFetchAsDbaRequest) GetDisableBinlogs() bool
  • func (x *ExecuteFetchAsDbaRequest) GetMaxRows() uint64
  • func (x *ExecuteFetchAsDbaRequest) GetQuery() []byte
  • func (x *ExecuteFetchAsDbaRequest) GetReloadSchema() bool
  • func (m *ExecuteFetchAsDbaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ExecuteFetchAsDbaRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ExecuteFetchAsDbaRequest) MarshalVT() (dAtA []byte, err error)
  • func (*ExecuteFetchAsDbaRequest) ProtoMessage()
  • func (x *ExecuteFetchAsDbaRequest) ProtoReflect() protoreflect.Message
  • func (x *ExecuteFetchAsDbaRequest) Reset()
  • func (m *ExecuteFetchAsDbaRequest) SizeVT() (n int)
  • func (x *ExecuteFetchAsDbaRequest) String() string
  • func (m *ExecuteFetchAsDbaRequest) UnmarshalVT(dAtA []byte) error
• type ExecuteFetchAsDbaResponse
  • func (*ExecuteFetchAsDbaResponse) Descriptor() ([]byte, []int)
  • func (x *ExecuteFetchAsDbaResponse) GetResult() *query.QueryResult
  • func (m *ExecuteFetchAsDbaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ExecuteFetchAsDbaResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ExecuteFetchAsDbaResponse) MarshalVT() (dAtA []byte, err error)
  • func (*ExecuteFetchAsDbaResponse) ProtoMessage()
  • func (x *ExecuteFetchAsDbaResponse) ProtoReflect() protoreflect.Message
  • func (x *ExecuteFetchAsDbaResponse) Reset()
  • func (m *ExecuteFetchAsDbaResponse) SizeVT() (n int)
  • func (x *ExecuteFetchAsDbaResponse) String() string
  • func (m *ExecuteFetchAsDbaResponse) UnmarshalVT(dAtA []byte) error
• type ExecuteHookRequest
  • func (*ExecuteHookRequest) Descriptor() ([]byte, []int)
  • func (x *ExecuteHookRequest) GetExtraEnv() map[string]string
  • func (x *ExecuteHookRequest) GetName() string
  • func (x *ExecuteHookRequest) GetParameters() []string
  • func (m *ExecuteHookRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ExecuteHookRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ExecuteHookRequest) MarshalVT() (dAtA []byte, err error)
  • func (*ExecuteHookRequest) ProtoMessage()
  • func (x *ExecuteHookRequest) ProtoReflect() protoreflect.Message
  • func (x *ExecuteHookRequest) Reset()
  • func (m *ExecuteHookRequest) SizeVT() (n int)
  • func (x *ExecuteHookRequest) String() string
  • func (m *ExecuteHookRequest) UnmarshalVT(dAtA []byte) error
• type ExecuteHookResponse
  • func (*ExecuteHookResponse) Descriptor() ([]byte, []int)
  • func (x *ExecuteHookResponse) GetExitStatus() int64
  • func (x *ExecuteHookResponse) GetStderr() string
  • func (x *ExecuteHookResponse) GetStdout() string
  • func (m *ExecuteHookResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ExecuteHookResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ExecuteHookResponse) MarshalVT() (dAtA []byte, err error)
  • func (*ExecuteHookResponse) ProtoMessage()
  • func (x *ExecuteHookResponse) ProtoReflect() protoreflect.Message
  • func (x *ExecuteHookResponse) Reset()
  • func (m *ExecuteHookResponse) SizeVT() (n int)
  • func (x *ExecuteHookResponse) String() string
  • func (m *ExecuteHookResponse) UnmarshalVT(dAtA []byte) error
• type ExecuteQueryRequest
  • func (*ExecuteQueryRequest) Descriptor() ([]byte, []int)
  • func (x *ExecuteQueryRequest) GetCallerId() *vtrpc.CallerID
  • func (x *ExecuteQueryRequest) GetDbName() string
  • func (x *ExecuteQueryRequest) GetMaxRows() uint64
  • func (x *ExecuteQueryRequest) GetQuery() []byte
  • func (m *ExecuteQueryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ExecuteQueryRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ExecuteQueryRequest) MarshalVT() (dAtA []byte, err error)
  • func (*ExecuteQueryRequest) ProtoMessage()
  • func (x *ExecuteQueryRequest) ProtoReflect() protoreflect.Message
  • func (x *ExecuteQueryRequest) Reset()
  • func (m *ExecuteQueryRequest) SizeVT() (n int)
  • func (x *ExecuteQueryRequest) String() string
  • func (m *ExecuteQueryRequest) UnmarshalVT(dAtA []byte) error
• type ExecuteQueryResponse
  • func (*ExecuteQueryResponse) Descriptor() ([]byte, []int)
  • func (x *ExecuteQueryResponse) GetResult() *query.QueryResult
  • func (m *ExecuteQueryResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ExecuteQueryResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ExecuteQueryResponse) MarshalVT() (dAtA []byte, err error)
  • func (*ExecuteQueryResponse) ProtoMessage()
  • func (x *ExecuteQueryResponse) ProtoReflect() protoreflect.Message
  • func (x *ExecuteQueryResponse) Reset()
  • func (m *ExecuteQueryResponse) SizeVT() (n int)
  • func (x *ExecuteQueryResponse) String() string
  • func (m *ExecuteQueryResponse) UnmarshalVT(dAtA []byte) error
• type FullStatusRequest
  • func (*FullStatusRequest) Descriptor() ([]byte, []int)
  • func (m *FullStatusRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *FullStatusRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *FullStatusRequest) MarshalVT() (dAtA []byte, err error)
  • func (*FullStatusRequest) ProtoMessage()
  • func (x *FullStatusRequest) ProtoReflect() protoreflect.Message
  • func (x *FullStatusRequest) Reset()
  • func (m *FullStatusRequest) SizeVT() (n int)
  • func (x *FullStatusRequest) String() string
  • func (m *FullStatusRequest) UnmarshalVT(dAtA []byte) error
• type FullStatusResponse
  • func (*FullStatusResponse) Descriptor() ([]byte, []int)
  • func (x *FullStatusResponse) GetStatus() *replicationdata.FullStatus
  • func (m *FullStatusResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *FullStatusResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *FullStatusResponse) MarshalVT() (dAtA []byte, err error)
  • func (*FullStatusResponse) ProtoMessage()
  • func (x *FullStatusResponse) ProtoReflect() protoreflect.Message
  • func (x *FullStatusResponse) Reset()
  • func (m *FullStatusResponse) SizeVT() (n int)
  • func (x *FullStatusResponse) String() string
  • func (m *FullStatusResponse) UnmarshalVT(dAtA []byte) error
• type GetPermissionsRequest
  • func (*GetPermissionsRequest) Descriptor() ([]byte, []int)
  • func (m *GetPermissionsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *GetPermissionsRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *GetPermissionsRequest) MarshalVT() (dAtA []byte, err error)
  • func (*GetPermissionsRequest) ProtoMessage()
  • func (x *GetPermissionsRequest) ProtoReflect() protoreflect.Message
  • func (x *GetPermissionsRequest) Reset()
  • func (m *GetPermissionsRequest) SizeVT() (n int)
  • func (x *GetPermissionsRequest) String() string
  • func (m *GetPermissionsRequest) UnmarshalVT(dAtA []byte) error
• type GetPermissionsResponse
  • func (*GetPermissionsResponse) Descriptor() ([]byte, []int)
  • func (x *GetPermissionsResponse) GetPermissions() *Permissions
  • func (m *GetPermissionsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *GetPermissionsResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *GetPermissionsResponse) MarshalVT() (dAtA []byte, err error)
  • func (*GetPermissionsResponse) ProtoMessage()
  • func (x *GetPermissionsResponse) ProtoReflect() protoreflect.Message
  • func (x *GetPermissionsResponse) Reset()
  • func (m *GetPermissionsResponse) SizeVT() (n int)
  • func (x *GetPermissionsResponse) String() string
  • func (m *GetPermissionsResponse) UnmarshalVT(dAtA []byte) error
• type GetReplicasRequest
  • func (*GetReplicasRequest) Descriptor() ([]byte, []int)
  • func (m *GetReplicasRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *GetReplicasRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *GetReplicasRequest) MarshalVT() (dAtA []byte, err error)
  • func (*GetReplicasRequest) ProtoMessage()
  • func (x *GetReplicasRequest) ProtoReflect() protoreflect.Message
  • func (x *GetReplicasRequest) Reset()
  • func (m *GetReplicasRequest) SizeVT() (n int)
  • func (x *GetReplicasRequest) String() string
  • func (m *GetReplicasRequest) UnmarshalVT(dAtA []byte) error
• type GetReplicasResponse
  • func (*GetReplicasResponse) Descriptor() ([]byte, []int)
  • func (x *GetReplicasResponse) GetAddrs() []string
  • func (m *GetReplicasResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *GetReplicasResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *GetReplicasResponse) MarshalVT() (dAtA []byte, err error)
  • func (*GetReplicasResponse) ProtoMessage()
  • func (x *GetReplicasResponse) ProtoReflect() protoreflect.Message
  • func (x *GetReplicasResponse) Reset()
  • func (m *GetReplicasResponse) SizeVT() (n int)
  • func (x *GetReplicasResponse) String() string
  • func (m *GetReplicasResponse) UnmarshalVT(dAtA []byte) error
• type GetSchemaRequest
  • func (*GetSchemaRequest) Descriptor() ([]byte, []int)
  • func (x *GetSchemaRequest) GetExcludeTables() []string
  • func (x *GetSchemaRequest) GetIncludeViews() bool
  • func (x *GetSchemaRequest) GetTableSchemaOnly() bool
  • func (x *GetSchemaRequest) GetTables() []string
  • func (m *GetSchemaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *GetSchemaRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *GetSchemaRequest) MarshalVT() (dAtA []byte, err error)
  • func (*GetSchemaRequest) ProtoMessage()
  • func (x *GetSchemaRequest) ProtoReflect() protoreflect.Message
  • func (x *GetSchemaRequest) Reset()
  • func (m *GetSchemaRequest) SizeVT() (n int)
  • func (x *GetSchemaRequest) String() string
  • func (m *GetSchemaRequest) UnmarshalVT(dAtA []byte) error
• type GetSchemaResponse
  • func (*GetSchemaResponse) Descriptor() ([]byte, []int)
  • func (x *GetSchemaResponse) GetSchemaDefinition() *SchemaDefinition
  • func (m *GetSchemaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *GetSchemaResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *GetSchemaResponse) MarshalVT() (dAtA []byte, err error)
  • func (*GetSchemaResponse) ProtoMessage()
  • func (x *GetSchemaResponse) ProtoReflect() protoreflect.Message
  • func (x *GetSchemaResponse) Reset()
  • func (m *GetSchemaResponse) SizeVT() (n int)
  • func (x *GetSchemaResponse) String() string
  • func (m *GetSchemaResponse) UnmarshalVT(dAtA []byte) error
• type InitPrimaryRequest
  • func (*InitPrimaryRequest) Descriptor() ([]byte, []int)
  • func (x *InitPrimaryRequest) GetSemiSync() bool
  • func (m *InitPrimaryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *InitPrimaryRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *InitPrimaryRequest) MarshalVT() (dAtA []byte, err error)
  • func (*InitPrimaryRequest) ProtoMessage()
  • func (x *InitPrimaryRequest) ProtoReflect() protoreflect.Message
  • func (x *InitPrimaryRequest) Reset()
  • func (m *InitPrimaryRequest) SizeVT() (n int)
  • func (x *InitPrimaryRequest) String() string
  • func (m *InitPrimaryRequest) UnmarshalVT(dAtA []byte) error
• type InitPrimaryResponse
  • func (*InitPrimaryResponse) Descriptor() ([]byte, []int)
  • func (x *InitPrimaryResponse) GetPosition() string
  • func (m *InitPrimaryResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *InitPrimaryResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *InitPrimaryResponse) MarshalVT() (dAtA []byte, err error)
  • func (*InitPrimaryResponse) ProtoMessage()
  • func (x *InitPrimaryResponse) ProtoReflect() protoreflect.Message
  • func (x *InitPrimaryResponse) Reset()
  • func (m *InitPrimaryResponse) SizeVT() (n int)
  • func (x *InitPrimaryResponse) String() string
  • func (m *InitPrimaryResponse) UnmarshalVT(dAtA []byte) error
• type InitReplicaRequest
  • func (*InitReplicaRequest) Descriptor() ([]byte, []int)
  • func (x *InitReplicaRequest) GetParent() *topodata.TabletAlias
  • func (x *InitReplicaRequest) GetReplicationPosition() string
  • func (x *InitReplicaRequest) GetSemiSync() bool
  • func (x *InitReplicaRequest) GetTimeCreatedNs() int64
  • func (m *InitReplicaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *InitReplicaRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *InitReplicaRequest) MarshalVT() (dAtA []byte, err error)
  • func (*InitReplicaRequest) ProtoMessage()
  • func (x *InitReplicaRequest) ProtoReflect() protoreflect.Message
  • func (x *InitReplicaRequest) Reset()
  • func (m *InitReplicaRequest) SizeVT() (n int)
  • func (x *InitReplicaRequest) String() string
  • func (m *InitReplicaRequest) UnmarshalVT(dAtA []byte) error
• type InitReplicaResponse
  • func (*InitReplicaResponse) Descriptor() ([]byte, []int)
  • func (m *InitReplicaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *InitReplicaResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *InitReplicaResponse) MarshalVT() (dAtA []byte, err error)
  • func (*InitReplicaResponse) ProtoMessage()
  • func (x *InitReplicaResponse) ProtoReflect() protoreflect.Message
  • func (x *InitReplicaResponse) Reset()
  • func (m *InitReplicaResponse) SizeVT() (n int)
  • func (x *InitReplicaResponse) String() string
  • func (m *InitReplicaResponse) UnmarshalVT(dAtA []byte) error
• type LockTablesRequest
  • func (*LockTablesRequest) Descriptor() ([]byte, []int)
  • func (m *LockTablesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *LockTablesRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *LockTablesRequest) MarshalVT() (dAtA []byte, err error)
  • func (*LockTablesRequest) ProtoMessage()
  • func (x *LockTablesRequest) ProtoReflect() protoreflect.Message
  • func (x *LockTablesRequest) Reset()
  • func (m *LockTablesRequest) SizeVT() (n int)
  • func (x *LockTablesRequest) String() string
  • func (m *LockTablesRequest) UnmarshalVT(dAtA []byte) error
• type LockTablesResponse
  • func (*LockTablesResponse) Descriptor() ([]byte, []int)
  • func (m *LockTablesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *LockTablesResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *LockTablesResponse) MarshalVT() (dAtA []byte, err error)
  • func (*LockTablesResponse) ProtoMessage()
  • func (x *LockTablesResponse) ProtoReflect() protoreflect.Message
  • func (x *LockTablesResponse) Reset()
  • func (m *LockTablesResponse) SizeVT() (n int)
  • func (x *LockTablesResponse) String() string
  • func (m *LockTablesResponse) UnmarshalVT(dAtA []byte) error
• type Permissions
  • func (*Permissions) Descriptor() ([]byte, []int)
  • func (x *Permissions) GetDbPermissions() []*DbPermission
  • func (x *Permissions) GetUserPermissions() []*UserPermission
  • func (m *Permissions) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *Permissions) MarshalToVT(dAtA []byte) (int, error)
  • func (m *Permissions) MarshalVT() (dAtA []byte, err error)
  • func (*Permissions) ProtoMessage()
  • func (x *Permissions) ProtoReflect() protoreflect.Message
  • func (x *Permissions) Reset()
  • func (m *Permissions) SizeVT() (n int)
  • func (x *Permissions) String() string
  • func (m *Permissions) UnmarshalVT(dAtA []byte) error
• type PingRequest
  • func (*PingRequest) Descriptor() ([]byte, []int)
  • func (x *PingRequest) GetPayload() string
  • func (m *PingRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *PingRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *PingRequest) MarshalVT() (dAtA []byte, err error)
  • func (*PingRequest) ProtoMessage()
  • func (x *PingRequest) ProtoReflect() protoreflect.Message
  • func (x *PingRequest) Reset()
  • func (m *PingRequest) SizeVT() (n int)
  • func (x *PingRequest) String() string
  • func (m *PingRequest) UnmarshalVT(dAtA []byte) error
• type PingResponse
  • func (*PingResponse) Descriptor() ([]byte, []int)
  • func (x *PingResponse) GetPayload() string
  • func (m *PingResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *PingResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *PingResponse) MarshalVT() (dAtA []byte, err error)
  • func (*PingResponse) ProtoMessage()
  • func (x *PingResponse) ProtoReflect() protoreflect.Message
  • func (x *PingResponse) Reset()
  • func (m *PingResponse) SizeVT() (n int)
  • func (x *PingResponse) String() string
  • func (m *PingResponse) UnmarshalVT(dAtA []byte) error
• type PopulateReparentJournalRequest
  • func (*PopulateReparentJournalRequest) Descriptor() ([]byte, []int)
  • func (x *PopulateReparentJournalRequest) GetActionName() string
  • func (x *PopulateReparentJournalRequest) GetPrimaryAlias() *topodata.TabletAlias
  • func (x *PopulateReparentJournalRequest) GetReplicationPosition() string
  • func (x *PopulateReparentJournalRequest) GetTimeCreatedNs() int64
  • func (m *PopulateReparentJournalRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *PopulateReparentJournalRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *PopulateReparentJournalRequest) MarshalVT() (dAtA []byte, err error)
  • func (*PopulateReparentJournalRequest) ProtoMessage()
  • func (x *PopulateReparentJournalRequest) ProtoReflect() protoreflect.Message
  • func (x *PopulateReparentJournalRequest) Reset()
  • func (m *PopulateReparentJournalRequest) SizeVT() (n int)
  • func (x *PopulateReparentJournalRequest) String() string
  • func (m *PopulateReparentJournalRequest) UnmarshalVT(dAtA []byte) error
• type PopulateReparentJournalResponse
  • func (*PopulateReparentJournalResponse) Descriptor() ([]byte, []int)
  • func (m *PopulateReparentJournalResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *PopulateReparentJournalResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *PopulateReparentJournalResponse) MarshalVT() (dAtA []byte, err error)
  • func (*PopulateReparentJournalResponse) ProtoMessage()
  • func (x *PopulateReparentJournalResponse) ProtoReflect() protoreflect.Message
  • func (x *PopulateReparentJournalResponse) Reset()
  • func (m *PopulateReparentJournalResponse) SizeVT() (n int)
  • func (x *PopulateReparentJournalResponse) String() string
  • func (m *PopulateReparentJournalResponse) UnmarshalVT(dAtA []byte) error
• type PreflightSchemaRequest
  • func (*PreflightSchemaRequest) Descriptor() ([]byte, []int)
  • func (x *PreflightSchemaRequest) GetChanges() []string
  • func (m *PreflightSchemaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *PreflightSchemaRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *PreflightSchemaRequest) MarshalVT() (dAtA []byte, err error)
  • func (*PreflightSchemaRequest) ProtoMessage()
  • func (x *PreflightSchemaRequest) ProtoReflect() protoreflect.Message
  • func (x *PreflightSchemaRequest) Reset()
  • func (m *PreflightSchemaRequest) SizeVT() (n int)
  • func (x *PreflightSchemaRequest) String() string
  • func (m *PreflightSchemaRequest) UnmarshalVT(dAtA []byte) error
• type PreflightSchemaResponse
  • func (*PreflightSchemaResponse) Descriptor() ([]byte, []int)
  • func (x *PreflightSchemaResponse) GetChangeResults() []*SchemaChangeResult
  • func (m *PreflightSchemaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *PreflightSchemaResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *PreflightSchemaResponse) MarshalVT() (dAtA []byte, err error)
  • func (*PreflightSchemaResponse) ProtoMessage()
  • func (x *PreflightSchemaResponse) ProtoReflect() protoreflect.Message
  • func (x *PreflightSchemaResponse) Reset()
  • func (m *PreflightSchemaResponse) SizeVT() (n int)
  • func (x *PreflightSchemaResponse) String() string
  • func (m *PreflightSchemaResponse) UnmarshalVT(dAtA []byte) error
• type PrimaryPositionRequest
  • func (*PrimaryPositionRequest) Descriptor() ([]byte, []int)
  • func (m *PrimaryPositionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *PrimaryPositionRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *PrimaryPositionRequest) MarshalVT() (dAtA []byte, err error)
  • func (*PrimaryPositionRequest) ProtoMessage()
  • func (x *PrimaryPositionRequest) ProtoReflect() protoreflect.Message
  • func (x *PrimaryPositionRequest) Reset()
  • func (m *PrimaryPositionRequest) SizeVT() (n int)
  • func (x *PrimaryPositionRequest) String() string
  • func (m *PrimaryPositionRequest) UnmarshalVT(dAtA []byte) error
• type PrimaryPositionResponse
  • func (*PrimaryPositionResponse) Descriptor() ([]byte, []int)
  • func (x *PrimaryPositionResponse) GetPosition() string
  • func (m *PrimaryPositionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *PrimaryPositionResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *PrimaryPositionResponse) MarshalVT() (dAtA []byte, err error)
  • func (*PrimaryPositionResponse) ProtoMessage()
  • func (x *PrimaryPositionResponse) ProtoReflect() protoreflect.Message
  • func (x *PrimaryPositionResponse) Reset()
  • func (m *PrimaryPositionResponse) SizeVT() (n int)
  • func (x *PrimaryPositionResponse) String() string
  • func (m *PrimaryPositionResponse) UnmarshalVT(dAtA []byte) error
• type PrimaryStatusRequest
  • func (*PrimaryStatusRequest) Descriptor() ([]byte, []int)
  • func (m *PrimaryStatusRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *PrimaryStatusRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *PrimaryStatusRequest) MarshalVT() (dAtA []byte, err error)
  • func (*PrimaryStatusRequest) ProtoMessage()
  • func (x *PrimaryStatusRequest) ProtoReflect() protoreflect.Message
  • func (x *PrimaryStatusRequest) Reset()
  • func (m *PrimaryStatusRequest) SizeVT() (n int)
  • func (x *PrimaryStatusRequest) String() string
  • func (m *PrimaryStatusRequest) UnmarshalVT(dAtA []byte) error
• type PrimaryStatusResponse
  • func (*PrimaryStatusResponse) Descriptor() ([]byte, []int)
  • func (x *PrimaryStatusResponse) GetStatus() *replicationdata.PrimaryStatus
  • func (m *PrimaryStatusResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *PrimaryStatusResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *PrimaryStatusResponse) MarshalVT() (dAtA []byte, err error)
  • func (*PrimaryStatusResponse) ProtoMessage()
  • func (x *PrimaryStatusResponse) ProtoReflect() protoreflect.Message
  • func (x *PrimaryStatusResponse) Reset()
  • func (m *PrimaryStatusResponse) SizeVT() (n int)
  • func (x *PrimaryStatusResponse) String() string
  • func (m *PrimaryStatusResponse) UnmarshalVT(dAtA []byte) error
• type PromoteReplicaRequest
  • func (*PromoteReplicaRequest) Descriptor() ([]byte, []int)
  • func (x *PromoteReplicaRequest) GetSemiSync() bool
  • func (m *PromoteReplicaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *PromoteReplicaRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *PromoteReplicaRequest) MarshalVT() (dAtA []byte, err error)
  • func (*PromoteReplicaRequest) ProtoMessage()
  • func (x *PromoteReplicaRequest) ProtoReflect() protoreflect.Message
  • func (x *PromoteReplicaRequest) Reset()
  • func (m *PromoteReplicaRequest) SizeVT() (n int)
  • func (x *PromoteReplicaRequest) String() string
  • func (m *PromoteReplicaRequest) UnmarshalVT(dAtA []byte) error
• type PromoteReplicaResponse
  • func (*PromoteReplicaResponse) Descriptor() ([]byte, []int)
  • func (x *PromoteReplicaResponse) GetPosition() string
  • func (m *PromoteReplicaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *PromoteReplicaResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *PromoteReplicaResponse) MarshalVT() (dAtA []byte, err error)
  • func (*PromoteReplicaResponse) ProtoMessage()
  • func (x *PromoteReplicaResponse) ProtoReflect() protoreflect.Message
  • func (x *PromoteReplicaResponse) Reset()
  • func (m *PromoteReplicaResponse) SizeVT() (n int)
  • func (x *PromoteReplicaResponse) String() string
  • func (m *PromoteReplicaResponse) UnmarshalVT(dAtA []byte) error
• type RefreshStateRequest
  • func (*RefreshStateRequest) Descriptor() ([]byte, []int)
  • func (m *RefreshStateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *RefreshStateRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *RefreshStateRequest) MarshalVT() (dAtA []byte, err error)
  • func (*RefreshStateRequest) ProtoMessage()
  • func (x *RefreshStateRequest) ProtoReflect() protoreflect.Message
  • func (x *RefreshStateRequest) Reset()
  • func (m *RefreshStateRequest) SizeVT() (n int)
  • func (x *RefreshStateRequest) String() string
  • func (m *RefreshStateRequest) UnmarshalVT(dAtA []byte) error
• type RefreshStateResponse
  • func (*RefreshStateResponse) Descriptor() ([]byte, []int)
  • func (m *RefreshStateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *RefreshStateResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *RefreshStateResponse) MarshalVT() (dAtA []byte, err error)
  • func (*RefreshStateResponse) ProtoMessage()
  • func (x *RefreshStateResponse) ProtoReflect() protoreflect.Message
  • func (x *RefreshStateResponse) Reset()
  • func (m *RefreshStateResponse) SizeVT() (n int)
  • func (x *RefreshStateResponse) String() string
  • func (m *RefreshStateResponse) UnmarshalVT(dAtA []byte) error
• type ReloadSchemaRequest
  • func (*ReloadSchemaRequest) Descriptor() ([]byte, []int)
  • func (x *ReloadSchemaRequest) GetWaitPosition() string
  • func (m *ReloadSchemaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ReloadSchemaRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ReloadSchemaRequest) MarshalVT() (dAtA []byte, err error)
  • func (*ReloadSchemaRequest) ProtoMessage()
  • func (x *ReloadSchemaRequest) ProtoReflect() protoreflect.Message
  • func (x *ReloadSchemaRequest) Reset()
  • func (m *ReloadSchemaRequest) SizeVT() (n int)
  • func (x *ReloadSchemaRequest) String() string
  • func (m *ReloadSchemaRequest) UnmarshalVT(dAtA []byte) error
• type ReloadSchemaResponse
  • func (*ReloadSchemaResponse) Descriptor() ([]byte, []int)
  • func (m *ReloadSchemaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ReloadSchemaResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ReloadSchemaResponse) MarshalVT() (dAtA []byte, err error)
  • func (*ReloadSchemaResponse) ProtoMessage()
  • func (x *ReloadSchemaResponse) ProtoReflect() protoreflect.Message
  • func (x *ReloadSchemaResponse) Reset()
  • func (m *ReloadSchemaResponse) SizeVT() (n int)
  • func (x *ReloadSchemaResponse) String() string
  • func (m *ReloadSchemaResponse) UnmarshalVT(dAtA []byte) error
• type ReplicaWasPromotedRequest
  • func (*ReplicaWasPromotedRequest) Descriptor() ([]byte, []int)
  • func (m *ReplicaWasPromotedRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ReplicaWasPromotedRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ReplicaWasPromotedRequest) MarshalVT() (dAtA []byte, err error)
  • func (*ReplicaWasPromotedRequest) ProtoMessage()
  • func (x *ReplicaWasPromotedRequest) ProtoReflect() protoreflect.Message
  • func (x *ReplicaWasPromotedRequest) Reset()
  • func (m *ReplicaWasPromotedRequest) SizeVT() (n int)
  • func (x *ReplicaWasPromotedRequest) String() string
  • func (m *ReplicaWasPromotedRequest) UnmarshalVT(dAtA []byte) error
• type ReplicaWasPromotedResponse
  • func (*ReplicaWasPromotedResponse) Descriptor() ([]byte, []int)
  • func (m *ReplicaWasPromotedResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ReplicaWasPromotedResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ReplicaWasPromotedResponse) MarshalVT() (dAtA []byte, err error)
  • func (*ReplicaWasPromotedResponse) ProtoMessage()
  • func (x *ReplicaWasPromotedResponse) ProtoReflect() protoreflect.Message
  • func (x *ReplicaWasPromotedResponse) Reset()
  • func (m *ReplicaWasPromotedResponse) SizeVT() (n int)
  • func (x *ReplicaWasPromotedResponse) String() string
  • func (m *ReplicaWasPromotedResponse) UnmarshalVT(dAtA []byte) error
• type ReplicaWasRestartedRequest
  • func (*ReplicaWasRestartedRequest) Descriptor() ([]byte, []int)
  • func (x *ReplicaWasRestartedRequest) GetParent() *topodata.TabletAlias
  • func (m *ReplicaWasRestartedRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ReplicaWasRestartedRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ReplicaWasRestartedRequest) MarshalVT() (dAtA []byte, err error)
  • func (*ReplicaWasRestartedRequest) ProtoMessage()
  • func (x *ReplicaWasRestartedRequest) ProtoReflect() protoreflect.Message
  • func (x *ReplicaWasRestartedRequest) Reset()
  • func (m *ReplicaWasRestartedRequest) SizeVT() (n int)
  • func (x *ReplicaWasRestartedRequest) String() string
  • func (m *ReplicaWasRestartedRequest) UnmarshalVT(dAtA []byte) error
• type ReplicaWasRestartedResponse
  • func (*ReplicaWasRestartedResponse) Descriptor() ([]byte, []int)
  • func (m *ReplicaWasRestartedResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ReplicaWasRestartedResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ReplicaWasRestartedResponse) MarshalVT() (dAtA []byte, err error)
  • func (*ReplicaWasRestartedResponse) ProtoMessage()
  • func (x *ReplicaWasRestartedResponse) ProtoReflect() protoreflect.Message
  • func (x *ReplicaWasRestartedResponse) Reset()
  • func (m *ReplicaWasRestartedResponse) SizeVT() (n int)
  • func (x *ReplicaWasRestartedResponse) String() string
  • func (m *ReplicaWasRestartedResponse) UnmarshalVT(dAtA []byte) error
• type ReplicationStatusRequest
  • func (*ReplicationStatusRequest) Descriptor() ([]byte, []int)
  • func (m *ReplicationStatusRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ReplicationStatusRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ReplicationStatusRequest) MarshalVT() (dAtA []byte, err error)
  • func (*ReplicationStatusRequest) ProtoMessage()
  • func (x *ReplicationStatusRequest) ProtoReflect() protoreflect.Message
  • func (x *ReplicationStatusRequest) Reset()
  • func (m *ReplicationStatusRequest) SizeVT() (n int)
  • func (x *ReplicationStatusRequest) String() string
  • func (m *ReplicationStatusRequest) UnmarshalVT(dAtA []byte) error
• type ReplicationStatusResponse
  • func (*ReplicationStatusResponse) Descriptor() ([]byte, []int)
  • func (x *ReplicationStatusResponse) GetStatus() *replicationdata.Status
  • func (m *ReplicationStatusResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ReplicationStatusResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ReplicationStatusResponse) MarshalVT() (dAtA []byte, err error)
  • func (*ReplicationStatusResponse) ProtoMessage()
  • func (x *ReplicationStatusResponse) ProtoReflect() protoreflect.Message
  • func (x *ReplicationStatusResponse) Reset()
  • func (m *ReplicationStatusResponse) SizeVT() (n int)
  • func (x *ReplicationStatusResponse) String() string
  • func (m *ReplicationStatusResponse) UnmarshalVT(dAtA []byte) error
• type ResetReplicationParametersRequest
  • func (*ResetReplicationParametersRequest) Descriptor() ([]byte, []int)
  • func (m *ResetReplicationParametersRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ResetReplicationParametersRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ResetReplicationParametersRequest) MarshalVT() (dAtA []byte, err error)
  • func (*ResetReplicationParametersRequest) ProtoMessage()
  • func (x *ResetReplicationParametersRequest) ProtoReflect() protoreflect.Message
  • func (x *ResetReplicationParametersRequest) Reset()
  • func (m *ResetReplicationParametersRequest) SizeVT() (n int)
  • func (x *ResetReplicationParametersRequest) String() string
  • func (m *ResetReplicationParametersRequest) UnmarshalVT(dAtA []byte) error
• type ResetReplicationParametersResponse
  • func (*ResetReplicationParametersResponse) Descriptor() ([]byte, []int)
  • func (m *ResetReplicationParametersResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ResetReplicationParametersResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ResetReplicationParametersResponse) MarshalVT() (dAtA []byte, err error)
  • func (*ResetReplicationParametersResponse) ProtoMessage()
  • func (x *ResetReplicationParametersResponse) ProtoReflect() protoreflect.Message
  • func (x *ResetReplicationParametersResponse) Reset()
  • func (m *ResetReplicationParametersResponse) SizeVT() (n int)
  • func (x *ResetReplicationParametersResponse) String() string
  • func (m *ResetReplicationParametersResponse) UnmarshalVT(dAtA []byte) error
• type ResetReplicationRequest
  • func (*ResetReplicationRequest) Descriptor() ([]byte, []int)
  • func (m *ResetReplicationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ResetReplicationRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ResetReplicationRequest) MarshalVT() (dAtA []byte, err error)
  • func (*ResetReplicationRequest) ProtoMessage()
  • func (x *ResetReplicationRequest) ProtoReflect() protoreflect.Message
  • func (x *ResetReplicationRequest) Reset()
  • func (m *ResetReplicationRequest) SizeVT() (n int)
  • func (x *ResetReplicationRequest) String() string
  • func (m *ResetReplicationRequest) UnmarshalVT(dAtA []byte) error
• type ResetReplicationResponse
  • func (*ResetReplicationResponse) Descriptor() ([]byte, []int)
  • func (m *ResetReplicationResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ResetReplicationResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ResetReplicationResponse) MarshalVT() (dAtA []byte, err error)
  • func (*ResetReplicationResponse) ProtoMessage()
  • func (x *ResetReplicationResponse) ProtoReflect() protoreflect.Message
  • func (x *ResetReplicationResponse) Reset()
  • func (m *ResetReplicationResponse) SizeVT() (n int)
  • func (x *ResetReplicationResponse) String() string
  • func (m *ResetReplicationResponse) UnmarshalVT(dAtA []byte) error
• type RestoreFromBackupRequest
  • func (*RestoreFromBackupRequest) Descriptor() ([]byte, []int)
  • func (x *RestoreFromBackupRequest) GetBackupTime() *vttime.Time
  • func (m *RestoreFromBackupRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *RestoreFromBackupRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *RestoreFromBackupRequest) MarshalVT() (dAtA []byte, err error)
  • func (*RestoreFromBackupRequest) ProtoMessage()
  • func (x *RestoreFromBackupRequest) ProtoReflect() protoreflect.Message
  • func (x *RestoreFromBackupRequest) Reset()
  • func (m *RestoreFromBackupRequest) SizeVT() (n int)
  • func (x *RestoreFromBackupRequest) String() string
  • func (m *RestoreFromBackupRequest) UnmarshalVT(dAtA []byte) error
• type RestoreFromBackupResponse
  • func (*RestoreFromBackupResponse) Descriptor() ([]byte, []int)
  • func (x *RestoreFromBackupResponse) GetEvent() *logutil.Event
  • func (m *RestoreFromBackupResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *RestoreFromBackupResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *RestoreFromBackupResponse) MarshalVT() (dAtA []byte, err error)
  • func (*RestoreFromBackupResponse) ProtoMessage()
  • func (x *RestoreFromBackupResponse) ProtoReflect() protoreflect.Message
  • func (x *RestoreFromBackupResponse) Reset()
  • func (m *RestoreFromBackupResponse) SizeVT() (n int)
  • func (x *RestoreFromBackupResponse) String() string
  • func (m *RestoreFromBackupResponse) UnmarshalVT(dAtA []byte) error
• type RunHealthCheckRequest
  • func (*RunHealthCheckRequest) Descriptor() ([]byte, []int)
  • func (m *RunHealthCheckRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *RunHealthCheckRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *RunHealthCheckRequest) MarshalVT() (dAtA []byte, err error)
  • func (*RunHealthCheckRequest) ProtoMessage()
  • func (x *RunHealthCheckRequest) ProtoReflect() protoreflect.Message
  • func (x *RunHealthCheckRequest) Reset()
  • func (m *RunHealthCheckRequest) SizeVT() (n int)
  • func (x *RunHealthCheckRequest) String() string
  • func (m *RunHealthCheckRequest) UnmarshalVT(dAtA []byte) error
• type RunHealthCheckResponse
  • func (*RunHealthCheckResponse) Descriptor() ([]byte, []int)
  • func (m *RunHealthCheckResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *RunHealthCheckResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *RunHealthCheckResponse) MarshalVT() (dAtA []byte, err error)
  • func (*RunHealthCheckResponse) ProtoMessage()
  • func (x *RunHealthCheckResponse) ProtoReflect() protoreflect.Message
  • func (x *RunHealthCheckResponse) Reset()
  • func (m *RunHealthCheckResponse) SizeVT() (n int)
  • func (x *RunHealthCheckResponse) String() string
  • func (m *RunHealthCheckResponse) UnmarshalVT(dAtA []byte) error
• type SchemaChangeResult
  • func (*SchemaChangeResult) Descriptor() ([]byte, []int)
  • func (x *SchemaChangeResult) GetAfterSchema() *SchemaDefinition
  • func (x *SchemaChangeResult) GetBeforeSchema() *SchemaDefinition
  • func (m *SchemaChangeResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *SchemaChangeResult) MarshalToVT(dAtA []byte) (int, error)
  • func (m *SchemaChangeResult) MarshalVT() (dAtA []byte, err error)
  • func (*SchemaChangeResult) ProtoMessage()
  • func (x *SchemaChangeResult) ProtoReflect() protoreflect.Message
  • func (x *SchemaChangeResult) Reset()
  • func (m *SchemaChangeResult) SizeVT() (n int)
  • func (x *SchemaChangeResult) String() string
  • func (m *SchemaChangeResult) UnmarshalVT(dAtA []byte) error
• type SchemaDefinition
  • func (*SchemaDefinition) Descriptor() ([]byte, []int)
  • func (x *SchemaDefinition) GetDatabaseSchema() string
  • func (x *SchemaDefinition) GetTableDefinitions() []*TableDefinition
  • func (x *SchemaDefinition) GetVersion() string
  • func (m *SchemaDefinition) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *SchemaDefinition) MarshalToVT(dAtA []byte) (int, error)
  • func (m *SchemaDefinition) MarshalVT() (dAtA []byte, err error)
  • func (*SchemaDefinition) ProtoMessage()
  • func (x *SchemaDefinition) ProtoReflect() protoreflect.Message
  • func (x *SchemaDefinition) Reset()
  • func (m *SchemaDefinition) SizeVT() (n int)
  • func (x *SchemaDefinition) String() string
  • func (m *SchemaDefinition) UnmarshalVT(dAtA []byte) error
• type SetReadOnlyRequest
  • func (*SetReadOnlyRequest) Descriptor() ([]byte, []int)
  • func (m *SetReadOnlyRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *SetReadOnlyRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *SetReadOnlyRequest) MarshalVT() (dAtA []byte, err error)
  • func (*SetReadOnlyRequest) ProtoMessage()
  • func (x *SetReadOnlyRequest) ProtoReflect() protoreflect.Message
  • func (x *SetReadOnlyRequest) Reset()
  • func (m *SetReadOnlyRequest) SizeVT() (n int)
  • func (x *SetReadOnlyRequest) String() string
  • func (m *SetReadOnlyRequest) UnmarshalVT(dAtA []byte) error
• type SetReadOnlyResponse
  • func (*SetReadOnlyResponse) Descriptor() ([]byte, []int)
  • func (m *SetReadOnlyResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *SetReadOnlyResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *SetReadOnlyResponse) MarshalVT() (dAtA []byte, err error)
  • func (*SetReadOnlyResponse) ProtoMessage()
  • func (x *SetReadOnlyResponse) ProtoReflect() protoreflect.Message
  • func (x *SetReadOnlyResponse) Reset()
  • func (m *SetReadOnlyResponse) SizeVT() (n int)
  • func (x *SetReadOnlyResponse) String() string
  • func (m *SetReadOnlyResponse) UnmarshalVT(dAtA []byte) error
• type SetReadWriteRequest
  • func (*SetReadWriteRequest) Descriptor() ([]byte, []int)
  • func (m *SetReadWriteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *SetReadWriteRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *SetReadWriteRequest) MarshalVT() (dAtA []byte, err error)
  • func (*SetReadWriteRequest) ProtoMessage()
  • func (x *SetReadWriteRequest) ProtoReflect() protoreflect.Message
  • func (x *SetReadWriteRequest) Reset()
  • func (m *SetReadWriteRequest) SizeVT() (n int)
  • func (x *SetReadWriteRequest) String() string
  • func (m *SetReadWriteRequest) UnmarshalVT(dAtA []byte) error
• type SetReadWriteResponse
  • func (*SetReadWriteResponse) Descriptor() ([]byte, []int)
  • func (m *SetReadWriteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *SetReadWriteResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *SetReadWriteResponse) MarshalVT() (dAtA []byte, err error)
  • func (*SetReadWriteResponse) ProtoMessage()
  • func (x *SetReadWriteResponse) ProtoReflect() protoreflect.Message
  • func (x *SetReadWriteResponse) Reset()
  • func (m *SetReadWriteResponse) SizeVT() (n int)
  • func (x *SetReadWriteResponse) String() string
  • func (m *SetReadWriteResponse) UnmarshalVT(dAtA []byte) error
• type SetReplicationSourceRequest
  • func (*SetReplicationSourceRequest) Descriptor() ([]byte, []int)
  • func (x *SetReplicationSourceRequest) GetForceStartReplication() bool
  • func (x *SetReplicationSourceRequest) GetParent() *topodata.TabletAlias
  • func (x *SetReplicationSourceRequest) GetSemiSync() bool
  • func (x *SetReplicationSourceRequest) GetTimeCreatedNs() int64
  • func (x *SetReplicationSourceRequest) GetWaitPosition() string
  • func (m *SetReplicationSourceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *SetReplicationSourceRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *SetReplicationSourceRequest) MarshalVT() (dAtA []byte, err error)
  • func (*SetReplicationSourceRequest) ProtoMessage()
  • func (x *SetReplicationSourceRequest) ProtoReflect() protoreflect.Message
  • func (x *SetReplicationSourceRequest) Reset()
  • func (m *SetReplicationSourceRequest) SizeVT() (n int)
  • func (x *SetReplicationSourceRequest) String() string
  • func (m *SetReplicationSourceRequest) UnmarshalVT(dAtA []byte) error
• type SetReplicationSourceResponse
  • func (*SetReplicationSourceResponse) Descriptor() ([]byte, []int)
  • func (m *SetReplicationSourceResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *SetReplicationSourceResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *SetReplicationSourceResponse) MarshalVT() (dAtA []byte, err error)
  • func (*SetReplicationSourceResponse) ProtoMessage()
  • func (x *SetReplicationSourceResponse) ProtoReflect() protoreflect.Message
  • func (x *SetReplicationSourceResponse) Reset()
  • func (m *SetReplicationSourceResponse) SizeVT() (n int)
  • func (x *SetReplicationSourceResponse) String() string
  • func (m *SetReplicationSourceResponse) UnmarshalVT(dAtA []byte) error
• type SleepRequest
  • func (*SleepRequest) Descriptor() ([]byte, []int)
  • func (x *SleepRequest) GetDuration() int64
  • func (m *SleepRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *SleepRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *SleepRequest) MarshalVT() (dAtA []byte, err error)
  • func (*SleepRequest) ProtoMessage()
  • func (x *SleepRequest) ProtoReflect() protoreflect.Message
  • func (x *SleepRequest) Reset()
  • func (m *SleepRequest) SizeVT() (n int)
  • func (x *SleepRequest) String() string
  • func (m *SleepRequest) UnmarshalVT(dAtA []byte) error
• type SleepResponse
  • func (*SleepResponse) Descriptor() ([]byte, []int)
  • func (m *SleepResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *SleepResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *SleepResponse) MarshalVT() (dAtA []byte, err error)
  • func (*SleepResponse) ProtoMessage()
  • func (x *SleepResponse) ProtoReflect() protoreflect.Message
  • func (x *SleepResponse) Reset()
  • func (m *SleepResponse) SizeVT() (n int)
  • func (x *SleepResponse) String() string
  • func (m *SleepResponse) UnmarshalVT(dAtA []byte) error
• type StartReplicationRequest
  • func (*StartReplicationRequest) Descriptor() ([]byte, []int)
  • func (x *StartReplicationRequest) GetSemiSync() bool
  • func (m *StartReplicationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *StartReplicationRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *StartReplicationRequest) MarshalVT() (dAtA []byte, err error)
  • func (*StartReplicationRequest) ProtoMessage()
  • func (x *StartReplicationRequest) ProtoReflect() protoreflect.Message
  • func (x *StartReplicationRequest) Reset()
  • func (m *StartReplicationRequest) SizeVT() (n int)
  • func (x *StartReplicationRequest) String() string
  • func (m *StartReplicationRequest) UnmarshalVT(dAtA []byte) error
• type StartReplicationResponse
  • func (*StartReplicationResponse) Descriptor() ([]byte, []int)
  • func (m *StartReplicationResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *StartReplicationResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *StartReplicationResponse) MarshalVT() (dAtA []byte, err error)
  • func (*StartReplicationResponse) ProtoMessage()
  • func (x *StartReplicationResponse) ProtoReflect() protoreflect.Message
  • func (x *StartReplicationResponse) Reset()
  • func (m *StartReplicationResponse) SizeVT() (n int)
  • func (x *StartReplicationResponse) String() string
  • func (m *StartReplicationResponse) UnmarshalVT(dAtA []byte) error
• type StartReplicationUntilAfterRequest
  • func (*StartReplicationUntilAfterRequest) Descriptor() ([]byte, []int)
  • func (x *StartReplicationUntilAfterRequest) GetPosition() string
  • func (x *StartReplicationUntilAfterRequest) GetWaitTimeout() int64
  • func (m *StartReplicationUntilAfterRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *StartReplicationUntilAfterRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *StartReplicationUntilAfterRequest) MarshalVT() (dAtA []byte, err error)
  • func (*StartReplicationUntilAfterRequest) ProtoMessage()
  • func (x *StartReplicationUntilAfterRequest) ProtoReflect() protoreflect.Message
  • func (x *StartReplicationUntilAfterRequest) Reset()
  • func (m *StartReplicationUntilAfterRequest) SizeVT() (n int)
  • func (x *StartReplicationUntilAfterRequest) String() string
  • func (m *StartReplicationUntilAfterRequest) UnmarshalVT(dAtA []byte) error
• type StartReplicationUntilAfterResponse
  • func (*StartReplicationUntilAfterResponse) Descriptor() ([]byte, []int)
  • func (m *StartReplicationUntilAfterResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *StartReplicationUntilAfterResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *StartReplicationUntilAfterResponse) MarshalVT() (dAtA []byte, err error)
  • func (*StartReplicationUntilAfterResponse) ProtoMessage()
  • func (x *StartReplicationUntilAfterResponse) ProtoReflect() protoreflect.Message
  • func (x *StartReplicationUntilAfterResponse) Reset()
  • func (m *StartReplicationUntilAfterResponse) SizeVT() (n int)
  • func (x *StartReplicationUntilAfterResponse) String() string
  • func (m *StartReplicationUntilAfterResponse) UnmarshalVT(dAtA []byte) error
• type StopReplicationAndGetStatusRequest
  • func (*StopReplicationAndGetStatusRequest) Descriptor() ([]byte, []int)
  • func (x *StopReplicationAndGetStatusRequest) GetStopReplicationMode() replicationdata.StopReplicationMode
  • func (m *StopReplicationAndGetStatusRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *StopReplicationAndGetStatusRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *StopReplicationAndGetStatusRequest) MarshalVT() (dAtA []byte, err error)
  • func (*StopReplicationAndGetStatusRequest) ProtoMessage()
  • func (x *StopReplicationAndGetStatusRequest) ProtoReflect() protoreflect.Message
  • func (x *StopReplicationAndGetStatusRequest) Reset()
  • func (m *StopReplicationAndGetStatusRequest) SizeVT() (n int)
  • func (x *StopReplicationAndGetStatusRequest) String() string
  • func (m *StopReplicationAndGetStatusRequest) UnmarshalVT(dAtA []byte) error
• type StopReplicationAndGetStatusResponse
  • func (*StopReplicationAndGetStatusResponse) Descriptor() ([]byte, []int)
  • func (x *StopReplicationAndGetStatusResponse) GetStatus() *replicationdata.StopReplicationStatus
  • func (m *StopReplicationAndGetStatusResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *StopReplicationAndGetStatusResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *StopReplicationAndGetStatusResponse) MarshalVT() (dAtA []byte, err error)
  • func (*StopReplicationAndGetStatusResponse) ProtoMessage()
  • func (x *StopReplicationAndGetStatusResponse) ProtoReflect() protoreflect.Message
  • func (x *StopReplicationAndGetStatusResponse) Reset()
  • func (m *StopReplicationAndGetStatusResponse) SizeVT() (n int)
  • func (x *StopReplicationAndGetStatusResponse) String() string
  • func (m *StopReplicationAndGetStatusResponse) UnmarshalVT(dAtA []byte) error
• type StopReplicationMinimumRequest
  • func (*StopReplicationMinimumRequest) Descriptor() ([]byte, []int)
  • func (x *StopReplicationMinimumRequest) GetPosition() string
  • func (x *StopReplicationMinimumRequest) GetWaitTimeout() int64
  • func (m *StopReplicationMinimumRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *StopReplicationMinimumRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *StopReplicationMinimumRequest) MarshalVT() (dAtA []byte, err error)
  • func (*StopReplicationMinimumRequest) ProtoMessage()
  • func (x *StopReplicationMinimumRequest) ProtoReflect() protoreflect.Message
  • func (x *StopReplicationMinimumRequest) Reset()
  • func (m *StopReplicationMinimumRequest) SizeVT() (n int)
  • func (x *StopReplicationMinimumRequest) String() string
  • func (m *StopReplicationMinimumRequest) UnmarshalVT(dAtA []byte) error
• type StopReplicationMinimumResponse
  • func (*StopReplicationMinimumResponse) Descriptor() ([]byte, []int)
  • func (x *StopReplicationMinimumResponse) GetPosition() string
  • func (m *StopReplicationMinimumResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *StopReplicationMinimumResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *StopReplicationMinimumResponse) MarshalVT() (dAtA []byte, err error)
  • func (*StopReplicationMinimumResponse) ProtoMessage()
  • func (x *StopReplicationMinimumResponse) ProtoReflect() protoreflect.Message
  • func (x *StopReplicationMinimumResponse) Reset()
  • func (m *StopReplicationMinimumResponse) SizeVT() (n int)
  • func (x *StopReplicationMinimumResponse) String() string
  • func (m *StopReplicationMinimumResponse) UnmarshalVT(dAtA []byte) error
• type StopReplicationRequest
  • func (*StopReplicationRequest) Descriptor() ([]byte, []int)
  • func (m *StopReplicationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *StopReplicationRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *StopReplicationRequest) MarshalVT() (dAtA []byte, err error)
  • func (*StopReplicationRequest) ProtoMessage()
  • func (x *StopReplicationRequest) ProtoReflect() protoreflect.Message
  • func (x *StopReplicationRequest) Reset()
  • func (m *StopReplicationRequest) SizeVT() (n int)
  • func (x *StopReplicationRequest) String() string
  • func (m *StopReplicationRequest) UnmarshalVT(dAtA []byte) error
• type StopReplicationResponse
  • func (*StopReplicationResponse) Descriptor() ([]byte, []int)
  • func (m *StopReplicationResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *StopReplicationResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *StopReplicationResponse) MarshalVT() (dAtA []byte, err error)
  • func (*StopReplicationResponse) ProtoMessage()
  • func (x *StopReplicationResponse) ProtoReflect() protoreflect.Message
  • func (x *StopReplicationResponse) Reset()
  • func (m *StopReplicationResponse) SizeVT() (n int)
  • func (x *StopReplicationResponse) String() string
  • func (m *StopReplicationResponse) UnmarshalVT(dAtA []byte) error
• type TableDefinition
  • func (*TableDefinition) Descriptor() ([]byte, []int)
  • func (x *TableDefinition) GetColumns() []string
  • func (x *TableDefinition) GetDataLength() uint64
  • func (x *TableDefinition) GetFields() []*query.Field
  • func (x *TableDefinition) GetName() string
  • func (x *TableDefinition) GetPrimaryKeyColumns() []string
  • func (x *TableDefinition) GetRowCount() uint64
  • func (x *TableDefinition) GetSchema() string
  • func (x *TableDefinition) GetType() string
  • func (m *TableDefinition) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *TableDefinition) MarshalToVT(dAtA []byte) (int, error)
  • func (m *TableDefinition) MarshalVT() (dAtA []byte, err error)
  • func (*TableDefinition) ProtoMessage()
  • func (x *TableDefinition) ProtoReflect() protoreflect.Message
  • func (x *TableDefinition) Reset()
  • func (m *TableDefinition) SizeVT() (n int)
  • func (x *TableDefinition) String() string
  • func (m *TableDefinition) UnmarshalVT(dAtA []byte) error
• type UndoDemotePrimaryRequest
  • func (*UndoDemotePrimaryRequest) Descriptor() ([]byte, []int)
  • func (x *UndoDemotePrimaryRequest) GetSemiSync() bool
  • func (m *UndoDemotePrimaryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *UndoDemotePrimaryRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *UndoDemotePrimaryRequest) MarshalVT() (dAtA []byte, err error)
  • func (*UndoDemotePrimaryRequest) ProtoMessage()
  • func (x *UndoDemotePrimaryRequest) ProtoReflect() protoreflect.Message
  • func (x *UndoDemotePrimaryRequest) Reset()
  • func (m *UndoDemotePrimaryRequest) SizeVT() (n int)
  • func (x *UndoDemotePrimaryRequest) String() string
  • func (m *UndoDemotePrimaryRequest) UnmarshalVT(dAtA []byte) error
• type UndoDemotePrimaryResponse
  • func (*UndoDemotePrimaryResponse) Descriptor() ([]byte, []int)
  • func (m *UndoDemotePrimaryResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *UndoDemotePrimaryResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *UndoDemotePrimaryResponse) MarshalVT() (dAtA []byte, err error)
  • func (*UndoDemotePrimaryResponse) ProtoMessage()
  • func (x *UndoDemotePrimaryResponse) ProtoReflect() protoreflect.Message
  • func (x *UndoDemotePrimaryResponse) Reset()
  • func (m *UndoDemotePrimaryResponse) SizeVT() (n int)
  • func (x *UndoDemotePrimaryResponse) String() string
  • func (m *UndoDemotePrimaryResponse) UnmarshalVT(dAtA []byte) error
• type UnlockTablesRequest
  • func (*UnlockTablesRequest) Descriptor() ([]byte, []int)
  • func (m *UnlockTablesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *UnlockTablesRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *UnlockTablesRequest) MarshalVT() (dAtA []byte, err error)
  • func (*UnlockTablesRequest) ProtoMessage()
  • func (x *UnlockTablesRequest) ProtoReflect() protoreflect.Message
  • func (x *UnlockTablesRequest) Reset()
  • func (m *UnlockTablesRequest) SizeVT() (n int)
  • func (x *UnlockTablesRequest) String() string
  • func (m *UnlockTablesRequest) UnmarshalVT(dAtA []byte) error
• type UnlockTablesResponse
  • func (*UnlockTablesResponse) Descriptor() ([]byte, []int)
  • func (m *UnlockTablesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *UnlockTablesResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *UnlockTablesResponse) MarshalVT() (dAtA []byte, err error)
  • func (*UnlockTablesResponse) ProtoMessage()
  • func (x *UnlockTablesResponse) ProtoReflect() protoreflect.Message
  • func (x *UnlockTablesResponse) Reset()
  • func (m *UnlockTablesResponse) SizeVT() (n int)
  • func (x *UnlockTablesResponse) String() string
  • func (m *UnlockTablesResponse) UnmarshalVT(dAtA []byte) error
• type UserPermission
  • func (*UserPermission) Descriptor() ([]byte, []int)
  • func (x *UserPermission) GetHost() string
  • func (x *UserPermission) GetPasswordChecksum() uint64
  • func (x *UserPermission) GetPrivileges() map[string]string
  • func (x *UserPermission) GetUser() string
  • func (m *UserPermission) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *UserPermission) MarshalToVT(dAtA []byte) (int, error)
  • func (m *UserPermission) MarshalVT() (dAtA []byte, err error)
  • func (*UserPermission) ProtoMessage()
  • func (x *UserPermission) ProtoReflect() protoreflect.Message
  • func (x *UserPermission) Reset()
  • func (m *UserPermission) SizeVT() (n int)
  • func (x *UserPermission) String() string
  • func (m *UserPermission) UnmarshalVT(dAtA []byte) error
• type VDiffCoreOptions
  • func (*VDiffCoreOptions) Descriptor() ([]byte, []int)
  • func (x *VDiffCoreOptions) GetAutoRetry() bool
  • func (x *VDiffCoreOptions) GetChecksum() bool
  • func (x *VDiffCoreOptions) GetMaxExtraRowsToCompare() int64
  • func (x *VDiffCoreOptions) GetMaxRows() int64
  • func (x *VDiffCoreOptions) GetSamplePct() int64
  • func (x *VDiffCoreOptions) GetTables() string
  • func (x *VDiffCoreOptions) GetTimeoutSeconds() int64
  • func (m *VDiffCoreOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *VDiffCoreOptions) MarshalToVT(dAtA []byte) (int, error)
  • func (m *VDiffCoreOptions) MarshalVT() (dAtA []byte, err error)
  • func (*VDiffCoreOptions) ProtoMessage()
  • func (x *VDiffCoreOptions) ProtoReflect() protoreflect.Message
  • func (x *VDiffCoreOptions) Reset()
  • func (m *VDiffCoreOptions) SizeVT() (n int)
  • func (x *VDiffCoreOptions) String() string
  • func (m *VDiffCoreOptions) UnmarshalVT(dAtA []byte) error
• type VDiffOptions
  • func (*VDiffOptions) Descriptor() ([]byte, []int)
  • func (x *VDiffOptions) GetCoreOptions() *VDiffCoreOptions
  • func (x *VDiffOptions) GetPickerOptions() *VDiffPickerOptions
  • func (x *VDiffOptions) GetReportOptions() *VDiffReportOptions
  • func (m *VDiffOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *VDiffOptions) MarshalToVT(dAtA []byte) (int, error)
  • func (m *VDiffOptions) MarshalVT() (dAtA []byte, err error)
  • func (*VDiffOptions) ProtoMessage()
  • func (x *VDiffOptions) ProtoReflect() protoreflect.Message
  • func (x *VDiffOptions) Reset()
  • func (m *VDiffOptions) SizeVT() (n int)
  • func (x *VDiffOptions) String() string
  • func (m *VDiffOptions) UnmarshalVT(dAtA []byte) error
• type VDiffPickerOptions
  • func (*VDiffPickerOptions) Descriptor() ([]byte, []int)
  • func (x *VDiffPickerOptions) GetSourceCell() string
  • func (x *VDiffPickerOptions) GetTabletTypes() string
  • func (x *VDiffPickerOptions) GetTargetCell() string
  • func (m *VDiffPickerOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *VDiffPickerOptions) MarshalToVT(dAtA []byte) (int, error)
  • func (m *VDiffPickerOptions) MarshalVT() (dAtA []byte, err error)
  • func (*VDiffPickerOptions) ProtoMessage()
  • func (x *VDiffPickerOptions) ProtoReflect() protoreflect.Message
  • func (x *VDiffPickerOptions) Reset()
  • func (m *VDiffPickerOptions) SizeVT() (n int)
  • func (x *VDiffPickerOptions) String() string
  • func (m *VDiffPickerOptions) UnmarshalVT(dAtA []byte) error
• type VDiffReportOptions
  • func (*VDiffReportOptions) Descriptor() ([]byte, []int)
  • func (x *VDiffReportOptions) GetDebugQuery() bool
  • func (x *VDiffReportOptions) GetFormat() string
  • func (x *VDiffReportOptions) GetOnlyPKS() bool
  • func (m *VDiffReportOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *VDiffReportOptions) MarshalToVT(dAtA []byte) (int, error)
  • func (m *VDiffReportOptions) MarshalVT() (dAtA []byte, err error)
  • func (*VDiffReportOptions) ProtoMessage()
  • func (x *VDiffReportOptions) ProtoReflect() protoreflect.Message
  • func (x *VDiffReportOptions) Reset()
  • func (m *VDiffReportOptions) SizeVT() (n int)
  • func (x *VDiffReportOptions) String() string
  • func (m *VDiffReportOptions) UnmarshalVT(dAtA []byte) error
• type VDiffRequest
  • func (*VDiffRequest) Descriptor() ([]byte, []int)
  • func (x *VDiffRequest) GetAction() string
  • func (x *VDiffRequest) GetActionArg() string
  • func (x *VDiffRequest) GetKeyspace() string
  • func (x *VDiffRequest) GetOptions() *VDiffOptions
  • func (x *VDiffRequest) GetVdiffUuid() string
  • func (x *VDiffRequest) GetWorkflow() string
  • func (m *VDiffRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *VDiffRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *VDiffRequest) MarshalVT() (dAtA []byte, err error)
  • func (*VDiffRequest) ProtoMessage()
  • func (x *VDiffRequest) ProtoReflect() protoreflect.Message
  • func (x *VDiffRequest) Reset()
  • func (m *VDiffRequest) SizeVT() (n int)
  • func (x *VDiffRequest) String() string
  • func (m *VDiffRequest) UnmarshalVT(dAtA []byte) error
• type VDiffResponse
  • func (*VDiffResponse) Descriptor() ([]byte, []int)
  • func (x *VDiffResponse) GetId() int64
  • func (x *VDiffResponse) GetOutput() *query.QueryResult
  • func (x *VDiffResponse) GetVdiffUuid() string
  • func (m *VDiffResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *VDiffResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *VDiffResponse) MarshalVT() (dAtA []byte, err error)
  • func (*VDiffResponse) ProtoMessage()
  • func (x *VDiffResponse) ProtoReflect() protoreflect.Message
  • func (x *VDiffResponse) Reset()
  • func (m *VDiffResponse) SizeVT() (n int)
  • func (x *VDiffResponse) String() string
  • func (m *VDiffResponse) UnmarshalVT(dAtA []byte) error
• type VExecRequest
  • func (*VExecRequest) Descriptor() ([]byte, []int)
  • func (x *VExecRequest) GetKeyspace() string
  • func (x *VExecRequest) GetQuery() string
  • func (x *VExecRequest) GetWorkflow() string
  • func (m *VExecRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *VExecRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *VExecRequest) MarshalVT() (dAtA []byte, err error)
  • func (*VExecRequest) ProtoMessage()
  • func (x *VExecRequest) ProtoReflect() protoreflect.Message
  • func (x *VExecRequest) Reset()
  • func (m *VExecRequest) SizeVT() (n int)
  • func (x *VExecRequest) String() string
  • func (m *VExecRequest) UnmarshalVT(dAtA []byte) error
• type VExecResponse
  • func (*VExecResponse) Descriptor() ([]byte, []int)
  • func (x *VExecResponse) GetResult() *query.QueryResult
  • func (m *VExecResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *VExecResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *VExecResponse) MarshalVT() (dAtA []byte, err error)
  • func (*VExecResponse) ProtoMessage()
  • func (x *VExecResponse) ProtoReflect() protoreflect.Message
  • func (x *VExecResponse) Reset()
  • func (m *VExecResponse) SizeVT() (n int)
  • func (x *VExecResponse) String() string
  • func (m *VExecResponse) UnmarshalVT(dAtA []byte) error
• type VReplicationExecRequest
  • func (*VReplicationExecRequest) Descriptor() ([]byte, []int)
  • func (x *VReplicationExecRequest) GetQuery() string
  • func (m *VReplicationExecRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *VReplicationExecRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *VReplicationExecRequest) MarshalVT() (dAtA []byte, err error)
  • func (*VReplicationExecRequest) ProtoMessage()
  • func (x *VReplicationExecRequest) ProtoReflect() protoreflect.Message
  • func (x *VReplicationExecRequest) Reset()
  • func (m *VReplicationExecRequest) SizeVT() (n int)
  • func (x *VReplicationExecRequest) String() string
  • func (m *VReplicationExecRequest) UnmarshalVT(dAtA []byte) error
• type VReplicationExecResponse
  • func (*VReplicationExecResponse) Descriptor() ([]byte, []int)
  • func (x *VReplicationExecResponse) GetResult() *query.QueryResult
  • func (m *VReplicationExecResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *VReplicationExecResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *VReplicationExecResponse) MarshalVT() (dAtA []byte, err error)
  • func (*VReplicationExecResponse) ProtoMessage()
  • func (x *VReplicationExecResponse) ProtoReflect() protoreflect.Message
  • func (x *VReplicationExecResponse) Reset()
  • func (m *VReplicationExecResponse) SizeVT() (n int)
  • func (x *VReplicationExecResponse) String() string
  • func (m *VReplicationExecResponse) UnmarshalVT(dAtA []byte) error
• type VReplicationWaitForPosRequest
  • func (*VReplicationWaitForPosRequest) Descriptor() ([]byte, []int)
  • func (x *VReplicationWaitForPosRequest) GetId() int64
  • func (x *VReplicationWaitForPosRequest) GetPosition() string
  • func (m *VReplicationWaitForPosRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *VReplicationWaitForPosRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *VReplicationWaitForPosRequest) MarshalVT() (dAtA []byte, err error)
  • func (*VReplicationWaitForPosRequest) ProtoMessage()
  • func (x *VReplicationWaitForPosRequest) ProtoReflect() protoreflect.Message
  • func (x *VReplicationWaitForPosRequest) Reset()
  • func (m *VReplicationWaitForPosRequest) SizeVT() (n int)
  • func (x *VReplicationWaitForPosRequest) String() string
  • func (m *VReplicationWaitForPosRequest) UnmarshalVT(dAtA []byte) error
• type VReplicationWaitForPosResponse
  • func (*VReplicationWaitForPosResponse) Descriptor() ([]byte, []int)
  • func (m *VReplicationWaitForPosResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *VReplicationWaitForPosResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *VReplicationWaitForPosResponse) MarshalVT() (dAtA []byte, err error)
  • func (*VReplicationWaitForPosResponse) ProtoMessage()
  • func (x *VReplicationWaitForPosResponse) ProtoReflect() protoreflect.Message
  • func (x *VReplicationWaitForPosResponse) Reset()
  • func (m *VReplicationWaitForPosResponse) SizeVT() (n int)
  • func (x *VReplicationWaitForPosResponse) String() string
  • func (m *VReplicationWaitForPosResponse) UnmarshalVT(dAtA []byte) error
• type WaitForPositionRequest
  • func (*WaitForPositionRequest) Descriptor() ([]byte, []int)
  • func (x *WaitForPositionRequest) GetPosition() string
  • func (m *WaitForPositionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *WaitForPositionRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *WaitForPositionRequest) MarshalVT() (dAtA []byte, err error)
  • func (*WaitForPositionRequest) ProtoMessage()
  • func (x *WaitForPositionRequest) ProtoReflect() protoreflect.Message
  • func (x *WaitForPositionRequest) Reset()
  • func (m *WaitForPositionRequest) SizeVT() (n int)
  • func (x *WaitForPositionRequest) String() string
  • func (m *WaitForPositionRequest) UnmarshalVT(dAtA []byte) error
• type WaitForPositionResponse
  • func (*WaitForPositionResponse) Descriptor() ([]byte, []int)
  • func (m *WaitForPositionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *WaitForPositionResponse) MarshalToVT(dAtA []byte) (int, error)
  • func (m *WaitForPositionResponse) MarshalVT() (dAtA []byte, err error)
  • func (*WaitForPositionResponse) ProtoMessage()
  • func (x *WaitForPositionResponse) ProtoReflect() protoreflect.Message
  • func (x *WaitForPositionResponse) Reset()
  • func (m *WaitForPositionResponse) SizeVT() (n int)
  • func (x *WaitForPositionResponse) String() string
  • func (m *WaitForPositionResponse) UnmarshalVT(dAtA []byte) error

Variables

var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)

var File_tabletmanagerdata_proto protoreflect.FileDescriptor

Types

type ApplySchemaRequest

type ApplySchemaRequest struct {
	Sql              string            `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	Force            bool              `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	AllowReplication bool              `protobuf:"varint,3,opt,name=allow_replication,json=allowReplication,proto3" json:"allow_replication,omitempty"`
	BeforeSchema     *SchemaDefinition `protobuf:"bytes,4,opt,name=before_schema,json=beforeSchema,proto3" json:"before_schema,omitempty"`
	AfterSchema      *SchemaDefinition `protobuf:"bytes,5,opt,name=after_schema,json=afterSchema,proto3" json:"after_schema,omitempty"`
	SqlMode          string            `protobuf:"bytes,6,opt,name=sql_mode,json=sqlMode,proto3" json:"sql_mode,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplySchemaRequest) Descriptor

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

Deprecated: Use ApplySchemaRequest.ProtoReflect.Descriptor instead.

func (*ApplySchemaRequest) GetAfterSchema

func (x *ApplySchemaRequest) GetAfterSchema() *SchemaDefinition

func (*ApplySchemaRequest) GetAllowReplication

func (x *ApplySchemaRequest) GetAllowReplication() bool

func (*ApplySchemaRequest) GetBeforeSchema

func (x *ApplySchemaRequest) GetBeforeSchema() *SchemaDefinition

func (*ApplySchemaRequest) GetForce

func (x *ApplySchemaRequest) GetForce() bool

func (*ApplySchemaRequest) GetSql

func (x *ApplySchemaRequest) GetSql() string

func (*ApplySchemaRequest) GetSqlMode

func (x *ApplySchemaRequest) GetSqlMode() string

func (*ApplySchemaRequest) MarshalToSizedBufferVT

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

func (*ApplySchemaRequest) MarshalToVT

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

func (*ApplySchemaRequest) MarshalVT

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

func (*ApplySchemaRequest) ProtoMessage

func (*ApplySchemaRequest) ProtoMessage()

func (*ApplySchemaRequest) ProtoReflect

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

func (*ApplySchemaRequest) Reset

func (x *ApplySchemaRequest) Reset()

func (*ApplySchemaRequest) SizeVT

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

func (*ApplySchemaRequest) String

func (x *ApplySchemaRequest) String() string

func (*ApplySchemaRequest) UnmarshalVT

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

type ApplySchemaResponse

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

func (*ApplySchemaResponse) Descriptor

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

Deprecated: Use ApplySchemaResponse.ProtoReflect.Descriptor instead.

func (*ApplySchemaResponse) GetAfterSchema

func (x *ApplySchemaResponse) GetAfterSchema() *SchemaDefinition

func (*ApplySchemaResponse) GetBeforeSchema

func (x *ApplySchemaResponse) GetBeforeSchema() *SchemaDefinition

func (*ApplySchemaResponse) MarshalToSizedBufferVT

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

func (*ApplySchemaResponse) MarshalToVT

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

func (*ApplySchemaResponse) MarshalVT

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

func (*ApplySchemaResponse) ProtoMessage

func (*ApplySchemaResponse) ProtoMessage()

func (*ApplySchemaResponse) ProtoReflect

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

func (*ApplySchemaResponse) Reset

func (x *ApplySchemaResponse) Reset()

func (*ApplySchemaResponse) SizeVT

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

func (*ApplySchemaResponse) String

func (x *ApplySchemaResponse) String() string

func (*ApplySchemaResponse) UnmarshalVT

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

type BackupRequest

type BackupRequest struct {
	Concurrency  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

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

Deprecated: Use BackupRequest.ProtoReflect.Descriptor instead.

func (*BackupRequest) GetAllowPrimary

func (x *BackupRequest) GetAllowPrimary() bool

func (*BackupRequest) GetConcurrency

func (x *BackupRequest) GetConcurrency() int64

func (*BackupRequest) MarshalToSizedBufferVT

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

func (*BackupRequest) MarshalToVT

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

func (*BackupRequest) MarshalVT

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

func (*BackupRequest) ProtoMessage

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) ProtoReflect

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

func (*BackupRequest) Reset

func (x *BackupRequest) Reset()

func (*BackupRequest) SizeVT

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

func (*BackupRequest) String

func (x *BackupRequest) String() string

func (*BackupRequest) UnmarshalVT

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

type BackupResponse

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

func (*BackupResponse) Descriptor

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

Deprecated: Use BackupResponse.ProtoReflect.Descriptor instead.

func (*BackupResponse) GetEvent

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

func (*BackupResponse) MarshalToSizedBufferVT

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

func (*BackupResponse) MarshalToVT

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

func (*BackupResponse) MarshalVT

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

func (*BackupResponse) ProtoMessage

func (*BackupResponse) ProtoMessage()

func (*BackupResponse) ProtoReflect

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

func (*BackupResponse) Reset

func (x *BackupResponse) Reset()

func (*BackupResponse) SizeVT

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

func (*BackupResponse) String

func (x *BackupResponse) String() string

func (*BackupResponse) UnmarshalVT

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

type ChangeTypeRequest

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

func (*ChangeTypeRequest) Descriptor

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

Deprecated: Use ChangeTypeRequest.ProtoReflect.Descriptor instead.

func (*ChangeTypeRequest) GetSemiSync

func (x *ChangeTypeRequest) GetSemiSync() bool

func (*ChangeTypeRequest) GetTabletType

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

func (*ChangeTypeRequest) MarshalToSizedBufferVT

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

func (*ChangeTypeRequest) MarshalToVT

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

func (*ChangeTypeRequest) MarshalVT

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

func (*ChangeTypeRequest) ProtoMessage

func (*ChangeTypeRequest) ProtoMessage()

func (*ChangeTypeRequest) ProtoReflect

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

func (*ChangeTypeRequest) Reset

func (x *ChangeTypeRequest) Reset()

func (*ChangeTypeRequest) SizeVT

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

func (*ChangeTypeRequest) String

func (x *ChangeTypeRequest) String() string

func (*ChangeTypeRequest) UnmarshalVT

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

type ChangeTypeResponse

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

func (*ChangeTypeResponse) Descriptor

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

Deprecated: Use ChangeTypeResponse.ProtoReflect.Descriptor instead.

func (*ChangeTypeResponse) MarshalToSizedBufferVT

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

func (*ChangeTypeResponse) MarshalToVT

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

func (*ChangeTypeResponse) MarshalVT

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

func (*ChangeTypeResponse) ProtoMessage

func (*ChangeTypeResponse) ProtoMessage()

func (*ChangeTypeResponse) ProtoReflect

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

func (*ChangeTypeResponse) Reset

func (x *ChangeTypeResponse) Reset()

func (*ChangeTypeResponse) SizeVT

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

func (*ChangeTypeResponse) String

func (x *ChangeTypeResponse) String() string

func (*ChangeTypeResponse) UnmarshalVT

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

type 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

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

Deprecated: Use DbPermission.ProtoReflect.Descriptor instead.

func (*DbPermission) GetDb

func (x *DbPermission) GetDb() string

func (*DbPermission) GetHost

func (x *DbPermission) GetHost() string

func (*DbPermission) GetPrivileges

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

func (*DbPermission) GetUser

func (x *DbPermission) GetUser() string

func (*DbPermission) MarshalToSizedBufferVT

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

func (*DbPermission) MarshalToVT

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

func (*DbPermission) MarshalVT

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

func (*DbPermission) ProtoMessage

func (*DbPermission) ProtoMessage()

func (*DbPermission) ProtoReflect

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

func (*DbPermission) Reset

func (x *DbPermission) Reset()

func (*DbPermission) SizeVT

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

func (*DbPermission) String

func (x *DbPermission) String() string

func (*DbPermission) UnmarshalVT

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

type DemotePrimaryRequest

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

func (*DemotePrimaryRequest) Descriptor

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

Deprecated: Use DemotePrimaryRequest.ProtoReflect.Descriptor instead.

func (*DemotePrimaryRequest) MarshalToSizedBufferVT

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

func (*DemotePrimaryRequest) MarshalToVT

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

func (*DemotePrimaryRequest) MarshalVT

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

func (*DemotePrimaryRequest) ProtoMessage

func (*DemotePrimaryRequest) ProtoMessage()

func (*DemotePrimaryRequest) ProtoReflect

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

func (*DemotePrimaryRequest) Reset

func (x *DemotePrimaryRequest) Reset()

func (*DemotePrimaryRequest) SizeVT

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

func (*DemotePrimaryRequest) String

func (x *DemotePrimaryRequest) String() string

func (*DemotePrimaryRequest) UnmarshalVT

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

type DemotePrimaryResponse

type DemotePrimaryResponse struct {

	// PrimaryStatus represents the response from calling `SHOW 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

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

Deprecated: Use DemotePrimaryResponse.ProtoReflect.Descriptor instead.

func (*DemotePrimaryResponse) GetPrimaryStatus

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

func (*DemotePrimaryResponse) MarshalToSizedBufferVT

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

func (*DemotePrimaryResponse) MarshalToVT

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

func (*DemotePrimaryResponse) MarshalVT

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

func (*DemotePrimaryResponse) ProtoMessage

func (*DemotePrimaryResponse) ProtoMessage()

func (*DemotePrimaryResponse) ProtoReflect

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

func (*DemotePrimaryResponse) Reset

func (x *DemotePrimaryResponse) Reset()

func (*DemotePrimaryResponse) SizeVT

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

func (*DemotePrimaryResponse) String

func (x *DemotePrimaryResponse) String() string

func (*DemotePrimaryResponse) UnmarshalVT

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

type ExecuteFetchAsAllPrivsRequest

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

func (*ExecuteFetchAsAllPrivsRequest) Descriptor

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

Deprecated: Use ExecuteFetchAsAllPrivsRequest.ProtoReflect.Descriptor instead.

func (*ExecuteFetchAsAllPrivsRequest) GetDbName

func (x *ExecuteFetchAsAllPrivsRequest) GetDbName() string

func (*ExecuteFetchAsAllPrivsRequest) GetMaxRows

func (x *ExecuteFetchAsAllPrivsRequest) GetMaxRows() uint64

func (*ExecuteFetchAsAllPrivsRequest) GetQuery

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

func (*ExecuteFetchAsAllPrivsRequest) GetReloadSchema

func (x *ExecuteFetchAsAllPrivsRequest) GetReloadSchema() bool

func (*ExecuteFetchAsAllPrivsRequest) MarshalToSizedBufferVT

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

func (*ExecuteFetchAsAllPrivsRequest) MarshalToVT

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

func (*ExecuteFetchAsAllPrivsRequest) MarshalVT

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

func (*ExecuteFetchAsAllPrivsRequest) ProtoMessage

func (*ExecuteFetchAsAllPrivsRequest) ProtoMessage()

func (*ExecuteFetchAsAllPrivsRequest) ProtoReflect

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

func (*ExecuteFetchAsAllPrivsRequest) Reset

func (x *ExecuteFetchAsAllPrivsRequest) Reset()

func (*ExecuteFetchAsAllPrivsRequest) SizeVT

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

func (*ExecuteFetchAsAllPrivsRequest) String

func (x *ExecuteFetchAsAllPrivsRequest) String() string

func (*ExecuteFetchAsAllPrivsRequest) UnmarshalVT

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

type ExecuteFetchAsAllPrivsResponse

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

func (*ExecuteFetchAsAllPrivsResponse) Descriptor

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

Deprecated: Use ExecuteFetchAsAllPrivsResponse.ProtoReflect.Descriptor instead.

func (*ExecuteFetchAsAllPrivsResponse) GetResult

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

func (*ExecuteFetchAsAllPrivsResponse) MarshalToSizedBufferVT

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

func (*ExecuteFetchAsAllPrivsResponse) MarshalToVT

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

func (*ExecuteFetchAsAllPrivsResponse) MarshalVT

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

func (*ExecuteFetchAsAllPrivsResponse) ProtoMessage

func (*ExecuteFetchAsAllPrivsResponse) ProtoMessage()

func (*ExecuteFetchAsAllPrivsResponse) ProtoReflect

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

func (*ExecuteFetchAsAllPrivsResponse) Reset

func (x *ExecuteFetchAsAllPrivsResponse) Reset()

func (*ExecuteFetchAsAllPrivsResponse) SizeVT

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

func (*ExecuteFetchAsAllPrivsResponse) String

func (x *ExecuteFetchAsAllPrivsResponse) String() string

func (*ExecuteFetchAsAllPrivsResponse) UnmarshalVT

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

type ExecuteFetchAsAppRequest

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

func (*ExecuteFetchAsAppRequest) Descriptor

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

Deprecated: Use ExecuteFetchAsAppRequest.ProtoReflect.Descriptor instead.

func (*ExecuteFetchAsAppRequest) GetMaxRows

func (x *ExecuteFetchAsAppRequest) GetMaxRows() uint64

func (*ExecuteFetchAsAppRequest) GetQuery

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

func (*ExecuteFetchAsAppRequest) MarshalToSizedBufferVT

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

func (*ExecuteFetchAsAppRequest) MarshalToVT

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

func (*ExecuteFetchAsAppRequest) MarshalVT

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

func (*ExecuteFetchAsAppRequest) ProtoMessage

func (*ExecuteFetchAsAppRequest) ProtoMessage()

func (*ExecuteFetchAsAppRequest) ProtoReflect

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

func (*ExecuteFetchAsAppRequest) Reset

func (x *ExecuteFetchAsAppRequest) Reset()

func (*ExecuteFetchAsAppRequest) SizeVT

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

func (*ExecuteFetchAsAppRequest) String

func (x *ExecuteFetchAsAppRequest) String() string

func (*ExecuteFetchAsAppRequest) UnmarshalVT

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

type ExecuteFetchAsAppResponse

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

func (*ExecuteFetchAsAppResponse) Descriptor

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

Deprecated: Use ExecuteFetchAsAppResponse.ProtoReflect.Descriptor instead.

func (*ExecuteFetchAsAppResponse) GetResult

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

func (*ExecuteFetchAsAppResponse) MarshalToSizedBufferVT

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

func (*ExecuteFetchAsAppResponse) MarshalToVT

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

func (*ExecuteFetchAsAppResponse) MarshalVT

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

func (*ExecuteFetchAsAppResponse) ProtoMessage

func (*ExecuteFetchAsAppResponse) ProtoMessage()

func (*ExecuteFetchAsAppResponse) ProtoReflect

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

func (*ExecuteFetchAsAppResponse) Reset

func (x *ExecuteFetchAsAppResponse) Reset()

func (*ExecuteFetchAsAppResponse) SizeVT

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

func (*ExecuteFetchAsAppResponse) String

func (x *ExecuteFetchAsAppResponse) String() string

func (*ExecuteFetchAsAppResponse) UnmarshalVT

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

type ExecuteFetchAsDbaRequest

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

func (*ExecuteFetchAsDbaRequest) Descriptor

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

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

func (*ExecuteFetchAsDbaRequest) MarshalToVT

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

func (*ExecuteFetchAsDbaRequest) MarshalVT

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

func (*ExecuteFetchAsDbaRequest) ProtoMessage

func (*ExecuteFetchAsDbaRequest) ProtoMessage()

func (*ExecuteFetchAsDbaRequest) ProtoReflect

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

func (*ExecuteFetchAsDbaRequest) Reset

func (x *ExecuteFetchAsDbaRequest) Reset()

func (*ExecuteFetchAsDbaRequest) SizeVT

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

func (*ExecuteFetchAsDbaRequest) String

func (x *ExecuteFetchAsDbaRequest) String() string

func (*ExecuteFetchAsDbaRequest) UnmarshalVT

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

type ExecuteFetchAsDbaResponse

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

func (*ExecuteFetchAsDbaResponse) Descriptor

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

Deprecated: Use ExecuteFetchAsDbaResponse.ProtoReflect.Descriptor instead.

func (*ExecuteFetchAsDbaResponse) GetResult

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

func (*ExecuteFetchAsDbaResponse) MarshalToSizedBufferVT

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

func (*ExecuteFetchAsDbaResponse) MarshalToVT

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

func (*ExecuteFetchAsDbaResponse) MarshalVT

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

func (*ExecuteFetchAsDbaResponse) ProtoMessage

func (*ExecuteFetchAsDbaResponse) ProtoMessage()

func (*ExecuteFetchAsDbaResponse) ProtoReflect

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

func (*ExecuteFetchAsDbaResponse) Reset

func (x *ExecuteFetchAsDbaResponse) Reset()

func (*ExecuteFetchAsDbaResponse) SizeVT

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

func (*ExecuteFetchAsDbaResponse) String

func (x *ExecuteFetchAsDbaResponse) String() string

func (*ExecuteFetchAsDbaResponse) UnmarshalVT

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

type ExecuteHookRequest

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

func (*ExecuteHookRequest) Descriptor

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

Deprecated: Use ExecuteHookRequest.ProtoReflect.Descriptor instead.

func (*ExecuteHookRequest) GetExtraEnv

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

func (*ExecuteHookRequest) GetName

func (x *ExecuteHookRequest) GetName() string

func (*ExecuteHookRequest) GetParameters

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

func (*ExecuteHookRequest) MarshalToSizedBufferVT

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

func (*ExecuteHookRequest) MarshalToVT

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

func (*ExecuteHookRequest) MarshalVT

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

func (*ExecuteHookRequest) ProtoMessage

func (*ExecuteHookRequest) ProtoMessage()

func (*ExecuteHookRequest) ProtoReflect

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

func (*ExecuteHookRequest) Reset

func (x *ExecuteHookRequest) Reset()

func (*ExecuteHookRequest) SizeVT

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

func (*ExecuteHookRequest) String

func (x *ExecuteHookRequest) String() string

func (*ExecuteHookRequest) UnmarshalVT

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

type ExecuteHookResponse

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

func (*ExecuteHookResponse) Descriptor

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

Deprecated: Use ExecuteHookResponse.ProtoReflect.Descriptor instead.

func (*ExecuteHookResponse) GetExitStatus

func (x *ExecuteHookResponse) GetExitStatus() int64

func (*ExecuteHookResponse) GetStderr

func (x *ExecuteHookResponse) GetStderr() string

func (*ExecuteHookResponse) GetStdout

func (x *ExecuteHookResponse) GetStdout() string

func (*ExecuteHookResponse) MarshalToSizedBufferVT

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

func (*ExecuteHookResponse) MarshalToVT

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

func (*ExecuteHookResponse) MarshalVT

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

func (*ExecuteHookResponse) ProtoMessage

func (*ExecuteHookResponse) ProtoMessage()

func (*ExecuteHookResponse) ProtoReflect

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

func (*ExecuteHookResponse) Reset

func (x *ExecuteHookResponse) Reset()

func (*ExecuteHookResponse) SizeVT

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

func (*ExecuteHookResponse) String

func (x *ExecuteHookResponse) String() string

func (*ExecuteHookResponse) UnmarshalVT

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

type ExecuteQueryRequest

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

func (*ExecuteQueryRequest) Descriptor

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

Deprecated: Use ExecuteQueryRequest.ProtoReflect.Descriptor instead.

func (*ExecuteQueryRequest) GetCallerId

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

func (*ExecuteQueryRequest) GetDbName

func (x *ExecuteQueryRequest) GetDbName() string

func (*ExecuteQueryRequest) GetMaxRows

func (x *ExecuteQueryRequest) GetMaxRows() uint64

func (*ExecuteQueryRequest) GetQuery

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

func (*ExecuteQueryRequest) MarshalToSizedBufferVT

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

func (*ExecuteQueryRequest) MarshalToVT

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

func (*ExecuteQueryRequest) MarshalVT

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

func (*ExecuteQueryRequest) ProtoMessage

func (*ExecuteQueryRequest) ProtoMessage()

func (*ExecuteQueryRequest) ProtoReflect

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

func (*ExecuteQueryRequest) Reset

func (x *ExecuteQueryRequest) Reset()

func (*ExecuteQueryRequest) SizeVT

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

func (*ExecuteQueryRequest) String

func (x *ExecuteQueryRequest) String() string

func (*ExecuteQueryRequest) UnmarshalVT

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

type ExecuteQueryResponse

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

func (*ExecuteQueryResponse) Descriptor

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

Deprecated: Use ExecuteQueryResponse.ProtoReflect.Descriptor instead.

func (*ExecuteQueryResponse) GetResult

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

func (*ExecuteQueryResponse) MarshalToSizedBufferVT

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

func (*ExecuteQueryResponse) MarshalToVT

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

func (*ExecuteQueryResponse) MarshalVT

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

func (*ExecuteQueryResponse) ProtoMessage

func (*ExecuteQueryResponse) ProtoMessage()

func (*ExecuteQueryResponse) ProtoReflect

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

func (*ExecuteQueryResponse) Reset

func (x *ExecuteQueryResponse) Reset()

func (*ExecuteQueryResponse) SizeVT

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

func (*ExecuteQueryResponse) String

func (x *ExecuteQueryResponse) String() string

func (*ExecuteQueryResponse) UnmarshalVT

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

type FullStatusRequest

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

func (*FullStatusRequest) Descriptor

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

Deprecated: Use FullStatusRequest.ProtoReflect.Descriptor instead.

func (*FullStatusRequest) MarshalToSizedBufferVT

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

func (*FullStatusRequest) MarshalToVT

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

func (*FullStatusRequest) MarshalVT

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

func (*FullStatusRequest) ProtoMessage

func (*FullStatusRequest) ProtoMessage()

func (*FullStatusRequest) ProtoReflect

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

func (*FullStatusRequest) Reset

func (x *FullStatusRequest) Reset()

func (*FullStatusRequest) SizeVT

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

func (*FullStatusRequest) String

func (x *FullStatusRequest) String() string

func (*FullStatusRequest) UnmarshalVT

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

type FullStatusResponse

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

func (*FullStatusResponse) Descriptor

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

Deprecated: Use FullStatusResponse.ProtoReflect.Descriptor instead.

func (*FullStatusResponse) GetStatus

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

func (*FullStatusResponse) MarshalToSizedBufferVT

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

func (*FullStatusResponse) MarshalToVT

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

func (*FullStatusResponse) MarshalVT

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

func (*FullStatusResponse) ProtoMessage

func (*FullStatusResponse) ProtoMessage()

func (*FullStatusResponse) ProtoReflect

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

func (*FullStatusResponse) Reset

func (x *FullStatusResponse) Reset()

func (*FullStatusResponse) SizeVT

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

func (*FullStatusResponse) String

func (x *FullStatusResponse) String() string

func (*FullStatusResponse) UnmarshalVT

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

type GetPermissionsRequest

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

func (*GetPermissionsRequest) Descriptor

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

Deprecated: Use GetPermissionsRequest.ProtoReflect.Descriptor instead.

func (*GetPermissionsRequest) MarshalToSizedBufferVT

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

func (*GetPermissionsRequest) MarshalToVT

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

func (*GetPermissionsRequest) MarshalVT

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

func (*GetPermissionsRequest) ProtoMessage

func (*GetPermissionsRequest) ProtoMessage()

func (*GetPermissionsRequest) ProtoReflect

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

func (*GetPermissionsRequest) Reset

func (x *GetPermissionsRequest) Reset()

func (*GetPermissionsRequest) SizeVT

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

func (*GetPermissionsRequest) String

func (x *GetPermissionsRequest) String() string

func (*GetPermissionsRequest) UnmarshalVT

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

type GetPermissionsResponse

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

func (*GetPermissionsResponse) Descriptor

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

Deprecated: Use GetPermissionsResponse.ProtoReflect.Descriptor instead.

func (*GetPermissionsResponse) GetPermissions

func (x *GetPermissionsResponse) GetPermissions() *Permissions

func (*GetPermissionsResponse) MarshalToSizedBufferVT

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

func (*GetPermissionsResponse) MarshalToVT

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

func (*GetPermissionsResponse) MarshalVT

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

func (*GetPermissionsResponse) ProtoMessage

func (*GetPermissionsResponse) ProtoMessage()

func (*GetPermissionsResponse) ProtoReflect

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

func (*GetPermissionsResponse) Reset

func (x *GetPermissionsResponse) Reset()

func (*GetPermissionsResponse) SizeVT

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

func (*GetPermissionsResponse) String

func (x *GetPermissionsResponse) String() string

func (*GetPermissionsResponse) UnmarshalVT

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

type GetReplicasRequest

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

func (*GetReplicasRequest) Descriptor

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

Deprecated: Use GetReplicasRequest.ProtoReflect.Descriptor instead.

func (*GetReplicasRequest) MarshalToSizedBufferVT

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

func (*GetReplicasRequest) MarshalToVT

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

func (*GetReplicasRequest) MarshalVT

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

func (*GetReplicasRequest) ProtoMessage

func (*GetReplicasRequest) ProtoMessage()

func (*GetReplicasRequest) ProtoReflect

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

func (*GetReplicasRequest) Reset

func (x *GetReplicasRequest) Reset()

func (*GetReplicasRequest) SizeVT

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

func (*GetReplicasRequest) String

func (x *GetReplicasRequest) String() string

func (*GetReplicasRequest) UnmarshalVT

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

type GetReplicasResponse

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

func (*GetReplicasResponse) Descriptor

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

Deprecated: Use GetReplicasResponse.ProtoReflect.Descriptor instead.

func (*GetReplicasResponse) GetAddrs

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

func (*GetReplicasResponse) MarshalToSizedBufferVT

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

func (*GetReplicasResponse) MarshalToVT

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

func (*GetReplicasResponse) MarshalVT

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

func (*GetReplicasResponse) ProtoMessage

func (*GetReplicasResponse) ProtoMessage()

func (*GetReplicasResponse) ProtoReflect

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

func (*GetReplicasResponse) Reset

func (x *GetReplicasResponse) Reset()

func (*GetReplicasResponse) SizeVT

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

func (*GetReplicasResponse) String

func (x *GetReplicasResponse) String() string

func (*GetReplicasResponse) UnmarshalVT

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

type GetSchemaRequest

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

func (*GetSchemaRequest) Descriptor

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

Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaRequest) GetExcludeTables

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

func (*GetSchemaRequest) GetIncludeViews

func (x *GetSchemaRequest) GetIncludeViews() bool

func (*GetSchemaRequest) GetTableSchemaOnly

func (x *GetSchemaRequest) GetTableSchemaOnly() bool

func (*GetSchemaRequest) GetTables

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

func (*GetSchemaRequest) MarshalToSizedBufferVT

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

func (*GetSchemaRequest) MarshalToVT

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

func (*GetSchemaRequest) MarshalVT

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

func (*GetSchemaRequest) ProtoMessage

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) ProtoReflect

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

func (*GetSchemaRequest) Reset

func (x *GetSchemaRequest) Reset()

func (*GetSchemaRequest) SizeVT

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

func (*GetSchemaRequest) String

func (x *GetSchemaRequest) String() string

func (*GetSchemaRequest) UnmarshalVT

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

type GetSchemaResponse

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

func (*GetSchemaResponse) Descriptor

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

Deprecated: Use GetSchemaResponse.ProtoReflect.Descriptor instead.

func (*GetSchemaResponse) GetSchemaDefinition

func (x *GetSchemaResponse) GetSchemaDefinition() *SchemaDefinition

func (*GetSchemaResponse) MarshalToSizedBufferVT

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

func (*GetSchemaResponse) MarshalToVT

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

func (*GetSchemaResponse) MarshalVT

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

func (*GetSchemaResponse) ProtoMessage

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) ProtoReflect

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

func (*GetSchemaResponse) Reset

func (x *GetSchemaResponse) Reset()

func (*GetSchemaResponse) SizeVT

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

func (*GetSchemaResponse) String

func (x *GetSchemaResponse) String() string

func (*GetSchemaResponse) UnmarshalVT

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

type InitPrimaryRequest

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

func (*InitPrimaryRequest) Descriptor

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

Deprecated: Use InitPrimaryRequest.ProtoReflect.Descriptor instead.

func (*InitPrimaryRequest) GetSemiSync

func (x *InitPrimaryRequest) GetSemiSync() bool

func (*InitPrimaryRequest) MarshalToSizedBufferVT

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

func (*InitPrimaryRequest) MarshalToVT

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

func (*InitPrimaryRequest) MarshalVT

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

func (*InitPrimaryRequest) ProtoMessage

func (*InitPrimaryRequest) ProtoMessage()

func (*InitPrimaryRequest) ProtoReflect

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

func (*InitPrimaryRequest) Reset

func (x *InitPrimaryRequest) Reset()

func (*InitPrimaryRequest) SizeVT

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

func (*InitPrimaryRequest) String

func (x *InitPrimaryRequest) String() string

func (*InitPrimaryRequest) UnmarshalVT

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

type InitPrimaryResponse

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

func (*InitPrimaryResponse) Descriptor

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

Deprecated: Use InitPrimaryResponse.ProtoReflect.Descriptor instead.

func (*InitPrimaryResponse) GetPosition

func (x *InitPrimaryResponse) GetPosition() string

func (*InitPrimaryResponse) MarshalToSizedBufferVT

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

func (*InitPrimaryResponse) MarshalToVT

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

func (*InitPrimaryResponse) MarshalVT

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

func (*InitPrimaryResponse) ProtoMessage

func (*InitPrimaryResponse) ProtoMessage()

func (*InitPrimaryResponse) ProtoReflect

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

func (*InitPrimaryResponse) Reset

func (x *InitPrimaryResponse) Reset()

func (*InitPrimaryResponse) SizeVT

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

func (*InitPrimaryResponse) String

func (x *InitPrimaryResponse) String() string

func (*InitPrimaryResponse) UnmarshalVT

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

type InitReplicaRequest

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

func (*InitReplicaRequest) Descriptor

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

Deprecated: Use InitReplicaRequest.ProtoReflect.Descriptor instead.

func (*InitReplicaRequest) GetParent

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

func (*InitReplicaRequest) GetReplicationPosition

func (x *InitReplicaRequest) GetReplicationPosition() string

func (*InitReplicaRequest) GetSemiSync

func (x *InitReplicaRequest) GetSemiSync() bool

func (*InitReplicaRequest) GetTimeCreatedNs

func (x *InitReplicaRequest) GetTimeCreatedNs() int64

func (*InitReplicaRequest) MarshalToSizedBufferVT

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

func (*InitReplicaRequest) MarshalToVT

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

func (*InitReplicaRequest) MarshalVT

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

func (*InitReplicaRequest) ProtoMessage

func (*InitReplicaRequest) ProtoMessage()

func (*InitReplicaRequest) ProtoReflect

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

func (*InitReplicaRequest) Reset

func (x *InitReplicaRequest) Reset()

func (*InitReplicaRequest) SizeVT

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

func (*InitReplicaRequest) String

func (x *InitReplicaRequest) String() string

func (*InitReplicaRequest) UnmarshalVT

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

type InitReplicaResponse

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

func (*InitReplicaResponse) Descriptor

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

Deprecated: Use InitReplicaResponse.ProtoReflect.Descriptor instead.

func (*InitReplicaResponse) MarshalToSizedBufferVT

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

func (*InitReplicaResponse) MarshalToVT

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

func (*InitReplicaResponse) MarshalVT

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

func (*InitReplicaResponse) ProtoMessage

func (*InitReplicaResponse) ProtoMessage()

func (*InitReplicaResponse) ProtoReflect

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

func (*InitReplicaResponse) Reset

func (x *InitReplicaResponse) Reset()

func (*InitReplicaResponse) SizeVT

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

func (*InitReplicaResponse) String

func (x *InitReplicaResponse) String() string

func (*InitReplicaResponse) UnmarshalVT

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

type LockTablesRequest

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

func (*LockTablesRequest) Descriptor

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

Deprecated: Use LockTablesRequest.ProtoReflect.Descriptor instead.

func (*LockTablesRequest) MarshalToSizedBufferVT

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

func (*LockTablesRequest) MarshalToVT

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

func (*LockTablesRequest) MarshalVT

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

func (*LockTablesRequest) ProtoMessage

func (*LockTablesRequest) ProtoMessage()

func (*LockTablesRequest) ProtoReflect

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

func (*LockTablesRequest) Reset

func (x *LockTablesRequest) Reset()

func (*LockTablesRequest) SizeVT

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

func (*LockTablesRequest) String

func (x *LockTablesRequest) String() string

func (*LockTablesRequest) UnmarshalVT

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

type LockTablesResponse

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

func (*LockTablesResponse) Descriptor

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

Deprecated: Use LockTablesResponse.ProtoReflect.Descriptor instead.

func (*LockTablesResponse) MarshalToSizedBufferVT

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

func (*LockTablesResponse) MarshalToVT

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

func (*LockTablesResponse) MarshalVT

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

func (*LockTablesResponse) ProtoMessage

func (*LockTablesResponse) ProtoMessage()

func (*LockTablesResponse) ProtoReflect

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

func (*LockTablesResponse) Reset

func (x *LockTablesResponse) Reset()

func (*LockTablesResponse) SizeVT

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

func (*LockTablesResponse) String

func (x *LockTablesResponse) String() string

func (*LockTablesResponse) UnmarshalVT

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

type Permissions

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

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

func (*Permissions) Descriptor

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

Deprecated: Use Permissions.ProtoReflect.Descriptor instead.

func (*Permissions) GetDbPermissions

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

func (*Permissions) GetUserPermissions

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

func (*Permissions) MarshalToSizedBufferVT

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

func (*Permissions) MarshalToVT

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

func (*Permissions) MarshalVT

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

func (*Permissions) ProtoMessage

func (*Permissions) ProtoMessage()

func (*Permissions) ProtoReflect

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

func (*Permissions) Reset

func (x *Permissions) Reset()

func (*Permissions) SizeVT

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

func (*Permissions) String

func (x *Permissions) String() string

func (*Permissions) UnmarshalVT

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

type PingRequest

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

func (*PingRequest) Descriptor

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) GetPayload

func (x *PingRequest) GetPayload() string

func (*PingRequest) MarshalToSizedBufferVT

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

func (*PingRequest) MarshalToVT

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

func (*PingRequest) MarshalVT

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

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect

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

func (*PingRequest) Reset

func (x *PingRequest) Reset()

func (*PingRequest) SizeVT

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

func (*PingRequest) String

func (x *PingRequest) String() string

func (*PingRequest) UnmarshalVT

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

type PingResponse

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

func (*PingResponse) Descriptor

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetPayload

func (x *PingResponse) GetPayload() string

func (*PingResponse) MarshalToSizedBufferVT

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

func (*PingResponse) MarshalToVT

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

func (*PingResponse) MarshalVT

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

func (*PingResponse) ProtoMessage

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect

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

func (*PingResponse) Reset

func (x *PingResponse) Reset()

func (*PingResponse) SizeVT

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

func (*PingResponse) String

func (x *PingResponse) String() string

func (*PingResponse) UnmarshalVT

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

type PopulateReparentJournalRequest

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

func (*PopulateReparentJournalRequest) Descriptor

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

Deprecated: Use PopulateReparentJournalRequest.ProtoReflect.Descriptor instead.

func (*PopulateReparentJournalRequest) GetActionName

func (x *PopulateReparentJournalRequest) GetActionName() string

func (*PopulateReparentJournalRequest) GetPrimaryAlias

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

func (*PopulateReparentJournalRequest) GetReplicationPosition

func (x *PopulateReparentJournalRequest) GetReplicationPosition() string

func (*PopulateReparentJournalRequest) GetTimeCreatedNs

func (x *PopulateReparentJournalRequest) GetTimeCreatedNs() int64

func (*PopulateReparentJournalRequest) MarshalToSizedBufferVT

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

func (*PopulateReparentJournalRequest) MarshalToVT

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

func (*PopulateReparentJournalRequest) MarshalVT

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

func (*PopulateReparentJournalRequest) ProtoMessage

func (*PopulateReparentJournalRequest) ProtoMessage()

func (*PopulateReparentJournalRequest) ProtoReflect

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

func (*PopulateReparentJournalRequest) Reset

func (x *PopulateReparentJournalRequest) Reset()

func (*PopulateReparentJournalRequest) SizeVT

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

func (*PopulateReparentJournalRequest) String

func (x *PopulateReparentJournalRequest) String() string

func (*PopulateReparentJournalRequest) UnmarshalVT

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

type PopulateReparentJournalResponse

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

func (*PopulateReparentJournalResponse) Descriptor

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

Deprecated: Use PopulateReparentJournalResponse.ProtoReflect.Descriptor instead.

func (*PopulateReparentJournalResponse) MarshalToSizedBufferVT

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

func (*PopulateReparentJournalResponse) MarshalToVT

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

func (*PopulateReparentJournalResponse) MarshalVT

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

func (*PopulateReparentJournalResponse) ProtoMessage

func (*PopulateReparentJournalResponse) ProtoMessage()

func (*PopulateReparentJournalResponse) ProtoReflect

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

func (*PopulateReparentJournalResponse) Reset

func (x *PopulateReparentJournalResponse) Reset()

func (*PopulateReparentJournalResponse) SizeVT

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

func (*PopulateReparentJournalResponse) String

func (x *PopulateReparentJournalResponse) String() string

func (*PopulateReparentJournalResponse) UnmarshalVT

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

type PreflightSchemaRequest

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

func (*PreflightSchemaRequest) Descriptor

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

Deprecated: Use PreflightSchemaRequest.ProtoReflect.Descriptor instead.

func (*PreflightSchemaRequest) GetChanges

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

func (*PreflightSchemaRequest) MarshalToSizedBufferVT

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

func (*PreflightSchemaRequest) MarshalToVT

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

func (*PreflightSchemaRequest) MarshalVT

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

func (*PreflightSchemaRequest) ProtoMessage

func (*PreflightSchemaRequest) ProtoMessage()

func (*PreflightSchemaRequest) ProtoReflect

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

func (*PreflightSchemaRequest) Reset

func (x *PreflightSchemaRequest) Reset()

func (*PreflightSchemaRequest) SizeVT

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

func (*PreflightSchemaRequest) String

func (x *PreflightSchemaRequest) String() string

func (*PreflightSchemaRequest) UnmarshalVT

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

type PreflightSchemaResponse

type PreflightSchemaResponse struct {

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

func (*PreflightSchemaResponse) Descriptor

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

Deprecated: Use PreflightSchemaResponse.ProtoReflect.Descriptor instead.

func (*PreflightSchemaResponse) GetChangeResults

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

func (*PreflightSchemaResponse) MarshalToSizedBufferVT

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

func (*PreflightSchemaResponse) MarshalToVT

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

func (*PreflightSchemaResponse) MarshalVT

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

func (*PreflightSchemaResponse) ProtoMessage

func (*PreflightSchemaResponse) ProtoMessage()

func (*PreflightSchemaResponse) ProtoReflect

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

func (*PreflightSchemaResponse) Reset

func (x *PreflightSchemaResponse) Reset()

func (*PreflightSchemaResponse) SizeVT

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

func (*PreflightSchemaResponse) String

func (x *PreflightSchemaResponse) String() string

func (*PreflightSchemaResponse) UnmarshalVT

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

type PrimaryPositionRequest

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

func (*PrimaryPositionRequest) Descriptor

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

Deprecated: Use PrimaryPositionRequest.ProtoReflect.Descriptor instead.

func (*PrimaryPositionRequest) MarshalToSizedBufferVT

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

func (*PrimaryPositionRequest) MarshalToVT

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

func (*PrimaryPositionRequest) MarshalVT

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

func (*PrimaryPositionRequest) ProtoMessage

func (*PrimaryPositionRequest) ProtoMessage()

func (*PrimaryPositionRequest) ProtoReflect

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

func (*PrimaryPositionRequest) Reset

func (x *PrimaryPositionRequest) Reset()

func (*PrimaryPositionRequest) SizeVT

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

func (*PrimaryPositionRequest) String

func (x *PrimaryPositionRequest) String() string

func (*PrimaryPositionRequest) UnmarshalVT

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

type PrimaryPositionResponse

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

func (*PrimaryPositionResponse) Descriptor

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

Deprecated: Use PrimaryPositionResponse.ProtoReflect.Descriptor instead.

func (*PrimaryPositionResponse) GetPosition

func (x *PrimaryPositionResponse) GetPosition() string

func (*PrimaryPositionResponse) MarshalToSizedBufferVT

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

func (*PrimaryPositionResponse) MarshalToVT

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

func (*PrimaryPositionResponse) MarshalVT

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

func (*PrimaryPositionResponse) ProtoMessage

func (*PrimaryPositionResponse) ProtoMessage()

func (*PrimaryPositionResponse) ProtoReflect

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

func (*PrimaryPositionResponse) Reset

func (x *PrimaryPositionResponse) Reset()

func (*PrimaryPositionResponse) SizeVT

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

func (*PrimaryPositionResponse) String

func (x *PrimaryPositionResponse) String() string

func (*PrimaryPositionResponse) UnmarshalVT

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

type PrimaryStatusRequest

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

func (*PrimaryStatusRequest) Descriptor

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

Deprecated: Use PrimaryStatusRequest.ProtoReflect.Descriptor instead.

func (*PrimaryStatusRequest) MarshalToSizedBufferVT

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

func (*PrimaryStatusRequest) MarshalToVT

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

func (*PrimaryStatusRequest) MarshalVT

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

func (*PrimaryStatusRequest) ProtoMessage

func (*PrimaryStatusRequest) ProtoMessage()

func (*PrimaryStatusRequest) ProtoReflect

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

func (*PrimaryStatusRequest) Reset

func (x *PrimaryStatusRequest) Reset()

func (*PrimaryStatusRequest) SizeVT

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

func (*PrimaryStatusRequest) String

func (x *PrimaryStatusRequest) String() string

func (*PrimaryStatusRequest) UnmarshalVT

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

type PrimaryStatusResponse

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

func (*PrimaryStatusResponse) Descriptor

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

Deprecated: Use PrimaryStatusResponse.ProtoReflect.Descriptor instead.

func (*PrimaryStatusResponse) GetStatus

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

func (*PrimaryStatusResponse) MarshalToSizedBufferVT

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

func (*PrimaryStatusResponse) MarshalToVT

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

func (*PrimaryStatusResponse) MarshalVT

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

func (*PrimaryStatusResponse) ProtoMessage

func (*PrimaryStatusResponse) ProtoMessage()

func (*PrimaryStatusResponse) ProtoReflect

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

func (*PrimaryStatusResponse) Reset

func (x *PrimaryStatusResponse) Reset()

func (*PrimaryStatusResponse) SizeVT

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

func (*PrimaryStatusResponse) String

func (x *PrimaryStatusResponse) String() string

func (*PrimaryStatusResponse) UnmarshalVT

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

type PromoteReplicaRequest

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

func (*PromoteReplicaRequest) Descriptor

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

Deprecated: Use PromoteReplicaRequest.ProtoReflect.Descriptor instead.

func (*PromoteReplicaRequest) GetSemiSync

func (x *PromoteReplicaRequest) GetSemiSync() bool

func (*PromoteReplicaRequest) MarshalToSizedBufferVT

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

func (*PromoteReplicaRequest) MarshalToVT

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

func (*PromoteReplicaRequest) MarshalVT

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

func (*PromoteReplicaRequest) ProtoMessage

func (*PromoteReplicaRequest) ProtoMessage()

func (*PromoteReplicaRequest) ProtoReflect

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

func (*PromoteReplicaRequest) Reset

func (x *PromoteReplicaRequest) Reset()

func (*PromoteReplicaRequest) SizeVT

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

func (*PromoteReplicaRequest) String

func (x *PromoteReplicaRequest) String() string

func (*PromoteReplicaRequest) UnmarshalVT

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

type PromoteReplicaResponse

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

func (*PromoteReplicaResponse) Descriptor

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

Deprecated: Use PromoteReplicaResponse.ProtoReflect.Descriptor instead.

func (*PromoteReplicaResponse) GetPosition

func (x *PromoteReplicaResponse) GetPosition() string

func (*PromoteReplicaResponse) MarshalToSizedBufferVT

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

func (*PromoteReplicaResponse) MarshalToVT

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

func (*PromoteReplicaResponse) MarshalVT

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

func (*PromoteReplicaResponse) ProtoMessage

func (*PromoteReplicaResponse) ProtoMessage()

func (*PromoteReplicaResponse) ProtoReflect

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

func (*PromoteReplicaResponse) Reset

func (x *PromoteReplicaResponse) Reset()

func (*PromoteReplicaResponse) SizeVT

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

func (*PromoteReplicaResponse) String

func (x *PromoteReplicaResponse) String() string

func (*PromoteReplicaResponse) UnmarshalVT

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

type RefreshStateRequest

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

func (*RefreshStateRequest) Descriptor

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

Deprecated: Use RefreshStateRequest.ProtoReflect.Descriptor instead.

func (*RefreshStateRequest) MarshalToSizedBufferVT

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

func (*RefreshStateRequest) MarshalToVT

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

func (*RefreshStateRequest) MarshalVT

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

func (*RefreshStateRequest) ProtoMessage

func (*RefreshStateRequest) ProtoMessage()

func (*RefreshStateRequest) ProtoReflect

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

func (*RefreshStateRequest) Reset

func (x *RefreshStateRequest) Reset()

func (*RefreshStateRequest) SizeVT

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

func (*RefreshStateRequest) String

func (x *RefreshStateRequest) String() string

func (*RefreshStateRequest) UnmarshalVT

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

type RefreshStateResponse

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

func (*RefreshStateResponse) Descriptor

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

Deprecated: Use RefreshStateResponse.ProtoReflect.Descriptor instead.

func (*RefreshStateResponse) MarshalToSizedBufferVT

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

func (*RefreshStateResponse) MarshalToVT

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

func (*RefreshStateResponse) MarshalVT

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

func (*RefreshStateResponse) ProtoMessage

func (*RefreshStateResponse) ProtoMessage()

func (*RefreshStateResponse) ProtoReflect

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

func (*RefreshStateResponse) Reset

func (x *RefreshStateResponse) Reset()

func (*RefreshStateResponse) SizeVT

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

func (*RefreshStateResponse) String

func (x *RefreshStateResponse) String() string

func (*RefreshStateResponse) UnmarshalVT

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

type ReloadSchemaRequest

type ReloadSchemaRequest struct {

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

func (*ReloadSchemaRequest) Descriptor

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

Deprecated: Use ReloadSchemaRequest.ProtoReflect.Descriptor instead.

func (*ReloadSchemaRequest) GetWaitPosition

func (x *ReloadSchemaRequest) GetWaitPosition() string

func (*ReloadSchemaRequest) MarshalToSizedBufferVT

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

func (*ReloadSchemaRequest) MarshalToVT

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

func (*ReloadSchemaRequest) MarshalVT

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

func (*ReloadSchemaRequest) ProtoMessage

func (*ReloadSchemaRequest) ProtoMessage()

func (*ReloadSchemaRequest) ProtoReflect

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

func (*ReloadSchemaRequest) Reset

func (x *ReloadSchemaRequest) Reset()

func (*ReloadSchemaRequest) SizeVT

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

func (*ReloadSchemaRequest) String

func (x *ReloadSchemaRequest) String() string

func (*ReloadSchemaRequest) UnmarshalVT

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

type ReloadSchemaResponse

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

func (*ReloadSchemaResponse) Descriptor

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

Deprecated: Use ReloadSchemaResponse.ProtoReflect.Descriptor instead.

func (*ReloadSchemaResponse) MarshalToSizedBufferVT

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

func (*ReloadSchemaResponse) MarshalToVT

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

func (*ReloadSchemaResponse) MarshalVT

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

func (*ReloadSchemaResponse) ProtoMessage

func (*ReloadSchemaResponse) ProtoMessage()

func (*ReloadSchemaResponse) ProtoReflect

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

func (*ReloadSchemaResponse) Reset

func (x *ReloadSchemaResponse) Reset()

func (*ReloadSchemaResponse) SizeVT

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

func (*ReloadSchemaResponse) String

func (x *ReloadSchemaResponse) String() string

func (*ReloadSchemaResponse) UnmarshalVT

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

type ReplicaWasPromotedRequest

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

func (*ReplicaWasPromotedRequest) Descriptor

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

Deprecated: Use ReplicaWasPromotedRequest.ProtoReflect.Descriptor instead.

func (*ReplicaWasPromotedRequest) MarshalToSizedBufferVT

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

func (*ReplicaWasPromotedRequest) MarshalToVT

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

func (*ReplicaWasPromotedRequest) MarshalVT

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

func (*ReplicaWasPromotedRequest) ProtoMessage

func (*ReplicaWasPromotedRequest) ProtoMessage()

func (*ReplicaWasPromotedRequest) ProtoReflect

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

func (*ReplicaWasPromotedRequest) Reset

func (x *ReplicaWasPromotedRequest) Reset()

func (*ReplicaWasPromotedRequest) SizeVT

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

func (*ReplicaWasPromotedRequest) String

func (x *ReplicaWasPromotedRequest) String() string

func (*ReplicaWasPromotedRequest) UnmarshalVT

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

type ReplicaWasPromotedResponse

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

func (*ReplicaWasPromotedResponse) Descriptor

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

Deprecated: Use ReplicaWasPromotedResponse.ProtoReflect.Descriptor instead.

func (*ReplicaWasPromotedResponse) MarshalToSizedBufferVT

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

func (*ReplicaWasPromotedResponse) MarshalToVT

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

func (*ReplicaWasPromotedResponse) MarshalVT

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

func (*ReplicaWasPromotedResponse) ProtoMessage

func (*ReplicaWasPromotedResponse) ProtoMessage()

func (*ReplicaWasPromotedResponse) ProtoReflect

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

func (*ReplicaWasPromotedResponse) Reset

func (x *ReplicaWasPromotedResponse) Reset()

func (*ReplicaWasPromotedResponse) SizeVT

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

func (*ReplicaWasPromotedResponse) String

func (x *ReplicaWasPromotedResponse) String() string

func (*ReplicaWasPromotedResponse) UnmarshalVT

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

type ReplicaWasRestartedRequest

type ReplicaWasRestartedRequest struct {

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

func (*ReplicaWasRestartedRequest) Descriptor

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

Deprecated: Use ReplicaWasRestartedRequest.ProtoReflect.Descriptor instead.

func (*ReplicaWasRestartedRequest) GetParent

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

func (*ReplicaWasRestartedRequest) MarshalToSizedBufferVT

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

func (*ReplicaWasRestartedRequest) MarshalToVT

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

func (*ReplicaWasRestartedRequest) MarshalVT

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

func (*ReplicaWasRestartedRequest) ProtoMessage

func (*ReplicaWasRestartedRequest) ProtoMessage()

func (*ReplicaWasRestartedRequest) ProtoReflect

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

func (*ReplicaWasRestartedRequest) Reset

func (x *ReplicaWasRestartedRequest) Reset()

func (*ReplicaWasRestartedRequest) SizeVT

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

func (*ReplicaWasRestartedRequest) String

func (x *ReplicaWasRestartedRequest) String() string

func (*ReplicaWasRestartedRequest) UnmarshalVT

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

type ReplicaWasRestartedResponse

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

func (*ReplicaWasRestartedResponse) Descriptor

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

Deprecated: Use ReplicaWasRestartedResponse.ProtoReflect.Descriptor instead.

func (*ReplicaWasRestartedResponse) MarshalToSizedBufferVT

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

func (*ReplicaWasRestartedResponse) MarshalToVT

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

func (*ReplicaWasRestartedResponse) MarshalVT

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

func (*ReplicaWasRestartedResponse) ProtoMessage

func (*ReplicaWasRestartedResponse) ProtoMessage()

func (*ReplicaWasRestartedResponse) ProtoReflect

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

func (*ReplicaWasRestartedResponse) Reset

func (x *ReplicaWasRestartedResponse) Reset()

func (*ReplicaWasRestartedResponse) SizeVT

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

func (*ReplicaWasRestartedResponse) String

func (x *ReplicaWasRestartedResponse) String() string

func (*ReplicaWasRestartedResponse) UnmarshalVT

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

type ReplicationStatusRequest

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

func (*ReplicationStatusRequest) Descriptor

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

Deprecated: Use ReplicationStatusRequest.ProtoReflect.Descriptor instead.

func (*ReplicationStatusRequest) MarshalToSizedBufferVT

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

func (*ReplicationStatusRequest) MarshalToVT

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

func (*ReplicationStatusRequest) MarshalVT

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

func (*ReplicationStatusRequest) ProtoMessage

func (*ReplicationStatusRequest) ProtoMessage()

func (*ReplicationStatusRequest) ProtoReflect

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

func (*ReplicationStatusRequest) Reset

func (x *ReplicationStatusRequest) Reset()

func (*ReplicationStatusRequest) SizeVT

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

func (*ReplicationStatusRequest) String

func (x *ReplicationStatusRequest) String() string

func (*ReplicationStatusRequest) UnmarshalVT

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

type ReplicationStatusResponse

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

func (*ReplicationStatusResponse) Descriptor

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

Deprecated: Use ReplicationStatusResponse.ProtoReflect.Descriptor instead.

func (*ReplicationStatusResponse) GetStatus

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

func (*ReplicationStatusResponse) MarshalToSizedBufferVT

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

func (*ReplicationStatusResponse) MarshalToVT

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

func (*ReplicationStatusResponse) MarshalVT

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

func (*ReplicationStatusResponse) ProtoMessage

func (*ReplicationStatusResponse) ProtoMessage()

func (*ReplicationStatusResponse) ProtoReflect

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

func (*ReplicationStatusResponse) Reset

func (x *ReplicationStatusResponse) Reset()

func (*ReplicationStatusResponse) SizeVT

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

func (*ReplicationStatusResponse) String

func (x *ReplicationStatusResponse) String() string

func (*ReplicationStatusResponse) UnmarshalVT

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

type ResetReplicationParametersRequest

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

func (*ResetReplicationParametersRequest) Descriptor

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

Deprecated: Use ResetReplicationParametersRequest.ProtoReflect.Descriptor instead.

func (*ResetReplicationParametersRequest) MarshalToSizedBufferVT

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

func (*ResetReplicationParametersRequest) MarshalToVT

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

func (*ResetReplicationParametersRequest) MarshalVT

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

func (*ResetReplicationParametersRequest) ProtoMessage

func (*ResetReplicationParametersRequest) ProtoMessage()

func (*ResetReplicationParametersRequest) ProtoReflect

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

func (*ResetReplicationParametersRequest) Reset

func (x *ResetReplicationParametersRequest) Reset()

func (*ResetReplicationParametersRequest) SizeVT

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

func (*ResetReplicationParametersRequest) String

func (x *ResetReplicationParametersRequest) String() string

func (*ResetReplicationParametersRequest) UnmarshalVT

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

type ResetReplicationParametersResponse

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

func (*ResetReplicationParametersResponse) Descriptor

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

Deprecated: Use ResetReplicationParametersResponse.ProtoReflect.Descriptor instead.

func (*ResetReplicationParametersResponse) MarshalToSizedBufferVT

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

func (*ResetReplicationParametersResponse) MarshalToVT

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

func (*ResetReplicationParametersResponse) MarshalVT

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

func (*ResetReplicationParametersResponse) ProtoMessage

func (*ResetReplicationParametersResponse) ProtoMessage()

func (*ResetReplicationParametersResponse) ProtoReflect

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

func (*ResetReplicationParametersResponse) Reset

func (x *ResetReplicationParametersResponse) Reset()

func (*ResetReplicationParametersResponse) SizeVT

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

func (*ResetReplicationParametersResponse) String

func (x *ResetReplicationParametersResponse) String() string

func (*ResetReplicationParametersResponse) UnmarshalVT

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

type ResetReplicationRequest

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

func (*ResetReplicationRequest) Descriptor

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

Deprecated: Use ResetReplicationRequest.ProtoReflect.Descriptor instead.

func (*ResetReplicationRequest) MarshalToSizedBufferVT

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

func (*ResetReplicationRequest) MarshalToVT

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

func (*ResetReplicationRequest) MarshalVT

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

func (*ResetReplicationRequest) ProtoMessage

func (*ResetReplicationRequest) ProtoMessage()

func (*ResetReplicationRequest) ProtoReflect

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

func (*ResetReplicationRequest) Reset

func (x *ResetReplicationRequest) Reset()

func (*ResetReplicationRequest) SizeVT

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

func (*ResetReplicationRequest) String

func (x *ResetReplicationRequest) String() string

func (*ResetReplicationRequest) UnmarshalVT

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

type ResetReplicationResponse

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

func (*ResetReplicationResponse) Descriptor

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

Deprecated: Use ResetReplicationResponse.ProtoReflect.Descriptor instead.

func (*ResetReplicationResponse) MarshalToSizedBufferVT

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

func (*ResetReplicationResponse) MarshalToVT

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

func (*ResetReplicationResponse) MarshalVT

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

func (*ResetReplicationResponse) ProtoMessage

func (*ResetReplicationResponse) ProtoMessage()

func (*ResetReplicationResponse) ProtoReflect

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

func (*ResetReplicationResponse) Reset

func (x *ResetReplicationResponse) Reset()

func (*ResetReplicationResponse) SizeVT

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

func (*ResetReplicationResponse) String

func (x *ResetReplicationResponse) String() string

func (*ResetReplicationResponse) UnmarshalVT

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

type 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

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

Deprecated: Use RestoreFromBackupRequest.ProtoReflect.Descriptor instead.

func (*RestoreFromBackupRequest) GetBackupTime

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

func (*RestoreFromBackupRequest) MarshalToSizedBufferVT

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

func (*RestoreFromBackupRequest) MarshalToVT

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

func (*RestoreFromBackupRequest) MarshalVT

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

func (*RestoreFromBackupRequest) ProtoMessage

func (*RestoreFromBackupRequest) ProtoMessage()

func (*RestoreFromBackupRequest) ProtoReflect

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

func (*RestoreFromBackupRequest) Reset

func (x *RestoreFromBackupRequest) Reset()

func (*RestoreFromBackupRequest) SizeVT

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

func (*RestoreFromBackupRequest) String

func (x *RestoreFromBackupRequest) String() string

func (*RestoreFromBackupRequest) UnmarshalVT

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

type RestoreFromBackupResponse

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

func (*RestoreFromBackupResponse) Descriptor

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

Deprecated: Use RestoreFromBackupResponse.ProtoReflect.Descriptor instead.

func (*RestoreFromBackupResponse) GetEvent

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

func (*RestoreFromBackupResponse) MarshalToSizedBufferVT

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

func (*RestoreFromBackupResponse) MarshalToVT

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

func (*RestoreFromBackupResponse) MarshalVT

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

func (*RestoreFromBackupResponse) ProtoMessage

func (*RestoreFromBackupResponse) ProtoMessage()

func (*RestoreFromBackupResponse) ProtoReflect

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

func (*RestoreFromBackupResponse) Reset

func (x *RestoreFromBackupResponse) Reset()

func (*RestoreFromBackupResponse) SizeVT

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

func (*RestoreFromBackupResponse) String

func (x *RestoreFromBackupResponse) String() string

func (*RestoreFromBackupResponse) UnmarshalVT

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

type RunHealthCheckRequest

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

func (*RunHealthCheckRequest) Descriptor

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

Deprecated: Use RunHealthCheckRequest.ProtoReflect.Descriptor instead.

func (*RunHealthCheckRequest) MarshalToSizedBufferVT

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

func (*RunHealthCheckRequest) MarshalToVT

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

func (*RunHealthCheckRequest) MarshalVT

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

func (*RunHealthCheckRequest) ProtoMessage

func (*RunHealthCheckRequest) ProtoMessage()

func (*RunHealthCheckRequest) ProtoReflect

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

func (*RunHealthCheckRequest) Reset

func (x *RunHealthCheckRequest) Reset()

func (*RunHealthCheckRequest) SizeVT

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

func (*RunHealthCheckRequest) String

func (x *RunHealthCheckRequest) String() string

func (*RunHealthCheckRequest) UnmarshalVT

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

type RunHealthCheckResponse

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

func (*RunHealthCheckResponse) Descriptor

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

Deprecated: Use RunHealthCheckResponse.ProtoReflect.Descriptor instead.

func (*RunHealthCheckResponse) MarshalToSizedBufferVT

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

func (*RunHealthCheckResponse) MarshalToVT

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

func (*RunHealthCheckResponse) MarshalVT

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

func (*RunHealthCheckResponse) ProtoMessage

func (*RunHealthCheckResponse) ProtoMessage()

func (*RunHealthCheckResponse) ProtoReflect

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

func (*RunHealthCheckResponse) Reset

func (x *RunHealthCheckResponse) Reset()

func (*RunHealthCheckResponse) SizeVT

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

func (*RunHealthCheckResponse) String

func (x *RunHealthCheckResponse) String() string

func (*RunHealthCheckResponse) UnmarshalVT

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

type SchemaChangeResult

type SchemaChangeResult struct {

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

func (*SchemaChangeResult) Descriptor

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

Deprecated: Use SchemaChangeResult.ProtoReflect.Descriptor instead.

func (*SchemaChangeResult) GetAfterSchema

func (x *SchemaChangeResult) GetAfterSchema() *SchemaDefinition

func (*SchemaChangeResult) GetBeforeSchema

func (x *SchemaChangeResult) GetBeforeSchema() *SchemaDefinition

func (*SchemaChangeResult) MarshalToSizedBufferVT

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

func (*SchemaChangeResult) MarshalToVT

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

func (*SchemaChangeResult) MarshalVT

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

func (*SchemaChangeResult) ProtoMessage

func (*SchemaChangeResult) ProtoMessage()

func (*SchemaChangeResult) ProtoReflect

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

func (*SchemaChangeResult) Reset

func (x *SchemaChangeResult) Reset()

func (*SchemaChangeResult) SizeVT

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

func (*SchemaChangeResult) String

func (x *SchemaChangeResult) String() string

func (*SchemaChangeResult) UnmarshalVT

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

type SchemaDefinition

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

func (*SchemaDefinition) Descriptor

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

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

func (*SchemaDefinition) MarshalToVT

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

func (*SchemaDefinition) MarshalVT

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

func (*SchemaDefinition) ProtoMessage

func (*SchemaDefinition) ProtoMessage()

func (*SchemaDefinition) ProtoReflect

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

func (*SchemaDefinition) Reset

func (x *SchemaDefinition) Reset()

func (*SchemaDefinition) SizeVT

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

func (*SchemaDefinition) String

func (x *SchemaDefinition) String() string

func (*SchemaDefinition) UnmarshalVT

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

type SetReadOnlyRequest

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

func (*SetReadOnlyRequest) Descriptor

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

Deprecated: Use SetReadOnlyRequest.ProtoReflect.Descriptor instead.

func (*SetReadOnlyRequest) MarshalToSizedBufferVT

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

func (*SetReadOnlyRequest) MarshalToVT

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

func (*SetReadOnlyRequest) MarshalVT

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

func (*SetReadOnlyRequest) ProtoMessage

func (*SetReadOnlyRequest) ProtoMessage()

func (*SetReadOnlyRequest) ProtoReflect

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

func (*SetReadOnlyRequest) Reset

func (x *SetReadOnlyRequest) Reset()

func (*SetReadOnlyRequest) SizeVT

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

func (*SetReadOnlyRequest) String

func (x *SetReadOnlyRequest) String() string

func (*SetReadOnlyRequest) UnmarshalVT

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

type SetReadOnlyResponse

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

func (*SetReadOnlyResponse) Descriptor

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

Deprecated: Use SetReadOnlyResponse.ProtoReflect.Descriptor instead.

func (*SetReadOnlyResponse) MarshalToSizedBufferVT

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

func (*SetReadOnlyResponse) MarshalToVT

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

func (*SetReadOnlyResponse) MarshalVT

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

func (*SetReadOnlyResponse) ProtoMessage

func (*SetReadOnlyResponse) ProtoMessage()

func (*SetReadOnlyResponse) ProtoReflect

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

func (*SetReadOnlyResponse) Reset

func (x *SetReadOnlyResponse) Reset()

func (*SetReadOnlyResponse) SizeVT

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

func (*SetReadOnlyResponse) String

func (x *SetReadOnlyResponse) String() string

func (*SetReadOnlyResponse) UnmarshalVT

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

type SetReadWriteRequest

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

func (*SetReadWriteRequest) Descriptor

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

Deprecated: Use SetReadWriteRequest.ProtoReflect.Descriptor instead.

func (*SetReadWriteRequest) MarshalToSizedBufferVT

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

func (*SetReadWriteRequest) MarshalToVT

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

func (*SetReadWriteRequest) MarshalVT

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

func (*SetReadWriteRequest) ProtoMessage

func (*SetReadWriteRequest) ProtoMessage()

func (*SetReadWriteRequest) ProtoReflect

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

func (*SetReadWriteRequest) Reset

func (x *SetReadWriteRequest) Reset()

func (*SetReadWriteRequest) SizeVT

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

func (*SetReadWriteRequest) String

func (x *SetReadWriteRequest) String() string

func (*SetReadWriteRequest) UnmarshalVT

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

type SetReadWriteResponse

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

func (*SetReadWriteResponse) Descriptor

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

Deprecated: Use SetReadWriteResponse.ProtoReflect.Descriptor instead.

func (*SetReadWriteResponse) MarshalToSizedBufferVT

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

func (*SetReadWriteResponse) MarshalToVT

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

func (*SetReadWriteResponse) MarshalVT

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

func (*SetReadWriteResponse) ProtoMessage

func (*SetReadWriteResponse) ProtoMessage()

func (*SetReadWriteResponse) ProtoReflect

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

func (*SetReadWriteResponse) Reset

func (x *SetReadWriteResponse) Reset()

func (*SetReadWriteResponse) SizeVT

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

func (*SetReadWriteResponse) String

func (x *SetReadWriteResponse) String() string

func (*SetReadWriteResponse) UnmarshalVT

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

type SetReplicationSourceRequest

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

func (*SetReplicationSourceRequest) Descriptor

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

Deprecated: Use SetReplicationSourceRequest.ProtoReflect.Descriptor instead.

func (*SetReplicationSourceRequest) GetForceStartReplication

func (x *SetReplicationSourceRequest) GetForceStartReplication() bool

func (*SetReplicationSourceRequest) GetParent

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

func (*SetReplicationSourceRequest) GetSemiSync

func (x *SetReplicationSourceRequest) GetSemiSync() bool

func (*SetReplicationSourceRequest) GetTimeCreatedNs

func (x *SetReplicationSourceRequest) GetTimeCreatedNs() int64

func (*SetReplicationSourceRequest) GetWaitPosition

func (x *SetReplicationSourceRequest) GetWaitPosition() string

func (*SetReplicationSourceRequest) MarshalToSizedBufferVT

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

func (*SetReplicationSourceRequest) MarshalToVT

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

func (*SetReplicationSourceRequest) MarshalVT

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

func (*SetReplicationSourceRequest) ProtoMessage

func (*SetReplicationSourceRequest) ProtoMessage()

func (*SetReplicationSourceRequest) ProtoReflect

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

func (*SetReplicationSourceRequest) Reset

func (x *SetReplicationSourceRequest) Reset()

func (*SetReplicationSourceRequest) SizeVT

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

func (*SetReplicationSourceRequest) String

func (x *SetReplicationSourceRequest) String() string

func (*SetReplicationSourceRequest) UnmarshalVT

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

type SetReplicationSourceResponse

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

func (*SetReplicationSourceResponse) Descriptor

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

Deprecated: Use SetReplicationSourceResponse.ProtoReflect.Descriptor instead.

func (*SetReplicationSourceResponse) MarshalToSizedBufferVT

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

func (*SetReplicationSourceResponse) MarshalToVT

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

func (*SetReplicationSourceResponse) MarshalVT

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

func (*SetReplicationSourceResponse) ProtoMessage

func (*SetReplicationSourceResponse) ProtoMessage()

func (*SetReplicationSourceResponse) ProtoReflect

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

func (*SetReplicationSourceResponse) Reset

func (x *SetReplicationSourceResponse) Reset()

func (*SetReplicationSourceResponse) SizeVT

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

func (*SetReplicationSourceResponse) String

func (x *SetReplicationSourceResponse) String() string

func (*SetReplicationSourceResponse) UnmarshalVT

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

type SleepRequest

type SleepRequest struct {

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

func (*SleepRequest) Descriptor

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

Deprecated: Use SleepRequest.ProtoReflect.Descriptor instead.

func (*SleepRequest) GetDuration

func (x *SleepRequest) GetDuration() int64

func (*SleepRequest) MarshalToSizedBufferVT

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

func (*SleepRequest) MarshalToVT

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

func (*SleepRequest) MarshalVT

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

func (*SleepRequest) ProtoMessage

func (*SleepRequest) ProtoMessage()

func (*SleepRequest) ProtoReflect

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

func (*SleepRequest) Reset

func (x *SleepRequest) Reset()

func (*SleepRequest) SizeVT

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

func (*SleepRequest) String

func (x *SleepRequest) String() string

func (*SleepRequest) UnmarshalVT

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

type SleepResponse

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

func (*SleepResponse) Descriptor

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

Deprecated: Use SleepResponse.ProtoReflect.Descriptor instead.

func (*SleepResponse) MarshalToSizedBufferVT

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

func (*SleepResponse) MarshalToVT

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

func (*SleepResponse) MarshalVT

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

func (*SleepResponse) ProtoMessage

func (*SleepResponse) ProtoMessage()

func (*SleepResponse) ProtoReflect

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

func (*SleepResponse) Reset

func (x *SleepResponse) Reset()

func (*SleepResponse) SizeVT

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

func (*SleepResponse) String

func (x *SleepResponse) String() string

func (*SleepResponse) UnmarshalVT

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

type StartReplicationRequest

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

func (*StartReplicationRequest) Descriptor

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

Deprecated: Use StartReplicationRequest.ProtoReflect.Descriptor instead.

func (*StartReplicationRequest) GetSemiSync

func (x *StartReplicationRequest) GetSemiSync() bool

func (*StartReplicationRequest) MarshalToSizedBufferVT

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

func (*StartReplicationRequest) MarshalToVT

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

func (*StartReplicationRequest) MarshalVT

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

func (*StartReplicationRequest) ProtoMessage

func (*StartReplicationRequest) ProtoMessage()

func (*StartReplicationRequest) ProtoReflect

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

func (*StartReplicationRequest) Reset

func (x *StartReplicationRequest) Reset()

func (*StartReplicationRequest) SizeVT

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

func (*StartReplicationRequest) String

func (x *StartReplicationRequest) String() string

func (*StartReplicationRequest) UnmarshalVT

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

type StartReplicationResponse

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

func (*StartReplicationResponse) Descriptor

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

Deprecated: Use StartReplicationResponse.ProtoReflect.Descriptor instead.

func (*StartReplicationResponse) MarshalToSizedBufferVT

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

func (*StartReplicationResponse) MarshalToVT

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

func (*StartReplicationResponse) MarshalVT

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

func (*StartReplicationResponse) ProtoMessage

func (*StartReplicationResponse) ProtoMessage()

func (*StartReplicationResponse) ProtoReflect

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

func (*StartReplicationResponse) Reset

func (x *StartReplicationResponse) Reset()

func (*StartReplicationResponse) SizeVT

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

func (*StartReplicationResponse) String

func (x *StartReplicationResponse) String() string

func (*StartReplicationResponse) UnmarshalVT

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

type StartReplicationUntilAfterRequest

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

func (*StartReplicationUntilAfterRequest) Descriptor

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

Deprecated: Use StartReplicationUntilAfterRequest.ProtoReflect.Descriptor instead.

func (*StartReplicationUntilAfterRequest) GetPosition

func (x *StartReplicationUntilAfterRequest) GetPosition() string

func (*StartReplicationUntilAfterRequest) GetWaitTimeout

func (x *StartReplicationUntilAfterRequest) GetWaitTimeout() int64

func (*StartReplicationUntilAfterRequest) MarshalToSizedBufferVT

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

func (*StartReplicationUntilAfterRequest) MarshalToVT

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

func (*StartReplicationUntilAfterRequest) MarshalVT

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

func (*StartReplicationUntilAfterRequest) ProtoMessage

func (*StartReplicationUntilAfterRequest) ProtoMessage()

func (*StartReplicationUntilAfterRequest) ProtoReflect

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

func (*StartReplicationUntilAfterRequest) Reset

func (x *StartReplicationUntilAfterRequest) Reset()

func (*StartReplicationUntilAfterRequest) SizeVT

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

func (*StartReplicationUntilAfterRequest) String

func (x *StartReplicationUntilAfterRequest) String() string

func (*StartReplicationUntilAfterRequest) UnmarshalVT

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

type StartReplicationUntilAfterResponse

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

func (*StartReplicationUntilAfterResponse) Descriptor

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

Deprecated: Use StartReplicationUntilAfterResponse.ProtoReflect.Descriptor instead.

func (*StartReplicationUntilAfterResponse) MarshalToSizedBufferVT

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

func (*StartReplicationUntilAfterResponse) MarshalToVT

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

func (*StartReplicationUntilAfterResponse) MarshalVT

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

func (*StartReplicationUntilAfterResponse) ProtoMessage

func (*StartReplicationUntilAfterResponse) ProtoMessage()

func (*StartReplicationUntilAfterResponse) ProtoReflect

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

func (*StartReplicationUntilAfterResponse) Reset

func (x *StartReplicationUntilAfterResponse) Reset()

func (*StartReplicationUntilAfterResponse) SizeVT

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

func (*StartReplicationUntilAfterResponse) String

func (x *StartReplicationUntilAfterResponse) String() string

func (*StartReplicationUntilAfterResponse) UnmarshalVT

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

type StopReplicationAndGetStatusRequest

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

func (*StopReplicationAndGetStatusRequest) Descriptor

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

Deprecated: Use StopReplicationAndGetStatusRequest.ProtoReflect.Descriptor instead.

func (*StopReplicationAndGetStatusRequest) GetStopReplicationMode

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

func (*StopReplicationAndGetStatusRequest) MarshalToSizedBufferVT

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

func (*StopReplicationAndGetStatusRequest) MarshalToVT

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

func (*StopReplicationAndGetStatusRequest) MarshalVT

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

func (*StopReplicationAndGetStatusRequest) ProtoMessage

func (*StopReplicationAndGetStatusRequest) ProtoMessage()

func (*StopReplicationAndGetStatusRequest) ProtoReflect

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

func (*StopReplicationAndGetStatusRequest) Reset

func (x *StopReplicationAndGetStatusRequest) Reset()

func (*StopReplicationAndGetStatusRequest) SizeVT

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

func (*StopReplicationAndGetStatusRequest) String

func (x *StopReplicationAndGetStatusRequest) String() string

func (*StopReplicationAndGetStatusRequest) UnmarshalVT

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

type StopReplicationAndGetStatusResponse

type StopReplicationAndGetStatusResponse struct {

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

func (*StopReplicationAndGetStatusResponse) Descriptor

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

Deprecated: Use StopReplicationAndGetStatusResponse.ProtoReflect.Descriptor instead.

func (*StopReplicationAndGetStatusResponse) GetStatus

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

func (*StopReplicationAndGetStatusResponse) MarshalToSizedBufferVT

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

func (*StopReplicationAndGetStatusResponse) MarshalToVT

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

func (*StopReplicationAndGetStatusResponse) MarshalVT

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

func (*StopReplicationAndGetStatusResponse) ProtoMessage

func (*StopReplicationAndGetStatusResponse) ProtoMessage()

func (*StopReplicationAndGetStatusResponse) ProtoReflect

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

func (*StopReplicationAndGetStatusResponse) Reset

func (x *StopReplicationAndGetStatusResponse) Reset()

func (*StopReplicationAndGetStatusResponse) SizeVT

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

func (*StopReplicationAndGetStatusResponse) String

func (x *StopReplicationAndGetStatusResponse) String() string

func (*StopReplicationAndGetStatusResponse) UnmarshalVT

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

type StopReplicationMinimumRequest

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

func (*StopReplicationMinimumRequest) Descriptor

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

Deprecated: Use StopReplicationMinimumRequest.ProtoReflect.Descriptor instead.

func (*StopReplicationMinimumRequest) GetPosition

func (x *StopReplicationMinimumRequest) GetPosition() string

func (*StopReplicationMinimumRequest) GetWaitTimeout

func (x *StopReplicationMinimumRequest) GetWaitTimeout() int64

func (*StopReplicationMinimumRequest) MarshalToSizedBufferVT

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

func (*StopReplicationMinimumRequest) MarshalToVT

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

func (*StopReplicationMinimumRequest) MarshalVT

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

func (*StopReplicationMinimumRequest) ProtoMessage

func (*StopReplicationMinimumRequest) ProtoMessage()

func (*StopReplicationMinimumRequest) ProtoReflect

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

func (*StopReplicationMinimumRequest) Reset

func (x *StopReplicationMinimumRequest) Reset()

func (*StopReplicationMinimumRequest) SizeVT

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

func (*StopReplicationMinimumRequest) String

func (x *StopReplicationMinimumRequest) String() string

func (*StopReplicationMinimumRequest) UnmarshalVT

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

type StopReplicationMinimumResponse

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

func (*StopReplicationMinimumResponse) Descriptor

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

Deprecated: Use StopReplicationMinimumResponse.ProtoReflect.Descriptor instead.

func (*StopReplicationMinimumResponse) GetPosition

func (x *StopReplicationMinimumResponse) GetPosition() string

func (*StopReplicationMinimumResponse) MarshalToSizedBufferVT

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

func (*StopReplicationMinimumResponse) MarshalToVT

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

func (*StopReplicationMinimumResponse) MarshalVT

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

func (*StopReplicationMinimumResponse) ProtoMessage

func (*StopReplicationMinimumResponse) ProtoMessage()

func (*StopReplicationMinimumResponse) ProtoReflect

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

func (*StopReplicationMinimumResponse) Reset

func (x *StopReplicationMinimumResponse) Reset()

func (*StopReplicationMinimumResponse) SizeVT

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

func (*StopReplicationMinimumResponse) String

func (x *StopReplicationMinimumResponse) String() string

func (*StopReplicationMinimumResponse) UnmarshalVT

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

type StopReplicationRequest

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

func (*StopReplicationRequest) Descriptor

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

Deprecated: Use StopReplicationRequest.ProtoReflect.Descriptor instead.

func (*StopReplicationRequest) MarshalToSizedBufferVT

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

func (*StopReplicationRequest) MarshalToVT

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

func (*StopReplicationRequest) MarshalVT

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

func (*StopReplicationRequest) ProtoMessage

func (*StopReplicationRequest) ProtoMessage()

func (*StopReplicationRequest) ProtoReflect

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

func (*StopReplicationRequest) Reset

func (x *StopReplicationRequest) Reset()

func (*StopReplicationRequest) SizeVT

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

func (*StopReplicationRequest) String

func (x *StopReplicationRequest) String() string

func (*StopReplicationRequest) UnmarshalVT

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

type StopReplicationResponse

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

func (*StopReplicationResponse) Descriptor

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

Deprecated: Use StopReplicationResponse.ProtoReflect.Descriptor instead.

func (*StopReplicationResponse) MarshalToSizedBufferVT

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

func (*StopReplicationResponse) MarshalToVT

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

func (*StopReplicationResponse) MarshalVT

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

func (*StopReplicationResponse) ProtoMessage

func (*StopReplicationResponse) ProtoMessage()

func (*StopReplicationResponse) ProtoReflect

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

func (*StopReplicationResponse) Reset

func (x *StopReplicationResponse) Reset()

func (*StopReplicationResponse) SizeVT

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

func (*StopReplicationResponse) String

func (x *StopReplicationResponse) String() string

func (*StopReplicationResponse) UnmarshalVT

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

type TableDefinition

type TableDefinition struct {

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

func (*TableDefinition) Descriptor

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

Deprecated: Use TableDefinition.ProtoReflect.Descriptor instead.

func (*TableDefinition) GetColumns

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

func (*TableDefinition) GetDataLength

func (x *TableDefinition) GetDataLength() uint64

func (*TableDefinition) GetFields

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

func (*TableDefinition) GetName

func (x *TableDefinition) GetName() string

func (*TableDefinition) GetPrimaryKeyColumns

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

func (*TableDefinition) GetRowCount

func (x *TableDefinition) GetRowCount() uint64

func (*TableDefinition) GetSchema

func (x *TableDefinition) GetSchema() string

func (*TableDefinition) GetType

func (x *TableDefinition) GetType() string

func (*TableDefinition) MarshalToSizedBufferVT

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

func (*TableDefinition) MarshalToVT

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

func (*TableDefinition) MarshalVT

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

func (*TableDefinition) ProtoMessage

func (*TableDefinition) ProtoMessage()

func (*TableDefinition) ProtoReflect

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

func (*TableDefinition) Reset

func (x *TableDefinition) Reset()

func (*TableDefinition) SizeVT

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

func (*TableDefinition) String

func (x *TableDefinition) String() string

func (*TableDefinition) UnmarshalVT

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

type UndoDemotePrimaryRequest

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

func (*UndoDemotePrimaryRequest) Descriptor

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

Deprecated: Use UndoDemotePrimaryRequest.ProtoReflect.Descriptor instead.

func (*UndoDemotePrimaryRequest) GetSemiSync

func (x *UndoDemotePrimaryRequest) GetSemiSync() bool

func (*UndoDemotePrimaryRequest) MarshalToSizedBufferVT

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

func (*UndoDemotePrimaryRequest) MarshalToVT

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

func (*UndoDemotePrimaryRequest) MarshalVT

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

func (*UndoDemotePrimaryRequest) ProtoMessage

func (*UndoDemotePrimaryRequest) ProtoMessage()

func (*UndoDemotePrimaryRequest) ProtoReflect

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

func (*UndoDemotePrimaryRequest) Reset

func (x *UndoDemotePrimaryRequest) Reset()

func (*UndoDemotePrimaryRequest) SizeVT

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

func (*UndoDemotePrimaryRequest) String

func (x *UndoDemotePrimaryRequest) String() string

func (*UndoDemotePrimaryRequest) UnmarshalVT

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

type UndoDemotePrimaryResponse

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

func (*UndoDemotePrimaryResponse) Descriptor

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

Deprecated: Use UndoDemotePrimaryResponse.ProtoReflect.Descriptor instead.

func (*UndoDemotePrimaryResponse) MarshalToSizedBufferVT

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

func (*UndoDemotePrimaryResponse) MarshalToVT

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

func (*UndoDemotePrimaryResponse) MarshalVT

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

func (*UndoDemotePrimaryResponse) ProtoMessage

func (*UndoDemotePrimaryResponse) ProtoMessage()

func (*UndoDemotePrimaryResponse) ProtoReflect

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

func (*UndoDemotePrimaryResponse) Reset

func (x *UndoDemotePrimaryResponse) Reset()

func (*UndoDemotePrimaryResponse) SizeVT

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

func (*UndoDemotePrimaryResponse) String

func (x *UndoDemotePrimaryResponse) String() string

func (*UndoDemotePrimaryResponse) UnmarshalVT

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

type UnlockTablesRequest

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

func (*UnlockTablesRequest) Descriptor

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

Deprecated: Use UnlockTablesRequest.ProtoReflect.Descriptor instead.

func (*UnlockTablesRequest) MarshalToSizedBufferVT

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

func (*UnlockTablesRequest) MarshalToVT

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

func (*UnlockTablesRequest) MarshalVT

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

func (*UnlockTablesRequest) ProtoMessage

func (*UnlockTablesRequest) ProtoMessage()

func (*UnlockTablesRequest) ProtoReflect

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

func (*UnlockTablesRequest) Reset

func (x *UnlockTablesRequest) Reset()

func (*UnlockTablesRequest) SizeVT

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

func (*UnlockTablesRequest) String

func (x *UnlockTablesRequest) String() string

func (*UnlockTablesRequest) UnmarshalVT

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

type UnlockTablesResponse

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

func (*UnlockTablesResponse) Descriptor

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

Deprecated: Use UnlockTablesResponse.ProtoReflect.Descriptor instead.

func (*UnlockTablesResponse) MarshalToSizedBufferVT

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

func (*UnlockTablesResponse) MarshalToVT

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

func (*UnlockTablesResponse) MarshalVT

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

func (*UnlockTablesResponse) ProtoMessage

func (*UnlockTablesResponse) ProtoMessage()

func (*UnlockTablesResponse) ProtoReflect

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

func (*UnlockTablesResponse) Reset

func (x *UnlockTablesResponse) Reset()

func (*UnlockTablesResponse) SizeVT

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

func (*UnlockTablesResponse) String

func (x *UnlockTablesResponse) String() string

func (*UnlockTablesResponse) UnmarshalVT

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

type 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

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

Deprecated: Use UserPermission.ProtoReflect.Descriptor instead.

func (*UserPermission) GetHost

func (x *UserPermission) GetHost() string

func (*UserPermission) GetPasswordChecksum

func (x *UserPermission) GetPasswordChecksum() uint64

func (*UserPermission) GetPrivileges

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

func (*UserPermission) GetUser

func (x *UserPermission) GetUser() string

func (*UserPermission) MarshalToSizedBufferVT

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

func (*UserPermission) MarshalToVT

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

func (*UserPermission) MarshalVT

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

func (*UserPermission) ProtoMessage

func (*UserPermission) ProtoMessage()

func (*UserPermission) ProtoReflect

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

func (*UserPermission) Reset

func (x *UserPermission) Reset()

func (*UserPermission) SizeVT

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

func (*UserPermission) String

func (x *UserPermission) String() string

func (*UserPermission) UnmarshalVT

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

type VDiffCoreOptions

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

func (*VDiffCoreOptions) Descriptor

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

Deprecated: Use VDiffCoreOptions.ProtoReflect.Descriptor instead.

func (*VDiffCoreOptions) GetAutoRetry

func (x *VDiffCoreOptions) GetAutoRetry() bool

func (*VDiffCoreOptions) GetChecksum

func (x *VDiffCoreOptions) GetChecksum() bool

func (*VDiffCoreOptions) GetMaxExtraRowsToCompare

func (x *VDiffCoreOptions) GetMaxExtraRowsToCompare() int64

func (*VDiffCoreOptions) GetMaxRows

func (x *VDiffCoreOptions) GetMaxRows() int64

func (*VDiffCoreOptions) GetSamplePct

func (x *VDiffCoreOptions) GetSamplePct() int64

func (*VDiffCoreOptions) GetTables

func (x *VDiffCoreOptions) GetTables() string

func (*VDiffCoreOptions) GetTimeoutSeconds

func (x *VDiffCoreOptions) GetTimeoutSeconds() int64

func (*VDiffCoreOptions) MarshalToSizedBufferVT

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

func (*VDiffCoreOptions) MarshalToVT

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

func (*VDiffCoreOptions) MarshalVT

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

func (*VDiffCoreOptions) ProtoMessage

func (*VDiffCoreOptions) ProtoMessage()

func (*VDiffCoreOptions) ProtoReflect

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

func (*VDiffCoreOptions) Reset

func (x *VDiffCoreOptions) Reset()

func (*VDiffCoreOptions) SizeVT

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

func (*VDiffCoreOptions) String

func (x *VDiffCoreOptions) String() string

func (*VDiffCoreOptions) UnmarshalVT

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

type VDiffOptions

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

func (*VDiffOptions) Descriptor

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

Deprecated: Use VDiffOptions.ProtoReflect.Descriptor instead.

func (*VDiffOptions) GetCoreOptions

func (x *VDiffOptions) GetCoreOptions() *VDiffCoreOptions

func (*VDiffOptions) GetPickerOptions

func (x *VDiffOptions) GetPickerOptions() *VDiffPickerOptions

func (*VDiffOptions) GetReportOptions

func (x *VDiffOptions) GetReportOptions() *VDiffReportOptions

func (*VDiffOptions) MarshalToSizedBufferVT

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

func (*VDiffOptions) MarshalToVT

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

func (*VDiffOptions) MarshalVT

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

func (*VDiffOptions) ProtoMessage

func (*VDiffOptions) ProtoMessage()

func (*VDiffOptions) ProtoReflect

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

func (*VDiffOptions) Reset

func (x *VDiffOptions) Reset()

func (*VDiffOptions) SizeVT

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

func (*VDiffOptions) String

func (x *VDiffOptions) String() string

func (*VDiffOptions) UnmarshalVT

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

type VDiffPickerOptions

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

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

func (*VDiffPickerOptions) Descriptor

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

Deprecated: Use VDiffPickerOptions.ProtoReflect.Descriptor instead.

func (*VDiffPickerOptions) GetSourceCell

func (x *VDiffPickerOptions) GetSourceCell() string

func (*VDiffPickerOptions) GetTabletTypes

func (x *VDiffPickerOptions) GetTabletTypes() string

func (*VDiffPickerOptions) GetTargetCell

func (x *VDiffPickerOptions) GetTargetCell() string

func (*VDiffPickerOptions) MarshalToSizedBufferVT

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

func (*VDiffPickerOptions) MarshalToVT

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

func (*VDiffPickerOptions) MarshalVT

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

func (*VDiffPickerOptions) ProtoMessage

func (*VDiffPickerOptions) ProtoMessage()

func (*VDiffPickerOptions) ProtoReflect

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

func (*VDiffPickerOptions) Reset

func (x *VDiffPickerOptions) Reset()

func (*VDiffPickerOptions) SizeVT

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

func (*VDiffPickerOptions) String

func (x *VDiffPickerOptions) String() string

func (*VDiffPickerOptions) UnmarshalVT

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

type VDiffReportOptions

type VDiffReportOptions struct {
	OnlyPKS    bool   `protobuf:"varint,1,opt,name=only_p_k_s,json=onlyPKS,proto3" json:"only_p_k_s,omitempty"`
	DebugQuery bool   `protobuf:"varint,2,opt,name=debug_query,json=debugQuery,proto3" json:"debug_query,omitempty"`
	Format     string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// contains filtered or unexported fields
}

options that only influence how vdiff differences are reported

func (*VDiffReportOptions) Descriptor

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

Deprecated: Use VDiffReportOptions.ProtoReflect.Descriptor instead.

func (*VDiffReportOptions) GetDebugQuery

func (x *VDiffReportOptions) GetDebugQuery() bool

func (*VDiffReportOptions) GetFormat

func (x *VDiffReportOptions) GetFormat() string

func (*VDiffReportOptions) GetOnlyPKS

func (x *VDiffReportOptions) GetOnlyPKS() bool

func (*VDiffReportOptions) MarshalToSizedBufferVT

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

func (*VDiffReportOptions) MarshalToVT

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

func (*VDiffReportOptions) MarshalVT

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

func (*VDiffReportOptions) ProtoMessage

func (*VDiffReportOptions) ProtoMessage()

func (*VDiffReportOptions) ProtoReflect

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

func (*VDiffReportOptions) Reset

func (x *VDiffReportOptions) Reset()

func (*VDiffReportOptions) SizeVT

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

func (*VDiffReportOptions) String

func (x *VDiffReportOptions) String() string

func (*VDiffReportOptions) UnmarshalVT

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

type VDiffRequest

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

func (*VDiffRequest) Descriptor

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

Deprecated: Use VDiffRequest.ProtoReflect.Descriptor instead.

func (*VDiffRequest) GetAction

func (x *VDiffRequest) GetAction() string

func (*VDiffRequest) GetActionArg

func (x *VDiffRequest) GetActionArg() string

func (*VDiffRequest) GetKeyspace

func (x *VDiffRequest) GetKeyspace() string

func (*VDiffRequest) GetOptions

func (x *VDiffRequest) GetOptions() *VDiffOptions

func (*VDiffRequest) GetVdiffUuid

func (x *VDiffRequest) GetVdiffUuid() string

func (*VDiffRequest) GetWorkflow

func (x *VDiffRequest) GetWorkflow() string

func (*VDiffRequest) MarshalToSizedBufferVT

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

func (*VDiffRequest) MarshalToVT

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

func (*VDiffRequest) MarshalVT

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

func (*VDiffRequest) ProtoMessage

func (*VDiffRequest) ProtoMessage()

func (*VDiffRequest) ProtoReflect

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

func (*VDiffRequest) Reset

func (x *VDiffRequest) Reset()

func (*VDiffRequest) SizeVT

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

func (*VDiffRequest) String

func (x *VDiffRequest) String() string

func (*VDiffRequest) UnmarshalVT

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

type VDiffResponse

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

func (*VDiffResponse) Descriptor

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

Deprecated: Use VDiffResponse.ProtoReflect.Descriptor instead.

func (*VDiffResponse) GetId

func (x *VDiffResponse) GetId() int64

func (*VDiffResponse) GetOutput

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

func (*VDiffResponse) GetVdiffUuid

func (x *VDiffResponse) GetVdiffUuid() string

func (*VDiffResponse) MarshalToSizedBufferVT

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

func (*VDiffResponse) MarshalToVT

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

func (*VDiffResponse) MarshalVT

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

func (*VDiffResponse) ProtoMessage

func (*VDiffResponse) ProtoMessage()

func (*VDiffResponse) ProtoReflect

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

func (*VDiffResponse) Reset

func (x *VDiffResponse) Reset()

func (*VDiffResponse) SizeVT

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

func (*VDiffResponse) String

func (x *VDiffResponse) String() string

func (*VDiffResponse) UnmarshalVT

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

type VExecRequest

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

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

Deprecated: Use VExecRequest.ProtoReflect.Descriptor instead.

func (*VExecRequest) GetKeyspace

func (x *VExecRequest) GetKeyspace() string

func (*VExecRequest) GetQuery

func (x *VExecRequest) GetQuery() string

func (*VExecRequest) GetWorkflow

func (x *VExecRequest) GetWorkflow() string

func (*VExecRequest) MarshalToSizedBufferVT

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

func (*VExecRequest) MarshalToVT

func (m *VExecRequest) MarshalToVT(dAtA []byte) (int, error)

func (*VExecRequest) MarshalVT

func (m *VExecRequest) MarshalVT() (dAtA []byte, err error)

func (*VExecRequest) ProtoMessage

func (*VExecRequest) ProtoMessage()

func (*VExecRequest) ProtoReflect

func (x *VExecRequest) ProtoReflect() protoreflect.Message

func (*VExecRequest) Reset

func (x *VExecRequest) Reset()

func (*VExecRequest) SizeVT

func (m *VExecRequest) SizeVT() (n int)

func (*VExecRequest) String

func (x *VExecRequest) String() string

func (*VExecRequest) UnmarshalVT

func (m *VExecRequest) UnmarshalVT(dAtA []byte) error

type VExecResponse

type VExecResponse struct {
	Result *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*VExecResponse) Descriptor

func (*VExecResponse) Descriptor() ([]byte, []int)

Deprecated: Use VExecResponse.ProtoReflect.Descriptor instead.

func (*VExecResponse) GetResult

func (x *VExecResponse) GetResult() *query.QueryResult

func (*VExecResponse) MarshalToSizedBufferVT

func (m *VExecResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VExecResponse) MarshalToVT

func (m *VExecResponse) MarshalToVT(dAtA []byte) (int, error)

func (*VExecResponse) MarshalVT

func (m *VExecResponse) MarshalVT() (dAtA []byte, err error)

func (*VExecResponse) ProtoMessage

func (*VExecResponse) ProtoMessage()

func (*VExecResponse) ProtoReflect

func (x *VExecResponse) ProtoReflect() protoreflect.Message

func (*VExecResponse) Reset

func (x *VExecResponse) Reset()

func (*VExecResponse) SizeVT

func (m *VExecResponse) SizeVT() (n int)

func (*VExecResponse) String

func (x *VExecResponse) String() string

func (*VExecResponse) UnmarshalVT

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

func (*VReplicationExecRequest) Descriptor() ([]byte, []int)

Deprecated: Use VReplicationExecRequest.ProtoReflect.Descriptor instead.

func (*VReplicationExecRequest) GetQuery

func (x *VReplicationExecRequest) GetQuery() string

func (*VReplicationExecRequest) MarshalToSizedBufferVT

func (m *VReplicationExecRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VReplicationExecRequest) MarshalToVT

func (m *VReplicationExecRequest) MarshalToVT(dAtA []byte) (int, error)

func (*VReplicationExecRequest) MarshalVT

func (m *VReplicationExecRequest) MarshalVT() (dAtA []byte, err error)

func (*VReplicationExecRequest) ProtoMessage

func (*VReplicationExecRequest) ProtoMessage()

func (*VReplicationExecRequest) ProtoReflect

func (x *VReplicationExecRequest) ProtoReflect() protoreflect.Message

func (*VReplicationExecRequest) Reset

func (x *VReplicationExecRequest) Reset()

func (*VReplicationExecRequest) SizeVT

func (m *VReplicationExecRequest) SizeVT() (n int)

func (*VReplicationExecRequest) String

func (x *VReplicationExecRequest) String() string

func (*VReplicationExecRequest) UnmarshalVT

func (m *VReplicationExecRequest) UnmarshalVT(dAtA []byte) error

type VReplicationExecResponse

type VReplicationExecResponse struct {
	Result *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*VReplicationExecResponse) Descriptor

func (*VReplicationExecResponse) Descriptor() ([]byte, []int)

Deprecated: Use VReplicationExecResponse.ProtoReflect.Descriptor instead.

func (*VReplicationExecResponse) GetResult

func (x *VReplicationExecResponse) GetResult() *query.QueryResult

func (*VReplicationExecResponse) MarshalToSizedBufferVT

func (m *VReplicationExecResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VReplicationExecResponse) MarshalToVT

func (m *VReplicationExecResponse) MarshalToVT(dAtA []byte) (int, error)

func (*VReplicationExecResponse) MarshalVT

func (m *VReplicationExecResponse) MarshalVT() (dAtA []byte, err error)

func (*VReplicationExecResponse) ProtoMessage

func (*VReplicationExecResponse) ProtoMessage()

func (*VReplicationExecResponse) ProtoReflect

func (x *VReplicationExecResponse) ProtoReflect() protoreflect.Message

func (*VReplicationExecResponse) Reset

func (x *VReplicationExecResponse) Reset()

func (*VReplicationExecResponse) SizeVT

func (m *VReplicationExecResponse) SizeVT() (n int)

func (*VReplicationExecResponse) String

func (x *VReplicationExecResponse) String() string

func (*VReplicationExecResponse) UnmarshalVT

func (m *VReplicationExecResponse) UnmarshalVT(dAtA []byte) error

type VReplicationWaitForPosRequest

type VReplicationWaitForPosRequest struct {
	Id       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

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

func (m *VReplicationWaitForPosRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VReplicationWaitForPosRequest) MarshalToVT

func (m *VReplicationWaitForPosRequest) MarshalToVT(dAtA []byte) (int, error)

func (*VReplicationWaitForPosRequest) MarshalVT

func (m *VReplicationWaitForPosRequest) MarshalVT() (dAtA []byte, err error)

func (*VReplicationWaitForPosRequest) ProtoMessage

func (*VReplicationWaitForPosRequest) ProtoMessage()

func (*VReplicationWaitForPosRequest) ProtoReflect

func (x *VReplicationWaitForPosRequest) ProtoReflect() protoreflect.Message

func (*VReplicationWaitForPosRequest) Reset

func (x *VReplicationWaitForPosRequest) Reset()

func (*VReplicationWaitForPosRequest) SizeVT

func (m *VReplicationWaitForPosRequest) SizeVT() (n int)

func (*VReplicationWaitForPosRequest) String

func (x *VReplicationWaitForPosRequest) String() string

func (*VReplicationWaitForPosRequest) UnmarshalVT

func (m *VReplicationWaitForPosRequest) UnmarshalVT(dAtA []byte) error

type VReplicationWaitForPosResponse

type VReplicationWaitForPosResponse struct {
	// contains filtered or unexported fields
}

func (*VReplicationWaitForPosResponse) Descriptor

func (*VReplicationWaitForPosResponse) Descriptor() ([]byte, []int)

Deprecated: Use VReplicationWaitForPosResponse.ProtoReflect.Descriptor instead.

func (*VReplicationWaitForPosResponse) MarshalToSizedBufferVT

func (m *VReplicationWaitForPosResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VReplicationWaitForPosResponse) MarshalToVT

func (m *VReplicationWaitForPosResponse) MarshalToVT(dAtA []byte) (int, error)

func (*VReplicationWaitForPosResponse) MarshalVT

func (m *VReplicationWaitForPosResponse) MarshalVT() (dAtA []byte, err error)

func (*VReplicationWaitForPosResponse) ProtoMessage

func (*VReplicationWaitForPosResponse) ProtoMessage()

func (*VReplicationWaitForPosResponse) ProtoReflect

func (x *VReplicationWaitForPosResponse) ProtoReflect() protoreflect.Message

func (*VReplicationWaitForPosResponse) Reset

func (x *VReplicationWaitForPosResponse) Reset()

func (*VReplicationWaitForPosResponse) SizeVT

func (m *VReplicationWaitForPosResponse) SizeVT() (n int)

func (*VReplicationWaitForPosResponse) String

func (x *VReplicationWaitForPosResponse) String() string

func (*VReplicationWaitForPosResponse) UnmarshalVT

func (m *VReplicationWaitForPosResponse) UnmarshalVT(dAtA []byte) error

type WaitForPositionRequest

type WaitForPositionRequest struct {
	Position string `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitForPositionRequest) Descriptor

func (*WaitForPositionRequest) Descriptor() ([]byte, []int)

Deprecated: Use WaitForPositionRequest.ProtoReflect.Descriptor instead.

func (*WaitForPositionRequest) GetPosition

func (x *WaitForPositionRequest) GetPosition() string

func (*WaitForPositionRequest) MarshalToSizedBufferVT

func (m *WaitForPositionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WaitForPositionRequest) MarshalToVT

func (m *WaitForPositionRequest) MarshalToVT(dAtA []byte) (int, error)

func (*WaitForPositionRequest) MarshalVT

func (m *WaitForPositionRequest) MarshalVT() (dAtA []byte, err error)

func (*WaitForPositionRequest) ProtoMessage

func (*WaitForPositionRequest) ProtoMessage()

func (*WaitForPositionRequest) ProtoReflect

func (x *WaitForPositionRequest) ProtoReflect() protoreflect.Message

func (*WaitForPositionRequest) Reset

func (x *WaitForPositionRequest) Reset()

func (*WaitForPositionRequest) SizeVT

func (m *WaitForPositionRequest) SizeVT() (n int)

func (*WaitForPositionRequest) String

func (x *WaitForPositionRequest) String() string

func (*WaitForPositionRequest) UnmarshalVT

func (m *WaitForPositionRequest) UnmarshalVT(dAtA []byte) error

type WaitForPositionResponse

type WaitForPositionResponse struct {
	// contains filtered or unexported fields
}

func (*WaitForPositionResponse) Descriptor

func (*WaitForPositionResponse) Descriptor() ([]byte, []int)

Deprecated: Use WaitForPositionResponse.ProtoReflect.Descriptor instead.

func (*WaitForPositionResponse) MarshalToSizedBufferVT

func (m *WaitForPositionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WaitForPositionResponse) MarshalToVT

func (m *WaitForPositionResponse) MarshalToVT(dAtA []byte) (int, error)

func (*WaitForPositionResponse) MarshalVT

func (m *WaitForPositionResponse) MarshalVT() (dAtA []byte, err error)

func (*WaitForPositionResponse) ProtoMessage

func (*WaitForPositionResponse) ProtoMessage()

func (*WaitForPositionResponse) ProtoReflect

func (x *WaitForPositionResponse) ProtoReflect() protoreflect.Message

func (*WaitForPositionResponse) Reset

func (x *WaitForPositionResponse) Reset()

func (*WaitForPositionResponse) SizeVT

func (m *WaitForPositionResponse) SizeVT() (n int)

func (*WaitForPositionResponse) String

func (x *WaitForPositionResponse) String() string

func (*WaitForPositionResponse) UnmarshalVT

func (m *WaitForPositionResponse) UnmarshalVT(dAtA []byte) error