grpcvtctldserver

package
v0.15.10 Latest Latest
Warning

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

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

Documentation

Overview

Copyright 2023 The Vitess Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

View Source 
const (
	AllMigrationsIndicator = "all"
)
View Source 
const (

	// DefaultWaitReplicasTimeout is the default value for waitReplicasTimeout, which is used when calling method ApplySchema.
	DefaultWaitReplicasTimeout = 10 * time.Second
)

Variables

This section is empty.

Functions

func GetVersionFunc 

func GetVersionFunc() func(string) (string, error)

func SetVersionFunc 

func SetVersionFunc(versionFunc func(string) (string, error))

func StartServer 

func StartServer(s *grpc.Server, env *vtenv.Environment, ts *topo.Server)

StartServer registers a VtctldServer for RPCs on the given gRPC server.

Types

type VtctldServer 

type VtctldServer struct {
	vtctlservicepb.UnimplementedVtctldServer
	// contains filtered or unexported fields
}

VtctldServer implements the Vtctld RPC service protocol.

func NewTestVtctldServer 

func NewTestVtctldServer(ts *topo.Server, tmc tmclient.TabletManagerClient) *VtctldServer

NewTestVtctldServer returns a new VtctldServer for the given topo server AND tmclient for use in tests. This should NOT be used in production.

func NewVtctldServer 

func NewVtctldServer(env *vtenv.Environment, ts *topo.Server) *VtctldServer

NewVtctldServer returns a new VtctldServer for the given topo server.

func (*VtctldServer) AddCellInfo 

func (s *VtctldServer) AddCellInfo(ctx context.Context, req *vtctldatapb.AddCellInfoRequest) (resp *vtctldatapb.AddCellInfoResponse, err error)

AddCellInfo is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) AddCellsAlias 

func (s *VtctldServer) AddCellsAlias(ctx context.Context, req *vtctldatapb.AddCellsAliasRequest) (resp *vtctldatapb.AddCellsAliasResponse, err error)

AddCellsAlias is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ApplyKeyspaceRoutingRules 

func (s *VtctldServer) ApplyKeyspaceRoutingRules(ctx context.Context, req *vtctldatapb.ApplyKeyspaceRoutingRulesRequest) (*vtctldatapb.ApplyKeyspaceRoutingRulesResponse, error)

ApplyKeyspaceRoutingRules is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ApplyRoutingRules 

func (s *VtctldServer) ApplyRoutingRules(ctx context.Context, req *vtctldatapb.ApplyRoutingRulesRequest) (resp *vtctldatapb.ApplyRoutingRulesResponse, err error)

ApplyRoutingRules is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ApplySchema 

func (s *VtctldServer) ApplySchema(ctx context.Context, req *vtctldatapb.ApplySchemaRequest) (resp *vtctldatapb.ApplySchemaResponse, err error)

ApplySchema is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ApplyShardRoutingRules 

func (s *VtctldServer) ApplyShardRoutingRules(ctx context.Context, req *vtctldatapb.ApplyShardRoutingRulesRequest) (*vtctldatapb.ApplyShardRoutingRulesResponse, error)

ApplyShardRoutingRules is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ApplyVSchema 

func (s *VtctldServer) ApplyVSchema(ctx context.Context, req *vtctldatapb.ApplyVSchemaRequest) (resp *vtctldatapb.ApplyVSchemaResponse, err error)

ApplyVSchema is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) Backup 

func (s *VtctldServer) Backup(req *vtctldatapb.BackupRequest, stream vtctlservicepb.Vtctld_BackupServer) (err error)

Backup is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) BackupShard 

func (s *VtctldServer) BackupShard(req *vtctldatapb.BackupShardRequest, stream vtctlservicepb.Vtctld_BackupShardServer) (err error)

BackupShard is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) CancelSchemaMigration 

func (s *VtctldServer) CancelSchemaMigration(ctx context.Context, req *vtctldatapb.CancelSchemaMigrationRequest) (resp *vtctldatapb.CancelSchemaMigrationResponse, err error)

CancelSchemaMigration is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ChangeTabletType 

func (s *VtctldServer) ChangeTabletType(ctx context.Context, req *vtctldatapb.ChangeTabletTypeRequest) (resp *vtctldatapb.ChangeTabletTypeResponse, err error)

ChangeTabletType is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) CleanupSchemaMigration 

func (s *VtctldServer) CleanupSchemaMigration(ctx context.Context, req *vtctldatapb.CleanupSchemaMigrationRequest) (resp *vtctldatapb.CleanupSchemaMigrationResponse, err error)

CleanupSchemaMigration is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) CompleteSchemaMigration 

func (s *VtctldServer) CompleteSchemaMigration(ctx context.Context, req *vtctldatapb.CompleteSchemaMigrationRequest) (resp *vtctldatapb.CompleteSchemaMigrationResponse, err error)

CompleteSchemaMigration is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) CreateKeyspace 

func (s *VtctldServer) CreateKeyspace(ctx context.Context, req *vtctldatapb.CreateKeyspaceRequest) (resp *vtctldatapb.CreateKeyspaceResponse, err error)

CreateKeyspace is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) CreateShard 

func (s *VtctldServer) CreateShard(ctx context.Context, req *vtctldatapb.CreateShardRequest) (resp *vtctldatapb.CreateShardResponse, err error)

CreateShard is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) DeleteCellInfo 

func (s *VtctldServer) DeleteCellInfo(ctx context.Context, req *vtctldatapb.DeleteCellInfoRequest) (resp *vtctldatapb.DeleteCellInfoResponse, err error)

DeleteCellInfo is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) DeleteCellsAlias 

func (s *VtctldServer) DeleteCellsAlias(ctx context.Context, req *vtctldatapb.DeleteCellsAliasRequest) (resp *vtctldatapb.DeleteCellsAliasResponse, err error)

DeleteCellsAlias is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) DeleteKeyspace 

func (s *VtctldServer) DeleteKeyspace(ctx context.Context, req *vtctldatapb.DeleteKeyspaceRequest) (resp *vtctldatapb.DeleteKeyspaceResponse, err error)

DeleteKeyspace is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) DeleteShards 

func (s *VtctldServer) DeleteShards(ctx context.Context, req *vtctldatapb.DeleteShardsRequest) (resp *vtctldatapb.DeleteShardsResponse, err error)

DeleteShards is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) DeleteSrvVSchema 

func (s *VtctldServer) DeleteSrvVSchema(ctx context.Context, req *vtctldatapb.DeleteSrvVSchemaRequest) (resp *vtctldatapb.DeleteSrvVSchemaResponse, err error)

DeleteSrvVSchema is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) DeleteTablets 

func (s *VtctldServer) DeleteTablets(ctx context.Context, req *vtctldatapb.DeleteTabletsRequest) (resp *vtctldatapb.DeleteTabletsResponse, err error)

DeleteTablets is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) EmergencyReparentShard 

func (s *VtctldServer) EmergencyReparentShard(ctx context.Context, req *vtctldatapb.EmergencyReparentShardRequest) (resp *vtctldatapb.EmergencyReparentShardResponse, err error)

EmergencyReparentShard is part of the vtctldservicepb.VtctldServer interface.

func (*VtctldServer) ExecuteFetchAsApp 

func (s *VtctldServer) ExecuteFetchAsApp(ctx context.Context, req *vtctldatapb.ExecuteFetchAsAppRequest) (resp *vtctldatapb.ExecuteFetchAsAppResponse, err error)

ExecuteFetchAsApp is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ExecuteFetchAsDBA 

func (s *VtctldServer) ExecuteFetchAsDBA(ctx context.Context, req *vtctldatapb.ExecuteFetchAsDBARequest) (resp *vtctldatapb.ExecuteFetchAsDBAResponse, err error)

ExecuteFetchAsDBA is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ExecuteHook 

func (s *VtctldServer) ExecuteHook(ctx context.Context, req *vtctldatapb.ExecuteHookRequest) (resp *vtctldatapb.ExecuteHookResponse, err error)

ExecuteHook is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ExecuteMultiFetchAsDBA 

func (s *VtctldServer) ExecuteMultiFetchAsDBA(ctx context.Context, req *vtctldatapb.ExecuteMultiFetchAsDBARequest) (resp *vtctldatapb.ExecuteMultiFetchAsDBAResponse, err error)

ExecuteMultiFetchAsDBA is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) FindAllShardsInKeyspace 

func (s *VtctldServer) FindAllShardsInKeyspace(ctx context.Context, req *vtctldatapb.FindAllShardsInKeyspaceRequest) (resp *vtctldatapb.FindAllShardsInKeyspaceResponse, err error)

FindAllShardsInKeyspace is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ForceCutOverSchemaMigration 

func (s *VtctldServer) ForceCutOverSchemaMigration(ctx context.Context, req *vtctldatapb.ForceCutOverSchemaMigrationRequest) (resp *vtctldatapb.ForceCutOverSchemaMigrationResponse, err error)

ForceCutOverSchemaMigration is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetBackups 

func (s *VtctldServer) GetBackups(ctx context.Context, req *vtctldatapb.GetBackupsRequest) (resp *vtctldatapb.GetBackupsResponse, err error)

GetBackups is part of the vtctldservicepb.VtctldServer interface.

func (*VtctldServer) GetCellInfo 

func (s *VtctldServer) GetCellInfo(ctx context.Context, req *vtctldatapb.GetCellInfoRequest) (resp *vtctldatapb.GetCellInfoResponse, err error)

GetCellInfo is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetCellInfoNames 

func (s *VtctldServer) GetCellInfoNames(ctx context.Context, req *vtctldatapb.GetCellInfoNamesRequest) (resp *vtctldatapb.GetCellInfoNamesResponse, err error)

GetCellInfoNames is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetCellsAliases 

func (s *VtctldServer) GetCellsAliases(ctx context.Context, req *vtctldatapb.GetCellsAliasesRequest) (resp *vtctldatapb.GetCellsAliasesResponse, err error)

GetCellsAliases is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetFullStatus 

func (s *VtctldServer) GetFullStatus(ctx context.Context, req *vtctldatapb.GetFullStatusRequest) (resp *vtctldatapb.GetFullStatusResponse, err error)

GetFullStatus is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetKeyspace 

func (s *VtctldServer) GetKeyspace(ctx context.Context, req *vtctldatapb.GetKeyspaceRequest) (resp *vtctldatapb.GetKeyspaceResponse, err error)

GetKeyspace is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetKeyspaceRoutingRules 

func (s *VtctldServer) GetKeyspaceRoutingRules(ctx context.Context, req *vtctldatapb.GetKeyspaceRoutingRulesRequest) (*vtctldatapb.GetKeyspaceRoutingRulesResponse, error)

GetKeyspaceRoutingRules is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetKeyspaces 

func (s *VtctldServer) GetKeyspaces(ctx context.Context, req *vtctldatapb.GetKeyspacesRequest) (resp *vtctldatapb.GetKeyspacesResponse, err error)

GetKeyspaces is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetPermissions 

func (s *VtctldServer) GetPermissions(ctx context.Context, req *vtctldatapb.GetPermissionsRequest) (resp *vtctldatapb.GetPermissionsResponse, err error)

GetPermissions is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetRoutingRules 

func (s *VtctldServer) GetRoutingRules(ctx context.Context, req *vtctldatapb.GetRoutingRulesRequest) (resp *vtctldatapb.GetRoutingRulesResponse, err error)

GetRoutingRules is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetSchema 

func (s *VtctldServer) GetSchema(ctx context.Context, req *vtctldatapb.GetSchemaRequest) (resp *vtctldatapb.GetSchemaResponse, err error)

GetSchema is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetSchemaMigrations 

func (s *VtctldServer) GetSchemaMigrations(ctx context.Context, req *vtctldatapb.GetSchemaMigrationsRequest) (resp *vtctldatapb.GetSchemaMigrationsResponse, err error)

func (*VtctldServer) GetShard 

func (s *VtctldServer) GetShard(ctx context.Context, req *vtctldatapb.GetShardRequest) (resp *vtctldatapb.GetShardResponse, err error)

GetShard is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetShardReplication 

func (s *VtctldServer) GetShardReplication(ctx context.Context, req *vtctldatapb.GetShardReplicationRequest) (resp *vtctldatapb.GetShardReplicationResponse, err error)

GetShardReplication is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetShardRoutingRules 

func (s *VtctldServer) GetShardRoutingRules(ctx context.Context, req *vtctldatapb.GetShardRoutingRulesRequest) (*vtctldatapb.GetShardRoutingRulesResponse, error)

GetShardRoutingRules is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetSrvKeyspaceNames 

func (s *VtctldServer) GetSrvKeyspaceNames(ctx context.Context, req *vtctldatapb.GetSrvKeyspaceNamesRequest) (resp *vtctldatapb.GetSrvKeyspaceNamesResponse, err error)

GetSrvKeyspaceNames is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetSrvKeyspaces 

func (s *VtctldServer) GetSrvKeyspaces(ctx context.Context, req *vtctldatapb.GetSrvKeyspacesRequest) (resp *vtctldatapb.GetSrvKeyspacesResponse, err error)

GetSrvKeyspaces is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetSrvVSchema 

func (s *VtctldServer) GetSrvVSchema(ctx context.Context, req *vtctldatapb.GetSrvVSchemaRequest) (resp *vtctldatapb.GetSrvVSchemaResponse, err error)

GetSrvVSchema is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetSrvVSchemas 

func (s *VtctldServer) GetSrvVSchemas(ctx context.Context, req *vtctldatapb.GetSrvVSchemasRequest) (resp *vtctldatapb.GetSrvVSchemasResponse, err error)

GetSrvVSchemas is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetTablet 

func (s *VtctldServer) GetTablet(ctx context.Context, req *vtctldatapb.GetTabletRequest) (resp *vtctldatapb.GetTabletResponse, err error)

GetTablet is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetTablets 

func (s *VtctldServer) GetTablets(ctx context.Context, req *vtctldatapb.GetTabletsRequest) (resp *vtctldatapb.GetTabletsResponse, err error)

GetTablets is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetTopologyPath 

func (s *VtctldServer) GetTopologyPath(ctx context.Context, req *vtctldatapb.GetTopologyPathRequest) (*vtctldatapb.GetTopologyPathResponse, error)

GetTopologyPath is part of the vtctlservicepb.VtctldServer interface. It returns the cell located at the provided path in the topology server.

func (*VtctldServer) GetVSchema 

func (s *VtctldServer) GetVSchema(ctx context.Context, req *vtctldatapb.GetVSchemaRequest) (resp *vtctldatapb.GetVSchemaResponse, err error)

GetVSchema is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetVersion 

func (s *VtctldServer) GetVersion(ctx context.Context, req *vtctldatapb.GetVersionRequest) (resp *vtctldatapb.GetVersionResponse, err error)

GetVersion returns the version of a tablet from its debug vars

func (*VtctldServer) GetWorkflows 

func (s *VtctldServer) GetWorkflows(ctx context.Context, req *vtctldatapb.GetWorkflowsRequest) (resp *vtctldatapb.GetWorkflowsResponse, err error)

GetWorkflows is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) InitShardPrimary 

func (s *VtctldServer) InitShardPrimary(ctx context.Context, req *vtctldatapb.InitShardPrimaryRequest) (resp *vtctldatapb.InitShardPrimaryResponse, err error)

InitShardPrimary is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) InitShardPrimaryLocked 

func (s *VtctldServer) InitShardPrimaryLocked(
	ctx context.Context,
	ev *events.Reparent,
	req *vtctldatapb.InitShardPrimaryRequest,
	waitReplicasTimeout time.Duration,
	tmc tmclient.TabletManagerClient,
	logger logutil.Logger,
) error

InitShardPrimaryLocked is the main work of doing an InitShardPrimary. It should only called by callers that have already locked the shard in the topo. It is only public so that it can be used in wrangler and legacy vtctl server.

func (*VtctldServer) LaunchSchemaMigration 

func (s *VtctldServer) LaunchSchemaMigration(ctx context.Context, req *vtctldatapb.LaunchSchemaMigrationRequest) (resp *vtctldatapb.LaunchSchemaMigrationResponse, err error)

LaunchSchemaMigration is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) LookupVindexCreate 

func (s *VtctldServer) LookupVindexCreate(ctx context.Context, req *vtctldatapb.LookupVindexCreateRequest) (resp *vtctldatapb.LookupVindexCreateResponse, err error)

LookupVindexCreate is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) LookupVindexExternalize 

func (s *VtctldServer) LookupVindexExternalize(ctx context.Context, req *vtctldatapb.LookupVindexExternalizeRequest) (resp *vtctldatapb.LookupVindexExternalizeResponse, err error)

LookupVindexExternalize is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) MaterializeCreate 

func (s *VtctldServer) MaterializeCreate(ctx context.Context, req *vtctldatapb.MaterializeCreateRequest) (resp *vtctldatapb.MaterializeCreateResponse, err error)

MaterializeCreate is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) MigrateCreate 

func (s *VtctldServer) MigrateCreate(ctx context.Context, req *vtctldatapb.MigrateCreateRequest) (resp *vtctldatapb.WorkflowStatusResponse, err error)

MigrateCreate is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) MountList 

func (s *VtctldServer) MountList(ctx context.Context, req *vtctldatapb.MountListRequest) (resp *vtctldatapb.MountListResponse, err error)

MountList is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) MountRegister 

func (s *VtctldServer) MountRegister(ctx context.Context, req *vtctldatapb.MountRegisterRequest) (resp *vtctldatapb.MountRegisterResponse, err error)

MountRegister is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) MountShow 

func (s *VtctldServer) MountShow(ctx context.Context, req *vtctldatapb.MountShowRequest) (resp *vtctldatapb.MountShowResponse, err error)

MountShow is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) MountUnregister 

func (s *VtctldServer) MountUnregister(ctx context.Context, req *vtctldatapb.MountUnregisterRequest) (resp *vtctldatapb.MountUnregisterResponse, err error)

MountUnregister is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) MoveTablesComplete 

func (s *VtctldServer) MoveTablesComplete(ctx context.Context, req *vtctldatapb.MoveTablesCompleteRequest) (resp *vtctldatapb.MoveTablesCompleteResponse, err error)

MoveTablesComplete is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) MoveTablesCreate 

func (s *VtctldServer) MoveTablesCreate(ctx context.Context, req *vtctldatapb.MoveTablesCreateRequest) (resp *vtctldatapb.WorkflowStatusResponse, err error)

MoveTablesCreate is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) PingTablet 

func (s *VtctldServer) PingTablet(ctx context.Context, req *vtctldatapb.PingTabletRequest) (resp *vtctldatapb.PingTabletResponse, err error)

PingTablet is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) PlannedReparentShard 

func (s *VtctldServer) PlannedReparentShard(ctx context.Context, req *vtctldatapb.PlannedReparentShardRequest) (resp *vtctldatapb.PlannedReparentShardResponse, err error)

PlannedReparentShard is part of the vtctldservicepb.VtctldServer interface.

func (*VtctldServer) RebuildKeyspaceGraph 

func (s *VtctldServer) RebuildKeyspaceGraph(ctx context.Context, req *vtctldatapb.RebuildKeyspaceGraphRequest) (resp *vtctldatapb.RebuildKeyspaceGraphResponse, err error)

RebuildKeyspaceGraph is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) RebuildVSchemaGraph 

func (s *VtctldServer) RebuildVSchemaGraph(ctx context.Context, req *vtctldatapb.RebuildVSchemaGraphRequest) (resp *vtctldatapb.RebuildVSchemaGraphResponse, err error)

RebuildVSchemaGraph is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) RefreshState 

func (s *VtctldServer) RefreshState(ctx context.Context, req *vtctldatapb.RefreshStateRequest) (resp *vtctldatapb.RefreshStateResponse, err error)

RefreshState is part of the vtctldservicepb.VtctldServer interface.

func (*VtctldServer) RefreshStateByShard 

func (s *VtctldServer) RefreshStateByShard(ctx context.Context, req *vtctldatapb.RefreshStateByShardRequest) (resp *vtctldatapb.RefreshStateByShardResponse, err error)

RefreshStateByShard is part of the vtctldservicepb.VtctldServer interface.

func (*VtctldServer) ReloadSchema 

func (s *VtctldServer) ReloadSchema(ctx context.Context, req *vtctldatapb.ReloadSchemaRequest) (resp *vtctldatapb.ReloadSchemaResponse, err error)

ReloadSchema is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ReloadSchemaKeyspace 

func (s *VtctldServer) ReloadSchemaKeyspace(ctx context.Context, req *vtctldatapb.ReloadSchemaKeyspaceRequest) (resp *vtctldatapb.ReloadSchemaKeyspaceResponse, err error)

ReloadSchemaKeyspace is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ReloadSchemaShard 

func (s *VtctldServer) ReloadSchemaShard(ctx context.Context, req *vtctldatapb.ReloadSchemaShardRequest) (resp *vtctldatapb.ReloadSchemaShardResponse, err error)

ReloadSchemaShard is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) RemoveBackup 

func (s *VtctldServer) RemoveBackup(ctx context.Context, req *vtctldatapb.RemoveBackupRequest) (resp *vtctldatapb.RemoveBackupResponse, err error)

RemoveBackup is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) RemoveKeyspaceCell 

func (s *VtctldServer) RemoveKeyspaceCell(ctx context.Context, req *vtctldatapb.RemoveKeyspaceCellRequest) (resp *vtctldatapb.RemoveKeyspaceCellResponse, err error)

RemoveKeyspaceCell is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) RemoveShardCell 

func (s *VtctldServer) RemoveShardCell(ctx context.Context, req *vtctldatapb.RemoveShardCellRequest) (resp *vtctldatapb.RemoveShardCellResponse, err error)

RemoveShardCell is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ReparentTablet 

func (s *VtctldServer) ReparentTablet(ctx context.Context, req *vtctldatapb.ReparentTabletRequest) (resp *vtctldatapb.ReparentTabletResponse, err error)

ReparentTablet is part of the vtctldservicepb.VtctldServer interface.

func (*VtctldServer) ReshardCreate 

func (s *VtctldServer) ReshardCreate(ctx context.Context, req *vtctldatapb.ReshardCreateRequest) (resp *vtctldatapb.WorkflowStatusResponse, err error)

ReshardCreate is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) RestoreFromBackup 

func (s *VtctldServer) RestoreFromBackup(req *vtctldatapb.RestoreFromBackupRequest, stream vtctlservicepb.Vtctld_RestoreFromBackupServer) (err error)

func (*VtctldServer) RetrySchemaMigration 

func (s *VtctldServer) RetrySchemaMigration(ctx context.Context, req *vtctldatapb.RetrySchemaMigrationRequest) (resp *vtctldatapb.RetrySchemaMigrationResponse, err error)

RetrySchemaMigration is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) RunHealthCheck 

func (s *VtctldServer) RunHealthCheck(ctx context.Context, req *vtctldatapb.RunHealthCheckRequest) (resp *vtctldatapb.RunHealthCheckResponse, err error)

RunHealthCheck is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) SetKeyspaceDurabilityPolicy 

func (s *VtctldServer) SetKeyspaceDurabilityPolicy(ctx context.Context, req *vtctldatapb.SetKeyspaceDurabilityPolicyRequest) (resp *vtctldatapb.SetKeyspaceDurabilityPolicyResponse, err error)

SetKeyspaceDurabilityPolicy is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) SetShardIsPrimaryServing 

func (s *VtctldServer) SetShardIsPrimaryServing(ctx context.Context, req *vtctldatapb.SetShardIsPrimaryServingRequest) (resp *vtctldatapb.SetShardIsPrimaryServingResponse, err error)

SetShardIsPrimaryServing is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) SetShardTabletControl 

func (s *VtctldServer) SetShardTabletControl(ctx context.Context, req *vtctldatapb.SetShardTabletControlRequest) (resp *vtctldatapb.SetShardTabletControlResponse, err error)

SetShardTabletControl is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) SetWritable 

func (s *VtctldServer) SetWritable(ctx context.Context, req *vtctldatapb.SetWritableRequest) (resp *vtctldatapb.SetWritableResponse, err error)

SetWritable is part of the vtctldservicepb.VtctldServer interface.

func (*VtctldServer) ShardReplicationAdd 

func (s *VtctldServer) ShardReplicationAdd(ctx context.Context, req *vtctldatapb.ShardReplicationAddRequest) (resp *vtctldatapb.ShardReplicationAddResponse, err error)

ShardReplicationAdd is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ShardReplicationFix 

func (s *VtctldServer) ShardReplicationFix(ctx context.Context, req *vtctldatapb.ShardReplicationFixRequest) (resp *vtctldatapb.ShardReplicationFixResponse, err error)

ShardReplicationFix is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ShardReplicationPositions 

func (s *VtctldServer) ShardReplicationPositions(ctx context.Context, req *vtctldatapb.ShardReplicationPositionsRequest) (resp *vtctldatapb.ShardReplicationPositionsResponse, err error)

ShardReplicationPositions is part of the vtctldservicepb.VtctldServer interface.

func (*VtctldServer) ShardReplicationRemove 

func (s *VtctldServer) ShardReplicationRemove(ctx context.Context, req *vtctldatapb.ShardReplicationRemoveRequest) (resp *vtctldatapb.ShardReplicationRemoveResponse, err error)

ShardReplicationRemove is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) SleepTablet 

func (s *VtctldServer) SleepTablet(ctx context.Context, req *vtctldatapb.SleepTabletRequest) (resp *vtctldatapb.SleepTabletResponse, err error)

SleepTablet is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) SourceShardAdd 

func (s *VtctldServer) SourceShardAdd(ctx context.Context, req *vtctldatapb.SourceShardAddRequest) (resp *vtctldatapb.SourceShardAddResponse, err error)

SourceShardAdd is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) SourceShardDelete 

func (s *VtctldServer) SourceShardDelete(ctx context.Context, req *vtctldatapb.SourceShardDeleteRequest) (resp *vtctldatapb.SourceShardDeleteResponse, err error)

SourceShardDelete is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) StartReplication 

func (s *VtctldServer) StartReplication(ctx context.Context, req *vtctldatapb.StartReplicationRequest) (resp *vtctldatapb.StartReplicationResponse, err error)

StartReplication is part of the vtctldservicepb.VtctldServer interface.

func (*VtctldServer) StopReplication 

func (s *VtctldServer) StopReplication(ctx context.Context, req *vtctldatapb.StopReplicationRequest) (resp *vtctldatapb.StopReplicationResponse, err error)

StopReplication is part of the vtctldservicepb.VtctldServer interface.

func (*VtctldServer) TabletExternallyReparented 

func (s *VtctldServer) TabletExternallyReparented(ctx context.Context, req *vtctldatapb.TabletExternallyReparentedRequest) (resp *vtctldatapb.TabletExternallyReparentedResponse, err error)

TabletExternallyReparented is part of the vtctldservicepb.VtctldServer interface.

func (*VtctldServer) UpdateCellInfo 

func (s *VtctldServer) UpdateCellInfo(ctx context.Context, req *vtctldatapb.UpdateCellInfoRequest) (resp *vtctldatapb.UpdateCellInfoResponse, err error)

UpdateCellInfo is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) UpdateCellsAlias 

func (s *VtctldServer) UpdateCellsAlias(ctx context.Context, req *vtctldatapb.UpdateCellsAliasRequest) (resp *vtctldatapb.UpdateCellsAliasResponse, err error)

UpdateCellsAlias is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) UpdateThrottlerConfig 

func (s *VtctldServer) UpdateThrottlerConfig(ctx context.Context, req *vtctldatapb.UpdateThrottlerConfigRequest) (resp *vtctldatapb.UpdateThrottlerConfigResponse, err error)

UpdateThrottlerConfig updates throttler config for all cells

func (*VtctldServer) VDiffCreate 

func (s *VtctldServer) VDiffCreate(ctx context.Context, req *vtctldatapb.VDiffCreateRequest) (resp *vtctldatapb.VDiffCreateResponse, err error)

VDiffCreate is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) VDiffDelete 

func (s *VtctldServer) VDiffDelete(ctx context.Context, req *vtctldatapb.VDiffDeleteRequest) (resp *vtctldatapb.VDiffDeleteResponse, err error)

VDiffDelete is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) VDiffResume 

func (s *VtctldServer) VDiffResume(ctx context.Context, req *vtctldatapb.VDiffResumeRequest) (resp *vtctldatapb.VDiffResumeResponse, err error)

VDiffResume is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) VDiffShow 

func (s *VtctldServer) VDiffShow(ctx context.Context, req *vtctldatapb.VDiffShowRequest) (resp *vtctldatapb.VDiffShowResponse, err error)

VDiffShow is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) VDiffStop 

func (s *VtctldServer) VDiffStop(ctx context.Context, req *vtctldatapb.VDiffStopRequest) (resp *vtctldatapb.VDiffStopResponse, err error)

VDiffStop is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) Validate 

func (s *VtctldServer) Validate(ctx context.Context, req *vtctldatapb.ValidateRequest) (resp *vtctldatapb.ValidateResponse, err error)

Validate is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ValidateKeyspace 

func (s *VtctldServer) ValidateKeyspace(ctx context.Context, req *vtctldatapb.ValidateKeyspaceRequest) (resp *vtctldatapb.ValidateKeyspaceResponse, err error)

ValidateKeyspace is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ValidateSchemaKeyspace 

func (s *VtctldServer) ValidateSchemaKeyspace(ctx context.Context, req *vtctldatapb.ValidateSchemaKeyspaceRequest) (resp *vtctldatapb.ValidateSchemaKeyspaceResponse, err error)

ValidateSchemaKeyspace is a part of the vtctlservicepb.VtctldServer interface. It will diff the schema from all the tablets in the keyspace.

func (*VtctldServer) ValidateShard 

func (s *VtctldServer) ValidateShard(ctx context.Context, req *vtctldatapb.ValidateShardRequest) (resp *vtctldatapb.ValidateShardResponse, err error)

ValidateShard is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ValidateVSchema 

func (s *VtctldServer) ValidateVSchema(ctx context.Context, req *vtctldatapb.ValidateVSchemaRequest) (resp *vtctldatapb.ValidateVSchemaResponse, err error)

ValidateVSchema compares the schema of each primary tablet in "keyspace/shards..." to the vschema and errs if there are differences

func (*VtctldServer) ValidateVersionKeyspace 

func (s *VtctldServer) ValidateVersionKeyspace(ctx context.Context, req *vtctldatapb.ValidateVersionKeyspaceRequest) (resp *vtctldatapb.ValidateVersionKeyspaceResponse, err error)

ValidateVersionKeyspace validates all versions are the same in all tablets in a keyspace

func (*VtctldServer) ValidateVersionShard 

func (s *VtctldServer) ValidateVersionShard(ctx context.Context, req *vtctldatapb.ValidateVersionShardRequest) (resp *vtctldatapb.ValidateVersionShardResponse, err error)

ValidateVersionShard validates all versions are the same in all tablets in a shard

func (*VtctldServer) WorkflowDelete 

func (s *VtctldServer) WorkflowDelete(ctx context.Context, req *vtctldatapb.WorkflowDeleteRequest) (resp *vtctldatapb.WorkflowDeleteResponse, err error)

WorkflowDelete is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) WorkflowStatus 

func (s *VtctldServer) WorkflowStatus(ctx context.Context, req *vtctldatapb.WorkflowStatusRequest) (resp *vtctldatapb.WorkflowStatusResponse, err error)

WorkflowStatus is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) WorkflowSwitchTraffic 

func (s *VtctldServer) WorkflowSwitchTraffic(ctx context.Context, req *vtctldatapb.WorkflowSwitchTrafficRequest) (resp *vtctldatapb.WorkflowSwitchTrafficResponse, err error)

WorkflowSwitchTraffic is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) WorkflowUpdate 

func (s *VtctldServer) WorkflowUpdate(ctx context.Context, req *vtctldatapb.WorkflowUpdateRequest) (resp *vtctldatapb.WorkflowUpdateResponse, err error)

WorkflowUpdate is part of the vtctlservicepb.VtctldServer interface.

Source Files

View all Source files

Directories

Path Synopsis
Package testutil contains utility functions for writing tests for the grpcvtctldserver.
 Package testutil contains utility functions for writing tests for the grpcvtctldserver.

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.