vtadmin

package
v0.13.3 Latest Latest
Warning

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

 Go to latest Published: Sep 1, 2022 License: Apache-2.0 Imports: 16 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: "FindSchema",
			Handler:    _VTAdmin_FindSchema_Handler,
		},
		{
			MethodName: "GetBackups",
			Handler:    _VTAdmin_GetBackups_Handler,
		},
		{
			MethodName: "GetClusters",
			Handler:    _VTAdmin_GetClusters_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: "GetSrvVSchema",
			Handler:    _VTAdmin_GetSrvVSchema_Handler,
		},
		{
			MethodName: "GetSrvVSchemas",
			Handler:    _VTAdmin_GetSrvVSchemas_Handler,
		},
		{
			MethodName: "GetTablet",
			Handler:    _VTAdmin_GetTablet_Handler,
		},
		{
			MethodName: "GetTablets",
			Handler:    _VTAdmin_GetTablets_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: "RefreshState",
			Handler:    _VTAdmin_RefreshState_Handler,
		},
		{
			MethodName: "ReparentTablet",
			Handler:    _VTAdmin_ReparentTablet_Handler,
		},
		{
			MethodName: "RunHealthCheck",
			Handler:    _VTAdmin_RunHealthCheck_Handler,
		},
		{
			MethodName: "StartReplication",
			Handler:    _VTAdmin_StartReplication_Handler,
		},
		{
			MethodName: "StopReplication",
			Handler:    _VTAdmin_StopReplication_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) 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) 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 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) 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) 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) 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) 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) 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) 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) 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      string   `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 (*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() string

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

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

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

Deprecated: Use DeleteTabletResponse.ProtoReflect.Descriptor instead.

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 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) 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) 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) 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 GetClustersRequest added in v0.10.0 

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

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) 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 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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 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) 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) 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) 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 of the standard form: "$cell-$uid"
	Alias string `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 disamiguate 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) 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() string

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) 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) 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 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) 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) 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) 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) 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) 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) 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) 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) 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) 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 string `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 disamiguate 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) 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() string

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

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

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

Deprecated: Use PingTabletResponse.ProtoReflect.Descriptor instead.

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

type RefreshStateRequest struct {
	Alias      string   `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) 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() string

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

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

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

Deprecated: Use RefreshStateResponse.ProtoReflect.Descriptor instead.

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

type ReparentTabletRequest struct {
	Alias      string   `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 (*ReparentTabletRequest) Descriptor deprecated added in v0.13.0 

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

Deprecated: Use ReparentTabletRequest.ProtoReflect.Descriptor instead.

func (*ReparentTabletRequest) GetAlias added in v0.13.0 

func (x *ReparentTabletRequest) GetAlias() string

func (*ReparentTabletRequest) GetClusterIds added in v0.13.0 

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

func (*ReparentTabletRequest) MarshalToSizedBufferVT added in v0.13.0 

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

func (*ReparentTabletRequest) MarshalToVT added in v0.13.0 

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

func (*ReparentTabletRequest) MarshalVT added in v0.13.0 

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

func (*ReparentTabletRequest) ProtoMessage added in v0.13.0 

func (*ReparentTabletRequest) ProtoMessage()

func (*ReparentTabletRequest) ProtoReflect added in v0.13.0 

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

func (*ReparentTabletRequest) Reset added in v0.13.0 

func (x *ReparentTabletRequest) Reset()

func (*ReparentTabletRequest) SizeVT added in v0.13.0 

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

func (*ReparentTabletRequest) String added in v0.13.0 

func (x *ReparentTabletRequest) String() string

func (*ReparentTabletRequest) UnmarshalVT added in v0.13.0 

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

type ReparentTabletResponse added in v0.13.0 

type ReparentTabletResponse 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  string `protobuf:"bytes,3,opt,name=primary,proto3" json:"primary,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ReparentTabletResponse.ProtoReflect.Descriptor instead.

func (*ReparentTabletResponse) GetKeyspace added in v0.13.0 

func (x *ReparentTabletResponse) GetKeyspace() string

func (*ReparentTabletResponse) GetPrimary added in v0.13.0 

func (x *ReparentTabletResponse) GetPrimary() string

func (*ReparentTabletResponse) GetShard added in v0.13.0 

func (x *ReparentTabletResponse) GetShard() string

func (*ReparentTabletResponse) MarshalToSizedBufferVT added in v0.13.0 

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

func (*ReparentTabletResponse) MarshalToVT added in v0.13.0 

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

func (*ReparentTabletResponse) MarshalVT added in v0.13.0 

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

func (*ReparentTabletResponse) ProtoMessage added in v0.13.0 

func (*ReparentTabletResponse) ProtoMessage()

func (*ReparentTabletResponse) ProtoReflect added in v0.13.0 

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

func (*ReparentTabletResponse) Reset added in v0.13.0 

func (x *ReparentTabletResponse) Reset()

func (*ReparentTabletResponse) SizeVT added in v0.13.0 

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

func (*ReparentTabletResponse) String added in v0.13.0 

func (x *ReparentTabletResponse) String() string

func (*ReparentTabletResponse) UnmarshalVT added in v0.13.0 

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

type RunHealthCheckRequest added in v0.13.0 

type RunHealthCheckRequest struct {
	Alias      string   `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) 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() string

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

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

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

Deprecated: Use RunHealthCheckResponse.ProtoReflect.Descriptor instead.

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) 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) 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) 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 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) 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      string   `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) 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() string

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

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

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

Deprecated: Use StartReplicationResponse.ProtoReflect.Descriptor instead.

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      string   `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) 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() string

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

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

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

Deprecated: Use StopReplicationResponse.ProtoReflect.Descriptor instead.

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) 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 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) 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) GetClusters added in v0.10.0 

func (UnimplementedVTAdminServer) GetClusters(context.Context, *GetClustersRequest) (*GetClustersResponse, 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) 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) 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) RefreshState added in v0.13.0 

func (UnimplementedVTAdminServer) RefreshState(context.Context, *RefreshStateRequest) (*RefreshStateResponse, error)

func (UnimplementedVTAdminServer) ReparentTablet added in v0.13.0 

func (UnimplementedVTAdminServer) ReparentTablet(context.Context, *ReparentTabletRequest) (*ReparentTabletResponse, error)

func (UnimplementedVTAdminServer) RunHealthCheck added in v0.13.0 

func (UnimplementedVTAdminServer) RunHealthCheck(context.Context, *RunHealthCheckRequest) (*RunHealthCheckResponse, 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) VTExplain added in v0.10.0 

func (UnimplementedVTAdminServer) VTExplain(context.Context, *VTExplainRequest) (*VTExplainResponse, 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) 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)
	// 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)
	// GetClusters returns all configured clusters.
	GetClusters(ctx context.Context, in *GetClustersRequest, opts ...grpc.CallOption) (*GetClustersResponse, 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)
	// 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)
	// 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)
	// RefreshState reloads the tablet record on the specified tablet.
	RefreshState(ctx context.Context, in *RefreshStateRequest, opts ...grpc.CallOption) (*RefreshStateResponse, error)
	// ReparentTablet
	ReparentTablet(ctx context.Context, in *ReparentTabletRequest, opts ...grpc.CallOption) (*ReparentTabletResponse, error)
	// RunHealthCheck runs a health check on the tablet
	RunHealthCheck(ctx context.Context, in *RunHealthCheckRequest, opts ...grpc.CallOption) (*RunHealthCheckResponse, error)
	// StartReplication will run the underlying database command to start replication on a tablet
	StartReplication(ctx context.Context, in *StartReplicationRequest, opts ...grpc.CallOption) (*StartReplicationResponse, error)
	// StopReplication will run th underlying database command to stop replication on a tablet
	StopReplication(ctx context.Context, in *StopReplicationRequest, opts ...grpc.CallOption) (*StopReplicationResponse, 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)
	// 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)
	// GetClusters returns all configured clusters.
	GetClusters(context.Context, *GetClustersRequest) (*GetClustersResponse, 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)
	// 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)
	// 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)
	// RefreshState reloads the tablet record on the specified tablet.
	RefreshState(context.Context, *RefreshStateRequest) (*RefreshStateResponse, error)
	// ReparentTablet
	ReparentTablet(context.Context, *ReparentTabletRequest) (*ReparentTabletResponse, error)
	// RunHealthCheck runs a health check on the tablet
	RunHealthCheck(context.Context, *RunHealthCheckRequest) (*RunHealthCheckResponse, error)
	// StartReplication will run the underlying database command to start replication on a tablet
	StartReplication(context.Context, *StartReplicationRequest) (*StartReplicationResponse, error)
	// StopReplication will run th underlying database command to stop replication on a tablet
	StopReplication(context.Context, *StopReplicationRequest) (*StopReplicationResponse, 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) 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) 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) 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 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) 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) 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.