grpcvtctldserver

package
v0.15.1 Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2022 License: Apache-2.0 Imports: 52 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StartServer 

func StartServer(s *grpc.Server, 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 NewVtctldServer 

func NewVtctldServer(ts *topo.Server) *VtctldServer

NewVtctldServer returns a new VtctldServer for the given topo server.

func (*VtctldServer) AddCellInfo added in v0.11.0 

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

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

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

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

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

ApplyShardRoutingRules is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ApplyVSchema added in v0.11.0 

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

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

Backup is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) BackupShard added in v0.14.0 

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

BackupShard is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) ChangeTabletType added in v0.10.0 

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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) GetShardRoutingRules added in v0.15.0 

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

GetShardRoutingRules is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) GetSrvKeyspaceNames added in v0.12.0 

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

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

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

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

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

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

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

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

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

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

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

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) PingTablet added in v0.12.0 

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

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

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

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

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

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

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

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

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

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

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

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

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) RestoreFromBackup added in v0.14.0 

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

func (*VtctldServer) RunHealthCheck added in v0.12.0 

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

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

func (s *VtctldServer) SetKeyspaceServedFrom(ctx context.Context, req *vtctldatapb.SetKeyspaceServedFromRequest) (resp *vtctldatapb.SetKeyspaceServedFromResponse, err error)

SetKeyspaceServedFrom is part of the vtctlservicepb.VtctldServer interface.

func (*VtctldServer) SetShardIsPrimaryServing added in v0.12.0 

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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) Validate added in v0.12.0 

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

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

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

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

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

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

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

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.