grpcvtctldserver

package
v0.11.0 Latest Latest
Warning

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

 Go to latest Published: Jul 27, 2021 License: Apache-2.0 Imports: 37 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) (*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) 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) 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) 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) 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) 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) 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) 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) 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) 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.

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.