Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterTabletManagerServer(s grpc.ServiceRegistrar, srv TabletManagerServer)
- type TabletManagerClient
- type TabletManagerServer
- type TabletManager_BackupClient
- type TabletManager_BackupServer
- type TabletManager_RestoreFromBackupClient
- type TabletManager_RestoreFromBackupServer
- type UnimplementedTabletManagerServer
- func (UnimplementedTabletManagerServer) ApplySchema(context.Context, *v18.ApplySchemaRequest) (*v18.ApplySchemaResponse, error)
- func (UnimplementedTabletManagerServer) Backup(*v18.BackupRequest, TabletManager_BackupServer) error
- func (UnimplementedTabletManagerServer) ChangeType(context.Context, *v18.ChangeTypeRequest) (*v18.ChangeTypeResponse, error)
- func (UnimplementedTabletManagerServer) CheckThrottler(context.Context, *v18.CheckThrottlerRequest) (*v18.CheckThrottlerResponse, error)
- func (UnimplementedTabletManagerServer) CreateVReplicationWorkflow(context.Context, *v18.CreateVReplicationWorkflowRequest) (*v18.CreateVReplicationWorkflowResponse, error)
- func (UnimplementedTabletManagerServer) DeleteVReplicationWorkflow(context.Context, *v18.DeleteVReplicationWorkflowRequest) (*v18.DeleteVReplicationWorkflowResponse, error)
- func (UnimplementedTabletManagerServer) DemotePrimary(context.Context, *v18.DemotePrimaryRequest) (*v18.DemotePrimaryResponse, error)
- func (UnimplementedTabletManagerServer) ExecuteFetchAsAllPrivs(context.Context, *v18.ExecuteFetchAsAllPrivsRequest) (*v18.ExecuteFetchAsAllPrivsResponse, error)
- func (UnimplementedTabletManagerServer) ExecuteFetchAsApp(context.Context, *v18.ExecuteFetchAsAppRequest) (*v18.ExecuteFetchAsAppResponse, error)
- func (UnimplementedTabletManagerServer) ExecuteFetchAsDba(context.Context, *v18.ExecuteFetchAsDbaRequest) (*v18.ExecuteFetchAsDbaResponse, error)
- func (UnimplementedTabletManagerServer) ExecuteHook(context.Context, *v18.ExecuteHookRequest) (*v18.ExecuteHookResponse, error)
- func (UnimplementedTabletManagerServer) ExecuteQuery(context.Context, *v18.ExecuteQueryRequest) (*v18.ExecuteQueryResponse, error)
- func (UnimplementedTabletManagerServer) FullStatus(context.Context, *v18.FullStatusRequest) (*v18.FullStatusResponse, error)
- func (UnimplementedTabletManagerServer) GetPermissions(context.Context, *v18.GetPermissionsRequest) (*v18.GetPermissionsResponse, error)
- func (UnimplementedTabletManagerServer) GetReplicas(context.Context, *v18.GetReplicasRequest) (*v18.GetReplicasResponse, error)
- func (UnimplementedTabletManagerServer) GetSchema(context.Context, *v18.GetSchemaRequest) (*v18.GetSchemaResponse, error)
- func (UnimplementedTabletManagerServer) InitPrimary(context.Context, *v18.InitPrimaryRequest) (*v18.InitPrimaryResponse, error)
- func (UnimplementedTabletManagerServer) InitReplica(context.Context, *v18.InitReplicaRequest) (*v18.InitReplicaResponse, error)
- func (UnimplementedTabletManagerServer) LockTables(context.Context, *v18.LockTablesRequest) (*v18.LockTablesResponse, error)
- func (UnimplementedTabletManagerServer) Ping(context.Context, *v18.PingRequest) (*v18.PingResponse, error)
- func (UnimplementedTabletManagerServer) PopulateReparentJournal(context.Context, *v18.PopulateReparentJournalRequest) (*v18.PopulateReparentJournalResponse, error)
- func (UnimplementedTabletManagerServer) PreflightSchema(context.Context, *v18.PreflightSchemaRequest) (*v18.PreflightSchemaResponse, error)
- func (UnimplementedTabletManagerServer) PrimaryPosition(context.Context, *v18.PrimaryPositionRequest) (*v18.PrimaryPositionResponse, error)
- func (UnimplementedTabletManagerServer) PrimaryStatus(context.Context, *v18.PrimaryStatusRequest) (*v18.PrimaryStatusResponse, error)
- func (UnimplementedTabletManagerServer) PromoteReplica(context.Context, *v18.PromoteReplicaRequest) (*v18.PromoteReplicaResponse, error)
- func (UnimplementedTabletManagerServer) ReadVReplicationWorkflow(context.Context, *v18.ReadVReplicationWorkflowRequest) (*v18.ReadVReplicationWorkflowResponse, error)
- func (UnimplementedTabletManagerServer) RefreshState(context.Context, *v18.RefreshStateRequest) (*v18.RefreshStateResponse, error)
- func (UnimplementedTabletManagerServer) ReloadSchema(context.Context, *v18.ReloadSchemaRequest) (*v18.ReloadSchemaResponse, error)
- func (UnimplementedTabletManagerServer) ReplicaWasPromoted(context.Context, *v18.ReplicaWasPromotedRequest) (*v18.ReplicaWasPromotedResponse, error)
- func (UnimplementedTabletManagerServer) ReplicaWasRestarted(context.Context, *v18.ReplicaWasRestartedRequest) (*v18.ReplicaWasRestartedResponse, error)
- func (UnimplementedTabletManagerServer) ReplicationStatus(context.Context, *v18.ReplicationStatusRequest) (*v18.ReplicationStatusResponse, error)
- func (UnimplementedTabletManagerServer) ResetReplication(context.Context, *v18.ResetReplicationRequest) (*v18.ResetReplicationResponse, error)
- func (UnimplementedTabletManagerServer) ResetReplicationParameters(context.Context, *v18.ResetReplicationParametersRequest) (*v18.ResetReplicationParametersResponse, error)
- func (UnimplementedTabletManagerServer) ResetSequences(context.Context, *v18.ResetSequencesRequest) (*v18.ResetSequencesResponse, error)
- func (UnimplementedTabletManagerServer) RestoreFromBackup(*v18.RestoreFromBackupRequest, TabletManager_RestoreFromBackupServer) error
- func (UnimplementedTabletManagerServer) RunHealthCheck(context.Context, *v18.RunHealthCheckRequest) (*v18.RunHealthCheckResponse, error)
- func (UnimplementedTabletManagerServer) SetReadOnly(context.Context, *v18.SetReadOnlyRequest) (*v18.SetReadOnlyResponse, error)
- func (UnimplementedTabletManagerServer) SetReadWrite(context.Context, *v18.SetReadWriteRequest) (*v18.SetReadWriteResponse, error)
- func (UnimplementedTabletManagerServer) SetReplicationSource(context.Context, *v18.SetReplicationSourceRequest) (*v18.SetReplicationSourceResponse, error)
- func (UnimplementedTabletManagerServer) Sleep(context.Context, *v18.SleepRequest) (*v18.SleepResponse, error)
- func (UnimplementedTabletManagerServer) StartReplication(context.Context, *v18.StartReplicationRequest) (*v18.StartReplicationResponse, error)
- func (UnimplementedTabletManagerServer) StartReplicationUntilAfter(context.Context, *v18.StartReplicationUntilAfterRequest) (*v18.StartReplicationUntilAfterResponse, error)
- func (UnimplementedTabletManagerServer) StopReplication(context.Context, *v18.StopReplicationRequest) (*v18.StopReplicationResponse, error)
- func (UnimplementedTabletManagerServer) StopReplicationAndGetStatus(context.Context, *v18.StopReplicationAndGetStatusRequest) (*v18.StopReplicationAndGetStatusResponse, error)
- func (UnimplementedTabletManagerServer) StopReplicationMinimum(context.Context, *v18.StopReplicationMinimumRequest) (*v18.StopReplicationMinimumResponse, error)
- func (UnimplementedTabletManagerServer) UndoDemotePrimary(context.Context, *v18.UndoDemotePrimaryRequest) (*v18.UndoDemotePrimaryResponse, error)
- func (UnimplementedTabletManagerServer) UnlockTables(context.Context, *v18.UnlockTablesRequest) (*v18.UnlockTablesResponse, error)
- func (UnimplementedTabletManagerServer) UpdateVReplicationWorkflow(context.Context, *v18.UpdateVReplicationWorkflowRequest) (*v18.UpdateVReplicationWorkflowResponse, error)
- func (UnimplementedTabletManagerServer) VDiff(context.Context, *v18.VDiffRequest) (*v18.VDiffResponse, error)
- func (UnimplementedTabletManagerServer) VReplicationExec(context.Context, *v18.VReplicationExecRequest) (*v18.VReplicationExecResponse, error)
- func (UnimplementedTabletManagerServer) VReplicationWaitForPos(context.Context, *v18.VReplicationWaitForPosRequest) (*v18.VReplicationWaitForPosResponse, error)
- func (UnimplementedTabletManagerServer) WaitForPosition(context.Context, *v18.WaitForPositionRequest) (*v18.WaitForPositionResponse, error)
- type UnsafeTabletManagerServer
Constants ¶
const ( TabletManager_Ping_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/Ping" TabletManager_Sleep_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/Sleep" TabletManager_ExecuteHook_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/ExecuteHook" TabletManager_GetSchema_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/GetSchema" TabletManager_GetPermissions_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/GetPermissions" TabletManager_SetReadOnly_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/SetReadOnly" TabletManager_SetReadWrite_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/SetReadWrite" TabletManager_ChangeType_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/ChangeType" TabletManager_RefreshState_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/RefreshState" TabletManager_RunHealthCheck_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/RunHealthCheck" TabletManager_ReloadSchema_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/ReloadSchema" TabletManager_PreflightSchema_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/PreflightSchema" TabletManager_ApplySchema_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/ApplySchema" TabletManager_ResetSequences_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/ResetSequences" TabletManager_LockTables_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/LockTables" TabletManager_UnlockTables_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/UnlockTables" TabletManager_ExecuteQuery_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/ExecuteQuery" TabletManager_ExecuteFetchAsDba_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/ExecuteFetchAsDba" TabletManager_ExecuteFetchAsAllPrivs_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/ExecuteFetchAsAllPrivs" TabletManager_ExecuteFetchAsApp_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/ExecuteFetchAsApp" TabletManager_ReplicationStatus_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/ReplicationStatus" TabletManager_PrimaryStatus_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/PrimaryStatus" TabletManager_PrimaryPosition_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/PrimaryPosition" TabletManager_WaitForPosition_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/WaitForPosition" TabletManager_StopReplication_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/StopReplication" TabletManager_StopReplicationMinimum_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/StopReplicationMinimum" TabletManager_StartReplication_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/StartReplication" TabletManager_StartReplicationUntilAfter_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/StartReplicationUntilAfter" TabletManager_GetReplicas_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/GetReplicas" TabletManager_CreateVReplicationWorkflow_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/CreateVReplicationWorkflow" TabletManager_DeleteVReplicationWorkflow_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/DeleteVReplicationWorkflow" TabletManager_ReadVReplicationWorkflow_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/ReadVReplicationWorkflow" TabletManager_VReplicationExec_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/VReplicationExec" TabletManager_VReplicationWaitForPos_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/VReplicationWaitForPos" TabletManager_UpdateVReplicationWorkflow_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/UpdateVReplicationWorkflow" TabletManager_VDiff_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/VDiff" TabletManager_ResetReplication_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/ResetReplication" TabletManager_InitPrimary_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/InitPrimary" TabletManager_PopulateReparentJournal_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/PopulateReparentJournal" TabletManager_InitReplica_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/InitReplica" TabletManager_DemotePrimary_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/DemotePrimary" TabletManager_UndoDemotePrimary_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/UndoDemotePrimary" TabletManager_ReplicaWasPromoted_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/ReplicaWasPromoted" TabletManager_ResetReplicationParameters_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/ResetReplicationParameters" TabletManager_FullStatus_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/FullStatus" TabletManager_SetReplicationSource_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/SetReplicationSource" TabletManager_ReplicaWasRestarted_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/ReplicaWasRestarted" TabletManager_StopReplicationAndGetStatus_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/StopReplicationAndGetStatus" TabletManager_PromoteReplica_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/PromoteReplica" TabletManager_Backup_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/Backup" TabletManager_RestoreFromBackup_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/RestoreFromBackup" TabletManager_CheckThrottler_FullMethodName = "/vitess.tabletmanagerservice.v18.TabletManager/CheckThrottler" )
Variables ¶
var TabletManager_ServiceDesc = grpc.ServiceDesc{ ServiceName: "vitess.tabletmanagerservice.v18.TabletManager", HandlerType: (*TabletManagerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Ping", Handler: _TabletManager_Ping_Handler, }, { MethodName: "Sleep", Handler: _TabletManager_Sleep_Handler, }, { MethodName: "ExecuteHook", Handler: _TabletManager_ExecuteHook_Handler, }, { MethodName: "GetSchema", Handler: _TabletManager_GetSchema_Handler, }, { MethodName: "GetPermissions", Handler: _TabletManager_GetPermissions_Handler, }, { MethodName: "SetReadOnly", Handler: _TabletManager_SetReadOnly_Handler, }, { MethodName: "SetReadWrite", Handler: _TabletManager_SetReadWrite_Handler, }, { MethodName: "ChangeType", Handler: _TabletManager_ChangeType_Handler, }, { MethodName: "RefreshState", Handler: _TabletManager_RefreshState_Handler, }, { MethodName: "RunHealthCheck", Handler: _TabletManager_RunHealthCheck_Handler, }, { MethodName: "ReloadSchema", Handler: _TabletManager_ReloadSchema_Handler, }, { MethodName: "PreflightSchema", Handler: _TabletManager_PreflightSchema_Handler, }, { MethodName: "ApplySchema", Handler: _TabletManager_ApplySchema_Handler, }, { MethodName: "ResetSequences", Handler: _TabletManager_ResetSequences_Handler, }, { MethodName: "LockTables", Handler: _TabletManager_LockTables_Handler, }, { MethodName: "UnlockTables", Handler: _TabletManager_UnlockTables_Handler, }, { MethodName: "ExecuteQuery", Handler: _TabletManager_ExecuteQuery_Handler, }, { MethodName: "ExecuteFetchAsDba", Handler: _TabletManager_ExecuteFetchAsDba_Handler, }, { MethodName: "ExecuteFetchAsAllPrivs", Handler: _TabletManager_ExecuteFetchAsAllPrivs_Handler, }, { MethodName: "ExecuteFetchAsApp", Handler: _TabletManager_ExecuteFetchAsApp_Handler, }, { MethodName: "ReplicationStatus", Handler: _TabletManager_ReplicationStatus_Handler, }, { MethodName: "PrimaryStatus", Handler: _TabletManager_PrimaryStatus_Handler, }, { MethodName: "PrimaryPosition", Handler: _TabletManager_PrimaryPosition_Handler, }, { MethodName: "WaitForPosition", Handler: _TabletManager_WaitForPosition_Handler, }, { MethodName: "StopReplication", Handler: _TabletManager_StopReplication_Handler, }, { MethodName: "StopReplicationMinimum", Handler: _TabletManager_StopReplicationMinimum_Handler, }, { MethodName: "StartReplication", Handler: _TabletManager_StartReplication_Handler, }, { MethodName: "StartReplicationUntilAfter", Handler: _TabletManager_StartReplicationUntilAfter_Handler, }, { MethodName: "GetReplicas", Handler: _TabletManager_GetReplicas_Handler, }, { MethodName: "CreateVReplicationWorkflow", Handler: _TabletManager_CreateVReplicationWorkflow_Handler, }, { MethodName: "DeleteVReplicationWorkflow", Handler: _TabletManager_DeleteVReplicationWorkflow_Handler, }, { MethodName: "ReadVReplicationWorkflow", Handler: _TabletManager_ReadVReplicationWorkflow_Handler, }, { MethodName: "VReplicationExec", Handler: _TabletManager_VReplicationExec_Handler, }, { MethodName: "VReplicationWaitForPos", Handler: _TabletManager_VReplicationWaitForPos_Handler, }, { MethodName: "UpdateVReplicationWorkflow", Handler: _TabletManager_UpdateVReplicationWorkflow_Handler, }, { MethodName: "VDiff", Handler: _TabletManager_VDiff_Handler, }, { MethodName: "ResetReplication", Handler: _TabletManager_ResetReplication_Handler, }, { MethodName: "InitPrimary", Handler: _TabletManager_InitPrimary_Handler, }, { MethodName: "PopulateReparentJournal", Handler: _TabletManager_PopulateReparentJournal_Handler, }, { MethodName: "InitReplica", Handler: _TabletManager_InitReplica_Handler, }, { MethodName: "DemotePrimary", Handler: _TabletManager_DemotePrimary_Handler, }, { MethodName: "UndoDemotePrimary", Handler: _TabletManager_UndoDemotePrimary_Handler, }, { MethodName: "ReplicaWasPromoted", Handler: _TabletManager_ReplicaWasPromoted_Handler, }, { MethodName: "ResetReplicationParameters", Handler: _TabletManager_ResetReplicationParameters_Handler, }, { MethodName: "FullStatus", Handler: _TabletManager_FullStatus_Handler, }, { MethodName: "SetReplicationSource", Handler: _TabletManager_SetReplicationSource_Handler, }, { MethodName: "ReplicaWasRestarted", Handler: _TabletManager_ReplicaWasRestarted_Handler, }, { MethodName: "StopReplicationAndGetStatus", Handler: _TabletManager_StopReplicationAndGetStatus_Handler, }, { MethodName: "PromoteReplica", Handler: _TabletManager_PromoteReplica_Handler, }, { MethodName: "CheckThrottler", Handler: _TabletManager_CheckThrottler_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Backup", Handler: _TabletManager_Backup_Handler, ServerStreams: true, }, { StreamName: "RestoreFromBackup", Handler: _TabletManager_RestoreFromBackup_Handler, ServerStreams: true, }, }, Metadata: "vitess/tabletmanagerservice/v18/tabletmanagerservice.proto", }
TabletManager_ServiceDesc is the grpc.ServiceDesc for TabletManager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterTabletManagerServer ¶
func RegisterTabletManagerServer(s grpc.ServiceRegistrar, srv TabletManagerServer)
Types ¶
type TabletManagerClient ¶
type TabletManagerClient interface { // Ping returns the input payload Ping(ctx context.Context, in *v18.PingRequest, opts ...grpc.CallOption) (*v18.PingResponse, error) // Sleep sleeps for the provided duration Sleep(ctx context.Context, in *v18.SleepRequest, opts ...grpc.CallOption) (*v18.SleepResponse, error) // ExecuteHook executes the hook remotely ExecuteHook(ctx context.Context, in *v18.ExecuteHookRequest, opts ...grpc.CallOption) (*v18.ExecuteHookResponse, error) // GetSchema asks the tablet for its schema GetSchema(ctx context.Context, in *v18.GetSchemaRequest, opts ...grpc.CallOption) (*v18.GetSchemaResponse, error) // GetPermissions asks the tablet for its permissions GetPermissions(ctx context.Context, in *v18.GetPermissionsRequest, opts ...grpc.CallOption) (*v18.GetPermissionsResponse, error) SetReadOnly(ctx context.Context, in *v18.SetReadOnlyRequest, opts ...grpc.CallOption) (*v18.SetReadOnlyResponse, error) SetReadWrite(ctx context.Context, in *v18.SetReadWriteRequest, opts ...grpc.CallOption) (*v18.SetReadWriteResponse, error) // ChangeType asks the remote tablet to change its type ChangeType(ctx context.Context, in *v18.ChangeTypeRequest, opts ...grpc.CallOption) (*v18.ChangeTypeResponse, error) RefreshState(ctx context.Context, in *v18.RefreshStateRequest, opts ...grpc.CallOption) (*v18.RefreshStateResponse, error) RunHealthCheck(ctx context.Context, in *v18.RunHealthCheckRequest, opts ...grpc.CallOption) (*v18.RunHealthCheckResponse, error) ReloadSchema(ctx context.Context, in *v18.ReloadSchemaRequest, opts ...grpc.CallOption) (*v18.ReloadSchemaResponse, error) PreflightSchema(ctx context.Context, in *v18.PreflightSchemaRequest, opts ...grpc.CallOption) (*v18.PreflightSchemaResponse, error) ApplySchema(ctx context.Context, in *v18.ApplySchemaRequest, opts ...grpc.CallOption) (*v18.ApplySchemaResponse, error) ResetSequences(ctx context.Context, in *v18.ResetSequencesRequest, opts ...grpc.CallOption) (*v18.ResetSequencesResponse, error) LockTables(ctx context.Context, in *v18.LockTablesRequest, opts ...grpc.CallOption) (*v18.LockTablesResponse, error) UnlockTables(ctx context.Context, in *v18.UnlockTablesRequest, opts ...grpc.CallOption) (*v18.UnlockTablesResponse, error) ExecuteQuery(ctx context.Context, in *v18.ExecuteQueryRequest, opts ...grpc.CallOption) (*v18.ExecuteQueryResponse, error) ExecuteFetchAsDba(ctx context.Context, in *v18.ExecuteFetchAsDbaRequest, opts ...grpc.CallOption) (*v18.ExecuteFetchAsDbaResponse, error) ExecuteFetchAsAllPrivs(ctx context.Context, in *v18.ExecuteFetchAsAllPrivsRequest, opts ...grpc.CallOption) (*v18.ExecuteFetchAsAllPrivsResponse, error) ExecuteFetchAsApp(ctx context.Context, in *v18.ExecuteFetchAsAppRequest, opts ...grpc.CallOption) (*v18.ExecuteFetchAsAppResponse, error) // ReplicationStatus returns the current replication status. ReplicationStatus(ctx context.Context, in *v18.ReplicationStatusRequest, opts ...grpc.CallOption) (*v18.ReplicationStatusResponse, error) // PrimaryStatus returns the current primary status. PrimaryStatus(ctx context.Context, in *v18.PrimaryStatusRequest, opts ...grpc.CallOption) (*v18.PrimaryStatusResponse, error) // PrimaryPosition returns the current primary position PrimaryPosition(ctx context.Context, in *v18.PrimaryPositionRequest, opts ...grpc.CallOption) (*v18.PrimaryPositionResponse, error) // WaitForPosition waits for the position to be reached WaitForPosition(ctx context.Context, in *v18.WaitForPositionRequest, opts ...grpc.CallOption) (*v18.WaitForPositionResponse, error) // StopReplication makes mysql stop its replication StopReplication(ctx context.Context, in *v18.StopReplicationRequest, opts ...grpc.CallOption) (*v18.StopReplicationResponse, error) // StopReplicationMinimum stops the mysql replication after it reaches // the provided minimum point StopReplicationMinimum(ctx context.Context, in *v18.StopReplicationMinimumRequest, opts ...grpc.CallOption) (*v18.StopReplicationMinimumResponse, error) // StartReplication starts the mysql replication StartReplication(ctx context.Context, in *v18.StartReplicationRequest, opts ...grpc.CallOption) (*v18.StartReplicationResponse, error) // StartReplicationUnitAfter starts the mysql replication until and including // the provided position StartReplicationUntilAfter(ctx context.Context, in *v18.StartReplicationUntilAfterRequest, opts ...grpc.CallOption) (*v18.StartReplicationUntilAfterResponse, error) // GetReplicas asks for the list of mysql replicas GetReplicas(ctx context.Context, in *v18.GetReplicasRequest, opts ...grpc.CallOption) (*v18.GetReplicasResponse, error) // VReplication API CreateVReplicationWorkflow(ctx context.Context, in *v18.CreateVReplicationWorkflowRequest, opts ...grpc.CallOption) (*v18.CreateVReplicationWorkflowResponse, error) DeleteVReplicationWorkflow(ctx context.Context, in *v18.DeleteVReplicationWorkflowRequest, opts ...grpc.CallOption) (*v18.DeleteVReplicationWorkflowResponse, error) ReadVReplicationWorkflow(ctx context.Context, in *v18.ReadVReplicationWorkflowRequest, opts ...grpc.CallOption) (*v18.ReadVReplicationWorkflowResponse, error) VReplicationExec(ctx context.Context, in *v18.VReplicationExecRequest, opts ...grpc.CallOption) (*v18.VReplicationExecResponse, error) VReplicationWaitForPos(ctx context.Context, in *v18.VReplicationWaitForPosRequest, opts ...grpc.CallOption) (*v18.VReplicationWaitForPosResponse, error) UpdateVReplicationWorkflow(ctx context.Context, in *v18.UpdateVReplicationWorkflowRequest, opts ...grpc.CallOption) (*v18.UpdateVReplicationWorkflowResponse, error) // VDiff API VDiff(ctx context.Context, in *v18.VDiffRequest, opts ...grpc.CallOption) (*v18.VDiffResponse, error) // ResetReplication makes the target not replicating ResetReplication(ctx context.Context, in *v18.ResetReplicationRequest, opts ...grpc.CallOption) (*v18.ResetReplicationResponse, error) // InitPrimary initializes the tablet as a primary InitPrimary(ctx context.Context, in *v18.InitPrimaryRequest, opts ...grpc.CallOption) (*v18.InitPrimaryResponse, error) // PopulateReparentJournal tells the tablet to add an entry to its // reparent journal PopulateReparentJournal(ctx context.Context, in *v18.PopulateReparentJournalRequest, opts ...grpc.CallOption) (*v18.PopulateReparentJournalResponse, error) // InitReplica tells the tablet to reparent to the primary unconditionally InitReplica(ctx context.Context, in *v18.InitReplicaRequest, opts ...grpc.CallOption) (*v18.InitReplicaResponse, error) // DemotePrimary tells the soon-to-be-former primary it's gonna change DemotePrimary(ctx context.Context, in *v18.DemotePrimaryRequest, opts ...grpc.CallOption) (*v18.DemotePrimaryResponse, error) // UndoDemotePrimary reverts all changes made by DemotePrimary UndoDemotePrimary(ctx context.Context, in *v18.UndoDemotePrimaryRequest, opts ...grpc.CallOption) (*v18.UndoDemotePrimaryResponse, error) // ReplicaWasPromoted tells the remote tablet it is now the primary ReplicaWasPromoted(ctx context.Context, in *v18.ReplicaWasPromotedRequest, opts ...grpc.CallOption) (*v18.ReplicaWasPromotedResponse, error) // ResetReplicationParameters resets the replica replication parameters ResetReplicationParameters(ctx context.Context, in *v18.ResetReplicationParametersRequest, opts ...grpc.CallOption) (*v18.ResetReplicationParametersResponse, error) // FullStatus collects and returns the full status of MySQL including the replication information, semi-sync information, GTID information among others FullStatus(ctx context.Context, in *v18.FullStatusRequest, opts ...grpc.CallOption) (*v18.FullStatusResponse, error) // SetReplicationSource tells the replica to reparent SetReplicationSource(ctx context.Context, in *v18.SetReplicationSourceRequest, opts ...grpc.CallOption) (*v18.SetReplicationSourceResponse, error) // ReplicaWasRestarted tells the remote tablet its primary has changed ReplicaWasRestarted(ctx context.Context, in *v18.ReplicaWasRestartedRequest, opts ...grpc.CallOption) (*v18.ReplicaWasRestartedResponse, error) // StopReplicationAndGetStatus stops MySQL replication, and returns the // replication status StopReplicationAndGetStatus(ctx context.Context, in *v18.StopReplicationAndGetStatusRequest, opts ...grpc.CallOption) (*v18.StopReplicationAndGetStatusResponse, error) // PromoteReplica makes the replica the new primary PromoteReplica(ctx context.Context, in *v18.PromoteReplicaRequest, opts ...grpc.CallOption) (*v18.PromoteReplicaResponse, error) Backup(ctx context.Context, in *v18.BackupRequest, opts ...grpc.CallOption) (TabletManager_BackupClient, error) // RestoreFromBackup deletes all local data and restores it from the latest backup. RestoreFromBackup(ctx context.Context, in *v18.RestoreFromBackupRequest, opts ...grpc.CallOption) (TabletManager_RestoreFromBackupClient, error) // CheckThrottler issues a 'check' on a tablet's throttler CheckThrottler(ctx context.Context, in *v18.CheckThrottlerRequest, opts ...grpc.CallOption) (*v18.CheckThrottlerResponse, error) }
TabletManagerClient is the client API for TabletManager service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewTabletManagerClient ¶
func NewTabletManagerClient(cc grpc.ClientConnInterface) TabletManagerClient
type TabletManagerServer ¶
type TabletManagerServer interface { // Ping returns the input payload Ping(context.Context, *v18.PingRequest) (*v18.PingResponse, error) // Sleep sleeps for the provided duration Sleep(context.Context, *v18.SleepRequest) (*v18.SleepResponse, error) // ExecuteHook executes the hook remotely ExecuteHook(context.Context, *v18.ExecuteHookRequest) (*v18.ExecuteHookResponse, error) // GetSchema asks the tablet for its schema GetSchema(context.Context, *v18.GetSchemaRequest) (*v18.GetSchemaResponse, error) // GetPermissions asks the tablet for its permissions GetPermissions(context.Context, *v18.GetPermissionsRequest) (*v18.GetPermissionsResponse, error) SetReadOnly(context.Context, *v18.SetReadOnlyRequest) (*v18.SetReadOnlyResponse, error) SetReadWrite(context.Context, *v18.SetReadWriteRequest) (*v18.SetReadWriteResponse, error) // ChangeType asks the remote tablet to change its type ChangeType(context.Context, *v18.ChangeTypeRequest) (*v18.ChangeTypeResponse, error) RefreshState(context.Context, *v18.RefreshStateRequest) (*v18.RefreshStateResponse, error) RunHealthCheck(context.Context, *v18.RunHealthCheckRequest) (*v18.RunHealthCheckResponse, error) ReloadSchema(context.Context, *v18.ReloadSchemaRequest) (*v18.ReloadSchemaResponse, error) PreflightSchema(context.Context, *v18.PreflightSchemaRequest) (*v18.PreflightSchemaResponse, error) ApplySchema(context.Context, *v18.ApplySchemaRequest) (*v18.ApplySchemaResponse, error) ResetSequences(context.Context, *v18.ResetSequencesRequest) (*v18.ResetSequencesResponse, error) LockTables(context.Context, *v18.LockTablesRequest) (*v18.LockTablesResponse, error) UnlockTables(context.Context, *v18.UnlockTablesRequest) (*v18.UnlockTablesResponse, error) ExecuteQuery(context.Context, *v18.ExecuteQueryRequest) (*v18.ExecuteQueryResponse, error) ExecuteFetchAsDba(context.Context, *v18.ExecuteFetchAsDbaRequest) (*v18.ExecuteFetchAsDbaResponse, error) ExecuteFetchAsAllPrivs(context.Context, *v18.ExecuteFetchAsAllPrivsRequest) (*v18.ExecuteFetchAsAllPrivsResponse, error) ExecuteFetchAsApp(context.Context, *v18.ExecuteFetchAsAppRequest) (*v18.ExecuteFetchAsAppResponse, error) // ReplicationStatus returns the current replication status. ReplicationStatus(context.Context, *v18.ReplicationStatusRequest) (*v18.ReplicationStatusResponse, error) // PrimaryStatus returns the current primary status. PrimaryStatus(context.Context, *v18.PrimaryStatusRequest) (*v18.PrimaryStatusResponse, error) // PrimaryPosition returns the current primary position PrimaryPosition(context.Context, *v18.PrimaryPositionRequest) (*v18.PrimaryPositionResponse, error) // WaitForPosition waits for the position to be reached WaitForPosition(context.Context, *v18.WaitForPositionRequest) (*v18.WaitForPositionResponse, error) // StopReplication makes mysql stop its replication StopReplication(context.Context, *v18.StopReplicationRequest) (*v18.StopReplicationResponse, error) // StopReplicationMinimum stops the mysql replication after it reaches // the provided minimum point StopReplicationMinimum(context.Context, *v18.StopReplicationMinimumRequest) (*v18.StopReplicationMinimumResponse, error) // StartReplication starts the mysql replication StartReplication(context.Context, *v18.StartReplicationRequest) (*v18.StartReplicationResponse, error) // StartReplicationUnitAfter starts the mysql replication until and including // the provided position StartReplicationUntilAfter(context.Context, *v18.StartReplicationUntilAfterRequest) (*v18.StartReplicationUntilAfterResponse, error) // GetReplicas asks for the list of mysql replicas GetReplicas(context.Context, *v18.GetReplicasRequest) (*v18.GetReplicasResponse, error) // VReplication API CreateVReplicationWorkflow(context.Context, *v18.CreateVReplicationWorkflowRequest) (*v18.CreateVReplicationWorkflowResponse, error) DeleteVReplicationWorkflow(context.Context, *v18.DeleteVReplicationWorkflowRequest) (*v18.DeleteVReplicationWorkflowResponse, error) ReadVReplicationWorkflow(context.Context, *v18.ReadVReplicationWorkflowRequest) (*v18.ReadVReplicationWorkflowResponse, error) VReplicationExec(context.Context, *v18.VReplicationExecRequest) (*v18.VReplicationExecResponse, error) VReplicationWaitForPos(context.Context, *v18.VReplicationWaitForPosRequest) (*v18.VReplicationWaitForPosResponse, error) UpdateVReplicationWorkflow(context.Context, *v18.UpdateVReplicationWorkflowRequest) (*v18.UpdateVReplicationWorkflowResponse, error) // VDiff API VDiff(context.Context, *v18.VDiffRequest) (*v18.VDiffResponse, error) // ResetReplication makes the target not replicating ResetReplication(context.Context, *v18.ResetReplicationRequest) (*v18.ResetReplicationResponse, error) // InitPrimary initializes the tablet as a primary InitPrimary(context.Context, *v18.InitPrimaryRequest) (*v18.InitPrimaryResponse, error) // PopulateReparentJournal tells the tablet to add an entry to its // reparent journal PopulateReparentJournal(context.Context, *v18.PopulateReparentJournalRequest) (*v18.PopulateReparentJournalResponse, error) // InitReplica tells the tablet to reparent to the primary unconditionally InitReplica(context.Context, *v18.InitReplicaRequest) (*v18.InitReplicaResponse, error) // DemotePrimary tells the soon-to-be-former primary it's gonna change DemotePrimary(context.Context, *v18.DemotePrimaryRequest) (*v18.DemotePrimaryResponse, error) // UndoDemotePrimary reverts all changes made by DemotePrimary UndoDemotePrimary(context.Context, *v18.UndoDemotePrimaryRequest) (*v18.UndoDemotePrimaryResponse, error) // ReplicaWasPromoted tells the remote tablet it is now the primary ReplicaWasPromoted(context.Context, *v18.ReplicaWasPromotedRequest) (*v18.ReplicaWasPromotedResponse, error) // ResetReplicationParameters resets the replica replication parameters ResetReplicationParameters(context.Context, *v18.ResetReplicationParametersRequest) (*v18.ResetReplicationParametersResponse, error) // FullStatus collects and returns the full status of MySQL including the replication information, semi-sync information, GTID information among others FullStatus(context.Context, *v18.FullStatusRequest) (*v18.FullStatusResponse, error) // SetReplicationSource tells the replica to reparent SetReplicationSource(context.Context, *v18.SetReplicationSourceRequest) (*v18.SetReplicationSourceResponse, error) // ReplicaWasRestarted tells the remote tablet its primary has changed ReplicaWasRestarted(context.Context, *v18.ReplicaWasRestartedRequest) (*v18.ReplicaWasRestartedResponse, error) // StopReplicationAndGetStatus stops MySQL replication, and returns the // replication status StopReplicationAndGetStatus(context.Context, *v18.StopReplicationAndGetStatusRequest) (*v18.StopReplicationAndGetStatusResponse, error) // PromoteReplica makes the replica the new primary PromoteReplica(context.Context, *v18.PromoteReplicaRequest) (*v18.PromoteReplicaResponse, error) Backup(*v18.BackupRequest, TabletManager_BackupServer) error // RestoreFromBackup deletes all local data and restores it from the latest backup. RestoreFromBackup(*v18.RestoreFromBackupRequest, TabletManager_RestoreFromBackupServer) error // CheckThrottler issues a 'check' on a tablet's throttler CheckThrottler(context.Context, *v18.CheckThrottlerRequest) (*v18.CheckThrottlerResponse, error) }
TabletManagerServer is the server API for TabletManager service. All implementations should embed UnimplementedTabletManagerServer for forward compatibility
type TabletManager_BackupClient ¶
type TabletManager_BackupClient interface { Recv() (*v18.BackupResponse, error) grpc.ClientStream }
type TabletManager_BackupServer ¶
type TabletManager_BackupServer interface { Send(*v18.BackupResponse) error grpc.ServerStream }
type TabletManager_RestoreFromBackupClient ¶
type TabletManager_RestoreFromBackupClient interface { Recv() (*v18.RestoreFromBackupResponse, error) grpc.ClientStream }
type TabletManager_RestoreFromBackupServer ¶
type TabletManager_RestoreFromBackupServer interface { Send(*v18.RestoreFromBackupResponse) error grpc.ServerStream }
type UnimplementedTabletManagerServer ¶
type UnimplementedTabletManagerServer struct { }
UnimplementedTabletManagerServer should be embedded to have forward compatible implementations.
func (UnimplementedTabletManagerServer) ApplySchema ¶
func (UnimplementedTabletManagerServer) ApplySchema(context.Context, *v18.ApplySchemaRequest) (*v18.ApplySchemaResponse, error)
func (UnimplementedTabletManagerServer) Backup ¶
func (UnimplementedTabletManagerServer) Backup(*v18.BackupRequest, TabletManager_BackupServer) error
func (UnimplementedTabletManagerServer) ChangeType ¶
func (UnimplementedTabletManagerServer) ChangeType(context.Context, *v18.ChangeTypeRequest) (*v18.ChangeTypeResponse, error)
func (UnimplementedTabletManagerServer) CheckThrottler ¶
func (UnimplementedTabletManagerServer) CheckThrottler(context.Context, *v18.CheckThrottlerRequest) (*v18.CheckThrottlerResponse, error)
func (UnimplementedTabletManagerServer) CreateVReplicationWorkflow ¶
func (UnimplementedTabletManagerServer) CreateVReplicationWorkflow(context.Context, *v18.CreateVReplicationWorkflowRequest) (*v18.CreateVReplicationWorkflowResponse, error)
func (UnimplementedTabletManagerServer) DeleteVReplicationWorkflow ¶
func (UnimplementedTabletManagerServer) DeleteVReplicationWorkflow(context.Context, *v18.DeleteVReplicationWorkflowRequest) (*v18.DeleteVReplicationWorkflowResponse, error)
func (UnimplementedTabletManagerServer) DemotePrimary ¶
func (UnimplementedTabletManagerServer) DemotePrimary(context.Context, *v18.DemotePrimaryRequest) (*v18.DemotePrimaryResponse, error)
func (UnimplementedTabletManagerServer) ExecuteFetchAsAllPrivs ¶
func (UnimplementedTabletManagerServer) ExecuteFetchAsAllPrivs(context.Context, *v18.ExecuteFetchAsAllPrivsRequest) (*v18.ExecuteFetchAsAllPrivsResponse, error)
func (UnimplementedTabletManagerServer) ExecuteFetchAsApp ¶
func (UnimplementedTabletManagerServer) ExecuteFetchAsApp(context.Context, *v18.ExecuteFetchAsAppRequest) (*v18.ExecuteFetchAsAppResponse, error)
func (UnimplementedTabletManagerServer) ExecuteFetchAsDba ¶
func (UnimplementedTabletManagerServer) ExecuteFetchAsDba(context.Context, *v18.ExecuteFetchAsDbaRequest) (*v18.ExecuteFetchAsDbaResponse, error)
func (UnimplementedTabletManagerServer) ExecuteHook ¶
func (UnimplementedTabletManagerServer) ExecuteHook(context.Context, *v18.ExecuteHookRequest) (*v18.ExecuteHookResponse, error)
func (UnimplementedTabletManagerServer) ExecuteQuery ¶
func (UnimplementedTabletManagerServer) ExecuteQuery(context.Context, *v18.ExecuteQueryRequest) (*v18.ExecuteQueryResponse, error)
func (UnimplementedTabletManagerServer) FullStatus ¶
func (UnimplementedTabletManagerServer) FullStatus(context.Context, *v18.FullStatusRequest) (*v18.FullStatusResponse, error)
func (UnimplementedTabletManagerServer) GetPermissions ¶
func (UnimplementedTabletManagerServer) GetPermissions(context.Context, *v18.GetPermissionsRequest) (*v18.GetPermissionsResponse, error)
func (UnimplementedTabletManagerServer) GetReplicas ¶
func (UnimplementedTabletManagerServer) GetReplicas(context.Context, *v18.GetReplicasRequest) (*v18.GetReplicasResponse, error)
func (UnimplementedTabletManagerServer) GetSchema ¶
func (UnimplementedTabletManagerServer) GetSchema(context.Context, *v18.GetSchemaRequest) (*v18.GetSchemaResponse, error)
func (UnimplementedTabletManagerServer) InitPrimary ¶
func (UnimplementedTabletManagerServer) InitPrimary(context.Context, *v18.InitPrimaryRequest) (*v18.InitPrimaryResponse, error)
func (UnimplementedTabletManagerServer) InitReplica ¶
func (UnimplementedTabletManagerServer) InitReplica(context.Context, *v18.InitReplicaRequest) (*v18.InitReplicaResponse, error)
func (UnimplementedTabletManagerServer) LockTables ¶
func (UnimplementedTabletManagerServer) LockTables(context.Context, *v18.LockTablesRequest) (*v18.LockTablesResponse, error)
func (UnimplementedTabletManagerServer) Ping ¶
func (UnimplementedTabletManagerServer) Ping(context.Context, *v18.PingRequest) (*v18.PingResponse, error)
func (UnimplementedTabletManagerServer) PopulateReparentJournal ¶
func (UnimplementedTabletManagerServer) PopulateReparentJournal(context.Context, *v18.PopulateReparentJournalRequest) (*v18.PopulateReparentJournalResponse, error)
func (UnimplementedTabletManagerServer) PreflightSchema ¶
func (UnimplementedTabletManagerServer) PreflightSchema(context.Context, *v18.PreflightSchemaRequest) (*v18.PreflightSchemaResponse, error)
func (UnimplementedTabletManagerServer) PrimaryPosition ¶
func (UnimplementedTabletManagerServer) PrimaryPosition(context.Context, *v18.PrimaryPositionRequest) (*v18.PrimaryPositionResponse, error)
func (UnimplementedTabletManagerServer) PrimaryStatus ¶
func (UnimplementedTabletManagerServer) PrimaryStatus(context.Context, *v18.PrimaryStatusRequest) (*v18.PrimaryStatusResponse, error)
func (UnimplementedTabletManagerServer) PromoteReplica ¶
func (UnimplementedTabletManagerServer) PromoteReplica(context.Context, *v18.PromoteReplicaRequest) (*v18.PromoteReplicaResponse, error)
func (UnimplementedTabletManagerServer) ReadVReplicationWorkflow ¶
func (UnimplementedTabletManagerServer) ReadVReplicationWorkflow(context.Context, *v18.ReadVReplicationWorkflowRequest) (*v18.ReadVReplicationWorkflowResponse, error)
func (UnimplementedTabletManagerServer) RefreshState ¶
func (UnimplementedTabletManagerServer) RefreshState(context.Context, *v18.RefreshStateRequest) (*v18.RefreshStateResponse, error)
func (UnimplementedTabletManagerServer) ReloadSchema ¶
func (UnimplementedTabletManagerServer) ReloadSchema(context.Context, *v18.ReloadSchemaRequest) (*v18.ReloadSchemaResponse, error)
func (UnimplementedTabletManagerServer) ReplicaWasPromoted ¶
func (UnimplementedTabletManagerServer) ReplicaWasPromoted(context.Context, *v18.ReplicaWasPromotedRequest) (*v18.ReplicaWasPromotedResponse, error)
func (UnimplementedTabletManagerServer) ReplicaWasRestarted ¶
func (UnimplementedTabletManagerServer) ReplicaWasRestarted(context.Context, *v18.ReplicaWasRestartedRequest) (*v18.ReplicaWasRestartedResponse, error)
func (UnimplementedTabletManagerServer) ReplicationStatus ¶
func (UnimplementedTabletManagerServer) ReplicationStatus(context.Context, *v18.ReplicationStatusRequest) (*v18.ReplicationStatusResponse, error)
func (UnimplementedTabletManagerServer) ResetReplication ¶
func (UnimplementedTabletManagerServer) ResetReplication(context.Context, *v18.ResetReplicationRequest) (*v18.ResetReplicationResponse, error)
func (UnimplementedTabletManagerServer) ResetReplicationParameters ¶
func (UnimplementedTabletManagerServer) ResetReplicationParameters(context.Context, *v18.ResetReplicationParametersRequest) (*v18.ResetReplicationParametersResponse, error)
func (UnimplementedTabletManagerServer) ResetSequences ¶
func (UnimplementedTabletManagerServer) ResetSequences(context.Context, *v18.ResetSequencesRequest) (*v18.ResetSequencesResponse, error)
func (UnimplementedTabletManagerServer) RestoreFromBackup ¶
func (UnimplementedTabletManagerServer) RestoreFromBackup(*v18.RestoreFromBackupRequest, TabletManager_RestoreFromBackupServer) error
func (UnimplementedTabletManagerServer) RunHealthCheck ¶
func (UnimplementedTabletManagerServer) RunHealthCheck(context.Context, *v18.RunHealthCheckRequest) (*v18.RunHealthCheckResponse, error)
func (UnimplementedTabletManagerServer) SetReadOnly ¶
func (UnimplementedTabletManagerServer) SetReadOnly(context.Context, *v18.SetReadOnlyRequest) (*v18.SetReadOnlyResponse, error)
func (UnimplementedTabletManagerServer) SetReadWrite ¶
func (UnimplementedTabletManagerServer) SetReadWrite(context.Context, *v18.SetReadWriteRequest) (*v18.SetReadWriteResponse, error)
func (UnimplementedTabletManagerServer) SetReplicationSource ¶
func (UnimplementedTabletManagerServer) SetReplicationSource(context.Context, *v18.SetReplicationSourceRequest) (*v18.SetReplicationSourceResponse, error)
func (UnimplementedTabletManagerServer) Sleep ¶
func (UnimplementedTabletManagerServer) Sleep(context.Context, *v18.SleepRequest) (*v18.SleepResponse, error)
func (UnimplementedTabletManagerServer) StartReplication ¶
func (UnimplementedTabletManagerServer) StartReplication(context.Context, *v18.StartReplicationRequest) (*v18.StartReplicationResponse, error)
func (UnimplementedTabletManagerServer) StartReplicationUntilAfter ¶
func (UnimplementedTabletManagerServer) StartReplicationUntilAfter(context.Context, *v18.StartReplicationUntilAfterRequest) (*v18.StartReplicationUntilAfterResponse, error)
func (UnimplementedTabletManagerServer) StopReplication ¶
func (UnimplementedTabletManagerServer) StopReplication(context.Context, *v18.StopReplicationRequest) (*v18.StopReplicationResponse, error)
func (UnimplementedTabletManagerServer) StopReplicationAndGetStatus ¶
func (UnimplementedTabletManagerServer) StopReplicationAndGetStatus(context.Context, *v18.StopReplicationAndGetStatusRequest) (*v18.StopReplicationAndGetStatusResponse, error)
func (UnimplementedTabletManagerServer) StopReplicationMinimum ¶
func (UnimplementedTabletManagerServer) StopReplicationMinimum(context.Context, *v18.StopReplicationMinimumRequest) (*v18.StopReplicationMinimumResponse, error)
func (UnimplementedTabletManagerServer) UndoDemotePrimary ¶
func (UnimplementedTabletManagerServer) UndoDemotePrimary(context.Context, *v18.UndoDemotePrimaryRequest) (*v18.UndoDemotePrimaryResponse, error)
func (UnimplementedTabletManagerServer) UnlockTables ¶
func (UnimplementedTabletManagerServer) UnlockTables(context.Context, *v18.UnlockTablesRequest) (*v18.UnlockTablesResponse, error)
func (UnimplementedTabletManagerServer) UpdateVReplicationWorkflow ¶
func (UnimplementedTabletManagerServer) UpdateVReplicationWorkflow(context.Context, *v18.UpdateVReplicationWorkflowRequest) (*v18.UpdateVReplicationWorkflowResponse, error)
func (UnimplementedTabletManagerServer) VDiff ¶
func (UnimplementedTabletManagerServer) VDiff(context.Context, *v18.VDiffRequest) (*v18.VDiffResponse, error)
func (UnimplementedTabletManagerServer) VReplicationExec ¶
func (UnimplementedTabletManagerServer) VReplicationExec(context.Context, *v18.VReplicationExecRequest) (*v18.VReplicationExecResponse, error)
func (UnimplementedTabletManagerServer) VReplicationWaitForPos ¶
func (UnimplementedTabletManagerServer) VReplicationWaitForPos(context.Context, *v18.VReplicationWaitForPosRequest) (*v18.VReplicationWaitForPosResponse, error)
func (UnimplementedTabletManagerServer) WaitForPosition ¶
func (UnimplementedTabletManagerServer) WaitForPosition(context.Context, *v18.WaitForPositionRequest) (*v18.WaitForPositionResponse, error)
type UnsafeTabletManagerServer ¶
type UnsafeTabletManagerServer interface {
// contains filtered or unexported methods
}
UnsafeTabletManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TabletManagerServer will result in compilation errors.