vtadmin

package
v0.15.10 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Tablet_ServingState_name = map[int32]string{
		0: "UNKNOWN",
		1: "SERVING",
		2: "NOT_SERVING",
	}
	Tablet_ServingState_value = map[string]int32{
		"UNKNOWN":     0,
		"SERVING":     1,
		"NOT_SERVING": 2,
	}
)

Enum value maps for Tablet_ServingState.

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_vtadmin_proto protoreflect.FileDescriptor
View Source 
var VTAdmin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vtadmin.VTAdmin",
	HandlerType: (*VTAdminServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ApplySchema",
			Handler:    _VTAdmin_ApplySchema_Handler,
		},
		{
			MethodName: "CancelSchemaMigration",
			Handler:    _VTAdmin_CancelSchemaMigration_Handler,
		},
		{
			MethodName: "CleanupSchemaMigration",
			Handler:    _VTAdmin_CleanupSchemaMigration_Handler,
		},
		{
			MethodName: "CompleteSchemaMigration",
			Handler:    _VTAdmin_CompleteSchemaMigration_Handler,
		},
		{
			MethodName: "CreateKeyspace",
			Handler:    _VTAdmin_CreateKeyspace_Handler,
		},
		{
			MethodName: "CreateShard",
			Handler:    _VTAdmin_CreateShard_Handler,
		},
		{
			MethodName: "DeleteKeyspace",
			Handler:    _VTAdmin_DeleteKeyspace_Handler,
		},
		{
			MethodName: "DeleteShards",
			Handler:    _VTAdmin_DeleteShards_Handler,
		},
		{
			MethodName: "DeleteTablet",
			Handler:    _VTAdmin_DeleteTablet_Handler,
		},
		{
			MethodName: "EmergencyFailoverShard",
			Handler:    _VTAdmin_EmergencyFailoverShard_Handler,
		},
		{
			MethodName: "FindSchema",
			Handler:    _VTAdmin_FindSchema_Handler,
		},
		{
			MethodName: "GetBackups",
			Handler:    _VTAdmin_GetBackups_Handler,
		},
		{
			MethodName: "GetCellInfos",
			Handler:    _VTAdmin_GetCellInfos_Handler,
		},
		{
			MethodName: "GetCellsAliases",
			Handler:    _VTAdmin_GetCellsAliases_Handler,
		},
		{
			MethodName: "GetClusters",
			Handler:    _VTAdmin_GetClusters_Handler,
		},
		{
			MethodName: "GetFullStatus",
			Handler:    _VTAdmin_GetFullStatus_Handler,
		},
		{
			MethodName: "GetGates",
			Handler:    _VTAdmin_GetGates_Handler,
		},
		{
			MethodName: "GetKeyspace",
			Handler:    _VTAdmin_GetKeyspace_Handler,
		},
		{
			MethodName: "GetKeyspaces",
			Handler:    _VTAdmin_GetKeyspaces_Handler,
		},
		{
			MethodName: "GetSchema",
			Handler:    _VTAdmin_GetSchema_Handler,
		},
		{
			MethodName: "GetSchemas",
			Handler:    _VTAdmin_GetSchemas_Handler,
		},
		{
			MethodName: "GetSchemaMigrations",
			Handler:    _VTAdmin_GetSchemaMigrations_Handler,
		},
		{
			MethodName: "GetShardReplicationPositions",
			Handler:    _VTAdmin_GetShardReplicationPositions_Handler,
		},
		{
			MethodName: "GetSrvKeyspace",
			Handler:    _VTAdmin_GetSrvKeyspace_Handler,
		},
		{
			MethodName: "GetSrvKeyspaces",
			Handler:    _VTAdmin_GetSrvKeyspaces_Handler,
		},
		{
			MethodName: "GetSrvVSchema",
			Handler:    _VTAdmin_GetSrvVSchema_Handler,
		},
		{
			MethodName: "GetSrvVSchemas",
			Handler:    _VTAdmin_GetSrvVSchemas_Handler,
		},
		{
			MethodName: "GetTablet",
			Handler:    _VTAdmin_GetTablet_Handler,
		},
		{
			MethodName: "GetTablets",
			Handler:    _VTAdmin_GetTablets_Handler,
		},
		{
			MethodName: "GetTopologyPath",
			Handler:    _VTAdmin_GetTopologyPath_Handler,
		},
		{
			MethodName: "GetVSchema",
			Handler:    _VTAdmin_GetVSchema_Handler,
		},
		{
			MethodName: "GetVSchemas",
			Handler:    _VTAdmin_GetVSchemas_Handler,
		},
		{
			MethodName: "GetVtctlds",
			Handler:    _VTAdmin_GetVtctlds_Handler,
		},
		{
			MethodName: "GetWorkflow",
			Handler:    _VTAdmin_GetWorkflow_Handler,
		},
		{
			MethodName: "GetWorkflows",
			Handler:    _VTAdmin_GetWorkflows_Handler,
		},
		{
			MethodName: "LaunchSchemaMigration",
			Handler:    _VTAdmin_LaunchSchemaMigration_Handler,
		},
		{
			MethodName: "PingTablet",
			Handler:    _VTAdmin_PingTablet_Handler,
		},
		{
			MethodName: "PlannedFailoverShard",
			Handler:    _VTAdmin_PlannedFailoverShard_Handler,
		},
		{
			MethodName: "RebuildKeyspaceGraph",
			Handler:    _VTAdmin_RebuildKeyspaceGraph_Handler,
		},
		{
			MethodName: "RefreshState",
			Handler:    _VTAdmin_RefreshState_Handler,
		},
		{
			MethodName: "RefreshTabletReplicationSource",
			Handler:    _VTAdmin_RefreshTabletReplicationSource_Handler,
		},
		{
			MethodName: "ReloadSchemas",
			Handler:    _VTAdmin_ReloadSchemas_Handler,
		},
		{
			MethodName: "ReloadSchemaShard",
			Handler:    _VTAdmin_ReloadSchemaShard_Handler,
		},
		{
			MethodName: "RemoveKeyspaceCell",
			Handler:    _VTAdmin_RemoveKeyspaceCell_Handler,
		},
		{
			MethodName: "RetrySchemaMigration",
			Handler:    _VTAdmin_RetrySchemaMigration_Handler,
		},
		{
			MethodName: "RunHealthCheck",
			Handler:    _VTAdmin_RunHealthCheck_Handler,
		},
		{
			MethodName: "SetReadOnly",
			Handler:    _VTAdmin_SetReadOnly_Handler,
		},
		{
			MethodName: "SetReadWrite",
			Handler:    _VTAdmin_SetReadWrite_Handler,
		},
		{
			MethodName: "StartReplication",
			Handler:    _VTAdmin_StartReplication_Handler,
		},
		{
			MethodName: "StopReplication",
			Handler:    _VTAdmin_StopReplication_Handler,
		},
		{
			MethodName: "TabletExternallyPromoted",
			Handler:    _VTAdmin_TabletExternallyPromoted_Handler,
		},
		{
			MethodName: "Validate",
			Handler:    _VTAdmin_Validate_Handler,
		},
		{
			MethodName: "ValidateKeyspace",
			Handler:    _VTAdmin_ValidateKeyspace_Handler,
		},
		{
			MethodName: "ValidateSchemaKeyspace",
			Handler:    _VTAdmin_ValidateSchemaKeyspace_Handler,
		},
		{
			MethodName: "ValidateShard",
			Handler:    _VTAdmin_ValidateShard_Handler,
		},
		{
			MethodName: "ValidateVersionKeyspace",
			Handler:    _VTAdmin_ValidateVersionKeyspace_Handler,
		},
		{
			MethodName: "ValidateVersionShard",
			Handler:    _VTAdmin_ValidateVersionShard_Handler,
		},
		{
			MethodName: "VTExplain",
			Handler:    _VTAdmin_VTExplain_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "vtadmin.proto",
}

VTAdmin_ServiceDesc is the grpc.ServiceDesc for VTAdmin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterVTAdminServer 

func RegisterVTAdminServer(s grpc.ServiceRegistrar, srv VTAdminServer)

Types

type ApplySchemaRequest 

type ApplySchemaRequest struct {
	ClusterId string                        `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *vtctldata.ApplySchemaRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplySchemaRequest) CloneMessageVT 

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

func (*ApplySchemaRequest) CloneVT 

func (m *ApplySchemaRequest) CloneVT() *ApplySchemaRequest

func (*ApplySchemaRequest) Descriptor deprecated 

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

Deprecated: Use ApplySchemaRequest.ProtoReflect.Descriptor instead.

func (*ApplySchemaRequest) GetClusterId 

func (x *ApplySchemaRequest) GetClusterId() string

func (*ApplySchemaRequest) GetRequest 

func (x *ApplySchemaRequest) GetRequest() *vtctldata.ApplySchemaRequest

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 CancelSchemaMigrationRequest 

type CancelSchemaMigrationRequest struct {
	ClusterId string                                  `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *vtctldata.CancelSchemaMigrationRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelSchemaMigrationRequest) CloneMessageVT 

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

func (*CancelSchemaMigrationRequest) CloneVT 

func (m *CancelSchemaMigrationRequest) CloneVT() *CancelSchemaMigrationRequest

func (*CancelSchemaMigrationRequest) Descriptor deprecated 

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

Deprecated: Use CancelSchemaMigrationRequest.ProtoReflect.Descriptor instead.

func (*CancelSchemaMigrationRequest) GetClusterId 

func (x *CancelSchemaMigrationRequest) GetClusterId() string

func (*CancelSchemaMigrationRequest) GetRequest 

func (x *CancelSchemaMigrationRequest) GetRequest() *vtctldata.CancelSchemaMigrationRequest

func (*CancelSchemaMigrationRequest) MarshalToSizedBufferVT 

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

func (*CancelSchemaMigrationRequest) MarshalToVT 

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

func (*CancelSchemaMigrationRequest) MarshalVT 

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

func (*CancelSchemaMigrationRequest) ProtoMessage 

func (*CancelSchemaMigrationRequest) ProtoMessage()

func (*CancelSchemaMigrationRequest) ProtoReflect 

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

func (*CancelSchemaMigrationRequest) Reset 

func (x *CancelSchemaMigrationRequest) Reset()

func (*CancelSchemaMigrationRequest) SizeVT 

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

func (*CancelSchemaMigrationRequest) String 

func (x *CancelSchemaMigrationRequest) String() string

func (*CancelSchemaMigrationRequest) UnmarshalVT 

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

type CleanupSchemaMigrationRequest 

type CleanupSchemaMigrationRequest struct {
	ClusterId string                                   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *vtctldata.CleanupSchemaMigrationRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*CleanupSchemaMigrationRequest) CloneMessageVT 

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

func (*CleanupSchemaMigrationRequest) CloneVT 

func (m *CleanupSchemaMigrationRequest) CloneVT() *CleanupSchemaMigrationRequest

func (*CleanupSchemaMigrationRequest) Descriptor deprecated 

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

Deprecated: Use CleanupSchemaMigrationRequest.ProtoReflect.Descriptor instead.

func (*CleanupSchemaMigrationRequest) GetClusterId 

func (x *CleanupSchemaMigrationRequest) GetClusterId() string

func (*CleanupSchemaMigrationRequest) GetRequest 

func (x *CleanupSchemaMigrationRequest) GetRequest() *vtctldata.CleanupSchemaMigrationRequest

func (*CleanupSchemaMigrationRequest) MarshalToSizedBufferVT 

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

func (*CleanupSchemaMigrationRequest) MarshalToVT 

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

func (*CleanupSchemaMigrationRequest) MarshalVT 

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

func (*CleanupSchemaMigrationRequest) ProtoMessage 

func (*CleanupSchemaMigrationRequest) ProtoMessage()

func (*CleanupSchemaMigrationRequest) ProtoReflect 

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

func (*CleanupSchemaMigrationRequest) Reset 

func (x *CleanupSchemaMigrationRequest) Reset()

func (*CleanupSchemaMigrationRequest) SizeVT 

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

func (*CleanupSchemaMigrationRequest) String 

func (x *CleanupSchemaMigrationRequest) String() string

func (*CleanupSchemaMigrationRequest) UnmarshalVT 

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

type Cluster 

type Cluster struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Cluster represents information about a Vitess cluster.

func (*Cluster) CloneMessageVT 

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

func (*Cluster) CloneVT 

func (m *Cluster) CloneVT() *Cluster

func (*Cluster) Descriptor deprecated 

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetId 

func (x *Cluster) GetId() string

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) MarshalToSizedBufferVT 

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

func (*Cluster) MarshalToVT 

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

func (*Cluster) MarshalVT 

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

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

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

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) SizeVT 

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

func (*Cluster) String 

func (x *Cluster) String() string

func (*Cluster) UnmarshalVT 

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

type ClusterBackup 

type ClusterBackup struct {
	Cluster *Cluster             `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Backup  *mysqlctl.BackupInfo `protobuf:"bytes,2,opt,name=backup,proto3" json:"backup,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterBackup) CloneMessageVT 

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

func (*ClusterBackup) CloneVT 

func (m *ClusterBackup) CloneVT() *ClusterBackup

func (*ClusterBackup) Descriptor deprecated 

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

Deprecated: Use ClusterBackup.ProtoReflect.Descriptor instead.

func (*ClusterBackup) GetBackup 

func (x *ClusterBackup) GetBackup() *mysqlctl.BackupInfo

func (*ClusterBackup) GetCluster 

func (x *ClusterBackup) GetCluster() *Cluster

func (*ClusterBackup) MarshalToSizedBufferVT 

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

func (*ClusterBackup) MarshalToVT 

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

func (*ClusterBackup) MarshalVT 

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

func (*ClusterBackup) ProtoMessage 

func (*ClusterBackup) ProtoMessage()

func (*ClusterBackup) ProtoReflect 

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

func (*ClusterBackup) Reset 

func (x *ClusterBackup) Reset()

func (*ClusterBackup) SizeVT 

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

func (*ClusterBackup) String 

func (x *ClusterBackup) String() string

func (*ClusterBackup) UnmarshalVT 

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

type ClusterCellInfo 

type ClusterCellInfo struct {
	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Name    string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// CellInfo contains the data for the cell.
	//
	// It may be nil if the GetCellsInfosRequest specified NamesOnly.
	CellInfo *topodata.CellInfo `protobuf:"bytes,3,opt,name=cell_info,json=cellInfo,proto3" json:"cell_info,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterCellInfo) CloneMessageVT 

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

func (*ClusterCellInfo) CloneVT 

func (m *ClusterCellInfo) CloneVT() *ClusterCellInfo

func (*ClusterCellInfo) Descriptor deprecated 

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

Deprecated: Use ClusterCellInfo.ProtoReflect.Descriptor instead.

func (*ClusterCellInfo) GetCellInfo 

func (x *ClusterCellInfo) GetCellInfo() *topodata.CellInfo

func (*ClusterCellInfo) GetCluster 

func (x *ClusterCellInfo) GetCluster() *Cluster

func (*ClusterCellInfo) GetName 

func (x *ClusterCellInfo) GetName() string

func (*ClusterCellInfo) MarshalToSizedBufferVT 

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

func (*ClusterCellInfo) MarshalToVT 

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

func (*ClusterCellInfo) MarshalVT 

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

func (*ClusterCellInfo) ProtoMessage 

func (*ClusterCellInfo) ProtoMessage()

func (*ClusterCellInfo) ProtoReflect 

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

func (*ClusterCellInfo) Reset 

func (x *ClusterCellInfo) Reset()

func (*ClusterCellInfo) SizeVT 

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

func (*ClusterCellInfo) String 

func (x *ClusterCellInfo) String() string

func (*ClusterCellInfo) UnmarshalVT 

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

type ClusterCellsAliases 

type ClusterCellsAliases struct {
	Cluster *Cluster                        `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Aliases map[string]*topodata.CellsAlias `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ClusterCellsAliases) CloneMessageVT 

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

func (*ClusterCellsAliases) CloneVT 

func (m *ClusterCellsAliases) CloneVT() *ClusterCellsAliases

func (*ClusterCellsAliases) Descriptor deprecated 

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

Deprecated: Use ClusterCellsAliases.ProtoReflect.Descriptor instead.

func (*ClusterCellsAliases) GetAliases 

func (x *ClusterCellsAliases) GetAliases() map[string]*topodata.CellsAlias

func (*ClusterCellsAliases) GetCluster 

func (x *ClusterCellsAliases) GetCluster() *Cluster

func (*ClusterCellsAliases) MarshalToSizedBufferVT 

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

func (*ClusterCellsAliases) MarshalToVT 

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

func (*ClusterCellsAliases) MarshalVT 

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

func (*ClusterCellsAliases) ProtoMessage 

func (*ClusterCellsAliases) ProtoMessage()

func (*ClusterCellsAliases) ProtoReflect 

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

func (*ClusterCellsAliases) Reset 

func (x *ClusterCellsAliases) Reset()

func (*ClusterCellsAliases) SizeVT 

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

func (*ClusterCellsAliases) String 

func (x *ClusterCellsAliases) String() string

func (*ClusterCellsAliases) UnmarshalVT 

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

type ClusterShardReplicationPosition 

type ClusterShardReplicationPosition struct {
	Cluster      *Cluster                                     `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace     string                                       `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard        string                                       `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	PositionInfo *vtctldata.ShardReplicationPositionsResponse `protobuf:"bytes,4,opt,name=position_info,json=positionInfo,proto3" json:"position_info,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterShardReplicationPosition) CloneMessageVT 

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

func (*ClusterShardReplicationPosition) CloneVT 

func (m *ClusterShardReplicationPosition) CloneVT() *ClusterShardReplicationPosition

func (*ClusterShardReplicationPosition) Descriptor deprecated 

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

Deprecated: Use ClusterShardReplicationPosition.ProtoReflect.Descriptor instead.

func (*ClusterShardReplicationPosition) GetCluster 

func (x *ClusterShardReplicationPosition) GetCluster() *Cluster

func (*ClusterShardReplicationPosition) GetKeyspace 

func (x *ClusterShardReplicationPosition) GetKeyspace() string

func (*ClusterShardReplicationPosition) GetPositionInfo 

func (x *ClusterShardReplicationPosition) GetPositionInfo() *vtctldata.ShardReplicationPositionsResponse

func (*ClusterShardReplicationPosition) GetShard 

func (x *ClusterShardReplicationPosition) GetShard() string

func (*ClusterShardReplicationPosition) MarshalToSizedBufferVT 

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

func (*ClusterShardReplicationPosition) MarshalToVT 

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

func (*ClusterShardReplicationPosition) MarshalVT 

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

func (*ClusterShardReplicationPosition) ProtoMessage 

func (*ClusterShardReplicationPosition) ProtoMessage()

func (*ClusterShardReplicationPosition) ProtoReflect 

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

func (*ClusterShardReplicationPosition) Reset 

func (x *ClusterShardReplicationPosition) Reset()

func (*ClusterShardReplicationPosition) SizeVT 

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

func (*ClusterShardReplicationPosition) String 

func (x *ClusterShardReplicationPosition) String() string

func (*ClusterShardReplicationPosition) UnmarshalVT 

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

type ClusterWorkflows 

type ClusterWorkflows struct {
	Workflows []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// Warnings is a list of non-fatal errors encountered when fetching
	// workflows for a particular cluster.
	Warnings []string `protobuf:"bytes,2,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterWorkflows) CloneMessageVT 

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

func (*ClusterWorkflows) CloneVT 

func (m *ClusterWorkflows) CloneVT() *ClusterWorkflows

func (*ClusterWorkflows) Descriptor deprecated 

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

Deprecated: Use ClusterWorkflows.ProtoReflect.Descriptor instead.

func (*ClusterWorkflows) GetWarnings 

func (x *ClusterWorkflows) GetWarnings() []string

func (*ClusterWorkflows) GetWorkflows 

func (x *ClusterWorkflows) GetWorkflows() []*Workflow

func (*ClusterWorkflows) MarshalToSizedBufferVT 

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

func (*ClusterWorkflows) MarshalToVT 

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

func (*ClusterWorkflows) MarshalVT 

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

func (*ClusterWorkflows) ProtoMessage 

func (*ClusterWorkflows) ProtoMessage()

func (*ClusterWorkflows) ProtoReflect 

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

func (*ClusterWorkflows) Reset 

func (x *ClusterWorkflows) Reset()

func (*ClusterWorkflows) SizeVT 

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

func (*ClusterWorkflows) String 

func (x *ClusterWorkflows) String() string

func (*ClusterWorkflows) UnmarshalVT 

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

type CompleteSchemaMigrationRequest 

type CompleteSchemaMigrationRequest struct {
	ClusterId string                                    `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *vtctldata.CompleteSchemaMigrationRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*CompleteSchemaMigrationRequest) CloneMessageVT 

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

func (*CompleteSchemaMigrationRequest) CloneVT 

func (m *CompleteSchemaMigrationRequest) CloneVT() *CompleteSchemaMigrationRequest

func (*CompleteSchemaMigrationRequest) Descriptor deprecated 

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

Deprecated: Use CompleteSchemaMigrationRequest.ProtoReflect.Descriptor instead.

func (*CompleteSchemaMigrationRequest) GetClusterId 

func (x *CompleteSchemaMigrationRequest) GetClusterId() string

func (*CompleteSchemaMigrationRequest) GetRequest 

func (x *CompleteSchemaMigrationRequest) GetRequest() *vtctldata.CompleteSchemaMigrationRequest

func (*CompleteSchemaMigrationRequest) MarshalToSizedBufferVT 

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

func (*CompleteSchemaMigrationRequest) MarshalToVT 

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

func (*CompleteSchemaMigrationRequest) MarshalVT 

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

func (*CompleteSchemaMigrationRequest) ProtoMessage 

func (*CompleteSchemaMigrationRequest) ProtoMessage()

func (*CompleteSchemaMigrationRequest) ProtoReflect 

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

func (*CompleteSchemaMigrationRequest) Reset 

func (x *CompleteSchemaMigrationRequest) Reset()

func (*CompleteSchemaMigrationRequest) SizeVT 

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

func (*CompleteSchemaMigrationRequest) String 

func (x *CompleteSchemaMigrationRequest) String() string

func (*CompleteSchemaMigrationRequest) UnmarshalVT 

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

type CreateKeyspaceRequest 

type CreateKeyspaceRequest struct {
	ClusterId string                           `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Options   *vtctldata.CreateKeyspaceRequest `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateKeyspaceRequest) CloneMessageVT 

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

func (*CreateKeyspaceRequest) CloneVT 

func (m *CreateKeyspaceRequest) CloneVT() *CreateKeyspaceRequest

func (*CreateKeyspaceRequest) Descriptor deprecated 

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

Deprecated: Use CreateKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*CreateKeyspaceRequest) GetClusterId 

func (x *CreateKeyspaceRequest) GetClusterId() string

func (*CreateKeyspaceRequest) GetOptions 

func (x *CreateKeyspaceRequest) GetOptions() *vtctldata.CreateKeyspaceRequest

func (*CreateKeyspaceRequest) MarshalToSizedBufferVT 

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

func (*CreateKeyspaceRequest) MarshalToVT 

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

func (*CreateKeyspaceRequest) MarshalVT 

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

func (*CreateKeyspaceRequest) ProtoMessage 

func (*CreateKeyspaceRequest) ProtoMessage()

func (*CreateKeyspaceRequest) ProtoReflect 

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

func (*CreateKeyspaceRequest) Reset 

func (x *CreateKeyspaceRequest) Reset()

func (*CreateKeyspaceRequest) SizeVT 

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

func (*CreateKeyspaceRequest) String 

func (x *CreateKeyspaceRequest) String() string

func (*CreateKeyspaceRequest) UnmarshalVT 

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

type CreateKeyspaceResponse 

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

func (*CreateKeyspaceResponse) CloneMessageVT 

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

func (*CreateKeyspaceResponse) CloneVT 

func (m *CreateKeyspaceResponse) CloneVT() *CreateKeyspaceResponse

func (*CreateKeyspaceResponse) Descriptor deprecated 

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

Deprecated: Use CreateKeyspaceResponse.ProtoReflect.Descriptor instead.

func (*CreateKeyspaceResponse) GetKeyspace 

func (x *CreateKeyspaceResponse) GetKeyspace() *Keyspace

func (*CreateKeyspaceResponse) MarshalToSizedBufferVT 

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

func (*CreateKeyspaceResponse) MarshalToVT 

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

func (*CreateKeyspaceResponse) MarshalVT 

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

func (*CreateKeyspaceResponse) ProtoMessage 

func (*CreateKeyspaceResponse) ProtoMessage()

func (*CreateKeyspaceResponse) ProtoReflect 

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

func (*CreateKeyspaceResponse) Reset 

func (x *CreateKeyspaceResponse) Reset()

func (*CreateKeyspaceResponse) SizeVT 

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

func (*CreateKeyspaceResponse) String 

func (x *CreateKeyspaceResponse) String() string

func (*CreateKeyspaceResponse) UnmarshalVT 

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

type CreateShardRequest 

type CreateShardRequest struct {
	ClusterId string                        `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Options   *vtctldata.CreateShardRequest `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateShardRequest) CloneMessageVT 

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

func (*CreateShardRequest) CloneVT 

func (m *CreateShardRequest) CloneVT() *CreateShardRequest

func (*CreateShardRequest) Descriptor deprecated 

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

Deprecated: Use CreateShardRequest.ProtoReflect.Descriptor instead.

func (*CreateShardRequest) GetClusterId 

func (x *CreateShardRequest) GetClusterId() string

func (*CreateShardRequest) GetOptions 

func (x *CreateShardRequest) GetOptions() *vtctldata.CreateShardRequest

func (*CreateShardRequest) MarshalToSizedBufferVT 

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

func (*CreateShardRequest) MarshalToVT 

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

func (*CreateShardRequest) MarshalVT 

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

func (*CreateShardRequest) ProtoMessage 

func (*CreateShardRequest) ProtoMessage()

func (*CreateShardRequest) ProtoReflect 

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

func (*CreateShardRequest) Reset 

func (x *CreateShardRequest) Reset()

func (*CreateShardRequest) SizeVT 

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

func (*CreateShardRequest) String 

func (x *CreateShardRequest) String() string

func (*CreateShardRequest) UnmarshalVT 

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

type DeleteKeyspaceRequest 

type DeleteKeyspaceRequest struct {
	ClusterId string                           `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Options   *vtctldata.DeleteKeyspaceRequest `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeyspaceRequest) CloneMessageVT 

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

func (*DeleteKeyspaceRequest) CloneVT 

func (m *DeleteKeyspaceRequest) CloneVT() *DeleteKeyspaceRequest

func (*DeleteKeyspaceRequest) Descriptor deprecated 

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

Deprecated: Use DeleteKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*DeleteKeyspaceRequest) GetClusterId 

func (x *DeleteKeyspaceRequest) GetClusterId() string

func (*DeleteKeyspaceRequest) GetOptions 

func (x *DeleteKeyspaceRequest) GetOptions() *vtctldata.DeleteKeyspaceRequest

func (*DeleteKeyspaceRequest) MarshalToSizedBufferVT 

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

func (*DeleteKeyspaceRequest) MarshalToVT 

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

func (*DeleteKeyspaceRequest) MarshalVT 

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

func (*DeleteKeyspaceRequest) ProtoMessage 

func (*DeleteKeyspaceRequest) ProtoMessage()

func (*DeleteKeyspaceRequest) ProtoReflect 

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

func (*DeleteKeyspaceRequest) Reset 

func (x *DeleteKeyspaceRequest) Reset()

func (*DeleteKeyspaceRequest) SizeVT 

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

func (*DeleteKeyspaceRequest) String 

func (x *DeleteKeyspaceRequest) String() string

func (*DeleteKeyspaceRequest) UnmarshalVT 

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

type DeleteShardsRequest 

type DeleteShardsRequest struct {
	ClusterId string                         `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Options   *vtctldata.DeleteShardsRequest `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteShardsRequest) CloneMessageVT 

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

func (*DeleteShardsRequest) CloneVT 

func (m *DeleteShardsRequest) CloneVT() *DeleteShardsRequest

func (*DeleteShardsRequest) Descriptor deprecated 

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

Deprecated: Use DeleteShardsRequest.ProtoReflect.Descriptor instead.

func (*DeleteShardsRequest) GetClusterId 

func (x *DeleteShardsRequest) GetClusterId() string

func (*DeleteShardsRequest) GetOptions 

func (x *DeleteShardsRequest) GetOptions() *vtctldata.DeleteShardsRequest

func (*DeleteShardsRequest) MarshalToSizedBufferVT 

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

func (*DeleteShardsRequest) MarshalToVT 

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

func (*DeleteShardsRequest) MarshalVT 

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

func (*DeleteShardsRequest) ProtoMessage 

func (*DeleteShardsRequest) ProtoMessage()

func (*DeleteShardsRequest) ProtoReflect 

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

func (*DeleteShardsRequest) Reset 

func (x *DeleteShardsRequest) Reset()

func (*DeleteShardsRequest) SizeVT 

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

func (*DeleteShardsRequest) String 

func (x *DeleteShardsRequest) String() string

func (*DeleteShardsRequest) UnmarshalVT 

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

type DeleteTabletRequest 

type DeleteTabletRequest struct {
	Alias        *topodata.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds   []string              `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	AllowPrimary bool                  `protobuf:"varint,3,opt,name=allow_primary,json=allowPrimary,proto3" json:"allow_primary,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTabletRequest) CloneMessageVT 

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

func (*DeleteTabletRequest) CloneVT 

func (m *DeleteTabletRequest) CloneVT() *DeleteTabletRequest

func (*DeleteTabletRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTabletRequest.ProtoReflect.Descriptor instead.

func (*DeleteTabletRequest) GetAlias 

func (x *DeleteTabletRequest) GetAlias() *topodata.TabletAlias

func (*DeleteTabletRequest) GetAllowPrimary 

func (x *DeleteTabletRequest) GetAllowPrimary() bool

func (*DeleteTabletRequest) GetClusterIds 

func (x *DeleteTabletRequest) GetClusterIds() []string

func (*DeleteTabletRequest) MarshalToSizedBufferVT 

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

func (*DeleteTabletRequest) MarshalToVT 

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

func (*DeleteTabletRequest) MarshalVT 

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

func (*DeleteTabletRequest) ProtoMessage 

func (*DeleteTabletRequest) ProtoMessage()

func (*DeleteTabletRequest) ProtoReflect 

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

func (*DeleteTabletRequest) Reset 

func (x *DeleteTabletRequest) Reset()

func (*DeleteTabletRequest) SizeVT 

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

func (*DeleteTabletRequest) String 

func (x *DeleteTabletRequest) String() string

func (*DeleteTabletRequest) UnmarshalVT 

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

type DeleteTabletResponse 

type DeleteTabletResponse struct {
	Status  string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTabletResponse) CloneMessageVT 

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

func (*DeleteTabletResponse) CloneVT 

func (m *DeleteTabletResponse) CloneVT() *DeleteTabletResponse

func (*DeleteTabletResponse) Descriptor deprecated 

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

Deprecated: Use DeleteTabletResponse.ProtoReflect.Descriptor instead.

func (*DeleteTabletResponse) GetCluster 

func (x *DeleteTabletResponse) GetCluster() *Cluster

func (*DeleteTabletResponse) GetStatus 

func (x *DeleteTabletResponse) GetStatus() string

func (*DeleteTabletResponse) MarshalToSizedBufferVT 

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

func (*DeleteTabletResponse) MarshalToVT 

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

func (*DeleteTabletResponse) MarshalVT 

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

func (*DeleteTabletResponse) ProtoMessage 

func (*DeleteTabletResponse) ProtoMessage()

func (*DeleteTabletResponse) ProtoReflect 

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

func (*DeleteTabletResponse) Reset 

func (x *DeleteTabletResponse) Reset()

func (*DeleteTabletResponse) SizeVT 

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

func (*DeleteTabletResponse) String 

func (x *DeleteTabletResponse) String() string

func (*DeleteTabletResponse) UnmarshalVT 

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

type EmergencyFailoverShardRequest 

type EmergencyFailoverShardRequest struct {
	ClusterId string                                   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Options   *vtctldata.EmergencyReparentShardRequest `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*EmergencyFailoverShardRequest) CloneMessageVT 

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

func (*EmergencyFailoverShardRequest) CloneVT 

func (m *EmergencyFailoverShardRequest) CloneVT() *EmergencyFailoverShardRequest

func (*EmergencyFailoverShardRequest) Descriptor deprecated 

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

Deprecated: Use EmergencyFailoverShardRequest.ProtoReflect.Descriptor instead.

func (*EmergencyFailoverShardRequest) GetClusterId 

func (x *EmergencyFailoverShardRequest) GetClusterId() string

func (*EmergencyFailoverShardRequest) GetOptions 

func (x *EmergencyFailoverShardRequest) GetOptions() *vtctldata.EmergencyReparentShardRequest

func (*EmergencyFailoverShardRequest) MarshalToSizedBufferVT 

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

func (*EmergencyFailoverShardRequest) MarshalToVT 

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

func (*EmergencyFailoverShardRequest) MarshalVT 

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

func (*EmergencyFailoverShardRequest) ProtoMessage 

func (*EmergencyFailoverShardRequest) ProtoMessage()

func (*EmergencyFailoverShardRequest) ProtoReflect 

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

func (*EmergencyFailoverShardRequest) Reset 

func (x *EmergencyFailoverShardRequest) Reset()

func (*EmergencyFailoverShardRequest) SizeVT 

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

func (*EmergencyFailoverShardRequest) String 

func (x *EmergencyFailoverShardRequest) String() string

func (*EmergencyFailoverShardRequest) UnmarshalVT 

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

type EmergencyFailoverShardResponse 

type EmergencyFailoverShardResponse struct {
	Cluster  *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace string   `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard    string   `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	// PromotedPrimary is the tablet alias that was promoted to shard primary.
	// If NewPrimary was set in the request options, then this will be the
	// same tablet alias. Otherwise, it will be the alias of the tablet found
	// to be most up-to-date in the shard.
	PromotedPrimary *topodata.TabletAlias `protobuf:"bytes,4,opt,name=promoted_primary,json=promotedPrimary,proto3" json:"promoted_primary,omitempty"`
	Events          []*logutil.Event      `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*EmergencyFailoverShardResponse) CloneMessageVT 

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

func (*EmergencyFailoverShardResponse) CloneVT 

func (m *EmergencyFailoverShardResponse) CloneVT() *EmergencyFailoverShardResponse

func (*EmergencyFailoverShardResponse) Descriptor deprecated 

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

Deprecated: Use EmergencyFailoverShardResponse.ProtoReflect.Descriptor instead.

func (*EmergencyFailoverShardResponse) GetCluster 

func (x *EmergencyFailoverShardResponse) GetCluster() *Cluster

func (*EmergencyFailoverShardResponse) GetEvents 

func (x *EmergencyFailoverShardResponse) GetEvents() []*logutil.Event

func (*EmergencyFailoverShardResponse) GetKeyspace 

func (x *EmergencyFailoverShardResponse) GetKeyspace() string

func (*EmergencyFailoverShardResponse) GetPromotedPrimary 

func (x *EmergencyFailoverShardResponse) GetPromotedPrimary() *topodata.TabletAlias

func (*EmergencyFailoverShardResponse) GetShard 

func (x *EmergencyFailoverShardResponse) GetShard() string

func (*EmergencyFailoverShardResponse) MarshalToSizedBufferVT 

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

func (*EmergencyFailoverShardResponse) MarshalToVT 

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

func (*EmergencyFailoverShardResponse) MarshalVT 

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

func (*EmergencyFailoverShardResponse) ProtoMessage 

func (*EmergencyFailoverShardResponse) ProtoMessage()

func (*EmergencyFailoverShardResponse) ProtoReflect 

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

func (*EmergencyFailoverShardResponse) Reset 

func (x *EmergencyFailoverShardResponse) Reset()

func (*EmergencyFailoverShardResponse) SizeVT 

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

func (*EmergencyFailoverShardResponse) String 

func (x *EmergencyFailoverShardResponse) String() string

func (*EmergencyFailoverShardResponse) UnmarshalVT 

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

type FindSchemaRequest 

type FindSchemaRequest struct {
	Table            string                     `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	ClusterIds       []string                   `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	TableSizeOptions *GetSchemaTableSizeOptions `protobuf:"bytes,3,opt,name=table_size_options,json=tableSizeOptions,proto3" json:"table_size_options,omitempty"`
	// contains filtered or unexported fields
}

func (*FindSchemaRequest) CloneMessageVT 

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

func (*FindSchemaRequest) CloneVT 

func (m *FindSchemaRequest) CloneVT() *FindSchemaRequest

func (*FindSchemaRequest) Descriptor deprecated 

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

Deprecated: Use FindSchemaRequest.ProtoReflect.Descriptor instead.

func (*FindSchemaRequest) GetClusterIds 

func (x *FindSchemaRequest) GetClusterIds() []string

func (*FindSchemaRequest) GetTable 

func (x *FindSchemaRequest) GetTable() string

func (*FindSchemaRequest) GetTableSizeOptions 

func (x *FindSchemaRequest) GetTableSizeOptions() *GetSchemaTableSizeOptions

func (*FindSchemaRequest) MarshalToSizedBufferVT 

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

func (*FindSchemaRequest) MarshalToVT 

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

func (*FindSchemaRequest) MarshalVT 

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

func (*FindSchemaRequest) ProtoMessage 

func (*FindSchemaRequest) ProtoMessage()

func (*FindSchemaRequest) ProtoReflect 

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

func (*FindSchemaRequest) Reset 

func (x *FindSchemaRequest) Reset()

func (*FindSchemaRequest) SizeVT 

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

func (*FindSchemaRequest) String 

func (x *FindSchemaRequest) String() string

func (*FindSchemaRequest) UnmarshalVT 

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

type GetBackupsRequest 

type GetBackupsRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// Keyspaces, if set, limits backups to just the specified keyspaces.
	// Applies to all clusters in the request.
	Keyspaces []string `protobuf:"bytes,2,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	// KeyspaceShards, if set, limits backups to just the specified
	// keyspace/shards. Applies to all clusters in the request.
	//
	// This field takes precedence over Keyspaces. If KeyspaceShards is set,
	// Keyspaces is ignored.
	KeyspaceShards []string `protobuf:"bytes,3,rep,name=keyspace_shards,json=keyspaceShards,proto3" json:"keyspace_shards,omitempty"`
	// RequestOptions controls the per-shard request options when making
	// GetBackups requests to vtctlds. Note that the Keyspace and Shard fields
	// of this field are ignored; it is used only to specify Limit and Detailed
	// fields.
	RequestOptions *vtctldata.GetBackupsRequest `protobuf:"bytes,4,opt,name=request_options,json=requestOptions,proto3" json:"request_options,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBackupsRequest) CloneMessageVT 

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

func (*GetBackupsRequest) CloneVT 

func (m *GetBackupsRequest) CloneVT() *GetBackupsRequest

func (*GetBackupsRequest) Descriptor deprecated 

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

Deprecated: Use GetBackupsRequest.ProtoReflect.Descriptor instead.

func (*GetBackupsRequest) GetClusterIds 

func (x *GetBackupsRequest) GetClusterIds() []string

func (*GetBackupsRequest) GetKeyspaceShards 

func (x *GetBackupsRequest) GetKeyspaceShards() []string

func (*GetBackupsRequest) GetKeyspaces 

func (x *GetBackupsRequest) GetKeyspaces() []string

func (*GetBackupsRequest) GetRequestOptions 

func (x *GetBackupsRequest) GetRequestOptions() *vtctldata.GetBackupsRequest

func (*GetBackupsRequest) MarshalToSizedBufferVT 

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

func (*GetBackupsRequest) MarshalToVT 

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

func (*GetBackupsRequest) MarshalVT 

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

func (*GetBackupsRequest) ProtoMessage 

func (*GetBackupsRequest) ProtoMessage()

func (*GetBackupsRequest) ProtoReflect 

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

func (*GetBackupsRequest) Reset 

func (x *GetBackupsRequest) Reset()

func (*GetBackupsRequest) SizeVT 

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

func (*GetBackupsRequest) String 

func (x *GetBackupsRequest) String() string

func (*GetBackupsRequest) UnmarshalVT 

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

type GetBackupsResponse 

type GetBackupsResponse struct {
	Backups []*ClusterBackup `protobuf:"bytes,1,rep,name=backups,proto3" json:"backups,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBackupsResponse) CloneMessageVT 

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

func (*GetBackupsResponse) CloneVT 

func (m *GetBackupsResponse) CloneVT() *GetBackupsResponse

func (*GetBackupsResponse) Descriptor deprecated 

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

Deprecated: Use GetBackupsResponse.ProtoReflect.Descriptor instead.

func (*GetBackupsResponse) GetBackups 

func (x *GetBackupsResponse) GetBackups() []*ClusterBackup

func (*GetBackupsResponse) MarshalToSizedBufferVT 

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

func (*GetBackupsResponse) MarshalToVT 

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

func (*GetBackupsResponse) MarshalVT 

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

func (*GetBackupsResponse) ProtoMessage 

func (*GetBackupsResponse) ProtoMessage()

func (*GetBackupsResponse) ProtoReflect 

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

func (*GetBackupsResponse) Reset 

func (x *GetBackupsResponse) Reset()

func (*GetBackupsResponse) SizeVT 

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

func (*GetBackupsResponse) String 

func (x *GetBackupsResponse) String() string

func (*GetBackupsResponse) UnmarshalVT 

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

type GetCellInfosRequest 

type GetCellInfosRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// Cells, if specified, limits the response to include only CellInfo objects
	// with those names. If omitted, all CellInfo objects in each cluster are
	// returned.
	//
	// Mutually-exclusive with NamesOnly. If both are set, this field takes
	// precedence.
	Cells []string `protobuf:"bytes,2,rep,name=cells,proto3" json:"cells,omitempty"`
	// Return only the cell names in each cluster; the actual CellInfo objects
	// will be empty.
	NamesOnly bool `protobuf:"varint,3,opt,name=names_only,json=namesOnly,proto3" json:"names_only,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCellInfosRequest) CloneMessageVT 

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

func (*GetCellInfosRequest) CloneVT 

func (m *GetCellInfosRequest) CloneVT() *GetCellInfosRequest

func (*GetCellInfosRequest) Descriptor deprecated 

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

Deprecated: Use GetCellInfosRequest.ProtoReflect.Descriptor instead.

func (*GetCellInfosRequest) GetCells 

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

func (*GetCellInfosRequest) GetClusterIds 

func (x *GetCellInfosRequest) GetClusterIds() []string

func (*GetCellInfosRequest) GetNamesOnly 

func (x *GetCellInfosRequest) GetNamesOnly() bool

func (*GetCellInfosRequest) MarshalToSizedBufferVT 

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

func (*GetCellInfosRequest) MarshalToVT 

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

func (*GetCellInfosRequest) MarshalVT 

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

func (*GetCellInfosRequest) ProtoMessage 

func (*GetCellInfosRequest) ProtoMessage()

func (*GetCellInfosRequest) ProtoReflect 

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

func (*GetCellInfosRequest) Reset 

func (x *GetCellInfosRequest) Reset()

func (*GetCellInfosRequest) SizeVT 

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

func (*GetCellInfosRequest) String 

func (x *GetCellInfosRequest) String() string

func (*GetCellInfosRequest) UnmarshalVT 

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

type GetCellInfosResponse 

type GetCellInfosResponse struct {
	CellInfos []*ClusterCellInfo `protobuf:"bytes,1,rep,name=cell_infos,json=cellInfos,proto3" json:"cell_infos,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCellInfosResponse) CloneMessageVT 

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

func (*GetCellInfosResponse) CloneVT 

func (m *GetCellInfosResponse) CloneVT() *GetCellInfosResponse

func (*GetCellInfosResponse) Descriptor deprecated 

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

Deprecated: Use GetCellInfosResponse.ProtoReflect.Descriptor instead.

func (*GetCellInfosResponse) GetCellInfos 

func (x *GetCellInfosResponse) GetCellInfos() []*ClusterCellInfo

func (*GetCellInfosResponse) MarshalToSizedBufferVT 

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

func (*GetCellInfosResponse) MarshalToVT 

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

func (*GetCellInfosResponse) MarshalVT 

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

func (*GetCellInfosResponse) ProtoMessage 

func (*GetCellInfosResponse) ProtoMessage()

func (*GetCellInfosResponse) ProtoReflect 

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

func (*GetCellInfosResponse) Reset 

func (x *GetCellInfosResponse) Reset()

func (*GetCellInfosResponse) SizeVT 

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

func (*GetCellInfosResponse) String 

func (x *GetCellInfosResponse) String() string

func (*GetCellInfosResponse) UnmarshalVT 

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

type GetCellsAliasesRequest 

type GetCellsAliasesRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCellsAliasesRequest) CloneMessageVT 

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

func (*GetCellsAliasesRequest) CloneVT 

func (m *GetCellsAliasesRequest) CloneVT() *GetCellsAliasesRequest

func (*GetCellsAliasesRequest) Descriptor deprecated 

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

Deprecated: Use GetCellsAliasesRequest.ProtoReflect.Descriptor instead.

func (*GetCellsAliasesRequest) GetClusterIds 

func (x *GetCellsAliasesRequest) GetClusterIds() []string

func (*GetCellsAliasesRequest) MarshalToSizedBufferVT 

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

func (*GetCellsAliasesRequest) MarshalToVT 

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

func (*GetCellsAliasesRequest) MarshalVT 

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

func (*GetCellsAliasesRequest) ProtoMessage 

func (*GetCellsAliasesRequest) ProtoMessage()

func (*GetCellsAliasesRequest) ProtoReflect 

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

func (*GetCellsAliasesRequest) Reset 

func (x *GetCellsAliasesRequest) Reset()

func (*GetCellsAliasesRequest) SizeVT 

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

func (*GetCellsAliasesRequest) String 

func (x *GetCellsAliasesRequest) String() string

func (*GetCellsAliasesRequest) UnmarshalVT 

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

type GetCellsAliasesResponse 

type GetCellsAliasesResponse struct {
	Aliases []*ClusterCellsAliases `protobuf:"bytes,1,rep,name=aliases,proto3" json:"aliases,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCellsAliasesResponse) CloneMessageVT 

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

func (*GetCellsAliasesResponse) CloneVT 

func (m *GetCellsAliasesResponse) CloneVT() *GetCellsAliasesResponse

func (*GetCellsAliasesResponse) Descriptor deprecated 

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

Deprecated: Use GetCellsAliasesResponse.ProtoReflect.Descriptor instead.

func (*GetCellsAliasesResponse) GetAliases 

func (x *GetCellsAliasesResponse) GetAliases() []*ClusterCellsAliases

func (*GetCellsAliasesResponse) MarshalToSizedBufferVT 

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

func (*GetCellsAliasesResponse) MarshalToVT 

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

func (*GetCellsAliasesResponse) MarshalVT 

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

func (*GetCellsAliasesResponse) ProtoMessage 

func (*GetCellsAliasesResponse) ProtoMessage()

func (*GetCellsAliasesResponse) ProtoReflect 

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

func (*GetCellsAliasesResponse) Reset 

func (x *GetCellsAliasesResponse) Reset()

func (*GetCellsAliasesResponse) SizeVT 

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

func (*GetCellsAliasesResponse) String 

func (x *GetCellsAliasesResponse) String() string

func (*GetCellsAliasesResponse) UnmarshalVT 

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

type GetClustersRequest 

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

func (*GetClustersRequest) CloneMessageVT 

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

func (*GetClustersRequest) CloneVT 

func (m *GetClustersRequest) CloneVT() *GetClustersRequest

func (*GetClustersRequest) Descriptor deprecated 

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

Deprecated: Use GetClustersRequest.ProtoReflect.Descriptor instead.

func (*GetClustersRequest) MarshalToSizedBufferVT 

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

func (*GetClustersRequest) MarshalToVT 

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

func (*GetClustersRequest) MarshalVT 

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

func (*GetClustersRequest) ProtoMessage 

func (*GetClustersRequest) ProtoMessage()

func (*GetClustersRequest) ProtoReflect 

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

func (*GetClustersRequest) Reset 

func (x *GetClustersRequest) Reset()

func (*GetClustersRequest) SizeVT 

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

func (*GetClustersRequest) String 

func (x *GetClustersRequest) String() string

func (*GetClustersRequest) UnmarshalVT 

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

type GetClustersResponse 

type GetClustersResponse struct {
	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

func (*GetClustersResponse) CloneMessageVT 

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

func (*GetClustersResponse) CloneVT 

func (m *GetClustersResponse) CloneVT() *GetClustersResponse

func (*GetClustersResponse) Descriptor deprecated 

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

Deprecated: Use GetClustersResponse.ProtoReflect.Descriptor instead.

func (*GetClustersResponse) GetClusters 

func (x *GetClustersResponse) GetClusters() []*Cluster

func (*GetClustersResponse) MarshalToSizedBufferVT 

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

func (*GetClustersResponse) MarshalToVT 

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

func (*GetClustersResponse) MarshalVT 

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

func (*GetClustersResponse) ProtoMessage 

func (*GetClustersResponse) ProtoMessage()

func (*GetClustersResponse) ProtoReflect 

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

func (*GetClustersResponse) Reset 

func (x *GetClustersResponse) Reset()

func (*GetClustersResponse) SizeVT 

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

func (*GetClustersResponse) String 

func (x *GetClustersResponse) String() string

func (*GetClustersResponse) UnmarshalVT 

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

type GetFullStatusRequest 

type GetFullStatusRequest struct {
	ClusterId string                `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Alias     *topodata.TabletAlias `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFullStatusRequest) CloneMessageVT 

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

func (*GetFullStatusRequest) CloneVT 

func (m *GetFullStatusRequest) CloneVT() *GetFullStatusRequest

func (*GetFullStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetFullStatusRequest.ProtoReflect.Descriptor instead.

func (*GetFullStatusRequest) GetAlias 

func (x *GetFullStatusRequest) GetAlias() *topodata.TabletAlias

func (*GetFullStatusRequest) GetClusterId 

func (x *GetFullStatusRequest) GetClusterId() string

func (*GetFullStatusRequest) MarshalToSizedBufferVT 

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

func (*GetFullStatusRequest) MarshalToVT 

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

func (*GetFullStatusRequest) MarshalVT 

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

func (*GetFullStatusRequest) ProtoMessage 

func (*GetFullStatusRequest) ProtoMessage()

func (*GetFullStatusRequest) ProtoReflect 

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

func (*GetFullStatusRequest) Reset 

func (x *GetFullStatusRequest) Reset()

func (*GetFullStatusRequest) SizeVT 

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

func (*GetFullStatusRequest) String 

func (x *GetFullStatusRequest) String() string

func (*GetFullStatusRequest) UnmarshalVT 

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

type GetGatesRequest 

type GetGatesRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetGatesRequest) CloneMessageVT 

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

func (*GetGatesRequest) CloneVT 

func (m *GetGatesRequest) CloneVT() *GetGatesRequest

func (*GetGatesRequest) Descriptor deprecated 

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

Deprecated: Use GetGatesRequest.ProtoReflect.Descriptor instead.

func (*GetGatesRequest) GetClusterIds 

func (x *GetGatesRequest) GetClusterIds() []string

func (*GetGatesRequest) MarshalToSizedBufferVT 

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

func (*GetGatesRequest) MarshalToVT 

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

func (*GetGatesRequest) MarshalVT 

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

func (*GetGatesRequest) ProtoMessage 

func (*GetGatesRequest) ProtoMessage()

func (*GetGatesRequest) ProtoReflect 

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

func (*GetGatesRequest) Reset 

func (x *GetGatesRequest) Reset()

func (*GetGatesRequest) SizeVT 

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

func (*GetGatesRequest) String 

func (x *GetGatesRequest) String() string

func (*GetGatesRequest) UnmarshalVT 

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

type GetGatesResponse 

type GetGatesResponse struct {
	Gates []*VTGate `protobuf:"bytes,1,rep,name=gates,proto3" json:"gates,omitempty"`
	// contains filtered or unexported fields
}

func (*GetGatesResponse) CloneMessageVT 

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

func (*GetGatesResponse) CloneVT 

func (m *GetGatesResponse) CloneVT() *GetGatesResponse

func (*GetGatesResponse) Descriptor deprecated 

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

Deprecated: Use GetGatesResponse.ProtoReflect.Descriptor instead.

func (*GetGatesResponse) GetGates 

func (x *GetGatesResponse) GetGates() []*VTGate

func (*GetGatesResponse) MarshalToSizedBufferVT 

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

func (*GetGatesResponse) MarshalToVT 

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

func (*GetGatesResponse) MarshalVT 

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

func (*GetGatesResponse) ProtoMessage 

func (*GetGatesResponse) ProtoMessage()

func (*GetGatesResponse) ProtoReflect 

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

func (*GetGatesResponse) Reset 

func (x *GetGatesResponse) Reset()

func (*GetGatesResponse) SizeVT 

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

func (*GetGatesResponse) String 

func (x *GetGatesResponse) String() string

func (*GetGatesResponse) UnmarshalVT 

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

type GetKeyspaceRequest 

type GetKeyspaceRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeyspaceRequest) CloneMessageVT 

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

func (*GetKeyspaceRequest) CloneVT 

func (m *GetKeyspaceRequest) CloneVT() *GetKeyspaceRequest

func (*GetKeyspaceRequest) Descriptor deprecated 

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

Deprecated: Use GetKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*GetKeyspaceRequest) GetClusterId 

func (x *GetKeyspaceRequest) GetClusterId() string

func (*GetKeyspaceRequest) GetKeyspace 

func (x *GetKeyspaceRequest) GetKeyspace() string

func (*GetKeyspaceRequest) MarshalToSizedBufferVT 

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

func (*GetKeyspaceRequest) MarshalToVT 

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

func (*GetKeyspaceRequest) MarshalVT 

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

func (*GetKeyspaceRequest) ProtoMessage 

func (*GetKeyspaceRequest) ProtoMessage()

func (*GetKeyspaceRequest) ProtoReflect 

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

func (*GetKeyspaceRequest) Reset 

func (x *GetKeyspaceRequest) Reset()

func (*GetKeyspaceRequest) SizeVT 

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

func (*GetKeyspaceRequest) String 

func (x *GetKeyspaceRequest) String() string

func (*GetKeyspaceRequest) UnmarshalVT 

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

type GetKeyspacesRequest 

type GetKeyspacesRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeyspacesRequest) CloneMessageVT 

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

func (*GetKeyspacesRequest) CloneVT 

func (m *GetKeyspacesRequest) CloneVT() *GetKeyspacesRequest

func (*GetKeyspacesRequest) Descriptor deprecated 

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

Deprecated: Use GetKeyspacesRequest.ProtoReflect.Descriptor instead.

func (*GetKeyspacesRequest) GetClusterIds 

func (x *GetKeyspacesRequest) GetClusterIds() []string

func (*GetKeyspacesRequest) MarshalToSizedBufferVT 

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

func (*GetKeyspacesRequest) MarshalToVT 

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

func (*GetKeyspacesRequest) MarshalVT 

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

func (*GetKeyspacesRequest) ProtoMessage 

func (*GetKeyspacesRequest) ProtoMessage()

func (*GetKeyspacesRequest) ProtoReflect 

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

func (*GetKeyspacesRequest) Reset 

func (x *GetKeyspacesRequest) Reset()

func (*GetKeyspacesRequest) SizeVT 

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

func (*GetKeyspacesRequest) String 

func (x *GetKeyspacesRequest) String() string

func (*GetKeyspacesRequest) UnmarshalVT 

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

type GetKeyspacesResponse 

type GetKeyspacesResponse struct {
	Keyspaces []*Keyspace `protobuf:"bytes,1,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeyspacesResponse) CloneMessageVT 

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

func (*GetKeyspacesResponse) CloneVT 

func (m *GetKeyspacesResponse) CloneVT() *GetKeyspacesResponse

func (*GetKeyspacesResponse) Descriptor deprecated 

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

Deprecated: Use GetKeyspacesResponse.ProtoReflect.Descriptor instead.

func (*GetKeyspacesResponse) GetKeyspaces 

func (x *GetKeyspacesResponse) GetKeyspaces() []*Keyspace

func (*GetKeyspacesResponse) MarshalToSizedBufferVT 

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

func (*GetKeyspacesResponse) MarshalToVT 

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

func (*GetKeyspacesResponse) MarshalVT 

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

func (*GetKeyspacesResponse) ProtoMessage 

func (*GetKeyspacesResponse) ProtoMessage()

func (*GetKeyspacesResponse) ProtoReflect 

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

func (*GetKeyspacesResponse) Reset 

func (x *GetKeyspacesResponse) Reset()

func (*GetKeyspacesResponse) SizeVT 

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

func (*GetKeyspacesResponse) String 

func (x *GetKeyspacesResponse) String() string

func (*GetKeyspacesResponse) UnmarshalVT 

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

type GetSchemaMigrationsRequest 

type GetSchemaMigrationsRequest struct {
	ClusterRequests []*GetSchemaMigrationsRequest_ClusterRequest `protobuf:"bytes,1,rep,name=cluster_requests,json=clusterRequests,proto3" json:"cluster_requests,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaMigrationsRequest) CloneMessageVT 

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

func (*GetSchemaMigrationsRequest) CloneVT 

func (m *GetSchemaMigrationsRequest) CloneVT() *GetSchemaMigrationsRequest

func (*GetSchemaMigrationsRequest) Descriptor deprecated 

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

Deprecated: Use GetSchemaMigrationsRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaMigrationsRequest) GetClusterRequests 

func (x *GetSchemaMigrationsRequest) GetClusterRequests() []*GetSchemaMigrationsRequest_ClusterRequest

func (*GetSchemaMigrationsRequest) MarshalToSizedBufferVT 

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

func (*GetSchemaMigrationsRequest) MarshalToVT 

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

func (*GetSchemaMigrationsRequest) MarshalVT 

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

func (*GetSchemaMigrationsRequest) ProtoMessage 

func (*GetSchemaMigrationsRequest) ProtoMessage()

func (*GetSchemaMigrationsRequest) ProtoReflect 

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

func (*GetSchemaMigrationsRequest) Reset 

func (x *GetSchemaMigrationsRequest) Reset()

func (*GetSchemaMigrationsRequest) SizeVT 

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

func (*GetSchemaMigrationsRequest) String 

func (x *GetSchemaMigrationsRequest) String() string

func (*GetSchemaMigrationsRequest) UnmarshalVT 

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

type GetSchemaMigrationsRequest_ClusterRequest 

type GetSchemaMigrationsRequest_ClusterRequest struct {
	ClusterId string                                `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *vtctldata.GetSchemaMigrationsRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaMigrationsRequest_ClusterRequest) CloneMessageVT 

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

func (*GetSchemaMigrationsRequest_ClusterRequest) CloneVT 

func (m *GetSchemaMigrationsRequest_ClusterRequest) CloneVT() *GetSchemaMigrationsRequest_ClusterRequest

func (*GetSchemaMigrationsRequest_ClusterRequest) Descriptor deprecated 

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

Deprecated: Use GetSchemaMigrationsRequest_ClusterRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaMigrationsRequest_ClusterRequest) GetClusterId 

func (x *GetSchemaMigrationsRequest_ClusterRequest) GetClusterId() string

func (*GetSchemaMigrationsRequest_ClusterRequest) GetRequest 

func (x *GetSchemaMigrationsRequest_ClusterRequest) GetRequest() *vtctldata.GetSchemaMigrationsRequest

func (*GetSchemaMigrationsRequest_ClusterRequest) MarshalToSizedBufferVT 

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

func (*GetSchemaMigrationsRequest_ClusterRequest) MarshalToVT 

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

func (*GetSchemaMigrationsRequest_ClusterRequest) MarshalVT 

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

func (*GetSchemaMigrationsRequest_ClusterRequest) ProtoMessage 

func (*GetSchemaMigrationsRequest_ClusterRequest) ProtoMessage()

func (*GetSchemaMigrationsRequest_ClusterRequest) ProtoReflect 

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

func (*GetSchemaMigrationsRequest_ClusterRequest) Reset 

func (x *GetSchemaMigrationsRequest_ClusterRequest) Reset()

func (*GetSchemaMigrationsRequest_ClusterRequest) SizeVT 

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

func (*GetSchemaMigrationsRequest_ClusterRequest) String 

func (x *GetSchemaMigrationsRequest_ClusterRequest) String() string

func (*GetSchemaMigrationsRequest_ClusterRequest) UnmarshalVT 

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

type GetSchemaMigrationsResponse 

type GetSchemaMigrationsResponse struct {
	SchemaMigrations []*SchemaMigration `protobuf:"bytes,1,rep,name=schema_migrations,json=schemaMigrations,proto3" json:"schema_migrations,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaMigrationsResponse) CloneMessageVT 

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

func (*GetSchemaMigrationsResponse) CloneVT 

func (m *GetSchemaMigrationsResponse) CloneVT() *GetSchemaMigrationsResponse

func (*GetSchemaMigrationsResponse) Descriptor deprecated 

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

Deprecated: Use GetSchemaMigrationsResponse.ProtoReflect.Descriptor instead.

func (*GetSchemaMigrationsResponse) GetSchemaMigrations 

func (x *GetSchemaMigrationsResponse) GetSchemaMigrations() []*SchemaMigration

func (*GetSchemaMigrationsResponse) MarshalToSizedBufferVT 

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

func (*GetSchemaMigrationsResponse) MarshalToVT 

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

func (*GetSchemaMigrationsResponse) MarshalVT 

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

func (*GetSchemaMigrationsResponse) ProtoMessage 

func (*GetSchemaMigrationsResponse) ProtoMessage()

func (*GetSchemaMigrationsResponse) ProtoReflect 

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

func (*GetSchemaMigrationsResponse) Reset 

func (x *GetSchemaMigrationsResponse) Reset()

func (*GetSchemaMigrationsResponse) SizeVT 

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

func (*GetSchemaMigrationsResponse) String 

func (x *GetSchemaMigrationsResponse) String() string

func (*GetSchemaMigrationsResponse) UnmarshalVT 

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

type GetSchemaRequest 

type GetSchemaRequest struct {
	ClusterId        string                     `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace         string                     `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Table            string                     `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	TableSizeOptions *GetSchemaTableSizeOptions `protobuf:"bytes,4,opt,name=table_size_options,json=tableSizeOptions,proto3" json:"table_size_options,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaRequest) CloneMessageVT 

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

func (*GetSchemaRequest) CloneVT 

func (m *GetSchemaRequest) CloneVT() *GetSchemaRequest

func (*GetSchemaRequest) Descriptor deprecated 

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

Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaRequest) GetClusterId 

func (x *GetSchemaRequest) GetClusterId() string

func (*GetSchemaRequest) GetKeyspace 

func (x *GetSchemaRequest) GetKeyspace() string

func (*GetSchemaRequest) GetTable 

func (x *GetSchemaRequest) GetTable() string

func (*GetSchemaRequest) GetTableSizeOptions 

func (x *GetSchemaRequest) GetTableSizeOptions() *GetSchemaTableSizeOptions

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 GetSchemaTableSizeOptions 

type GetSchemaTableSizeOptions struct {
	AggregateSizes          bool `protobuf:"varint,1,opt,name=aggregate_sizes,json=aggregateSizes,proto3" json:"aggregate_sizes,omitempty"`
	IncludeNonServingShards bool `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetSchemaTableSizeOptions) CloneMessageVT 

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

func (*GetSchemaTableSizeOptions) CloneVT 

func (m *GetSchemaTableSizeOptions) CloneVT() *GetSchemaTableSizeOptions

func (*GetSchemaTableSizeOptions) Descriptor deprecated 

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

Deprecated: Use GetSchemaTableSizeOptions.ProtoReflect.Descriptor instead.

func (*GetSchemaTableSizeOptions) GetAggregateSizes 

func (x *GetSchemaTableSizeOptions) GetAggregateSizes() bool

func (*GetSchemaTableSizeOptions) GetIncludeNonServingShards 

func (x *GetSchemaTableSizeOptions) GetIncludeNonServingShards() bool

func (*GetSchemaTableSizeOptions) MarshalToSizedBufferVT 

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

func (*GetSchemaTableSizeOptions) MarshalToVT 

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

func (*GetSchemaTableSizeOptions) MarshalVT 

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

func (*GetSchemaTableSizeOptions) ProtoMessage 

func (*GetSchemaTableSizeOptions) ProtoMessage()

func (*GetSchemaTableSizeOptions) ProtoReflect 

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

func (*GetSchemaTableSizeOptions) Reset 

func (x *GetSchemaTableSizeOptions) Reset()

func (*GetSchemaTableSizeOptions) SizeVT 

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

func (*GetSchemaTableSizeOptions) String 

func (x *GetSchemaTableSizeOptions) String() string

func (*GetSchemaTableSizeOptions) UnmarshalVT 

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

type GetSchemasRequest 

type GetSchemasRequest struct {
	ClusterIds       []string                   `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	TableSizeOptions *GetSchemaTableSizeOptions `protobuf:"bytes,2,opt,name=table_size_options,json=tableSizeOptions,proto3" json:"table_size_options,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemasRequest) CloneMessageVT 

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

func (*GetSchemasRequest) CloneVT 

func (m *GetSchemasRequest) CloneVT() *GetSchemasRequest

func (*GetSchemasRequest) Descriptor deprecated 

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

Deprecated: Use GetSchemasRequest.ProtoReflect.Descriptor instead.

func (*GetSchemasRequest) GetClusterIds 

func (x *GetSchemasRequest) GetClusterIds() []string

func (*GetSchemasRequest) GetTableSizeOptions 

func (x *GetSchemasRequest) GetTableSizeOptions() *GetSchemaTableSizeOptions

func (*GetSchemasRequest) MarshalToSizedBufferVT 

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

func (*GetSchemasRequest) MarshalToVT 

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

func (*GetSchemasRequest) MarshalVT 

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

func (*GetSchemasRequest) ProtoMessage 

func (*GetSchemasRequest) ProtoMessage()

func (*GetSchemasRequest) ProtoReflect 

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

func (*GetSchemasRequest) Reset 

func (x *GetSchemasRequest) Reset()

func (*GetSchemasRequest) SizeVT 

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

func (*GetSchemasRequest) String 

func (x *GetSchemasRequest) String() string

func (*GetSchemasRequest) UnmarshalVT 

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

type GetSchemasResponse 

type GetSchemasResponse struct {
	Schemas []*Schema `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemasResponse) CloneMessageVT 

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

func (*GetSchemasResponse) CloneVT 

func (m *GetSchemasResponse) CloneVT() *GetSchemasResponse

func (*GetSchemasResponse) Descriptor deprecated 

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

Deprecated: Use GetSchemasResponse.ProtoReflect.Descriptor instead.

func (*GetSchemasResponse) GetSchemas 

func (x *GetSchemasResponse) GetSchemas() []*Schema

func (*GetSchemasResponse) MarshalToSizedBufferVT 

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

func (*GetSchemasResponse) MarshalToVT 

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

func (*GetSchemasResponse) MarshalVT 

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

func (*GetSchemasResponse) ProtoMessage 

func (*GetSchemasResponse) ProtoMessage()

func (*GetSchemasResponse) ProtoReflect 

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

func (*GetSchemasResponse) Reset 

func (x *GetSchemasResponse) Reset()

func (*GetSchemasResponse) SizeVT 

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

func (*GetSchemasResponse) String 

func (x *GetSchemasResponse) String() string

func (*GetSchemasResponse) UnmarshalVT 

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

type GetShardReplicationPositionsRequest 

type GetShardReplicationPositionsRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// Keyspaces, if set, limits replication positions to just the specified
	// keyspaces. Applies to all clusters in the request.
	Keyspaces []string `protobuf:"bytes,2,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	// KeyspaceShards, if set, limits replicatin positions to just the specified
	// keyspace/shards. Applies to all clusters in the request.
	//
	// This field takes precedence over Keyspaces. If KeyspaceShards is set,
	// Keyspaces is ignored.
	KeyspaceShards []string `protobuf:"bytes,3,rep,name=keyspace_shards,json=keyspaceShards,proto3" json:"keyspace_shards,omitempty"`
	// contains filtered or unexported fields
}

func (*GetShardReplicationPositionsRequest) CloneMessageVT 

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

func (*GetShardReplicationPositionsRequest) CloneVT 

func (m *GetShardReplicationPositionsRequest) CloneVT() *GetShardReplicationPositionsRequest

func (*GetShardReplicationPositionsRequest) Descriptor deprecated 

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

Deprecated: Use GetShardReplicationPositionsRequest.ProtoReflect.Descriptor instead.

func (*GetShardReplicationPositionsRequest) GetClusterIds 

func (x *GetShardReplicationPositionsRequest) GetClusterIds() []string

func (*GetShardReplicationPositionsRequest) GetKeyspaceShards 

func (x *GetShardReplicationPositionsRequest) GetKeyspaceShards() []string

func (*GetShardReplicationPositionsRequest) GetKeyspaces 

func (x *GetShardReplicationPositionsRequest) GetKeyspaces() []string

func (*GetShardReplicationPositionsRequest) MarshalToSizedBufferVT 

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

func (*GetShardReplicationPositionsRequest) MarshalToVT 

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

func (*GetShardReplicationPositionsRequest) MarshalVT 

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

func (*GetShardReplicationPositionsRequest) ProtoMessage 

func (*GetShardReplicationPositionsRequest) ProtoMessage()

func (*GetShardReplicationPositionsRequest) ProtoReflect 

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

func (*GetShardReplicationPositionsRequest) Reset 

func (x *GetShardReplicationPositionsRequest) Reset()

func (*GetShardReplicationPositionsRequest) SizeVT 

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

func (*GetShardReplicationPositionsRequest) String 

func (x *GetShardReplicationPositionsRequest) String() string

func (*GetShardReplicationPositionsRequest) UnmarshalVT 

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

type GetShardReplicationPositionsResponse 

type GetShardReplicationPositionsResponse struct {
	ReplicationPositions []*ClusterShardReplicationPosition `protobuf:"bytes,1,rep,name=replication_positions,json=replicationPositions,proto3" json:"replication_positions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetShardReplicationPositionsResponse) CloneMessageVT 

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

func (*GetShardReplicationPositionsResponse) CloneVT 

func (m *GetShardReplicationPositionsResponse) CloneVT() *GetShardReplicationPositionsResponse

func (*GetShardReplicationPositionsResponse) Descriptor deprecated 

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

Deprecated: Use GetShardReplicationPositionsResponse.ProtoReflect.Descriptor instead.

func (*GetShardReplicationPositionsResponse) GetReplicationPositions 

func (x *GetShardReplicationPositionsResponse) GetReplicationPositions() []*ClusterShardReplicationPosition

func (*GetShardReplicationPositionsResponse) MarshalToSizedBufferVT 

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

func (*GetShardReplicationPositionsResponse) MarshalToVT 

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

func (*GetShardReplicationPositionsResponse) MarshalVT 

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

func (*GetShardReplicationPositionsResponse) ProtoMessage 

func (*GetShardReplicationPositionsResponse) ProtoMessage()

func (*GetShardReplicationPositionsResponse) ProtoReflect 

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

func (*GetShardReplicationPositionsResponse) Reset 

func (x *GetShardReplicationPositionsResponse) Reset()

func (*GetShardReplicationPositionsResponse) SizeVT 

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

func (*GetShardReplicationPositionsResponse) String 

func (x *GetShardReplicationPositionsResponse) String() string

func (*GetShardReplicationPositionsResponse) UnmarshalVT 

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

type GetSrvKeyspaceRequest 

type GetSrvKeyspaceRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// Cells is a list of cells to lookup a SrvKeyspace for. Leaving this empty is
	// equivalent to specifying all cells in the topo.
	Cells []string `protobuf:"bytes,3,rep,name=cells,proto3" json:"cells,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSrvKeyspaceRequest) CloneMessageVT 

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

func (*GetSrvKeyspaceRequest) CloneVT 

func (m *GetSrvKeyspaceRequest) CloneVT() *GetSrvKeyspaceRequest

func (*GetSrvKeyspaceRequest) Descriptor deprecated 

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

Deprecated: Use GetSrvKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*GetSrvKeyspaceRequest) GetCells 

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

func (*GetSrvKeyspaceRequest) GetClusterId 

func (x *GetSrvKeyspaceRequest) GetClusterId() string

func (*GetSrvKeyspaceRequest) GetKeyspace 

func (x *GetSrvKeyspaceRequest) GetKeyspace() string

func (*GetSrvKeyspaceRequest) MarshalToSizedBufferVT 

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

func (*GetSrvKeyspaceRequest) MarshalToVT 

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

func (*GetSrvKeyspaceRequest) MarshalVT 

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

func (*GetSrvKeyspaceRequest) ProtoMessage 

func (*GetSrvKeyspaceRequest) ProtoMessage()

func (*GetSrvKeyspaceRequest) ProtoReflect 

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

func (*GetSrvKeyspaceRequest) Reset 

func (x *GetSrvKeyspaceRequest) Reset()

func (*GetSrvKeyspaceRequest) SizeVT 

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

func (*GetSrvKeyspaceRequest) String 

func (x *GetSrvKeyspaceRequest) String() string

func (*GetSrvKeyspaceRequest) UnmarshalVT 

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

type GetSrvKeyspacesRequest 

type GetSrvKeyspacesRequest struct {

	// An optional list of cluster IDs to filter specific clusters
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// Cells is a list of cells to lookup a SrvKeyspace for. Leaving this empty is
	// equivalent to specifying all cells in the topo.
	Cells []string `protobuf:"bytes,2,rep,name=cells,proto3" json:"cells,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSrvKeyspacesRequest) CloneMessageVT 

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

func (*GetSrvKeyspacesRequest) CloneVT 

func (m *GetSrvKeyspacesRequest) CloneVT() *GetSrvKeyspacesRequest

func (*GetSrvKeyspacesRequest) Descriptor deprecated 

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

Deprecated: Use GetSrvKeyspacesRequest.ProtoReflect.Descriptor instead.

func (*GetSrvKeyspacesRequest) GetCells 

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

func (*GetSrvKeyspacesRequest) GetClusterIds 

func (x *GetSrvKeyspacesRequest) GetClusterIds() []string

func (*GetSrvKeyspacesRequest) MarshalToSizedBufferVT 

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

func (*GetSrvKeyspacesRequest) MarshalToVT 

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

func (*GetSrvKeyspacesRequest) MarshalVT 

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

func (*GetSrvKeyspacesRequest) ProtoMessage 

func (*GetSrvKeyspacesRequest) ProtoMessage()

func (*GetSrvKeyspacesRequest) ProtoReflect 

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

func (*GetSrvKeyspacesRequest) Reset 

func (x *GetSrvKeyspacesRequest) Reset()

func (*GetSrvKeyspacesRequest) SizeVT 

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

func (*GetSrvKeyspacesRequest) String 

func (x *GetSrvKeyspacesRequest) String() string

func (*GetSrvKeyspacesRequest) UnmarshalVT 

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

type GetSrvKeyspacesResponse 

type GetSrvKeyspacesResponse struct {

	// GetSrvKeyspaces responses for each keyspace
	SrvKeyspaces map[string]*vtctldata.GetSrvKeyspacesResponse `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetSrvKeyspacesResponse) CloneMessageVT 

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

func (*GetSrvKeyspacesResponse) CloneVT 

func (m *GetSrvKeyspacesResponse) CloneVT() *GetSrvKeyspacesResponse

func (*GetSrvKeyspacesResponse) Descriptor deprecated 

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

Deprecated: Use GetSrvKeyspacesResponse.ProtoReflect.Descriptor instead.

func (*GetSrvKeyspacesResponse) GetSrvKeyspaces 

func (x *GetSrvKeyspacesResponse) GetSrvKeyspaces() map[string]*vtctldata.GetSrvKeyspacesResponse

func (*GetSrvKeyspacesResponse) MarshalToSizedBufferVT 

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

func (*GetSrvKeyspacesResponse) MarshalToVT 

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

func (*GetSrvKeyspacesResponse) MarshalVT 

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

func (*GetSrvKeyspacesResponse) ProtoMessage 

func (*GetSrvKeyspacesResponse) ProtoMessage()

func (*GetSrvKeyspacesResponse) ProtoReflect 

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

func (*GetSrvKeyspacesResponse) Reset 

func (x *GetSrvKeyspacesResponse) Reset()

func (*GetSrvKeyspacesResponse) SizeVT 

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

func (*GetSrvKeyspacesResponse) String 

func (x *GetSrvKeyspacesResponse) String() string

func (*GetSrvKeyspacesResponse) UnmarshalVT 

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

type GetSrvVSchemaRequest 

type GetSrvVSchemaRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Cell      string `protobuf:"bytes,2,opt,name=cell,proto3" json:"cell,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSrvVSchemaRequest) CloneMessageVT 

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

func (*GetSrvVSchemaRequest) CloneVT 

func (m *GetSrvVSchemaRequest) CloneVT() *GetSrvVSchemaRequest

func (*GetSrvVSchemaRequest) Descriptor deprecated 

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

Deprecated: Use GetSrvVSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSrvVSchemaRequest) GetCell 

func (x *GetSrvVSchemaRequest) GetCell() string

func (*GetSrvVSchemaRequest) GetClusterId 

func (x *GetSrvVSchemaRequest) GetClusterId() string

func (*GetSrvVSchemaRequest) MarshalToSizedBufferVT 

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

func (*GetSrvVSchemaRequest) MarshalToVT 

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

func (*GetSrvVSchemaRequest) MarshalVT 

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

func (*GetSrvVSchemaRequest) ProtoMessage 

func (*GetSrvVSchemaRequest) ProtoMessage()

func (*GetSrvVSchemaRequest) ProtoReflect 

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

func (*GetSrvVSchemaRequest) Reset 

func (x *GetSrvVSchemaRequest) Reset()

func (*GetSrvVSchemaRequest) SizeVT 

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

func (*GetSrvVSchemaRequest) String 

func (x *GetSrvVSchemaRequest) String() string

func (*GetSrvVSchemaRequest) UnmarshalVT 

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

type GetSrvVSchemasRequest 

type GetSrvVSchemasRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	Cells      []string `protobuf:"bytes,2,rep,name=cells,proto3" json:"cells,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSrvVSchemasRequest) CloneMessageVT 

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

func (*GetSrvVSchemasRequest) CloneVT 

func (m *GetSrvVSchemasRequest) CloneVT() *GetSrvVSchemasRequest

func (*GetSrvVSchemasRequest) Descriptor deprecated 

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

Deprecated: Use GetSrvVSchemasRequest.ProtoReflect.Descriptor instead.

func (*GetSrvVSchemasRequest) GetCells 

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

func (*GetSrvVSchemasRequest) GetClusterIds 

func (x *GetSrvVSchemasRequest) GetClusterIds() []string

func (*GetSrvVSchemasRequest) MarshalToSizedBufferVT 

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

func (*GetSrvVSchemasRequest) MarshalToVT 

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

func (*GetSrvVSchemasRequest) MarshalVT 

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

func (*GetSrvVSchemasRequest) ProtoMessage 

func (*GetSrvVSchemasRequest) ProtoMessage()

func (*GetSrvVSchemasRequest) ProtoReflect 

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

func (*GetSrvVSchemasRequest) Reset 

func (x *GetSrvVSchemasRequest) Reset()

func (*GetSrvVSchemasRequest) SizeVT 

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

func (*GetSrvVSchemasRequest) String 

func (x *GetSrvVSchemasRequest) String() string

func (*GetSrvVSchemasRequest) UnmarshalVT 

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

type GetSrvVSchemasResponse 

type GetSrvVSchemasResponse struct {
	SrvVSchemas []*SrvVSchema `protobuf:"bytes,1,rep,name=srv_v_schemas,json=srvVSchemas,proto3" json:"srv_v_schemas,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSrvVSchemasResponse) CloneMessageVT 

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

func (*GetSrvVSchemasResponse) CloneVT 

func (m *GetSrvVSchemasResponse) CloneVT() *GetSrvVSchemasResponse

func (*GetSrvVSchemasResponse) Descriptor deprecated 

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

Deprecated: Use GetSrvVSchemasResponse.ProtoReflect.Descriptor instead.

func (*GetSrvVSchemasResponse) GetSrvVSchemas 

func (x *GetSrvVSchemasResponse) GetSrvVSchemas() []*SrvVSchema

func (*GetSrvVSchemasResponse) MarshalToSizedBufferVT 

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

func (*GetSrvVSchemasResponse) MarshalToVT 

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

func (*GetSrvVSchemasResponse) MarshalVT 

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

func (*GetSrvVSchemasResponse) ProtoMessage 

func (*GetSrvVSchemasResponse) ProtoMessage()

func (*GetSrvVSchemasResponse) ProtoReflect 

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

func (*GetSrvVSchemasResponse) Reset 

func (x *GetSrvVSchemasResponse) Reset()

func (*GetSrvVSchemasResponse) SizeVT 

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

func (*GetSrvVSchemasResponse) String 

func (x *GetSrvVSchemasResponse) String() string

func (*GetSrvVSchemasResponse) UnmarshalVT 

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

type GetTabletRequest 

type GetTabletRequest struct {

	// Unique (per cluster) tablet alias.
	Alias *topodata.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	// ClusterIDs is an optional parameter to narrow the scope of the search, if
	// the caller knows which cluster the tablet may be in, or, to disambiguate
	// if multiple clusters have a tablet with the same hostname.
	ClusterIds []string `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTabletRequest) CloneMessageVT 

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

func (*GetTabletRequest) CloneVT 

func (m *GetTabletRequest) CloneVT() *GetTabletRequest

func (*GetTabletRequest) Descriptor deprecated 

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

Deprecated: Use GetTabletRequest.ProtoReflect.Descriptor instead.

func (*GetTabletRequest) GetAlias 

func (x *GetTabletRequest) GetAlias() *topodata.TabletAlias

func (*GetTabletRequest) GetClusterIds 

func (x *GetTabletRequest) GetClusterIds() []string

func (*GetTabletRequest) MarshalToSizedBufferVT 

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

func (*GetTabletRequest) MarshalToVT 

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

func (*GetTabletRequest) MarshalVT 

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

func (*GetTabletRequest) ProtoMessage 

func (*GetTabletRequest) ProtoMessage()

func (*GetTabletRequest) ProtoReflect 

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

func (*GetTabletRequest) Reset 

func (x *GetTabletRequest) Reset()

func (*GetTabletRequest) SizeVT 

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

func (*GetTabletRequest) String 

func (x *GetTabletRequest) String() string

func (*GetTabletRequest) UnmarshalVT 

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

type GetTabletsRequest 

type GetTabletsRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTabletsRequest) CloneMessageVT 

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

func (*GetTabletsRequest) CloneVT 

func (m *GetTabletsRequest) CloneVT() *GetTabletsRequest

func (*GetTabletsRequest) Descriptor deprecated 

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

Deprecated: Use GetTabletsRequest.ProtoReflect.Descriptor instead.

func (*GetTabletsRequest) GetClusterIds 

func (x *GetTabletsRequest) GetClusterIds() []string

func (*GetTabletsRequest) MarshalToSizedBufferVT 

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

func (*GetTabletsRequest) MarshalToVT 

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

func (*GetTabletsRequest) MarshalVT 

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

func (*GetTabletsRequest) ProtoMessage 

func (*GetTabletsRequest) ProtoMessage()

func (*GetTabletsRequest) ProtoReflect 

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

func (*GetTabletsRequest) Reset 

func (x *GetTabletsRequest) Reset()

func (*GetTabletsRequest) SizeVT 

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

func (*GetTabletsRequest) String 

func (x *GetTabletsRequest) String() string

func (*GetTabletsRequest) UnmarshalVT 

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

type GetTabletsResponse 

type GetTabletsResponse struct {
	Tablets []*Tablet `protobuf:"bytes,1,rep,name=tablets,proto3" json:"tablets,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTabletsResponse) CloneMessageVT 

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

func (*GetTabletsResponse) CloneVT 

func (m *GetTabletsResponse) CloneVT() *GetTabletsResponse

func (*GetTabletsResponse) Descriptor deprecated 

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

Deprecated: Use GetTabletsResponse.ProtoReflect.Descriptor instead.

func (*GetTabletsResponse) GetTablets 

func (x *GetTabletsResponse) GetTablets() []*Tablet

func (*GetTabletsResponse) MarshalToSizedBufferVT 

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

func (*GetTabletsResponse) MarshalToVT 

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

func (*GetTabletsResponse) MarshalVT 

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

func (*GetTabletsResponse) ProtoMessage 

func (*GetTabletsResponse) ProtoMessage()

func (*GetTabletsResponse) ProtoReflect 

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

func (*GetTabletsResponse) Reset 

func (x *GetTabletsResponse) Reset()

func (*GetTabletsResponse) SizeVT 

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

func (*GetTabletsResponse) String 

func (x *GetTabletsResponse) String() string

func (*GetTabletsResponse) UnmarshalVT 

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

type GetTopologyPathRequest 

type GetTopologyPathRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Path      string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTopologyPathRequest) CloneMessageVT 

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

func (*GetTopologyPathRequest) CloneVT 

func (m *GetTopologyPathRequest) CloneVT() *GetTopologyPathRequest

func (*GetTopologyPathRequest) Descriptor deprecated 

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

Deprecated: Use GetTopologyPathRequest.ProtoReflect.Descriptor instead.

func (*GetTopologyPathRequest) GetClusterId 

func (x *GetTopologyPathRequest) GetClusterId() string

func (*GetTopologyPathRequest) GetPath 

func (x *GetTopologyPathRequest) GetPath() string

func (*GetTopologyPathRequest) MarshalToSizedBufferVT 

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

func (*GetTopologyPathRequest) MarshalToVT 

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

func (*GetTopologyPathRequest) MarshalVT 

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

func (*GetTopologyPathRequest) ProtoMessage 

func (*GetTopologyPathRequest) ProtoMessage()

func (*GetTopologyPathRequest) ProtoReflect 

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

func (*GetTopologyPathRequest) Reset 

func (x *GetTopologyPathRequest) Reset()

func (*GetTopologyPathRequest) SizeVT 

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

func (*GetTopologyPathRequest) String 

func (x *GetTopologyPathRequest) String() string

func (*GetTopologyPathRequest) UnmarshalVT 

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

type GetVSchemaRequest 

type GetVSchemaRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVSchemaRequest) CloneMessageVT 

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

func (*GetVSchemaRequest) CloneVT 

func (m *GetVSchemaRequest) CloneVT() *GetVSchemaRequest

func (*GetVSchemaRequest) Descriptor deprecated 

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

Deprecated: Use GetVSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetVSchemaRequest) GetClusterId 

func (x *GetVSchemaRequest) GetClusterId() string

func (*GetVSchemaRequest) GetKeyspace 

func (x *GetVSchemaRequest) GetKeyspace() string

func (*GetVSchemaRequest) MarshalToSizedBufferVT 

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

func (*GetVSchemaRequest) MarshalToVT 

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

func (*GetVSchemaRequest) MarshalVT 

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

func (*GetVSchemaRequest) ProtoMessage 

func (*GetVSchemaRequest) ProtoMessage()

func (*GetVSchemaRequest) ProtoReflect 

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

func (*GetVSchemaRequest) Reset 

func (x *GetVSchemaRequest) Reset()

func (*GetVSchemaRequest) SizeVT 

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

func (*GetVSchemaRequest) String 

func (x *GetVSchemaRequest) String() string

func (*GetVSchemaRequest) UnmarshalVT 

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

type GetVSchemasRequest 

type GetVSchemasRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVSchemasRequest) CloneMessageVT 

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

func (*GetVSchemasRequest) CloneVT 

func (m *GetVSchemasRequest) CloneVT() *GetVSchemasRequest

func (*GetVSchemasRequest) Descriptor deprecated 

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

Deprecated: Use GetVSchemasRequest.ProtoReflect.Descriptor instead.

func (*GetVSchemasRequest) GetClusterIds 

func (x *GetVSchemasRequest) GetClusterIds() []string

func (*GetVSchemasRequest) MarshalToSizedBufferVT 

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

func (*GetVSchemasRequest) MarshalToVT 

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

func (*GetVSchemasRequest) MarshalVT 

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

func (*GetVSchemasRequest) ProtoMessage 

func (*GetVSchemasRequest) ProtoMessage()

func (*GetVSchemasRequest) ProtoReflect 

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

func (*GetVSchemasRequest) Reset 

func (x *GetVSchemasRequest) Reset()

func (*GetVSchemasRequest) SizeVT 

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

func (*GetVSchemasRequest) String 

func (x *GetVSchemasRequest) String() string

func (*GetVSchemasRequest) UnmarshalVT 

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

type GetVSchemasResponse 

type GetVSchemasResponse struct {
	VSchemas []*VSchema `protobuf:"bytes,1,rep,name=v_schemas,json=vSchemas,proto3" json:"v_schemas,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVSchemasResponse) CloneMessageVT 

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

func (*GetVSchemasResponse) CloneVT 

func (m *GetVSchemasResponse) CloneVT() *GetVSchemasResponse

func (*GetVSchemasResponse) Descriptor deprecated 

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

Deprecated: Use GetVSchemasResponse.ProtoReflect.Descriptor instead.

func (*GetVSchemasResponse) GetVSchemas 

func (x *GetVSchemasResponse) GetVSchemas() []*VSchema

func (*GetVSchemasResponse) MarshalToSizedBufferVT 

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

func (*GetVSchemasResponse) MarshalToVT 

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

func (*GetVSchemasResponse) MarshalVT 

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

func (*GetVSchemasResponse) ProtoMessage 

func (*GetVSchemasResponse) ProtoMessage()

func (*GetVSchemasResponse) ProtoReflect 

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

func (*GetVSchemasResponse) Reset 

func (x *GetVSchemasResponse) Reset()

func (*GetVSchemasResponse) SizeVT 

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

func (*GetVSchemasResponse) String 

func (x *GetVSchemasResponse) String() string

func (*GetVSchemasResponse) UnmarshalVT 

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

type GetVtctldsRequest 

type GetVtctldsRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVtctldsRequest) CloneMessageVT 

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

func (*GetVtctldsRequest) CloneVT 

func (m *GetVtctldsRequest) CloneVT() *GetVtctldsRequest

func (*GetVtctldsRequest) Descriptor deprecated 

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

Deprecated: Use GetVtctldsRequest.ProtoReflect.Descriptor instead.

func (*GetVtctldsRequest) GetClusterIds 

func (x *GetVtctldsRequest) GetClusterIds() []string

func (*GetVtctldsRequest) MarshalToSizedBufferVT 

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

func (*GetVtctldsRequest) MarshalToVT 

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

func (*GetVtctldsRequest) MarshalVT 

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

func (*GetVtctldsRequest) ProtoMessage 

func (*GetVtctldsRequest) ProtoMessage()

func (*GetVtctldsRequest) ProtoReflect 

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

func (*GetVtctldsRequest) Reset 

func (x *GetVtctldsRequest) Reset()

func (*GetVtctldsRequest) SizeVT 

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

func (*GetVtctldsRequest) String 

func (x *GetVtctldsRequest) String() string

func (*GetVtctldsRequest) UnmarshalVT 

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

type GetVtctldsResponse 

type GetVtctldsResponse struct {
	Vtctlds []*Vtctld `protobuf:"bytes,1,rep,name=vtctlds,proto3" json:"vtctlds,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVtctldsResponse) CloneMessageVT 

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

func (*GetVtctldsResponse) CloneVT 

func (m *GetVtctldsResponse) CloneVT() *GetVtctldsResponse

func (*GetVtctldsResponse) Descriptor deprecated 

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

Deprecated: Use GetVtctldsResponse.ProtoReflect.Descriptor instead.

func (*GetVtctldsResponse) GetVtctlds 

func (x *GetVtctldsResponse) GetVtctlds() []*Vtctld

func (*GetVtctldsResponse) MarshalToSizedBufferVT 

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

func (*GetVtctldsResponse) MarshalToVT 

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

func (*GetVtctldsResponse) MarshalVT 

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

func (*GetVtctldsResponse) ProtoMessage 

func (*GetVtctldsResponse) ProtoMessage()

func (*GetVtctldsResponse) ProtoReflect 

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

func (*GetVtctldsResponse) Reset 

func (x *GetVtctldsResponse) Reset()

func (*GetVtctldsResponse) SizeVT 

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

func (*GetVtctldsResponse) String 

func (x *GetVtctldsResponse) String() string

func (*GetVtctldsResponse) UnmarshalVT 

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

type GetWorkflowRequest 

type GetWorkflowRequest struct {
	ClusterId  string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace   string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Name       string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	ActiveOnly bool   `protobuf:"varint,4,opt,name=active_only,json=activeOnly,proto3" json:"active_only,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowRequest) CloneMessageVT 

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

func (*GetWorkflowRequest) CloneVT 

func (m *GetWorkflowRequest) CloneVT() *GetWorkflowRequest

func (*GetWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowRequest) GetActiveOnly 

func (x *GetWorkflowRequest) GetActiveOnly() bool

func (*GetWorkflowRequest) GetClusterId 

func (x *GetWorkflowRequest) GetClusterId() string

func (*GetWorkflowRequest) GetKeyspace 

func (x *GetWorkflowRequest) GetKeyspace() string

func (*GetWorkflowRequest) GetName 

func (x *GetWorkflowRequest) GetName() string

func (*GetWorkflowRequest) MarshalToSizedBufferVT 

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

func (*GetWorkflowRequest) MarshalToVT 

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

func (*GetWorkflowRequest) MarshalVT 

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

func (*GetWorkflowRequest) ProtoMessage 

func (*GetWorkflowRequest) ProtoMessage()

func (*GetWorkflowRequest) ProtoReflect 

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

func (*GetWorkflowRequest) Reset 

func (x *GetWorkflowRequest) Reset()

func (*GetWorkflowRequest) SizeVT 

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

func (*GetWorkflowRequest) String 

func (x *GetWorkflowRequest) String() string

func (*GetWorkflowRequest) UnmarshalVT 

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

type GetWorkflowsRequest 

type GetWorkflowsRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// ActiveOnly specifies whether to return workflows that are currently
	// active (running or paused) instead of all workflows.
	ActiveOnly bool `protobuf:"varint,2,opt,name=active_only,json=activeOnly,proto3" json:"active_only,omitempty"`
	// Keyspaces is a list of keyspaces to restrict the workflow search to. Note
	// that the keyspaces list applies across all cluster IDs in the request.
	//
	// If, for example, you have two clusters, each with a keyspace called "foo"
	// and want the workflows from "foo" in cluster1 but not from cluster2, you
	// must make two requests.
	//
	// Keyspaces and IgnoreKeyspaces are mutually-exclusive, and Keyspaces takes
	// precedence; if Keyspaces is a non-empty list, then IgnoreKeyspaces is
	// ignored completely.
	Keyspaces []string `protobuf:"bytes,3,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	// IgnoreKeyspaces is a list of keyspaces to skip during the workflow
	// search. It has the same semantics as the Keyspaces parameter, so refer to
	// that documentation for more details.
	IgnoreKeyspaces []string `protobuf:"bytes,4,rep,name=ignore_keyspaces,json=ignoreKeyspaces,proto3" json:"ignore_keyspaces,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowsRequest) CloneMessageVT 

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

func (*GetWorkflowsRequest) CloneVT 

func (m *GetWorkflowsRequest) CloneVT() *GetWorkflowsRequest

func (*GetWorkflowsRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowsRequest) GetActiveOnly 

func (x *GetWorkflowsRequest) GetActiveOnly() bool

func (*GetWorkflowsRequest) GetClusterIds 

func (x *GetWorkflowsRequest) GetClusterIds() []string

func (*GetWorkflowsRequest) GetIgnoreKeyspaces 

func (x *GetWorkflowsRequest) GetIgnoreKeyspaces() []string

func (*GetWorkflowsRequest) GetKeyspaces 

func (x *GetWorkflowsRequest) GetKeyspaces() []string

func (*GetWorkflowsRequest) MarshalToSizedBufferVT 

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

func (*GetWorkflowsRequest) MarshalToVT 

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

func (*GetWorkflowsRequest) MarshalVT 

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

func (*GetWorkflowsRequest) ProtoMessage 

func (*GetWorkflowsRequest) ProtoMessage()

func (*GetWorkflowsRequest) ProtoReflect 

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

func (*GetWorkflowsRequest) Reset 

func (x *GetWorkflowsRequest) Reset()

func (*GetWorkflowsRequest) SizeVT 

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

func (*GetWorkflowsRequest) String 

func (x *GetWorkflowsRequest) String() string

func (*GetWorkflowsRequest) UnmarshalVT 

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

type GetWorkflowsResponse 

type GetWorkflowsResponse struct {
	WorkflowsByCluster map[string]*ClusterWorkflows `` /* 205-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetWorkflowsResponse) CloneMessageVT 

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

func (*GetWorkflowsResponse) CloneVT 

func (m *GetWorkflowsResponse) CloneVT() *GetWorkflowsResponse

func (*GetWorkflowsResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowsResponse) GetWorkflowsByCluster 

func (x *GetWorkflowsResponse) GetWorkflowsByCluster() map[string]*ClusterWorkflows

func (*GetWorkflowsResponse) MarshalToSizedBufferVT 

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

func (*GetWorkflowsResponse) MarshalToVT 

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

func (*GetWorkflowsResponse) MarshalVT 

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

func (*GetWorkflowsResponse) ProtoMessage 

func (*GetWorkflowsResponse) ProtoMessage()

func (*GetWorkflowsResponse) ProtoReflect 

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

func (*GetWorkflowsResponse) Reset 

func (x *GetWorkflowsResponse) Reset()

func (*GetWorkflowsResponse) SizeVT 

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

func (*GetWorkflowsResponse) String 

func (x *GetWorkflowsResponse) String() string

func (*GetWorkflowsResponse) UnmarshalVT 

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

type Keyspace 

type Keyspace struct {
	Cluster  *Cluster                    `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace *vtctldata.Keyspace         `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shards   map[string]*vtctldata.Shard `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Keyspace represents information about a keyspace in a particular Vitess cluster.

func (*Keyspace) CloneMessageVT 

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

func (*Keyspace) CloneVT 

func (m *Keyspace) CloneVT() *Keyspace

func (*Keyspace) Descriptor deprecated 

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

Deprecated: Use Keyspace.ProtoReflect.Descriptor instead.

func (*Keyspace) GetCluster 

func (x *Keyspace) GetCluster() *Cluster

func (*Keyspace) GetKeyspace 

func (x *Keyspace) GetKeyspace() *vtctldata.Keyspace

func (*Keyspace) GetShards 

func (x *Keyspace) GetShards() map[string]*vtctldata.Shard

func (*Keyspace) MarshalToSizedBufferVT 

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

func (*Keyspace) MarshalToVT 

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

func (*Keyspace) MarshalVT 

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

func (*Keyspace) ProtoMessage 

func (*Keyspace) ProtoMessage()

func (*Keyspace) ProtoReflect 

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

func (*Keyspace) Reset 

func (x *Keyspace) Reset()

func (*Keyspace) SizeVT 

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

func (*Keyspace) String 

func (x *Keyspace) String() string

func (*Keyspace) UnmarshalVT 

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

type LaunchSchemaMigrationRequest 

type LaunchSchemaMigrationRequest struct {
	ClusterId string                                  `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *vtctldata.LaunchSchemaMigrationRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*LaunchSchemaMigrationRequest) CloneMessageVT 

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

func (*LaunchSchemaMigrationRequest) CloneVT 

func (m *LaunchSchemaMigrationRequest) CloneVT() *LaunchSchemaMigrationRequest

func (*LaunchSchemaMigrationRequest) Descriptor deprecated 

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

Deprecated: Use LaunchSchemaMigrationRequest.ProtoReflect.Descriptor instead.

func (*LaunchSchemaMigrationRequest) GetClusterId 

func (x *LaunchSchemaMigrationRequest) GetClusterId() string

func (*LaunchSchemaMigrationRequest) GetRequest 

func (x *LaunchSchemaMigrationRequest) GetRequest() *vtctldata.LaunchSchemaMigrationRequest

func (*LaunchSchemaMigrationRequest) MarshalToSizedBufferVT 

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

func (*LaunchSchemaMigrationRequest) MarshalToVT 

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

func (*LaunchSchemaMigrationRequest) MarshalVT 

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

func (*LaunchSchemaMigrationRequest) ProtoMessage 

func (*LaunchSchemaMigrationRequest) ProtoMessage()

func (*LaunchSchemaMigrationRequest) ProtoReflect 

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

func (*LaunchSchemaMigrationRequest) Reset 

func (x *LaunchSchemaMigrationRequest) Reset()

func (*LaunchSchemaMigrationRequest) SizeVT 

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

func (*LaunchSchemaMigrationRequest) String 

func (x *LaunchSchemaMigrationRequest) String() string

func (*LaunchSchemaMigrationRequest) UnmarshalVT 

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

type PingTabletRequest 

type PingTabletRequest struct {

	// Unique (per cluster) tablet alias of the standard form: "$cell-$uid"
	Alias *topodata.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	// ClusterIDs is an optional parameter to narrow the scope of the search, if
	// the caller knows which cluster the tablet may be in, or, to disambiguate
	// if multiple clusters have a tablet with the same hostname.
	ClusterIds []string `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*PingTabletRequest) CloneMessageVT 

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

func (*PingTabletRequest) CloneVT 

func (m *PingTabletRequest) CloneVT() *PingTabletRequest

func (*PingTabletRequest) Descriptor deprecated 

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

Deprecated: Use PingTabletRequest.ProtoReflect.Descriptor instead.

func (*PingTabletRequest) GetAlias 

func (x *PingTabletRequest) GetAlias() *topodata.TabletAlias

func (*PingTabletRequest) GetClusterIds 

func (x *PingTabletRequest) GetClusterIds() []string

func (*PingTabletRequest) MarshalToSizedBufferVT 

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

func (*PingTabletRequest) MarshalToVT 

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

func (*PingTabletRequest) MarshalVT 

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

func (*PingTabletRequest) ProtoMessage 

func (*PingTabletRequest) ProtoMessage()

func (*PingTabletRequest) ProtoReflect 

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

func (*PingTabletRequest) Reset 

func (x *PingTabletRequest) Reset()

func (*PingTabletRequest) SizeVT 

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

func (*PingTabletRequest) String 

func (x *PingTabletRequest) String() string

func (*PingTabletRequest) UnmarshalVT 

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

type PingTabletResponse 

type PingTabletResponse struct {
	Status  string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*PingTabletResponse) CloneMessageVT 

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

func (*PingTabletResponse) CloneVT 

func (m *PingTabletResponse) CloneVT() *PingTabletResponse

func (*PingTabletResponse) Descriptor deprecated 

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

Deprecated: Use PingTabletResponse.ProtoReflect.Descriptor instead.

func (*PingTabletResponse) GetCluster 

func (x *PingTabletResponse) GetCluster() *Cluster

func (*PingTabletResponse) GetStatus 

func (x *PingTabletResponse) GetStatus() string

func (*PingTabletResponse) MarshalToSizedBufferVT 

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

func (*PingTabletResponse) MarshalToVT 

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

func (*PingTabletResponse) MarshalVT 

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

func (*PingTabletResponse) ProtoMessage 

func (*PingTabletResponse) ProtoMessage()

func (*PingTabletResponse) ProtoReflect 

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

func (*PingTabletResponse) Reset 

func (x *PingTabletResponse) Reset()

func (*PingTabletResponse) SizeVT 

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

func (*PingTabletResponse) String 

func (x *PingTabletResponse) String() string

func (*PingTabletResponse) UnmarshalVT 

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

type PlannedFailoverShardRequest 

type PlannedFailoverShardRequest struct {
	ClusterId string                                 `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Options   *vtctldata.PlannedReparentShardRequest `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*PlannedFailoverShardRequest) CloneMessageVT 

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

func (*PlannedFailoverShardRequest) CloneVT 

func (m *PlannedFailoverShardRequest) CloneVT() *PlannedFailoverShardRequest

func (*PlannedFailoverShardRequest) Descriptor deprecated 

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

Deprecated: Use PlannedFailoverShardRequest.ProtoReflect.Descriptor instead.

func (*PlannedFailoverShardRequest) GetClusterId 

func (x *PlannedFailoverShardRequest) GetClusterId() string

func (*PlannedFailoverShardRequest) GetOptions 

func (x *PlannedFailoverShardRequest) GetOptions() *vtctldata.PlannedReparentShardRequest

func (*PlannedFailoverShardRequest) MarshalToSizedBufferVT 

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

func (*PlannedFailoverShardRequest) MarshalToVT 

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

func (*PlannedFailoverShardRequest) MarshalVT 

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

func (*PlannedFailoverShardRequest) ProtoMessage 

func (*PlannedFailoverShardRequest) ProtoMessage()

func (*PlannedFailoverShardRequest) ProtoReflect 

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

func (*PlannedFailoverShardRequest) Reset 

func (x *PlannedFailoverShardRequest) Reset()

func (*PlannedFailoverShardRequest) SizeVT 

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

func (*PlannedFailoverShardRequest) String 

func (x *PlannedFailoverShardRequest) String() string

func (*PlannedFailoverShardRequest) UnmarshalVT 

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

type PlannedFailoverShardResponse 

type PlannedFailoverShardResponse struct {
	Cluster  *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace string   `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard    string   `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	// PromotedPrimary is the tablet alias that was promoted to shard primary.
	// If NewPrimary was set in the request options, then this will be the
	// same tablet alias. Otherwise, it will be the alias of the tablet found
	// to be most up-to-date in the shard.
	PromotedPrimary *topodata.TabletAlias `protobuf:"bytes,4,opt,name=promoted_primary,json=promotedPrimary,proto3" json:"promoted_primary,omitempty"`
	Events          []*logutil.Event      `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*PlannedFailoverShardResponse) CloneMessageVT 

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

func (*PlannedFailoverShardResponse) CloneVT 

func (m *PlannedFailoverShardResponse) CloneVT() *PlannedFailoverShardResponse

func (*PlannedFailoverShardResponse) Descriptor deprecated 

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

Deprecated: Use PlannedFailoverShardResponse.ProtoReflect.Descriptor instead.

func (*PlannedFailoverShardResponse) GetCluster 

func (x *PlannedFailoverShardResponse) GetCluster() *Cluster

func (*PlannedFailoverShardResponse) GetEvents 

func (x *PlannedFailoverShardResponse) GetEvents() []*logutil.Event

func (*PlannedFailoverShardResponse) GetKeyspace 

func (x *PlannedFailoverShardResponse) GetKeyspace() string

func (*PlannedFailoverShardResponse) GetPromotedPrimary 

func (x *PlannedFailoverShardResponse) GetPromotedPrimary() *topodata.TabletAlias

func (*PlannedFailoverShardResponse) GetShard 

func (x *PlannedFailoverShardResponse) GetShard() string

func (*PlannedFailoverShardResponse) MarshalToSizedBufferVT 

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

func (*PlannedFailoverShardResponse) MarshalToVT 

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

func (*PlannedFailoverShardResponse) MarshalVT 

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

func (*PlannedFailoverShardResponse) ProtoMessage 

func (*PlannedFailoverShardResponse) ProtoMessage()

func (*PlannedFailoverShardResponse) ProtoReflect 

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

func (*PlannedFailoverShardResponse) Reset 

func (x *PlannedFailoverShardResponse) Reset()

func (*PlannedFailoverShardResponse) SizeVT 

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

func (*PlannedFailoverShardResponse) String 

func (x *PlannedFailoverShardResponse) String() string

func (*PlannedFailoverShardResponse) UnmarshalVT 

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

type RebuildKeyspaceGraphRequest 

type RebuildKeyspaceGraphRequest struct {
	ClusterId    string   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace     string   `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Cells        []string `protobuf:"bytes,3,rep,name=cells,proto3" json:"cells,omitempty"`
	AllowPartial bool     `protobuf:"varint,4,opt,name=allow_partial,json=allowPartial,proto3" json:"allow_partial,omitempty"`
	// contains filtered or unexported fields
}

func (*RebuildKeyspaceGraphRequest) CloneMessageVT 

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

func (*RebuildKeyspaceGraphRequest) CloneVT 

func (m *RebuildKeyspaceGraphRequest) CloneVT() *RebuildKeyspaceGraphRequest

func (*RebuildKeyspaceGraphRequest) Descriptor deprecated 

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

Deprecated: Use RebuildKeyspaceGraphRequest.ProtoReflect.Descriptor instead.

func (*RebuildKeyspaceGraphRequest) GetAllowPartial 

func (x *RebuildKeyspaceGraphRequest) GetAllowPartial() bool

func (*RebuildKeyspaceGraphRequest) GetCells 

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

func (*RebuildKeyspaceGraphRequest) GetClusterId 

func (x *RebuildKeyspaceGraphRequest) GetClusterId() string

func (*RebuildKeyspaceGraphRequest) GetKeyspace 

func (x *RebuildKeyspaceGraphRequest) GetKeyspace() string

func (*RebuildKeyspaceGraphRequest) MarshalToSizedBufferVT 

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

func (*RebuildKeyspaceGraphRequest) MarshalToVT 

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

func (*RebuildKeyspaceGraphRequest) MarshalVT 

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

func (*RebuildKeyspaceGraphRequest) ProtoMessage 

func (*RebuildKeyspaceGraphRequest) ProtoMessage()

func (*RebuildKeyspaceGraphRequest) ProtoReflect 

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

func (*RebuildKeyspaceGraphRequest) Reset 

func (x *RebuildKeyspaceGraphRequest) Reset()

func (*RebuildKeyspaceGraphRequest) SizeVT 

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

func (*RebuildKeyspaceGraphRequest) String 

func (x *RebuildKeyspaceGraphRequest) String() string

func (*RebuildKeyspaceGraphRequest) UnmarshalVT 

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

type RebuildKeyspaceGraphResponse 

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

func (*RebuildKeyspaceGraphResponse) CloneMessageVT 

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

func (*RebuildKeyspaceGraphResponse) CloneVT 

func (m *RebuildKeyspaceGraphResponse) CloneVT() *RebuildKeyspaceGraphResponse

func (*RebuildKeyspaceGraphResponse) Descriptor deprecated 

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

Deprecated: Use RebuildKeyspaceGraphResponse.ProtoReflect.Descriptor instead.

func (*RebuildKeyspaceGraphResponse) GetStatus 

func (x *RebuildKeyspaceGraphResponse) GetStatus() string

func (*RebuildKeyspaceGraphResponse) MarshalToSizedBufferVT 

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

func (*RebuildKeyspaceGraphResponse) MarshalToVT 

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

func (*RebuildKeyspaceGraphResponse) MarshalVT 

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

func (*RebuildKeyspaceGraphResponse) ProtoMessage 

func (*RebuildKeyspaceGraphResponse) ProtoMessage()

func (*RebuildKeyspaceGraphResponse) ProtoReflect 

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

func (*RebuildKeyspaceGraphResponse) Reset 

func (x *RebuildKeyspaceGraphResponse) Reset()

func (*RebuildKeyspaceGraphResponse) SizeVT 

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

func (*RebuildKeyspaceGraphResponse) String 

func (x *RebuildKeyspaceGraphResponse) String() string

func (*RebuildKeyspaceGraphResponse) UnmarshalVT 

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

type RefreshStateRequest 

type RefreshStateRequest struct {
	Alias      *topodata.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string              `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshStateRequest) CloneMessageVT 

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

func (*RefreshStateRequest) CloneVT 

func (m *RefreshStateRequest) CloneVT() *RefreshStateRequest

func (*RefreshStateRequest) Descriptor deprecated 

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

Deprecated: Use RefreshStateRequest.ProtoReflect.Descriptor instead.

func (*RefreshStateRequest) GetAlias 

func (x *RefreshStateRequest) GetAlias() *topodata.TabletAlias

func (*RefreshStateRequest) GetClusterIds 

func (x *RefreshStateRequest) GetClusterIds() []string

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 {
	Status  string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshStateResponse) CloneMessageVT 

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

func (*RefreshStateResponse) CloneVT 

func (m *RefreshStateResponse) CloneVT() *RefreshStateResponse

func (*RefreshStateResponse) Descriptor deprecated 

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

Deprecated: Use RefreshStateResponse.ProtoReflect.Descriptor instead.

func (*RefreshStateResponse) GetCluster 

func (x *RefreshStateResponse) GetCluster() *Cluster

func (*RefreshStateResponse) GetStatus 

func (x *RefreshStateResponse) GetStatus() string

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 RefreshTabletReplicationSourceRequest 

type RefreshTabletReplicationSourceRequest struct {
	Alias      *topodata.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string              `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshTabletReplicationSourceRequest) CloneMessageVT 

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

func (*RefreshTabletReplicationSourceRequest) CloneVT 

func (m *RefreshTabletReplicationSourceRequest) CloneVT() *RefreshTabletReplicationSourceRequest

func (*RefreshTabletReplicationSourceRequest) Descriptor deprecated 

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

Deprecated: Use RefreshTabletReplicationSourceRequest.ProtoReflect.Descriptor instead.

func (*RefreshTabletReplicationSourceRequest) GetAlias 

func (x *RefreshTabletReplicationSourceRequest) GetAlias() *topodata.TabletAlias

func (*RefreshTabletReplicationSourceRequest) GetClusterIds 

func (x *RefreshTabletReplicationSourceRequest) GetClusterIds() []string

func (*RefreshTabletReplicationSourceRequest) MarshalToSizedBufferVT 

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

func (*RefreshTabletReplicationSourceRequest) MarshalToVT 

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

func (*RefreshTabletReplicationSourceRequest) MarshalVT 

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

func (*RefreshTabletReplicationSourceRequest) ProtoMessage 

func (*RefreshTabletReplicationSourceRequest) ProtoMessage()

func (*RefreshTabletReplicationSourceRequest) ProtoReflect 

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

func (*RefreshTabletReplicationSourceRequest) Reset 

func (x *RefreshTabletReplicationSourceRequest) Reset()

func (*RefreshTabletReplicationSourceRequest) SizeVT 

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

func (*RefreshTabletReplicationSourceRequest) String 

func (x *RefreshTabletReplicationSourceRequest) String() string

func (*RefreshTabletReplicationSourceRequest) UnmarshalVT 

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

type RefreshTabletReplicationSourceResponse 

type RefreshTabletReplicationSourceResponse struct {
	Keyspace string                `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard    string                `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
	Primary  *topodata.TabletAlias `protobuf:"bytes,3,opt,name=primary,proto3" json:"primary,omitempty"`
	Cluster  *Cluster              `protobuf:"bytes,4,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshTabletReplicationSourceResponse) CloneMessageVT 

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

func (*RefreshTabletReplicationSourceResponse) CloneVT 

func (m *RefreshTabletReplicationSourceResponse) CloneVT() *RefreshTabletReplicationSourceResponse

func (*RefreshTabletReplicationSourceResponse) Descriptor deprecated 

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

Deprecated: Use RefreshTabletReplicationSourceResponse.ProtoReflect.Descriptor instead.

func (*RefreshTabletReplicationSourceResponse) GetCluster 

func (x *RefreshTabletReplicationSourceResponse) GetCluster() *Cluster

func (*RefreshTabletReplicationSourceResponse) GetKeyspace 

func (x *RefreshTabletReplicationSourceResponse) GetKeyspace() string

func (*RefreshTabletReplicationSourceResponse) GetPrimary 

func (x *RefreshTabletReplicationSourceResponse) GetPrimary() *topodata.TabletAlias

func (*RefreshTabletReplicationSourceResponse) GetShard 

func (x *RefreshTabletReplicationSourceResponse) GetShard() string

func (*RefreshTabletReplicationSourceResponse) MarshalToSizedBufferVT 

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

func (*RefreshTabletReplicationSourceResponse) MarshalToVT 

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

func (*RefreshTabletReplicationSourceResponse) MarshalVT 

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

func (*RefreshTabletReplicationSourceResponse) ProtoMessage 

func (*RefreshTabletReplicationSourceResponse) ProtoMessage()

func (*RefreshTabletReplicationSourceResponse) ProtoReflect 

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

func (*RefreshTabletReplicationSourceResponse) Reset 

func (x *RefreshTabletReplicationSourceResponse) Reset()

func (*RefreshTabletReplicationSourceResponse) SizeVT 

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

func (*RefreshTabletReplicationSourceResponse) String 

func (x *RefreshTabletReplicationSourceResponse) String() string

func (*RefreshTabletReplicationSourceResponse) UnmarshalVT 

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

type ReloadSchemaShardRequest 

type ReloadSchemaShardRequest struct {
	ClusterId      string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace       string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard          string `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	WaitPosition   string `protobuf:"bytes,4,opt,name=wait_position,json=waitPosition,proto3" json:"wait_position,omitempty"`
	IncludePrimary bool   `protobuf:"varint,5,opt,name=include_primary,json=includePrimary,proto3" json:"include_primary,omitempty"`
	Concurrency    int32  `protobuf:"varint,6,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	// contains filtered or unexported fields
}

func (*ReloadSchemaShardRequest) CloneMessageVT 

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

func (*ReloadSchemaShardRequest) CloneVT 

func (m *ReloadSchemaShardRequest) CloneVT() *ReloadSchemaShardRequest

func (*ReloadSchemaShardRequest) Descriptor deprecated 

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

Deprecated: Use ReloadSchemaShardRequest.ProtoReflect.Descriptor instead.

func (*ReloadSchemaShardRequest) GetClusterId 

func (x *ReloadSchemaShardRequest) GetClusterId() string

func (*ReloadSchemaShardRequest) GetConcurrency 

func (x *ReloadSchemaShardRequest) GetConcurrency() int32

func (*ReloadSchemaShardRequest) GetIncludePrimary 

func (x *ReloadSchemaShardRequest) GetIncludePrimary() bool

func (*ReloadSchemaShardRequest) GetKeyspace 

func (x *ReloadSchemaShardRequest) GetKeyspace() string

func (*ReloadSchemaShardRequest) GetShard 

func (x *ReloadSchemaShardRequest) GetShard() string

func (*ReloadSchemaShardRequest) GetWaitPosition 

func (x *ReloadSchemaShardRequest) GetWaitPosition() string

func (*ReloadSchemaShardRequest) MarshalToSizedBufferVT 

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

func (*ReloadSchemaShardRequest) MarshalToVT 

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

func (*ReloadSchemaShardRequest) MarshalVT 

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

func (*ReloadSchemaShardRequest) ProtoMessage 

func (*ReloadSchemaShardRequest) ProtoMessage()

func (*ReloadSchemaShardRequest) ProtoReflect 

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

func (*ReloadSchemaShardRequest) Reset 

func (x *ReloadSchemaShardRequest) Reset()

func (*ReloadSchemaShardRequest) SizeVT 

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

func (*ReloadSchemaShardRequest) String 

func (x *ReloadSchemaShardRequest) String() string

func (*ReloadSchemaShardRequest) UnmarshalVT 

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

type ReloadSchemaShardResponse 

type ReloadSchemaShardResponse struct {
	Events []*logutil.Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*ReloadSchemaShardResponse) CloneMessageVT 

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

func (*ReloadSchemaShardResponse) CloneVT 

func (m *ReloadSchemaShardResponse) CloneVT() *ReloadSchemaShardResponse

func (*ReloadSchemaShardResponse) Descriptor deprecated 

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

Deprecated: Use ReloadSchemaShardResponse.ProtoReflect.Descriptor instead.

func (*ReloadSchemaShardResponse) GetEvents 

func (x *ReloadSchemaShardResponse) GetEvents() []*logutil.Event

func (*ReloadSchemaShardResponse) MarshalToSizedBufferVT 

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

func (*ReloadSchemaShardResponse) MarshalToVT 

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

func (*ReloadSchemaShardResponse) MarshalVT 

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

func (*ReloadSchemaShardResponse) ProtoMessage 

func (*ReloadSchemaShardResponse) ProtoMessage()

func (*ReloadSchemaShardResponse) ProtoReflect 

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

func (*ReloadSchemaShardResponse) Reset 

func (x *ReloadSchemaShardResponse) Reset()

func (*ReloadSchemaShardResponse) SizeVT 

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

func (*ReloadSchemaShardResponse) String 

func (x *ReloadSchemaShardResponse) String() string

func (*ReloadSchemaShardResponse) UnmarshalVT 

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

type ReloadSchemasRequest 

type ReloadSchemasRequest struct {

	// Keyspaces, if set, will reload schemas across one or more keyspaces. A
	// keyspace not existing in a cluster will not fail the overall request.
	//
	// Superceded by KeyspaceShards and Tablets, in that order.
	Keyspaces []string `protobuf:"bytes,1,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	// KeyspaceShards, if set, will reload schemas across one or more shards.
	// Each element must be a valid keyspace/shard according to
	// topoproto.ParseKeyspaceShard. A shard not existing in a cluster will not
	// fail the overall request.
	//
	// Supercedes Keyspaces, and is superceded by Tablets.
	KeyspaceShards []string `protobuf:"bytes,2,rep,name=keyspace_shards,json=keyspaceShards,proto3" json:"keyspace_shards,omitempty"`
	// Tablets, if set will reload schemas across one or more tablets.
	// Supercedes both Keyspaces and KeyspaceShards.
	Tablets []*topodata.TabletAlias `protobuf:"bytes,3,rep,name=tablets,proto3" json:"tablets,omitempty"`
	// ClusterIds optionally restricts the reload operation to clusters with
	// the specified IDs. An empty list of ClusterIds will operate on all
	// clusters.
	ClusterIds []string `protobuf:"bytes,4,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// Concurrency controls the number of tablets to reload at any given time.
	// Its semantics depend on whether the request is for keyspace, shard, or
	// tablet mode.
	//
	// In Keyspaces mode, Concurrency is the number of tablets to reload at once
	// *per keyspace*.
	//
	// In KeyspaceShards mode, Concurrency is the number of tablets to reload at
	// once *per shard*.
	//
	// In Tablets mode, Concurrency is the number of tablets to reload at once
	// *per cluster*.
	Concurrency int32 `protobuf:"varint,5,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	// WaitPosition is the replication position that replicating tablets should
	// reach prior to reloading their schemas.
	//
	// Does not apply in Tablets mode.
	WaitPosition string `protobuf:"bytes,6,opt,name=wait_position,json=waitPosition,proto3" json:"wait_position,omitempty"`
	// IncludePrimary, if set, will reload the schemas on PRIMARY tablets as
	// well as REPLICA and RDONLY.
	//
	// Does not apply in Tablets mode.
	IncludePrimary bool `protobuf:"varint,7,opt,name=include_primary,json=includePrimary,proto3" json:"include_primary,omitempty"`
	// contains filtered or unexported fields
}

func (*ReloadSchemasRequest) CloneMessageVT 

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

func (*ReloadSchemasRequest) CloneVT 

func (m *ReloadSchemasRequest) CloneVT() *ReloadSchemasRequest

func (*ReloadSchemasRequest) Descriptor deprecated 

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

Deprecated: Use ReloadSchemasRequest.ProtoReflect.Descriptor instead.

func (*ReloadSchemasRequest) GetClusterIds 

func (x *ReloadSchemasRequest) GetClusterIds() []string

func (*ReloadSchemasRequest) GetConcurrency 

func (x *ReloadSchemasRequest) GetConcurrency() int32

func (*ReloadSchemasRequest) GetIncludePrimary 

func (x *ReloadSchemasRequest) GetIncludePrimary() bool

func (*ReloadSchemasRequest) GetKeyspaceShards 

func (x *ReloadSchemasRequest) GetKeyspaceShards() []string

func (*ReloadSchemasRequest) GetKeyspaces 

func (x *ReloadSchemasRequest) GetKeyspaces() []string

func (*ReloadSchemasRequest) GetTablets 

func (x *ReloadSchemasRequest) GetTablets() []*topodata.TabletAlias

func (*ReloadSchemasRequest) GetWaitPosition 

func (x *ReloadSchemasRequest) GetWaitPosition() string

func (*ReloadSchemasRequest) MarshalToSizedBufferVT 

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

func (*ReloadSchemasRequest) MarshalToVT 

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

func (*ReloadSchemasRequest) MarshalVT 

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

func (*ReloadSchemasRequest) ProtoMessage 

func (*ReloadSchemasRequest) ProtoMessage()

func (*ReloadSchemasRequest) ProtoReflect 

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

func (*ReloadSchemasRequest) Reset 

func (x *ReloadSchemasRequest) Reset()

func (*ReloadSchemasRequest) SizeVT 

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

func (*ReloadSchemasRequest) String 

func (x *ReloadSchemasRequest) String() string

func (*ReloadSchemasRequest) UnmarshalVT 

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

type ReloadSchemasResponse 

type ReloadSchemasResponse struct {

	// KeyspaceResults is the list of KeyspaceResult objects for a ReloadSchemas
	// operation. It is only set when the request mandates Keyspaces mode (see
	// ReloadSchemasRequest).
	KeyspaceResults []*ReloadSchemasResponse_KeyspaceResult `protobuf:"bytes,1,rep,name=keyspace_results,json=keyspaceResults,proto3" json:"keyspace_results,omitempty"`
	// ShardResults is the list of ShardResult objects for a ReloadSchemas
	// operation. It is only set when the request mandates KeyspaceShards mode
	// (see ReloadSchemasRequest).
	ShardResults []*ReloadSchemasResponse_ShardResult `protobuf:"bytes,2,rep,name=shard_results,json=shardResults,proto3" json:"shard_results,omitempty"`
	// TabletResults is the list of TabletResult objects for a ReloadSchemas
	// operation. It is only set when the request mandates Tablets mode (see
	// ReloadSchemasRequest).
	TabletResults []*ReloadSchemasResponse_TabletResult `protobuf:"bytes,3,rep,name=tablet_results,json=tabletResults,proto3" json:"tablet_results,omitempty"`
	// contains filtered or unexported fields
}

func (*ReloadSchemasResponse) CloneMessageVT 

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

func (*ReloadSchemasResponse) CloneVT 

func (m *ReloadSchemasResponse) CloneVT() *ReloadSchemasResponse

func (*ReloadSchemasResponse) Descriptor deprecated 

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

Deprecated: Use ReloadSchemasResponse.ProtoReflect.Descriptor instead.

func (*ReloadSchemasResponse) GetKeyspaceResults 

func (x *ReloadSchemasResponse) GetKeyspaceResults() []*ReloadSchemasResponse_KeyspaceResult

func (*ReloadSchemasResponse) GetShardResults 

func (x *ReloadSchemasResponse) GetShardResults() []*ReloadSchemasResponse_ShardResult

func (*ReloadSchemasResponse) GetTabletResults 

func (x *ReloadSchemasResponse) GetTabletResults() []*ReloadSchemasResponse_TabletResult

func (*ReloadSchemasResponse) MarshalToSizedBufferVT 

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

func (*ReloadSchemasResponse) MarshalToVT 

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

func (*ReloadSchemasResponse) MarshalVT 

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

func (*ReloadSchemasResponse) ProtoMessage 

func (*ReloadSchemasResponse) ProtoMessage()

func (*ReloadSchemasResponse) ProtoReflect 

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

func (*ReloadSchemasResponse) Reset 

func (x *ReloadSchemasResponse) Reset()

func (*ReloadSchemasResponse) SizeVT 

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

func (*ReloadSchemasResponse) String 

func (x *ReloadSchemasResponse) String() string

func (*ReloadSchemasResponse) UnmarshalVT 

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

type ReloadSchemasResponse_KeyspaceResult 

type ReloadSchemasResponse_KeyspaceResult struct {
	Keyspace *Keyspace        `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Events   []*logutil.Event `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

KeyspaceResult is a grouping of a Keyspace and any log events that occurred in that keyspace during a schema reload (usually associated with partial errors - ReloadSchemas requests are best-effort).

It is only set when a ReloadSchemas request mandates Keyspaces mode (see ReloadSchemasRequest).

func (*ReloadSchemasResponse_KeyspaceResult) CloneMessageVT 

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

func (*ReloadSchemasResponse_KeyspaceResult) CloneVT 

func (m *ReloadSchemasResponse_KeyspaceResult) CloneVT() *ReloadSchemasResponse_KeyspaceResult

func (*ReloadSchemasResponse_KeyspaceResult) Descriptor deprecated 

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

Deprecated: Use ReloadSchemasResponse_KeyspaceResult.ProtoReflect.Descriptor instead.

func (*ReloadSchemasResponse_KeyspaceResult) GetEvents 

func (x *ReloadSchemasResponse_KeyspaceResult) GetEvents() []*logutil.Event

func (*ReloadSchemasResponse_KeyspaceResult) GetKeyspace 

func (x *ReloadSchemasResponse_KeyspaceResult) GetKeyspace() *Keyspace

func (*ReloadSchemasResponse_KeyspaceResult) MarshalToSizedBufferVT 

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

func (*ReloadSchemasResponse_KeyspaceResult) MarshalToVT 

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

func (*ReloadSchemasResponse_KeyspaceResult) MarshalVT 

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

func (*ReloadSchemasResponse_KeyspaceResult) ProtoMessage 

func (*ReloadSchemasResponse_KeyspaceResult) ProtoMessage()

func (*ReloadSchemasResponse_KeyspaceResult) ProtoReflect 

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

func (*ReloadSchemasResponse_KeyspaceResult) Reset 

func (x *ReloadSchemasResponse_KeyspaceResult) Reset()

func (*ReloadSchemasResponse_KeyspaceResult) SizeVT 

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

func (*ReloadSchemasResponse_KeyspaceResult) String 

func (x *ReloadSchemasResponse_KeyspaceResult) String() string

func (*ReloadSchemasResponse_KeyspaceResult) UnmarshalVT 

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

type ReloadSchemasResponse_ShardResult 

type ReloadSchemasResponse_ShardResult struct {
	Shard  *Shard           `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
	Events []*logutil.Event `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

ShardResult is a grouping of a Shard and any log events that occurred in that shard during a schema reload (usually associated with partial errors - ReloadSchemas requests are best-effort).

It is only set when a ReloadSchemas request mandates KeyspaceShards mode (see ReloadSchemasRequest).

func (*ReloadSchemasResponse_ShardResult) CloneMessageVT 

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

func (*ReloadSchemasResponse_ShardResult) CloneVT 

func (m *ReloadSchemasResponse_ShardResult) CloneVT() *ReloadSchemasResponse_ShardResult

func (*ReloadSchemasResponse_ShardResult) Descriptor deprecated 

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

Deprecated: Use ReloadSchemasResponse_ShardResult.ProtoReflect.Descriptor instead.

func (*ReloadSchemasResponse_ShardResult) GetEvents 

func (x *ReloadSchemasResponse_ShardResult) GetEvents() []*logutil.Event

func (*ReloadSchemasResponse_ShardResult) GetShard 

func (x *ReloadSchemasResponse_ShardResult) GetShard() *Shard

func (*ReloadSchemasResponse_ShardResult) MarshalToSizedBufferVT 

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

func (*ReloadSchemasResponse_ShardResult) MarshalToVT 

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

func (*ReloadSchemasResponse_ShardResult) MarshalVT 

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

func (*ReloadSchemasResponse_ShardResult) ProtoMessage 

func (*ReloadSchemasResponse_ShardResult) ProtoMessage()

func (*ReloadSchemasResponse_ShardResult) ProtoReflect 

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

func (*ReloadSchemasResponse_ShardResult) Reset 

func (x *ReloadSchemasResponse_ShardResult) Reset()

func (*ReloadSchemasResponse_ShardResult) SizeVT 

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

func (*ReloadSchemasResponse_ShardResult) String 

func (x *ReloadSchemasResponse_ShardResult) String() string

func (*ReloadSchemasResponse_ShardResult) UnmarshalVT 

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

type ReloadSchemasResponse_TabletResult 

type ReloadSchemasResponse_TabletResult struct {
	Tablet *Tablet `protobuf:"bytes,1,opt,name=tablet,proto3" json:"tablet,omitempty"`
	Result string  `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

TabletResult is a grouping of a Tablet and the result of reloading that Tablet's schema. Result will either be the string "ok", or the error message from that tablet. Note ReloadSchemas is best-effort, so tablet's failing to reload is not treated as an overall failure.

It is only set when a ReloadSchemas request mandates Tablets mode (see ReloadSchemasRequest).

func (*ReloadSchemasResponse_TabletResult) CloneMessageVT 

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

func (*ReloadSchemasResponse_TabletResult) CloneVT 

func (m *ReloadSchemasResponse_TabletResult) CloneVT() *ReloadSchemasResponse_TabletResult

func (*ReloadSchemasResponse_TabletResult) Descriptor deprecated 

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

Deprecated: Use ReloadSchemasResponse_TabletResult.ProtoReflect.Descriptor instead.

func (*ReloadSchemasResponse_TabletResult) GetResult 

func (x *ReloadSchemasResponse_TabletResult) GetResult() string

func (*ReloadSchemasResponse_TabletResult) GetTablet 

func (x *ReloadSchemasResponse_TabletResult) GetTablet() *Tablet

func (*ReloadSchemasResponse_TabletResult) MarshalToSizedBufferVT 

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

func (*ReloadSchemasResponse_TabletResult) MarshalToVT 

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

func (*ReloadSchemasResponse_TabletResult) MarshalVT 

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

func (*ReloadSchemasResponse_TabletResult) ProtoMessage 

func (*ReloadSchemasResponse_TabletResult) ProtoMessage()

func (*ReloadSchemasResponse_TabletResult) ProtoReflect 

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

func (*ReloadSchemasResponse_TabletResult) Reset 

func (x *ReloadSchemasResponse_TabletResult) Reset()

func (*ReloadSchemasResponse_TabletResult) SizeVT 

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

func (*ReloadSchemasResponse_TabletResult) String 

func (x *ReloadSchemasResponse_TabletResult) String() string

func (*ReloadSchemasResponse_TabletResult) UnmarshalVT 

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

type RemoveKeyspaceCellRequest 

type RemoveKeyspaceCellRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Cell      string `protobuf:"bytes,3,opt,name=cell,proto3" json:"cell,omitempty"`
	Force     bool   `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"`
	Recursive bool   `protobuf:"varint,5,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveKeyspaceCellRequest) CloneMessageVT 

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

func (*RemoveKeyspaceCellRequest) CloneVT 

func (m *RemoveKeyspaceCellRequest) CloneVT() *RemoveKeyspaceCellRequest

func (*RemoveKeyspaceCellRequest) Descriptor deprecated 

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

Deprecated: Use RemoveKeyspaceCellRequest.ProtoReflect.Descriptor instead.

func (*RemoveKeyspaceCellRequest) GetCell 

func (x *RemoveKeyspaceCellRequest) GetCell() string

func (*RemoveKeyspaceCellRequest) GetClusterId 

func (x *RemoveKeyspaceCellRequest) GetClusterId() string

func (*RemoveKeyspaceCellRequest) GetForce 

func (x *RemoveKeyspaceCellRequest) GetForce() bool

func (*RemoveKeyspaceCellRequest) GetKeyspace 

func (x *RemoveKeyspaceCellRequest) GetKeyspace() string

func (*RemoveKeyspaceCellRequest) GetRecursive 

func (x *RemoveKeyspaceCellRequest) GetRecursive() bool

func (*RemoveKeyspaceCellRequest) MarshalToSizedBufferVT 

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

func (*RemoveKeyspaceCellRequest) MarshalToVT 

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

func (*RemoveKeyspaceCellRequest) MarshalVT 

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

func (*RemoveKeyspaceCellRequest) ProtoMessage 

func (*RemoveKeyspaceCellRequest) ProtoMessage()

func (*RemoveKeyspaceCellRequest) ProtoReflect 

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

func (*RemoveKeyspaceCellRequest) Reset 

func (x *RemoveKeyspaceCellRequest) Reset()

func (*RemoveKeyspaceCellRequest) SizeVT 

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

func (*RemoveKeyspaceCellRequest) String 

func (x *RemoveKeyspaceCellRequest) String() string

func (*RemoveKeyspaceCellRequest) UnmarshalVT 

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

type RemoveKeyspaceCellResponse 

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

func (*RemoveKeyspaceCellResponse) CloneMessageVT 

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

func (*RemoveKeyspaceCellResponse) CloneVT 

func (m *RemoveKeyspaceCellResponse) CloneVT() *RemoveKeyspaceCellResponse

func (*RemoveKeyspaceCellResponse) Descriptor deprecated 

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

Deprecated: Use RemoveKeyspaceCellResponse.ProtoReflect.Descriptor instead.

func (*RemoveKeyspaceCellResponse) GetStatus 

func (x *RemoveKeyspaceCellResponse) GetStatus() string

func (*RemoveKeyspaceCellResponse) MarshalToSizedBufferVT 

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

func (*RemoveKeyspaceCellResponse) MarshalToVT 

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

func (*RemoveKeyspaceCellResponse) MarshalVT 

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

func (*RemoveKeyspaceCellResponse) ProtoMessage 

func (*RemoveKeyspaceCellResponse) ProtoMessage()

func (*RemoveKeyspaceCellResponse) ProtoReflect 

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

func (*RemoveKeyspaceCellResponse) Reset 

func (x *RemoveKeyspaceCellResponse) Reset()

func (*RemoveKeyspaceCellResponse) SizeVT 

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

func (*RemoveKeyspaceCellResponse) String 

func (x *RemoveKeyspaceCellResponse) String() string

func (*RemoveKeyspaceCellResponse) UnmarshalVT 

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

type RetrySchemaMigrationRequest 

type RetrySchemaMigrationRequest struct {
	ClusterId string                                 `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *vtctldata.RetrySchemaMigrationRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*RetrySchemaMigrationRequest) CloneMessageVT 

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

func (*RetrySchemaMigrationRequest) CloneVT 

func (m *RetrySchemaMigrationRequest) CloneVT() *RetrySchemaMigrationRequest

func (*RetrySchemaMigrationRequest) Descriptor deprecated 

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

Deprecated: Use RetrySchemaMigrationRequest.ProtoReflect.Descriptor instead.

func (*RetrySchemaMigrationRequest) GetClusterId 

func (x *RetrySchemaMigrationRequest) GetClusterId() string

func (*RetrySchemaMigrationRequest) GetRequest 

func (x *RetrySchemaMigrationRequest) GetRequest() *vtctldata.RetrySchemaMigrationRequest

func (*RetrySchemaMigrationRequest) MarshalToSizedBufferVT 

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

func (*RetrySchemaMigrationRequest) MarshalToVT 

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

func (*RetrySchemaMigrationRequest) MarshalVT 

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

func (*RetrySchemaMigrationRequest) ProtoMessage 

func (*RetrySchemaMigrationRequest) ProtoMessage()

func (*RetrySchemaMigrationRequest) ProtoReflect 

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

func (*RetrySchemaMigrationRequest) Reset 

func (x *RetrySchemaMigrationRequest) Reset()

func (*RetrySchemaMigrationRequest) SizeVT 

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

func (*RetrySchemaMigrationRequest) String 

func (x *RetrySchemaMigrationRequest) String() string

func (*RetrySchemaMigrationRequest) UnmarshalVT 

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

type RunHealthCheckRequest 

type RunHealthCheckRequest struct {
	Alias      *topodata.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string              `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*RunHealthCheckRequest) CloneMessageVT 

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

func (*RunHealthCheckRequest) CloneVT 

func (m *RunHealthCheckRequest) CloneVT() *RunHealthCheckRequest

func (*RunHealthCheckRequest) Descriptor deprecated 

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

Deprecated: Use RunHealthCheckRequest.ProtoReflect.Descriptor instead.

func (*RunHealthCheckRequest) GetAlias 

func (x *RunHealthCheckRequest) GetAlias() *topodata.TabletAlias

func (*RunHealthCheckRequest) GetClusterIds 

func (x *RunHealthCheckRequest) GetClusterIds() []string

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 {
	Status  string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*RunHealthCheckResponse) CloneMessageVT 

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

func (*RunHealthCheckResponse) CloneVT 

func (m *RunHealthCheckResponse) CloneVT() *RunHealthCheckResponse

func (*RunHealthCheckResponse) Descriptor deprecated 

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

Deprecated: Use RunHealthCheckResponse.ProtoReflect.Descriptor instead.

func (*RunHealthCheckResponse) GetCluster 

func (x *RunHealthCheckResponse) GetCluster() *Cluster

func (*RunHealthCheckResponse) GetStatus 

func (x *RunHealthCheckResponse) GetStatus() string

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 Schema 

type Schema struct {
	Cluster          *Cluster                             `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace         string                               `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	TableDefinitions []*tabletmanagerdata.TableDefinition `protobuf:"bytes,3,rep,name=table_definitions,json=tableDefinitions,proto3" json:"table_definitions,omitempty"`
	// TableSizes is a mapping of table name to TableSize information.
	TableSizes map[string]*Schema_TableSize `` /* 179-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Schema) CloneMessageVT 

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

func (*Schema) CloneVT 

func (m *Schema) CloneVT() *Schema

func (*Schema) Descriptor deprecated 

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetCluster 

func (x *Schema) GetCluster() *Cluster

func (*Schema) GetKeyspace 

func (x *Schema) GetKeyspace() string

func (*Schema) GetTableDefinitions 

func (x *Schema) GetTableDefinitions() []*tabletmanagerdata.TableDefinition

func (*Schema) GetTableSizes 

func (x *Schema) GetTableSizes() map[string]*Schema_TableSize

func (*Schema) MarshalToSizedBufferVT 

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

func (*Schema) MarshalToVT 

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

func (*Schema) MarshalVT 

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

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect 

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

func (*Schema) Reset 

func (x *Schema) Reset()

func (*Schema) SizeVT 

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

func (*Schema) String 

func (x *Schema) String() string

func (*Schema) UnmarshalVT 

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

type SchemaMigration 

type SchemaMigration struct {
	Cluster         *Cluster                   `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	SchemaMigration *vtctldata.SchemaMigration `protobuf:"bytes,2,opt,name=schema_migration,json=schemaMigration,proto3" json:"schema_migration,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaMigration) CloneMessageVT 

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

func (*SchemaMigration) CloneVT 

func (m *SchemaMigration) CloneVT() *SchemaMigration

func (*SchemaMigration) Descriptor deprecated 

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

Deprecated: Use SchemaMigration.ProtoReflect.Descriptor instead.

func (*SchemaMigration) GetCluster 

func (x *SchemaMigration) GetCluster() *Cluster

func (*SchemaMigration) GetSchemaMigration 

func (x *SchemaMigration) GetSchemaMigration() *vtctldata.SchemaMigration

func (*SchemaMigration) MarshalToSizedBufferVT 

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

func (*SchemaMigration) MarshalToVT 

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

func (*SchemaMigration) MarshalVT 

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

func (*SchemaMigration) ProtoMessage 

func (*SchemaMigration) ProtoMessage()

func (*SchemaMigration) ProtoReflect 

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

func (*SchemaMigration) Reset 

func (x *SchemaMigration) Reset()

func (*SchemaMigration) SizeVT 

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

func (*SchemaMigration) String 

func (x *SchemaMigration) String() string

func (*SchemaMigration) UnmarshalVT 

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

type Schema_ShardTableSize 

type Schema_ShardTableSize struct {
	RowCount   uint64 `protobuf:"varint,1,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	DataLength uint64 `protobuf:"varint,2,opt,name=data_length,json=dataLength,proto3" json:"data_length,omitempty"`
	// contains filtered or unexported fields
}

func (*Schema_ShardTableSize) CloneMessageVT 

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

func (*Schema_ShardTableSize) CloneVT 

func (m *Schema_ShardTableSize) CloneVT() *Schema_ShardTableSize

func (*Schema_ShardTableSize) Descriptor deprecated 

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

Deprecated: Use Schema_ShardTableSize.ProtoReflect.Descriptor instead.

func (*Schema_ShardTableSize) GetDataLength 

func (x *Schema_ShardTableSize) GetDataLength() uint64

func (*Schema_ShardTableSize) GetRowCount 

func (x *Schema_ShardTableSize) GetRowCount() uint64

func (*Schema_ShardTableSize) MarshalToSizedBufferVT 

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

func (*Schema_ShardTableSize) MarshalToVT 

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

func (*Schema_ShardTableSize) MarshalVT 

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

func (*Schema_ShardTableSize) ProtoMessage 

func (*Schema_ShardTableSize) ProtoMessage()

func (*Schema_ShardTableSize) ProtoReflect 

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

func (*Schema_ShardTableSize) Reset 

func (x *Schema_ShardTableSize) Reset()

func (*Schema_ShardTableSize) SizeVT 

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

func (*Schema_ShardTableSize) String 

func (x *Schema_ShardTableSize) String() string

func (*Schema_ShardTableSize) UnmarshalVT 

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

type Schema_TableSize 

type Schema_TableSize struct {
	RowCount   uint64                            `protobuf:"varint,1,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	DataLength uint64                            `protobuf:"varint,2,opt,name=data_length,json=dataLength,proto3" json:"data_length,omitempty"`
	ByShard    map[string]*Schema_ShardTableSize `` /* 170-byte string literal not displayed */
	// contains filtered or unexported fields
}

TableSize aggregates table size information across all shards containing in the given keyspace and cluster, as well as per-shard size information.

func (*Schema_TableSize) CloneMessageVT 

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

func (*Schema_TableSize) CloneVT 

func (m *Schema_TableSize) CloneVT() *Schema_TableSize

func (*Schema_TableSize) Descriptor deprecated 

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

Deprecated: Use Schema_TableSize.ProtoReflect.Descriptor instead.

func (*Schema_TableSize) GetByShard 

func (x *Schema_TableSize) GetByShard() map[string]*Schema_ShardTableSize

func (*Schema_TableSize) GetDataLength 

func (x *Schema_TableSize) GetDataLength() uint64

func (*Schema_TableSize) GetRowCount 

func (x *Schema_TableSize) GetRowCount() uint64

func (*Schema_TableSize) MarshalToSizedBufferVT 

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

func (*Schema_TableSize) MarshalToVT 

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

func (*Schema_TableSize) MarshalVT 

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

func (*Schema_TableSize) ProtoMessage 

func (*Schema_TableSize) ProtoMessage()

func (*Schema_TableSize) ProtoReflect 

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

func (*Schema_TableSize) Reset 

func (x *Schema_TableSize) Reset()

func (*Schema_TableSize) SizeVT 

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

func (*Schema_TableSize) String 

func (x *Schema_TableSize) String() string

func (*Schema_TableSize) UnmarshalVT 

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

type SetReadOnlyRequest 

type SetReadOnlyRequest struct {
	Alias      *topodata.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string              `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*SetReadOnlyRequest) CloneMessageVT 

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

func (*SetReadOnlyRequest) CloneVT 

func (m *SetReadOnlyRequest) CloneVT() *SetReadOnlyRequest

func (*SetReadOnlyRequest) Descriptor deprecated 

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

Deprecated: Use SetReadOnlyRequest.ProtoReflect.Descriptor instead.

func (*SetReadOnlyRequest) GetAlias 

func (x *SetReadOnlyRequest) GetAlias() *topodata.TabletAlias

func (*SetReadOnlyRequest) GetClusterIds 

func (x *SetReadOnlyRequest) GetClusterIds() []string

func (*SetReadOnlyRequest) MarshalToSizedBufferVT 

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

func (*SetReadOnlyRequest) MarshalToVT 

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

func (*SetReadOnlyRequest) MarshalVT 

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

func (*SetReadOnlyRequest) ProtoMessage 

func (*SetReadOnlyRequest) ProtoMessage()

func (*SetReadOnlyRequest) ProtoReflect 

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

func (*SetReadOnlyRequest) Reset 

func (x *SetReadOnlyRequest) Reset()

func (*SetReadOnlyRequest) SizeVT 

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

func (*SetReadOnlyRequest) String 

func (x *SetReadOnlyRequest) String() string

func (*SetReadOnlyRequest) UnmarshalVT 

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

type SetReadOnlyResponse 

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

func (*SetReadOnlyResponse) CloneMessageVT 

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

func (*SetReadOnlyResponse) CloneVT 

func (m *SetReadOnlyResponse) CloneVT() *SetReadOnlyResponse

func (*SetReadOnlyResponse) Descriptor deprecated 

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

Deprecated: Use SetReadOnlyResponse.ProtoReflect.Descriptor instead.

func (*SetReadOnlyResponse) MarshalToSizedBufferVT 

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

func (*SetReadOnlyResponse) MarshalToVT 

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

func (*SetReadOnlyResponse) MarshalVT 

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

func (*SetReadOnlyResponse) ProtoMessage 

func (*SetReadOnlyResponse) ProtoMessage()

func (*SetReadOnlyResponse) ProtoReflect 

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

func (*SetReadOnlyResponse) Reset 

func (x *SetReadOnlyResponse) Reset()

func (*SetReadOnlyResponse) SizeVT 

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

func (*SetReadOnlyResponse) String 

func (x *SetReadOnlyResponse) String() string

func (*SetReadOnlyResponse) UnmarshalVT 

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

type SetReadWriteRequest 

type SetReadWriteRequest struct {
	Alias      *topodata.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string              `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*SetReadWriteRequest) CloneMessageVT 

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

func (*SetReadWriteRequest) CloneVT 

func (m *SetReadWriteRequest) CloneVT() *SetReadWriteRequest

func (*SetReadWriteRequest) Descriptor deprecated 

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

Deprecated: Use SetReadWriteRequest.ProtoReflect.Descriptor instead.

func (*SetReadWriteRequest) GetAlias 

func (x *SetReadWriteRequest) GetAlias() *topodata.TabletAlias

func (*SetReadWriteRequest) GetClusterIds 

func (x *SetReadWriteRequest) GetClusterIds() []string

func (*SetReadWriteRequest) MarshalToSizedBufferVT 

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

func (*SetReadWriteRequest) MarshalToVT 

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

func (*SetReadWriteRequest) MarshalVT 

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

func (*SetReadWriteRequest) ProtoMessage 

func (*SetReadWriteRequest) ProtoMessage()

func (*SetReadWriteRequest) ProtoReflect 

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

func (*SetReadWriteRequest) Reset 

func (x *SetReadWriteRequest) Reset()

func (*SetReadWriteRequest) SizeVT 

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

func (*SetReadWriteRequest) String 

func (x *SetReadWriteRequest) String() string

func (*SetReadWriteRequest) UnmarshalVT 

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

type SetReadWriteResponse 

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

func (*SetReadWriteResponse) CloneMessageVT 

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

func (*SetReadWriteResponse) CloneVT 

func (m *SetReadWriteResponse) CloneVT() *SetReadWriteResponse

func (*SetReadWriteResponse) Descriptor deprecated 

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

Deprecated: Use SetReadWriteResponse.ProtoReflect.Descriptor instead.

func (*SetReadWriteResponse) MarshalToSizedBufferVT 

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

func (*SetReadWriteResponse) MarshalToVT 

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

func (*SetReadWriteResponse) MarshalVT 

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

func (*SetReadWriteResponse) ProtoMessage 

func (*SetReadWriteResponse) ProtoMessage()

func (*SetReadWriteResponse) ProtoReflect 

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

func (*SetReadWriteResponse) Reset 

func (x *SetReadWriteResponse) Reset()

func (*SetReadWriteResponse) SizeVT 

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

func (*SetReadWriteResponse) String 

func (x *SetReadWriteResponse) String() string

func (*SetReadWriteResponse) UnmarshalVT 

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

type Shard 

type Shard struct {
	Cluster *Cluster         `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Shard   *vtctldata.Shard `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

Shard groups the vtctldata information about a shard record together with the Vitess cluster it belongs to.

func (*Shard) CloneMessageVT 

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

func (*Shard) CloneVT 

func (m *Shard) CloneVT() *Shard

func (*Shard) Descriptor deprecated 

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

Deprecated: Use Shard.ProtoReflect.Descriptor instead.

func (*Shard) GetCluster 

func (x *Shard) GetCluster() *Cluster

func (*Shard) GetShard 

func (x *Shard) GetShard() *vtctldata.Shard

func (*Shard) MarshalToSizedBufferVT 

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

func (*Shard) MarshalToVT 

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

func (*Shard) MarshalVT 

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

func (*Shard) ProtoMessage 

func (*Shard) ProtoMessage()

func (*Shard) ProtoReflect 

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

func (*Shard) Reset 

func (x *Shard) Reset()

func (*Shard) SizeVT 

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

func (*Shard) String 

func (x *Shard) String() string

func (*Shard) UnmarshalVT 

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

type SrvVSchema 

type SrvVSchema struct {
	Cell       string              `protobuf:"bytes,1,opt,name=cell,proto3" json:"cell,omitempty"`
	Cluster    *Cluster            `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	SrvVSchema *vschema.SrvVSchema `protobuf:"bytes,3,opt,name=srv_v_schema,json=srvVSchema,proto3" json:"srv_v_schema,omitempty"`
	// contains filtered or unexported fields
}

func (*SrvVSchema) CloneMessageVT 

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

func (*SrvVSchema) CloneVT 

func (m *SrvVSchema) CloneVT() *SrvVSchema

func (*SrvVSchema) Descriptor deprecated 

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

Deprecated: Use SrvVSchema.ProtoReflect.Descriptor instead.

func (*SrvVSchema) GetCell 

func (x *SrvVSchema) GetCell() string

func (*SrvVSchema) GetCluster 

func (x *SrvVSchema) GetCluster() *Cluster

func (*SrvVSchema) GetSrvVSchema 

func (x *SrvVSchema) GetSrvVSchema() *vschema.SrvVSchema

func (*SrvVSchema) MarshalToSizedBufferVT 

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

func (*SrvVSchema) MarshalToVT 

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

func (*SrvVSchema) MarshalVT 

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

func (*SrvVSchema) ProtoMessage 

func (*SrvVSchema) ProtoMessage()

func (*SrvVSchema) ProtoReflect 

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

func (*SrvVSchema) Reset 

func (x *SrvVSchema) Reset()

func (*SrvVSchema) SizeVT 

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

func (*SrvVSchema) String 

func (x *SrvVSchema) String() string

func (*SrvVSchema) UnmarshalVT 

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

type StartReplicationRequest 

type StartReplicationRequest struct {
	Alias      *topodata.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string              `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*StartReplicationRequest) CloneMessageVT 

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

func (*StartReplicationRequest) CloneVT 

func (m *StartReplicationRequest) CloneVT() *StartReplicationRequest

func (*StartReplicationRequest) Descriptor deprecated 

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

Deprecated: Use StartReplicationRequest.ProtoReflect.Descriptor instead.

func (*StartReplicationRequest) GetAlias 

func (x *StartReplicationRequest) GetAlias() *topodata.TabletAlias

func (*StartReplicationRequest) GetClusterIds 

func (x *StartReplicationRequest) GetClusterIds() []string

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 {
	Status  string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*StartReplicationResponse) CloneMessageVT 

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

func (*StartReplicationResponse) CloneVT 

func (m *StartReplicationResponse) CloneVT() *StartReplicationResponse

func (*StartReplicationResponse) Descriptor deprecated 

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

Deprecated: Use StartReplicationResponse.ProtoReflect.Descriptor instead.

func (*StartReplicationResponse) GetCluster 

func (x *StartReplicationResponse) GetCluster() *Cluster

func (*StartReplicationResponse) GetStatus 

func (x *StartReplicationResponse) GetStatus() string

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 StopReplicationRequest 

type StopReplicationRequest struct {
	Alias      *topodata.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string              `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*StopReplicationRequest) CloneMessageVT 

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

func (*StopReplicationRequest) CloneVT 

func (m *StopReplicationRequest) CloneVT() *StopReplicationRequest

func (*StopReplicationRequest) Descriptor deprecated 

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

Deprecated: Use StopReplicationRequest.ProtoReflect.Descriptor instead.

func (*StopReplicationRequest) GetAlias 

func (x *StopReplicationRequest) GetAlias() *topodata.TabletAlias

func (*StopReplicationRequest) GetClusterIds 

func (x *StopReplicationRequest) GetClusterIds() []string

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 {
	Status  string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*StopReplicationResponse) CloneMessageVT 

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

func (*StopReplicationResponse) CloneVT 

func (m *StopReplicationResponse) CloneVT() *StopReplicationResponse

func (*StopReplicationResponse) Descriptor deprecated 

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

Deprecated: Use StopReplicationResponse.ProtoReflect.Descriptor instead.

func (*StopReplicationResponse) GetCluster 

func (x *StopReplicationResponse) GetCluster() *Cluster

func (*StopReplicationResponse) GetStatus 

func (x *StopReplicationResponse) GetStatus() string

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 Tablet 

type Tablet struct {
	Cluster *Cluster            `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Tablet  *topodata.Tablet    `protobuf:"bytes,2,opt,name=tablet,proto3" json:"tablet,omitempty"`
	State   Tablet_ServingState `protobuf:"varint,3,opt,name=state,proto3,enum=vtadmin.Tablet_ServingState" json:"state,omitempty"`
	FQDN    string              `protobuf:"bytes,4,opt,name=FQDN,proto3" json:"FQDN,omitempty"`
	// contains filtered or unexported fields
}

Tablet groups the topo information of a tablet together with the Vitess cluster it belongs to.

func (*Tablet) CloneMessageVT 

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

func (*Tablet) CloneVT 

func (m *Tablet) CloneVT() *Tablet

func (*Tablet) Descriptor deprecated 

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

Deprecated: Use Tablet.ProtoReflect.Descriptor instead.

func (*Tablet) GetCluster 

func (x *Tablet) GetCluster() *Cluster

func (*Tablet) GetFQDN 

func (x *Tablet) GetFQDN() string

func (*Tablet) GetState 

func (x *Tablet) GetState() Tablet_ServingState

func (*Tablet) GetTablet 

func (x *Tablet) GetTablet() *topodata.Tablet

func (*Tablet) MarshalToSizedBufferVT 

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

func (*Tablet) MarshalToVT 

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

func (*Tablet) MarshalVT 

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

func (*Tablet) ProtoMessage 

func (*Tablet) ProtoMessage()

func (*Tablet) ProtoReflect 

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

func (*Tablet) Reset 

func (x *Tablet) Reset()

func (*Tablet) SizeVT 

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

func (*Tablet) String 

func (x *Tablet) String() string

func (*Tablet) UnmarshalVT 

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

type TabletExternallyPromotedRequest 

type TabletExternallyPromotedRequest struct {

	// Tablet is the alias of the tablet that was promoted externally and should
	// be updated to the shard primary in the topo.
	Alias      *topodata.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string              `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*TabletExternallyPromotedRequest) CloneMessageVT 

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

func (*TabletExternallyPromotedRequest) CloneVT 

func (m *TabletExternallyPromotedRequest) CloneVT() *TabletExternallyPromotedRequest

func (*TabletExternallyPromotedRequest) Descriptor deprecated 

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

Deprecated: Use TabletExternallyPromotedRequest.ProtoReflect.Descriptor instead.

func (*TabletExternallyPromotedRequest) GetAlias 

func (x *TabletExternallyPromotedRequest) GetAlias() *topodata.TabletAlias

func (*TabletExternallyPromotedRequest) GetClusterIds 

func (x *TabletExternallyPromotedRequest) GetClusterIds() []string

func (*TabletExternallyPromotedRequest) MarshalToSizedBufferVT 

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

func (*TabletExternallyPromotedRequest) MarshalToVT 

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

func (*TabletExternallyPromotedRequest) MarshalVT 

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

func (*TabletExternallyPromotedRequest) ProtoMessage 

func (*TabletExternallyPromotedRequest) ProtoMessage()

func (*TabletExternallyPromotedRequest) ProtoReflect 

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

func (*TabletExternallyPromotedRequest) Reset 

func (x *TabletExternallyPromotedRequest) Reset()

func (*TabletExternallyPromotedRequest) SizeVT 

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

func (*TabletExternallyPromotedRequest) String 

func (x *TabletExternallyPromotedRequest) String() string

func (*TabletExternallyPromotedRequest) UnmarshalVT 

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

type TabletExternallyPromotedResponse 

type TabletExternallyPromotedResponse struct {
	Cluster    *Cluster              `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace   string                `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard      string                `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	NewPrimary *topodata.TabletAlias `protobuf:"bytes,4,opt,name=new_primary,json=newPrimary,proto3" json:"new_primary,omitempty"`
	OldPrimary *topodata.TabletAlias `protobuf:"bytes,5,opt,name=old_primary,json=oldPrimary,proto3" json:"old_primary,omitempty"`
	// contains filtered or unexported fields
}

func (*TabletExternallyPromotedResponse) CloneMessageVT 

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

func (*TabletExternallyPromotedResponse) CloneVT 

func (m *TabletExternallyPromotedResponse) CloneVT() *TabletExternallyPromotedResponse

func (*TabletExternallyPromotedResponse) Descriptor deprecated 

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

Deprecated: Use TabletExternallyPromotedResponse.ProtoReflect.Descriptor instead.

func (*TabletExternallyPromotedResponse) GetCluster 

func (x *TabletExternallyPromotedResponse) GetCluster() *Cluster

func (*TabletExternallyPromotedResponse) GetKeyspace 

func (x *TabletExternallyPromotedResponse) GetKeyspace() string

func (*TabletExternallyPromotedResponse) GetNewPrimary 

func (x *TabletExternallyPromotedResponse) GetNewPrimary() *topodata.TabletAlias

func (*TabletExternallyPromotedResponse) GetOldPrimary 

func (x *TabletExternallyPromotedResponse) GetOldPrimary() *topodata.TabletAlias

func (*TabletExternallyPromotedResponse) GetShard 

func (x *TabletExternallyPromotedResponse) GetShard() string

func (*TabletExternallyPromotedResponse) MarshalToSizedBufferVT 

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

func (*TabletExternallyPromotedResponse) MarshalToVT 

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

func (*TabletExternallyPromotedResponse) MarshalVT 

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

func (*TabletExternallyPromotedResponse) ProtoMessage 

func (*TabletExternallyPromotedResponse) ProtoMessage()

func (*TabletExternallyPromotedResponse) ProtoReflect 

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

func (*TabletExternallyPromotedResponse) Reset 

func (x *TabletExternallyPromotedResponse) Reset()

func (*TabletExternallyPromotedResponse) SizeVT 

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

func (*TabletExternallyPromotedResponse) String 

func (x *TabletExternallyPromotedResponse) String() string

func (*TabletExternallyPromotedResponse) UnmarshalVT 

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

type TabletExternallyReparentedRequest 

type TabletExternallyReparentedRequest struct {
	Alias      *topodata.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string              `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*TabletExternallyReparentedRequest) CloneMessageVT 

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

func (*TabletExternallyReparentedRequest) CloneVT 

func (m *TabletExternallyReparentedRequest) CloneVT() *TabletExternallyReparentedRequest

func (*TabletExternallyReparentedRequest) Descriptor deprecated 

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

Deprecated: Use TabletExternallyReparentedRequest.ProtoReflect.Descriptor instead.

func (*TabletExternallyReparentedRequest) GetAlias 

func (x *TabletExternallyReparentedRequest) GetAlias() *topodata.TabletAlias

func (*TabletExternallyReparentedRequest) GetClusterIds 

func (x *TabletExternallyReparentedRequest) GetClusterIds() []string

func (*TabletExternallyReparentedRequest) MarshalToSizedBufferVT 

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

func (*TabletExternallyReparentedRequest) MarshalToVT 

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

func (*TabletExternallyReparentedRequest) MarshalVT 

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

func (*TabletExternallyReparentedRequest) ProtoMessage 

func (*TabletExternallyReparentedRequest) ProtoMessage()

func (*TabletExternallyReparentedRequest) ProtoReflect 

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

func (*TabletExternallyReparentedRequest) Reset 

func (x *TabletExternallyReparentedRequest) Reset()

func (*TabletExternallyReparentedRequest) SizeVT 

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

func (*TabletExternallyReparentedRequest) String 

func (x *TabletExternallyReparentedRequest) String() string

func (*TabletExternallyReparentedRequest) UnmarshalVT 

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

type Tablet_ServingState 

type Tablet_ServingState int32
const (
	Tablet_UNKNOWN     Tablet_ServingState = 0
	Tablet_SERVING     Tablet_ServingState = 1
	Tablet_NOT_SERVING Tablet_ServingState = 2
)

func (Tablet_ServingState) Descriptor 

func (Tablet_ServingState) Descriptor() protoreflect.EnumDescriptor

func (Tablet_ServingState) Enum 

func (x Tablet_ServingState) Enum() *Tablet_ServingState

func (Tablet_ServingState) EnumDescriptor deprecated 

func (Tablet_ServingState) EnumDescriptor() ([]byte, []int)

Deprecated: Use Tablet_ServingState.Descriptor instead.

func (Tablet_ServingState) Number 

func (x Tablet_ServingState) Number() protoreflect.EnumNumber

func (Tablet_ServingState) String 

func (x Tablet_ServingState) String() string

func (Tablet_ServingState) Type 

func (Tablet_ServingState) Type() protoreflect.EnumType

type UnimplementedVTAdminServer 

type UnimplementedVTAdminServer struct {
}

UnimplementedVTAdminServer must be embedded to have forward compatible implementations.

func (UnimplementedVTAdminServer) ApplySchema 

func (UnimplementedVTAdminServer) ApplySchema(context.Context, *ApplySchemaRequest) (*vtctldata.ApplySchemaResponse, error)

func (UnimplementedVTAdminServer) CancelSchemaMigration 

func (UnimplementedVTAdminServer) CancelSchemaMigration(context.Context, *CancelSchemaMigrationRequest) (*vtctldata.CancelSchemaMigrationResponse, error)

func (UnimplementedVTAdminServer) CleanupSchemaMigration 

func (UnimplementedVTAdminServer) CleanupSchemaMigration(context.Context, *CleanupSchemaMigrationRequest) (*vtctldata.CleanupSchemaMigrationResponse, error)

func (UnimplementedVTAdminServer) CompleteSchemaMigration 

func (UnimplementedVTAdminServer) CompleteSchemaMigration(context.Context, *CompleteSchemaMigrationRequest) (*vtctldata.CompleteSchemaMigrationResponse, error)

func (UnimplementedVTAdminServer) CreateKeyspace 

func (UnimplementedVTAdminServer) CreateKeyspace(context.Context, *CreateKeyspaceRequest) (*CreateKeyspaceResponse, error)

func (UnimplementedVTAdminServer) CreateShard 

func (UnimplementedVTAdminServer) CreateShard(context.Context, *CreateShardRequest) (*vtctldata.CreateShardResponse, error)

func (UnimplementedVTAdminServer) DeleteKeyspace 

func (UnimplementedVTAdminServer) DeleteKeyspace(context.Context, *DeleteKeyspaceRequest) (*vtctldata.DeleteKeyspaceResponse, error)

func (UnimplementedVTAdminServer) DeleteShards 

func (UnimplementedVTAdminServer) DeleteShards(context.Context, *DeleteShardsRequest) (*vtctldata.DeleteShardsResponse, error)

func (UnimplementedVTAdminServer) DeleteTablet 

func (UnimplementedVTAdminServer) DeleteTablet(context.Context, *DeleteTabletRequest) (*DeleteTabletResponse, error)

func (UnimplementedVTAdminServer) EmergencyFailoverShard 

func (UnimplementedVTAdminServer) EmergencyFailoverShard(context.Context, *EmergencyFailoverShardRequest) (*EmergencyFailoverShardResponse, error)

func (UnimplementedVTAdminServer) FindSchema 

func (UnimplementedVTAdminServer) FindSchema(context.Context, *FindSchemaRequest) (*Schema, error)

func (UnimplementedVTAdminServer) GetBackups 

func (UnimplementedVTAdminServer) GetBackups(context.Context, *GetBackupsRequest) (*GetBackupsResponse, error)

func (UnimplementedVTAdminServer) GetCellInfos 

func (UnimplementedVTAdminServer) GetCellInfos(context.Context, *GetCellInfosRequest) (*GetCellInfosResponse, error)

func (UnimplementedVTAdminServer) GetCellsAliases 

func (UnimplementedVTAdminServer) GetCellsAliases(context.Context, *GetCellsAliasesRequest) (*GetCellsAliasesResponse, error)

func (UnimplementedVTAdminServer) GetClusters 

func (UnimplementedVTAdminServer) GetClusters(context.Context, *GetClustersRequest) (*GetClustersResponse, error)

func (UnimplementedVTAdminServer) GetFullStatus 

func (UnimplementedVTAdminServer) GetFullStatus(context.Context, *GetFullStatusRequest) (*vtctldata.GetFullStatusResponse, error)

func (UnimplementedVTAdminServer) GetGates 

func (UnimplementedVTAdminServer) GetGates(context.Context, *GetGatesRequest) (*GetGatesResponse, error)

func (UnimplementedVTAdminServer) GetKeyspace 

func (UnimplementedVTAdminServer) GetKeyspace(context.Context, *GetKeyspaceRequest) (*Keyspace, error)

func (UnimplementedVTAdminServer) GetKeyspaces 

func (UnimplementedVTAdminServer) GetKeyspaces(context.Context, *GetKeyspacesRequest) (*GetKeyspacesResponse, error)

func (UnimplementedVTAdminServer) GetSchema 

func (UnimplementedVTAdminServer) GetSchema(context.Context, *GetSchemaRequest) (*Schema, error)

func (UnimplementedVTAdminServer) GetSchemaMigrations 

func (UnimplementedVTAdminServer) GetSchemaMigrations(context.Context, *GetSchemaMigrationsRequest) (*GetSchemaMigrationsResponse, error)

func (UnimplementedVTAdminServer) GetSchemas 

func (UnimplementedVTAdminServer) GetSchemas(context.Context, *GetSchemasRequest) (*GetSchemasResponse, error)

func (UnimplementedVTAdminServer) GetShardReplicationPositions 

func (UnimplementedVTAdminServer) GetShardReplicationPositions(context.Context, *GetShardReplicationPositionsRequest) (*GetShardReplicationPositionsResponse, error)

func (UnimplementedVTAdminServer) GetSrvKeyspace 

func (UnimplementedVTAdminServer) GetSrvKeyspace(context.Context, *GetSrvKeyspaceRequest) (*vtctldata.GetSrvKeyspacesResponse, error)

func (UnimplementedVTAdminServer) GetSrvKeyspaces 

func (UnimplementedVTAdminServer) GetSrvKeyspaces(context.Context, *GetSrvKeyspacesRequest) (*GetSrvKeyspacesResponse, error)

func (UnimplementedVTAdminServer) GetSrvVSchema 

func (UnimplementedVTAdminServer) GetSrvVSchema(context.Context, *GetSrvVSchemaRequest) (*SrvVSchema, error)

func (UnimplementedVTAdminServer) GetSrvVSchemas 

func (UnimplementedVTAdminServer) GetSrvVSchemas(context.Context, *GetSrvVSchemasRequest) (*GetSrvVSchemasResponse, error)

func (UnimplementedVTAdminServer) GetTablet 

func (UnimplementedVTAdminServer) GetTablet(context.Context, *GetTabletRequest) (*Tablet, error)

func (UnimplementedVTAdminServer) GetTablets 

func (UnimplementedVTAdminServer) GetTablets(context.Context, *GetTabletsRequest) (*GetTabletsResponse, error)

func (UnimplementedVTAdminServer) GetTopologyPath 

func (UnimplementedVTAdminServer) GetTopologyPath(context.Context, *GetTopologyPathRequest) (*vtctldata.GetTopologyPathResponse, error)

func (UnimplementedVTAdminServer) GetVSchema 

func (UnimplementedVTAdminServer) GetVSchema(context.Context, *GetVSchemaRequest) (*VSchema, error)

func (UnimplementedVTAdminServer) GetVSchemas 

func (UnimplementedVTAdminServer) GetVSchemas(context.Context, *GetVSchemasRequest) (*GetVSchemasResponse, error)

func (UnimplementedVTAdminServer) GetVtctlds 

func (UnimplementedVTAdminServer) GetVtctlds(context.Context, *GetVtctldsRequest) (*GetVtctldsResponse, error)

func (UnimplementedVTAdminServer) GetWorkflow 

func (UnimplementedVTAdminServer) GetWorkflow(context.Context, *GetWorkflowRequest) (*Workflow, error)

func (UnimplementedVTAdminServer) GetWorkflows 

func (UnimplementedVTAdminServer) GetWorkflows(context.Context, *GetWorkflowsRequest) (*GetWorkflowsResponse, error)

func (UnimplementedVTAdminServer) LaunchSchemaMigration 

func (UnimplementedVTAdminServer) LaunchSchemaMigration(context.Context, *LaunchSchemaMigrationRequest) (*vtctldata.LaunchSchemaMigrationResponse, error)

func (UnimplementedVTAdminServer) PingTablet 

func (UnimplementedVTAdminServer) PingTablet(context.Context, *PingTabletRequest) (*PingTabletResponse, error)

func (UnimplementedVTAdminServer) PlannedFailoverShard 

func (UnimplementedVTAdminServer) PlannedFailoverShard(context.Context, *PlannedFailoverShardRequest) (*PlannedFailoverShardResponse, error)

func (UnimplementedVTAdminServer) RebuildKeyspaceGraph 

func (UnimplementedVTAdminServer) RebuildKeyspaceGraph(context.Context, *RebuildKeyspaceGraphRequest) (*RebuildKeyspaceGraphResponse, error)

func (UnimplementedVTAdminServer) RefreshState 

func (UnimplementedVTAdminServer) RefreshState(context.Context, *RefreshStateRequest) (*RefreshStateResponse, error)

func (UnimplementedVTAdminServer) RefreshTabletReplicationSource 

func (UnimplementedVTAdminServer) RefreshTabletReplicationSource(context.Context, *RefreshTabletReplicationSourceRequest) (*RefreshTabletReplicationSourceResponse, error)

func (UnimplementedVTAdminServer) ReloadSchemaShard 

func (UnimplementedVTAdminServer) ReloadSchemaShard(context.Context, *ReloadSchemaShardRequest) (*ReloadSchemaShardResponse, error)

func (UnimplementedVTAdminServer) ReloadSchemas 

func (UnimplementedVTAdminServer) ReloadSchemas(context.Context, *ReloadSchemasRequest) (*ReloadSchemasResponse, error)

func (UnimplementedVTAdminServer) RemoveKeyspaceCell 

func (UnimplementedVTAdminServer) RemoveKeyspaceCell(context.Context, *RemoveKeyspaceCellRequest) (*RemoveKeyspaceCellResponse, error)

func (UnimplementedVTAdminServer) RetrySchemaMigration 

func (UnimplementedVTAdminServer) RetrySchemaMigration(context.Context, *RetrySchemaMigrationRequest) (*vtctldata.RetrySchemaMigrationResponse, error)

func (UnimplementedVTAdminServer) RunHealthCheck 

func (UnimplementedVTAdminServer) RunHealthCheck(context.Context, *RunHealthCheckRequest) (*RunHealthCheckResponse, error)

func (UnimplementedVTAdminServer) SetReadOnly 

func (UnimplementedVTAdminServer) SetReadOnly(context.Context, *SetReadOnlyRequest) (*SetReadOnlyResponse, error)

func (UnimplementedVTAdminServer) SetReadWrite 

func (UnimplementedVTAdminServer) SetReadWrite(context.Context, *SetReadWriteRequest) (*SetReadWriteResponse, error)

func (UnimplementedVTAdminServer) StartReplication 

func (UnimplementedVTAdminServer) StartReplication(context.Context, *StartReplicationRequest) (*StartReplicationResponse, error)

func (UnimplementedVTAdminServer) StopReplication 

func (UnimplementedVTAdminServer) StopReplication(context.Context, *StopReplicationRequest) (*StopReplicationResponse, error)

func (UnimplementedVTAdminServer) TabletExternallyPromoted 

func (UnimplementedVTAdminServer) TabletExternallyPromoted(context.Context, *TabletExternallyPromotedRequest) (*TabletExternallyPromotedResponse, error)

func (UnimplementedVTAdminServer) VTExplain 

func (UnimplementedVTAdminServer) VTExplain(context.Context, *VTExplainRequest) (*VTExplainResponse, error)

func (UnimplementedVTAdminServer) Validate 

func (UnimplementedVTAdminServer) Validate(context.Context, *ValidateRequest) (*vtctldata.ValidateResponse, error)

func (UnimplementedVTAdminServer) ValidateKeyspace 

func (UnimplementedVTAdminServer) ValidateKeyspace(context.Context, *ValidateKeyspaceRequest) (*vtctldata.ValidateKeyspaceResponse, error)

func (UnimplementedVTAdminServer) ValidateSchemaKeyspace 

func (UnimplementedVTAdminServer) ValidateSchemaKeyspace(context.Context, *ValidateSchemaKeyspaceRequest) (*vtctldata.ValidateSchemaKeyspaceResponse, error)

func (UnimplementedVTAdminServer) ValidateShard 

func (UnimplementedVTAdminServer) ValidateShard(context.Context, *ValidateShardRequest) (*vtctldata.ValidateShardResponse, error)

func (UnimplementedVTAdminServer) ValidateVersionKeyspace 

func (UnimplementedVTAdminServer) ValidateVersionKeyspace(context.Context, *ValidateVersionKeyspaceRequest) (*vtctldata.ValidateVersionKeyspaceResponse, error)

func (UnimplementedVTAdminServer) ValidateVersionShard 

func (UnimplementedVTAdminServer) ValidateVersionShard(context.Context, *ValidateVersionShardRequest) (*vtctldata.ValidateVersionShardResponse, error)

type UnsafeVTAdminServer 

type UnsafeVTAdminServer interface {
	// contains filtered or unexported methods
}

UnsafeVTAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VTAdminServer will result in compilation errors.

type VSchema 

type VSchema struct {
	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Name is the name of the keyspace this VSchema is for.
	Name    string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	VSchema *vschema.Keyspace `protobuf:"bytes,3,opt,name=v_schema,json=vSchema,proto3" json:"v_schema,omitempty"`
	// contains filtered or unexported fields
}

VSchema represents the vschema for a keyspace in the cluster it belongs to.

func (*VSchema) CloneMessageVT 

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

func (*VSchema) CloneVT 

func (m *VSchema) CloneVT() *VSchema

func (*VSchema) Descriptor deprecated 

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

Deprecated: Use VSchema.ProtoReflect.Descriptor instead.

func (*VSchema) GetCluster 

func (x *VSchema) GetCluster() *Cluster

func (*VSchema) GetName 

func (x *VSchema) GetName() string

func (*VSchema) GetVSchema 

func (x *VSchema) GetVSchema() *vschema.Keyspace

func (*VSchema) MarshalToSizedBufferVT 

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

func (*VSchema) MarshalToVT 

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

func (*VSchema) MarshalVT 

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

func (*VSchema) ProtoMessage 

func (*VSchema) ProtoMessage()

func (*VSchema) ProtoReflect 

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

func (*VSchema) Reset 

func (x *VSchema) Reset()

func (*VSchema) SizeVT 

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

func (*VSchema) String 

func (x *VSchema) String() string

func (*VSchema) UnmarshalVT 

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

type VTAdminClient 

type VTAdminClient interface {
	// ApplySchema applies a schema to a keyspace in the given cluster.
	ApplySchema(ctx context.Context, in *ApplySchemaRequest, opts ...grpc.CallOption) (*vtctldata.ApplySchemaResponse, error)
	// CancelSchemaMigration cancels one or all schema migrations in the given
	// cluster, terminating any running ones as needed.
	CancelSchemaMigration(ctx context.Context, in *CancelSchemaMigrationRequest, opts ...grpc.CallOption) (*vtctldata.CancelSchemaMigrationResponse, error)
	// CleanupSchemaMigration marks a schema migration in the given cluster as
	// ready for artifact cleanup.
	CleanupSchemaMigration(ctx context.Context, in *CleanupSchemaMigrationRequest, opts ...grpc.CallOption) (*vtctldata.CleanupSchemaMigrationResponse, error)
	// CompleteSchemaMigration completes one or all migrations in the given
	// cluster executed with --postpone-completion.
	CompleteSchemaMigration(ctx context.Context, in *CompleteSchemaMigrationRequest, opts ...grpc.CallOption) (*vtctldata.CompleteSchemaMigrationResponse, error)
	// CreateKeyspace creates a new keyspace in the given cluster.
	CreateKeyspace(ctx context.Context, in *CreateKeyspaceRequest, opts ...grpc.CallOption) (*CreateKeyspaceResponse, error)
	// CreateShard creates a new shard in the given cluster and keyspace.
	CreateShard(ctx context.Context, in *CreateShardRequest, opts ...grpc.CallOption) (*vtctldata.CreateShardResponse, error)
	// DeleteKeyspace deletes a keyspace in the given cluster.
	DeleteKeyspace(ctx context.Context, in *DeleteKeyspaceRequest, opts ...grpc.CallOption) (*vtctldata.DeleteKeyspaceResponse, error)
	// DeleteShard deletes one or more shards in the given cluster and keyspace.
	DeleteShards(ctx context.Context, in *DeleteShardsRequest, opts ...grpc.CallOption) (*vtctldata.DeleteShardsResponse, error)
	// DeleteTablet deletes a tablet from the topology
	DeleteTablet(ctx context.Context, in *DeleteTabletRequest, opts ...grpc.CallOption) (*DeleteTabletResponse, error)
	// EmergencyFailoverShard fails over a shard to a new primary. It assumes
	// the old primary is dead or otherwise not responding.
	EmergencyFailoverShard(ctx context.Context, in *EmergencyFailoverShardRequest, opts ...grpc.CallOption) (*EmergencyFailoverShardResponse, error)
	// FindSchema returns a single Schema that matches the provided table name
	// across all specified clusters IDs. Not specifying a set of cluster IDs
	// causes the search to span all configured clusters.
	//
	// An error occurs if either no table exists across any of the clusters with
	// the specified table name, or if multiple tables exist with that name.
	FindSchema(ctx context.Context, in *FindSchemaRequest, opts ...grpc.CallOption) (*Schema, error)
	// GetBackups returns backups grouped by cluster.
	GetBackups(ctx context.Context, in *GetBackupsRequest, opts ...grpc.CallOption) (*GetBackupsResponse, error)
	// GetCellInfos returns the CellInfo objects for the specified clusters.
	//
	// Callers may optionally restrict the set of CellInfos, or restrict the
	// response to include only cell names.
	GetCellInfos(ctx context.Context, in *GetCellInfosRequest, opts ...grpc.CallOption) (*GetCellInfosResponse, error)
	// GetCellsAliases returns the CellsAliases data for the specified clusters.
	GetCellsAliases(ctx context.Context, in *GetCellsAliasesRequest, opts ...grpc.CallOption) (*GetCellsAliasesResponse, error)
	// GetClusters returns all configured clusters.
	GetClusters(ctx context.Context, in *GetClustersRequest, opts ...grpc.CallOption) (*GetClustersResponse, error)
	// GetFullStatus returns the full status of MySQL including the replication information, semi-sync information, GTID information among others
	GetFullStatus(ctx context.Context, in *GetFullStatusRequest, opts ...grpc.CallOption) (*vtctldata.GetFullStatusResponse, error)
	// GetGates returns all gates across all the specified clusters.
	GetGates(ctx context.Context, in *GetGatesRequest, opts ...grpc.CallOption) (*GetGatesResponse, error)
	// GetKeyspace returns a keyspace by name in the specified cluster.
	GetKeyspace(ctx context.Context, in *GetKeyspaceRequest, opts ...grpc.CallOption) (*Keyspace, error)
	// GetKeyspaces returns all keyspaces across the specified clusters.
	GetKeyspaces(ctx context.Context, in *GetKeyspacesRequest, opts ...grpc.CallOption) (*GetKeyspacesResponse, error)
	// GetSchema returns the schema for the specified (cluster, keyspace, table)
	// tuple.
	GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*Schema, error)
	// GetSchemas returns all schemas across the specified clusters.
	GetSchemas(ctx context.Context, in *GetSchemasRequest, opts ...grpc.CallOption) (*GetSchemasResponse, error)
	// GetSchemaMigrations returns one or more online schema migrations for the
	// set of keyspaces (or all keyspaces) in the given clusters, analagous to
	// repeated executions of `SHOW VITESS_MIGRATIONS`.
	//
	// Different fields in the request message result in different behaviors.
	// See the documentation on vtctldata.GetSchemaMigrationsRequest for details.
	GetSchemaMigrations(ctx context.Context, in *GetSchemaMigrationsRequest, opts ...grpc.CallOption) (*GetSchemaMigrationsResponse, error)
	// GetShardReplicationPositions returns shard replication positions grouped
	// by cluster.
	GetShardReplicationPositions(ctx context.Context, in *GetShardReplicationPositionsRequest, opts ...grpc.CallOption) (*GetShardReplicationPositionsResponse, error)
	// GetSrvKeyspace returns the SrvKeyspace for a keyspace in one or more cells.
	GetSrvKeyspace(ctx context.Context, in *GetSrvKeyspaceRequest, opts ...grpc.CallOption) (*vtctldata.GetSrvKeyspacesResponse, error)
	// GetSrvKeyspaces returns the SrvKeyspaces for all keyspaces across all the specified clusters.
	GetSrvKeyspaces(ctx context.Context, in *GetSrvKeyspacesRequest, opts ...grpc.CallOption) (*GetSrvKeyspacesResponse, error)
	// GetSrvVSchema returns the SrvVSchema for the given cluster and cell.
	GetSrvVSchema(ctx context.Context, in *GetSrvVSchemaRequest, opts ...grpc.CallOption) (*SrvVSchema, error)
	// GetSrvVSchemas returns all SrvVSchemas across all (or specified) clusters
	// and cells.
	GetSrvVSchemas(ctx context.Context, in *GetSrvVSchemasRequest, opts ...grpc.CallOption) (*GetSrvVSchemasResponse, error)
	// GetTablet looks up a tablet by hostname across all clusters and returns
	// the result.
	GetTablet(ctx context.Context, in *GetTabletRequest, opts ...grpc.CallOption) (*Tablet, error)
	// GetTablets returns all tablets across all the specified clusters.
	GetTablets(ctx context.Context, in *GetTabletsRequest, opts ...grpc.CallOption) (*GetTabletsResponse, error)
	// GetTopologyPath returns the cell located at the specified path in the topology server.
	GetTopologyPath(ctx context.Context, in *GetTopologyPathRequest, opts ...grpc.CallOption) (*vtctldata.GetTopologyPathResponse, error)
	// GetVSchema returns a VSchema for the specified keyspace in the specified
	// cluster.
	GetVSchema(ctx context.Context, in *GetVSchemaRequest, opts ...grpc.CallOption) (*VSchema, error)
	// GetVSchemas returns the VSchemas for all specified clusters.
	GetVSchemas(ctx context.Context, in *GetVSchemasRequest, opts ...grpc.CallOption) (*GetVSchemasResponse, error)
	// GetVtctlds returns the Vtctlds for all specified clusters.
	GetVtctlds(ctx context.Context, in *GetVtctldsRequest, opts ...grpc.CallOption) (*GetVtctldsResponse, error)
	// GetWorkflow returns a single Workflow for a given cluster, keyspace, and
	// workflow name.
	GetWorkflow(ctx context.Context, in *GetWorkflowRequest, opts ...grpc.CallOption) (*Workflow, error)
	// GetWorkflows returns the Workflows for all specified clusters.
	GetWorkflows(ctx context.Context, in *GetWorkflowsRequest, opts ...grpc.CallOption) (*GetWorkflowsResponse, error)
	// LaunchSchemaMigration launches one or all migrations in the given
	// cluster executed with --postpone-launch.
	LaunchSchemaMigration(ctx context.Context, in *LaunchSchemaMigrationRequest, opts ...grpc.CallOption) (*vtctldata.LaunchSchemaMigrationResponse, error)
	// PingTablet checks that the specified tablet is awake and responding to
	// RPCs. This command can be blocked by other in-flight operations.
	PingTablet(ctx context.Context, in *PingTabletRequest, opts ...grpc.CallOption) (*PingTabletResponse, error)
	// PlannedFailoverShard fails over the shard to a new primary, or away from
	// an old primary. Both the old and new primaries must be reachable and
	// running.
	//
	// NOTE: A planned failover will not consider replicas outside the current
	// shard primary's cell as promotion candidates unless NewPrimary is
	// explicitly provided in the request.
	PlannedFailoverShard(ctx context.Context, in *PlannedFailoverShardRequest, opts ...grpc.CallOption) (*PlannedFailoverShardResponse, error)
	// RebuildKeyspaceGraph rebuilds the serving data for a keyspace.
	RebuildKeyspaceGraph(ctx context.Context, in *RebuildKeyspaceGraphRequest, opts ...grpc.CallOption) (*RebuildKeyspaceGraphResponse, error)
	// RefreshState reloads the tablet record on the specified tablet.
	RefreshState(ctx context.Context, in *RefreshStateRequest, opts ...grpc.CallOption) (*RefreshStateResponse, error)
	// RefreshTabletReplicationSource performs a `CHANGE REPLICATION SOURCE TO`
	// on a tablet to replicate from the current primary in the shard.
	RefreshTabletReplicationSource(ctx context.Context, in *RefreshTabletReplicationSourceRequest, opts ...grpc.CallOption) (*RefreshTabletReplicationSourceResponse, error)
	// ReloadSchemas reloads the schema definition across keyspaces, shards, or
	// tablets in one or more clusters, depending on the request fields (see
	// ReloadSchemasRequest for details).
	ReloadSchemas(ctx context.Context, in *ReloadSchemasRequest, opts ...grpc.CallOption) (*ReloadSchemasResponse, error)
	// ReloadSchemaShard reloads the schema on all tablets in a shard. This is done on a best-effort basis.
	ReloadSchemaShard(ctx context.Context, in *ReloadSchemaShardRequest, opts ...grpc.CallOption) (*ReloadSchemaShardResponse, error)
	// RemoveKeyspaceCell removes the cell from the Cells list for all shards in the keyspace, and the SrvKeyspace for that keyspace in that cell.
	RemoveKeyspaceCell(ctx context.Context, in *RemoveKeyspaceCellRequest, opts ...grpc.CallOption) (*RemoveKeyspaceCellResponse, error)
	// RetrySchemaMigration marks a given schema migration in the given cluster
	// for retry.
	RetrySchemaMigration(ctx context.Context, in *RetrySchemaMigrationRequest, opts ...grpc.CallOption) (*vtctldata.RetrySchemaMigrationResponse, error)
	// RunHealthCheck runs a healthcheck on the tablet.
	RunHealthCheck(ctx context.Context, in *RunHealthCheckRequest, opts ...grpc.CallOption) (*RunHealthCheckResponse, error)
	// SetReadOnly sets the tablet to read-only mode.
	SetReadOnly(ctx context.Context, in *SetReadOnlyRequest, opts ...grpc.CallOption) (*SetReadOnlyResponse, error)
	// SetReadWrite sets the tablet to read-write mode.
	SetReadWrite(ctx context.Context, in *SetReadWriteRequest, opts ...grpc.CallOption) (*SetReadWriteResponse, error)
	// StartReplication runs the underlying database command to start
	// replication on a tablet.
	StartReplication(ctx context.Context, in *StartReplicationRequest, opts ...grpc.CallOption) (*StartReplicationResponse, error)
	// StopReplication runs the underlying database command to stop replication
	// on a tablet
	StopReplication(ctx context.Context, in *StopReplicationRequest, opts ...grpc.CallOption) (*StopReplicationResponse, error)
	// TabletExternallyPromoted updates the metadata in a cluster's topology
	// to acknowledge a shard primary change performed by an external tool
	// (e.g. orchestrator*).
	//
	// See the Reparenting guide for more information:
	// https://vitess.io/docs/user-guides/configuration-advanced/reparenting/#external-reparenting.
	//
	// * "orchestrator" here refers to external orchestrator, not the newer,
	// Vitess-aware orchestrator, VTOrc.
	TabletExternallyPromoted(ctx context.Context, in *TabletExternallyPromotedRequest, opts ...grpc.CallOption) (*TabletExternallyPromotedResponse, error)
	// Validate validates all nodes in a cluster that are reachable from the global replication graph,
	// as well as all tablets in discoverable cells, are consistent
	Validate(ctx context.Context, in *ValidateRequest, opts ...grpc.CallOption) (*vtctldata.ValidateResponse, error)
	// ValidateKeyspace validates that all nodes reachable from the specified
	// keyspace are consistent.
	ValidateKeyspace(ctx context.Context, in *ValidateKeyspaceRequest, opts ...grpc.CallOption) (*vtctldata.ValidateKeyspaceResponse, error)
	// ValidateSchemaKeyspace validates that the schema on the primary tablet
	// for shard 0 matches the schema on all of the other tablets in the
	// keyspace.
	ValidateSchemaKeyspace(ctx context.Context, in *ValidateSchemaKeyspaceRequest, opts ...grpc.CallOption) (*vtctldata.ValidateSchemaKeyspaceResponse, error)
	// ValidateShard validates that that all nodes reachable from the specified shard are consistent.
	ValidateShard(ctx context.Context, in *ValidateShardRequest, opts ...grpc.CallOption) (*vtctldata.ValidateShardResponse, error)
	// ValidateVersionKeyspace validates that the version on the primary of
	// shard 0 matches all of the other tablets in the keyspace.
	ValidateVersionKeyspace(ctx context.Context, in *ValidateVersionKeyspaceRequest, opts ...grpc.CallOption) (*vtctldata.ValidateVersionKeyspaceResponse, error)
	// ValidateVersionShard validates that the version on the primary matches all of the replicas.
	ValidateVersionShard(ctx context.Context, in *ValidateVersionShardRequest, opts ...grpc.CallOption) (*vtctldata.ValidateVersionShardResponse, error)
	// VTExplain provides information on how Vitess plans to execute a
	// particular query.
	VTExplain(ctx context.Context, in *VTExplainRequest, opts ...grpc.CallOption) (*VTExplainResponse, error)
}

VTAdminClient is the client API for VTAdmin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewVTAdminClient 

func NewVTAdminClient(cc grpc.ClientConnInterface) VTAdminClient

type VTAdminServer 

type VTAdminServer interface {
	// ApplySchema applies a schema to a keyspace in the given cluster.
	ApplySchema(context.Context, *ApplySchemaRequest) (*vtctldata.ApplySchemaResponse, error)
	// CancelSchemaMigration cancels one or all schema migrations in the given
	// cluster, terminating any running ones as needed.
	CancelSchemaMigration(context.Context, *CancelSchemaMigrationRequest) (*vtctldata.CancelSchemaMigrationResponse, error)
	// CleanupSchemaMigration marks a schema migration in the given cluster as
	// ready for artifact cleanup.
	CleanupSchemaMigration(context.Context, *CleanupSchemaMigrationRequest) (*vtctldata.CleanupSchemaMigrationResponse, error)
	// CompleteSchemaMigration completes one or all migrations in the given
	// cluster executed with --postpone-completion.
	CompleteSchemaMigration(context.Context, *CompleteSchemaMigrationRequest) (*vtctldata.CompleteSchemaMigrationResponse, error)
	// CreateKeyspace creates a new keyspace in the given cluster.
	CreateKeyspace(context.Context, *CreateKeyspaceRequest) (*CreateKeyspaceResponse, error)
	// CreateShard creates a new shard in the given cluster and keyspace.
	CreateShard(context.Context, *CreateShardRequest) (*vtctldata.CreateShardResponse, error)
	// DeleteKeyspace deletes a keyspace in the given cluster.
	DeleteKeyspace(context.Context, *DeleteKeyspaceRequest) (*vtctldata.DeleteKeyspaceResponse, error)
	// DeleteShard deletes one or more shards in the given cluster and keyspace.
	DeleteShards(context.Context, *DeleteShardsRequest) (*vtctldata.DeleteShardsResponse, error)
	// DeleteTablet deletes a tablet from the topology
	DeleteTablet(context.Context, *DeleteTabletRequest) (*DeleteTabletResponse, error)
	// EmergencyFailoverShard fails over a shard to a new primary. It assumes
	// the old primary is dead or otherwise not responding.
	EmergencyFailoverShard(context.Context, *EmergencyFailoverShardRequest) (*EmergencyFailoverShardResponse, error)
	// FindSchema returns a single Schema that matches the provided table name
	// across all specified clusters IDs. Not specifying a set of cluster IDs
	// causes the search to span all configured clusters.
	//
	// An error occurs if either no table exists across any of the clusters with
	// the specified table name, or if multiple tables exist with that name.
	FindSchema(context.Context, *FindSchemaRequest) (*Schema, error)
	// GetBackups returns backups grouped by cluster.
	GetBackups(context.Context, *GetBackupsRequest) (*GetBackupsResponse, error)
	// GetCellInfos returns the CellInfo objects for the specified clusters.
	//
	// Callers may optionally restrict the set of CellInfos, or restrict the
	// response to include only cell names.
	GetCellInfos(context.Context, *GetCellInfosRequest) (*GetCellInfosResponse, error)
	// GetCellsAliases returns the CellsAliases data for the specified clusters.
	GetCellsAliases(context.Context, *GetCellsAliasesRequest) (*GetCellsAliasesResponse, error)
	// GetClusters returns all configured clusters.
	GetClusters(context.Context, *GetClustersRequest) (*GetClustersResponse, error)
	// GetFullStatus returns the full status of MySQL including the replication information, semi-sync information, GTID information among others
	GetFullStatus(context.Context, *GetFullStatusRequest) (*vtctldata.GetFullStatusResponse, error)
	// GetGates returns all gates across all the specified clusters.
	GetGates(context.Context, *GetGatesRequest) (*GetGatesResponse, error)
	// GetKeyspace returns a keyspace by name in the specified cluster.
	GetKeyspace(context.Context, *GetKeyspaceRequest) (*Keyspace, error)
	// GetKeyspaces returns all keyspaces across the specified clusters.
	GetKeyspaces(context.Context, *GetKeyspacesRequest) (*GetKeyspacesResponse, error)
	// GetSchema returns the schema for the specified (cluster, keyspace, table)
	// tuple.
	GetSchema(context.Context, *GetSchemaRequest) (*Schema, error)
	// GetSchemas returns all schemas across the specified clusters.
	GetSchemas(context.Context, *GetSchemasRequest) (*GetSchemasResponse, error)
	// GetSchemaMigrations returns one or more online schema migrations for the
	// set of keyspaces (or all keyspaces) in the given clusters, analagous to
	// repeated executions of `SHOW VITESS_MIGRATIONS`.
	//
	// Different fields in the request message result in different behaviors.
	// See the documentation on vtctldata.GetSchemaMigrationsRequest for details.
	GetSchemaMigrations(context.Context, *GetSchemaMigrationsRequest) (*GetSchemaMigrationsResponse, error)
	// GetShardReplicationPositions returns shard replication positions grouped
	// by cluster.
	GetShardReplicationPositions(context.Context, *GetShardReplicationPositionsRequest) (*GetShardReplicationPositionsResponse, error)
	// GetSrvKeyspace returns the SrvKeyspace for a keyspace in one or more cells.
	GetSrvKeyspace(context.Context, *GetSrvKeyspaceRequest) (*vtctldata.GetSrvKeyspacesResponse, error)
	// GetSrvKeyspaces returns the SrvKeyspaces for all keyspaces across all the specified clusters.
	GetSrvKeyspaces(context.Context, *GetSrvKeyspacesRequest) (*GetSrvKeyspacesResponse, error)
	// GetSrvVSchema returns the SrvVSchema for the given cluster and cell.
	GetSrvVSchema(context.Context, *GetSrvVSchemaRequest) (*SrvVSchema, error)
	// GetSrvVSchemas returns all SrvVSchemas across all (or specified) clusters
	// and cells.
	GetSrvVSchemas(context.Context, *GetSrvVSchemasRequest) (*GetSrvVSchemasResponse, error)
	// GetTablet looks up a tablet by hostname across all clusters and returns
	// the result.
	GetTablet(context.Context, *GetTabletRequest) (*Tablet, error)
	// GetTablets returns all tablets across all the specified clusters.
	GetTablets(context.Context, *GetTabletsRequest) (*GetTabletsResponse, error)
	// GetTopologyPath returns the cell located at the specified path in the topology server.
	GetTopologyPath(context.Context, *GetTopologyPathRequest) (*vtctldata.GetTopologyPathResponse, error)
	// GetVSchema returns a VSchema for the specified keyspace in the specified
	// cluster.
	GetVSchema(context.Context, *GetVSchemaRequest) (*VSchema, error)
	// GetVSchemas returns the VSchemas for all specified clusters.
	GetVSchemas(context.Context, *GetVSchemasRequest) (*GetVSchemasResponse, error)
	// GetVtctlds returns the Vtctlds for all specified clusters.
	GetVtctlds(context.Context, *GetVtctldsRequest) (*GetVtctldsResponse, error)
	// GetWorkflow returns a single Workflow for a given cluster, keyspace, and
	// workflow name.
	GetWorkflow(context.Context, *GetWorkflowRequest) (*Workflow, error)
	// GetWorkflows returns the Workflows for all specified clusters.
	GetWorkflows(context.Context, *GetWorkflowsRequest) (*GetWorkflowsResponse, error)
	// LaunchSchemaMigration launches one or all migrations in the given
	// cluster executed with --postpone-launch.
	LaunchSchemaMigration(context.Context, *LaunchSchemaMigrationRequest) (*vtctldata.LaunchSchemaMigrationResponse, error)
	// PingTablet checks that the specified tablet is awake and responding to
	// RPCs. This command can be blocked by other in-flight operations.
	PingTablet(context.Context, *PingTabletRequest) (*PingTabletResponse, error)
	// PlannedFailoverShard fails over the shard to a new primary, or away from
	// an old primary. Both the old and new primaries must be reachable and
	// running.
	//
	// NOTE: A planned failover will not consider replicas outside the current
	// shard primary's cell as promotion candidates unless NewPrimary is
	// explicitly provided in the request.
	PlannedFailoverShard(context.Context, *PlannedFailoverShardRequest) (*PlannedFailoverShardResponse, error)
	// RebuildKeyspaceGraph rebuilds the serving data for a keyspace.
	RebuildKeyspaceGraph(context.Context, *RebuildKeyspaceGraphRequest) (*RebuildKeyspaceGraphResponse, error)
	// RefreshState reloads the tablet record on the specified tablet.
	RefreshState(context.Context, *RefreshStateRequest) (*RefreshStateResponse, error)
	// RefreshTabletReplicationSource performs a `CHANGE REPLICATION SOURCE TO`
	// on a tablet to replicate from the current primary in the shard.
	RefreshTabletReplicationSource(context.Context, *RefreshTabletReplicationSourceRequest) (*RefreshTabletReplicationSourceResponse, error)
	// ReloadSchemas reloads the schema definition across keyspaces, shards, or
	// tablets in one or more clusters, depending on the request fields (see
	// ReloadSchemasRequest for details).
	ReloadSchemas(context.Context, *ReloadSchemasRequest) (*ReloadSchemasResponse, error)
	// ReloadSchemaShard reloads the schema on all tablets in a shard. This is done on a best-effort basis.
	ReloadSchemaShard(context.Context, *ReloadSchemaShardRequest) (*ReloadSchemaShardResponse, error)
	// RemoveKeyspaceCell removes the cell from the Cells list for all shards in the keyspace, and the SrvKeyspace for that keyspace in that cell.
	RemoveKeyspaceCell(context.Context, *RemoveKeyspaceCellRequest) (*RemoveKeyspaceCellResponse, error)
	// RetrySchemaMigration marks a given schema migration in the given cluster
	// for retry.
	RetrySchemaMigration(context.Context, *RetrySchemaMigrationRequest) (*vtctldata.RetrySchemaMigrationResponse, error)
	// RunHealthCheck runs a healthcheck on the tablet.
	RunHealthCheck(context.Context, *RunHealthCheckRequest) (*RunHealthCheckResponse, error)
	// SetReadOnly sets the tablet to read-only mode.
	SetReadOnly(context.Context, *SetReadOnlyRequest) (*SetReadOnlyResponse, error)
	// SetReadWrite sets the tablet to read-write mode.
	SetReadWrite(context.Context, *SetReadWriteRequest) (*SetReadWriteResponse, error)
	// StartReplication runs the underlying database command to start
	// replication on a tablet.
	StartReplication(context.Context, *StartReplicationRequest) (*StartReplicationResponse, error)
	// StopReplication runs the underlying database command to stop replication
	// on a tablet
	StopReplication(context.Context, *StopReplicationRequest) (*StopReplicationResponse, error)
	// TabletExternallyPromoted updates the metadata in a cluster's topology
	// to acknowledge a shard primary change performed by an external tool
	// (e.g. orchestrator*).
	//
	// See the Reparenting guide for more information:
	// https://vitess.io/docs/user-guides/configuration-advanced/reparenting/#external-reparenting.
	//
	// * "orchestrator" here refers to external orchestrator, not the newer,
	// Vitess-aware orchestrator, VTOrc.
	TabletExternallyPromoted(context.Context, *TabletExternallyPromotedRequest) (*TabletExternallyPromotedResponse, error)
	// Validate validates all nodes in a cluster that are reachable from the global replication graph,
	// as well as all tablets in discoverable cells, are consistent
	Validate(context.Context, *ValidateRequest) (*vtctldata.ValidateResponse, error)
	// ValidateKeyspace validates that all nodes reachable from the specified
	// keyspace are consistent.
	ValidateKeyspace(context.Context, *ValidateKeyspaceRequest) (*vtctldata.ValidateKeyspaceResponse, error)
	// ValidateSchemaKeyspace validates that the schema on the primary tablet
	// for shard 0 matches the schema on all of the other tablets in the
	// keyspace.
	ValidateSchemaKeyspace(context.Context, *ValidateSchemaKeyspaceRequest) (*vtctldata.ValidateSchemaKeyspaceResponse, error)
	// ValidateShard validates that that all nodes reachable from the specified shard are consistent.
	ValidateShard(context.Context, *ValidateShardRequest) (*vtctldata.ValidateShardResponse, error)
	// ValidateVersionKeyspace validates that the version on the primary of
	// shard 0 matches all of the other tablets in the keyspace.
	ValidateVersionKeyspace(context.Context, *ValidateVersionKeyspaceRequest) (*vtctldata.ValidateVersionKeyspaceResponse, error)
	// ValidateVersionShard validates that the version on the primary matches all of the replicas.
	ValidateVersionShard(context.Context, *ValidateVersionShardRequest) (*vtctldata.ValidateVersionShardResponse, error)
	// VTExplain provides information on how Vitess plans to execute a
	// particular query.
	VTExplain(context.Context, *VTExplainRequest) (*VTExplainResponse, error)
	// contains filtered or unexported methods
}

VTAdminServer is the server API for VTAdmin service. All implementations must embed UnimplementedVTAdminServer for forward compatibility

type VTExplainRequest 

type VTExplainRequest struct {
	Cluster  string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Sql      string `protobuf:"bytes,3,opt,name=sql,proto3" json:"sql,omitempty"`
	// contains filtered or unexported fields
}

func (*VTExplainRequest) CloneMessageVT 

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

func (*VTExplainRequest) CloneVT 

func (m *VTExplainRequest) CloneVT() *VTExplainRequest

func (*VTExplainRequest) Descriptor deprecated 

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

Deprecated: Use VTExplainRequest.ProtoReflect.Descriptor instead.

func (*VTExplainRequest) GetCluster 

func (x *VTExplainRequest) GetCluster() string

func (*VTExplainRequest) GetKeyspace 

func (x *VTExplainRequest) GetKeyspace() string

func (*VTExplainRequest) GetSql 

func (x *VTExplainRequest) GetSql() string

func (*VTExplainRequest) MarshalToSizedBufferVT 

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

func (*VTExplainRequest) MarshalToVT 

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

func (*VTExplainRequest) MarshalVT 

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

func (*VTExplainRequest) ProtoMessage 

func (*VTExplainRequest) ProtoMessage()

func (*VTExplainRequest) ProtoReflect 

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

func (*VTExplainRequest) Reset 

func (x *VTExplainRequest) Reset()

func (*VTExplainRequest) SizeVT 

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

func (*VTExplainRequest) String 

func (x *VTExplainRequest) String() string

func (*VTExplainRequest) UnmarshalVT 

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

type VTExplainResponse 

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

func (*VTExplainResponse) CloneMessageVT 

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

func (*VTExplainResponse) CloneVT 

func (m *VTExplainResponse) CloneVT() *VTExplainResponse

func (*VTExplainResponse) Descriptor deprecated 

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

Deprecated: Use VTExplainResponse.ProtoReflect.Descriptor instead.

func (*VTExplainResponse) GetResponse 

func (x *VTExplainResponse) GetResponse() string

func (*VTExplainResponse) MarshalToSizedBufferVT 

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

func (*VTExplainResponse) MarshalToVT 

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

func (*VTExplainResponse) MarshalVT 

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

func (*VTExplainResponse) ProtoMessage 

func (*VTExplainResponse) ProtoMessage()

func (*VTExplainResponse) ProtoReflect 

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

func (*VTExplainResponse) Reset 

func (x *VTExplainResponse) Reset()

func (*VTExplainResponse) SizeVT 

func (m *VTExplainResponse) SizeVT() (n int)

func (*VTExplainResponse) String 

func (x *VTExplainResponse) String() string

func (*VTExplainResponse) UnmarshalVT 

func (m *VTExplainResponse) UnmarshalVT(dAtA []byte) error

type VTGate 

type VTGate struct {

	// Hostname is the shortname of the VTGate.
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Pool is group the VTGate serves queries for. Some deployments segment
	// VTGates into groups or pools, based on the workloads they serve queries
	// for. Use of this field is optional.
	Pool string `protobuf:"bytes,2,opt,name=pool,proto3" json:"pool,omitempty"`
	// Cell is the topology cell the VTGate is in.
	Cell string `protobuf:"bytes,3,opt,name=cell,proto3" json:"cell,omitempty"`
	// Cluster is the cluster the VTGate serves.
	Cluster *Cluster `protobuf:"bytes,4,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Keyspaces is the list of keyspaces-to-watch for the VTGate.
	Keyspaces []string `protobuf:"bytes,5,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	FQDN      string   `protobuf:"bytes,6,opt,name=FQDN,proto3" json:"FQDN,omitempty"`
	// contains filtered or unexported fields
}

VTGate represents information about a single VTGate host.

func (*VTGate) CloneMessageVT 

func (m *VTGate) CloneMessageVT() proto.Message

func (*VTGate) CloneVT 

func (m *VTGate) CloneVT() *VTGate

func (*VTGate) Descriptor deprecated 

func (*VTGate) Descriptor() ([]byte, []int)

Deprecated: Use VTGate.ProtoReflect.Descriptor instead.

func (*VTGate) GetCell 

func (x *VTGate) GetCell() string

func (*VTGate) GetCluster 

func (x *VTGate) GetCluster() *Cluster

func (*VTGate) GetFQDN 

func (x *VTGate) GetFQDN() string

func (*VTGate) GetHostname 

func (x *VTGate) GetHostname() string

func (*VTGate) GetKeyspaces 

func (x *VTGate) GetKeyspaces() []string

func (*VTGate) GetPool 

func (x *VTGate) GetPool() string

func (*VTGate) MarshalToSizedBufferVT 

func (m *VTGate) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VTGate) MarshalToVT 

func (m *VTGate) MarshalToVT(dAtA []byte) (int, error)

func (*VTGate) MarshalVT 

func (m *VTGate) MarshalVT() (dAtA []byte, err error)

func (*VTGate) ProtoMessage 

func (*VTGate) ProtoMessage()

func (*VTGate) ProtoReflect 

func (x *VTGate) ProtoReflect() protoreflect.Message

func (*VTGate) Reset 

func (x *VTGate) Reset()

func (*VTGate) SizeVT 

func (m *VTGate) SizeVT() (n int)

func (*VTGate) String 

func (x *VTGate) String() string

func (*VTGate) UnmarshalVT 

func (m *VTGate) UnmarshalVT(dAtA []byte) error

type ValidateKeyspaceRequest 

type ValidateKeyspaceRequest struct {
	ClusterId   string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace    string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	PingTablets bool   `protobuf:"varint,3,opt,name=ping_tablets,json=pingTablets,proto3" json:"ping_tablets,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateKeyspaceRequest) CloneMessageVT 

func (m *ValidateKeyspaceRequest) CloneMessageVT() proto.Message

func (*ValidateKeyspaceRequest) CloneVT 

func (m *ValidateKeyspaceRequest) CloneVT() *ValidateKeyspaceRequest

func (*ValidateKeyspaceRequest) Descriptor deprecated 

func (*ValidateKeyspaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*ValidateKeyspaceRequest) GetClusterId 

func (x *ValidateKeyspaceRequest) GetClusterId() string

func (*ValidateKeyspaceRequest) GetKeyspace 

func (x *ValidateKeyspaceRequest) GetKeyspace() string

func (*ValidateKeyspaceRequest) GetPingTablets 

func (x *ValidateKeyspaceRequest) GetPingTablets() bool

func (*ValidateKeyspaceRequest) MarshalToSizedBufferVT 

func (m *ValidateKeyspaceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidateKeyspaceRequest) MarshalToVT 

func (m *ValidateKeyspaceRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ValidateKeyspaceRequest) MarshalVT 

func (m *ValidateKeyspaceRequest) MarshalVT() (dAtA []byte, err error)

func (*ValidateKeyspaceRequest) ProtoMessage 

func (*ValidateKeyspaceRequest) ProtoMessage()

func (*ValidateKeyspaceRequest) ProtoReflect 

func (x *ValidateKeyspaceRequest) ProtoReflect() protoreflect.Message

func (*ValidateKeyspaceRequest) Reset 

func (x *ValidateKeyspaceRequest) Reset()

func (*ValidateKeyspaceRequest) SizeVT 

func (m *ValidateKeyspaceRequest) SizeVT() (n int)

func (*ValidateKeyspaceRequest) String 

func (x *ValidateKeyspaceRequest) String() string

func (*ValidateKeyspaceRequest) UnmarshalVT 

func (m *ValidateKeyspaceRequest) UnmarshalVT(dAtA []byte) error

type ValidateRequest 

type ValidateRequest struct {
	ClusterId   string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	PingTablets bool   `protobuf:"varint,2,opt,name=ping_tablets,json=pingTablets,proto3" json:"ping_tablets,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateRequest) CloneMessageVT 

func (m *ValidateRequest) CloneMessageVT() proto.Message

func (*ValidateRequest) CloneVT 

func (m *ValidateRequest) CloneVT() *ValidateRequest

func (*ValidateRequest) Descriptor deprecated 

func (*ValidateRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateRequest.ProtoReflect.Descriptor instead.

func (*ValidateRequest) GetClusterId 

func (x *ValidateRequest) GetClusterId() string

func (*ValidateRequest) GetPingTablets 

func (x *ValidateRequest) GetPingTablets() bool

func (*ValidateRequest) MarshalToSizedBufferVT 

func (m *ValidateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidateRequest) MarshalToVT 

func (m *ValidateRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ValidateRequest) MarshalVT 

func (m *ValidateRequest) MarshalVT() (dAtA []byte, err error)

func (*ValidateRequest) ProtoMessage 

func (*ValidateRequest) ProtoMessage()

func (*ValidateRequest) ProtoReflect 

func (x *ValidateRequest) ProtoReflect() protoreflect.Message

func (*ValidateRequest) Reset 

func (x *ValidateRequest) Reset()

func (*ValidateRequest) SizeVT 

func (m *ValidateRequest) SizeVT() (n int)

func (*ValidateRequest) String 

func (x *ValidateRequest) String() string

func (*ValidateRequest) UnmarshalVT 

func (m *ValidateRequest) UnmarshalVT(dAtA []byte) error

type ValidateSchemaKeyspaceRequest 

type ValidateSchemaKeyspaceRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateSchemaKeyspaceRequest) CloneMessageVT 

func (m *ValidateSchemaKeyspaceRequest) CloneMessageVT() proto.Message

func (*ValidateSchemaKeyspaceRequest) CloneVT 

func (m *ValidateSchemaKeyspaceRequest) CloneVT() *ValidateSchemaKeyspaceRequest

func (*ValidateSchemaKeyspaceRequest) Descriptor deprecated 

func (*ValidateSchemaKeyspaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateSchemaKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*ValidateSchemaKeyspaceRequest) GetClusterId 

func (x *ValidateSchemaKeyspaceRequest) GetClusterId() string

func (*ValidateSchemaKeyspaceRequest) GetKeyspace 

func (x *ValidateSchemaKeyspaceRequest) GetKeyspace() string

func (*ValidateSchemaKeyspaceRequest) MarshalToSizedBufferVT 

func (m *ValidateSchemaKeyspaceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidateSchemaKeyspaceRequest) MarshalToVT 

func (m *ValidateSchemaKeyspaceRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ValidateSchemaKeyspaceRequest) MarshalVT 

func (m *ValidateSchemaKeyspaceRequest) MarshalVT() (dAtA []byte, err error)

func (*ValidateSchemaKeyspaceRequest) ProtoMessage 

func (*ValidateSchemaKeyspaceRequest) ProtoMessage()

func (*ValidateSchemaKeyspaceRequest) ProtoReflect 

func (x *ValidateSchemaKeyspaceRequest) ProtoReflect() protoreflect.Message

func (*ValidateSchemaKeyspaceRequest) Reset 

func (x *ValidateSchemaKeyspaceRequest) Reset()

func (*ValidateSchemaKeyspaceRequest) SizeVT 

func (m *ValidateSchemaKeyspaceRequest) SizeVT() (n int)

func (*ValidateSchemaKeyspaceRequest) String 

func (x *ValidateSchemaKeyspaceRequest) String() string

func (*ValidateSchemaKeyspaceRequest) UnmarshalVT 

func (m *ValidateSchemaKeyspaceRequest) UnmarshalVT(dAtA []byte) error

type ValidateShardRequest 

type ValidateShardRequest struct {
	ClusterId   string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace    string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard       string `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	PingTablets bool   `protobuf:"varint,4,opt,name=ping_tablets,json=pingTablets,proto3" json:"ping_tablets,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateShardRequest) CloneMessageVT 

func (m *ValidateShardRequest) CloneMessageVT() proto.Message

func (*ValidateShardRequest) CloneVT 

func (m *ValidateShardRequest) CloneVT() *ValidateShardRequest

func (*ValidateShardRequest) Descriptor deprecated 

func (*ValidateShardRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateShardRequest.ProtoReflect.Descriptor instead.

func (*ValidateShardRequest) GetClusterId 

func (x *ValidateShardRequest) GetClusterId() string

func (*ValidateShardRequest) GetKeyspace 

func (x *ValidateShardRequest) GetKeyspace() string

func (*ValidateShardRequest) GetPingTablets 

func (x *ValidateShardRequest) GetPingTablets() bool

func (*ValidateShardRequest) GetShard 

func (x *ValidateShardRequest) GetShard() string

func (*ValidateShardRequest) MarshalToSizedBufferVT 

func (m *ValidateShardRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidateShardRequest) MarshalToVT 

func (m *ValidateShardRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ValidateShardRequest) MarshalVT 

func (m *ValidateShardRequest) MarshalVT() (dAtA []byte, err error)

func (*ValidateShardRequest) ProtoMessage 

func (*ValidateShardRequest) ProtoMessage()

func (*ValidateShardRequest) ProtoReflect 

func (x *ValidateShardRequest) ProtoReflect() protoreflect.Message

func (*ValidateShardRequest) Reset 

func (x *ValidateShardRequest) Reset()

func (*ValidateShardRequest) SizeVT 

func (m *ValidateShardRequest) SizeVT() (n int)

func (*ValidateShardRequest) String 

func (x *ValidateShardRequest) String() string

func (*ValidateShardRequest) UnmarshalVT 

func (m *ValidateShardRequest) UnmarshalVT(dAtA []byte) error

type ValidateVersionKeyspaceRequest 

type ValidateVersionKeyspaceRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateVersionKeyspaceRequest) CloneMessageVT 

func (m *ValidateVersionKeyspaceRequest) CloneMessageVT() proto.Message

func (*ValidateVersionKeyspaceRequest) CloneVT 

func (m *ValidateVersionKeyspaceRequest) CloneVT() *ValidateVersionKeyspaceRequest

func (*ValidateVersionKeyspaceRequest) Descriptor deprecated 

func (*ValidateVersionKeyspaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateVersionKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*ValidateVersionKeyspaceRequest) GetClusterId 

func (x *ValidateVersionKeyspaceRequest) GetClusterId() string

func (*ValidateVersionKeyspaceRequest) GetKeyspace 

func (x *ValidateVersionKeyspaceRequest) GetKeyspace() string

func (*ValidateVersionKeyspaceRequest) MarshalToSizedBufferVT 

func (m *ValidateVersionKeyspaceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidateVersionKeyspaceRequest) MarshalToVT 

func (m *ValidateVersionKeyspaceRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ValidateVersionKeyspaceRequest) MarshalVT 

func (m *ValidateVersionKeyspaceRequest) MarshalVT() (dAtA []byte, err error)

func (*ValidateVersionKeyspaceRequest) ProtoMessage 

func (*ValidateVersionKeyspaceRequest) ProtoMessage()

func (*ValidateVersionKeyspaceRequest) ProtoReflect 

func (x *ValidateVersionKeyspaceRequest) ProtoReflect() protoreflect.Message

func (*ValidateVersionKeyspaceRequest) Reset 

func (x *ValidateVersionKeyspaceRequest) Reset()

func (*ValidateVersionKeyspaceRequest) SizeVT 

func (m *ValidateVersionKeyspaceRequest) SizeVT() (n int)

func (*ValidateVersionKeyspaceRequest) String 

func (x *ValidateVersionKeyspaceRequest) String() string

func (*ValidateVersionKeyspaceRequest) UnmarshalVT 

func (m *ValidateVersionKeyspaceRequest) UnmarshalVT(dAtA []byte) error

type ValidateVersionShardRequest 

type ValidateVersionShardRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard     string `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateVersionShardRequest) CloneMessageVT 

func (m *ValidateVersionShardRequest) CloneMessageVT() proto.Message

func (*ValidateVersionShardRequest) CloneVT 

func (m *ValidateVersionShardRequest) CloneVT() *ValidateVersionShardRequest

func (*ValidateVersionShardRequest) Descriptor deprecated 

func (*ValidateVersionShardRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateVersionShardRequest.ProtoReflect.Descriptor instead.

func (*ValidateVersionShardRequest) GetClusterId 

func (x *ValidateVersionShardRequest) GetClusterId() string

func (*ValidateVersionShardRequest) GetKeyspace 

func (x *ValidateVersionShardRequest) GetKeyspace() string

func (*ValidateVersionShardRequest) GetShard 

func (x *ValidateVersionShardRequest) GetShard() string

func (*ValidateVersionShardRequest) MarshalToSizedBufferVT 

func (m *ValidateVersionShardRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidateVersionShardRequest) MarshalToVT 

func (m *ValidateVersionShardRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ValidateVersionShardRequest) MarshalVT 

func (m *ValidateVersionShardRequest) MarshalVT() (dAtA []byte, err error)

func (*ValidateVersionShardRequest) ProtoMessage 

func (*ValidateVersionShardRequest) ProtoMessage()

func (*ValidateVersionShardRequest) ProtoReflect 

func (x *ValidateVersionShardRequest) ProtoReflect() protoreflect.Message

func (*ValidateVersionShardRequest) Reset 

func (x *ValidateVersionShardRequest) Reset()

func (*ValidateVersionShardRequest) SizeVT 

func (m *ValidateVersionShardRequest) SizeVT() (n int)

func (*ValidateVersionShardRequest) String 

func (x *ValidateVersionShardRequest) String() string

func (*ValidateVersionShardRequest) UnmarshalVT 

func (m *ValidateVersionShardRequest) UnmarshalVT(dAtA []byte) error

type Vtctld 

type Vtctld struct {
	Hostname string   `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Cluster  *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	FQDN     string   `protobuf:"bytes,3,opt,name=FQDN,proto3" json:"FQDN,omitempty"`
	// contains filtered or unexported fields
}

Vtctld represents information about a single Vtctld host.

func (*Vtctld) CloneMessageVT 

func (m *Vtctld) CloneMessageVT() proto.Message

func (*Vtctld) CloneVT 

func (m *Vtctld) CloneVT() *Vtctld

func (*Vtctld) Descriptor deprecated 

func (*Vtctld) Descriptor() ([]byte, []int)

Deprecated: Use Vtctld.ProtoReflect.Descriptor instead.

func (*Vtctld) GetCluster 

func (x *Vtctld) GetCluster() *Cluster

func (*Vtctld) GetFQDN 

func (x *Vtctld) GetFQDN() string

func (*Vtctld) GetHostname 

func (x *Vtctld) GetHostname() string

func (*Vtctld) MarshalToSizedBufferVT 

func (m *Vtctld) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Vtctld) MarshalToVT 

func (m *Vtctld) MarshalToVT(dAtA []byte) (int, error)

func (*Vtctld) MarshalVT 

func (m *Vtctld) MarshalVT() (dAtA []byte, err error)

func (*Vtctld) ProtoMessage 

func (*Vtctld) ProtoMessage()

func (*Vtctld) ProtoReflect 

func (x *Vtctld) ProtoReflect() protoreflect.Message

func (*Vtctld) Reset 

func (x *Vtctld) Reset()

func (*Vtctld) SizeVT 

func (m *Vtctld) SizeVT() (n int)

func (*Vtctld) String 

func (x *Vtctld) String() string

func (*Vtctld) UnmarshalVT 

func (m *Vtctld) UnmarshalVT(dAtA []byte) error

type Workflow 

type Workflow struct {
	Cluster  *Cluster            `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace string              `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Workflow *vtctldata.Workflow `protobuf:"bytes,3,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// contains filtered or unexported fields
}

func (*Workflow) CloneMessageVT 

func (m *Workflow) CloneMessageVT() proto.Message

func (*Workflow) CloneVT 

func (m *Workflow) CloneVT() *Workflow

func (*Workflow) Descriptor deprecated 

func (*Workflow) Descriptor() ([]byte, []int)

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetCluster 

func (x *Workflow) GetCluster() *Cluster

func (*Workflow) GetKeyspace 

func (x *Workflow) GetKeyspace() string

func (*Workflow) GetWorkflow 

func (x *Workflow) GetWorkflow() *vtctldata.Workflow

func (*Workflow) MarshalToSizedBufferVT 

func (m *Workflow) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Workflow) MarshalToVT 

func (m *Workflow) MarshalToVT(dAtA []byte) (int, error)

func (*Workflow) MarshalVT 

func (m *Workflow) MarshalVT() (dAtA []byte, err error)

func (*Workflow) ProtoMessage 

func (*Workflow) ProtoMessage()

func (*Workflow) ProtoReflect 

func (x *Workflow) ProtoReflect() protoreflect.Message

func (*Workflow) Reset 

func (x *Workflow) Reset()

func (*Workflow) SizeVT 

func (m *Workflow) SizeVT() (n int)

func (*Workflow) String 

func (x *Workflow) String() string

func (*Workflow) UnmarshalVT 

func (m *Workflow) UnmarshalVT(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.