vtctlservicev17grpc

package
v1.3.0-20231211191728-... Latest Latest
Warning

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

 Go to latest Published: unknown License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Vtctld_AddCellInfo_FullMethodName                 = "/vitess.vtctlservice.v17.Vtctld/AddCellInfo"
	Vtctld_AddCellsAlias_FullMethodName               = "/vitess.vtctlservice.v17.Vtctld/AddCellsAlias"
	Vtctld_ApplyRoutingRules_FullMethodName           = "/vitess.vtctlservice.v17.Vtctld/ApplyRoutingRules"
	Vtctld_ApplySchema_FullMethodName                 = "/vitess.vtctlservice.v17.Vtctld/ApplySchema"
	Vtctld_ApplyShardRoutingRules_FullMethodName      = "/vitess.vtctlservice.v17.Vtctld/ApplyShardRoutingRules"
	Vtctld_ApplyVSchema_FullMethodName                = "/vitess.vtctlservice.v17.Vtctld/ApplyVSchema"
	Vtctld_Backup_FullMethodName                      = "/vitess.vtctlservice.v17.Vtctld/Backup"
	Vtctld_BackupShard_FullMethodName                 = "/vitess.vtctlservice.v17.Vtctld/BackupShard"
	Vtctld_ChangeTabletType_FullMethodName            = "/vitess.vtctlservice.v17.Vtctld/ChangeTabletType"
	Vtctld_CreateKeyspace_FullMethodName              = "/vitess.vtctlservice.v17.Vtctld/CreateKeyspace"
	Vtctld_CreateShard_FullMethodName                 = "/vitess.vtctlservice.v17.Vtctld/CreateShard"
	Vtctld_DeleteCellInfo_FullMethodName              = "/vitess.vtctlservice.v17.Vtctld/DeleteCellInfo"
	Vtctld_DeleteCellsAlias_FullMethodName            = "/vitess.vtctlservice.v17.Vtctld/DeleteCellsAlias"
	Vtctld_DeleteKeyspace_FullMethodName              = "/vitess.vtctlservice.v17.Vtctld/DeleteKeyspace"
	Vtctld_DeleteShards_FullMethodName                = "/vitess.vtctlservice.v17.Vtctld/DeleteShards"
	Vtctld_DeleteSrvVSchema_FullMethodName            = "/vitess.vtctlservice.v17.Vtctld/DeleteSrvVSchema"
	Vtctld_DeleteTablets_FullMethodName               = "/vitess.vtctlservice.v17.Vtctld/DeleteTablets"
	Vtctld_EmergencyReparentShard_FullMethodName      = "/vitess.vtctlservice.v17.Vtctld/EmergencyReparentShard"
	Vtctld_ExecuteFetchAsApp_FullMethodName           = "/vitess.vtctlservice.v17.Vtctld/ExecuteFetchAsApp"
	Vtctld_ExecuteFetchAsDBA_FullMethodName           = "/vitess.vtctlservice.v17.Vtctld/ExecuteFetchAsDBA"
	Vtctld_ExecuteHook_FullMethodName                 = "/vitess.vtctlservice.v17.Vtctld/ExecuteHook"
	Vtctld_FindAllShardsInKeyspace_FullMethodName     = "/vitess.vtctlservice.v17.Vtctld/FindAllShardsInKeyspace"
	Vtctld_GetBackups_FullMethodName                  = "/vitess.vtctlservice.v17.Vtctld/GetBackups"
	Vtctld_GetCellInfo_FullMethodName                 = "/vitess.vtctlservice.v17.Vtctld/GetCellInfo"
	Vtctld_GetCellInfoNames_FullMethodName            = "/vitess.vtctlservice.v17.Vtctld/GetCellInfoNames"
	Vtctld_GetCellsAliases_FullMethodName             = "/vitess.vtctlservice.v17.Vtctld/GetCellsAliases"
	Vtctld_GetFullStatus_FullMethodName               = "/vitess.vtctlservice.v17.Vtctld/GetFullStatus"
	Vtctld_GetKeyspace_FullMethodName                 = "/vitess.vtctlservice.v17.Vtctld/GetKeyspace"
	Vtctld_GetKeyspaces_FullMethodName                = "/vitess.vtctlservice.v17.Vtctld/GetKeyspaces"
	Vtctld_GetPermissions_FullMethodName              = "/vitess.vtctlservice.v17.Vtctld/GetPermissions"
	Vtctld_GetRoutingRules_FullMethodName             = "/vitess.vtctlservice.v17.Vtctld/GetRoutingRules"
	Vtctld_GetSchema_FullMethodName                   = "/vitess.vtctlservice.v17.Vtctld/GetSchema"
	Vtctld_GetShard_FullMethodName                    = "/vitess.vtctlservice.v17.Vtctld/GetShard"
	Vtctld_GetShardRoutingRules_FullMethodName        = "/vitess.vtctlservice.v17.Vtctld/GetShardRoutingRules"
	Vtctld_GetSrvKeyspaceNames_FullMethodName         = "/vitess.vtctlservice.v17.Vtctld/GetSrvKeyspaceNames"
	Vtctld_GetSrvKeyspaces_FullMethodName             = "/vitess.vtctlservice.v17.Vtctld/GetSrvKeyspaces"
	Vtctld_UpdateThrottlerConfig_FullMethodName       = "/vitess.vtctlservice.v17.Vtctld/UpdateThrottlerConfig"
	Vtctld_GetSrvVSchema_FullMethodName               = "/vitess.vtctlservice.v17.Vtctld/GetSrvVSchema"
	Vtctld_GetSrvVSchemas_FullMethodName              = "/vitess.vtctlservice.v17.Vtctld/GetSrvVSchemas"
	Vtctld_GetTablet_FullMethodName                   = "/vitess.vtctlservice.v17.Vtctld/GetTablet"
	Vtctld_GetTablets_FullMethodName                  = "/vitess.vtctlservice.v17.Vtctld/GetTablets"
	Vtctld_GetTopologyPath_FullMethodName             = "/vitess.vtctlservice.v17.Vtctld/GetTopologyPath"
	Vtctld_GetVersion_FullMethodName                  = "/vitess.vtctlservice.v17.Vtctld/GetVersion"
	Vtctld_GetVSchema_FullMethodName                  = "/vitess.vtctlservice.v17.Vtctld/GetVSchema"
	Vtctld_GetWorkflows_FullMethodName                = "/vitess.vtctlservice.v17.Vtctld/GetWorkflows"
	Vtctld_InitShardPrimary_FullMethodName            = "/vitess.vtctlservice.v17.Vtctld/InitShardPrimary"
	Vtctld_PingTablet_FullMethodName                  = "/vitess.vtctlservice.v17.Vtctld/PingTablet"
	Vtctld_PlannedReparentShard_FullMethodName        = "/vitess.vtctlservice.v17.Vtctld/PlannedReparentShard"
	Vtctld_RebuildKeyspaceGraph_FullMethodName        = "/vitess.vtctlservice.v17.Vtctld/RebuildKeyspaceGraph"
	Vtctld_RebuildVSchemaGraph_FullMethodName         = "/vitess.vtctlservice.v17.Vtctld/RebuildVSchemaGraph"
	Vtctld_RefreshState_FullMethodName                = "/vitess.vtctlservice.v17.Vtctld/RefreshState"
	Vtctld_RefreshStateByShard_FullMethodName         = "/vitess.vtctlservice.v17.Vtctld/RefreshStateByShard"
	Vtctld_ReloadSchema_FullMethodName                = "/vitess.vtctlservice.v17.Vtctld/ReloadSchema"
	Vtctld_ReloadSchemaKeyspace_FullMethodName        = "/vitess.vtctlservice.v17.Vtctld/ReloadSchemaKeyspace"
	Vtctld_ReloadSchemaShard_FullMethodName           = "/vitess.vtctlservice.v17.Vtctld/ReloadSchemaShard"
	Vtctld_RemoveBackup_FullMethodName                = "/vitess.vtctlservice.v17.Vtctld/RemoveBackup"
	Vtctld_RemoveKeyspaceCell_FullMethodName          = "/vitess.vtctlservice.v17.Vtctld/RemoveKeyspaceCell"
	Vtctld_RemoveShardCell_FullMethodName             = "/vitess.vtctlservice.v17.Vtctld/RemoveShardCell"
	Vtctld_ReparentTablet_FullMethodName              = "/vitess.vtctlservice.v17.Vtctld/ReparentTablet"
	Vtctld_RestoreFromBackup_FullMethodName           = "/vitess.vtctlservice.v17.Vtctld/RestoreFromBackup"
	Vtctld_RunHealthCheck_FullMethodName              = "/vitess.vtctlservice.v17.Vtctld/RunHealthCheck"
	Vtctld_SetKeyspaceDurabilityPolicy_FullMethodName = "/vitess.vtctlservice.v17.Vtctld/SetKeyspaceDurabilityPolicy"
	Vtctld_SetShardIsPrimaryServing_FullMethodName    = "/vitess.vtctlservice.v17.Vtctld/SetShardIsPrimaryServing"
	Vtctld_SetShardTabletControl_FullMethodName       = "/vitess.vtctlservice.v17.Vtctld/SetShardTabletControl"
	Vtctld_SetWritable_FullMethodName                 = "/vitess.vtctlservice.v17.Vtctld/SetWritable"
	Vtctld_ShardReplicationAdd_FullMethodName         = "/vitess.vtctlservice.v17.Vtctld/ShardReplicationAdd"
	Vtctld_ShardReplicationFix_FullMethodName         = "/vitess.vtctlservice.v17.Vtctld/ShardReplicationFix"
	Vtctld_ShardReplicationPositions_FullMethodName   = "/vitess.vtctlservice.v17.Vtctld/ShardReplicationPositions"
	Vtctld_ShardReplicationRemove_FullMethodName      = "/vitess.vtctlservice.v17.Vtctld/ShardReplicationRemove"
	Vtctld_SleepTablet_FullMethodName                 = "/vitess.vtctlservice.v17.Vtctld/SleepTablet"
	Vtctld_SourceShardAdd_FullMethodName              = "/vitess.vtctlservice.v17.Vtctld/SourceShardAdd"
	Vtctld_SourceShardDelete_FullMethodName           = "/vitess.vtctlservice.v17.Vtctld/SourceShardDelete"
	Vtctld_StartReplication_FullMethodName            = "/vitess.vtctlservice.v17.Vtctld/StartReplication"
	Vtctld_StopReplication_FullMethodName             = "/vitess.vtctlservice.v17.Vtctld/StopReplication"
	Vtctld_TabletExternallyReparented_FullMethodName  = "/vitess.vtctlservice.v17.Vtctld/TabletExternallyReparented"
	Vtctld_UpdateCellInfo_FullMethodName              = "/vitess.vtctlservice.v17.Vtctld/UpdateCellInfo"
	Vtctld_UpdateCellsAlias_FullMethodName            = "/vitess.vtctlservice.v17.Vtctld/UpdateCellsAlias"
	Vtctld_Validate_FullMethodName                    = "/vitess.vtctlservice.v17.Vtctld/Validate"
	Vtctld_ValidateKeyspace_FullMethodName            = "/vitess.vtctlservice.v17.Vtctld/ValidateKeyspace"
	Vtctld_ValidateSchemaKeyspace_FullMethodName      = "/vitess.vtctlservice.v17.Vtctld/ValidateSchemaKeyspace"
	Vtctld_ValidateShard_FullMethodName               = "/vitess.vtctlservice.v17.Vtctld/ValidateShard"
	Vtctld_ValidateVersionKeyspace_FullMethodName     = "/vitess.vtctlservice.v17.Vtctld/ValidateVersionKeyspace"
	Vtctld_ValidateVersionShard_FullMethodName        = "/vitess.vtctlservice.v17.Vtctld/ValidateVersionShard"
	Vtctld_ValidateVSchema_FullMethodName             = "/vitess.vtctlservice.v17.Vtctld/ValidateVSchema"
	Vtctld_WorkflowUpdate_FullMethodName              = "/vitess.vtctlservice.v17.Vtctld/WorkflowUpdate"
)
View Source 
const (
	Vtctl_ExecuteVtctlCommand_FullMethodName = "/vitess.vtctlservice.v17.Vtctl/ExecuteVtctlCommand"
)

Variables

View Source 
var Vtctl_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vitess.vtctlservice.v17.Vtctl",
	HandlerType: (*VtctlServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExecuteVtctlCommand",
			Handler:       _Vtctl_ExecuteVtctlCommand_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "vitess/vtctlservice/v17/vtctlservice.proto",
}

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

View Source 
var Vtctld_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vitess.vtctlservice.v17.Vtctld",
	HandlerType: (*VtctldServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddCellInfo",
			Handler:    _Vtctld_AddCellInfo_Handler,
		},
		{
			MethodName: "AddCellsAlias",
			Handler:    _Vtctld_AddCellsAlias_Handler,
		},
		{
			MethodName: "ApplyRoutingRules",
			Handler:    _Vtctld_ApplyRoutingRules_Handler,
		},
		{
			MethodName: "ApplySchema",
			Handler:    _Vtctld_ApplySchema_Handler,
		},
		{
			MethodName: "ApplyShardRoutingRules",
			Handler:    _Vtctld_ApplyShardRoutingRules_Handler,
		},
		{
			MethodName: "ApplyVSchema",
			Handler:    _Vtctld_ApplyVSchema_Handler,
		},
		{
			MethodName: "ChangeTabletType",
			Handler:    _Vtctld_ChangeTabletType_Handler,
		},
		{
			MethodName: "CreateKeyspace",
			Handler:    _Vtctld_CreateKeyspace_Handler,
		},
		{
			MethodName: "CreateShard",
			Handler:    _Vtctld_CreateShard_Handler,
		},
		{
			MethodName: "DeleteCellInfo",
			Handler:    _Vtctld_DeleteCellInfo_Handler,
		},
		{
			MethodName: "DeleteCellsAlias",
			Handler:    _Vtctld_DeleteCellsAlias_Handler,
		},
		{
			MethodName: "DeleteKeyspace",
			Handler:    _Vtctld_DeleteKeyspace_Handler,
		},
		{
			MethodName: "DeleteShards",
			Handler:    _Vtctld_DeleteShards_Handler,
		},
		{
			MethodName: "DeleteSrvVSchema",
			Handler:    _Vtctld_DeleteSrvVSchema_Handler,
		},
		{
			MethodName: "DeleteTablets",
			Handler:    _Vtctld_DeleteTablets_Handler,
		},
		{
			MethodName: "EmergencyReparentShard",
			Handler:    _Vtctld_EmergencyReparentShard_Handler,
		},
		{
			MethodName: "ExecuteFetchAsApp",
			Handler:    _Vtctld_ExecuteFetchAsApp_Handler,
		},
		{
			MethodName: "ExecuteFetchAsDBA",
			Handler:    _Vtctld_ExecuteFetchAsDBA_Handler,
		},
		{
			MethodName: "ExecuteHook",
			Handler:    _Vtctld_ExecuteHook_Handler,
		},
		{
			MethodName: "FindAllShardsInKeyspace",
			Handler:    _Vtctld_FindAllShardsInKeyspace_Handler,
		},
		{
			MethodName: "GetBackups",
			Handler:    _Vtctld_GetBackups_Handler,
		},
		{
			MethodName: "GetCellInfo",
			Handler:    _Vtctld_GetCellInfo_Handler,
		},
		{
			MethodName: "GetCellInfoNames",
			Handler:    _Vtctld_GetCellInfoNames_Handler,
		},
		{
			MethodName: "GetCellsAliases",
			Handler:    _Vtctld_GetCellsAliases_Handler,
		},
		{
			MethodName: "GetFullStatus",
			Handler:    _Vtctld_GetFullStatus_Handler,
		},
		{
			MethodName: "GetKeyspace",
			Handler:    _Vtctld_GetKeyspace_Handler,
		},
		{
			MethodName: "GetKeyspaces",
			Handler:    _Vtctld_GetKeyspaces_Handler,
		},
		{
			MethodName: "GetPermissions",
			Handler:    _Vtctld_GetPermissions_Handler,
		},
		{
			MethodName: "GetRoutingRules",
			Handler:    _Vtctld_GetRoutingRules_Handler,
		},
		{
			MethodName: "GetSchema",
			Handler:    _Vtctld_GetSchema_Handler,
		},
		{
			MethodName: "GetShard",
			Handler:    _Vtctld_GetShard_Handler,
		},
		{
			MethodName: "GetShardRoutingRules",
			Handler:    _Vtctld_GetShardRoutingRules_Handler,
		},
		{
			MethodName: "GetSrvKeyspaceNames",
			Handler:    _Vtctld_GetSrvKeyspaceNames_Handler,
		},
		{
			MethodName: "GetSrvKeyspaces",
			Handler:    _Vtctld_GetSrvKeyspaces_Handler,
		},
		{
			MethodName: "UpdateThrottlerConfig",
			Handler:    _Vtctld_UpdateThrottlerConfig_Handler,
		},
		{
			MethodName: "GetSrvVSchema",
			Handler:    _Vtctld_GetSrvVSchema_Handler,
		},
		{
			MethodName: "GetSrvVSchemas",
			Handler:    _Vtctld_GetSrvVSchemas_Handler,
		},
		{
			MethodName: "GetTablet",
			Handler:    _Vtctld_GetTablet_Handler,
		},
		{
			MethodName: "GetTablets",
			Handler:    _Vtctld_GetTablets_Handler,
		},
		{
			MethodName: "GetTopologyPath",
			Handler:    _Vtctld_GetTopologyPath_Handler,
		},
		{
			MethodName: "GetVersion",
			Handler:    _Vtctld_GetVersion_Handler,
		},
		{
			MethodName: "GetVSchema",
			Handler:    _Vtctld_GetVSchema_Handler,
		},
		{
			MethodName: "GetWorkflows",
			Handler:    _Vtctld_GetWorkflows_Handler,
		},
		{
			MethodName: "InitShardPrimary",
			Handler:    _Vtctld_InitShardPrimary_Handler,
		},
		{
			MethodName: "PingTablet",
			Handler:    _Vtctld_PingTablet_Handler,
		},
		{
			MethodName: "PlannedReparentShard",
			Handler:    _Vtctld_PlannedReparentShard_Handler,
		},
		{
			MethodName: "RebuildKeyspaceGraph",
			Handler:    _Vtctld_RebuildKeyspaceGraph_Handler,
		},
		{
			MethodName: "RebuildVSchemaGraph",
			Handler:    _Vtctld_RebuildVSchemaGraph_Handler,
		},
		{
			MethodName: "RefreshState",
			Handler:    _Vtctld_RefreshState_Handler,
		},
		{
			MethodName: "RefreshStateByShard",
			Handler:    _Vtctld_RefreshStateByShard_Handler,
		},
		{
			MethodName: "ReloadSchema",
			Handler:    _Vtctld_ReloadSchema_Handler,
		},
		{
			MethodName: "ReloadSchemaKeyspace",
			Handler:    _Vtctld_ReloadSchemaKeyspace_Handler,
		},
		{
			MethodName: "ReloadSchemaShard",
			Handler:    _Vtctld_ReloadSchemaShard_Handler,
		},
		{
			MethodName: "RemoveBackup",
			Handler:    _Vtctld_RemoveBackup_Handler,
		},
		{
			MethodName: "RemoveKeyspaceCell",
			Handler:    _Vtctld_RemoveKeyspaceCell_Handler,
		},
		{
			MethodName: "RemoveShardCell",
			Handler:    _Vtctld_RemoveShardCell_Handler,
		},
		{
			MethodName: "ReparentTablet",
			Handler:    _Vtctld_ReparentTablet_Handler,
		},
		{
			MethodName: "RunHealthCheck",
			Handler:    _Vtctld_RunHealthCheck_Handler,
		},
		{
			MethodName: "SetKeyspaceDurabilityPolicy",
			Handler:    _Vtctld_SetKeyspaceDurabilityPolicy_Handler,
		},
		{
			MethodName: "SetShardIsPrimaryServing",
			Handler:    _Vtctld_SetShardIsPrimaryServing_Handler,
		},
		{
			MethodName: "SetShardTabletControl",
			Handler:    _Vtctld_SetShardTabletControl_Handler,
		},
		{
			MethodName: "SetWritable",
			Handler:    _Vtctld_SetWritable_Handler,
		},
		{
			MethodName: "ShardReplicationAdd",
			Handler:    _Vtctld_ShardReplicationAdd_Handler,
		},
		{
			MethodName: "ShardReplicationFix",
			Handler:    _Vtctld_ShardReplicationFix_Handler,
		},
		{
			MethodName: "ShardReplicationPositions",
			Handler:    _Vtctld_ShardReplicationPositions_Handler,
		},
		{
			MethodName: "ShardReplicationRemove",
			Handler:    _Vtctld_ShardReplicationRemove_Handler,
		},
		{
			MethodName: "SleepTablet",
			Handler:    _Vtctld_SleepTablet_Handler,
		},
		{
			MethodName: "SourceShardAdd",
			Handler:    _Vtctld_SourceShardAdd_Handler,
		},
		{
			MethodName: "SourceShardDelete",
			Handler:    _Vtctld_SourceShardDelete_Handler,
		},
		{
			MethodName: "StartReplication",
			Handler:    _Vtctld_StartReplication_Handler,
		},
		{
			MethodName: "StopReplication",
			Handler:    _Vtctld_StopReplication_Handler,
		},
		{
			MethodName: "TabletExternallyReparented",
			Handler:    _Vtctld_TabletExternallyReparented_Handler,
		},
		{
			MethodName: "UpdateCellInfo",
			Handler:    _Vtctld_UpdateCellInfo_Handler,
		},
		{
			MethodName: "UpdateCellsAlias",
			Handler:    _Vtctld_UpdateCellsAlias_Handler,
		},
		{
			MethodName: "Validate",
			Handler:    _Vtctld_Validate_Handler,
		},
		{
			MethodName: "ValidateKeyspace",
			Handler:    _Vtctld_ValidateKeyspace_Handler,
		},
		{
			MethodName: "ValidateSchemaKeyspace",
			Handler:    _Vtctld_ValidateSchemaKeyspace_Handler,
		},
		{
			MethodName: "ValidateShard",
			Handler:    _Vtctld_ValidateShard_Handler,
		},
		{
			MethodName: "ValidateVersionKeyspace",
			Handler:    _Vtctld_ValidateVersionKeyspace_Handler,
		},
		{
			MethodName: "ValidateVersionShard",
			Handler:    _Vtctld_ValidateVersionShard_Handler,
		},
		{
			MethodName: "ValidateVSchema",
			Handler:    _Vtctld_ValidateVSchema_Handler,
		},
		{
			MethodName: "WorkflowUpdate",
			Handler:    _Vtctld_WorkflowUpdate_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Backup",
			Handler:       _Vtctld_Backup_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "BackupShard",
			Handler:       _Vtctld_BackupShard_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "RestoreFromBackup",
			Handler:       _Vtctld_RestoreFromBackup_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "vitess/vtctlservice/v17/vtctlservice.proto",
}

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

Functions

func RegisterVtctlServer 

func RegisterVtctlServer(s grpc.ServiceRegistrar, srv VtctlServer)

func RegisterVtctldServer 

func RegisterVtctldServer(s grpc.ServiceRegistrar, srv VtctldServer)

Types

type UnimplementedVtctlServer 

type UnimplementedVtctlServer struct {
}

UnimplementedVtctlServer should be embedded to have forward compatible implementations.

func (UnimplementedVtctlServer) ExecuteVtctlCommand 

func (UnimplementedVtctlServer) ExecuteVtctlCommand(*v17.ExecuteVtctlCommandRequest, Vtctl_ExecuteVtctlCommandServer) error

type UnimplementedVtctldServer 

type UnimplementedVtctldServer struct {
}

UnimplementedVtctldServer should be embedded to have forward compatible implementations.

func (UnimplementedVtctldServer) AddCellInfo 

func (UnimplementedVtctldServer) AddCellInfo(context.Context, *v17.AddCellInfoRequest) (*v17.AddCellInfoResponse, error)

func (UnimplementedVtctldServer) AddCellsAlias 

func (UnimplementedVtctldServer) AddCellsAlias(context.Context, *v17.AddCellsAliasRequest) (*v17.AddCellsAliasResponse, error)

func (UnimplementedVtctldServer) ApplyRoutingRules 

func (UnimplementedVtctldServer) ApplyRoutingRules(context.Context, *v17.ApplyRoutingRulesRequest) (*v17.ApplyRoutingRulesResponse, error)

func (UnimplementedVtctldServer) ApplySchema 

func (UnimplementedVtctldServer) ApplySchema(context.Context, *v17.ApplySchemaRequest) (*v17.ApplySchemaResponse, error)

func (UnimplementedVtctldServer) ApplyShardRoutingRules 

func (UnimplementedVtctldServer) ApplyShardRoutingRules(context.Context, *v17.ApplyShardRoutingRulesRequest) (*v17.ApplyShardRoutingRulesResponse, error)

func (UnimplementedVtctldServer) ApplyVSchema 

func (UnimplementedVtctldServer) ApplyVSchema(context.Context, *v17.ApplyVSchemaRequest) (*v17.ApplyVSchemaResponse, error)

func (UnimplementedVtctldServer) Backup 

func (UnimplementedVtctldServer) Backup(*v17.BackupRequest, Vtctld_BackupServer) error

func (UnimplementedVtctldServer) BackupShard 

func (UnimplementedVtctldServer) BackupShard(*v17.BackupShardRequest, Vtctld_BackupShardServer) error

func (UnimplementedVtctldServer) ChangeTabletType 

func (UnimplementedVtctldServer) ChangeTabletType(context.Context, *v17.ChangeTabletTypeRequest) (*v17.ChangeTabletTypeResponse, error)

func (UnimplementedVtctldServer) CreateKeyspace 

func (UnimplementedVtctldServer) CreateKeyspace(context.Context, *v17.CreateKeyspaceRequest) (*v17.CreateKeyspaceResponse, error)

func (UnimplementedVtctldServer) CreateShard 

func (UnimplementedVtctldServer) CreateShard(context.Context, *v17.CreateShardRequest) (*v17.CreateShardResponse, error)

func (UnimplementedVtctldServer) DeleteCellInfo 

func (UnimplementedVtctldServer) DeleteCellInfo(context.Context, *v17.DeleteCellInfoRequest) (*v17.DeleteCellInfoResponse, error)

func (UnimplementedVtctldServer) DeleteCellsAlias 

func (UnimplementedVtctldServer) DeleteCellsAlias(context.Context, *v17.DeleteCellsAliasRequest) (*v17.DeleteCellsAliasResponse, error)

func (UnimplementedVtctldServer) DeleteKeyspace 

func (UnimplementedVtctldServer) DeleteKeyspace(context.Context, *v17.DeleteKeyspaceRequest) (*v17.DeleteKeyspaceResponse, error)

func (UnimplementedVtctldServer) DeleteShards 

func (UnimplementedVtctldServer) DeleteShards(context.Context, *v17.DeleteShardsRequest) (*v17.DeleteShardsResponse, error)

func (UnimplementedVtctldServer) DeleteSrvVSchema 

func (UnimplementedVtctldServer) DeleteSrvVSchema(context.Context, *v17.DeleteSrvVSchemaRequest) (*v17.DeleteSrvVSchemaResponse, error)

func (UnimplementedVtctldServer) DeleteTablets 

func (UnimplementedVtctldServer) DeleteTablets(context.Context, *v17.DeleteTabletsRequest) (*v17.DeleteTabletsResponse, error)

func (UnimplementedVtctldServer) EmergencyReparentShard 

func (UnimplementedVtctldServer) EmergencyReparentShard(context.Context, *v17.EmergencyReparentShardRequest) (*v17.EmergencyReparentShardResponse, error)

func (UnimplementedVtctldServer) ExecuteFetchAsApp 

func (UnimplementedVtctldServer) ExecuteFetchAsApp(context.Context, *v17.ExecuteFetchAsAppRequest) (*v17.ExecuteFetchAsAppResponse, error)

func (UnimplementedVtctldServer) ExecuteFetchAsDBA 

func (UnimplementedVtctldServer) ExecuteFetchAsDBA(context.Context, *v17.ExecuteFetchAsDBARequest) (*v17.ExecuteFetchAsDBAResponse, error)

func (UnimplementedVtctldServer) ExecuteHook 

func (UnimplementedVtctldServer) ExecuteHook(context.Context, *v17.ExecuteHookRequest) (*v17.ExecuteHookResponse, error)

func (UnimplementedVtctldServer) FindAllShardsInKeyspace 

func (UnimplementedVtctldServer) FindAllShardsInKeyspace(context.Context, *v17.FindAllShardsInKeyspaceRequest) (*v17.FindAllShardsInKeyspaceResponse, error)

func (UnimplementedVtctldServer) GetBackups 

func (UnimplementedVtctldServer) GetBackups(context.Context, *v17.GetBackupsRequest) (*v17.GetBackupsResponse, error)

func (UnimplementedVtctldServer) GetCellInfo 

func (UnimplementedVtctldServer) GetCellInfo(context.Context, *v17.GetCellInfoRequest) (*v17.GetCellInfoResponse, error)

func (UnimplementedVtctldServer) GetCellInfoNames 

func (UnimplementedVtctldServer) GetCellInfoNames(context.Context, *v17.GetCellInfoNamesRequest) (*v17.GetCellInfoNamesResponse, error)

func (UnimplementedVtctldServer) GetCellsAliases 

func (UnimplementedVtctldServer) GetCellsAliases(context.Context, *v17.GetCellsAliasesRequest) (*v17.GetCellsAliasesResponse, error)

func (UnimplementedVtctldServer) GetFullStatus 

func (UnimplementedVtctldServer) GetFullStatus(context.Context, *v17.GetFullStatusRequest) (*v17.GetFullStatusResponse, error)

func (UnimplementedVtctldServer) GetKeyspace 

func (UnimplementedVtctldServer) GetKeyspace(context.Context, *v17.GetKeyspaceRequest) (*v17.GetKeyspaceResponse, error)

func (UnimplementedVtctldServer) GetKeyspaces 

func (UnimplementedVtctldServer) GetKeyspaces(context.Context, *v17.GetKeyspacesRequest) (*v17.GetKeyspacesResponse, error)

func (UnimplementedVtctldServer) GetPermissions 

func (UnimplementedVtctldServer) GetPermissions(context.Context, *v17.GetPermissionsRequest) (*v17.GetPermissionsResponse, error)

func (UnimplementedVtctldServer) GetRoutingRules 

func (UnimplementedVtctldServer) GetRoutingRules(context.Context, *v17.GetRoutingRulesRequest) (*v17.GetRoutingRulesResponse, error)

func (UnimplementedVtctldServer) GetSchema 

func (UnimplementedVtctldServer) GetSchema(context.Context, *v17.GetSchemaRequest) (*v17.GetSchemaResponse, error)

func (UnimplementedVtctldServer) GetShard 

func (UnimplementedVtctldServer) GetShard(context.Context, *v17.GetShardRequest) (*v17.GetShardResponse, error)

func (UnimplementedVtctldServer) GetShardRoutingRules 

func (UnimplementedVtctldServer) GetShardRoutingRules(context.Context, *v17.GetShardRoutingRulesRequest) (*v17.GetShardRoutingRulesResponse, error)

func (UnimplementedVtctldServer) GetSrvKeyspaceNames 

func (UnimplementedVtctldServer) GetSrvKeyspaceNames(context.Context, *v17.GetSrvKeyspaceNamesRequest) (*v17.GetSrvKeyspaceNamesResponse, error)

func (UnimplementedVtctldServer) GetSrvKeyspaces 

func (UnimplementedVtctldServer) GetSrvKeyspaces(context.Context, *v17.GetSrvKeyspacesRequest) (*v17.GetSrvKeyspacesResponse, error)

func (UnimplementedVtctldServer) GetSrvVSchema 

func (UnimplementedVtctldServer) GetSrvVSchema(context.Context, *v17.GetSrvVSchemaRequest) (*v17.GetSrvVSchemaResponse, error)

func (UnimplementedVtctldServer) GetSrvVSchemas 

func (UnimplementedVtctldServer) GetSrvVSchemas(context.Context, *v17.GetSrvVSchemasRequest) (*v17.GetSrvVSchemasResponse, error)

func (UnimplementedVtctldServer) GetTablet 

func (UnimplementedVtctldServer) GetTablet(context.Context, *v17.GetTabletRequest) (*v17.GetTabletResponse, error)

func (UnimplementedVtctldServer) GetTablets 

func (UnimplementedVtctldServer) GetTablets(context.Context, *v17.GetTabletsRequest) (*v17.GetTabletsResponse, error)

func (UnimplementedVtctldServer) GetTopologyPath 

func (UnimplementedVtctldServer) GetTopologyPath(context.Context, *v17.GetTopologyPathRequest) (*v17.GetTopologyPathResponse, error)

func (UnimplementedVtctldServer) GetVSchema 

func (UnimplementedVtctldServer) GetVSchema(context.Context, *v17.GetVSchemaRequest) (*v17.GetVSchemaResponse, error)

func (UnimplementedVtctldServer) GetVersion 

func (UnimplementedVtctldServer) GetVersion(context.Context, *v17.GetVersionRequest) (*v17.GetVersionResponse, error)

func (UnimplementedVtctldServer) GetWorkflows 

func (UnimplementedVtctldServer) GetWorkflows(context.Context, *v17.GetWorkflowsRequest) (*v17.GetWorkflowsResponse, error)

func (UnimplementedVtctldServer) InitShardPrimary 

func (UnimplementedVtctldServer) InitShardPrimary(context.Context, *v17.InitShardPrimaryRequest) (*v17.InitShardPrimaryResponse, error)

func (UnimplementedVtctldServer) PingTablet 

func (UnimplementedVtctldServer) PingTablet(context.Context, *v17.PingTabletRequest) (*v17.PingTabletResponse, error)

func (UnimplementedVtctldServer) PlannedReparentShard 

func (UnimplementedVtctldServer) PlannedReparentShard(context.Context, *v17.PlannedReparentShardRequest) (*v17.PlannedReparentShardResponse, error)

func (UnimplementedVtctldServer) RebuildKeyspaceGraph 

func (UnimplementedVtctldServer) RebuildKeyspaceGraph(context.Context, *v17.RebuildKeyspaceGraphRequest) (*v17.RebuildKeyspaceGraphResponse, error)

func (UnimplementedVtctldServer) RebuildVSchemaGraph 

func (UnimplementedVtctldServer) RebuildVSchemaGraph(context.Context, *v17.RebuildVSchemaGraphRequest) (*v17.RebuildVSchemaGraphResponse, error)

func (UnimplementedVtctldServer) RefreshState 

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

func (UnimplementedVtctldServer) RefreshStateByShard 

func (UnimplementedVtctldServer) RefreshStateByShard(context.Context, *v17.RefreshStateByShardRequest) (*v17.RefreshStateByShardResponse, error)

func (UnimplementedVtctldServer) ReloadSchema 

func (UnimplementedVtctldServer) ReloadSchema(context.Context, *v17.ReloadSchemaRequest) (*v17.ReloadSchemaResponse, error)

func (UnimplementedVtctldServer) ReloadSchemaKeyspace 

func (UnimplementedVtctldServer) ReloadSchemaKeyspace(context.Context, *v17.ReloadSchemaKeyspaceRequest) (*v17.ReloadSchemaKeyspaceResponse, error)

func (UnimplementedVtctldServer) ReloadSchemaShard 

func (UnimplementedVtctldServer) ReloadSchemaShard(context.Context, *v17.ReloadSchemaShardRequest) (*v17.ReloadSchemaShardResponse, error)

func (UnimplementedVtctldServer) RemoveBackup 

func (UnimplementedVtctldServer) RemoveBackup(context.Context, *v17.RemoveBackupRequest) (*v17.RemoveBackupResponse, error)

func (UnimplementedVtctldServer) RemoveKeyspaceCell 

func (UnimplementedVtctldServer) RemoveKeyspaceCell(context.Context, *v17.RemoveKeyspaceCellRequest) (*v17.RemoveKeyspaceCellResponse, error)

func (UnimplementedVtctldServer) RemoveShardCell 

func (UnimplementedVtctldServer) RemoveShardCell(context.Context, *v17.RemoveShardCellRequest) (*v17.RemoveShardCellResponse, error)

func (UnimplementedVtctldServer) ReparentTablet 

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

func (UnimplementedVtctldServer) RestoreFromBackup 

func (UnimplementedVtctldServer) RestoreFromBackup(*v17.RestoreFromBackupRequest, Vtctld_RestoreFromBackupServer) error

func (UnimplementedVtctldServer) RunHealthCheck 

func (UnimplementedVtctldServer) RunHealthCheck(context.Context, *v17.RunHealthCheckRequest) (*v17.RunHealthCheckResponse, error)

func (UnimplementedVtctldServer) SetKeyspaceDurabilityPolicy 

func (UnimplementedVtctldServer) SetKeyspaceDurabilityPolicy(context.Context, *v17.SetKeyspaceDurabilityPolicyRequest) (*v17.SetKeyspaceDurabilityPolicyResponse, error)

func (UnimplementedVtctldServer) SetShardIsPrimaryServing 

func (UnimplementedVtctldServer) SetShardIsPrimaryServing(context.Context, *v17.SetShardIsPrimaryServingRequest) (*v17.SetShardIsPrimaryServingResponse, error)

func (UnimplementedVtctldServer) SetShardTabletControl 

func (UnimplementedVtctldServer) SetShardTabletControl(context.Context, *v17.SetShardTabletControlRequest) (*v17.SetShardTabletControlResponse, error)

func (UnimplementedVtctldServer) SetWritable 

func (UnimplementedVtctldServer) SetWritable(context.Context, *v17.SetWritableRequest) (*v17.SetWritableResponse, error)

func (UnimplementedVtctldServer) ShardReplicationAdd 

func (UnimplementedVtctldServer) ShardReplicationAdd(context.Context, *v17.ShardReplicationAddRequest) (*v17.ShardReplicationAddResponse, error)

func (UnimplementedVtctldServer) ShardReplicationFix 

func (UnimplementedVtctldServer) ShardReplicationFix(context.Context, *v17.ShardReplicationFixRequest) (*v17.ShardReplicationFixResponse, error)

func (UnimplementedVtctldServer) ShardReplicationPositions 

func (UnimplementedVtctldServer) ShardReplicationPositions(context.Context, *v17.ShardReplicationPositionsRequest) (*v17.ShardReplicationPositionsResponse, error)

func (UnimplementedVtctldServer) ShardReplicationRemove 

func (UnimplementedVtctldServer) ShardReplicationRemove(context.Context, *v17.ShardReplicationRemoveRequest) (*v17.ShardReplicationRemoveResponse, error)

func (UnimplementedVtctldServer) SleepTablet 

func (UnimplementedVtctldServer) SleepTablet(context.Context, *v17.SleepTabletRequest) (*v17.SleepTabletResponse, error)

func (UnimplementedVtctldServer) SourceShardAdd 

func (UnimplementedVtctldServer) SourceShardAdd(context.Context, *v17.SourceShardAddRequest) (*v17.SourceShardAddResponse, error)

func (UnimplementedVtctldServer) SourceShardDelete 

func (UnimplementedVtctldServer) SourceShardDelete(context.Context, *v17.SourceShardDeleteRequest) (*v17.SourceShardDeleteResponse, error)

func (UnimplementedVtctldServer) StartReplication 

func (UnimplementedVtctldServer) StartReplication(context.Context, *v17.StartReplicationRequest) (*v17.StartReplicationResponse, error)

func (UnimplementedVtctldServer) StopReplication 

func (UnimplementedVtctldServer) StopReplication(context.Context, *v17.StopReplicationRequest) (*v17.StopReplicationResponse, error)

func (UnimplementedVtctldServer) TabletExternallyReparented 

func (UnimplementedVtctldServer) TabletExternallyReparented(context.Context, *v17.TabletExternallyReparentedRequest) (*v17.TabletExternallyReparentedResponse, error)

func (UnimplementedVtctldServer) UpdateCellInfo 

func (UnimplementedVtctldServer) UpdateCellInfo(context.Context, *v17.UpdateCellInfoRequest) (*v17.UpdateCellInfoResponse, error)

func (UnimplementedVtctldServer) UpdateCellsAlias 

func (UnimplementedVtctldServer) UpdateCellsAlias(context.Context, *v17.UpdateCellsAliasRequest) (*v17.UpdateCellsAliasResponse, error)

func (UnimplementedVtctldServer) UpdateThrottlerConfig 

func (UnimplementedVtctldServer) UpdateThrottlerConfig(context.Context, *v17.UpdateThrottlerConfigRequest) (*v17.UpdateThrottlerConfigResponse, error)

func (UnimplementedVtctldServer) Validate 

func (UnimplementedVtctldServer) Validate(context.Context, *v17.ValidateRequest) (*v17.ValidateResponse, error)

func (UnimplementedVtctldServer) ValidateKeyspace 

func (UnimplementedVtctldServer) ValidateKeyspace(context.Context, *v17.ValidateKeyspaceRequest) (*v17.ValidateKeyspaceResponse, error)

func (UnimplementedVtctldServer) ValidateSchemaKeyspace 

func (UnimplementedVtctldServer) ValidateSchemaKeyspace(context.Context, *v17.ValidateSchemaKeyspaceRequest) (*v17.ValidateSchemaKeyspaceResponse, error)

func (UnimplementedVtctldServer) ValidateShard 

func (UnimplementedVtctldServer) ValidateShard(context.Context, *v17.ValidateShardRequest) (*v17.ValidateShardResponse, error)

func (UnimplementedVtctldServer) ValidateVSchema 

func (UnimplementedVtctldServer) ValidateVSchema(context.Context, *v17.ValidateVSchemaRequest) (*v17.ValidateVSchemaResponse, error)

func (UnimplementedVtctldServer) ValidateVersionKeyspace 

func (UnimplementedVtctldServer) ValidateVersionKeyspace(context.Context, *v17.ValidateVersionKeyspaceRequest) (*v17.ValidateVersionKeyspaceResponse, error)

func (UnimplementedVtctldServer) ValidateVersionShard 

func (UnimplementedVtctldServer) ValidateVersionShard(context.Context, *v17.ValidateVersionShardRequest) (*v17.ValidateVersionShardResponse, error)

func (UnimplementedVtctldServer) WorkflowUpdate 

func (UnimplementedVtctldServer) WorkflowUpdate(context.Context, *v17.WorkflowUpdateRequest) (*v17.WorkflowUpdateResponse, error)

type UnsafeVtctlServer 

type UnsafeVtctlServer interface {
	// contains filtered or unexported methods
}

UnsafeVtctlServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VtctlServer will result in compilation errors.

type UnsafeVtctldServer 

type UnsafeVtctldServer interface {
	// contains filtered or unexported methods
}

UnsafeVtctldServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VtctldServer will result in compilation errors.

type VtctlClient 

type VtctlClient interface {
	ExecuteVtctlCommand(ctx context.Context, in *v17.ExecuteVtctlCommandRequest, opts ...grpc.CallOption) (Vtctl_ExecuteVtctlCommandClient, error)
}

VtctlClient is the client API for Vtctl 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 NewVtctlClient 

func NewVtctlClient(cc grpc.ClientConnInterface) VtctlClient

type VtctlServer 

type VtctlServer interface {
	ExecuteVtctlCommand(*v17.ExecuteVtctlCommandRequest, Vtctl_ExecuteVtctlCommandServer) error
}

VtctlServer is the server API for Vtctl service. All implementations should embed UnimplementedVtctlServer for forward compatibility

type Vtctl_ExecuteVtctlCommandClient 

type Vtctl_ExecuteVtctlCommandClient interface {
	Recv() (*v17.ExecuteVtctlCommandResponse, error)
	grpc.ClientStream
}

type Vtctl_ExecuteVtctlCommandServer 

type Vtctl_ExecuteVtctlCommandServer interface {
	Send(*v17.ExecuteVtctlCommandResponse) error
	grpc.ServerStream
}

type VtctldClient 

type VtctldClient interface {
	// AddCellInfo registers a local topology service in a new cell by creating
	// the CellInfo with the provided parameters.
	AddCellInfo(ctx context.Context, in *v17.AddCellInfoRequest, opts ...grpc.CallOption) (*v17.AddCellInfoResponse, error)
	// AddCellsAlias defines a group of cells that can be referenced by a single
	// name (the alias).
	//
	// When routing query traffic, replica/rdonly traffic can be routed across
	// cells within the group (alias). Only primary traffic can be routed across
	// cells not in the same group (alias).
	AddCellsAlias(ctx context.Context, in *v17.AddCellsAliasRequest, opts ...grpc.CallOption) (*v17.AddCellsAliasResponse, error)
	// ApplyRoutingRules applies the VSchema routing rules.
	ApplyRoutingRules(ctx context.Context, in *v17.ApplyRoutingRulesRequest, opts ...grpc.CallOption) (*v17.ApplyRoutingRulesResponse, error)
	// ApplySchema applies a schema to a keyspace.
	ApplySchema(ctx context.Context, in *v17.ApplySchemaRequest, opts ...grpc.CallOption) (*v17.ApplySchemaResponse, error)
	// ApplyShardRoutingRules applies the VSchema shard routing rules.
	ApplyShardRoutingRules(ctx context.Context, in *v17.ApplyShardRoutingRulesRequest, opts ...grpc.CallOption) (*v17.ApplyShardRoutingRulesResponse, error)
	// ApplyVSchema applies a vschema to a keyspace.
	ApplyVSchema(ctx context.Context, in *v17.ApplyVSchemaRequest, opts ...grpc.CallOption) (*v17.ApplyVSchemaResponse, error)
	// Backup uses the BackupEngine and BackupStorage services on the specified
	// tablet to create and store a new backup.
	Backup(ctx context.Context, in *v17.BackupRequest, opts ...grpc.CallOption) (Vtctld_BackupClient, error)
	// BackupShard chooses a tablet in the shard and uses it to create a backup.
	BackupShard(ctx context.Context, in *v17.BackupShardRequest, opts ...grpc.CallOption) (Vtctld_BackupShardClient, error)
	// ChangeTabletType changes the db type for the specified tablet, if possible.
	// This is used primarily to arrange replicas, and it will not convert a
	// primary. For that, use InitShardPrimary.
	//
	// NOTE: This command automatically updates the serving graph.
	ChangeTabletType(ctx context.Context, in *v17.ChangeTabletTypeRequest, opts ...grpc.CallOption) (*v17.ChangeTabletTypeResponse, error)
	// CreateKeyspace creates the specified keyspace in the topology. For a
	// SNAPSHOT keyspace, the request must specify the name of a base keyspace,
	// as well as a snapshot time.
	CreateKeyspace(ctx context.Context, in *v17.CreateKeyspaceRequest, opts ...grpc.CallOption) (*v17.CreateKeyspaceResponse, error)
	// CreateShard creates the specified shard in the topology.
	CreateShard(ctx context.Context, in *v17.CreateShardRequest, opts ...grpc.CallOption) (*v17.CreateShardResponse, error)
	// DeleteCellInfo deletes the CellInfo for the provided cell. The cell cannot
	// be referenced by any Shard record in the topology.
	DeleteCellInfo(ctx context.Context, in *v17.DeleteCellInfoRequest, opts ...grpc.CallOption) (*v17.DeleteCellInfoResponse, error)
	// DeleteCellsAlias deletes the CellsAlias for the provided alias.
	DeleteCellsAlias(ctx context.Context, in *v17.DeleteCellsAliasRequest, opts ...grpc.CallOption) (*v17.DeleteCellsAliasResponse, error)
	// DeleteKeyspace deletes the specified keyspace from the topology. In
	// recursive mode, it also recursively deletes all shards in the keyspace.
	// Otherwise, the keyspace must be empty (have no shards), or DeleteKeyspace
	// returns an error.
	DeleteKeyspace(ctx context.Context, in *v17.DeleteKeyspaceRequest, opts ...grpc.CallOption) (*v17.DeleteKeyspaceResponse, error)
	// DeleteShards deletes the specified shards from the topology. In recursive
	// mode, it also deletes all tablets belonging to the shard. Otherwise, the
	// shard must be empty (have no tablets) or DeleteShards returns an error for
	// that shard.
	DeleteShards(ctx context.Context, in *v17.DeleteShardsRequest, opts ...grpc.CallOption) (*v17.DeleteShardsResponse, error)
	// DeleteSrvVSchema deletes the SrvVSchema object in the specified cell.
	DeleteSrvVSchema(ctx context.Context, in *v17.DeleteSrvVSchemaRequest, opts ...grpc.CallOption) (*v17.DeleteSrvVSchemaResponse, error)
	// DeleteTablets deletes one or more tablets from the topology.
	DeleteTablets(ctx context.Context, in *v17.DeleteTabletsRequest, opts ...grpc.CallOption) (*v17.DeleteTabletsResponse, error)
	// EmergencyReparentShard reparents the shard to the new primary. It assumes
	// the old primary is dead or otherwise not responding.
	EmergencyReparentShard(ctx context.Context, in *v17.EmergencyReparentShardRequest, opts ...grpc.CallOption) (*v17.EmergencyReparentShardResponse, error)
	// ExecuteFetchAsApp executes a SQL query on the remote tablet as the App user.
	ExecuteFetchAsApp(ctx context.Context, in *v17.ExecuteFetchAsAppRequest, opts ...grpc.CallOption) (*v17.ExecuteFetchAsAppResponse, error)
	// ExecuteFetchAsDBA executes a SQL query on the remote tablet as the DBA user.
	ExecuteFetchAsDBA(ctx context.Context, in *v17.ExecuteFetchAsDBARequest, opts ...grpc.CallOption) (*v17.ExecuteFetchAsDBAResponse, error)
	// ExecuteHook runs the hook on the tablet.
	ExecuteHook(ctx context.Context, in *v17.ExecuteHookRequest, opts ...grpc.CallOption) (*v17.ExecuteHookResponse, error)
	// FindAllShardsInKeyspace returns a map of shard names to shard references
	// for a given keyspace.
	FindAllShardsInKeyspace(ctx context.Context, in *v17.FindAllShardsInKeyspaceRequest, opts ...grpc.CallOption) (*v17.FindAllShardsInKeyspaceResponse, error)
	// GetBackups returns all the backups for a shard.
	GetBackups(ctx context.Context, in *v17.GetBackupsRequest, opts ...grpc.CallOption) (*v17.GetBackupsResponse, error)
	// GetCellInfo returns the information for a cell.
	GetCellInfo(ctx context.Context, in *v17.GetCellInfoRequest, opts ...grpc.CallOption) (*v17.GetCellInfoResponse, error)
	// GetCellInfoNames returns all the cells for which we have a CellInfo object,
	// meaning we have a topology service registered.
	GetCellInfoNames(ctx context.Context, in *v17.GetCellInfoNamesRequest, opts ...grpc.CallOption) (*v17.GetCellInfoNamesResponse, error)
	// GetCellsAliases returns a mapping of cell alias to cells identified by that
	// alias.
	GetCellsAliases(ctx context.Context, in *v17.GetCellsAliasesRequest, opts ...grpc.CallOption) (*v17.GetCellsAliasesResponse, error)
	// GetFullStatus returns the full status of MySQL including the replication information, semi-sync information, GTID information among others
	GetFullStatus(ctx context.Context, in *v17.GetFullStatusRequest, opts ...grpc.CallOption) (*v17.GetFullStatusResponse, error)
	// GetKeyspace reads the given keyspace from the topo and returns it.
	GetKeyspace(ctx context.Context, in *v17.GetKeyspaceRequest, opts ...grpc.CallOption) (*v17.GetKeyspaceResponse, error)
	// GetKeyspaces returns the keyspace struct of all keyspaces in the topo.
	GetKeyspaces(ctx context.Context, in *v17.GetKeyspacesRequest, opts ...grpc.CallOption) (*v17.GetKeyspacesResponse, error)
	// GetPermissions returns the permissions set on the remote tablet.
	GetPermissions(ctx context.Context, in *v17.GetPermissionsRequest, opts ...grpc.CallOption) (*v17.GetPermissionsResponse, error)
	// GetRoutingRules returns the VSchema routing rules.
	GetRoutingRules(ctx context.Context, in *v17.GetRoutingRulesRequest, opts ...grpc.CallOption) (*v17.GetRoutingRulesResponse, error)
	// GetSchema returns the schema for a tablet, or just the schema for the
	// specified tables in that tablet.
	GetSchema(ctx context.Context, in *v17.GetSchemaRequest, opts ...grpc.CallOption) (*v17.GetSchemaResponse, error)
	// GetShard returns information about a shard in the topology.
	GetShard(ctx context.Context, in *v17.GetShardRequest, opts ...grpc.CallOption) (*v17.GetShardResponse, error)
	// GetShardRoutingRules returns the VSchema shard routing rules.
	GetShardRoutingRules(ctx context.Context, in *v17.GetShardRoutingRulesRequest, opts ...grpc.CallOption) (*v17.GetShardRoutingRulesResponse, error)
	// GetSrvKeyspaceNames returns a mapping of cell name to the keyspaces served
	// in that cell.
	GetSrvKeyspaceNames(ctx context.Context, in *v17.GetSrvKeyspaceNamesRequest, opts ...grpc.CallOption) (*v17.GetSrvKeyspaceNamesResponse, error)
	// GetSrvKeyspaces returns the SrvKeyspaces for a keyspace in one or more
	// cells.
	GetSrvKeyspaces(ctx context.Context, in *v17.GetSrvKeyspacesRequest, opts ...grpc.CallOption) (*v17.GetSrvKeyspacesResponse, error)
	// UpdateThrottlerConfig updates the tablet throttler configuration
	UpdateThrottlerConfig(ctx context.Context, in *v17.UpdateThrottlerConfigRequest, opts ...grpc.CallOption) (*v17.UpdateThrottlerConfigResponse, error)
	// GetSrvVSchema returns the SrvVSchema for a cell.
	GetSrvVSchema(ctx context.Context, in *v17.GetSrvVSchemaRequest, opts ...grpc.CallOption) (*v17.GetSrvVSchemaResponse, error)
	// GetSrvVSchemas returns a mapping from cell name to SrvVSchema for all cells,
	// optionally filtered by cell name.
	GetSrvVSchemas(ctx context.Context, in *v17.GetSrvVSchemasRequest, opts ...grpc.CallOption) (*v17.GetSrvVSchemasResponse, error)
	// GetTablet returns information about a tablet.
	GetTablet(ctx context.Context, in *v17.GetTabletRequest, opts ...grpc.CallOption) (*v17.GetTabletResponse, error)
	// GetTablets returns tablets, optionally filtered by keyspace and shard.
	GetTablets(ctx context.Context, in *v17.GetTabletsRequest, opts ...grpc.CallOption) (*v17.GetTabletsResponse, error)
	// GetTopologyPath returns the topology cell at a given path.
	GetTopologyPath(ctx context.Context, in *v17.GetTopologyPathRequest, opts ...grpc.CallOption) (*v17.GetTopologyPathResponse, error)
	// GetVersion returns the version of a tablet from its debug vars.
	GetVersion(ctx context.Context, in *v17.GetVersionRequest, opts ...grpc.CallOption) (*v17.GetVersionResponse, error)
	// GetVSchema returns the vschema for a keyspace.
	GetVSchema(ctx context.Context, in *v17.GetVSchemaRequest, opts ...grpc.CallOption) (*v17.GetVSchemaResponse, error)
	// GetWorkflows returns a list of workflows for the given keyspace.
	GetWorkflows(ctx context.Context, in *v17.GetWorkflowsRequest, opts ...grpc.CallOption) (*v17.GetWorkflowsResponse, error)
	// InitShardPrimary sets the initial primary for a shard. Will make all other
	// tablets in the shard replicas of the provided primary.
	//
	// WARNING: This could cause data loss on an already replicating shard.
	// PlannedReparentShard or EmergencyReparentShard should be used in those
	// cases instead.
	InitShardPrimary(ctx context.Context, in *v17.InitShardPrimaryRequest, opts ...grpc.CallOption) (*v17.InitShardPrimaryResponse, 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 *v17.PingTabletRequest, opts ...grpc.CallOption) (*v17.PingTabletResponse, error)
	// PlannedReparentShard reparents the shard to the new primary, or away from
	// an old primary. Both the old and new primaries need to be reachable and
	// running.
	//
	// **NOTE**: The vtctld will not consider any replicas outside the cell the
	// current shard primary is in for promotion unless NewPrimary is explicitly
	// provided in the request.
	PlannedReparentShard(ctx context.Context, in *v17.PlannedReparentShardRequest, opts ...grpc.CallOption) (*v17.PlannedReparentShardResponse, error)
	// RebuildKeyspaceGraph rebuilds the serving data for a keyspace.
	//
	// This may trigger an update to all connected clients.
	RebuildKeyspaceGraph(ctx context.Context, in *v17.RebuildKeyspaceGraphRequest, opts ...grpc.CallOption) (*v17.RebuildKeyspaceGraphResponse, error)
	// RebuildVSchemaGraph rebuilds the per-cell SrvVSchema from the global
	// VSchema objects in the provided cells (or all cells in the topo none
	// provided).
	RebuildVSchemaGraph(ctx context.Context, in *v17.RebuildVSchemaGraphRequest, opts ...grpc.CallOption) (*v17.RebuildVSchemaGraphResponse, error)
	// RefreshState reloads the tablet record on the specified tablet.
	RefreshState(ctx context.Context, in *v17.RefreshStateRequest, opts ...grpc.CallOption) (*v17.RefreshStateResponse, error)
	// RefreshStateByShard calls RefreshState on all the tablets in the given shard.
	RefreshStateByShard(ctx context.Context, in *v17.RefreshStateByShardRequest, opts ...grpc.CallOption) (*v17.RefreshStateByShardResponse, error)
	// ReloadSchema instructs the remote tablet to reload its schema.
	ReloadSchema(ctx context.Context, in *v17.ReloadSchemaRequest, opts ...grpc.CallOption) (*v17.ReloadSchemaResponse, error)
	// ReloadSchemaKeyspace reloads the schema on all tablets in a keyspace.
	ReloadSchemaKeyspace(ctx context.Context, in *v17.ReloadSchemaKeyspaceRequest, opts ...grpc.CallOption) (*v17.ReloadSchemaKeyspaceResponse, error)
	// ReloadSchemaShard reloads the schema on all tablets in a shard.
	//
	// In general, we don't always expect all replicas to be ready to reload, and
	// the periodic schema reload makes them self-healing anyway. So, we do this
	// on a best-effort basis, and log warnings for any tablets that fail to
	// reload within the context deadline.
	ReloadSchemaShard(ctx context.Context, in *v17.ReloadSchemaShardRequest, opts ...grpc.CallOption) (*v17.ReloadSchemaShardResponse, error)
	// RemoveBackup removes a backup from the BackupStorage used by vtctld.
	RemoveBackup(ctx context.Context, in *v17.RemoveBackupRequest, opts ...grpc.CallOption) (*v17.RemoveBackupResponse, error)
	// RemoveKeyspaceCell removes the specified cell from the Cells list for all
	// shards in the specified keyspace (by calling RemoveShardCell on every
	// shard). It also removes the SrvKeyspace for that keyspace in that cell.
	RemoveKeyspaceCell(ctx context.Context, in *v17.RemoveKeyspaceCellRequest, opts ...grpc.CallOption) (*v17.RemoveKeyspaceCellResponse, error)
	// RemoveShardCell removes the specified cell from the specified shard's Cells
	// list.
	RemoveShardCell(ctx context.Context, in *v17.RemoveShardCellRequest, opts ...grpc.CallOption) (*v17.RemoveShardCellResponse, error)
	// ReparentTablet reparents a tablet to the current primary in the shard. This
	// only works if the current replica position matches the last known reparent
	// action.
	ReparentTablet(ctx context.Context, in *v17.ReparentTabletRequest, opts ...grpc.CallOption) (*v17.ReparentTabletResponse, error)
	// RestoreFromBackup stops mysqld for the given tablet and restores a backup.
	RestoreFromBackup(ctx context.Context, in *v17.RestoreFromBackupRequest, opts ...grpc.CallOption) (Vtctld_RestoreFromBackupClient, error)
	// RunHealthCheck runs a healthcheck on the remote tablet.
	RunHealthCheck(ctx context.Context, in *v17.RunHealthCheckRequest, opts ...grpc.CallOption) (*v17.RunHealthCheckResponse, error)
	// SetKeyspaceDurabilityPolicy updates the DurabilityPolicy for a keyspace.
	SetKeyspaceDurabilityPolicy(ctx context.Context, in *v17.SetKeyspaceDurabilityPolicyRequest, opts ...grpc.CallOption) (*v17.SetKeyspaceDurabilityPolicyResponse, error)
	// SetShardIsPrimaryServing adds or removes a shard from serving.
	//
	// This is meant as an emergency function. It does not rebuild any serving
	// graph (i.e. it does not run RebuildKeyspaceGraph).
	SetShardIsPrimaryServing(ctx context.Context, in *v17.SetShardIsPrimaryServingRequest, opts ...grpc.CallOption) (*v17.SetShardIsPrimaryServingResponse, error)
	// SetShardTabletControl updates the TabletControl topo record for a shard and
	// tablet type.
	//
	// This should only be used for an emergency fix, or after a finished
	// Reshard. See the documentation on SetShardTabletControlRequest for more
	// information about the different update modes.
	SetShardTabletControl(ctx context.Context, in *v17.SetShardTabletControlRequest, opts ...grpc.CallOption) (*v17.SetShardTabletControlResponse, error)
	// SetWritable sets a tablet as read-write (writable=true) or read-only (writable=false).
	SetWritable(ctx context.Context, in *v17.SetWritableRequest, opts ...grpc.CallOption) (*v17.SetWritableResponse, error)
	// ShardReplicationAdd adds an entry to a topodata.ShardReplication object.
	//
	// It is a low-level function and should generally not be called.
	ShardReplicationAdd(ctx context.Context, in *v17.ShardReplicationAddRequest, opts ...grpc.CallOption) (*v17.ShardReplicationAddResponse, error)
	// ShardReplicationFix walks the replication graph for a shard in a cell and
	// attempts to fix the first problem encountered, returning information about
	// the problem fixed, if any.
	ShardReplicationFix(ctx context.Context, in *v17.ShardReplicationFixRequest, opts ...grpc.CallOption) (*v17.ShardReplicationFixResponse, error)
	// ShardReplicationPositions returns the replication position of each tablet
	// in a shard. This RPC makes a best-effort to return partial results. For
	// example, if one tablet in the shard graph is unreachable, then
	// ShardReplicationPositions will return non-error, and include valid results
	// for the reachable tablets.
	ShardReplicationPositions(ctx context.Context, in *v17.ShardReplicationPositionsRequest, opts ...grpc.CallOption) (*v17.ShardReplicationPositionsResponse, error)
	// ShardReplicationRemove removes an entry from a topodata.ShardReplication
	// object.
	//
	// It is a low-level function and should generally not be called.
	ShardReplicationRemove(ctx context.Context, in *v17.ShardReplicationRemoveRequest, opts ...grpc.CallOption) (*v17.ShardReplicationRemoveResponse, error)
	// SleepTablet blocks the aciton queue on the specified tablet for the
	// specified duration.
	//
	// This is typically used for testing.
	SleepTablet(ctx context.Context, in *v17.SleepTabletRequest, opts ...grpc.CallOption) (*v17.SleepTabletResponse, error)
	// SourceShardAdd adds the SourceShard record with the provided index. This
	// should be used only as an emergency function.
	//
	// It does not call RefreshState for the shard primary.
	SourceShardAdd(ctx context.Context, in *v17.SourceShardAddRequest, opts ...grpc.CallOption) (*v17.SourceShardAddResponse, error)
	// SourceShardDelete deletes the SourceShard record with the provided index.
	// This should be used only as an emergency cleanup function.
	//
	// It does not call RefreshState for the shard primary.
	SourceShardDelete(ctx context.Context, in *v17.SourceShardDeleteRequest, opts ...grpc.CallOption) (*v17.SourceShardDeleteResponse, error)
	// StartReplication starts replication on the specified tablet.
	StartReplication(ctx context.Context, in *v17.StartReplicationRequest, opts ...grpc.CallOption) (*v17.StartReplicationResponse, error)
	// StopReplication stops replication on the specified tablet.
	StopReplication(ctx context.Context, in *v17.StopReplicationRequest, opts ...grpc.CallOption) (*v17.StopReplicationResponse, error)
	// TabletExternallyReparented changes metadata in the topology server to
	// acknowledge a shard primary change performed by an external tool (e.g.
	// orchestrator).
	//
	// See the Reparenting guide for more information:
	// https://vitess.io/docs/user-guides/configuration-advanced/reparenting/#external-reparenting.
	TabletExternallyReparented(ctx context.Context, in *v17.TabletExternallyReparentedRequest, opts ...grpc.CallOption) (*v17.TabletExternallyReparentedResponse, error)
	// UpdateCellInfo updates the content of a CellInfo with the provided
	// parameters. Empty values are ignored. If the cell does not exist, the
	// CellInfo will be created.
	UpdateCellInfo(ctx context.Context, in *v17.UpdateCellInfoRequest, opts ...grpc.CallOption) (*v17.UpdateCellInfoResponse, error)
	// UpdateCellsAlias updates the content of a CellsAlias with the provided
	// parameters. Empty values are ignored. If the alias does not exist, the
	// CellsAlias will be created.
	UpdateCellsAlias(ctx context.Context, in *v17.UpdateCellsAliasRequest, opts ...grpc.CallOption) (*v17.UpdateCellsAliasResponse, error)
	// Validate validates that all nodes from the global replication graph are
	// reachable, and that all tablets in discoverable cells are consistent.
	Validate(ctx context.Context, in *v17.ValidateRequest, opts ...grpc.CallOption) (*v17.ValidateResponse, error)
	// ValidateKeyspace validates that all nodes reachable from the specified
	// keyspace are consistent.
	ValidateKeyspace(ctx context.Context, in *v17.ValidateKeyspaceRequest, opts ...grpc.CallOption) (*v17.ValidateKeyspaceResponse, error)
	// ValidateSchemaKeyspace validates that the schema on the primary tablet for shard 0 matches the schema on all of the other tablets in the keyspace.
	ValidateSchemaKeyspace(ctx context.Context, in *v17.ValidateSchemaKeyspaceRequest, opts ...grpc.CallOption) (*v17.ValidateSchemaKeyspaceResponse, error)
	// ValidateShard validates that all nodes reachable from the specified shard
	// are consistent.
	ValidateShard(ctx context.Context, in *v17.ValidateShardRequest, opts ...grpc.CallOption) (*v17.ValidateShardResponse, error)
	// ValidateVersionKeyspace validates that the version on the primary of shard 0 matches all of the other tablets in the keyspace.
	ValidateVersionKeyspace(ctx context.Context, in *v17.ValidateVersionKeyspaceRequest, opts ...grpc.CallOption) (*v17.ValidateVersionKeyspaceResponse, error)
	// ValidateVersionShard validates that the version on the primary matches all of the replicas.
	ValidateVersionShard(ctx context.Context, in *v17.ValidateVersionShardRequest, opts ...grpc.CallOption) (*v17.ValidateVersionShardResponse, error)
	// ValidateVSchema compares the schema of each primary tablet in "keyspace/shards..." to the vschema and errs if there are differences.
	ValidateVSchema(ctx context.Context, in *v17.ValidateVSchemaRequest, opts ...grpc.CallOption) (*v17.ValidateVSchemaResponse, error)
	// WorkflowUpdate updates the configuration of a vreplication workflow
	// using the provided updated parameters.
	WorkflowUpdate(ctx context.Context, in *v17.WorkflowUpdateRequest, opts ...grpc.CallOption) (*v17.WorkflowUpdateResponse, error)
}

VtctldClient is the client API for Vtctld 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 NewVtctldClient 

func NewVtctldClient(cc grpc.ClientConnInterface) VtctldClient

type VtctldServer 

type VtctldServer interface {
	// AddCellInfo registers a local topology service in a new cell by creating
	// the CellInfo with the provided parameters.
	AddCellInfo(context.Context, *v17.AddCellInfoRequest) (*v17.AddCellInfoResponse, error)
	// AddCellsAlias defines a group of cells that can be referenced by a single
	// name (the alias).
	//
	// When routing query traffic, replica/rdonly traffic can be routed across
	// cells within the group (alias). Only primary traffic can be routed across
	// cells not in the same group (alias).
	AddCellsAlias(context.Context, *v17.AddCellsAliasRequest) (*v17.AddCellsAliasResponse, error)
	// ApplyRoutingRules applies the VSchema routing rules.
	ApplyRoutingRules(context.Context, *v17.ApplyRoutingRulesRequest) (*v17.ApplyRoutingRulesResponse, error)
	// ApplySchema applies a schema to a keyspace.
	ApplySchema(context.Context, *v17.ApplySchemaRequest) (*v17.ApplySchemaResponse, error)
	// ApplyShardRoutingRules applies the VSchema shard routing rules.
	ApplyShardRoutingRules(context.Context, *v17.ApplyShardRoutingRulesRequest) (*v17.ApplyShardRoutingRulesResponse, error)
	// ApplyVSchema applies a vschema to a keyspace.
	ApplyVSchema(context.Context, *v17.ApplyVSchemaRequest) (*v17.ApplyVSchemaResponse, error)
	// Backup uses the BackupEngine and BackupStorage services on the specified
	// tablet to create and store a new backup.
	Backup(*v17.BackupRequest, Vtctld_BackupServer) error
	// BackupShard chooses a tablet in the shard and uses it to create a backup.
	BackupShard(*v17.BackupShardRequest, Vtctld_BackupShardServer) error
	// ChangeTabletType changes the db type for the specified tablet, if possible.
	// This is used primarily to arrange replicas, and it will not convert a
	// primary. For that, use InitShardPrimary.
	//
	// NOTE: This command automatically updates the serving graph.
	ChangeTabletType(context.Context, *v17.ChangeTabletTypeRequest) (*v17.ChangeTabletTypeResponse, error)
	// CreateKeyspace creates the specified keyspace in the topology. For a
	// SNAPSHOT keyspace, the request must specify the name of a base keyspace,
	// as well as a snapshot time.
	CreateKeyspace(context.Context, *v17.CreateKeyspaceRequest) (*v17.CreateKeyspaceResponse, error)
	// CreateShard creates the specified shard in the topology.
	CreateShard(context.Context, *v17.CreateShardRequest) (*v17.CreateShardResponse, error)
	// DeleteCellInfo deletes the CellInfo for the provided cell. The cell cannot
	// be referenced by any Shard record in the topology.
	DeleteCellInfo(context.Context, *v17.DeleteCellInfoRequest) (*v17.DeleteCellInfoResponse, error)
	// DeleteCellsAlias deletes the CellsAlias for the provided alias.
	DeleteCellsAlias(context.Context, *v17.DeleteCellsAliasRequest) (*v17.DeleteCellsAliasResponse, error)
	// DeleteKeyspace deletes the specified keyspace from the topology. In
	// recursive mode, it also recursively deletes all shards in the keyspace.
	// Otherwise, the keyspace must be empty (have no shards), or DeleteKeyspace
	// returns an error.
	DeleteKeyspace(context.Context, *v17.DeleteKeyspaceRequest) (*v17.DeleteKeyspaceResponse, error)
	// DeleteShards deletes the specified shards from the topology. In recursive
	// mode, it also deletes all tablets belonging to the shard. Otherwise, the
	// shard must be empty (have no tablets) or DeleteShards returns an error for
	// that shard.
	DeleteShards(context.Context, *v17.DeleteShardsRequest) (*v17.DeleteShardsResponse, error)
	// DeleteSrvVSchema deletes the SrvVSchema object in the specified cell.
	DeleteSrvVSchema(context.Context, *v17.DeleteSrvVSchemaRequest) (*v17.DeleteSrvVSchemaResponse, error)
	// DeleteTablets deletes one or more tablets from the topology.
	DeleteTablets(context.Context, *v17.DeleteTabletsRequest) (*v17.DeleteTabletsResponse, error)
	// EmergencyReparentShard reparents the shard to the new primary. It assumes
	// the old primary is dead or otherwise not responding.
	EmergencyReparentShard(context.Context, *v17.EmergencyReparentShardRequest) (*v17.EmergencyReparentShardResponse, error)
	// ExecuteFetchAsApp executes a SQL query on the remote tablet as the App user.
	ExecuteFetchAsApp(context.Context, *v17.ExecuteFetchAsAppRequest) (*v17.ExecuteFetchAsAppResponse, error)
	// ExecuteFetchAsDBA executes a SQL query on the remote tablet as the DBA user.
	ExecuteFetchAsDBA(context.Context, *v17.ExecuteFetchAsDBARequest) (*v17.ExecuteFetchAsDBAResponse, error)
	// ExecuteHook runs the hook on the tablet.
	ExecuteHook(context.Context, *v17.ExecuteHookRequest) (*v17.ExecuteHookResponse, error)
	// FindAllShardsInKeyspace returns a map of shard names to shard references
	// for a given keyspace.
	FindAllShardsInKeyspace(context.Context, *v17.FindAllShardsInKeyspaceRequest) (*v17.FindAllShardsInKeyspaceResponse, error)
	// GetBackups returns all the backups for a shard.
	GetBackups(context.Context, *v17.GetBackupsRequest) (*v17.GetBackupsResponse, error)
	// GetCellInfo returns the information for a cell.
	GetCellInfo(context.Context, *v17.GetCellInfoRequest) (*v17.GetCellInfoResponse, error)
	// GetCellInfoNames returns all the cells for which we have a CellInfo object,
	// meaning we have a topology service registered.
	GetCellInfoNames(context.Context, *v17.GetCellInfoNamesRequest) (*v17.GetCellInfoNamesResponse, error)
	// GetCellsAliases returns a mapping of cell alias to cells identified by that
	// alias.
	GetCellsAliases(context.Context, *v17.GetCellsAliasesRequest) (*v17.GetCellsAliasesResponse, error)
	// GetFullStatus returns the full status of MySQL including the replication information, semi-sync information, GTID information among others
	GetFullStatus(context.Context, *v17.GetFullStatusRequest) (*v17.GetFullStatusResponse, error)
	// GetKeyspace reads the given keyspace from the topo and returns it.
	GetKeyspace(context.Context, *v17.GetKeyspaceRequest) (*v17.GetKeyspaceResponse, error)
	// GetKeyspaces returns the keyspace struct of all keyspaces in the topo.
	GetKeyspaces(context.Context, *v17.GetKeyspacesRequest) (*v17.GetKeyspacesResponse, error)
	// GetPermissions returns the permissions set on the remote tablet.
	GetPermissions(context.Context, *v17.GetPermissionsRequest) (*v17.GetPermissionsResponse, error)
	// GetRoutingRules returns the VSchema routing rules.
	GetRoutingRules(context.Context, *v17.GetRoutingRulesRequest) (*v17.GetRoutingRulesResponse, error)
	// GetSchema returns the schema for a tablet, or just the schema for the
	// specified tables in that tablet.
	GetSchema(context.Context, *v17.GetSchemaRequest) (*v17.GetSchemaResponse, error)
	// GetShard returns information about a shard in the topology.
	GetShard(context.Context, *v17.GetShardRequest) (*v17.GetShardResponse, error)
	// GetShardRoutingRules returns the VSchema shard routing rules.
	GetShardRoutingRules(context.Context, *v17.GetShardRoutingRulesRequest) (*v17.GetShardRoutingRulesResponse, error)
	// GetSrvKeyspaceNames returns a mapping of cell name to the keyspaces served
	// in that cell.
	GetSrvKeyspaceNames(context.Context, *v17.GetSrvKeyspaceNamesRequest) (*v17.GetSrvKeyspaceNamesResponse, error)
	// GetSrvKeyspaces returns the SrvKeyspaces for a keyspace in one or more
	// cells.
	GetSrvKeyspaces(context.Context, *v17.GetSrvKeyspacesRequest) (*v17.GetSrvKeyspacesResponse, error)
	// UpdateThrottlerConfig updates the tablet throttler configuration
	UpdateThrottlerConfig(context.Context, *v17.UpdateThrottlerConfigRequest) (*v17.UpdateThrottlerConfigResponse, error)
	// GetSrvVSchema returns the SrvVSchema for a cell.
	GetSrvVSchema(context.Context, *v17.GetSrvVSchemaRequest) (*v17.GetSrvVSchemaResponse, error)
	// GetSrvVSchemas returns a mapping from cell name to SrvVSchema for all cells,
	// optionally filtered by cell name.
	GetSrvVSchemas(context.Context, *v17.GetSrvVSchemasRequest) (*v17.GetSrvVSchemasResponse, error)
	// GetTablet returns information about a tablet.
	GetTablet(context.Context, *v17.GetTabletRequest) (*v17.GetTabletResponse, error)
	// GetTablets returns tablets, optionally filtered by keyspace and shard.
	GetTablets(context.Context, *v17.GetTabletsRequest) (*v17.GetTabletsResponse, error)
	// GetTopologyPath returns the topology cell at a given path.
	GetTopologyPath(context.Context, *v17.GetTopologyPathRequest) (*v17.GetTopologyPathResponse, error)
	// GetVersion returns the version of a tablet from its debug vars.
	GetVersion(context.Context, *v17.GetVersionRequest) (*v17.GetVersionResponse, error)
	// GetVSchema returns the vschema for a keyspace.
	GetVSchema(context.Context, *v17.GetVSchemaRequest) (*v17.GetVSchemaResponse, error)
	// GetWorkflows returns a list of workflows for the given keyspace.
	GetWorkflows(context.Context, *v17.GetWorkflowsRequest) (*v17.GetWorkflowsResponse, error)
	// InitShardPrimary sets the initial primary for a shard. Will make all other
	// tablets in the shard replicas of the provided primary.
	//
	// WARNING: This could cause data loss on an already replicating shard.
	// PlannedReparentShard or EmergencyReparentShard should be used in those
	// cases instead.
	InitShardPrimary(context.Context, *v17.InitShardPrimaryRequest) (*v17.InitShardPrimaryResponse, 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, *v17.PingTabletRequest) (*v17.PingTabletResponse, error)
	// PlannedReparentShard reparents the shard to the new primary, or away from
	// an old primary. Both the old and new primaries need to be reachable and
	// running.
	//
	// **NOTE**: The vtctld will not consider any replicas outside the cell the
	// current shard primary is in for promotion unless NewPrimary is explicitly
	// provided in the request.
	PlannedReparentShard(context.Context, *v17.PlannedReparentShardRequest) (*v17.PlannedReparentShardResponse, error)
	// RebuildKeyspaceGraph rebuilds the serving data for a keyspace.
	//
	// This may trigger an update to all connected clients.
	RebuildKeyspaceGraph(context.Context, *v17.RebuildKeyspaceGraphRequest) (*v17.RebuildKeyspaceGraphResponse, error)
	// RebuildVSchemaGraph rebuilds the per-cell SrvVSchema from the global
	// VSchema objects in the provided cells (or all cells in the topo none
	// provided).
	RebuildVSchemaGraph(context.Context, *v17.RebuildVSchemaGraphRequest) (*v17.RebuildVSchemaGraphResponse, error)
	// RefreshState reloads the tablet record on the specified tablet.
	RefreshState(context.Context, *v17.RefreshStateRequest) (*v17.RefreshStateResponse, error)
	// RefreshStateByShard calls RefreshState on all the tablets in the given shard.
	RefreshStateByShard(context.Context, *v17.RefreshStateByShardRequest) (*v17.RefreshStateByShardResponse, error)
	// ReloadSchema instructs the remote tablet to reload its schema.
	ReloadSchema(context.Context, *v17.ReloadSchemaRequest) (*v17.ReloadSchemaResponse, error)
	// ReloadSchemaKeyspace reloads the schema on all tablets in a keyspace.
	ReloadSchemaKeyspace(context.Context, *v17.ReloadSchemaKeyspaceRequest) (*v17.ReloadSchemaKeyspaceResponse, error)
	// ReloadSchemaShard reloads the schema on all tablets in a shard.
	//
	// In general, we don't always expect all replicas to be ready to reload, and
	// the periodic schema reload makes them self-healing anyway. So, we do this
	// on a best-effort basis, and log warnings for any tablets that fail to
	// reload within the context deadline.
	ReloadSchemaShard(context.Context, *v17.ReloadSchemaShardRequest) (*v17.ReloadSchemaShardResponse, error)
	// RemoveBackup removes a backup from the BackupStorage used by vtctld.
	RemoveBackup(context.Context, *v17.RemoveBackupRequest) (*v17.RemoveBackupResponse, error)
	// RemoveKeyspaceCell removes the specified cell from the Cells list for all
	// shards in the specified keyspace (by calling RemoveShardCell on every
	// shard). It also removes the SrvKeyspace for that keyspace in that cell.
	RemoveKeyspaceCell(context.Context, *v17.RemoveKeyspaceCellRequest) (*v17.RemoveKeyspaceCellResponse, error)
	// RemoveShardCell removes the specified cell from the specified shard's Cells
	// list.
	RemoveShardCell(context.Context, *v17.RemoveShardCellRequest) (*v17.RemoveShardCellResponse, error)
	// ReparentTablet reparents a tablet to the current primary in the shard. This
	// only works if the current replica position matches the last known reparent
	// action.
	ReparentTablet(context.Context, *v17.ReparentTabletRequest) (*v17.ReparentTabletResponse, error)
	// RestoreFromBackup stops mysqld for the given tablet and restores a backup.
	RestoreFromBackup(*v17.RestoreFromBackupRequest, Vtctld_RestoreFromBackupServer) error
	// RunHealthCheck runs a healthcheck on the remote tablet.
	RunHealthCheck(context.Context, *v17.RunHealthCheckRequest) (*v17.RunHealthCheckResponse, error)
	// SetKeyspaceDurabilityPolicy updates the DurabilityPolicy for a keyspace.
	SetKeyspaceDurabilityPolicy(context.Context, *v17.SetKeyspaceDurabilityPolicyRequest) (*v17.SetKeyspaceDurabilityPolicyResponse, error)
	// SetShardIsPrimaryServing adds or removes a shard from serving.
	//
	// This is meant as an emergency function. It does not rebuild any serving
	// graph (i.e. it does not run RebuildKeyspaceGraph).
	SetShardIsPrimaryServing(context.Context, *v17.SetShardIsPrimaryServingRequest) (*v17.SetShardIsPrimaryServingResponse, error)
	// SetShardTabletControl updates the TabletControl topo record for a shard and
	// tablet type.
	//
	// This should only be used for an emergency fix, or after a finished
	// Reshard. See the documentation on SetShardTabletControlRequest for more
	// information about the different update modes.
	SetShardTabletControl(context.Context, *v17.SetShardTabletControlRequest) (*v17.SetShardTabletControlResponse, error)
	// SetWritable sets a tablet as read-write (writable=true) or read-only (writable=false).
	SetWritable(context.Context, *v17.SetWritableRequest) (*v17.SetWritableResponse, error)
	// ShardReplicationAdd adds an entry to a topodata.ShardReplication object.
	//
	// It is a low-level function and should generally not be called.
	ShardReplicationAdd(context.Context, *v17.ShardReplicationAddRequest) (*v17.ShardReplicationAddResponse, error)
	// ShardReplicationFix walks the replication graph for a shard in a cell and
	// attempts to fix the first problem encountered, returning information about
	// the problem fixed, if any.
	ShardReplicationFix(context.Context, *v17.ShardReplicationFixRequest) (*v17.ShardReplicationFixResponse, error)
	// ShardReplicationPositions returns the replication position of each tablet
	// in a shard. This RPC makes a best-effort to return partial results. For
	// example, if one tablet in the shard graph is unreachable, then
	// ShardReplicationPositions will return non-error, and include valid results
	// for the reachable tablets.
	ShardReplicationPositions(context.Context, *v17.ShardReplicationPositionsRequest) (*v17.ShardReplicationPositionsResponse, error)
	// ShardReplicationRemove removes an entry from a topodata.ShardReplication
	// object.
	//
	// It is a low-level function and should generally not be called.
	ShardReplicationRemove(context.Context, *v17.ShardReplicationRemoveRequest) (*v17.ShardReplicationRemoveResponse, error)
	// SleepTablet blocks the aciton queue on the specified tablet for the
	// specified duration.
	//
	// This is typically used for testing.
	SleepTablet(context.Context, *v17.SleepTabletRequest) (*v17.SleepTabletResponse, error)
	// SourceShardAdd adds the SourceShard record with the provided index. This
	// should be used only as an emergency function.
	//
	// It does not call RefreshState for the shard primary.
	SourceShardAdd(context.Context, *v17.SourceShardAddRequest) (*v17.SourceShardAddResponse, error)
	// SourceShardDelete deletes the SourceShard record with the provided index.
	// This should be used only as an emergency cleanup function.
	//
	// It does not call RefreshState for the shard primary.
	SourceShardDelete(context.Context, *v17.SourceShardDeleteRequest) (*v17.SourceShardDeleteResponse, error)
	// StartReplication starts replication on the specified tablet.
	StartReplication(context.Context, *v17.StartReplicationRequest) (*v17.StartReplicationResponse, error)
	// StopReplication stops replication on the specified tablet.
	StopReplication(context.Context, *v17.StopReplicationRequest) (*v17.StopReplicationResponse, error)
	// TabletExternallyReparented changes metadata in the topology server to
	// acknowledge a shard primary change performed by an external tool (e.g.
	// orchestrator).
	//
	// See the Reparenting guide for more information:
	// https://vitess.io/docs/user-guides/configuration-advanced/reparenting/#external-reparenting.
	TabletExternallyReparented(context.Context, *v17.TabletExternallyReparentedRequest) (*v17.TabletExternallyReparentedResponse, error)
	// UpdateCellInfo updates the content of a CellInfo with the provided
	// parameters. Empty values are ignored. If the cell does not exist, the
	// CellInfo will be created.
	UpdateCellInfo(context.Context, *v17.UpdateCellInfoRequest) (*v17.UpdateCellInfoResponse, error)
	// UpdateCellsAlias updates the content of a CellsAlias with the provided
	// parameters. Empty values are ignored. If the alias does not exist, the
	// CellsAlias will be created.
	UpdateCellsAlias(context.Context, *v17.UpdateCellsAliasRequest) (*v17.UpdateCellsAliasResponse, error)
	// Validate validates that all nodes from the global replication graph are
	// reachable, and that all tablets in discoverable cells are consistent.
	Validate(context.Context, *v17.ValidateRequest) (*v17.ValidateResponse, error)
	// ValidateKeyspace validates that all nodes reachable from the specified
	// keyspace are consistent.
	ValidateKeyspace(context.Context, *v17.ValidateKeyspaceRequest) (*v17.ValidateKeyspaceResponse, error)
	// ValidateSchemaKeyspace validates that the schema on the primary tablet for shard 0 matches the schema on all of the other tablets in the keyspace.
	ValidateSchemaKeyspace(context.Context, *v17.ValidateSchemaKeyspaceRequest) (*v17.ValidateSchemaKeyspaceResponse, error)
	// ValidateShard validates that all nodes reachable from the specified shard
	// are consistent.
	ValidateShard(context.Context, *v17.ValidateShardRequest) (*v17.ValidateShardResponse, error)
	// ValidateVersionKeyspace validates that the version on the primary of shard 0 matches all of the other tablets in the keyspace.
	ValidateVersionKeyspace(context.Context, *v17.ValidateVersionKeyspaceRequest) (*v17.ValidateVersionKeyspaceResponse, error)
	// ValidateVersionShard validates that the version on the primary matches all of the replicas.
	ValidateVersionShard(context.Context, *v17.ValidateVersionShardRequest) (*v17.ValidateVersionShardResponse, error)
	// ValidateVSchema compares the schema of each primary tablet in "keyspace/shards..." to the vschema and errs if there are differences.
	ValidateVSchema(context.Context, *v17.ValidateVSchemaRequest) (*v17.ValidateVSchemaResponse, error)
	// WorkflowUpdate updates the configuration of a vreplication workflow
	// using the provided updated parameters.
	WorkflowUpdate(context.Context, *v17.WorkflowUpdateRequest) (*v17.WorkflowUpdateResponse, error)
}

VtctldServer is the server API for Vtctld service. All implementations should embed UnimplementedVtctldServer for forward compatibility

type Vtctld_BackupClient 

type Vtctld_BackupClient interface {
	Recv() (*v17.BackupResponse, error)
	grpc.ClientStream
}

type Vtctld_BackupServer 

type Vtctld_BackupServer interface {
	Send(*v17.BackupResponse) error
	grpc.ServerStream
}

type Vtctld_BackupShardClient 

type Vtctld_BackupShardClient interface {
	Recv() (*v17.BackupResponse, error)
	grpc.ClientStream
}

type Vtctld_BackupShardServer 

type Vtctld_BackupShardServer interface {
	Send(*v17.BackupResponse) error
	grpc.ServerStream
}

type Vtctld_RestoreFromBackupClient 

type Vtctld_RestoreFromBackupClient interface {
	Recv() (*v17.RestoreFromBackupResponse, error)
	grpc.ClientStream
}

type Vtctld_RestoreFromBackupServer 

type Vtctld_RestoreFromBackupServer interface {
	Send(*v17.RestoreFromBackupResponse) error
	grpc.ServerStream
}

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.