Documentation ¶
Index ¶
- func StartServer(s *grpc.Server, ts *topo.Server)
- type VtctldServer
- func (s *VtctldServer) AddCellInfo(ctx context.Context, req *vtctldatapb.AddCellInfoRequest) (*vtctldatapb.AddCellInfoResponse, error)
- func (s *VtctldServer) AddCellsAlias(ctx context.Context, req *vtctldatapb.AddCellsAliasRequest) (*vtctldatapb.AddCellsAliasResponse, error)
- func (s *VtctldServer) ApplyRoutingRules(ctx context.Context, req *vtctldatapb.ApplyRoutingRulesRequest) (*vtctldatapb.ApplyRoutingRulesResponse, error)
- func (s *VtctldServer) ApplySchema(ctx context.Context, req *vtctldatapb.ApplySchemaRequest) (resp *vtctldatapb.ApplySchemaResponse, err error)
- func (s *VtctldServer) ApplyVSchema(ctx context.Context, req *vtctldatapb.ApplyVSchemaRequest) (*vtctldatapb.ApplyVSchemaResponse, error)
- func (s *VtctldServer) ChangeTabletType(ctx context.Context, req *vtctldatapb.ChangeTabletTypeRequest) (*vtctldatapb.ChangeTabletTypeResponse, error)
- func (s *VtctldServer) CreateKeyspace(ctx context.Context, req *vtctldatapb.CreateKeyspaceRequest) (*vtctldatapb.CreateKeyspaceResponse, error)
- func (s *VtctldServer) CreateShard(ctx context.Context, req *vtctldatapb.CreateShardRequest) (*vtctldatapb.CreateShardResponse, error)
- func (s *VtctldServer) DeleteCellInfo(ctx context.Context, req *vtctldatapb.DeleteCellInfoRequest) (*vtctldatapb.DeleteCellInfoResponse, error)
- func (s *VtctldServer) DeleteCellsAlias(ctx context.Context, req *vtctldatapb.DeleteCellsAliasRequest) (*vtctldatapb.DeleteCellsAliasResponse, error)
- func (s *VtctldServer) DeleteKeyspace(ctx context.Context, req *vtctldatapb.DeleteKeyspaceRequest) (*vtctldatapb.DeleteKeyspaceResponse, error)
- func (s *VtctldServer) DeleteShards(ctx context.Context, req *vtctldatapb.DeleteShardsRequest) (*vtctldatapb.DeleteShardsResponse, error)
- func (s *VtctldServer) DeleteSrvVSchema(ctx context.Context, req *vtctldatapb.DeleteSrvVSchemaRequest) (*vtctldatapb.DeleteSrvVSchemaResponse, error)
- func (s *VtctldServer) DeleteTablets(ctx context.Context, req *vtctldatapb.DeleteTabletsRequest) (*vtctldatapb.DeleteTabletsResponse, error)
- func (s *VtctldServer) EmergencyReparentShard(ctx context.Context, req *vtctldatapb.EmergencyReparentShardRequest) (*vtctldatapb.EmergencyReparentShardResponse, error)
- func (s *VtctldServer) ExecuteHook(ctx context.Context, req *vtctldatapb.ExecuteHookRequest) (*vtctldatapb.ExecuteHookResponse, error)
- func (s *VtctldServer) FindAllShardsInKeyspace(ctx context.Context, req *vtctldatapb.FindAllShardsInKeyspaceRequest) (*vtctldatapb.FindAllShardsInKeyspaceResponse, error)
- func (s *VtctldServer) GetBackups(ctx context.Context, req *vtctldatapb.GetBackupsRequest) (*vtctldatapb.GetBackupsResponse, error)
- func (s *VtctldServer) GetCellInfo(ctx context.Context, req *vtctldatapb.GetCellInfoRequest) (*vtctldatapb.GetCellInfoResponse, error)
- func (s *VtctldServer) GetCellInfoNames(ctx context.Context, req *vtctldatapb.GetCellInfoNamesRequest) (*vtctldatapb.GetCellInfoNamesResponse, error)
- func (s *VtctldServer) GetCellsAliases(ctx context.Context, req *vtctldatapb.GetCellsAliasesRequest) (*vtctldatapb.GetCellsAliasesResponse, error)
- func (s *VtctldServer) GetKeyspace(ctx context.Context, req *vtctldatapb.GetKeyspaceRequest) (*vtctldatapb.GetKeyspaceResponse, error)
- func (s *VtctldServer) GetKeyspaces(ctx context.Context, req *vtctldatapb.GetKeyspacesRequest) (*vtctldatapb.GetKeyspacesResponse, error)
- func (s *VtctldServer) GetRoutingRules(ctx context.Context, req *vtctldatapb.GetRoutingRulesRequest) (*vtctldatapb.GetRoutingRulesResponse, error)
- func (s *VtctldServer) GetSchema(ctx context.Context, req *vtctldatapb.GetSchemaRequest) (*vtctldatapb.GetSchemaResponse, error)
- func (s *VtctldServer) GetShard(ctx context.Context, req *vtctldatapb.GetShardRequest) (*vtctldatapb.GetShardResponse, error)
- func (s *VtctldServer) GetSrvKeyspaceNames(ctx context.Context, req *vtctldatapb.GetSrvKeyspaceNamesRequest) (*vtctldatapb.GetSrvKeyspaceNamesResponse, error)
- func (s *VtctldServer) GetSrvKeyspaces(ctx context.Context, req *vtctldatapb.GetSrvKeyspacesRequest) (*vtctldatapb.GetSrvKeyspacesResponse, error)
- func (s *VtctldServer) GetSrvVSchema(ctx context.Context, req *vtctldatapb.GetSrvVSchemaRequest) (*vtctldatapb.GetSrvVSchemaResponse, error)
- func (s *VtctldServer) GetSrvVSchemas(ctx context.Context, req *vtctldatapb.GetSrvVSchemasRequest) (*vtctldatapb.GetSrvVSchemasResponse, error)
- func (s *VtctldServer) GetTablet(ctx context.Context, req *vtctldatapb.GetTabletRequest) (*vtctldatapb.GetTabletResponse, error)
- func (s *VtctldServer) GetTablets(ctx context.Context, req *vtctldatapb.GetTabletsRequest) (*vtctldatapb.GetTabletsResponse, error)
- func (s *VtctldServer) GetVSchema(ctx context.Context, req *vtctldatapb.GetVSchemaRequest) (*vtctldatapb.GetVSchemaResponse, error)
- func (s *VtctldServer) GetWorkflows(ctx context.Context, req *vtctldatapb.GetWorkflowsRequest) (*vtctldatapb.GetWorkflowsResponse, error)
- func (s *VtctldServer) InitShardPrimary(ctx context.Context, req *vtctldatapb.InitShardPrimaryRequest) (*vtctldatapb.InitShardPrimaryResponse, error)
- func (s *VtctldServer) InitShardPrimaryLocked(ctx context.Context, ev *events.Reparent, ...) error
- func (s *VtctldServer) PingTablet(ctx context.Context, req *vtctldatapb.PingTabletRequest) (*vtctldatapb.PingTabletResponse, error)
- func (s *VtctldServer) PlannedReparentShard(ctx context.Context, req *vtctldatapb.PlannedReparentShardRequest) (*vtctldatapb.PlannedReparentShardResponse, error)
- func (s *VtctldServer) RebuildKeyspaceGraph(ctx context.Context, req *vtctldatapb.RebuildKeyspaceGraphRequest) (*vtctldatapb.RebuildKeyspaceGraphResponse, error)
- func (s *VtctldServer) RebuildVSchemaGraph(ctx context.Context, req *vtctldatapb.RebuildVSchemaGraphRequest) (*vtctldatapb.RebuildVSchemaGraphResponse, error)
- func (s *VtctldServer) RefreshState(ctx context.Context, req *vtctldatapb.RefreshStateRequest) (*vtctldatapb.RefreshStateResponse, error)
- func (s *VtctldServer) RefreshStateByShard(ctx context.Context, req *vtctldatapb.RefreshStateByShardRequest) (*vtctldatapb.RefreshStateByShardResponse, error)
- func (s *VtctldServer) ReloadSchema(ctx context.Context, req *vtctldatapb.ReloadSchemaRequest) (*vtctldatapb.ReloadSchemaResponse, error)
- func (s *VtctldServer) ReloadSchemaKeyspace(ctx context.Context, req *vtctldatapb.ReloadSchemaKeyspaceRequest) (*vtctldatapb.ReloadSchemaKeyspaceResponse, error)
- func (s *VtctldServer) ReloadSchemaShard(ctx context.Context, req *vtctldatapb.ReloadSchemaShardRequest) (*vtctldatapb.ReloadSchemaShardResponse, error)
- func (s *VtctldServer) RemoveKeyspaceCell(ctx context.Context, req *vtctldatapb.RemoveKeyspaceCellRequest) (*vtctldatapb.RemoveKeyspaceCellResponse, error)
- func (s *VtctldServer) RemoveShardCell(ctx context.Context, req *vtctldatapb.RemoveShardCellRequest) (*vtctldatapb.RemoveShardCellResponse, error)
- func (s *VtctldServer) ReparentTablet(ctx context.Context, req *vtctldatapb.ReparentTabletRequest) (*vtctldatapb.ReparentTabletResponse, error)
- func (s *VtctldServer) RunHealthCheck(ctx context.Context, req *vtctldatapb.RunHealthCheckRequest) (*vtctldatapb.RunHealthCheckResponse, error)
- func (s *VtctldServer) SetKeyspaceServedFrom(ctx context.Context, req *vtctldatapb.SetKeyspaceServedFromRequest) (*vtctldatapb.SetKeyspaceServedFromResponse, error)
- func (s *VtctldServer) SetKeyspaceShardingInfo(ctx context.Context, req *vtctldatapb.SetKeyspaceShardingInfoRequest) (*vtctldatapb.SetKeyspaceShardingInfoResponse, error)
- func (s *VtctldServer) SetShardIsPrimaryServing(ctx context.Context, req *vtctldatapb.SetShardIsPrimaryServingRequest) (*vtctldatapb.SetShardIsPrimaryServingResponse, error)
- func (s *VtctldServer) SetShardTabletControl(ctx context.Context, req *vtctldatapb.SetShardTabletControlRequest) (*vtctldatapb.SetShardTabletControlResponse, error)
- func (s *VtctldServer) SetWritable(ctx context.Context, req *vtctldatapb.SetWritableRequest) (*vtctldatapb.SetWritableResponse, error)
- func (s *VtctldServer) ShardReplicationPositions(ctx context.Context, req *vtctldatapb.ShardReplicationPositionsRequest) (*vtctldatapb.ShardReplicationPositionsResponse, error)
- func (s *VtctldServer) SleepTablet(ctx context.Context, req *vtctldatapb.SleepTabletRequest) (*vtctldatapb.SleepTabletResponse, error)
- func (s *VtctldServer) StartReplication(ctx context.Context, req *vtctldatapb.StartReplicationRequest) (*vtctldatapb.StartReplicationResponse, error)
- func (s *VtctldServer) StopReplication(ctx context.Context, req *vtctldatapb.StopReplicationRequest) (*vtctldatapb.StopReplicationResponse, error)
- func (s *VtctldServer) TabletExternallyReparented(ctx context.Context, req *vtctldatapb.TabletExternallyReparentedRequest) (*vtctldatapb.TabletExternallyReparentedResponse, error)
- func (s *VtctldServer) UpdateCellInfo(ctx context.Context, req *vtctldatapb.UpdateCellInfoRequest) (*vtctldatapb.UpdateCellInfoResponse, error)
- func (s *VtctldServer) UpdateCellsAlias(ctx context.Context, req *vtctldatapb.UpdateCellsAliasRequest) (*vtctldatapb.UpdateCellsAliasResponse, error)
- func (s *VtctldServer) Validate(ctx context.Context, req *vtctldatapb.ValidateRequest) (*vtctldatapb.ValidateResponse, error)
- func (s *VtctldServer) ValidateKeyspace(ctx context.Context, req *vtctldatapb.ValidateKeyspaceRequest) (*vtctldatapb.ValidateKeyspaceResponse, error)
- func (s *VtctldServer) ValidateShard(ctx context.Context, req *vtctldatapb.ValidateShardRequest) (*vtctldatapb.ValidateShardResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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) (*vtctldatapb.AddCellInfoResponse, 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) (*vtctldatapb.AddCellsAliasResponse, 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) (*vtctldatapb.ApplyRoutingRulesResponse, 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) ApplyVSchema ¶ added in v0.11.0
func (s *VtctldServer) ApplyVSchema(ctx context.Context, req *vtctldatapb.ApplyVSchemaRequest) (*vtctldatapb.ApplyVSchemaResponse, error)
ApplyVSchema 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) (*vtctldatapb.ChangeTabletTypeResponse, 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) (*vtctldatapb.CreateKeyspaceResponse, 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) (*vtctldatapb.CreateShardResponse, 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) (*vtctldatapb.DeleteCellInfoResponse, 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) (*vtctldatapb.DeleteCellsAliasResponse, 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) (*vtctldatapb.DeleteKeyspaceResponse, 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) (*vtctldatapb.DeleteShardsResponse, 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) (*vtctldatapb.DeleteSrvVSchemaResponse, 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) (*vtctldatapb.DeleteTabletsResponse, 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) (*vtctldatapb.EmergencyReparentShardResponse, error)
EmergencyReparentShard is part of the vtctldservicepb.VtctldServer interface.
func (*VtctldServer) ExecuteHook ¶ added in v0.13.0
func (s *VtctldServer) ExecuteHook(ctx context.Context, req *vtctldatapb.ExecuteHookRequest) (*vtctldatapb.ExecuteHookResponse, error)
ExecuteHook is part of the vtctlservicepb.VtctldServer interface.
func (*VtctldServer) FindAllShardsInKeyspace ¶
func (s *VtctldServer) FindAllShardsInKeyspace(ctx context.Context, req *vtctldatapb.FindAllShardsInKeyspaceRequest) (*vtctldatapb.FindAllShardsInKeyspaceResponse, 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) (*vtctldatapb.GetBackupsResponse, 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) (*vtctldatapb.GetCellInfoResponse, 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) (*vtctldatapb.GetCellInfoNamesResponse, 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) (*vtctldatapb.GetCellsAliasesResponse, error)
GetCellsAliases is part of the vtctlservicepb.VtctldServer interface.
func (*VtctldServer) GetKeyspace ¶
func (s *VtctldServer) GetKeyspace(ctx context.Context, req *vtctldatapb.GetKeyspaceRequest) (*vtctldatapb.GetKeyspaceResponse, error)
GetKeyspace is part of the vtctlservicepb.VtctldServer interface.
func (*VtctldServer) GetKeyspaces ¶
func (s *VtctldServer) GetKeyspaces(ctx context.Context, req *vtctldatapb.GetKeyspacesRequest) (*vtctldatapb.GetKeyspacesResponse, error)
GetKeyspaces 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) (*vtctldatapb.GetRoutingRulesResponse, 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) (*vtctldatapb.GetSchemaResponse, 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) (*vtctldatapb.GetShardResponse, error)
GetShard 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) (*vtctldatapb.GetSrvKeyspaceNamesResponse, 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) (*vtctldatapb.GetSrvKeyspacesResponse, 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) (*vtctldatapb.GetSrvVSchemaResponse, 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) (*vtctldatapb.GetSrvVSchemasResponse, 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) (*vtctldatapb.GetTabletResponse, 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) (*vtctldatapb.GetTabletsResponse, error)
GetTablets is part of the vtctlservicepb.VtctldServer interface.
func (*VtctldServer) GetVSchema ¶ added in v0.10.0
func (s *VtctldServer) GetVSchema(ctx context.Context, req *vtctldatapb.GetVSchemaRequest) (*vtctldatapb.GetVSchemaResponse, error)
GetVSchema is part of the vtctlservicepb.VtctldServer interface.
func (*VtctldServer) GetWorkflows ¶ added in v0.10.0
func (s *VtctldServer) GetWorkflows(ctx context.Context, req *vtctldatapb.GetWorkflowsRequest) (*vtctldatapb.GetWorkflowsResponse, 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) (*vtctldatapb.InitShardPrimaryResponse, 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) (*vtctldatapb.PingTabletResponse, 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) (*vtctldatapb.PlannedReparentShardResponse, 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) (*vtctldatapb.RebuildKeyspaceGraphResponse, 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) (*vtctldatapb.RebuildVSchemaGraphResponse, 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) (*vtctldatapb.RefreshStateResponse, 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) (*vtctldatapb.RefreshStateByShardResponse, 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) (*vtctldatapb.ReloadSchemaResponse, 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) (*vtctldatapb.ReloadSchemaKeyspaceResponse, 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) (*vtctldatapb.ReloadSchemaShardResponse, error)
ReloadSchemaShard 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) (*vtctldatapb.RemoveKeyspaceCellResponse, 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) (*vtctldatapb.RemoveShardCellResponse, 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) (*vtctldatapb.ReparentTabletResponse, error)
ReparentTablet is part of the vtctldservicepb.VtctldServer interface.
func (*VtctldServer) RunHealthCheck ¶ added in v0.12.0
func (s *VtctldServer) RunHealthCheck(ctx context.Context, req *vtctldatapb.RunHealthCheckRequest) (*vtctldatapb.RunHealthCheckResponse, error)
RunHealthCheck 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) (*vtctldatapb.SetKeyspaceServedFromResponse, error)
SetKeyspaceServedFrom is part of the vtctlservicepb.VtctldServer interface.
func (*VtctldServer) SetKeyspaceShardingInfo ¶ added in v0.13.0
func (s *VtctldServer) SetKeyspaceShardingInfo(ctx context.Context, req *vtctldatapb.SetKeyspaceShardingInfoRequest) (*vtctldatapb.SetKeyspaceShardingInfoResponse, error)
SetKeyspaceShardingInfo 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) (*vtctldatapb.SetShardIsPrimaryServingResponse, 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) (*vtctldatapb.SetShardTabletControlResponse, 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) (*vtctldatapb.SetWritableResponse, error)
SetWritable is part of the vtctldservicepb.VtctldServer interface.
func (*VtctldServer) ShardReplicationPositions ¶ added in v0.10.0
func (s *VtctldServer) ShardReplicationPositions(ctx context.Context, req *vtctldatapb.ShardReplicationPositionsRequest) (*vtctldatapb.ShardReplicationPositionsResponse, error)
ShardReplicationPositions is part of the vtctldservicepb.VtctldServer interface.
func (*VtctldServer) SleepTablet ¶ added in v0.12.0
func (s *VtctldServer) SleepTablet(ctx context.Context, req *vtctldatapb.SleepTabletRequest) (*vtctldatapb.SleepTabletResponse, error)
SleepTablet 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) (*vtctldatapb.StartReplicationResponse, 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) (*vtctldatapb.StopReplicationResponse, 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) (*vtctldatapb.TabletExternallyReparentedResponse, 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) (*vtctldatapb.UpdateCellInfoResponse, 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) (*vtctldatapb.UpdateCellsAliasResponse, 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) (*vtctldatapb.ValidateResponse, 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) (*vtctldatapb.ValidateKeyspaceResponse, error)
ValidateKeyspace is part of the vtctlservicepb.VtctldServer interface.
func (*VtctldServer) ValidateShard ¶ added in v0.12.0
func (s *VtctldServer) ValidateShard(ctx context.Context, req *vtctldatapb.ValidateShardRequest) (*vtctldatapb.ValidateShardResponse, error)
ValidateShard is part of the vtctlservicepb.VtctldServer interface.