vtadmin

package
v0.18.4 Latest Latest
Warning

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

 Go to latest Published: Apr 4, 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: "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: "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: "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: "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 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 added in v0.18.0 

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

func (*Cluster) CloneVT added in v0.18.0 

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

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

func (*Cluster) MarshalToVT added in v0.11.0 

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

func (*Cluster) MarshalVT added in v0.11.0 

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

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect added in v0.11.0 

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

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) SizeVT added in v0.11.0 

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

func (*Cluster) String 

func (x *Cluster) String() string

func (*Cluster) UnmarshalVT added in v0.11.0 

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

type ClusterBackup added in v0.11.0 

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

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

func (*ClusterBackup) CloneVT added in v0.18.0 

func (m *ClusterBackup) CloneVT() *ClusterBackup

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

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

Deprecated: Use ClusterBackup.ProtoReflect.Descriptor instead.

func (*ClusterBackup) GetBackup added in v0.11.0 

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

func (*ClusterBackup) GetCluster added in v0.11.0 

func (x *ClusterBackup) GetCluster() *Cluster

func (*ClusterBackup) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ClusterBackup) MarshalToVT added in v0.11.0 

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

func (*ClusterBackup) MarshalVT added in v0.11.0 

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

func (*ClusterBackup) ProtoMessage added in v0.11.0 

func (*ClusterBackup) ProtoMessage()

func (*ClusterBackup) ProtoReflect added in v0.11.0 

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

func (*ClusterBackup) Reset added in v0.11.0 

func (x *ClusterBackup) Reset()

func (*ClusterBackup) SizeVT added in v0.11.0 

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

func (*ClusterBackup) String added in v0.11.0 

func (x *ClusterBackup) String() string

func (*ClusterBackup) UnmarshalVT added in v0.11.0 

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

type ClusterCellInfo added in v0.14.0 

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

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

func (*ClusterCellInfo) CloneVT added in v0.18.0 

func (m *ClusterCellInfo) CloneVT() *ClusterCellInfo

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

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

Deprecated: Use ClusterCellInfo.ProtoReflect.Descriptor instead.

func (*ClusterCellInfo) GetCellInfo added in v0.14.0 

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

func (*ClusterCellInfo) GetCluster added in v0.14.0 

func (x *ClusterCellInfo) GetCluster() *Cluster

func (*ClusterCellInfo) GetName added in v0.14.0 

func (x *ClusterCellInfo) GetName() string

func (*ClusterCellInfo) MarshalToSizedBufferVT added in v0.14.0 

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

func (*ClusterCellInfo) MarshalToVT added in v0.14.0 

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

func (*ClusterCellInfo) MarshalVT added in v0.14.0 

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

func (*ClusterCellInfo) ProtoMessage added in v0.14.0 

func (*ClusterCellInfo) ProtoMessage()

func (*ClusterCellInfo) ProtoReflect added in v0.14.0 

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

func (*ClusterCellInfo) Reset added in v0.14.0 

func (x *ClusterCellInfo) Reset()

func (*ClusterCellInfo) SizeVT added in v0.14.0 

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

func (*ClusterCellInfo) String added in v0.14.0 

func (x *ClusterCellInfo) String() string

func (*ClusterCellInfo) UnmarshalVT added in v0.14.0 

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

type ClusterCellsAliases added in v0.14.0 

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

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

func (*ClusterCellsAliases) CloneVT added in v0.18.0 

func (m *ClusterCellsAliases) CloneVT() *ClusterCellsAliases

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

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

Deprecated: Use ClusterCellsAliases.ProtoReflect.Descriptor instead.

func (*ClusterCellsAliases) GetAliases added in v0.14.0 

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

func (*ClusterCellsAliases) GetCluster added in v0.14.0 

func (x *ClusterCellsAliases) GetCluster() *Cluster

func (*ClusterCellsAliases) MarshalToSizedBufferVT added in v0.14.0 

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

func (*ClusterCellsAliases) MarshalToVT added in v0.14.0 

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

func (*ClusterCellsAliases) MarshalVT added in v0.14.0 

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

func (*ClusterCellsAliases) ProtoMessage added in v0.14.0 

func (*ClusterCellsAliases) ProtoMessage()

func (*ClusterCellsAliases) ProtoReflect added in v0.14.0 

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

func (*ClusterCellsAliases) Reset added in v0.14.0 

func (x *ClusterCellsAliases) Reset()

func (*ClusterCellsAliases) SizeVT added in v0.14.0 

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

func (*ClusterCellsAliases) String added in v0.14.0 

func (x *ClusterCellsAliases) String() string

func (*ClusterCellsAliases) UnmarshalVT added in v0.14.0 

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

type ClusterShardReplicationPosition added in v0.12.0 

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

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

func (*ClusterShardReplicationPosition) CloneVT added in v0.18.0 

func (m *ClusterShardReplicationPosition) CloneVT() *ClusterShardReplicationPosition

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

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

Deprecated: Use ClusterShardReplicationPosition.ProtoReflect.Descriptor instead.

func (*ClusterShardReplicationPosition) GetCluster added in v0.12.0 

func (x *ClusterShardReplicationPosition) GetCluster() *Cluster

func (*ClusterShardReplicationPosition) GetKeyspace added in v0.12.0 

func (x *ClusterShardReplicationPosition) GetKeyspace() string

func (*ClusterShardReplicationPosition) GetPositionInfo added in v0.12.0 

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

func (*ClusterShardReplicationPosition) GetShard added in v0.12.0 

func (x *ClusterShardReplicationPosition) GetShard() string

func (*ClusterShardReplicationPosition) MarshalToSizedBufferVT added in v0.12.0 

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

func (*ClusterShardReplicationPosition) MarshalToVT added in v0.12.0 

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

func (*ClusterShardReplicationPosition) MarshalVT added in v0.12.0 

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

func (*ClusterShardReplicationPosition) ProtoMessage added in v0.12.0 

func (*ClusterShardReplicationPosition) ProtoMessage()

func (*ClusterShardReplicationPosition) ProtoReflect added in v0.12.0 

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

func (*ClusterShardReplicationPosition) Reset added in v0.12.0 

func (x *ClusterShardReplicationPosition) Reset()

func (*ClusterShardReplicationPosition) SizeVT added in v0.12.0 

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

func (*ClusterShardReplicationPosition) String added in v0.12.0 

func (x *ClusterShardReplicationPosition) String() string

func (*ClusterShardReplicationPosition) UnmarshalVT added in v0.12.0 

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

type ClusterWorkflows added in v0.10.0 

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

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

func (*ClusterWorkflows) CloneVT added in v0.18.0 

func (m *ClusterWorkflows) CloneVT() *ClusterWorkflows

func (*ClusterWorkflows) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use ClusterWorkflows.ProtoReflect.Descriptor instead.

func (*ClusterWorkflows) GetWarnings added in v0.10.0 

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

func (*ClusterWorkflows) GetWorkflows added in v0.10.0 

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

func (*ClusterWorkflows) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ClusterWorkflows) MarshalToVT added in v0.11.0 

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

func (*ClusterWorkflows) MarshalVT added in v0.11.0 

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

func (*ClusterWorkflows) ProtoMessage added in v0.10.0 

func (*ClusterWorkflows) ProtoMessage()

func (*ClusterWorkflows) ProtoReflect added in v0.11.0 

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

func (*ClusterWorkflows) Reset added in v0.10.0 

func (x *ClusterWorkflows) Reset()

func (*ClusterWorkflows) SizeVT added in v0.11.0 

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

func (*ClusterWorkflows) String added in v0.10.0 

func (x *ClusterWorkflows) String() string

func (*ClusterWorkflows) UnmarshalVT added in v0.11.0 

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

type CreateKeyspaceRequest added in v0.12.0 

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

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

func (*CreateKeyspaceRequest) CloneVT added in v0.18.0 

func (m *CreateKeyspaceRequest) CloneVT() *CreateKeyspaceRequest

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

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

Deprecated: Use CreateKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*CreateKeyspaceRequest) GetClusterId added in v0.12.0 

func (x *CreateKeyspaceRequest) GetClusterId() string

func (*CreateKeyspaceRequest) GetOptions added in v0.12.0 

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

func (*CreateKeyspaceRequest) MarshalToSizedBufferVT added in v0.12.0 

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

func (*CreateKeyspaceRequest) MarshalToVT added in v0.12.0 

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

func (*CreateKeyspaceRequest) MarshalVT added in v0.12.0 

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

func (*CreateKeyspaceRequest) ProtoMessage added in v0.12.0 

func (*CreateKeyspaceRequest) ProtoMessage()

func (*CreateKeyspaceRequest) ProtoReflect added in v0.12.0 

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

func (*CreateKeyspaceRequest) Reset added in v0.12.0 

func (x *CreateKeyspaceRequest) Reset()

func (*CreateKeyspaceRequest) SizeVT added in v0.12.0 

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

func (*CreateKeyspaceRequest) String added in v0.12.0 

func (x *CreateKeyspaceRequest) String() string

func (*CreateKeyspaceRequest) UnmarshalVT added in v0.12.0 

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

type CreateKeyspaceResponse added in v0.12.0 

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

func (*CreateKeyspaceResponse) CloneMessageVT added in v0.18.0 

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

func (*CreateKeyspaceResponse) CloneVT added in v0.18.0 

func (m *CreateKeyspaceResponse) CloneVT() *CreateKeyspaceResponse

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

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

Deprecated: Use CreateKeyspaceResponse.ProtoReflect.Descriptor instead.

func (*CreateKeyspaceResponse) GetKeyspace added in v0.12.0 

func (x *CreateKeyspaceResponse) GetKeyspace() *Keyspace

func (*CreateKeyspaceResponse) MarshalToSizedBufferVT added in v0.12.0 

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

func (*CreateKeyspaceResponse) MarshalToVT added in v0.12.0 

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

func (*CreateKeyspaceResponse) MarshalVT added in v0.12.0 

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

func (*CreateKeyspaceResponse) ProtoMessage added in v0.12.0 

func (*CreateKeyspaceResponse) ProtoMessage()

func (*CreateKeyspaceResponse) ProtoReflect added in v0.12.0 

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

func (*CreateKeyspaceResponse) Reset added in v0.12.0 

func (x *CreateKeyspaceResponse) Reset()

func (*CreateKeyspaceResponse) SizeVT added in v0.12.0 

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

func (*CreateKeyspaceResponse) String added in v0.12.0 

func (x *CreateKeyspaceResponse) String() string

func (*CreateKeyspaceResponse) UnmarshalVT added in v0.12.0 

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

type CreateShardRequest added in v0.13.0 

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

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

func (*CreateShardRequest) CloneVT added in v0.18.0 

func (m *CreateShardRequest) CloneVT() *CreateShardRequest

func (*CreateShardRequest) Descriptor deprecated added in v0.13.0 

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

Deprecated: Use CreateShardRequest.ProtoReflect.Descriptor instead.

func (*CreateShardRequest) GetClusterId added in v0.13.0 

func (x *CreateShardRequest) GetClusterId() string

func (*CreateShardRequest) GetOptions added in v0.13.0 

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

func (*CreateShardRequest) MarshalToSizedBufferVT added in v0.13.0 

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

func (*CreateShardRequest) MarshalToVT added in v0.13.0 

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

func (*CreateShardRequest) MarshalVT added in v0.13.0 

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

func (*CreateShardRequest) ProtoMessage added in v0.13.0 

func (*CreateShardRequest) ProtoMessage()

func (*CreateShardRequest) ProtoReflect added in v0.13.0 

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

func (*CreateShardRequest) Reset added in v0.13.0 

func (x *CreateShardRequest) Reset()

func (*CreateShardRequest) SizeVT added in v0.13.0 

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

func (*CreateShardRequest) String added in v0.13.0 

func (x *CreateShardRequest) String() string

func (*CreateShardRequest) UnmarshalVT added in v0.13.0 

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

type DeleteKeyspaceRequest added in v0.12.0 

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

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

func (*DeleteKeyspaceRequest) CloneVT added in v0.18.0 

func (m *DeleteKeyspaceRequest) CloneVT() *DeleteKeyspaceRequest

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

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

Deprecated: Use DeleteKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*DeleteKeyspaceRequest) GetClusterId added in v0.12.0 

func (x *DeleteKeyspaceRequest) GetClusterId() string

func (*DeleteKeyspaceRequest) GetOptions added in v0.12.0 

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

func (*DeleteKeyspaceRequest) MarshalToSizedBufferVT added in v0.12.0 

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

func (*DeleteKeyspaceRequest) MarshalToVT added in v0.12.0 

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

func (*DeleteKeyspaceRequest) MarshalVT added in v0.12.0 

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

func (*DeleteKeyspaceRequest) ProtoMessage added in v0.12.0 

func (*DeleteKeyspaceRequest) ProtoMessage()

func (*DeleteKeyspaceRequest) ProtoReflect added in v0.12.0 

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

func (*DeleteKeyspaceRequest) Reset added in v0.12.0 

func (x *DeleteKeyspaceRequest) Reset()

func (*DeleteKeyspaceRequest) SizeVT added in v0.12.0 

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

func (*DeleteKeyspaceRequest) String added in v0.12.0 

func (x *DeleteKeyspaceRequest) String() string

func (*DeleteKeyspaceRequest) UnmarshalVT added in v0.12.0 

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

type DeleteShardsRequest added in v0.13.0 

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

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

func (*DeleteShardsRequest) CloneVT added in v0.18.0 

func (m *DeleteShardsRequest) CloneVT() *DeleteShardsRequest

func (*DeleteShardsRequest) Descriptor deprecated added in v0.13.0 

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

Deprecated: Use DeleteShardsRequest.ProtoReflect.Descriptor instead.

func (*DeleteShardsRequest) GetClusterId added in v0.13.0 

func (x *DeleteShardsRequest) GetClusterId() string

func (*DeleteShardsRequest) GetOptions added in v0.13.0 

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

func (*DeleteShardsRequest) MarshalToSizedBufferVT added in v0.13.0 

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

func (*DeleteShardsRequest) MarshalToVT added in v0.13.0 

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

func (*DeleteShardsRequest) MarshalVT added in v0.13.0 

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

func (*DeleteShardsRequest) ProtoMessage added in v0.13.0 

func (*DeleteShardsRequest) ProtoMessage()

func (*DeleteShardsRequest) ProtoReflect added in v0.13.0 

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

func (*DeleteShardsRequest) Reset added in v0.13.0 

func (x *DeleteShardsRequest) Reset()

func (*DeleteShardsRequest) SizeVT added in v0.13.0 

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

func (*DeleteShardsRequest) String added in v0.13.0 

func (x *DeleteShardsRequest) String() string

func (*DeleteShardsRequest) UnmarshalVT added in v0.13.0 

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

type DeleteTabletRequest added in v0.13.0 

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

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

func (*DeleteTabletRequest) CloneVT added in v0.18.0 

func (m *DeleteTabletRequest) CloneVT() *DeleteTabletRequest

func (*DeleteTabletRequest) Descriptor deprecated added in v0.13.0 

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

Deprecated: Use DeleteTabletRequest.ProtoReflect.Descriptor instead.

func (*DeleteTabletRequest) GetAlias added in v0.13.0 

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

func (*DeleteTabletRequest) GetAllowPrimary added in v0.14.0 

func (x *DeleteTabletRequest) GetAllowPrimary() bool

func (*DeleteTabletRequest) GetClusterIds added in v0.13.0 

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

func (*DeleteTabletRequest) MarshalToSizedBufferVT added in v0.13.0 

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

func (*DeleteTabletRequest) MarshalToVT added in v0.13.0 

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

func (*DeleteTabletRequest) MarshalVT added in v0.13.0 

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

func (*DeleteTabletRequest) ProtoMessage added in v0.13.0 

func (*DeleteTabletRequest) ProtoMessage()

func (*DeleteTabletRequest) ProtoReflect added in v0.13.0 

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

func (*DeleteTabletRequest) Reset added in v0.13.0 

func (x *DeleteTabletRequest) Reset()

func (*DeleteTabletRequest) SizeVT added in v0.13.0 

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

func (*DeleteTabletRequest) String added in v0.13.0 

func (x *DeleteTabletRequest) String() string

func (*DeleteTabletRequest) UnmarshalVT added in v0.13.0 

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

type DeleteTabletResponse added in v0.13.0 

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

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

func (*DeleteTabletResponse) CloneVT added in v0.18.0 

func (m *DeleteTabletResponse) CloneVT() *DeleteTabletResponse

func (*DeleteTabletResponse) Descriptor deprecated added in v0.13.0 

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

Deprecated: Use DeleteTabletResponse.ProtoReflect.Descriptor instead.

func (*DeleteTabletResponse) GetCluster added in v0.14.0 

func (x *DeleteTabletResponse) GetCluster() *Cluster

func (*DeleteTabletResponse) GetStatus added in v0.13.0 

func (x *DeleteTabletResponse) GetStatus() string

func (*DeleteTabletResponse) MarshalToSizedBufferVT added in v0.13.0 

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

func (*DeleteTabletResponse) MarshalToVT added in v0.13.0 

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

func (*DeleteTabletResponse) MarshalVT added in v0.13.0 

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

func (*DeleteTabletResponse) ProtoMessage added in v0.13.0 

func (*DeleteTabletResponse) ProtoMessage()

func (*DeleteTabletResponse) ProtoReflect added in v0.13.0 

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

func (*DeleteTabletResponse) Reset added in v0.13.0 

func (x *DeleteTabletResponse) Reset()

func (*DeleteTabletResponse) SizeVT added in v0.13.0 

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

func (*DeleteTabletResponse) String added in v0.13.0 

func (x *DeleteTabletResponse) String() string

func (*DeleteTabletResponse) UnmarshalVT added in v0.13.0 

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

type EmergencyFailoverShardRequest added in v0.14.0 

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

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

func (*EmergencyFailoverShardRequest) CloneVT added in v0.18.0 

func (m *EmergencyFailoverShardRequest) CloneVT() *EmergencyFailoverShardRequest

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

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

Deprecated: Use EmergencyFailoverShardRequest.ProtoReflect.Descriptor instead.

func (*EmergencyFailoverShardRequest) GetClusterId added in v0.14.0 

func (x *EmergencyFailoverShardRequest) GetClusterId() string

func (*EmergencyFailoverShardRequest) GetOptions added in v0.14.0 

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

func (*EmergencyFailoverShardRequest) MarshalToSizedBufferVT added in v0.14.0 

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

func (*EmergencyFailoverShardRequest) MarshalToVT added in v0.14.0 

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

func (*EmergencyFailoverShardRequest) MarshalVT added in v0.14.0 

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

func (*EmergencyFailoverShardRequest) ProtoMessage added in v0.14.0 

func (*EmergencyFailoverShardRequest) ProtoMessage()

func (*EmergencyFailoverShardRequest) ProtoReflect added in v0.14.0 

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

func (*EmergencyFailoverShardRequest) Reset added in v0.14.0 

func (x *EmergencyFailoverShardRequest) Reset()

func (*EmergencyFailoverShardRequest) SizeVT added in v0.14.0 

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

func (*EmergencyFailoverShardRequest) String added in v0.14.0 

func (x *EmergencyFailoverShardRequest) String() string

func (*EmergencyFailoverShardRequest) UnmarshalVT added in v0.14.0 

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

type EmergencyFailoverShardResponse added in v0.14.0 

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

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

func (*EmergencyFailoverShardResponse) CloneVT added in v0.18.0 

func (m *EmergencyFailoverShardResponse) CloneVT() *EmergencyFailoverShardResponse

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

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

Deprecated: Use EmergencyFailoverShardResponse.ProtoReflect.Descriptor instead.

func (*EmergencyFailoverShardResponse) GetCluster added in v0.14.0 

func (x *EmergencyFailoverShardResponse) GetCluster() *Cluster

func (*EmergencyFailoverShardResponse) GetEvents added in v0.14.0 

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

func (*EmergencyFailoverShardResponse) GetKeyspace added in v0.14.0 

func (x *EmergencyFailoverShardResponse) GetKeyspace() string

func (*EmergencyFailoverShardResponse) GetPromotedPrimary added in v0.14.0 

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

func (*EmergencyFailoverShardResponse) GetShard added in v0.14.0 

func (x *EmergencyFailoverShardResponse) GetShard() string

func (*EmergencyFailoverShardResponse) MarshalToSizedBufferVT added in v0.14.0 

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

func (*EmergencyFailoverShardResponse) MarshalToVT added in v0.14.0 

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

func (*EmergencyFailoverShardResponse) MarshalVT added in v0.14.0 

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

func (*EmergencyFailoverShardResponse) ProtoMessage added in v0.14.0 

func (*EmergencyFailoverShardResponse) ProtoMessage()

func (*EmergencyFailoverShardResponse) ProtoReflect added in v0.14.0 

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

func (*EmergencyFailoverShardResponse) Reset added in v0.14.0 

func (x *EmergencyFailoverShardResponse) Reset()

func (*EmergencyFailoverShardResponse) SizeVT added in v0.14.0 

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

func (*EmergencyFailoverShardResponse) String added in v0.14.0 

func (x *EmergencyFailoverShardResponse) String() string

func (*EmergencyFailoverShardResponse) UnmarshalVT added in v0.14.0 

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

type FindSchemaRequest added in v0.10.0 

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

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

func (*FindSchemaRequest) CloneVT added in v0.18.0 

func (m *FindSchemaRequest) CloneVT() *FindSchemaRequest

func (*FindSchemaRequest) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use FindSchemaRequest.ProtoReflect.Descriptor instead.

func (*FindSchemaRequest) GetClusterIds added in v0.10.0 

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

func (*FindSchemaRequest) GetTable added in v0.10.0 

func (x *FindSchemaRequest) GetTable() string

func (*FindSchemaRequest) GetTableSizeOptions added in v0.10.0 

func (x *FindSchemaRequest) GetTableSizeOptions() *GetSchemaTableSizeOptions

func (*FindSchemaRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*FindSchemaRequest) MarshalToVT added in v0.11.0 

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

func (*FindSchemaRequest) MarshalVT added in v0.11.0 

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

func (*FindSchemaRequest) ProtoMessage added in v0.10.0 

func (*FindSchemaRequest) ProtoMessage()

func (*FindSchemaRequest) ProtoReflect added in v0.11.0 

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

func (*FindSchemaRequest) Reset added in v0.10.0 

func (x *FindSchemaRequest) Reset()

func (*FindSchemaRequest) SizeVT added in v0.11.0 

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

func (*FindSchemaRequest) String added in v0.10.0 

func (x *FindSchemaRequest) String() string

func (*FindSchemaRequest) UnmarshalVT added in v0.11.0 

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

type GetBackupsRequest added in v0.11.0 

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

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

func (*GetBackupsRequest) CloneVT added in v0.18.0 

func (m *GetBackupsRequest) CloneVT() *GetBackupsRequest

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

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

Deprecated: Use GetBackupsRequest.ProtoReflect.Descriptor instead.

func (*GetBackupsRequest) GetClusterIds added in v0.11.0 

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

func (*GetBackupsRequest) GetKeyspaceShards added in v0.11.0 

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

func (*GetBackupsRequest) GetKeyspaces added in v0.11.0 

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

func (*GetBackupsRequest) GetRequestOptions added in v0.11.0 

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

func (*GetBackupsRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetBackupsRequest) MarshalToVT added in v0.11.0 

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

func (*GetBackupsRequest) MarshalVT added in v0.11.0 

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

func (*GetBackupsRequest) ProtoMessage added in v0.11.0 

func (*GetBackupsRequest) ProtoMessage()

func (*GetBackupsRequest) ProtoReflect added in v0.11.0 

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

func (*GetBackupsRequest) Reset added in v0.11.0 

func (x *GetBackupsRequest) Reset()

func (*GetBackupsRequest) SizeVT added in v0.11.0 

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

func (*GetBackupsRequest) String added in v0.11.0 

func (x *GetBackupsRequest) String() string

func (*GetBackupsRequest) UnmarshalVT added in v0.11.0 

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

type GetBackupsResponse added in v0.11.0 

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

func (*GetBackupsResponse) CloneMessageVT added in v0.18.0 

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

func (*GetBackupsResponse) CloneVT added in v0.18.0 

func (m *GetBackupsResponse) CloneVT() *GetBackupsResponse

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

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

Deprecated: Use GetBackupsResponse.ProtoReflect.Descriptor instead.

func (*GetBackupsResponse) GetBackups added in v0.11.0 

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

func (*GetBackupsResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetBackupsResponse) MarshalToVT added in v0.11.0 

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

func (*GetBackupsResponse) MarshalVT added in v0.11.0 

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

func (*GetBackupsResponse) ProtoMessage added in v0.11.0 

func (*GetBackupsResponse) ProtoMessage()

func (*GetBackupsResponse) ProtoReflect added in v0.11.0 

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

func (*GetBackupsResponse) Reset added in v0.11.0 

func (x *GetBackupsResponse) Reset()

func (*GetBackupsResponse) SizeVT added in v0.11.0 

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

func (*GetBackupsResponse) String added in v0.11.0 

func (x *GetBackupsResponse) String() string

func (*GetBackupsResponse) UnmarshalVT added in v0.11.0 

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

type GetCellInfosRequest added in v0.14.0 

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

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

func (*GetCellInfosRequest) CloneVT added in v0.18.0 

func (m *GetCellInfosRequest) CloneVT() *GetCellInfosRequest

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

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

Deprecated: Use GetCellInfosRequest.ProtoReflect.Descriptor instead.

func (*GetCellInfosRequest) GetCells added in v0.14.0 

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

func (*GetCellInfosRequest) GetClusterIds added in v0.14.0 

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

func (*GetCellInfosRequest) GetNamesOnly added in v0.14.0 

func (x *GetCellInfosRequest) GetNamesOnly() bool

func (*GetCellInfosRequest) MarshalToSizedBufferVT added in v0.14.0 

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

func (*GetCellInfosRequest) MarshalToVT added in v0.14.0 

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

func (*GetCellInfosRequest) MarshalVT added in v0.14.0 

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

func (*GetCellInfosRequest) ProtoMessage added in v0.14.0 

func (*GetCellInfosRequest) ProtoMessage()

func (*GetCellInfosRequest) ProtoReflect added in v0.14.0 

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

func (*GetCellInfosRequest) Reset added in v0.14.0 

func (x *GetCellInfosRequest) Reset()

func (*GetCellInfosRequest) SizeVT added in v0.14.0 

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

func (*GetCellInfosRequest) String added in v0.14.0 

func (x *GetCellInfosRequest) String() string

func (*GetCellInfosRequest) UnmarshalVT added in v0.14.0 

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

type GetCellInfosResponse added in v0.14.0 

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

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

func (*GetCellInfosResponse) CloneVT added in v0.18.0 

func (m *GetCellInfosResponse) CloneVT() *GetCellInfosResponse

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

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

Deprecated: Use GetCellInfosResponse.ProtoReflect.Descriptor instead.

func (*GetCellInfosResponse) GetCellInfos added in v0.14.0 

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

func (*GetCellInfosResponse) MarshalToSizedBufferVT added in v0.14.0 

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

func (*GetCellInfosResponse) MarshalToVT added in v0.14.0 

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

func (*GetCellInfosResponse) MarshalVT added in v0.14.0 

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

func (*GetCellInfosResponse) ProtoMessage added in v0.14.0 

func (*GetCellInfosResponse) ProtoMessage()

func (*GetCellInfosResponse) ProtoReflect added in v0.14.0 

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

func (*GetCellInfosResponse) Reset added in v0.14.0 

func (x *GetCellInfosResponse) Reset()

func (*GetCellInfosResponse) SizeVT added in v0.14.0 

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

func (*GetCellInfosResponse) String added in v0.14.0 

func (x *GetCellInfosResponse) String() string

func (*GetCellInfosResponse) UnmarshalVT added in v0.14.0 

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

type GetCellsAliasesRequest added in v0.14.0 

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

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

func (*GetCellsAliasesRequest) CloneVT added in v0.18.0 

func (m *GetCellsAliasesRequest) CloneVT() *GetCellsAliasesRequest

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

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

Deprecated: Use GetCellsAliasesRequest.ProtoReflect.Descriptor instead.

func (*GetCellsAliasesRequest) GetClusterIds added in v0.14.0 

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

func (*GetCellsAliasesRequest) MarshalToSizedBufferVT added in v0.14.0 

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

func (*GetCellsAliasesRequest) MarshalToVT added in v0.14.0 

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

func (*GetCellsAliasesRequest) MarshalVT added in v0.14.0 

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

func (*GetCellsAliasesRequest) ProtoMessage added in v0.14.0 

func (*GetCellsAliasesRequest) ProtoMessage()

func (*GetCellsAliasesRequest) ProtoReflect added in v0.14.0 

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

func (*GetCellsAliasesRequest) Reset added in v0.14.0 

func (x *GetCellsAliasesRequest) Reset()

func (*GetCellsAliasesRequest) SizeVT added in v0.14.0 

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

func (*GetCellsAliasesRequest) String added in v0.14.0 

func (x *GetCellsAliasesRequest) String() string

func (*GetCellsAliasesRequest) UnmarshalVT added in v0.14.0 

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

type GetCellsAliasesResponse added in v0.14.0 

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

func (*GetCellsAliasesResponse) CloneMessageVT added in v0.18.0 

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

func (*GetCellsAliasesResponse) CloneVT added in v0.18.0 

func (m *GetCellsAliasesResponse) CloneVT() *GetCellsAliasesResponse

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

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

Deprecated: Use GetCellsAliasesResponse.ProtoReflect.Descriptor instead.

func (*GetCellsAliasesResponse) GetAliases added in v0.14.0 

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

func (*GetCellsAliasesResponse) MarshalToSizedBufferVT added in v0.14.0 

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

func (*GetCellsAliasesResponse) MarshalToVT added in v0.14.0 

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

func (*GetCellsAliasesResponse) MarshalVT added in v0.14.0 

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

func (*GetCellsAliasesResponse) ProtoMessage added in v0.14.0 

func (*GetCellsAliasesResponse) ProtoMessage()

func (*GetCellsAliasesResponse) ProtoReflect added in v0.14.0 

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

func (*GetCellsAliasesResponse) Reset added in v0.14.0 

func (x *GetCellsAliasesResponse) Reset()

func (*GetCellsAliasesResponse) SizeVT added in v0.14.0 

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

func (*GetCellsAliasesResponse) String added in v0.14.0 

func (x *GetCellsAliasesResponse) String() string

func (*GetCellsAliasesResponse) UnmarshalVT added in v0.14.0 

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

type GetClustersRequest added in v0.10.0 

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

func (*GetClustersRequest) CloneMessageVT added in v0.18.0 

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

func (*GetClustersRequest) CloneVT added in v0.18.0 

func (m *GetClustersRequest) CloneVT() *GetClustersRequest

func (*GetClustersRequest) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetClustersRequest.ProtoReflect.Descriptor instead.

func (*GetClustersRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetClustersRequest) MarshalToVT added in v0.11.0 

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

func (*GetClustersRequest) MarshalVT added in v0.11.0 

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

func (*GetClustersRequest) ProtoMessage added in v0.10.0 

func (*GetClustersRequest) ProtoMessage()

func (*GetClustersRequest) ProtoReflect added in v0.11.0 

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

func (*GetClustersRequest) Reset added in v0.10.0 

func (x *GetClustersRequest) Reset()

func (*GetClustersRequest) SizeVT added in v0.11.0 

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

func (*GetClustersRequest) String added in v0.10.0 

func (x *GetClustersRequest) String() string

func (*GetClustersRequest) UnmarshalVT added in v0.11.0 

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

type GetClustersResponse added in v0.10.0 

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

func (*GetClustersResponse) CloneMessageVT added in v0.18.0 

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

func (*GetClustersResponse) CloneVT added in v0.18.0 

func (m *GetClustersResponse) CloneVT() *GetClustersResponse

func (*GetClustersResponse) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetClustersResponse.ProtoReflect.Descriptor instead.

func (*GetClustersResponse) GetClusters added in v0.10.0 

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

func (*GetClustersResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetClustersResponse) MarshalToVT added in v0.11.0 

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

func (*GetClustersResponse) MarshalVT added in v0.11.0 

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

func (*GetClustersResponse) ProtoMessage added in v0.10.0 

func (*GetClustersResponse) ProtoMessage()

func (*GetClustersResponse) ProtoReflect added in v0.11.0 

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

func (*GetClustersResponse) Reset added in v0.10.0 

func (x *GetClustersResponse) Reset()

func (*GetClustersResponse) SizeVT added in v0.11.0 

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

func (*GetClustersResponse) String added in v0.10.0 

func (x *GetClustersResponse) String() string

func (*GetClustersResponse) UnmarshalVT added in v0.11.0 

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

type GetFullStatusRequest added in v0.15.0 

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

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

func (*GetFullStatusRequest) CloneVT added in v0.18.0 

func (m *GetFullStatusRequest) CloneVT() *GetFullStatusRequest

func (*GetFullStatusRequest) Descriptor deprecated added in v0.15.0 

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

Deprecated: Use GetFullStatusRequest.ProtoReflect.Descriptor instead.

func (*GetFullStatusRequest) GetAlias added in v0.15.0 

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

func (*GetFullStatusRequest) GetClusterId added in v0.15.0 

func (x *GetFullStatusRequest) GetClusterId() string

func (*GetFullStatusRequest) MarshalToSizedBufferVT added in v0.15.0 

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

func (*GetFullStatusRequest) MarshalToVT added in v0.15.0 

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

func (*GetFullStatusRequest) MarshalVT added in v0.15.0 

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

func (*GetFullStatusRequest) ProtoMessage added in v0.15.0 

func (*GetFullStatusRequest) ProtoMessage()

func (*GetFullStatusRequest) ProtoReflect added in v0.15.0 

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

func (*GetFullStatusRequest) Reset added in v0.15.0 

func (x *GetFullStatusRequest) Reset()

func (*GetFullStatusRequest) SizeVT added in v0.15.0 

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

func (*GetFullStatusRequest) String added in v0.15.0 

func (x *GetFullStatusRequest) String() string

func (*GetFullStatusRequest) UnmarshalVT added in v0.15.0 

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

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

func (*GetGatesRequest) CloneVT added in v0.18.0 

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

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

func (*GetGatesRequest) MarshalToVT added in v0.11.0 

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

func (*GetGatesRequest) MarshalVT added in v0.11.0 

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

func (*GetGatesRequest) ProtoMessage 

func (*GetGatesRequest) ProtoMessage()

func (*GetGatesRequest) ProtoReflect added in v0.11.0 

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

func (*GetGatesRequest) Reset 

func (x *GetGatesRequest) Reset()

func (*GetGatesRequest) SizeVT added in v0.11.0 

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

func (*GetGatesRequest) String 

func (x *GetGatesRequest) String() string

func (*GetGatesRequest) UnmarshalVT added in v0.11.0 

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

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

func (*GetGatesResponse) CloneVT added in v0.18.0 

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

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

func (*GetGatesResponse) MarshalToVT added in v0.11.0 

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

func (*GetGatesResponse) MarshalVT added in v0.11.0 

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

func (*GetGatesResponse) ProtoMessage 

func (*GetGatesResponse) ProtoMessage()

func (*GetGatesResponse) ProtoReflect added in v0.11.0 

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

func (*GetGatesResponse) Reset 

func (x *GetGatesResponse) Reset()

func (*GetGatesResponse) SizeVT added in v0.11.0 

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

func (*GetGatesResponse) String 

func (x *GetGatesResponse) String() string

func (*GetGatesResponse) UnmarshalVT added in v0.11.0 

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

type GetKeyspaceRequest added in v0.11.0 

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

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

func (*GetKeyspaceRequest) CloneVT added in v0.18.0 

func (m *GetKeyspaceRequest) CloneVT() *GetKeyspaceRequest

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

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

Deprecated: Use GetKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*GetKeyspaceRequest) GetClusterId added in v0.11.0 

func (x *GetKeyspaceRequest) GetClusterId() string

func (*GetKeyspaceRequest) GetKeyspace added in v0.11.0 

func (x *GetKeyspaceRequest) GetKeyspace() string

func (*GetKeyspaceRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetKeyspaceRequest) MarshalToVT added in v0.11.0 

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

func (*GetKeyspaceRequest) MarshalVT added in v0.11.0 

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

func (*GetKeyspaceRequest) ProtoMessage added in v0.11.0 

func (*GetKeyspaceRequest) ProtoMessage()

func (*GetKeyspaceRequest) ProtoReflect added in v0.11.0 

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

func (*GetKeyspaceRequest) Reset added in v0.11.0 

func (x *GetKeyspaceRequest) Reset()

func (*GetKeyspaceRequest) SizeVT added in v0.11.0 

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

func (*GetKeyspaceRequest) String added in v0.11.0 

func (x *GetKeyspaceRequest) String() string

func (*GetKeyspaceRequest) UnmarshalVT added in v0.11.0 

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

type GetKeyspacesRequest added in v0.10.0 

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

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

func (*GetKeyspacesRequest) CloneVT added in v0.18.0 

func (m *GetKeyspacesRequest) CloneVT() *GetKeyspacesRequest

func (*GetKeyspacesRequest) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetKeyspacesRequest.ProtoReflect.Descriptor instead.

func (*GetKeyspacesRequest) GetClusterIds added in v0.10.0 

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

func (*GetKeyspacesRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetKeyspacesRequest) MarshalToVT added in v0.11.0 

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

func (*GetKeyspacesRequest) MarshalVT added in v0.11.0 

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

func (*GetKeyspacesRequest) ProtoMessage added in v0.10.0 

func (*GetKeyspacesRequest) ProtoMessage()

func (*GetKeyspacesRequest) ProtoReflect added in v0.11.0 

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

func (*GetKeyspacesRequest) Reset added in v0.10.0 

func (x *GetKeyspacesRequest) Reset()

func (*GetKeyspacesRequest) SizeVT added in v0.11.0 

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

func (*GetKeyspacesRequest) String added in v0.10.0 

func (x *GetKeyspacesRequest) String() string

func (*GetKeyspacesRequest) UnmarshalVT added in v0.11.0 

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

type GetKeyspacesResponse added in v0.10.0 

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

func (*GetKeyspacesResponse) CloneMessageVT added in v0.18.0 

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

func (*GetKeyspacesResponse) CloneVT added in v0.18.0 

func (m *GetKeyspacesResponse) CloneVT() *GetKeyspacesResponse

func (*GetKeyspacesResponse) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetKeyspacesResponse.ProtoReflect.Descriptor instead.

func (*GetKeyspacesResponse) GetKeyspaces added in v0.10.0 

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

func (*GetKeyspacesResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetKeyspacesResponse) MarshalToVT added in v0.11.0 

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

func (*GetKeyspacesResponse) MarshalVT added in v0.11.0 

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

func (*GetKeyspacesResponse) ProtoMessage added in v0.10.0 

func (*GetKeyspacesResponse) ProtoMessage()

func (*GetKeyspacesResponse) ProtoReflect added in v0.11.0 

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

func (*GetKeyspacesResponse) Reset added in v0.10.0 

func (x *GetKeyspacesResponse) Reset()

func (*GetKeyspacesResponse) SizeVT added in v0.11.0 

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

func (*GetKeyspacesResponse) String added in v0.10.0 

func (x *GetKeyspacesResponse) String() string

func (*GetKeyspacesResponse) UnmarshalVT added in v0.11.0 

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

type GetSchemaRequest added in v0.10.0 

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

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

func (*GetSchemaRequest) CloneVT added in v0.18.0 

func (m *GetSchemaRequest) CloneVT() *GetSchemaRequest

func (*GetSchemaRequest) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaRequest) GetClusterId added in v0.10.0 

func (x *GetSchemaRequest) GetClusterId() string

func (*GetSchemaRequest) GetKeyspace added in v0.10.0 

func (x *GetSchemaRequest) GetKeyspace() string

func (*GetSchemaRequest) GetTable added in v0.10.0 

func (x *GetSchemaRequest) GetTable() string

func (*GetSchemaRequest) GetTableSizeOptions added in v0.10.0 

func (x *GetSchemaRequest) GetTableSizeOptions() *GetSchemaTableSizeOptions

func (*GetSchemaRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSchemaRequest) MarshalToVT added in v0.11.0 

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

func (*GetSchemaRequest) MarshalVT added in v0.11.0 

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

func (*GetSchemaRequest) ProtoMessage added in v0.10.0 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) ProtoReflect added in v0.11.0 

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

func (*GetSchemaRequest) Reset added in v0.10.0 

func (x *GetSchemaRequest) Reset()

func (*GetSchemaRequest) SizeVT added in v0.11.0 

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

func (*GetSchemaRequest) String added in v0.10.0 

func (x *GetSchemaRequest) String() string

func (*GetSchemaRequest) UnmarshalVT added in v0.11.0 

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

type GetSchemaTableSizeOptions added in v0.10.0 

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

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

func (*GetSchemaTableSizeOptions) CloneVT added in v0.18.0 

func (m *GetSchemaTableSizeOptions) CloneVT() *GetSchemaTableSizeOptions

func (*GetSchemaTableSizeOptions) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetSchemaTableSizeOptions.ProtoReflect.Descriptor instead.

func (*GetSchemaTableSizeOptions) GetAggregateSizes added in v0.10.0 

func (x *GetSchemaTableSizeOptions) GetAggregateSizes() bool

func (*GetSchemaTableSizeOptions) GetIncludeNonServingShards added in v0.11.0 

func (x *GetSchemaTableSizeOptions) GetIncludeNonServingShards() bool

func (*GetSchemaTableSizeOptions) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSchemaTableSizeOptions) MarshalToVT added in v0.11.0 

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

func (*GetSchemaTableSizeOptions) MarshalVT added in v0.11.0 

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

func (*GetSchemaTableSizeOptions) ProtoMessage added in v0.10.0 

func (*GetSchemaTableSizeOptions) ProtoMessage()

func (*GetSchemaTableSizeOptions) ProtoReflect added in v0.11.0 

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

func (*GetSchemaTableSizeOptions) Reset added in v0.10.0 

func (x *GetSchemaTableSizeOptions) Reset()

func (*GetSchemaTableSizeOptions) SizeVT added in v0.11.0 

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

func (*GetSchemaTableSizeOptions) String added in v0.10.0 

func (x *GetSchemaTableSizeOptions) String() string

func (*GetSchemaTableSizeOptions) UnmarshalVT added in v0.11.0 

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

type GetSchemasRequest added in v0.10.0 

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

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

func (*GetSchemasRequest) CloneVT added in v0.18.0 

func (m *GetSchemasRequest) CloneVT() *GetSchemasRequest

func (*GetSchemasRequest) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetSchemasRequest.ProtoReflect.Descriptor instead.

func (*GetSchemasRequest) GetClusterIds added in v0.10.0 

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

func (*GetSchemasRequest) GetTableSizeOptions added in v0.10.0 

func (x *GetSchemasRequest) GetTableSizeOptions() *GetSchemaTableSizeOptions

func (*GetSchemasRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSchemasRequest) MarshalToVT added in v0.11.0 

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

func (*GetSchemasRequest) MarshalVT added in v0.11.0 

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

func (*GetSchemasRequest) ProtoMessage added in v0.10.0 

func (*GetSchemasRequest) ProtoMessage()

func (*GetSchemasRequest) ProtoReflect added in v0.11.0 

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

func (*GetSchemasRequest) Reset added in v0.10.0 

func (x *GetSchemasRequest) Reset()

func (*GetSchemasRequest) SizeVT added in v0.11.0 

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

func (*GetSchemasRequest) String added in v0.10.0 

func (x *GetSchemasRequest) String() string

func (*GetSchemasRequest) UnmarshalVT added in v0.11.0 

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

type GetSchemasResponse added in v0.10.0 

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

func (*GetSchemasResponse) CloneMessageVT added in v0.18.0 

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

func (*GetSchemasResponse) CloneVT added in v0.18.0 

func (m *GetSchemasResponse) CloneVT() *GetSchemasResponse

func (*GetSchemasResponse) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetSchemasResponse.ProtoReflect.Descriptor instead.

func (*GetSchemasResponse) GetSchemas added in v0.10.0 

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

func (*GetSchemasResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSchemasResponse) MarshalToVT added in v0.11.0 

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

func (*GetSchemasResponse) MarshalVT added in v0.11.0 

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

func (*GetSchemasResponse) ProtoMessage added in v0.10.0 

func (*GetSchemasResponse) ProtoMessage()

func (*GetSchemasResponse) ProtoReflect added in v0.11.0 

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

func (*GetSchemasResponse) Reset added in v0.10.0 

func (x *GetSchemasResponse) Reset()

func (*GetSchemasResponse) SizeVT added in v0.11.0 

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

func (*GetSchemasResponse) String added in v0.10.0 

func (x *GetSchemasResponse) String() string

func (*GetSchemasResponse) UnmarshalVT added in v0.11.0 

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

type GetShardReplicationPositionsRequest added in v0.12.0 

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

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

func (*GetShardReplicationPositionsRequest) CloneVT added in v0.18.0 

func (m *GetShardReplicationPositionsRequest) CloneVT() *GetShardReplicationPositionsRequest

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

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

Deprecated: Use GetShardReplicationPositionsRequest.ProtoReflect.Descriptor instead.

func (*GetShardReplicationPositionsRequest) GetClusterIds added in v0.12.0 

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

func (*GetShardReplicationPositionsRequest) GetKeyspaceShards added in v0.12.0 

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

func (*GetShardReplicationPositionsRequest) GetKeyspaces added in v0.12.0 

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

func (*GetShardReplicationPositionsRequest) MarshalToSizedBufferVT added in v0.12.0 

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

func (*GetShardReplicationPositionsRequest) MarshalToVT added in v0.12.0 

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

func (*GetShardReplicationPositionsRequest) MarshalVT added in v0.12.0 

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

func (*GetShardReplicationPositionsRequest) ProtoMessage added in v0.12.0 

func (*GetShardReplicationPositionsRequest) ProtoMessage()

func (*GetShardReplicationPositionsRequest) ProtoReflect added in v0.12.0 

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

func (*GetShardReplicationPositionsRequest) Reset added in v0.12.0 

func (x *GetShardReplicationPositionsRequest) Reset()

func (*GetShardReplicationPositionsRequest) SizeVT added in v0.12.0 

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

func (*GetShardReplicationPositionsRequest) String added in v0.12.0 

func (x *GetShardReplicationPositionsRequest) String() string

func (*GetShardReplicationPositionsRequest) UnmarshalVT added in v0.12.0 

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

type GetShardReplicationPositionsResponse added in v0.12.0 

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

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

func (*GetShardReplicationPositionsResponse) CloneVT added in v0.18.0 

func (m *GetShardReplicationPositionsResponse) CloneVT() *GetShardReplicationPositionsResponse

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

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

Deprecated: Use GetShardReplicationPositionsResponse.ProtoReflect.Descriptor instead.

func (*GetShardReplicationPositionsResponse) GetReplicationPositions added in v0.12.0 

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

func (*GetShardReplicationPositionsResponse) MarshalToSizedBufferVT added in v0.12.0 

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

func (*GetShardReplicationPositionsResponse) MarshalToVT added in v0.12.0 

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

func (*GetShardReplicationPositionsResponse) MarshalVT added in v0.12.0 

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

func (*GetShardReplicationPositionsResponse) ProtoMessage added in v0.12.0 

func (*GetShardReplicationPositionsResponse) ProtoMessage()

func (*GetShardReplicationPositionsResponse) ProtoReflect added in v0.12.0 

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

func (*GetShardReplicationPositionsResponse) Reset added in v0.12.0 

func (x *GetShardReplicationPositionsResponse) Reset()

func (*GetShardReplicationPositionsResponse) SizeVT added in v0.12.0 

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

func (*GetShardReplicationPositionsResponse) String added in v0.12.0 

func (x *GetShardReplicationPositionsResponse) String() string

func (*GetShardReplicationPositionsResponse) UnmarshalVT added in v0.12.0 

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

type GetSrvKeyspaceRequest added in v0.17.0 

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

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

func (*GetSrvKeyspaceRequest) CloneVT added in v0.18.0 

func (m *GetSrvKeyspaceRequest) CloneVT() *GetSrvKeyspaceRequest

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

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

Deprecated: Use GetSrvKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*GetSrvKeyspaceRequest) GetCells added in v0.17.0 

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

func (*GetSrvKeyspaceRequest) GetClusterId added in v0.17.0 

func (x *GetSrvKeyspaceRequest) GetClusterId() string

func (*GetSrvKeyspaceRequest) GetKeyspace added in v0.17.0 

func (x *GetSrvKeyspaceRequest) GetKeyspace() string

func (*GetSrvKeyspaceRequest) MarshalToSizedBufferVT added in v0.17.0 

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

func (*GetSrvKeyspaceRequest) MarshalToVT added in v0.17.0 

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

func (*GetSrvKeyspaceRequest) MarshalVT added in v0.17.0 

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

func (*GetSrvKeyspaceRequest) ProtoMessage added in v0.17.0 

func (*GetSrvKeyspaceRequest) ProtoMessage()

func (*GetSrvKeyspaceRequest) ProtoReflect added in v0.17.0 

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

func (*GetSrvKeyspaceRequest) Reset added in v0.17.0 

func (x *GetSrvKeyspaceRequest) Reset()

func (*GetSrvKeyspaceRequest) SizeVT added in v0.17.0 

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

func (*GetSrvKeyspaceRequest) String added in v0.17.0 

func (x *GetSrvKeyspaceRequest) String() string

func (*GetSrvKeyspaceRequest) UnmarshalVT added in v0.17.0 

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

type GetSrvKeyspacesRequest added in v0.17.0 

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

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

func (*GetSrvKeyspacesRequest) CloneVT added in v0.18.0 

func (m *GetSrvKeyspacesRequest) CloneVT() *GetSrvKeyspacesRequest

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

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

Deprecated: Use GetSrvKeyspacesRequest.ProtoReflect.Descriptor instead.

func (*GetSrvKeyspacesRequest) GetCells added in v0.17.0 

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

func (*GetSrvKeyspacesRequest) GetClusterIds added in v0.17.0 

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

func (*GetSrvKeyspacesRequest) MarshalToSizedBufferVT added in v0.17.0 

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

func (*GetSrvKeyspacesRequest) MarshalToVT added in v0.17.0 

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

func (*GetSrvKeyspacesRequest) MarshalVT added in v0.17.0 

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

func (*GetSrvKeyspacesRequest) ProtoMessage added in v0.17.0 

func (*GetSrvKeyspacesRequest) ProtoMessage()

func (*GetSrvKeyspacesRequest) ProtoReflect added in v0.17.0 

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

func (*GetSrvKeyspacesRequest) Reset added in v0.17.0 

func (x *GetSrvKeyspacesRequest) Reset()

func (*GetSrvKeyspacesRequest) SizeVT added in v0.17.0 

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

func (*GetSrvKeyspacesRequest) String added in v0.17.0 

func (x *GetSrvKeyspacesRequest) String() string

func (*GetSrvKeyspacesRequest) UnmarshalVT added in v0.17.0 

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

type GetSrvKeyspacesResponse added in v0.17.0 

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

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

func (*GetSrvKeyspacesResponse) CloneVT added in v0.18.0 

func (m *GetSrvKeyspacesResponse) CloneVT() *GetSrvKeyspacesResponse

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

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

Deprecated: Use GetSrvKeyspacesResponse.ProtoReflect.Descriptor instead.

func (*GetSrvKeyspacesResponse) GetSrvKeyspaces added in v0.17.0 

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

func (*GetSrvKeyspacesResponse) MarshalToSizedBufferVT added in v0.17.0 

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

func (*GetSrvKeyspacesResponse) MarshalToVT added in v0.17.0 

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

func (*GetSrvKeyspacesResponse) MarshalVT added in v0.17.0 

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

func (*GetSrvKeyspacesResponse) ProtoMessage added in v0.17.0 

func (*GetSrvKeyspacesResponse) ProtoMessage()

func (*GetSrvKeyspacesResponse) ProtoReflect added in v0.17.0 

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

func (*GetSrvKeyspacesResponse) Reset added in v0.17.0 

func (x *GetSrvKeyspacesResponse) Reset()

func (*GetSrvKeyspacesResponse) SizeVT added in v0.17.0 

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

func (*GetSrvKeyspacesResponse) String added in v0.17.0 

func (x *GetSrvKeyspacesResponse) String() string

func (*GetSrvKeyspacesResponse) UnmarshalVT added in v0.17.0 

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

type GetSrvVSchemaRequest added in v0.11.0 

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

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

func (*GetSrvVSchemaRequest) CloneVT added in v0.18.0 

func (m *GetSrvVSchemaRequest) CloneVT() *GetSrvVSchemaRequest

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

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

Deprecated: Use GetSrvVSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSrvVSchemaRequest) GetCell added in v0.11.0 

func (x *GetSrvVSchemaRequest) GetCell() string

func (*GetSrvVSchemaRequest) GetClusterId added in v0.11.0 

func (x *GetSrvVSchemaRequest) GetClusterId() string

func (*GetSrvVSchemaRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSrvVSchemaRequest) MarshalToVT added in v0.11.0 

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

func (*GetSrvVSchemaRequest) MarshalVT added in v0.11.0 

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

func (*GetSrvVSchemaRequest) ProtoMessage added in v0.11.0 

func (*GetSrvVSchemaRequest) ProtoMessage()

func (*GetSrvVSchemaRequest) ProtoReflect added in v0.11.0 

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

func (*GetSrvVSchemaRequest) Reset added in v0.11.0 

func (x *GetSrvVSchemaRequest) Reset()

func (*GetSrvVSchemaRequest) SizeVT added in v0.11.0 

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

func (*GetSrvVSchemaRequest) String added in v0.11.0 

func (x *GetSrvVSchemaRequest) String() string

func (*GetSrvVSchemaRequest) UnmarshalVT added in v0.11.0 

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

type GetSrvVSchemasRequest added in v0.11.0 

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

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

func (*GetSrvVSchemasRequest) CloneVT added in v0.18.0 

func (m *GetSrvVSchemasRequest) CloneVT() *GetSrvVSchemasRequest

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

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

Deprecated: Use GetSrvVSchemasRequest.ProtoReflect.Descriptor instead.

func (*GetSrvVSchemasRequest) GetCells added in v0.11.0 

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

func (*GetSrvVSchemasRequest) GetClusterIds added in v0.11.0 

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

func (*GetSrvVSchemasRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSrvVSchemasRequest) MarshalToVT added in v0.11.0 

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

func (*GetSrvVSchemasRequest) MarshalVT added in v0.11.0 

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

func (*GetSrvVSchemasRequest) ProtoMessage added in v0.11.0 

func (*GetSrvVSchemasRequest) ProtoMessage()

func (*GetSrvVSchemasRequest) ProtoReflect added in v0.11.0 

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

func (*GetSrvVSchemasRequest) Reset added in v0.11.0 

func (x *GetSrvVSchemasRequest) Reset()

func (*GetSrvVSchemasRequest) SizeVT added in v0.11.0 

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

func (*GetSrvVSchemasRequest) String added in v0.11.0 

func (x *GetSrvVSchemasRequest) String() string

func (*GetSrvVSchemasRequest) UnmarshalVT added in v0.11.0 

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

type GetSrvVSchemasResponse added in v0.11.0 

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

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

func (*GetSrvVSchemasResponse) CloneVT added in v0.18.0 

func (m *GetSrvVSchemasResponse) CloneVT() *GetSrvVSchemasResponse

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

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

Deprecated: Use GetSrvVSchemasResponse.ProtoReflect.Descriptor instead.

func (*GetSrvVSchemasResponse) GetSrvVSchemas added in v0.11.0 

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

func (*GetSrvVSchemasResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSrvVSchemasResponse) MarshalToVT added in v0.11.0 

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

func (*GetSrvVSchemasResponse) MarshalVT added in v0.11.0 

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

func (*GetSrvVSchemasResponse) ProtoMessage added in v0.11.0 

func (*GetSrvVSchemasResponse) ProtoMessage()

func (*GetSrvVSchemasResponse) ProtoReflect added in v0.11.0 

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

func (*GetSrvVSchemasResponse) Reset added in v0.11.0 

func (x *GetSrvVSchemasResponse) Reset()

func (*GetSrvVSchemasResponse) SizeVT added in v0.11.0 

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

func (*GetSrvVSchemasResponse) String added in v0.11.0 

func (x *GetSrvVSchemasResponse) String() string

func (*GetSrvVSchemasResponse) UnmarshalVT added in v0.11.0 

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

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

func (*GetTabletRequest) CloneVT added in v0.18.0 

func (m *GetTabletRequest) CloneVT() *GetTabletRequest

func (*GetTabletRequest) Descriptor deprecated 

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

Deprecated: Use GetTabletRequest.ProtoReflect.Descriptor instead.

func (*GetTabletRequest) GetAlias added in v0.11.0 

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

func (*GetTabletRequest) GetClusterIds 

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

func (*GetTabletRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetTabletRequest) MarshalToVT added in v0.11.0 

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

func (*GetTabletRequest) MarshalVT added in v0.11.0 

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

func (*GetTabletRequest) ProtoMessage 

func (*GetTabletRequest) ProtoMessage()

func (*GetTabletRequest) ProtoReflect added in v0.11.0 

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

func (*GetTabletRequest) Reset 

func (x *GetTabletRequest) Reset()

func (*GetTabletRequest) SizeVT added in v0.11.0 

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

func (*GetTabletRequest) String 

func (x *GetTabletRequest) String() string

func (*GetTabletRequest) UnmarshalVT added in v0.11.0 

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

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

func (*GetTabletsRequest) CloneVT added in v0.18.0 

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

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

func (*GetTabletsRequest) MarshalToVT added in v0.11.0 

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

func (*GetTabletsRequest) MarshalVT added in v0.11.0 

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

func (*GetTabletsRequest) ProtoMessage 

func (*GetTabletsRequest) ProtoMessage()

func (*GetTabletsRequest) ProtoReflect added in v0.11.0 

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

func (*GetTabletsRequest) Reset 

func (x *GetTabletsRequest) Reset()

func (*GetTabletsRequest) SizeVT added in v0.11.0 

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

func (*GetTabletsRequest) String 

func (x *GetTabletsRequest) String() string

func (*GetTabletsRequest) UnmarshalVT added in v0.11.0 

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

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

func (*GetTabletsResponse) CloneVT added in v0.18.0 

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

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

func (*GetTabletsResponse) MarshalToVT added in v0.11.0 

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

func (*GetTabletsResponse) MarshalVT added in v0.11.0 

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

func (*GetTabletsResponse) ProtoMessage 

func (*GetTabletsResponse) ProtoMessage()

func (*GetTabletsResponse) ProtoReflect added in v0.11.0 

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

func (*GetTabletsResponse) Reset 

func (x *GetTabletsResponse) Reset()

func (*GetTabletsResponse) SizeVT added in v0.11.0 

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

func (*GetTabletsResponse) String 

func (x *GetTabletsResponse) String() string

func (*GetTabletsResponse) UnmarshalVT added in v0.11.0 

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

type GetTopologyPathRequest added in v0.15.0 

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

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

func (*GetTopologyPathRequest) CloneVT added in v0.18.0 

func (m *GetTopologyPathRequest) CloneVT() *GetTopologyPathRequest

func (*GetTopologyPathRequest) Descriptor deprecated added in v0.15.0 

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

Deprecated: Use GetTopologyPathRequest.ProtoReflect.Descriptor instead.

func (*GetTopologyPathRequest) GetClusterId added in v0.15.0 

func (x *GetTopologyPathRequest) GetClusterId() string

func (*GetTopologyPathRequest) GetPath added in v0.15.0 

func (x *GetTopologyPathRequest) GetPath() string

func (*GetTopologyPathRequest) MarshalToSizedBufferVT added in v0.15.0 

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

func (*GetTopologyPathRequest) MarshalToVT added in v0.15.0 

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

func (*GetTopologyPathRequest) MarshalVT added in v0.15.0 

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

func (*GetTopologyPathRequest) ProtoMessage added in v0.15.0 

func (*GetTopologyPathRequest) ProtoMessage()

func (*GetTopologyPathRequest) ProtoReflect added in v0.15.0 

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

func (*GetTopologyPathRequest) Reset added in v0.15.0 

func (x *GetTopologyPathRequest) Reset()

func (*GetTopologyPathRequest) SizeVT added in v0.15.0 

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

func (*GetTopologyPathRequest) String added in v0.15.0 

func (x *GetTopologyPathRequest) String() string

func (*GetTopologyPathRequest) UnmarshalVT added in v0.15.0 

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

type GetVSchemaRequest added in v0.10.0 

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

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

func (*GetVSchemaRequest) CloneVT added in v0.18.0 

func (m *GetVSchemaRequest) CloneVT() *GetVSchemaRequest

func (*GetVSchemaRequest) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetVSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetVSchemaRequest) GetClusterId added in v0.10.0 

func (x *GetVSchemaRequest) GetClusterId() string

func (*GetVSchemaRequest) GetKeyspace added in v0.10.0 

func (x *GetVSchemaRequest) GetKeyspace() string

func (*GetVSchemaRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetVSchemaRequest) MarshalToVT added in v0.11.0 

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

func (*GetVSchemaRequest) MarshalVT added in v0.11.0 

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

func (*GetVSchemaRequest) ProtoMessage added in v0.10.0 

func (*GetVSchemaRequest) ProtoMessage()

func (*GetVSchemaRequest) ProtoReflect added in v0.11.0 

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

func (*GetVSchemaRequest) Reset added in v0.10.0 

func (x *GetVSchemaRequest) Reset()

func (*GetVSchemaRequest) SizeVT added in v0.11.0 

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

func (*GetVSchemaRequest) String added in v0.10.0 

func (x *GetVSchemaRequest) String() string

func (*GetVSchemaRequest) UnmarshalVT added in v0.11.0 

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

type GetVSchemasRequest added in v0.10.0 

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

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

func (*GetVSchemasRequest) CloneVT added in v0.18.0 

func (m *GetVSchemasRequest) CloneVT() *GetVSchemasRequest

func (*GetVSchemasRequest) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetVSchemasRequest.ProtoReflect.Descriptor instead.

func (*GetVSchemasRequest) GetClusterIds added in v0.10.0 

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

func (*GetVSchemasRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetVSchemasRequest) MarshalToVT added in v0.11.0 

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

func (*GetVSchemasRequest) MarshalVT added in v0.11.0 

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

func (*GetVSchemasRequest) ProtoMessage added in v0.10.0 

func (*GetVSchemasRequest) ProtoMessage()

func (*GetVSchemasRequest) ProtoReflect added in v0.11.0 

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

func (*GetVSchemasRequest) Reset added in v0.10.0 

func (x *GetVSchemasRequest) Reset()

func (*GetVSchemasRequest) SizeVT added in v0.11.0 

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

func (*GetVSchemasRequest) String added in v0.10.0 

func (x *GetVSchemasRequest) String() string

func (*GetVSchemasRequest) UnmarshalVT added in v0.11.0 

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

type GetVSchemasResponse added in v0.10.0 

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

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

func (*GetVSchemasResponse) CloneVT added in v0.18.0 

func (m *GetVSchemasResponse) CloneVT() *GetVSchemasResponse

func (*GetVSchemasResponse) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetVSchemasResponse.ProtoReflect.Descriptor instead.

func (*GetVSchemasResponse) GetVSchemas added in v0.10.0 

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

func (*GetVSchemasResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetVSchemasResponse) MarshalToVT added in v0.11.0 

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

func (*GetVSchemasResponse) MarshalVT added in v0.11.0 

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

func (*GetVSchemasResponse) ProtoMessage added in v0.10.0 

func (*GetVSchemasResponse) ProtoMessage()

func (*GetVSchemasResponse) ProtoReflect added in v0.11.0 

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

func (*GetVSchemasResponse) Reset added in v0.10.0 

func (x *GetVSchemasResponse) Reset()

func (*GetVSchemasResponse) SizeVT added in v0.11.0 

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

func (*GetVSchemasResponse) String added in v0.10.0 

func (x *GetVSchemasResponse) String() string

func (*GetVSchemasResponse) UnmarshalVT added in v0.11.0 

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

type GetVtctldsRequest added in v0.12.0 

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

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

func (*GetVtctldsRequest) CloneVT added in v0.18.0 

func (m *GetVtctldsRequest) CloneVT() *GetVtctldsRequest

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

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

Deprecated: Use GetVtctldsRequest.ProtoReflect.Descriptor instead.

func (*GetVtctldsRequest) GetClusterIds added in v0.12.0 

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

func (*GetVtctldsRequest) MarshalToSizedBufferVT added in v0.12.0 

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

func (*GetVtctldsRequest) MarshalToVT added in v0.12.0 

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

func (*GetVtctldsRequest) MarshalVT added in v0.12.0 

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

func (*GetVtctldsRequest) ProtoMessage added in v0.12.0 

func (*GetVtctldsRequest) ProtoMessage()

func (*GetVtctldsRequest) ProtoReflect added in v0.12.0 

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

func (*GetVtctldsRequest) Reset added in v0.12.0 

func (x *GetVtctldsRequest) Reset()

func (*GetVtctldsRequest) SizeVT added in v0.12.0 

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

func (*GetVtctldsRequest) String added in v0.12.0 

func (x *GetVtctldsRequest) String() string

func (*GetVtctldsRequest) UnmarshalVT added in v0.12.0 

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

type GetVtctldsResponse added in v0.12.0 

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

func (*GetVtctldsResponse) CloneMessageVT added in v0.18.0 

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

func (*GetVtctldsResponse) CloneVT added in v0.18.0 

func (m *GetVtctldsResponse) CloneVT() *GetVtctldsResponse

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

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

Deprecated: Use GetVtctldsResponse.ProtoReflect.Descriptor instead.

func (*GetVtctldsResponse) GetVtctlds added in v0.12.0 

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

func (*GetVtctldsResponse) MarshalToSizedBufferVT added in v0.12.0 

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

func (*GetVtctldsResponse) MarshalToVT added in v0.12.0 

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

func (*GetVtctldsResponse) MarshalVT added in v0.12.0 

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

func (*GetVtctldsResponse) ProtoMessage added in v0.12.0 

func (*GetVtctldsResponse) ProtoMessage()

func (*GetVtctldsResponse) ProtoReflect added in v0.12.0 

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

func (*GetVtctldsResponse) Reset added in v0.12.0 

func (x *GetVtctldsResponse) Reset()

func (*GetVtctldsResponse) SizeVT added in v0.12.0 

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

func (*GetVtctldsResponse) String added in v0.12.0 

func (x *GetVtctldsResponse) String() string

func (*GetVtctldsResponse) UnmarshalVT added in v0.12.0 

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

type GetWorkflowRequest added in v0.10.0 

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

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

func (*GetWorkflowRequest) CloneVT added in v0.18.0 

func (m *GetWorkflowRequest) CloneVT() *GetWorkflowRequest

func (*GetWorkflowRequest) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetWorkflowRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowRequest) GetActiveOnly added in v0.10.0 

func (x *GetWorkflowRequest) GetActiveOnly() bool

func (*GetWorkflowRequest) GetClusterId added in v0.10.0 

func (x *GetWorkflowRequest) GetClusterId() string

func (*GetWorkflowRequest) GetKeyspace added in v0.10.0 

func (x *GetWorkflowRequest) GetKeyspace() string

func (*GetWorkflowRequest) GetName added in v0.10.0 

func (x *GetWorkflowRequest) GetName() string

func (*GetWorkflowRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetWorkflowRequest) MarshalToVT added in v0.11.0 

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

func (*GetWorkflowRequest) MarshalVT added in v0.11.0 

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

func (*GetWorkflowRequest) ProtoMessage added in v0.10.0 

func (*GetWorkflowRequest) ProtoMessage()

func (*GetWorkflowRequest) ProtoReflect added in v0.11.0 

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

func (*GetWorkflowRequest) Reset added in v0.10.0 

func (x *GetWorkflowRequest) Reset()

func (*GetWorkflowRequest) SizeVT added in v0.11.0 

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

func (*GetWorkflowRequest) String added in v0.10.0 

func (x *GetWorkflowRequest) String() string

func (*GetWorkflowRequest) UnmarshalVT added in v0.11.0 

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

type GetWorkflowsRequest added in v0.10.0 

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

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

func (*GetWorkflowsRequest) CloneVT added in v0.18.0 

func (m *GetWorkflowsRequest) CloneVT() *GetWorkflowsRequest

func (*GetWorkflowsRequest) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetWorkflowsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowsRequest) GetActiveOnly added in v0.10.0 

func (x *GetWorkflowsRequest) GetActiveOnly() bool

func (*GetWorkflowsRequest) GetClusterIds added in v0.10.0 

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

func (*GetWorkflowsRequest) GetIgnoreKeyspaces added in v0.10.0 

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

func (*GetWorkflowsRequest) GetKeyspaces added in v0.10.0 

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

func (*GetWorkflowsRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetWorkflowsRequest) MarshalToVT added in v0.11.0 

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

func (*GetWorkflowsRequest) MarshalVT added in v0.11.0 

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

func (*GetWorkflowsRequest) ProtoMessage added in v0.10.0 

func (*GetWorkflowsRequest) ProtoMessage()

func (*GetWorkflowsRequest) ProtoReflect added in v0.11.0 

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

func (*GetWorkflowsRequest) Reset added in v0.10.0 

func (x *GetWorkflowsRequest) Reset()

func (*GetWorkflowsRequest) SizeVT added in v0.11.0 

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

func (*GetWorkflowsRequest) String added in v0.10.0 

func (x *GetWorkflowsRequest) String() string

func (*GetWorkflowsRequest) UnmarshalVT added in v0.11.0 

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

type GetWorkflowsResponse added in v0.10.0 

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

func (*GetWorkflowsResponse) CloneMessageVT added in v0.18.0 

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

func (*GetWorkflowsResponse) CloneVT added in v0.18.0 

func (m *GetWorkflowsResponse) CloneVT() *GetWorkflowsResponse

func (*GetWorkflowsResponse) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowsResponse) GetWorkflowsByCluster added in v0.10.0 

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

func (*GetWorkflowsResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetWorkflowsResponse) MarshalToVT added in v0.11.0 

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

func (*GetWorkflowsResponse) MarshalVT added in v0.11.0 

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

func (*GetWorkflowsResponse) ProtoMessage added in v0.10.0 

func (*GetWorkflowsResponse) ProtoMessage()

func (*GetWorkflowsResponse) ProtoReflect added in v0.11.0 

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

func (*GetWorkflowsResponse) Reset added in v0.10.0 

func (x *GetWorkflowsResponse) Reset()

func (*GetWorkflowsResponse) SizeVT added in v0.11.0 

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

func (*GetWorkflowsResponse) String added in v0.10.0 

func (x *GetWorkflowsResponse) String() string

func (*GetWorkflowsResponse) UnmarshalVT added in v0.11.0 

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

type Keyspace added in v0.10.0 

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

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

func (*Keyspace) CloneVT added in v0.18.0 

func (m *Keyspace) CloneVT() *Keyspace

func (*Keyspace) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use Keyspace.ProtoReflect.Descriptor instead.

func (*Keyspace) GetCluster added in v0.10.0 

func (x *Keyspace) GetCluster() *Cluster

func (*Keyspace) GetKeyspace added in v0.10.0 

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

func (*Keyspace) GetShards added in v0.10.0 

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

func (*Keyspace) MarshalToSizedBufferVT added in v0.11.0 

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

func (*Keyspace) MarshalToVT added in v0.11.0 

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

func (*Keyspace) MarshalVT added in v0.11.0 

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

func (*Keyspace) ProtoMessage added in v0.10.0 

func (*Keyspace) ProtoMessage()

func (*Keyspace) ProtoReflect added in v0.11.0 

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

func (*Keyspace) Reset added in v0.10.0 

func (x *Keyspace) Reset()

func (*Keyspace) SizeVT added in v0.11.0 

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

func (*Keyspace) String added in v0.10.0 

func (x *Keyspace) String() string

func (*Keyspace) UnmarshalVT added in v0.11.0 

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

type PingTabletRequest added in v0.13.0 

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

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

func (*PingTabletRequest) CloneVT added in v0.18.0 

func (m *PingTabletRequest) CloneVT() *PingTabletRequest

func (*PingTabletRequest) Descriptor deprecated added in v0.13.0 

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

Deprecated: Use PingTabletRequest.ProtoReflect.Descriptor instead.

func (*PingTabletRequest) GetAlias added in v0.13.0 

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

func (*PingTabletRequest) GetClusterIds added in v0.13.0 

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

func (*PingTabletRequest) MarshalToSizedBufferVT added in v0.13.0 

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

func (*PingTabletRequest) MarshalToVT added in v0.13.0 

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

func (*PingTabletRequest) MarshalVT added in v0.13.0 

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

func (*PingTabletRequest) ProtoMessage added in v0.13.0 

func (*PingTabletRequest) ProtoMessage()

func (*PingTabletRequest) ProtoReflect added in v0.13.0 

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

func (*PingTabletRequest) Reset added in v0.13.0 

func (x *PingTabletRequest) Reset()

func (*PingTabletRequest) SizeVT added in v0.13.0 

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

func (*PingTabletRequest) String added in v0.13.0 

func (x *PingTabletRequest) String() string

func (*PingTabletRequest) UnmarshalVT added in v0.13.0 

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

type PingTabletResponse added in v0.13.0 

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

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

func (*PingTabletResponse) CloneVT added in v0.18.0 

func (m *PingTabletResponse) CloneVT() *PingTabletResponse

func (*PingTabletResponse) Descriptor deprecated added in v0.13.0 

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

Deprecated: Use PingTabletResponse.ProtoReflect.Descriptor instead.

func (*PingTabletResponse) GetCluster added in v0.14.0 

func (x *PingTabletResponse) GetCluster() *Cluster

func (*PingTabletResponse) GetStatus added in v0.13.0 

func (x *PingTabletResponse) GetStatus() string

func (*PingTabletResponse) MarshalToSizedBufferVT added in v0.13.0 

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

func (*PingTabletResponse) MarshalToVT added in v0.13.0 

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

func (*PingTabletResponse) MarshalVT added in v0.13.0 

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

func (*PingTabletResponse) ProtoMessage added in v0.13.0 

func (*PingTabletResponse) ProtoMessage()

func (*PingTabletResponse) ProtoReflect added in v0.13.0 

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

func (*PingTabletResponse) Reset added in v0.13.0 

func (x *PingTabletResponse) Reset()

func (*PingTabletResponse) SizeVT added in v0.13.0 

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

func (*PingTabletResponse) String added in v0.13.0 

func (x *PingTabletResponse) String() string

func (*PingTabletResponse) UnmarshalVT added in v0.13.0 

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

type PlannedFailoverShardRequest added in v0.14.0 

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

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

func (*PlannedFailoverShardRequest) CloneVT added in v0.18.0 

func (m *PlannedFailoverShardRequest) CloneVT() *PlannedFailoverShardRequest

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

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

Deprecated: Use PlannedFailoverShardRequest.ProtoReflect.Descriptor instead.

func (*PlannedFailoverShardRequest) GetClusterId added in v0.14.0 

func (x *PlannedFailoverShardRequest) GetClusterId() string

func (*PlannedFailoverShardRequest) GetOptions added in v0.14.0 

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

func (*PlannedFailoverShardRequest) MarshalToSizedBufferVT added in v0.14.0 

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

func (*PlannedFailoverShardRequest) MarshalToVT added in v0.14.0 

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

func (*PlannedFailoverShardRequest) MarshalVT added in v0.14.0 

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

func (*PlannedFailoverShardRequest) ProtoMessage added in v0.14.0 

func (*PlannedFailoverShardRequest) ProtoMessage()

func (*PlannedFailoverShardRequest) ProtoReflect added in v0.14.0 

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

func (*PlannedFailoverShardRequest) Reset added in v0.14.0 

func (x *PlannedFailoverShardRequest) Reset()

func (*PlannedFailoverShardRequest) SizeVT added in v0.14.0 

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

func (*PlannedFailoverShardRequest) String added in v0.14.0 

func (x *PlannedFailoverShardRequest) String() string

func (*PlannedFailoverShardRequest) UnmarshalVT added in v0.14.0 

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

type PlannedFailoverShardResponse added in v0.14.0 

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

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

func (*PlannedFailoverShardResponse) CloneVT added in v0.18.0 

func (m *PlannedFailoverShardResponse) CloneVT() *PlannedFailoverShardResponse

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

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

Deprecated: Use PlannedFailoverShardResponse.ProtoReflect.Descriptor instead.

func (*PlannedFailoverShardResponse) GetCluster added in v0.14.0 

func (x *PlannedFailoverShardResponse) GetCluster() *Cluster

func (*PlannedFailoverShardResponse) GetEvents added in v0.14.0 

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

func (*PlannedFailoverShardResponse) GetKeyspace added in v0.14.0 

func (x *PlannedFailoverShardResponse) GetKeyspace() string

func (*PlannedFailoverShardResponse) GetPromotedPrimary added in v0.14.0 

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

func (*PlannedFailoverShardResponse) GetShard added in v0.14.0 

func (x *PlannedFailoverShardResponse) GetShard() string

func (*PlannedFailoverShardResponse) MarshalToSizedBufferVT added in v0.14.0 

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

func (*PlannedFailoverShardResponse) MarshalToVT added in v0.14.0 

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

func (*PlannedFailoverShardResponse) MarshalVT added in v0.14.0 

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

func (*PlannedFailoverShardResponse) ProtoMessage added in v0.14.0 

func (*PlannedFailoverShardResponse) ProtoMessage()

func (*PlannedFailoverShardResponse) ProtoReflect added in v0.14.0 

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

func (*PlannedFailoverShardResponse) Reset added in v0.14.0 

func (x *PlannedFailoverShardResponse) Reset()

func (*PlannedFailoverShardResponse) SizeVT added in v0.14.0 

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

func (*PlannedFailoverShardResponse) String added in v0.14.0 

func (x *PlannedFailoverShardResponse) String() string

func (*PlannedFailoverShardResponse) UnmarshalVT added in v0.14.0 

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

type RebuildKeyspaceGraphRequest added in v0.15.0 

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

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

func (*RebuildKeyspaceGraphRequest) CloneVT added in v0.18.0 

func (m *RebuildKeyspaceGraphRequest) CloneVT() *RebuildKeyspaceGraphRequest

func (*RebuildKeyspaceGraphRequest) Descriptor deprecated added in v0.15.0 

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

Deprecated: Use RebuildKeyspaceGraphRequest.ProtoReflect.Descriptor instead.

func (*RebuildKeyspaceGraphRequest) GetAllowPartial added in v0.15.0 

func (x *RebuildKeyspaceGraphRequest) GetAllowPartial() bool

func (*RebuildKeyspaceGraphRequest) GetCells added in v0.15.0 

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

func (*RebuildKeyspaceGraphRequest) GetClusterId added in v0.15.0 

func (x *RebuildKeyspaceGraphRequest) GetClusterId() string

func (*RebuildKeyspaceGraphRequest) GetKeyspace added in v0.15.0 

func (x *RebuildKeyspaceGraphRequest) GetKeyspace() string

func (*RebuildKeyspaceGraphRequest) MarshalToSizedBufferVT added in v0.15.0 

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

func (*RebuildKeyspaceGraphRequest) MarshalToVT added in v0.15.0 

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

func (*RebuildKeyspaceGraphRequest) MarshalVT added in v0.15.0 

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

func (*RebuildKeyspaceGraphRequest) ProtoMessage added in v0.15.0 

func (*RebuildKeyspaceGraphRequest) ProtoMessage()

func (*RebuildKeyspaceGraphRequest) ProtoReflect added in v0.15.0 

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

func (*RebuildKeyspaceGraphRequest) Reset added in v0.15.0 

func (x *RebuildKeyspaceGraphRequest) Reset()

func (*RebuildKeyspaceGraphRequest) SizeVT added in v0.15.0 

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

func (*RebuildKeyspaceGraphRequest) String added in v0.15.0 

func (x *RebuildKeyspaceGraphRequest) String() string

func (*RebuildKeyspaceGraphRequest) UnmarshalVT added in v0.15.0 

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

type RebuildKeyspaceGraphResponse added in v0.15.0 

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

func (*RebuildKeyspaceGraphResponse) CloneMessageVT added in v0.18.0 

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

func (*RebuildKeyspaceGraphResponse) CloneVT added in v0.18.0 

func (m *RebuildKeyspaceGraphResponse) CloneVT() *RebuildKeyspaceGraphResponse

func (*RebuildKeyspaceGraphResponse) Descriptor deprecated added in v0.15.0 

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

Deprecated: Use RebuildKeyspaceGraphResponse.ProtoReflect.Descriptor instead.

func (*RebuildKeyspaceGraphResponse) GetStatus added in v0.15.0 

func (x *RebuildKeyspaceGraphResponse) GetStatus() string

func (*RebuildKeyspaceGraphResponse) MarshalToSizedBufferVT added in v0.15.0 

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

func (*RebuildKeyspaceGraphResponse) MarshalToVT added in v0.15.0 

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

func (*RebuildKeyspaceGraphResponse) MarshalVT added in v0.15.0 

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

func (*RebuildKeyspaceGraphResponse) ProtoMessage added in v0.15.0 

func (*RebuildKeyspaceGraphResponse) ProtoMessage()

func (*RebuildKeyspaceGraphResponse) ProtoReflect added in v0.15.0 

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

func (*RebuildKeyspaceGraphResponse) Reset added in v0.15.0 

func (x *RebuildKeyspaceGraphResponse) Reset()

func (*RebuildKeyspaceGraphResponse) SizeVT added in v0.15.0 

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

func (*RebuildKeyspaceGraphResponse) String added in v0.15.0 

func (x *RebuildKeyspaceGraphResponse) String() string

func (*RebuildKeyspaceGraphResponse) UnmarshalVT added in v0.15.0 

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

type RefreshStateRequest added in v0.13.0 

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

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

func (*RefreshStateRequest) CloneVT added in v0.18.0 

func (m *RefreshStateRequest) CloneVT() *RefreshStateRequest

func (*RefreshStateRequest) Descriptor deprecated added in v0.13.0 

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

Deprecated: Use RefreshStateRequest.ProtoReflect.Descriptor instead.

func (*RefreshStateRequest) GetAlias added in v0.13.0 

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

func (*RefreshStateRequest) GetClusterIds added in v0.13.0 

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

func (*RefreshStateRequest) MarshalToSizedBufferVT added in v0.13.0 

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

func (*RefreshStateRequest) MarshalToVT added in v0.13.0 

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

func (*RefreshStateRequest) MarshalVT added in v0.13.0 

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

func (*RefreshStateRequest) ProtoMessage added in v0.13.0 

func (*RefreshStateRequest) ProtoMessage()

func (*RefreshStateRequest) ProtoReflect added in v0.13.0 

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

func (*RefreshStateRequest) Reset added in v0.13.0 

func (x *RefreshStateRequest) Reset()

func (*RefreshStateRequest) SizeVT added in v0.13.0 

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

func (*RefreshStateRequest) String added in v0.13.0 

func (x *RefreshStateRequest) String() string

func (*RefreshStateRequest) UnmarshalVT added in v0.13.0 

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

type RefreshStateResponse added in v0.13.0 

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

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

func (*RefreshStateResponse) CloneVT added in v0.18.0 

func (m *RefreshStateResponse) CloneVT() *RefreshStateResponse

func (*RefreshStateResponse) Descriptor deprecated added in v0.13.0 

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

Deprecated: Use RefreshStateResponse.ProtoReflect.Descriptor instead.

func (*RefreshStateResponse) GetCluster added in v0.14.0 

func (x *RefreshStateResponse) GetCluster() *Cluster

func (*RefreshStateResponse) GetStatus added in v0.13.0 

func (x *RefreshStateResponse) GetStatus() string

func (*RefreshStateResponse) MarshalToSizedBufferVT added in v0.13.0 

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

func (*RefreshStateResponse) MarshalToVT added in v0.13.0 

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

func (*RefreshStateResponse) MarshalVT added in v0.13.0 

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

func (*RefreshStateResponse) ProtoMessage added in v0.13.0 

func (*RefreshStateResponse) ProtoMessage()

func (*RefreshStateResponse) ProtoReflect added in v0.13.0 

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

func (*RefreshStateResponse) Reset added in v0.13.0 

func (x *RefreshStateResponse) Reset()

func (*RefreshStateResponse) SizeVT added in v0.13.0 

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

func (*RefreshStateResponse) String added in v0.13.0 

func (x *RefreshStateResponse) String() string

func (*RefreshStateResponse) UnmarshalVT added in v0.13.0 

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

type RefreshTabletReplicationSourceRequest added in v0.14.0 

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

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

func (*RefreshTabletReplicationSourceRequest) CloneVT added in v0.18.0 

func (m *RefreshTabletReplicationSourceRequest) CloneVT() *RefreshTabletReplicationSourceRequest

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

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

Deprecated: Use RefreshTabletReplicationSourceRequest.ProtoReflect.Descriptor instead.

func (*RefreshTabletReplicationSourceRequest) GetAlias added in v0.14.0 

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

func (*RefreshTabletReplicationSourceRequest) GetClusterIds added in v0.14.0 

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

func (*RefreshTabletReplicationSourceRequest) MarshalToSizedBufferVT added in v0.14.0 

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

func (*RefreshTabletReplicationSourceRequest) MarshalToVT added in v0.14.0 

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

func (*RefreshTabletReplicationSourceRequest) MarshalVT added in v0.14.0 

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

func (*RefreshTabletReplicationSourceRequest) ProtoMessage added in v0.14.0 

func (*RefreshTabletReplicationSourceRequest) ProtoMessage()

func (*RefreshTabletReplicationSourceRequest) ProtoReflect added in v0.14.0 

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

func (*RefreshTabletReplicationSourceRequest) Reset added in v0.14.0 

func (x *RefreshTabletReplicationSourceRequest) Reset()

func (*RefreshTabletReplicationSourceRequest) SizeVT added in v0.14.0 

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

func (*RefreshTabletReplicationSourceRequest) String added in v0.14.0 

func (x *RefreshTabletReplicationSourceRequest) String() string

func (*RefreshTabletReplicationSourceRequest) UnmarshalVT added in v0.14.0 

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

type RefreshTabletReplicationSourceResponse added in v0.14.0 

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

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

func (*RefreshTabletReplicationSourceResponse) CloneVT added in v0.18.0 

func (m *RefreshTabletReplicationSourceResponse) CloneVT() *RefreshTabletReplicationSourceResponse

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

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

Deprecated: Use RefreshTabletReplicationSourceResponse.ProtoReflect.Descriptor instead.

func (*RefreshTabletReplicationSourceResponse) GetCluster added in v0.14.0 

func (x *RefreshTabletReplicationSourceResponse) GetCluster() *Cluster

func (*RefreshTabletReplicationSourceResponse) GetKeyspace added in v0.14.0 

func (x *RefreshTabletReplicationSourceResponse) GetKeyspace() string

func (*RefreshTabletReplicationSourceResponse) GetPrimary added in v0.14.0 

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

func (*RefreshTabletReplicationSourceResponse) GetShard added in v0.14.0 

func (x *RefreshTabletReplicationSourceResponse) GetShard() string

func (*RefreshTabletReplicationSourceResponse) MarshalToSizedBufferVT added in v0.14.0 

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

func (*RefreshTabletReplicationSourceResponse) MarshalToVT added in v0.14.0 

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

func (*RefreshTabletReplicationSourceResponse) MarshalVT added in v0.14.0 

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

func (*RefreshTabletReplicationSourceResponse) ProtoMessage added in v0.14.0 

func (*RefreshTabletReplicationSourceResponse) ProtoMessage()

func (*RefreshTabletReplicationSourceResponse) ProtoReflect added in v0.14.0 

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

func (*RefreshTabletReplicationSourceResponse) Reset added in v0.14.0 

func (x *RefreshTabletReplicationSourceResponse) Reset()

func (*RefreshTabletReplicationSourceResponse) SizeVT added in v0.14.0 

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

func (*RefreshTabletReplicationSourceResponse) String added in v0.14.0 

func (x *RefreshTabletReplicationSourceResponse) String() string

func (*RefreshTabletReplicationSourceResponse) UnmarshalVT added in v0.14.0 

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

type ReloadSchemaShardRequest added in v0.15.0 

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    uint32 `protobuf:"varint,6,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	// contains filtered or unexported fields
}

func (*ReloadSchemaShardRequest) CloneMessageVT added in v0.18.0 

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

func (*ReloadSchemaShardRequest) CloneVT added in v0.18.0 

func (m *ReloadSchemaShardRequest) CloneVT() *ReloadSchemaShardRequest

func (*ReloadSchemaShardRequest) Descriptor deprecated added in v0.15.0 

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

Deprecated: Use ReloadSchemaShardRequest.ProtoReflect.Descriptor instead.

func (*ReloadSchemaShardRequest) GetClusterId added in v0.15.0 

func (x *ReloadSchemaShardRequest) GetClusterId() string

func (*ReloadSchemaShardRequest) GetConcurrency added in v0.15.0 

func (x *ReloadSchemaShardRequest) GetConcurrency() uint32

func (*ReloadSchemaShardRequest) GetIncludePrimary added in v0.15.0 

func (x *ReloadSchemaShardRequest) GetIncludePrimary() bool

func (*ReloadSchemaShardRequest) GetKeyspace added in v0.15.0 

func (x *ReloadSchemaShardRequest) GetKeyspace() string

func (*ReloadSchemaShardRequest) GetShard added in v0.15.0 

func (x *ReloadSchemaShardRequest) GetShard() string

func (*ReloadSchemaShardRequest) GetWaitPosition added in v0.15.0 

func (x *ReloadSchemaShardRequest) GetWaitPosition() string

func (*ReloadSchemaShardRequest) MarshalToSizedBufferVT added in v0.15.0 

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

func (*ReloadSchemaShardRequest) MarshalToVT added in v0.15.0 

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

func (*ReloadSchemaShardRequest) MarshalVT added in v0.15.0 

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

func (*ReloadSchemaShardRequest) ProtoMessage added in v0.15.0 

func (*ReloadSchemaShardRequest) ProtoMessage()

func (*ReloadSchemaShardRequest) ProtoReflect added in v0.15.0 

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

func (*ReloadSchemaShardRequest) Reset added in v0.15.0 

func (x *ReloadSchemaShardRequest) Reset()

func (*ReloadSchemaShardRequest) SizeVT added in v0.15.0 

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

func (*ReloadSchemaShardRequest) String added in v0.15.0 

func (x *ReloadSchemaShardRequest) String() string

func (*ReloadSchemaShardRequest) UnmarshalVT added in v0.15.0 

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

type ReloadSchemaShardResponse added in v0.15.0 

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

func (*ReloadSchemaShardResponse) CloneMessageVT added in v0.18.0 

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

func (*ReloadSchemaShardResponse) CloneVT added in v0.18.0 

func (m *ReloadSchemaShardResponse) CloneVT() *ReloadSchemaShardResponse

func (*ReloadSchemaShardResponse) Descriptor deprecated added in v0.15.0 

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

Deprecated: Use ReloadSchemaShardResponse.ProtoReflect.Descriptor instead.

func (*ReloadSchemaShardResponse) GetEvents added in v0.15.0 

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

func (*ReloadSchemaShardResponse) MarshalToSizedBufferVT added in v0.15.0 

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

func (*ReloadSchemaShardResponse) MarshalToVT added in v0.15.0 

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

func (*ReloadSchemaShardResponse) MarshalVT added in v0.15.0 

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

func (*ReloadSchemaShardResponse) ProtoMessage added in v0.15.0 

func (*ReloadSchemaShardResponse) ProtoMessage()

func (*ReloadSchemaShardResponse) ProtoReflect added in v0.15.0 

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

func (*ReloadSchemaShardResponse) Reset added in v0.15.0 

func (x *ReloadSchemaShardResponse) Reset()

func (*ReloadSchemaShardResponse) SizeVT added in v0.15.0 

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

func (*ReloadSchemaShardResponse) String added in v0.15.0 

func (x *ReloadSchemaShardResponse) String() string

func (*ReloadSchemaShardResponse) UnmarshalVT added in v0.15.0 

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

type ReloadSchemasRequest added in v0.14.0 

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

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

func (*ReloadSchemasRequest) CloneVT added in v0.18.0 

func (m *ReloadSchemasRequest) CloneVT() *ReloadSchemasRequest

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

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

Deprecated: Use ReloadSchemasRequest.ProtoReflect.Descriptor instead.

func (*ReloadSchemasRequest) GetClusterIds added in v0.14.0 

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

func (*ReloadSchemasRequest) GetConcurrency added in v0.14.0 

func (x *ReloadSchemasRequest) GetConcurrency() uint32

func (*ReloadSchemasRequest) GetIncludePrimary added in v0.14.0 

func (x *ReloadSchemasRequest) GetIncludePrimary() bool

func (*ReloadSchemasRequest) GetKeyspaceShards added in v0.14.0 

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

func (*ReloadSchemasRequest) GetKeyspaces added in v0.14.0 

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

func (*ReloadSchemasRequest) GetTablets added in v0.14.0 

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

func (*ReloadSchemasRequest) GetWaitPosition added in v0.14.0 

func (x *ReloadSchemasRequest) GetWaitPosition() string

func (*ReloadSchemasRequest) MarshalToSizedBufferVT added in v0.14.0 

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

func (*ReloadSchemasRequest) MarshalToVT added in v0.14.0 

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

func (*ReloadSchemasRequest) MarshalVT added in v0.14.0 

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

func (*ReloadSchemasRequest) ProtoMessage added in v0.14.0 

func (*ReloadSchemasRequest) ProtoMessage()

func (*ReloadSchemasRequest) ProtoReflect added in v0.14.0 

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

func (*ReloadSchemasRequest) Reset added in v0.14.0 

func (x *ReloadSchemasRequest) Reset()

func (*ReloadSchemasRequest) SizeVT added in v0.14.0 

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

func (*ReloadSchemasRequest) String added in v0.14.0 

func (x *ReloadSchemasRequest) String() string

func (*ReloadSchemasRequest) UnmarshalVT added in v0.14.0 

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

type ReloadSchemasResponse added in v0.14.0 

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

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

func (*ReloadSchemasResponse) CloneVT added in v0.18.0 

func (m *ReloadSchemasResponse) CloneVT() *ReloadSchemasResponse

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

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

Deprecated: Use ReloadSchemasResponse.ProtoReflect.Descriptor instead.

func (*ReloadSchemasResponse) GetKeyspaceResults added in v0.14.0 

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

func (*ReloadSchemasResponse) GetShardResults added in v0.14.0 

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

func (*ReloadSchemasResponse) GetTabletResults added in v0.14.0 

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

func (*ReloadSchemasResponse) MarshalToSizedBufferVT added in v0.14.0 

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

func (*ReloadSchemasResponse) MarshalToVT added in v0.14.0 

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

func (*ReloadSchemasResponse) MarshalVT added in v0.14.0 

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

func (*ReloadSchemasResponse) ProtoMessage added in v0.14.0 

func (*ReloadSchemasResponse) ProtoMessage()

func (*ReloadSchemasResponse) ProtoReflect added in v0.14.0 

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

func (*ReloadSchemasResponse) Reset added in v0.14.0 

func (x *ReloadSchemasResponse) Reset()

func (*ReloadSchemasResponse) SizeVT added in v0.14.0 

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

func (*ReloadSchemasResponse) String added in v0.14.0 

func (x *ReloadSchemasResponse) String() string

func (*ReloadSchemasResponse) UnmarshalVT added in v0.14.0 

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

type ReloadSchemasResponse_KeyspaceResult added in v0.14.0 

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

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

func (*ReloadSchemasResponse_KeyspaceResult) CloneVT added in v0.18.0 

func (m *ReloadSchemasResponse_KeyspaceResult) CloneVT() *ReloadSchemasResponse_KeyspaceResult

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

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

Deprecated: Use ReloadSchemasResponse_KeyspaceResult.ProtoReflect.Descriptor instead.

func (*ReloadSchemasResponse_KeyspaceResult) GetEvents added in v0.14.0 

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

func (*ReloadSchemasResponse_KeyspaceResult) GetKeyspace added in v0.14.0 

func (x *ReloadSchemasResponse_KeyspaceResult) GetKeyspace() *Keyspace

func (*ReloadSchemasResponse_KeyspaceResult) MarshalToSizedBufferVT added in v0.14.0 

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

func (*ReloadSchemasResponse_KeyspaceResult) MarshalToVT added in v0.14.0 

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

func (*ReloadSchemasResponse_KeyspaceResult) MarshalVT added in v0.14.0 

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

func (*ReloadSchemasResponse_KeyspaceResult) ProtoMessage added in v0.14.0 

func (*ReloadSchemasResponse_KeyspaceResult) ProtoMessage()

func (*ReloadSchemasResponse_KeyspaceResult) ProtoReflect added in v0.14.0 

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

func (*ReloadSchemasResponse_KeyspaceResult) Reset added in v0.14.0 

func (x *ReloadSchemasResponse_KeyspaceResult) Reset()

func (*ReloadSchemasResponse_KeyspaceResult) SizeVT added in v0.14.0 

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

func (*ReloadSchemasResponse_KeyspaceResult) String added in v0.14.0 

func (x *ReloadSchemasResponse_KeyspaceResult) String() string

func (*ReloadSchemasResponse_KeyspaceResult) UnmarshalVT added in v0.14.0 

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

type ReloadSchemasResponse_ShardResult added in v0.14.0 

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

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

func (*ReloadSchemasResponse_ShardResult) CloneVT added in v0.18.0 

func (m *ReloadSchemasResponse_ShardResult) CloneVT() *ReloadSchemasResponse_ShardResult

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

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

Deprecated: Use ReloadSchemasResponse_ShardResult.ProtoReflect.Descriptor instead.

func (*ReloadSchemasResponse_ShardResult) GetEvents added in v0.14.0 

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

func (*ReloadSchemasResponse_ShardResult) GetShard added in v0.14.0 

func (x *ReloadSchemasResponse_ShardResult) GetShard() *Shard

func (*ReloadSchemasResponse_ShardResult) MarshalToSizedBufferVT added in v0.14.0 

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

func (*ReloadSchemasResponse_ShardResult) MarshalToVT added in v0.14.0 

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

func (*ReloadSchemasResponse_ShardResult) MarshalVT added in v0.14.0 

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

func (*ReloadSchemasResponse_ShardResult) ProtoMessage added in v0.14.0 

func (*ReloadSchemasResponse_ShardResult) ProtoMessage()

func (*ReloadSchemasResponse_ShardResult) ProtoReflect added in v0.14.0 

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

func (*ReloadSchemasResponse_ShardResult) Reset added in v0.14.0 

func (x *ReloadSchemasResponse_ShardResult) Reset()

func (*ReloadSchemasResponse_ShardResult) SizeVT added in v0.14.0 

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

func (*ReloadSchemasResponse_ShardResult) String added in v0.14.0 

func (x *ReloadSchemasResponse_ShardResult) String() string

func (*ReloadSchemasResponse_ShardResult) UnmarshalVT added in v0.14.0 

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

type ReloadSchemasResponse_TabletResult added in v0.14.0 

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

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

func (*ReloadSchemasResponse_TabletResult) CloneVT added in v0.18.0 

func (m *ReloadSchemasResponse_TabletResult) CloneVT() *ReloadSchemasResponse_TabletResult

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

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

Deprecated: Use ReloadSchemasResponse_TabletResult.ProtoReflect.Descriptor instead.

func (*ReloadSchemasResponse_TabletResult) GetResult added in v0.14.0 

func (x *ReloadSchemasResponse_TabletResult) GetResult() string

func (*ReloadSchemasResponse_TabletResult) GetTablet added in v0.14.0 

func (x *ReloadSchemasResponse_TabletResult) GetTablet() *Tablet

func (*ReloadSchemasResponse_TabletResult) MarshalToSizedBufferVT added in v0.14.0 

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

func (*ReloadSchemasResponse_TabletResult) MarshalToVT added in v0.14.0 

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

func (*ReloadSchemasResponse_TabletResult) MarshalVT added in v0.14.0 

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

func (*ReloadSchemasResponse_TabletResult) ProtoMessage added in v0.14.0 

func (*ReloadSchemasResponse_TabletResult) ProtoMessage()

func (*ReloadSchemasResponse_TabletResult) ProtoReflect added in v0.14.0 

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

func (*ReloadSchemasResponse_TabletResult) Reset added in v0.14.0 

func (x *ReloadSchemasResponse_TabletResult) Reset()

func (*ReloadSchemasResponse_TabletResult) SizeVT added in v0.14.0 

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

func (*ReloadSchemasResponse_TabletResult) String added in v0.14.0 

func (x *ReloadSchemasResponse_TabletResult) String() string

func (*ReloadSchemasResponse_TabletResult) UnmarshalVT added in v0.14.0 

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

type RemoveKeyspaceCellRequest added in v0.15.0 

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

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

func (*RemoveKeyspaceCellRequest) CloneVT added in v0.18.0 

func (m *RemoveKeyspaceCellRequest) CloneVT() *RemoveKeyspaceCellRequest

func (*RemoveKeyspaceCellRequest) Descriptor deprecated added in v0.15.0 

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

Deprecated: Use RemoveKeyspaceCellRequest.ProtoReflect.Descriptor instead.

func (*RemoveKeyspaceCellRequest) GetCell added in v0.15.0 

func (x *RemoveKeyspaceCellRequest) GetCell() string

func (*RemoveKeyspaceCellRequest) GetClusterId added in v0.15.0 

func (x *RemoveKeyspaceCellRequest) GetClusterId() string

func (*RemoveKeyspaceCellRequest) GetForce added in v0.15.0 

func (x *RemoveKeyspaceCellRequest) GetForce() bool

func (*RemoveKeyspaceCellRequest) GetKeyspace added in v0.15.0 

func (x *RemoveKeyspaceCellRequest) GetKeyspace() string

func (*RemoveKeyspaceCellRequest) GetRecursive added in v0.15.0 

func (x *RemoveKeyspaceCellRequest) GetRecursive() bool

func (*RemoveKeyspaceCellRequest) MarshalToSizedBufferVT added in v0.15.0 

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

func (*RemoveKeyspaceCellRequest) MarshalToVT added in v0.15.0 

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

func (*RemoveKeyspaceCellRequest) MarshalVT added in v0.15.0 

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

func (*RemoveKeyspaceCellRequest) ProtoMessage added in v0.15.0 

func (*RemoveKeyspaceCellRequest) ProtoMessage()

func (*RemoveKeyspaceCellRequest) ProtoReflect added in v0.15.0 

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

func (*RemoveKeyspaceCellRequest) Reset added in v0.15.0 

func (x *RemoveKeyspaceCellRequest) Reset()

func (*RemoveKeyspaceCellRequest) SizeVT added in v0.15.0 

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

func (*RemoveKeyspaceCellRequest) String added in v0.15.0 

func (x *RemoveKeyspaceCellRequest) String() string

func (*RemoveKeyspaceCellRequest) UnmarshalVT added in v0.15.0 

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

type RemoveKeyspaceCellResponse added in v0.15.0 

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

func (*RemoveKeyspaceCellResponse) CloneMessageVT added in v0.18.0 

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

func (*RemoveKeyspaceCellResponse) CloneVT added in v0.18.0 

func (m *RemoveKeyspaceCellResponse) CloneVT() *RemoveKeyspaceCellResponse

func (*RemoveKeyspaceCellResponse) Descriptor deprecated added in v0.15.0 

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

Deprecated: Use RemoveKeyspaceCellResponse.ProtoReflect.Descriptor instead.

func (*RemoveKeyspaceCellResponse) GetStatus added in v0.15.0 

func (x *RemoveKeyspaceCellResponse) GetStatus() string

func (*RemoveKeyspaceCellResponse) MarshalToSizedBufferVT added in v0.15.0 

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

func (*RemoveKeyspaceCellResponse) MarshalToVT added in v0.15.0 

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

func (*RemoveKeyspaceCellResponse) MarshalVT added in v0.15.0 

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

func (*RemoveKeyspaceCellResponse) ProtoMessage added in v0.15.0 

func (*RemoveKeyspaceCellResponse) ProtoMessage()

func (*RemoveKeyspaceCellResponse) ProtoReflect added in v0.15.0 

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

func (*RemoveKeyspaceCellResponse) Reset added in v0.15.0 

func (x *RemoveKeyspaceCellResponse) Reset()

func (*RemoveKeyspaceCellResponse) SizeVT added in v0.15.0 

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

func (*RemoveKeyspaceCellResponse) String added in v0.15.0 

func (x *RemoveKeyspaceCellResponse) String() string

func (*RemoveKeyspaceCellResponse) UnmarshalVT added in v0.15.0 

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

type RunHealthCheckRequest added in v0.13.0 

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

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

func (*RunHealthCheckRequest) CloneVT added in v0.18.0 

func (m *RunHealthCheckRequest) CloneVT() *RunHealthCheckRequest

func (*RunHealthCheckRequest) Descriptor deprecated added in v0.13.0 

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

Deprecated: Use RunHealthCheckRequest.ProtoReflect.Descriptor instead.

func (*RunHealthCheckRequest) GetAlias added in v0.13.0 

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

func (*RunHealthCheckRequest) GetClusterIds added in v0.13.0 

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

func (*RunHealthCheckRequest) MarshalToSizedBufferVT added in v0.13.0 

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

func (*RunHealthCheckRequest) MarshalToVT added in v0.13.0 

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

func (*RunHealthCheckRequest) MarshalVT added in v0.13.0 

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

func (*RunHealthCheckRequest) ProtoMessage added in v0.13.0 

func (*RunHealthCheckRequest) ProtoMessage()

func (*RunHealthCheckRequest) ProtoReflect added in v0.13.0 

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

func (*RunHealthCheckRequest) Reset added in v0.13.0 

func (x *RunHealthCheckRequest) Reset()

func (*RunHealthCheckRequest) SizeVT added in v0.13.0 

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

func (*RunHealthCheckRequest) String added in v0.13.0 

func (x *RunHealthCheckRequest) String() string

func (*RunHealthCheckRequest) UnmarshalVT added in v0.13.0 

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

type RunHealthCheckResponse added in v0.13.0 

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

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

func (*RunHealthCheckResponse) CloneVT added in v0.18.0 

func (m *RunHealthCheckResponse) CloneVT() *RunHealthCheckResponse

func (*RunHealthCheckResponse) Descriptor deprecated added in v0.13.0 

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

Deprecated: Use RunHealthCheckResponse.ProtoReflect.Descriptor instead.

func (*RunHealthCheckResponse) GetCluster added in v0.14.0 

func (x *RunHealthCheckResponse) GetCluster() *Cluster

func (*RunHealthCheckResponse) GetStatus added in v0.13.0 

func (x *RunHealthCheckResponse) GetStatus() string

func (*RunHealthCheckResponse) MarshalToSizedBufferVT added in v0.13.0 

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

func (*RunHealthCheckResponse) MarshalToVT added in v0.13.0 

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

func (*RunHealthCheckResponse) MarshalVT added in v0.13.0 

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

func (*RunHealthCheckResponse) ProtoMessage added in v0.13.0 

func (*RunHealthCheckResponse) ProtoMessage()

func (*RunHealthCheckResponse) ProtoReflect added in v0.13.0 

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

func (*RunHealthCheckResponse) Reset added in v0.13.0 

func (x *RunHealthCheckResponse) Reset()

func (*RunHealthCheckResponse) SizeVT added in v0.13.0 

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

func (*RunHealthCheckResponse) String added in v0.13.0 

func (x *RunHealthCheckResponse) String() string

func (*RunHealthCheckResponse) UnmarshalVT added in v0.13.0 

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

type Schema added in v0.10.0 

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

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

func (*Schema) CloneVT added in v0.18.0 

func (m *Schema) CloneVT() *Schema

func (*Schema) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetCluster added in v0.10.0 

func (x *Schema) GetCluster() *Cluster

func (*Schema) GetKeyspace added in v0.10.0 

func (x *Schema) GetKeyspace() string

func (*Schema) GetTableDefinitions added in v0.10.0 

func (x *Schema) GetTableDefinitions() []*tabletmanagerdata.TableDefinition

func (*Schema) GetTableSizes added in v0.10.0 

func (x *Schema) GetTableSizes() map[string]*Schema_TableSize

func (*Schema) MarshalToSizedBufferVT added in v0.11.0 

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

func (*Schema) MarshalToVT added in v0.11.0 

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

func (*Schema) MarshalVT added in v0.11.0 

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

func (*Schema) ProtoMessage added in v0.10.0 

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect added in v0.11.0 

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

func (*Schema) Reset added in v0.10.0 

func (x *Schema) Reset()

func (*Schema) SizeVT added in v0.11.0 

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

func (*Schema) String added in v0.10.0 

func (x *Schema) String() string

func (*Schema) UnmarshalVT added in v0.11.0 

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

type Schema_ShardTableSize added in v0.10.0 

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 added in v0.18.0 

func (m *Schema_ShardTableSize) CloneMessageVT() proto.Message

func (*Schema_ShardTableSize) CloneVT added in v0.18.0 

func (m *Schema_ShardTableSize) CloneVT() *Schema_ShardTableSize

func (*Schema_ShardTableSize) Descriptor deprecated added in v0.10.0 

func (*Schema_ShardTableSize) Descriptor() ([]byte, []int)

Deprecated: Use Schema_ShardTableSize.ProtoReflect.Descriptor instead.

func (*Schema_ShardTableSize) GetDataLength added in v0.10.0 

func (x *Schema_ShardTableSize) GetDataLength() uint64

func (*Schema_ShardTableSize) GetRowCount added in v0.10.0 

func (x *Schema_ShardTableSize) GetRowCount() uint64

func (*Schema_ShardTableSize) MarshalToSizedBufferVT added in v0.11.0 

func (m *Schema_ShardTableSize) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Schema_ShardTableSize) MarshalToVT added in v0.11.0 

func (m *Schema_ShardTableSize) MarshalToVT(dAtA []byte) (int, error)

func (*Schema_ShardTableSize) MarshalVT added in v0.11.0 

func (m *Schema_ShardTableSize) MarshalVT() (dAtA []byte, err error)

func (*Schema_ShardTableSize) ProtoMessage added in v0.10.0 

func (*Schema_ShardTableSize) ProtoMessage()

func (*Schema_ShardTableSize) ProtoReflect added in v0.11.0 

func (x *Schema_ShardTableSize) ProtoReflect() protoreflect.Message

func (*Schema_ShardTableSize) Reset added in v0.10.0 

func (x *Schema_ShardTableSize) Reset()

func (*Schema_ShardTableSize) SizeVT added in v0.11.0 

func (m *Schema_ShardTableSize) SizeVT() (n int)

func (*Schema_ShardTableSize) String added in v0.10.0 

func (x *Schema_ShardTableSize) String() string

func (*Schema_ShardTableSize) UnmarshalVT added in v0.11.0 

func (m *Schema_ShardTableSize) UnmarshalVT(dAtA []byte) error

type Schema_TableSize added in v0.10.0 

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 added in v0.18.0 

func (m *Schema_TableSize) CloneMessageVT() proto.Message

func (*Schema_TableSize) CloneVT added in v0.18.0 

func (m *Schema_TableSize) CloneVT() *Schema_TableSize

func (*Schema_TableSize) Descriptor deprecated added in v0.10.0 

func (*Schema_TableSize) Descriptor() ([]byte, []int)

Deprecated: Use Schema_TableSize.ProtoReflect.Descriptor instead.

func (*Schema_TableSize) GetByShard added in v0.10.0 

func (x *Schema_TableSize) GetByShard() map[string]*Schema_ShardTableSize

func (*Schema_TableSize) GetDataLength added in v0.10.0 

func (x *Schema_TableSize) GetDataLength() uint64

func (*Schema_TableSize) GetRowCount added in v0.10.0 

func (x *Schema_TableSize) GetRowCount() uint64

func (*Schema_TableSize) MarshalToSizedBufferVT added in v0.11.0 

func (m *Schema_TableSize) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Schema_TableSize) MarshalToVT added in v0.11.0 

func (m *Schema_TableSize) MarshalToVT(dAtA []byte) (int, error)

func (*Schema_TableSize) MarshalVT added in v0.11.0 

func (m *Schema_TableSize) MarshalVT() (dAtA []byte, err error)

func (*Schema_TableSize) ProtoMessage added in v0.10.0 

func (*Schema_TableSize) ProtoMessage()

func (*Schema_TableSize) ProtoReflect added in v0.11.0 

func (x *Schema_TableSize) ProtoReflect() protoreflect.Message

func (*Schema_TableSize) Reset added in v0.10.0 

func (x *Schema_TableSize) Reset()

func (*Schema_TableSize) SizeVT added in v0.11.0 

func (m *Schema_TableSize) SizeVT() (n int)

func (*Schema_TableSize) String added in v0.10.0 

func (x *Schema_TableSize) String() string

func (*Schema_TableSize) UnmarshalVT added in v0.11.0 

func (m *Schema_TableSize) UnmarshalVT(dAtA []byte) error

type SetReadOnlyRequest added in v0.14.0 

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 added in v0.18.0 

func (m *SetReadOnlyRequest) CloneMessageVT() proto.Message

func (*SetReadOnlyRequest) CloneVT added in v0.18.0 

func (m *SetReadOnlyRequest) CloneVT() *SetReadOnlyRequest

func (*SetReadOnlyRequest) Descriptor deprecated added in v0.14.0 

func (*SetReadOnlyRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetReadOnlyRequest.ProtoReflect.Descriptor instead.

func (*SetReadOnlyRequest) GetAlias added in v0.14.0 

func (x *SetReadOnlyRequest) GetAlias() *topodata.TabletAlias

func (*SetReadOnlyRequest) GetClusterIds added in v0.14.0 

func (x *SetReadOnlyRequest) GetClusterIds() []string

func (*SetReadOnlyRequest) MarshalToSizedBufferVT added in v0.14.0 

func (m *SetReadOnlyRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetReadOnlyRequest) MarshalToVT added in v0.14.0 

func (m *SetReadOnlyRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SetReadOnlyRequest) MarshalVT added in v0.14.0 

func (m *SetReadOnlyRequest) MarshalVT() (dAtA []byte, err error)

func (*SetReadOnlyRequest) ProtoMessage added in v0.14.0 

func (*SetReadOnlyRequest) ProtoMessage()

func (*SetReadOnlyRequest) ProtoReflect added in v0.14.0 

func (x *SetReadOnlyRequest) ProtoReflect() protoreflect.Message

func (*SetReadOnlyRequest) Reset added in v0.14.0 

func (x *SetReadOnlyRequest) Reset()

func (*SetReadOnlyRequest) SizeVT added in v0.14.0 

func (m *SetReadOnlyRequest) SizeVT() (n int)

func (*SetReadOnlyRequest) String added in v0.14.0 

func (x *SetReadOnlyRequest) String() string

func (*SetReadOnlyRequest) UnmarshalVT added in v0.14.0 

func (m *SetReadOnlyRequest) UnmarshalVT(dAtA []byte) error

type SetReadOnlyResponse added in v0.14.0 

type SetReadOnlyResponse struct {
	// contains filtered or unexported fields
}

func (*SetReadOnlyResponse) CloneMessageVT added in v0.18.0 

func (m *SetReadOnlyResponse) CloneMessageVT() proto.Message

func (*SetReadOnlyResponse) CloneVT added in v0.18.0 

func (m *SetReadOnlyResponse) CloneVT() *SetReadOnlyResponse

func (*SetReadOnlyResponse) Descriptor deprecated added in v0.14.0 

func (*SetReadOnlyResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetReadOnlyResponse.ProtoReflect.Descriptor instead.

func (*SetReadOnlyResponse) MarshalToSizedBufferVT added in v0.14.0 

func (m *SetReadOnlyResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetReadOnlyResponse) MarshalToVT added in v0.14.0 

func (m *SetReadOnlyResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SetReadOnlyResponse) MarshalVT added in v0.14.0 

func (m *SetReadOnlyResponse) MarshalVT() (dAtA []byte, err error)

func (*SetReadOnlyResponse) ProtoMessage added in v0.14.0 

func (*SetReadOnlyResponse) ProtoMessage()

func (*SetReadOnlyResponse) ProtoReflect added in v0.14.0 

func (x *SetReadOnlyResponse) ProtoReflect() protoreflect.Message

func (*SetReadOnlyResponse) Reset added in v0.14.0 

func (x *SetReadOnlyResponse) Reset()

func (*SetReadOnlyResponse) SizeVT added in v0.14.0 

func (m *SetReadOnlyResponse) SizeVT() (n int)

func (*SetReadOnlyResponse) String added in v0.14.0 

func (x *SetReadOnlyResponse) String() string

func (*SetReadOnlyResponse) UnmarshalVT added in v0.14.0 

func (m *SetReadOnlyResponse) UnmarshalVT(dAtA []byte) error

type SetReadWriteRequest added in v0.14.0 

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 added in v0.18.0 

func (m *SetReadWriteRequest) CloneMessageVT() proto.Message

func (*SetReadWriteRequest) CloneVT added in v0.18.0 

func (m *SetReadWriteRequest) CloneVT() *SetReadWriteRequest

func (*SetReadWriteRequest) Descriptor deprecated added in v0.14.0 

func (*SetReadWriteRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetReadWriteRequest.ProtoReflect.Descriptor instead.

func (*SetReadWriteRequest) GetAlias added in v0.14.0 

func (x *SetReadWriteRequest) GetAlias() *topodata.TabletAlias

func (*SetReadWriteRequest) GetClusterIds added in v0.14.0 

func (x *SetReadWriteRequest) GetClusterIds() []string

func (*SetReadWriteRequest) MarshalToSizedBufferVT added in v0.14.0 

func (m *SetReadWriteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetReadWriteRequest) MarshalToVT added in v0.14.0 

func (m *SetReadWriteRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SetReadWriteRequest) MarshalVT added in v0.14.0 

func (m *SetReadWriteRequest) MarshalVT() (dAtA []byte, err error)

func (*SetReadWriteRequest) ProtoMessage added in v0.14.0 

func (*SetReadWriteRequest) ProtoMessage()

func (*SetReadWriteRequest) ProtoReflect added in v0.14.0 

func (x *SetReadWriteRequest) ProtoReflect() protoreflect.Message

func (*SetReadWriteRequest) Reset added in v0.14.0 

func (x *SetReadWriteRequest) Reset()

func (*SetReadWriteRequest) SizeVT added in v0.14.0 

func (m *SetReadWriteRequest) SizeVT() (n int)

func (*SetReadWriteRequest) String added in v0.14.0 

func (x *SetReadWriteRequest) String() string

func (*SetReadWriteRequest) UnmarshalVT added in v0.14.0 

func (m *SetReadWriteRequest) UnmarshalVT(dAtA []byte) error

type SetReadWriteResponse added in v0.14.0 

type SetReadWriteResponse struct {
	// contains filtered or unexported fields
}

func (*SetReadWriteResponse) CloneMessageVT added in v0.18.0 

func (m *SetReadWriteResponse) CloneMessageVT() proto.Message

func (*SetReadWriteResponse) CloneVT added in v0.18.0 

func (m *SetReadWriteResponse) CloneVT() *SetReadWriteResponse

func (*SetReadWriteResponse) Descriptor deprecated added in v0.14.0 

func (*SetReadWriteResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetReadWriteResponse.ProtoReflect.Descriptor instead.

func (*SetReadWriteResponse) MarshalToSizedBufferVT added in v0.14.0 

func (m *SetReadWriteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetReadWriteResponse) MarshalToVT added in v0.14.0 

func (m *SetReadWriteResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SetReadWriteResponse) MarshalVT added in v0.14.0 

func (m *SetReadWriteResponse) MarshalVT() (dAtA []byte, err error)

func (*SetReadWriteResponse) ProtoMessage added in v0.14.0 

func (*SetReadWriteResponse) ProtoMessage()

func (*SetReadWriteResponse) ProtoReflect added in v0.14.0 

func (x *SetReadWriteResponse) ProtoReflect() protoreflect.Message

func (*SetReadWriteResponse) Reset added in v0.14.0 

func (x *SetReadWriteResponse) Reset()

func (*SetReadWriteResponse) SizeVT added in v0.14.0 

func (m *SetReadWriteResponse) SizeVT() (n int)

func (*SetReadWriteResponse) String added in v0.14.0 

func (x *SetReadWriteResponse) String() string

func (*SetReadWriteResponse) UnmarshalVT added in v0.14.0 

func (m *SetReadWriteResponse) UnmarshalVT(dAtA []byte) error

type Shard added in v0.14.0 

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 added in v0.18.0 

func (m *Shard) CloneMessageVT() proto.Message

func (*Shard) CloneVT added in v0.18.0 

func (m *Shard) CloneVT() *Shard

func (*Shard) Descriptor deprecated added in v0.14.0 

func (*Shard) Descriptor() ([]byte, []int)

Deprecated: Use Shard.ProtoReflect.Descriptor instead.

func (*Shard) GetCluster added in v0.14.0 

func (x *Shard) GetCluster() *Cluster

func (*Shard) GetShard added in v0.14.0 

func (x *Shard) GetShard() *vtctldata.Shard

func (*Shard) MarshalToSizedBufferVT added in v0.14.0 

func (m *Shard) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Shard) MarshalToVT added in v0.14.0 

func (m *Shard) MarshalToVT(dAtA []byte) (int, error)

func (*Shard) MarshalVT added in v0.14.0 

func (m *Shard) MarshalVT() (dAtA []byte, err error)

func (*Shard) ProtoMessage added in v0.14.0 

func (*Shard) ProtoMessage()

func (*Shard) ProtoReflect added in v0.14.0 

func (x *Shard) ProtoReflect() protoreflect.Message

func (*Shard) Reset added in v0.14.0 

func (x *Shard) Reset()

func (*Shard) SizeVT added in v0.14.0 

func (m *Shard) SizeVT() (n int)

func (*Shard) String added in v0.14.0 

func (x *Shard) String() string

func (*Shard) UnmarshalVT added in v0.14.0 

func (m *Shard) UnmarshalVT(dAtA []byte) error

type SrvVSchema added in v0.11.0 

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 added in v0.18.0 

func (m *SrvVSchema) CloneMessageVT() proto.Message

func (*SrvVSchema) CloneVT added in v0.18.0 

func (m *SrvVSchema) CloneVT() *SrvVSchema

func (*SrvVSchema) Descriptor deprecated added in v0.11.0 

func (*SrvVSchema) Descriptor() ([]byte, []int)

Deprecated: Use SrvVSchema.ProtoReflect.Descriptor instead.

func (*SrvVSchema) GetCell added in v0.11.0 

func (x *SrvVSchema) GetCell() string

func (*SrvVSchema) GetCluster added in v0.11.0 

func (x *SrvVSchema) GetCluster() *Cluster

func (*SrvVSchema) GetSrvVSchema added in v0.11.0 

func (x *SrvVSchema) GetSrvVSchema() *vschema.SrvVSchema

func (*SrvVSchema) MarshalToSizedBufferVT added in v0.11.0 

func (m *SrvVSchema) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SrvVSchema) MarshalToVT added in v0.11.0 

func (m *SrvVSchema) MarshalToVT(dAtA []byte) (int, error)

func (*SrvVSchema) MarshalVT added in v0.11.0 

func (m *SrvVSchema) MarshalVT() (dAtA []byte, err error)

func (*SrvVSchema) ProtoMessage added in v0.11.0 

func (*SrvVSchema) ProtoMessage()

func (*SrvVSchema) ProtoReflect added in v0.11.0 

func (x *SrvVSchema) ProtoReflect() protoreflect.Message

func (*SrvVSchema) Reset added in v0.11.0 

func (x *SrvVSchema) Reset()

func (*SrvVSchema) SizeVT added in v0.11.0 

func (m *SrvVSchema) SizeVT() (n int)

func (*SrvVSchema) String added in v0.11.0 

func (x *SrvVSchema) String() string

func (*SrvVSchema) UnmarshalVT added in v0.11.0 

func (m *SrvVSchema) UnmarshalVT(dAtA []byte) error

type StartReplicationRequest added in v0.13.0 

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 added in v0.18.0 

func (m *StartReplicationRequest) CloneMessageVT() proto.Message

func (*StartReplicationRequest) CloneVT added in v0.18.0 

func (m *StartReplicationRequest) CloneVT() *StartReplicationRequest

func (*StartReplicationRequest) Descriptor deprecated added in v0.13.0 

func (*StartReplicationRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartReplicationRequest.ProtoReflect.Descriptor instead.

func (*StartReplicationRequest) GetAlias added in v0.13.0 

func (x *StartReplicationRequest) GetAlias() *topodata.TabletAlias

func (*StartReplicationRequest) GetClusterIds added in v0.13.0 

func (x *StartReplicationRequest) GetClusterIds() []string

func (*StartReplicationRequest) MarshalToSizedBufferVT added in v0.13.0 

func (m *StartReplicationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartReplicationRequest) MarshalToVT added in v0.13.0 

func (m *StartReplicationRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StartReplicationRequest) MarshalVT added in v0.13.0 

func (m *StartReplicationRequest) MarshalVT() (dAtA []byte, err error)

func (*StartReplicationRequest) ProtoMessage added in v0.13.0 

func (*StartReplicationRequest) ProtoMessage()

func (*StartReplicationRequest) ProtoReflect added in v0.13.0 

func (x *StartReplicationRequest) ProtoReflect() protoreflect.Message

func (*StartReplicationRequest) Reset added in v0.13.0 

func (x *StartReplicationRequest) Reset()

func (*StartReplicationRequest) SizeVT added in v0.13.0 

func (m *StartReplicationRequest) SizeVT() (n int)

func (*StartReplicationRequest) String added in v0.13.0 

func (x *StartReplicationRequest) String() string

func (*StartReplicationRequest) UnmarshalVT added in v0.13.0 

func (m *StartReplicationRequest) UnmarshalVT(dAtA []byte) error

type StartReplicationResponse added in v0.13.0 

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 added in v0.18.0 

func (m *StartReplicationResponse) CloneMessageVT() proto.Message

func (*StartReplicationResponse) CloneVT added in v0.18.0 

func (m *StartReplicationResponse) CloneVT() *StartReplicationResponse

func (*StartReplicationResponse) Descriptor deprecated added in v0.13.0 

func (*StartReplicationResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartReplicationResponse.ProtoReflect.Descriptor instead.

func (*StartReplicationResponse) GetCluster added in v0.14.0 

func (x *StartReplicationResponse) GetCluster() *Cluster

func (*StartReplicationResponse) GetStatus added in v0.13.0 

func (x *StartReplicationResponse) GetStatus() string

func (*StartReplicationResponse) MarshalToSizedBufferVT added in v0.13.0 

func (m *StartReplicationResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartReplicationResponse) MarshalToVT added in v0.13.0 

func (m *StartReplicationResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StartReplicationResponse) MarshalVT added in v0.13.0 

func (m *StartReplicationResponse) MarshalVT() (dAtA []byte, err error)

func (*StartReplicationResponse) ProtoMessage added in v0.13.0 

func (*StartReplicationResponse) ProtoMessage()

func (*StartReplicationResponse) ProtoReflect added in v0.13.0 

func (x *StartReplicationResponse) ProtoReflect() protoreflect.Message

func (*StartReplicationResponse) Reset added in v0.13.0 

func (x *StartReplicationResponse) Reset()

func (*StartReplicationResponse) SizeVT added in v0.13.0 

func (m *StartReplicationResponse) SizeVT() (n int)

func (*StartReplicationResponse) String added in v0.13.0 

func (x *StartReplicationResponse) String() string

func (*StartReplicationResponse) UnmarshalVT added in v0.13.0 

func (m *StartReplicationResponse) UnmarshalVT(dAtA []byte) error

type StopReplicationRequest added in v0.13.0 

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 added in v0.18.0 

func (m *StopReplicationRequest) CloneMessageVT() proto.Message

func (*StopReplicationRequest) CloneVT added in v0.18.0 

func (m *StopReplicationRequest) CloneVT() *StopReplicationRequest

func (*StopReplicationRequest) Descriptor deprecated added in v0.13.0 

func (*StopReplicationRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopReplicationRequest.ProtoReflect.Descriptor instead.

func (*StopReplicationRequest) GetAlias added in v0.13.0 

func (x *StopReplicationRequest) GetAlias() *topodata.TabletAlias

func (*StopReplicationRequest) GetClusterIds added in v0.13.0 

func (x *StopReplicationRequest) GetClusterIds() []string

func (*StopReplicationRequest) MarshalToSizedBufferVT added in v0.13.0 

func (m *StopReplicationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StopReplicationRequest) MarshalToVT added in v0.13.0 

func (m *StopReplicationRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StopReplicationRequest) MarshalVT added in v0.13.0 

func (m *StopReplicationRequest) MarshalVT() (dAtA []byte, err error)

func (*StopReplicationRequest) ProtoMessage added in v0.13.0 

func (*StopReplicationRequest) ProtoMessage()

func (*StopReplicationRequest) ProtoReflect added in v0.13.0 

func (x *StopReplicationRequest) ProtoReflect() protoreflect.Message

func (*StopReplicationRequest) Reset added in v0.13.0 

func (x *StopReplicationRequest) Reset()

func (*StopReplicationRequest) SizeVT added in v0.13.0 

func (m *StopReplicationRequest) SizeVT() (n int)

func (*StopReplicationRequest) String added in v0.13.0 

func (x *StopReplicationRequest) String() string

func (*StopReplicationRequest) UnmarshalVT added in v0.13.0 

func (m *StopReplicationRequest) UnmarshalVT(dAtA []byte) error

type StopReplicationResponse added in v0.13.0 

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 added in v0.18.0 

func (m *StopReplicationResponse) CloneMessageVT() proto.Message

func (*StopReplicationResponse) CloneVT added in v0.18.0 

func (m *StopReplicationResponse) CloneVT() *StopReplicationResponse

func (*StopReplicationResponse) Descriptor deprecated added in v0.13.0 

func (*StopReplicationResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopReplicationResponse.ProtoReflect.Descriptor instead.

func (*StopReplicationResponse) GetCluster added in v0.14.0 

func (x *StopReplicationResponse) GetCluster() *Cluster

func (*StopReplicationResponse) GetStatus added in v0.13.0 

func (x *StopReplicationResponse) GetStatus() string

func (*StopReplicationResponse) MarshalToSizedBufferVT added in v0.13.0 

func (m *StopReplicationResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StopReplicationResponse) MarshalToVT added in v0.13.0 

func (m *StopReplicationResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StopReplicationResponse) MarshalVT added in v0.13.0 

func (m *StopReplicationResponse) MarshalVT() (dAtA []byte, err error)

func (*StopReplicationResponse) ProtoMessage added in v0.13.0 

func (*StopReplicationResponse) ProtoMessage()

func (*StopReplicationResponse) ProtoReflect added in v0.13.0 

func (x *StopReplicationResponse) ProtoReflect() protoreflect.Message

func (*StopReplicationResponse) Reset added in v0.13.0 

func (x *StopReplicationResponse) Reset()

func (*StopReplicationResponse) SizeVT added in v0.13.0 

func (m *StopReplicationResponse) SizeVT() (n int)

func (*StopReplicationResponse) String added in v0.13.0 

func (x *StopReplicationResponse) String() string

func (*StopReplicationResponse) UnmarshalVT added in v0.13.0 

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 added in v0.18.0 

func (m *Tablet) CloneMessageVT() proto.Message

func (*Tablet) CloneVT added in v0.18.0 

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 added in v0.11.0 

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 added in v0.11.0 

func (m *Tablet) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Tablet) MarshalToVT added in v0.11.0 

func (m *Tablet) MarshalToVT(dAtA []byte) (int, error)

func (*Tablet) MarshalVT added in v0.11.0 

func (m *Tablet) MarshalVT() (dAtA []byte, err error)

func (*Tablet) ProtoMessage 

func (*Tablet) ProtoMessage()

func (*Tablet) ProtoReflect added in v0.11.0 

func (x *Tablet) ProtoReflect() protoreflect.Message

func (*Tablet) Reset 

func (x *Tablet) Reset()

func (*Tablet) SizeVT added in v0.11.0 

func (m *Tablet) SizeVT() (n int)

func (*Tablet) String 

func (x *Tablet) String() string

func (*Tablet) UnmarshalVT added in v0.11.0 

func (m *Tablet) UnmarshalVT(dAtA []byte) error

type TabletExternallyPromotedRequest added in v0.14.0 

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 added in v0.18.0 

func (m *TabletExternallyPromotedRequest) CloneMessageVT() proto.Message

func (*TabletExternallyPromotedRequest) CloneVT added in v0.18.0 

func (m *TabletExternallyPromotedRequest) CloneVT() *TabletExternallyPromotedRequest

func (*TabletExternallyPromotedRequest) Descriptor deprecated added in v0.14.0 

func (*TabletExternallyPromotedRequest) Descriptor() ([]byte, []int)

Deprecated: Use TabletExternallyPromotedRequest.ProtoReflect.Descriptor instead.

func (*TabletExternallyPromotedRequest) GetAlias added in v0.14.0 

func (x *TabletExternallyPromotedRequest) GetAlias() *topodata.TabletAlias

func (*TabletExternallyPromotedRequest) GetClusterIds added in v0.14.0 

func (x *TabletExternallyPromotedRequest) GetClusterIds() []string

func (*TabletExternallyPromotedRequest) MarshalToSizedBufferVT added in v0.14.0 

func (m *TabletExternallyPromotedRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TabletExternallyPromotedRequest) MarshalToVT added in v0.14.0 

func (m *TabletExternallyPromotedRequest) MarshalToVT(dAtA []byte) (int, error)

func (*TabletExternallyPromotedRequest) MarshalVT added in v0.14.0 

func (m *TabletExternallyPromotedRequest) MarshalVT() (dAtA []byte, err error)

func (*TabletExternallyPromotedRequest) ProtoMessage added in v0.14.0 

func (*TabletExternallyPromotedRequest) ProtoMessage()

func (*TabletExternallyPromotedRequest) ProtoReflect added in v0.14.0 

func (x *TabletExternallyPromotedRequest) ProtoReflect() protoreflect.Message

func (*TabletExternallyPromotedRequest) Reset added in v0.14.0 

func (x *TabletExternallyPromotedRequest) Reset()

func (*TabletExternallyPromotedRequest) SizeVT added in v0.14.0 

func (m *TabletExternallyPromotedRequest) SizeVT() (n int)

func (*TabletExternallyPromotedRequest) String added in v0.14.0 

func (x *TabletExternallyPromotedRequest) String() string

func (*TabletExternallyPromotedRequest) UnmarshalVT added in v0.14.0 

func (m *TabletExternallyPromotedRequest) UnmarshalVT(dAtA []byte) error

type TabletExternallyPromotedResponse added in v0.14.0 

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 added in v0.18.0 

func (m *TabletExternallyPromotedResponse) CloneMessageVT() proto.Message

func (*TabletExternallyPromotedResponse) CloneVT added in v0.18.0 

func (m *TabletExternallyPromotedResponse) CloneVT() *TabletExternallyPromotedResponse

func (*TabletExternallyPromotedResponse) Descriptor deprecated added in v0.14.0 

func (*TabletExternallyPromotedResponse) Descriptor() ([]byte, []int)

Deprecated: Use TabletExternallyPromotedResponse.ProtoReflect.Descriptor instead.

func (*TabletExternallyPromotedResponse) GetCluster added in v0.14.0 

func (x *TabletExternallyPromotedResponse) GetCluster() *Cluster

func (*TabletExternallyPromotedResponse) GetKeyspace added in v0.14.0 

func (x *TabletExternallyPromotedResponse) GetKeyspace() string

func (*TabletExternallyPromotedResponse) GetNewPrimary added in v0.14.0 

func (x *TabletExternallyPromotedResponse) GetNewPrimary() *topodata.TabletAlias

func (*TabletExternallyPromotedResponse) GetOldPrimary added in v0.14.0 

func (x *TabletExternallyPromotedResponse) GetOldPrimary() *topodata.TabletAlias

func (*TabletExternallyPromotedResponse) GetShard added in v0.14.0 

func (x *TabletExternallyPromotedResponse) GetShard() string

func (*TabletExternallyPromotedResponse) MarshalToSizedBufferVT added in v0.14.0 

func (m *TabletExternallyPromotedResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TabletExternallyPromotedResponse) MarshalToVT added in v0.14.0 

func (m *TabletExternallyPromotedResponse) MarshalToVT(dAtA []byte) (int, error)

func (*TabletExternallyPromotedResponse) MarshalVT added in v0.14.0 

func (m *TabletExternallyPromotedResponse) MarshalVT() (dAtA []byte, err error)

func (*TabletExternallyPromotedResponse) ProtoMessage added in v0.14.0 

func (*TabletExternallyPromotedResponse) ProtoMessage()

func (*TabletExternallyPromotedResponse) ProtoReflect added in v0.14.0 

func (x *TabletExternallyPromotedResponse) ProtoReflect() protoreflect.Message

func (*TabletExternallyPromotedResponse) Reset added in v0.14.0 

func (x *TabletExternallyPromotedResponse) Reset()

func (*TabletExternallyPromotedResponse) SizeVT added in v0.14.0 

func (m *TabletExternallyPromotedResponse) SizeVT() (n int)

func (*TabletExternallyPromotedResponse) String added in v0.14.0 

func (x *TabletExternallyPromotedResponse) String() string

func (*TabletExternallyPromotedResponse) UnmarshalVT added in v0.14.0 

func (m *TabletExternallyPromotedResponse) UnmarshalVT(dAtA []byte) error

type TabletExternallyReparentedRequest added in v0.15.0 

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 added in v0.18.0 

func (m *TabletExternallyReparentedRequest) CloneMessageVT() proto.Message

func (*TabletExternallyReparentedRequest) CloneVT added in v0.18.0 

func (m *TabletExternallyReparentedRequest) CloneVT() *TabletExternallyReparentedRequest

func (*TabletExternallyReparentedRequest) Descriptor deprecated added in v0.15.0 

func (*TabletExternallyReparentedRequest) Descriptor() ([]byte, []int)

Deprecated: Use TabletExternallyReparentedRequest.ProtoReflect.Descriptor instead.

func (*TabletExternallyReparentedRequest) GetAlias added in v0.15.0 

func (x *TabletExternallyReparentedRequest) GetAlias() *topodata.TabletAlias

func (*TabletExternallyReparentedRequest) GetClusterIds added in v0.15.0 

func (x *TabletExternallyReparentedRequest) GetClusterIds() []string

func (*TabletExternallyReparentedRequest) MarshalToSizedBufferVT added in v0.15.0 

func (m *TabletExternallyReparentedRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TabletExternallyReparentedRequest) MarshalToVT added in v0.15.0 

func (m *TabletExternallyReparentedRequest) MarshalToVT(dAtA []byte) (int, error)

func (*TabletExternallyReparentedRequest) MarshalVT added in v0.15.0 

func (m *TabletExternallyReparentedRequest) MarshalVT() (dAtA []byte, err error)

func (*TabletExternallyReparentedRequest) ProtoMessage added in v0.15.0 

func (*TabletExternallyReparentedRequest) ProtoMessage()

func (*TabletExternallyReparentedRequest) ProtoReflect added in v0.15.0 

func (x *TabletExternallyReparentedRequest) ProtoReflect() protoreflect.Message

func (*TabletExternallyReparentedRequest) Reset added in v0.15.0 

func (x *TabletExternallyReparentedRequest) Reset()

func (*TabletExternallyReparentedRequest) SizeVT added in v0.15.0 

func (m *TabletExternallyReparentedRequest) SizeVT() (n int)

func (*TabletExternallyReparentedRequest) String added in v0.15.0 

func (x *TabletExternallyReparentedRequest) String() string

func (*TabletExternallyReparentedRequest) UnmarshalVT added in v0.15.0 

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 added in v0.11.0 

func (Tablet_ServingState) Descriptor() protoreflect.EnumDescriptor

func (Tablet_ServingState) Enum added in v0.11.0 

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 added in v0.11.0 

func (x Tablet_ServingState) Number() protoreflect.EnumNumber

func (Tablet_ServingState) String 

func (x Tablet_ServingState) String() string

func (Tablet_ServingState) Type added in v0.11.0 

func (Tablet_ServingState) Type() protoreflect.EnumType

type UnimplementedVTAdminServer 

type UnimplementedVTAdminServer struct {
}

UnimplementedVTAdminServer must be embedded to have forward compatible implementations.

func (UnimplementedVTAdminServer) CreateKeyspace added in v0.12.0 

func (UnimplementedVTAdminServer) CreateKeyspace(context.Context, *CreateKeyspaceRequest) (*CreateKeyspaceResponse, error)

func (UnimplementedVTAdminServer) CreateShard added in v0.13.0 

func (UnimplementedVTAdminServer) CreateShard(context.Context, *CreateShardRequest) (*vtctldata.CreateShardResponse, error)

func (UnimplementedVTAdminServer) DeleteKeyspace added in v0.12.0 

func (UnimplementedVTAdminServer) DeleteKeyspace(context.Context, *DeleteKeyspaceRequest) (*vtctldata.DeleteKeyspaceResponse, error)

func (UnimplementedVTAdminServer) DeleteShards added in v0.13.0 

func (UnimplementedVTAdminServer) DeleteShards(context.Context, *DeleteShardsRequest) (*vtctldata.DeleteShardsResponse, error)

func (UnimplementedVTAdminServer) DeleteTablet added in v0.13.0 

func (UnimplementedVTAdminServer) DeleteTablet(context.Context, *DeleteTabletRequest) (*DeleteTabletResponse, error)

func (UnimplementedVTAdminServer) EmergencyFailoverShard added in v0.14.0 

func (UnimplementedVTAdminServer) EmergencyFailoverShard(context.Context, *EmergencyFailoverShardRequest) (*EmergencyFailoverShardResponse, error)

func (UnimplementedVTAdminServer) FindSchema added in v0.10.0 

func (UnimplementedVTAdminServer) FindSchema(context.Context, *FindSchemaRequest) (*Schema, error)

func (UnimplementedVTAdminServer) GetBackups added in v0.11.0 

func (UnimplementedVTAdminServer) GetBackups(context.Context, *GetBackupsRequest) (*GetBackupsResponse, error)

func (UnimplementedVTAdminServer) GetCellInfos added in v0.14.0 

func (UnimplementedVTAdminServer) GetCellInfos(context.Context, *GetCellInfosRequest) (*GetCellInfosResponse, error)

func (UnimplementedVTAdminServer) GetCellsAliases added in v0.14.0 

func (UnimplementedVTAdminServer) GetCellsAliases(context.Context, *GetCellsAliasesRequest) (*GetCellsAliasesResponse, error)

func (UnimplementedVTAdminServer) GetClusters added in v0.10.0 

func (UnimplementedVTAdminServer) GetClusters(context.Context, *GetClustersRequest) (*GetClustersResponse, error)

func (UnimplementedVTAdminServer) GetFullStatus added in v0.15.0 

func (UnimplementedVTAdminServer) GetFullStatus(context.Context, *GetFullStatusRequest) (*vtctldata.GetFullStatusResponse, error)

func (UnimplementedVTAdminServer) GetGates 

func (UnimplementedVTAdminServer) GetGates(context.Context, *GetGatesRequest) (*GetGatesResponse, error)

func (UnimplementedVTAdminServer) GetKeyspace added in v0.11.0 

func (UnimplementedVTAdminServer) GetKeyspace(context.Context, *GetKeyspaceRequest) (*Keyspace, error)

func (UnimplementedVTAdminServer) GetKeyspaces added in v0.10.0 

func (UnimplementedVTAdminServer) GetKeyspaces(context.Context, *GetKeyspacesRequest) (*GetKeyspacesResponse, error)

func (UnimplementedVTAdminServer) GetSchema added in v0.10.0 

func (UnimplementedVTAdminServer) GetSchema(context.Context, *GetSchemaRequest) (*Schema, error)

func (UnimplementedVTAdminServer) GetSchemas added in v0.10.0 

func (UnimplementedVTAdminServer) GetSchemas(context.Context, *GetSchemasRequest) (*GetSchemasResponse, error)

func (UnimplementedVTAdminServer) GetShardReplicationPositions added in v0.12.0 

func (UnimplementedVTAdminServer) GetShardReplicationPositions(context.Context, *GetShardReplicationPositionsRequest) (*GetShardReplicationPositionsResponse, error)

func (UnimplementedVTAdminServer) GetSrvKeyspace added in v0.17.0 

func (UnimplementedVTAdminServer) GetSrvKeyspace(context.Context, *GetSrvKeyspaceRequest) (*vtctldata.GetSrvKeyspacesResponse, error)

func (UnimplementedVTAdminServer) GetSrvKeyspaces added in v0.17.0 

func (UnimplementedVTAdminServer) GetSrvKeyspaces(context.Context, *GetSrvKeyspacesRequest) (*GetSrvKeyspacesResponse, error)

func (UnimplementedVTAdminServer) GetSrvVSchema added in v0.11.0 

func (UnimplementedVTAdminServer) GetSrvVSchema(context.Context, *GetSrvVSchemaRequest) (*SrvVSchema, error)

func (UnimplementedVTAdminServer) GetSrvVSchemas added in v0.11.0 

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 added in v0.15.0 

func (UnimplementedVTAdminServer) GetTopologyPath(context.Context, *GetTopologyPathRequest) (*vtctldata.GetTopologyPathResponse, error)

func (UnimplementedVTAdminServer) GetVSchema added in v0.10.0 

func (UnimplementedVTAdminServer) GetVSchema(context.Context, *GetVSchemaRequest) (*VSchema, error)

func (UnimplementedVTAdminServer) GetVSchemas added in v0.10.0 

func (UnimplementedVTAdminServer) GetVSchemas(context.Context, *GetVSchemasRequest) (*GetVSchemasResponse, error)

func (UnimplementedVTAdminServer) GetVtctlds added in v0.12.0 

func (UnimplementedVTAdminServer) GetVtctlds(context.Context, *GetVtctldsRequest) (*GetVtctldsResponse, error)

func (UnimplementedVTAdminServer) GetWorkflow added in v0.10.0 

func (UnimplementedVTAdminServer) GetWorkflow(context.Context, *GetWorkflowRequest) (*Workflow, error)

func (UnimplementedVTAdminServer) GetWorkflows added in v0.10.0 

func (UnimplementedVTAdminServer) GetWorkflows(context.Context, *GetWorkflowsRequest) (*GetWorkflowsResponse, error)

func (UnimplementedVTAdminServer) PingTablet added in v0.13.0 

func (UnimplementedVTAdminServer) PingTablet(context.Context, *PingTabletRequest) (*PingTabletResponse, error)

func (UnimplementedVTAdminServer) PlannedFailoverShard added in v0.14.0 

func (UnimplementedVTAdminServer) PlannedFailoverShard(context.Context, *PlannedFailoverShardRequest) (*PlannedFailoverShardResponse, error)

func (UnimplementedVTAdminServer) RebuildKeyspaceGraph added in v0.15.0 

func (UnimplementedVTAdminServer) RebuildKeyspaceGraph(context.Context, *RebuildKeyspaceGraphRequest) (*RebuildKeyspaceGraphResponse, error)

func (UnimplementedVTAdminServer) RefreshState added in v0.13.0 

func (UnimplementedVTAdminServer) RefreshState(context.Context, *RefreshStateRequest) (*RefreshStateResponse, error)

func (UnimplementedVTAdminServer) RefreshTabletReplicationSource added in v0.14.0 

func (UnimplementedVTAdminServer) RefreshTabletReplicationSource(context.Context, *RefreshTabletReplicationSourceRequest) (*RefreshTabletReplicationSourceResponse, error)

func (UnimplementedVTAdminServer) ReloadSchemaShard added in v0.15.0 

func (UnimplementedVTAdminServer) ReloadSchemaShard(context.Context, *ReloadSchemaShardRequest) (*ReloadSchemaShardResponse, error)

func (UnimplementedVTAdminServer) ReloadSchemas added in v0.14.0 

func (UnimplementedVTAdminServer) ReloadSchemas(context.Context, *ReloadSchemasRequest) (*ReloadSchemasResponse, error)

func (UnimplementedVTAdminServer) RemoveKeyspaceCell added in v0.15.0 

func (UnimplementedVTAdminServer) RemoveKeyspaceCell(context.Context, *RemoveKeyspaceCellRequest) (*RemoveKeyspaceCellResponse, error)

func (UnimplementedVTAdminServer) RunHealthCheck added in v0.13.0 

func (UnimplementedVTAdminServer) RunHealthCheck(context.Context, *RunHealthCheckRequest) (*RunHealthCheckResponse, error)

func (UnimplementedVTAdminServer) SetReadOnly added in v0.14.0 

func (UnimplementedVTAdminServer) SetReadOnly(context.Context, *SetReadOnlyRequest) (*SetReadOnlyResponse, error)

func (UnimplementedVTAdminServer) SetReadWrite added in v0.14.0 

func (UnimplementedVTAdminServer) SetReadWrite(context.Context, *SetReadWriteRequest) (*SetReadWriteResponse, error)

func (UnimplementedVTAdminServer) StartReplication added in v0.13.0 

func (UnimplementedVTAdminServer) StartReplication(context.Context, *StartReplicationRequest) (*StartReplicationResponse, error)

func (UnimplementedVTAdminServer) StopReplication added in v0.13.0 

func (UnimplementedVTAdminServer) StopReplication(context.Context, *StopReplicationRequest) (*StopReplicationResponse, error)

func (UnimplementedVTAdminServer) TabletExternallyPromoted added in v0.14.0 

func (UnimplementedVTAdminServer) TabletExternallyPromoted(context.Context, *TabletExternallyPromotedRequest) (*TabletExternallyPromotedResponse, error)

func (UnimplementedVTAdminServer) VTExplain added in v0.10.0 

func (UnimplementedVTAdminServer) VTExplain(context.Context, *VTExplainRequest) (*VTExplainResponse, error)

func (UnimplementedVTAdminServer) Validate added in v0.15.0 

func (UnimplementedVTAdminServer) Validate(context.Context, *ValidateRequest) (*vtctldata.ValidateResponse, error)

func (UnimplementedVTAdminServer) ValidateKeyspace added in v0.14.0 

func (UnimplementedVTAdminServer) ValidateKeyspace(context.Context, *ValidateKeyspaceRequest) (*vtctldata.ValidateKeyspaceResponse, error)

func (UnimplementedVTAdminServer) ValidateSchemaKeyspace added in v0.14.0 

func (UnimplementedVTAdminServer) ValidateSchemaKeyspace(context.Context, *ValidateSchemaKeyspaceRequest) (*vtctldata.ValidateSchemaKeyspaceResponse, error)

func (UnimplementedVTAdminServer) ValidateShard added in v0.15.0 

func (UnimplementedVTAdminServer) ValidateShard(context.Context, *ValidateShardRequest) (*vtctldata.ValidateShardResponse, error)

func (UnimplementedVTAdminServer) ValidateVersionKeyspace added in v0.14.0 

func (UnimplementedVTAdminServer) ValidateVersionKeyspace(context.Context, *ValidateVersionKeyspaceRequest) (*vtctldata.ValidateVersionKeyspaceResponse, error)

func (UnimplementedVTAdminServer) ValidateVersionShard added in v0.15.0 

func (UnimplementedVTAdminServer) ValidateVersionShard(context.Context, *ValidateVersionShardRequest) (*vtctldata.ValidateVersionShardResponse, error)

type UnsafeVTAdminServer added in v0.11.0 

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 added in v0.10.0 

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 added in v0.18.0 

func (m *VSchema) CloneMessageVT() proto.Message

func (*VSchema) CloneVT added in v0.18.0 

func (m *VSchema) CloneVT() *VSchema

func (*VSchema) Descriptor deprecated added in v0.10.0 

func (*VSchema) Descriptor() ([]byte, []int)

Deprecated: Use VSchema.ProtoReflect.Descriptor instead.

func (*VSchema) GetCluster added in v0.10.0 

func (x *VSchema) GetCluster() *Cluster

func (*VSchema) GetName added in v0.10.0 

func (x *VSchema) GetName() string

func (*VSchema) GetVSchema added in v0.10.0 

func (x *VSchema) GetVSchema() *vschema.Keyspace

func (*VSchema) MarshalToSizedBufferVT added in v0.11.0 

func (m *VSchema) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VSchema) MarshalToVT added in v0.11.0 

func (m *VSchema) MarshalToVT(dAtA []byte) (int, error)

func (*VSchema) MarshalVT added in v0.11.0 

func (m *VSchema) MarshalVT() (dAtA []byte, err error)

func (*VSchema) ProtoMessage added in v0.10.0 

func (*VSchema) ProtoMessage()

func (*VSchema) ProtoReflect added in v0.11.0 

func (x *VSchema) ProtoReflect() protoreflect.Message

func (*VSchema) Reset added in v0.10.0 

func (x *VSchema) Reset()

func (*VSchema) SizeVT added in v0.11.0 

func (m *VSchema) SizeVT() (n int)

func (*VSchema) String added in v0.10.0 

func (x *VSchema) String() string

func (*VSchema) UnmarshalVT added in v0.11.0 

func (m *VSchema) UnmarshalVT(dAtA []byte) error

type VTAdminClient 

type VTAdminClient interface {
	// 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)
	// 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)
	// 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)
	// 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 {
	// 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)
	// 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)
	// 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)
	// 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 added in v0.10.0 

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 added in v0.18.0 

func (m *VTExplainRequest) CloneMessageVT() proto.Message

func (*VTExplainRequest) CloneVT added in v0.18.0 

func (m *VTExplainRequest) CloneVT() *VTExplainRequest

func (*VTExplainRequest) Descriptor deprecated added in v0.10.0 

func (*VTExplainRequest) Descriptor() ([]byte, []int)

Deprecated: Use VTExplainRequest.ProtoReflect.Descriptor instead.

func (*VTExplainRequest) GetCluster added in v0.10.0 

func (x *VTExplainRequest) GetCluster() string

func (*VTExplainRequest) GetKeyspace added in v0.10.0 

func (x *VTExplainRequest) GetKeyspace() string

func (*VTExplainRequest) GetSql added in v0.10.0 

func (x *VTExplainRequest) GetSql() string

func (*VTExplainRequest) MarshalToSizedBufferVT added in v0.11.0 

func (m *VTExplainRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VTExplainRequest) MarshalToVT added in v0.11.0 

func (m *VTExplainRequest) MarshalToVT(dAtA []byte) (int, error)

func (*VTExplainRequest) MarshalVT added in v0.11.0 

func (m *VTExplainRequest) MarshalVT() (dAtA []byte, err error)

func (*VTExplainRequest) ProtoMessage added in v0.10.0 

func (*VTExplainRequest) ProtoMessage()

func (*VTExplainRequest) ProtoReflect added in v0.11.0 

func (x *VTExplainRequest) ProtoReflect() protoreflect.Message

func (*VTExplainRequest) Reset added in v0.10.0 

func (x *VTExplainRequest) Reset()

func (*VTExplainRequest) SizeVT added in v0.11.0 

func (m *VTExplainRequest) SizeVT() (n int)

func (*VTExplainRequest) String added in v0.10.0 

func (x *VTExplainRequest) String() string

func (*VTExplainRequest) UnmarshalVT added in v0.11.0 

func (m *VTExplainRequest) UnmarshalVT(dAtA []byte) error

type VTExplainResponse added in v0.10.0 

type VTExplainResponse struct {
	Response string `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*VTExplainResponse) CloneMessageVT added in v0.18.0 

func (m *VTExplainResponse) CloneMessageVT() proto.Message

func (*VTExplainResponse) CloneVT added in v0.18.0 

func (m *VTExplainResponse) CloneVT() *VTExplainResponse

func (*VTExplainResponse) Descriptor deprecated added in v0.10.0 

func (*VTExplainResponse) Descriptor() ([]byte, []int)

Deprecated: Use VTExplainResponse.ProtoReflect.Descriptor instead.

func (*VTExplainResponse) GetResponse added in v0.10.0 

func (x *VTExplainResponse) GetResponse() string

func (*VTExplainResponse) MarshalToSizedBufferVT added in v0.11.0 

func (m *VTExplainResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VTExplainResponse) MarshalToVT added in v0.11.0 

func (m *VTExplainResponse) MarshalToVT(dAtA []byte) (int, error)

func (*VTExplainResponse) MarshalVT added in v0.11.0 

func (m *VTExplainResponse) MarshalVT() (dAtA []byte, err error)

func (*VTExplainResponse) ProtoMessage added in v0.10.0 

func (*VTExplainResponse) ProtoMessage()

func (*VTExplainResponse) ProtoReflect added in v0.11.0 

func (x *VTExplainResponse) ProtoReflect() protoreflect.Message

func (*VTExplainResponse) Reset added in v0.10.0 

func (x *VTExplainResponse) Reset()

func (*VTExplainResponse) SizeVT added in v0.11.0 

func (m *VTExplainResponse) SizeVT() (n int)

func (*VTExplainResponse) String added in v0.10.0 

func (x *VTExplainResponse) String() string

func (*VTExplainResponse) UnmarshalVT added in v0.11.0 

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 added in v0.18.0 

func (m *VTGate) CloneMessageVT() proto.Message

func (*VTGate) CloneVT added in v0.18.0 

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 added in v0.11.0 

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 added in v0.11.0 

func (m *VTGate) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VTGate) MarshalToVT added in v0.11.0 

func (m *VTGate) MarshalToVT(dAtA []byte) (int, error)

func (*VTGate) MarshalVT added in v0.11.0 

func (m *VTGate) MarshalVT() (dAtA []byte, err error)

func (*VTGate) ProtoMessage 

func (*VTGate) ProtoMessage()

func (*VTGate) ProtoReflect added in v0.11.0 

func (x *VTGate) ProtoReflect() protoreflect.Message

func (*VTGate) Reset 

func (x *VTGate) Reset()

func (*VTGate) SizeVT added in v0.11.0 

func (m *VTGate) SizeVT() (n int)

func (*VTGate) String 

func (x *VTGate) String() string

func (*VTGate) UnmarshalVT added in v0.11.0 

func (m *VTGate) UnmarshalVT(dAtA []byte) error

type ValidateKeyspaceRequest added in v0.14.0 

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 added in v0.18.0 

func (m *ValidateKeyspaceRequest) CloneMessageVT() proto.Message

func (*ValidateKeyspaceRequest) CloneVT added in v0.18.0 

func (m *ValidateKeyspaceRequest) CloneVT() *ValidateKeyspaceRequest

func (*ValidateKeyspaceRequest) Descriptor deprecated added in v0.14.0 

func (*ValidateKeyspaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*ValidateKeyspaceRequest) GetClusterId added in v0.14.0 

func (x *ValidateKeyspaceRequest) GetClusterId() string

func (*ValidateKeyspaceRequest) GetKeyspace added in v0.14.0 

func (x *ValidateKeyspaceRequest) GetKeyspace() string

func (*ValidateKeyspaceRequest) GetPingTablets added in v0.14.0 

func (x *ValidateKeyspaceRequest) GetPingTablets() bool

func (*ValidateKeyspaceRequest) MarshalToSizedBufferVT added in v0.14.0 

func (m *ValidateKeyspaceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidateKeyspaceRequest) MarshalToVT added in v0.14.0 

func (m *ValidateKeyspaceRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ValidateKeyspaceRequest) MarshalVT added in v0.14.0 

func (m *ValidateKeyspaceRequest) MarshalVT() (dAtA []byte, err error)

func (*ValidateKeyspaceRequest) ProtoMessage added in v0.14.0 

func (*ValidateKeyspaceRequest) ProtoMessage()

func (*ValidateKeyspaceRequest) ProtoReflect added in v0.14.0 

func (x *ValidateKeyspaceRequest) ProtoReflect() protoreflect.Message

func (*ValidateKeyspaceRequest) Reset added in v0.14.0 

func (x *ValidateKeyspaceRequest) Reset()

func (*ValidateKeyspaceRequest) SizeVT added in v0.14.0 

func (m *ValidateKeyspaceRequest) SizeVT() (n int)

func (*ValidateKeyspaceRequest) String added in v0.14.0 

func (x *ValidateKeyspaceRequest) String() string

func (*ValidateKeyspaceRequest) UnmarshalVT added in v0.14.0 

func (m *ValidateKeyspaceRequest) UnmarshalVT(dAtA []byte) error

type ValidateRequest added in v0.15.0 

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 added in v0.18.0 

func (m *ValidateRequest) CloneMessageVT() proto.Message

func (*ValidateRequest) CloneVT added in v0.18.0 

func (m *ValidateRequest) CloneVT() *ValidateRequest

func (*ValidateRequest) Descriptor deprecated added in v0.15.0 

func (*ValidateRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateRequest.ProtoReflect.Descriptor instead.

func (*ValidateRequest) GetClusterId added in v0.15.0 

func (x *ValidateRequest) GetClusterId() string

func (*ValidateRequest) GetPingTablets added in v0.15.0 

func (x *ValidateRequest) GetPingTablets() bool

func (*ValidateRequest) MarshalToSizedBufferVT added in v0.15.0 

func (m *ValidateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidateRequest) MarshalToVT added in v0.15.0 

func (m *ValidateRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ValidateRequest) MarshalVT added in v0.15.0 

func (m *ValidateRequest) MarshalVT() (dAtA []byte, err error)

func (*ValidateRequest) ProtoMessage added in v0.15.0 

func (*ValidateRequest) ProtoMessage()

func (*ValidateRequest) ProtoReflect added in v0.15.0 

func (x *ValidateRequest) ProtoReflect() protoreflect.Message

func (*ValidateRequest) Reset added in v0.15.0 

func (x *ValidateRequest) Reset()

func (*ValidateRequest) SizeVT added in v0.15.0 

func (m *ValidateRequest) SizeVT() (n int)

func (*ValidateRequest) String added in v0.15.0 

func (x *ValidateRequest) String() string

func (*ValidateRequest) UnmarshalVT added in v0.15.0 

func (m *ValidateRequest) UnmarshalVT(dAtA []byte) error

type ValidateSchemaKeyspaceRequest added in v0.14.0 

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 added in v0.18.0 

func (m *ValidateSchemaKeyspaceRequest) CloneMessageVT() proto.Message

func (*ValidateSchemaKeyspaceRequest) CloneVT added in v0.18.0 

func (m *ValidateSchemaKeyspaceRequest) CloneVT() *ValidateSchemaKeyspaceRequest

func (*ValidateSchemaKeyspaceRequest) Descriptor deprecated added in v0.14.0 

func (*ValidateSchemaKeyspaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateSchemaKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*ValidateSchemaKeyspaceRequest) GetClusterId added in v0.14.0 

func (x *ValidateSchemaKeyspaceRequest) GetClusterId() string

func (*ValidateSchemaKeyspaceRequest) GetKeyspace added in v0.14.0 

func (x *ValidateSchemaKeyspaceRequest) GetKeyspace() string

func (*ValidateSchemaKeyspaceRequest) MarshalToSizedBufferVT added in v0.14.0 

func (m *ValidateSchemaKeyspaceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidateSchemaKeyspaceRequest) MarshalToVT added in v0.14.0 

func (m *ValidateSchemaKeyspaceRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ValidateSchemaKeyspaceRequest) MarshalVT added in v0.14.0 

func (m *ValidateSchemaKeyspaceRequest) MarshalVT() (dAtA []byte, err error)

func (*ValidateSchemaKeyspaceRequest) ProtoMessage added in v0.14.0 

func (*ValidateSchemaKeyspaceRequest) ProtoMessage()

func (*ValidateSchemaKeyspaceRequest) ProtoReflect added in v0.14.0 

func (x *ValidateSchemaKeyspaceRequest) ProtoReflect() protoreflect.Message

func (*ValidateSchemaKeyspaceRequest) Reset added in v0.14.0 

func (x *ValidateSchemaKeyspaceRequest) Reset()

func (*ValidateSchemaKeyspaceRequest) SizeVT added in v0.14.0 

func (m *ValidateSchemaKeyspaceRequest) SizeVT() (n int)

func (*ValidateSchemaKeyspaceRequest) String added in v0.14.0 

func (x *ValidateSchemaKeyspaceRequest) String() string

func (*ValidateSchemaKeyspaceRequest) UnmarshalVT added in v0.14.0 

func (m *ValidateSchemaKeyspaceRequest) UnmarshalVT(dAtA []byte) error

type ValidateShardRequest added in v0.15.0 

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 added in v0.18.0 

func (m *ValidateShardRequest) CloneMessageVT() proto.Message

func (*ValidateShardRequest) CloneVT added in v0.18.0 

func (m *ValidateShardRequest) CloneVT() *ValidateShardRequest

func (*ValidateShardRequest) Descriptor deprecated added in v0.15.0 

func (*ValidateShardRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateShardRequest.ProtoReflect.Descriptor instead.

func (*ValidateShardRequest) GetClusterId added in v0.15.0 

func (x *ValidateShardRequest) GetClusterId() string

func (*ValidateShardRequest) GetKeyspace added in v0.15.0 

func (x *ValidateShardRequest) GetKeyspace() string

func (*ValidateShardRequest) GetPingTablets added in v0.15.0 

func (x *ValidateShardRequest) GetPingTablets() bool

func (*ValidateShardRequest) GetShard added in v0.15.0 

func (x *ValidateShardRequest) GetShard() string

func (*ValidateShardRequest) MarshalToSizedBufferVT added in v0.15.0 

func (m *ValidateShardRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidateShardRequest) MarshalToVT added in v0.15.0 

func (m *ValidateShardRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ValidateShardRequest) MarshalVT added in v0.15.0 

func (m *ValidateShardRequest) MarshalVT() (dAtA []byte, err error)

func (*ValidateShardRequest) ProtoMessage added in v0.15.0 

func (*ValidateShardRequest) ProtoMessage()

func (*ValidateShardRequest) ProtoReflect added in v0.15.0 

func (x *ValidateShardRequest) ProtoReflect() protoreflect.Message

func (*ValidateShardRequest) Reset added in v0.15.0 

func (x *ValidateShardRequest) Reset()

func (*ValidateShardRequest) SizeVT added in v0.15.0 

func (m *ValidateShardRequest) SizeVT() (n int)

func (*ValidateShardRequest) String added in v0.15.0 

func (x *ValidateShardRequest) String() string

func (*ValidateShardRequest) UnmarshalVT added in v0.15.0 

func (m *ValidateShardRequest) UnmarshalVT(dAtA []byte) error

type ValidateVersionKeyspaceRequest added in v0.14.0 

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 added in v0.18.0 

func (m *ValidateVersionKeyspaceRequest) CloneMessageVT() proto.Message

func (*ValidateVersionKeyspaceRequest) CloneVT added in v0.18.0 

func (m *ValidateVersionKeyspaceRequest) CloneVT() *ValidateVersionKeyspaceRequest

func (*ValidateVersionKeyspaceRequest) Descriptor deprecated added in v0.14.0 

func (*ValidateVersionKeyspaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateVersionKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*ValidateVersionKeyspaceRequest) GetClusterId added in v0.14.0 

func (x *ValidateVersionKeyspaceRequest) GetClusterId() string

func (*ValidateVersionKeyspaceRequest) GetKeyspace added in v0.14.0 

func (x *ValidateVersionKeyspaceRequest) GetKeyspace() string

func (*ValidateVersionKeyspaceRequest) MarshalToSizedBufferVT added in v0.14.0 

func (m *ValidateVersionKeyspaceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidateVersionKeyspaceRequest) MarshalToVT added in v0.14.0 

func (m *ValidateVersionKeyspaceRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ValidateVersionKeyspaceRequest) MarshalVT added in v0.14.0 

func (m *ValidateVersionKeyspaceRequest) MarshalVT() (dAtA []byte, err error)

func (*ValidateVersionKeyspaceRequest) ProtoMessage added in v0.14.0 

func (*ValidateVersionKeyspaceRequest) ProtoMessage()

func (*ValidateVersionKeyspaceRequest) ProtoReflect added in v0.14.0 

func (x *ValidateVersionKeyspaceRequest) ProtoReflect() protoreflect.Message

func (*ValidateVersionKeyspaceRequest) Reset added in v0.14.0 

func (x *ValidateVersionKeyspaceRequest) Reset()

func (*ValidateVersionKeyspaceRequest) SizeVT added in v0.14.0 

func (m *ValidateVersionKeyspaceRequest) SizeVT() (n int)

func (*ValidateVersionKeyspaceRequest) String added in v0.14.0 

func (x *ValidateVersionKeyspaceRequest) String() string

func (*ValidateVersionKeyspaceRequest) UnmarshalVT added in v0.14.0 

func (m *ValidateVersionKeyspaceRequest) UnmarshalVT(dAtA []byte) error

type ValidateVersionShardRequest added in v0.15.0 

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 added in v0.18.0 

func (m *ValidateVersionShardRequest) CloneMessageVT() proto.Message

func (*ValidateVersionShardRequest) CloneVT added in v0.18.0 

func (m *ValidateVersionShardRequest) CloneVT() *ValidateVersionShardRequest

func (*ValidateVersionShardRequest) Descriptor deprecated added in v0.15.0 

func (*ValidateVersionShardRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateVersionShardRequest.ProtoReflect.Descriptor instead.

func (*ValidateVersionShardRequest) GetClusterId added in v0.15.0 

func (x *ValidateVersionShardRequest) GetClusterId() string

func (*ValidateVersionShardRequest) GetKeyspace added in v0.15.0 

func (x *ValidateVersionShardRequest) GetKeyspace() string

func (*ValidateVersionShardRequest) GetShard added in v0.15.0 

func (x *ValidateVersionShardRequest) GetShard() string

func (*ValidateVersionShardRequest) MarshalToSizedBufferVT added in v0.15.0 

func (m *ValidateVersionShardRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidateVersionShardRequest) MarshalToVT added in v0.15.0 

func (m *ValidateVersionShardRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ValidateVersionShardRequest) MarshalVT added in v0.15.0 

func (m *ValidateVersionShardRequest) MarshalVT() (dAtA []byte, err error)

func (*ValidateVersionShardRequest) ProtoMessage added in v0.15.0 

func (*ValidateVersionShardRequest) ProtoMessage()

func (*ValidateVersionShardRequest) ProtoReflect added in v0.15.0 

func (x *ValidateVersionShardRequest) ProtoReflect() protoreflect.Message

func (*ValidateVersionShardRequest) Reset added in v0.15.0 

func (x *ValidateVersionShardRequest) Reset()

func (*ValidateVersionShardRequest) SizeVT added in v0.15.0 

func (m *ValidateVersionShardRequest) SizeVT() (n int)

func (*ValidateVersionShardRequest) String added in v0.15.0 

func (x *ValidateVersionShardRequest) String() string

func (*ValidateVersionShardRequest) UnmarshalVT added in v0.15.0 

func (m *ValidateVersionShardRequest) UnmarshalVT(dAtA []byte) error

type Vtctld added in v0.10.0 

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 added in v0.18.0 

func (m *Vtctld) CloneMessageVT() proto.Message

func (*Vtctld) CloneVT added in v0.18.0 

func (m *Vtctld) CloneVT() *Vtctld

func (*Vtctld) Descriptor deprecated added in v0.10.0 

func (*Vtctld) Descriptor() ([]byte, []int)

Deprecated: Use Vtctld.ProtoReflect.Descriptor instead.

func (*Vtctld) GetCluster added in v0.10.0 

func (x *Vtctld) GetCluster() *Cluster

func (*Vtctld) GetFQDN added in v0.11.0 

func (x *Vtctld) GetFQDN() string

func (*Vtctld) GetHostname added in v0.10.0 

func (x *Vtctld) GetHostname() string

func (*Vtctld) MarshalToSizedBufferVT added in v0.11.0 

func (m *Vtctld) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Vtctld) MarshalToVT added in v0.11.0 

func (m *Vtctld) MarshalToVT(dAtA []byte) (int, error)

func (*Vtctld) MarshalVT added in v0.11.0 

func (m *Vtctld) MarshalVT() (dAtA []byte, err error)

func (*Vtctld) ProtoMessage added in v0.10.0 

func (*Vtctld) ProtoMessage()

func (*Vtctld) ProtoReflect added in v0.11.0 

func (x *Vtctld) ProtoReflect() protoreflect.Message

func (*Vtctld) Reset added in v0.10.0 

func (x *Vtctld) Reset()

func (*Vtctld) SizeVT added in v0.11.0 

func (m *Vtctld) SizeVT() (n int)

func (*Vtctld) String added in v0.10.0 

func (x *Vtctld) String() string

func (*Vtctld) UnmarshalVT added in v0.11.0 

func (m *Vtctld) UnmarshalVT(dAtA []byte) error

type Workflow added in v0.10.0 

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 added in v0.18.0 

func (m *Workflow) CloneMessageVT() proto.Message

func (*Workflow) CloneVT added in v0.18.0 

func (m *Workflow) CloneVT() *Workflow

func (*Workflow) Descriptor deprecated added in v0.10.0 

func (*Workflow) Descriptor() ([]byte, []int)

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetCluster added in v0.10.0 

func (x *Workflow) GetCluster() *Cluster

func (*Workflow) GetKeyspace added in v0.10.0 

func (x *Workflow) GetKeyspace() string

func (*Workflow) GetWorkflow added in v0.10.0 

func (x *Workflow) GetWorkflow() *vtctldata.Workflow

func (*Workflow) MarshalToSizedBufferVT added in v0.11.0 

func (m *Workflow) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Workflow) MarshalToVT added in v0.11.0 

func (m *Workflow) MarshalToVT(dAtA []byte) (int, error)

func (*Workflow) MarshalVT added in v0.11.0 

func (m *Workflow) MarshalVT() (dAtA []byte, err error)

func (*Workflow) ProtoMessage added in v0.10.0 

func (*Workflow) ProtoMessage()

func (*Workflow) ProtoReflect added in v0.11.0 

func (x *Workflow) ProtoReflect() protoreflect.Message

func (*Workflow) Reset added in v0.10.0 

func (x *Workflow) Reset()

func (*Workflow) SizeVT added in v0.11.0 

func (m *Workflow) SizeVT() (n int)

func (*Workflow) String added in v0.10.0 

func (x *Workflow) String() string

func (*Workflow) UnmarshalVT added in v0.11.0 

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.