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, *dev.ApplySchemaRequest) (*dev.ApplySchemaResponse, error)
- func (UnimplementedTabletManagerServer) Backup(*dev.BackupRequest, TabletManager_BackupServer) error
- func (UnimplementedTabletManagerServer) ChangeType(context.Context, *dev.ChangeTypeRequest) (*dev.ChangeTypeResponse, error)
- func (UnimplementedTabletManagerServer) CheckThrottler(context.Context, *dev.CheckThrottlerRequest) (*dev.CheckThrottlerResponse, error)
- func (UnimplementedTabletManagerServer) CreateVReplicationWorkflow(context.Context, *dev.CreateVReplicationWorkflowRequest) (*dev.CreateVReplicationWorkflowResponse, error)
- func (UnimplementedTabletManagerServer) DeleteVReplicationWorkflow(context.Context, *dev.DeleteVReplicationWorkflowRequest) (*dev.DeleteVReplicationWorkflowResponse, error)
- func (UnimplementedTabletManagerServer) DemotePrimary(context.Context, *dev.DemotePrimaryRequest) (*dev.DemotePrimaryResponse, error)
- func (UnimplementedTabletManagerServer) ExecuteFetchAsAllPrivs(context.Context, *dev.ExecuteFetchAsAllPrivsRequest) (*dev.ExecuteFetchAsAllPrivsResponse, error)
- func (UnimplementedTabletManagerServer) ExecuteFetchAsApp(context.Context, *dev.ExecuteFetchAsAppRequest) (*dev.ExecuteFetchAsAppResponse, error)
- func (UnimplementedTabletManagerServer) ExecuteFetchAsDba(context.Context, *dev.ExecuteFetchAsDbaRequest) (*dev.ExecuteFetchAsDbaResponse, error)
- func (UnimplementedTabletManagerServer) ExecuteHook(context.Context, *dev.ExecuteHookRequest) (*dev.ExecuteHookResponse, error)
- func (UnimplementedTabletManagerServer) ExecuteQuery(context.Context, *dev.ExecuteQueryRequest) (*dev.ExecuteQueryResponse, error)
- func (UnimplementedTabletManagerServer) FullStatus(context.Context, *dev.FullStatusRequest) (*dev.FullStatusResponse, error)
- func (UnimplementedTabletManagerServer) GetPermissions(context.Context, *dev.GetPermissionsRequest) (*dev.GetPermissionsResponse, error)
- func (UnimplementedTabletManagerServer) GetReplicas(context.Context, *dev.GetReplicasRequest) (*dev.GetReplicasResponse, error)
- func (UnimplementedTabletManagerServer) GetSchema(context.Context, *dev.GetSchemaRequest) (*dev.GetSchemaResponse, error)
- func (UnimplementedTabletManagerServer) InitPrimary(context.Context, *dev.InitPrimaryRequest) (*dev.InitPrimaryResponse, error)
- func (UnimplementedTabletManagerServer) InitReplica(context.Context, *dev.InitReplicaRequest) (*dev.InitReplicaResponse, error)
- func (UnimplementedTabletManagerServer) LockTables(context.Context, *dev.LockTablesRequest) (*dev.LockTablesResponse, error)
- func (UnimplementedTabletManagerServer) Ping(context.Context, *dev.PingRequest) (*dev.PingResponse, error)
- func (UnimplementedTabletManagerServer) PopulateReparentJournal(context.Context, *dev.PopulateReparentJournalRequest) (*dev.PopulateReparentJournalResponse, error)
- func (UnimplementedTabletManagerServer) PreflightSchema(context.Context, *dev.PreflightSchemaRequest) (*dev.PreflightSchemaResponse, error)
- func (UnimplementedTabletManagerServer) PrimaryPosition(context.Context, *dev.PrimaryPositionRequest) (*dev.PrimaryPositionResponse, error)
- func (UnimplementedTabletManagerServer) PrimaryStatus(context.Context, *dev.PrimaryStatusRequest) (*dev.PrimaryStatusResponse, error)
- func (UnimplementedTabletManagerServer) PromoteReplica(context.Context, *dev.PromoteReplicaRequest) (*dev.PromoteReplicaResponse, error)
- func (UnimplementedTabletManagerServer) ReadVReplicationWorkflow(context.Context, *dev.ReadVReplicationWorkflowRequest) (*dev.ReadVReplicationWorkflowResponse, error)
- func (UnimplementedTabletManagerServer) RefreshState(context.Context, *dev.RefreshStateRequest) (*dev.RefreshStateResponse, error)
- func (UnimplementedTabletManagerServer) ReloadSchema(context.Context, *dev.ReloadSchemaRequest) (*dev.ReloadSchemaResponse, error)
- func (UnimplementedTabletManagerServer) ReplicaWasPromoted(context.Context, *dev.ReplicaWasPromotedRequest) (*dev.ReplicaWasPromotedResponse, error)
- func (UnimplementedTabletManagerServer) ReplicaWasRestarted(context.Context, *dev.ReplicaWasRestartedRequest) (*dev.ReplicaWasRestartedResponse, error)
- func (UnimplementedTabletManagerServer) ReplicationStatus(context.Context, *dev.ReplicationStatusRequest) (*dev.ReplicationStatusResponse, error)
- func (UnimplementedTabletManagerServer) ResetReplication(context.Context, *dev.ResetReplicationRequest) (*dev.ResetReplicationResponse, error)
- func (UnimplementedTabletManagerServer) ResetReplicationParameters(context.Context, *dev.ResetReplicationParametersRequest) (*dev.ResetReplicationParametersResponse, error)
- func (UnimplementedTabletManagerServer) ResetSequences(context.Context, *dev.ResetSequencesRequest) (*dev.ResetSequencesResponse, error)
- func (UnimplementedTabletManagerServer) RestoreFromBackup(*dev.RestoreFromBackupRequest, TabletManager_RestoreFromBackupServer) error
- func (UnimplementedTabletManagerServer) RunHealthCheck(context.Context, *dev.RunHealthCheckRequest) (*dev.RunHealthCheckResponse, error)
- func (UnimplementedTabletManagerServer) SetReadOnly(context.Context, *dev.SetReadOnlyRequest) (*dev.SetReadOnlyResponse, error)
- func (UnimplementedTabletManagerServer) SetReadWrite(context.Context, *dev.SetReadWriteRequest) (*dev.SetReadWriteResponse, error)
- func (UnimplementedTabletManagerServer) SetReplicationSource(context.Context, *dev.SetReplicationSourceRequest) (*dev.SetReplicationSourceResponse, error)
- func (UnimplementedTabletManagerServer) Sleep(context.Context, *dev.SleepRequest) (*dev.SleepResponse, error)
- func (UnimplementedTabletManagerServer) StartReplication(context.Context, *dev.StartReplicationRequest) (*dev.StartReplicationResponse, error)
- func (UnimplementedTabletManagerServer) StartReplicationUntilAfter(context.Context, *dev.StartReplicationUntilAfterRequest) (*dev.StartReplicationUntilAfterResponse, error)
- func (UnimplementedTabletManagerServer) StopReplication(context.Context, *dev.StopReplicationRequest) (*dev.StopReplicationResponse, error)
- func (UnimplementedTabletManagerServer) StopReplicationAndGetStatus(context.Context, *dev.StopReplicationAndGetStatusRequest) (*dev.StopReplicationAndGetStatusResponse, error)
- func (UnimplementedTabletManagerServer) StopReplicationMinimum(context.Context, *dev.StopReplicationMinimumRequest) (*dev.StopReplicationMinimumResponse, error)
- func (UnimplementedTabletManagerServer) UndoDemotePrimary(context.Context, *dev.UndoDemotePrimaryRequest) (*dev.UndoDemotePrimaryResponse, error)
- func (UnimplementedTabletManagerServer) UnlockTables(context.Context, *dev.UnlockTablesRequest) (*dev.UnlockTablesResponse, error)
- func (UnimplementedTabletManagerServer) UpdateVReplicationWorkflow(context.Context, *dev.UpdateVReplicationWorkflowRequest) (*dev.UpdateVReplicationWorkflowResponse, error)
- func (UnimplementedTabletManagerServer) VDiff(context.Context, *dev.VDiffRequest) (*dev.VDiffResponse, error)
- func (UnimplementedTabletManagerServer) VReplicationExec(context.Context, *dev.VReplicationExecRequest) (*dev.VReplicationExecResponse, error)
- func (UnimplementedTabletManagerServer) VReplicationWaitForPos(context.Context, *dev.VReplicationWaitForPosRequest) (*dev.VReplicationWaitForPosResponse, error)
- func (UnimplementedTabletManagerServer) WaitForPosition(context.Context, *dev.WaitForPositionRequest) (*dev.WaitForPositionResponse, error)
- type UnsafeTabletManagerServer
Constants ¶
const ( TabletManager_Ping_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/Ping" TabletManager_Sleep_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/Sleep" TabletManager_ExecuteHook_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/ExecuteHook" TabletManager_GetSchema_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/GetSchema" TabletManager_GetPermissions_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/GetPermissions" TabletManager_SetReadOnly_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/SetReadOnly" TabletManager_SetReadWrite_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/SetReadWrite" TabletManager_ChangeType_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/ChangeType" TabletManager_RefreshState_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/RefreshState" TabletManager_RunHealthCheck_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/RunHealthCheck" TabletManager_ReloadSchema_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/ReloadSchema" TabletManager_PreflightSchema_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/PreflightSchema" TabletManager_ApplySchema_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/ApplySchema" TabletManager_ResetSequences_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/ResetSequences" TabletManager_LockTables_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/LockTables" TabletManager_UnlockTables_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/UnlockTables" TabletManager_ExecuteQuery_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/ExecuteQuery" TabletManager_ExecuteFetchAsDba_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/ExecuteFetchAsDba" TabletManager_ExecuteFetchAsAllPrivs_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/ExecuteFetchAsAllPrivs" TabletManager_ExecuteFetchAsApp_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/ExecuteFetchAsApp" TabletManager_ReplicationStatus_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/ReplicationStatus" TabletManager_PrimaryStatus_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/PrimaryStatus" TabletManager_PrimaryPosition_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/PrimaryPosition" TabletManager_WaitForPosition_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/WaitForPosition" TabletManager_StopReplication_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/StopReplication" TabletManager_StopReplicationMinimum_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/StopReplicationMinimum" TabletManager_StartReplication_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/StartReplication" TabletManager_StartReplicationUntilAfter_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/StartReplicationUntilAfter" TabletManager_GetReplicas_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/GetReplicas" TabletManager_CreateVReplicationWorkflow_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/CreateVReplicationWorkflow" TabletManager_DeleteVReplicationWorkflow_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/DeleteVReplicationWorkflow" TabletManager_ReadVReplicationWorkflow_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/ReadVReplicationWorkflow" TabletManager_VReplicationExec_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/VReplicationExec" TabletManager_VReplicationWaitForPos_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/VReplicationWaitForPos" TabletManager_UpdateVReplicationWorkflow_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/UpdateVReplicationWorkflow" TabletManager_VDiff_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/VDiff" TabletManager_ResetReplication_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/ResetReplication" TabletManager_InitPrimary_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/InitPrimary" TabletManager_PopulateReparentJournal_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/PopulateReparentJournal" TabletManager_InitReplica_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/InitReplica" TabletManager_DemotePrimary_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/DemotePrimary" TabletManager_UndoDemotePrimary_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/UndoDemotePrimary" TabletManager_ReplicaWasPromoted_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/ReplicaWasPromoted" TabletManager_ResetReplicationParameters_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/ResetReplicationParameters" TabletManager_FullStatus_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/FullStatus" TabletManager_SetReplicationSource_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/SetReplicationSource" TabletManager_ReplicaWasRestarted_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/ReplicaWasRestarted" TabletManager_StopReplicationAndGetStatus_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/StopReplicationAndGetStatus" TabletManager_PromoteReplica_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/PromoteReplica" TabletManager_Backup_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/Backup" TabletManager_RestoreFromBackup_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/RestoreFromBackup" TabletManager_CheckThrottler_FullMethodName = "/vitess.tabletmanagerservice.dev.TabletManager/CheckThrottler" )
Variables ¶
var TabletManager_ServiceDesc = grpc.ServiceDesc{ ServiceName: "vitess.tabletmanagerservice.dev.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/dev/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 *dev.PingRequest, opts ...grpc.CallOption) (*dev.PingResponse, error) // Sleep sleeps for the provided duration Sleep(ctx context.Context, in *dev.SleepRequest, opts ...grpc.CallOption) (*dev.SleepResponse, error) // ExecuteHook executes the hook remotely ExecuteHook(ctx context.Context, in *dev.ExecuteHookRequest, opts ...grpc.CallOption) (*dev.ExecuteHookResponse, error) // GetSchema asks the tablet for its schema GetSchema(ctx context.Context, in *dev.GetSchemaRequest, opts ...grpc.CallOption) (*dev.GetSchemaResponse, error) // GetPermissions asks the tablet for its permissions GetPermissions(ctx context.Context, in *dev.GetPermissionsRequest, opts ...grpc.CallOption) (*dev.GetPermissionsResponse, error) SetReadOnly(ctx context.Context, in *dev.SetReadOnlyRequest, opts ...grpc.CallOption) (*dev.SetReadOnlyResponse, error) SetReadWrite(ctx context.Context, in *dev.SetReadWriteRequest, opts ...grpc.CallOption) (*dev.SetReadWriteResponse, error) // ChangeType asks the remote tablet to change its type ChangeType(ctx context.Context, in *dev.ChangeTypeRequest, opts ...grpc.CallOption) (*dev.ChangeTypeResponse, error) RefreshState(ctx context.Context, in *dev.RefreshStateRequest, opts ...grpc.CallOption) (*dev.RefreshStateResponse, error) RunHealthCheck(ctx context.Context, in *dev.RunHealthCheckRequest, opts ...grpc.CallOption) (*dev.RunHealthCheckResponse, error) ReloadSchema(ctx context.Context, in *dev.ReloadSchemaRequest, opts ...grpc.CallOption) (*dev.ReloadSchemaResponse, error) PreflightSchema(ctx context.Context, in *dev.PreflightSchemaRequest, opts ...grpc.CallOption) (*dev.PreflightSchemaResponse, error) ApplySchema(ctx context.Context, in *dev.ApplySchemaRequest, opts ...grpc.CallOption) (*dev.ApplySchemaResponse, error) ResetSequences(ctx context.Context, in *dev.ResetSequencesRequest, opts ...grpc.CallOption) (*dev.ResetSequencesResponse, error) LockTables(ctx context.Context, in *dev.LockTablesRequest, opts ...grpc.CallOption) (*dev.LockTablesResponse, error) UnlockTables(ctx context.Context, in *dev.UnlockTablesRequest, opts ...grpc.CallOption) (*dev.UnlockTablesResponse, error) ExecuteQuery(ctx context.Context, in *dev.ExecuteQueryRequest, opts ...grpc.CallOption) (*dev.ExecuteQueryResponse, error) ExecuteFetchAsDba(ctx context.Context, in *dev.ExecuteFetchAsDbaRequest, opts ...grpc.CallOption) (*dev.ExecuteFetchAsDbaResponse, error) ExecuteFetchAsAllPrivs(ctx context.Context, in *dev.ExecuteFetchAsAllPrivsRequest, opts ...grpc.CallOption) (*dev.ExecuteFetchAsAllPrivsResponse, error) ExecuteFetchAsApp(ctx context.Context, in *dev.ExecuteFetchAsAppRequest, opts ...grpc.CallOption) (*dev.ExecuteFetchAsAppResponse, error) // ReplicationStatus returns the current replication status. ReplicationStatus(ctx context.Context, in *dev.ReplicationStatusRequest, opts ...grpc.CallOption) (*dev.ReplicationStatusResponse, error) // PrimaryStatus returns the current primary status. PrimaryStatus(ctx context.Context, in *dev.PrimaryStatusRequest, opts ...grpc.CallOption) (*dev.PrimaryStatusResponse, error) // PrimaryPosition returns the current primary position PrimaryPosition(ctx context.Context, in *dev.PrimaryPositionRequest, opts ...grpc.CallOption) (*dev.PrimaryPositionResponse, error) // WaitForPosition waits for the position to be reached WaitForPosition(ctx context.Context, in *dev.WaitForPositionRequest, opts ...grpc.CallOption) (*dev.WaitForPositionResponse, error) // StopReplication makes mysql stop its replication StopReplication(ctx context.Context, in *dev.StopReplicationRequest, opts ...grpc.CallOption) (*dev.StopReplicationResponse, error) // StopReplicationMinimum stops the mysql replication after it reaches // the provided minimum point StopReplicationMinimum(ctx context.Context, in *dev.StopReplicationMinimumRequest, opts ...grpc.CallOption) (*dev.StopReplicationMinimumResponse, error) // StartReplication starts the mysql replication StartReplication(ctx context.Context, in *dev.StartReplicationRequest, opts ...grpc.CallOption) (*dev.StartReplicationResponse, error) // StartReplicationUnitAfter starts the mysql replication until and including // the provided position StartReplicationUntilAfter(ctx context.Context, in *dev.StartReplicationUntilAfterRequest, opts ...grpc.CallOption) (*dev.StartReplicationUntilAfterResponse, error) // GetReplicas asks for the list of mysql replicas GetReplicas(ctx context.Context, in *dev.GetReplicasRequest, opts ...grpc.CallOption) (*dev.GetReplicasResponse, error) // VReplication API CreateVReplicationWorkflow(ctx context.Context, in *dev.CreateVReplicationWorkflowRequest, opts ...grpc.CallOption) (*dev.CreateVReplicationWorkflowResponse, error) DeleteVReplicationWorkflow(ctx context.Context, in *dev.DeleteVReplicationWorkflowRequest, opts ...grpc.CallOption) (*dev.DeleteVReplicationWorkflowResponse, error) ReadVReplicationWorkflow(ctx context.Context, in *dev.ReadVReplicationWorkflowRequest, opts ...grpc.CallOption) (*dev.ReadVReplicationWorkflowResponse, error) VReplicationExec(ctx context.Context, in *dev.VReplicationExecRequest, opts ...grpc.CallOption) (*dev.VReplicationExecResponse, error) VReplicationWaitForPos(ctx context.Context, in *dev.VReplicationWaitForPosRequest, opts ...grpc.CallOption) (*dev.VReplicationWaitForPosResponse, error) UpdateVReplicationWorkflow(ctx context.Context, in *dev.UpdateVReplicationWorkflowRequest, opts ...grpc.CallOption) (*dev.UpdateVReplicationWorkflowResponse, error) // VDiff API VDiff(ctx context.Context, in *dev.VDiffRequest, opts ...grpc.CallOption) (*dev.VDiffResponse, error) // ResetReplication makes the target not replicating ResetReplication(ctx context.Context, in *dev.ResetReplicationRequest, opts ...grpc.CallOption) (*dev.ResetReplicationResponse, error) // InitPrimary initializes the tablet as a primary InitPrimary(ctx context.Context, in *dev.InitPrimaryRequest, opts ...grpc.CallOption) (*dev.InitPrimaryResponse, error) // PopulateReparentJournal tells the tablet to add an entry to its // reparent journal PopulateReparentJournal(ctx context.Context, in *dev.PopulateReparentJournalRequest, opts ...grpc.CallOption) (*dev.PopulateReparentJournalResponse, error) // InitReplica tells the tablet to reparent to the primary unconditionally InitReplica(ctx context.Context, in *dev.InitReplicaRequest, opts ...grpc.CallOption) (*dev.InitReplicaResponse, error) // DemotePrimary tells the soon-to-be-former primary it's gonna change DemotePrimary(ctx context.Context, in *dev.DemotePrimaryRequest, opts ...grpc.CallOption) (*dev.DemotePrimaryResponse, error) // UndoDemotePrimary reverts all changes made by DemotePrimary UndoDemotePrimary(ctx context.Context, in *dev.UndoDemotePrimaryRequest, opts ...grpc.CallOption) (*dev.UndoDemotePrimaryResponse, error) // ReplicaWasPromoted tells the remote tablet it is now the primary ReplicaWasPromoted(ctx context.Context, in *dev.ReplicaWasPromotedRequest, opts ...grpc.CallOption) (*dev.ReplicaWasPromotedResponse, error) // ResetReplicationParameters resets the replica replication parameters ResetReplicationParameters(ctx context.Context, in *dev.ResetReplicationParametersRequest, opts ...grpc.CallOption) (*dev.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 *dev.FullStatusRequest, opts ...grpc.CallOption) (*dev.FullStatusResponse, error) // SetReplicationSource tells the replica to reparent SetReplicationSource(ctx context.Context, in *dev.SetReplicationSourceRequest, opts ...grpc.CallOption) (*dev.SetReplicationSourceResponse, error) // ReplicaWasRestarted tells the remote tablet its primary has changed ReplicaWasRestarted(ctx context.Context, in *dev.ReplicaWasRestartedRequest, opts ...grpc.CallOption) (*dev.ReplicaWasRestartedResponse, error) // StopReplicationAndGetStatus stops MySQL replication, and returns the // replication status StopReplicationAndGetStatus(ctx context.Context, in *dev.StopReplicationAndGetStatusRequest, opts ...grpc.CallOption) (*dev.StopReplicationAndGetStatusResponse, error) // PromoteReplica makes the replica the new primary PromoteReplica(ctx context.Context, in *dev.PromoteReplicaRequest, opts ...grpc.CallOption) (*dev.PromoteReplicaResponse, error) Backup(ctx context.Context, in *dev.BackupRequest, opts ...grpc.CallOption) (TabletManager_BackupClient, error) // RestoreFromBackup deletes all local data and restores it from the latest backup. RestoreFromBackup(ctx context.Context, in *dev.RestoreFromBackupRequest, opts ...grpc.CallOption) (TabletManager_RestoreFromBackupClient, error) // CheckThrottler issues a 'check' on a tablet's throttler CheckThrottler(ctx context.Context, in *dev.CheckThrottlerRequest, opts ...grpc.CallOption) (*dev.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, *dev.PingRequest) (*dev.PingResponse, error) // Sleep sleeps for the provided duration Sleep(context.Context, *dev.SleepRequest) (*dev.SleepResponse, error) // ExecuteHook executes the hook remotely ExecuteHook(context.Context, *dev.ExecuteHookRequest) (*dev.ExecuteHookResponse, error) // GetSchema asks the tablet for its schema GetSchema(context.Context, *dev.GetSchemaRequest) (*dev.GetSchemaResponse, error) // GetPermissions asks the tablet for its permissions GetPermissions(context.Context, *dev.GetPermissionsRequest) (*dev.GetPermissionsResponse, error) SetReadOnly(context.Context, *dev.SetReadOnlyRequest) (*dev.SetReadOnlyResponse, error) SetReadWrite(context.Context, *dev.SetReadWriteRequest) (*dev.SetReadWriteResponse, error) // ChangeType asks the remote tablet to change its type ChangeType(context.Context, *dev.ChangeTypeRequest) (*dev.ChangeTypeResponse, error) RefreshState(context.Context, *dev.RefreshStateRequest) (*dev.RefreshStateResponse, error) RunHealthCheck(context.Context, *dev.RunHealthCheckRequest) (*dev.RunHealthCheckResponse, error) ReloadSchema(context.Context, *dev.ReloadSchemaRequest) (*dev.ReloadSchemaResponse, error) PreflightSchema(context.Context, *dev.PreflightSchemaRequest) (*dev.PreflightSchemaResponse, error) ApplySchema(context.Context, *dev.ApplySchemaRequest) (*dev.ApplySchemaResponse, error) ResetSequences(context.Context, *dev.ResetSequencesRequest) (*dev.ResetSequencesResponse, error) LockTables(context.Context, *dev.LockTablesRequest) (*dev.LockTablesResponse, error) UnlockTables(context.Context, *dev.UnlockTablesRequest) (*dev.UnlockTablesResponse, error) ExecuteQuery(context.Context, *dev.ExecuteQueryRequest) (*dev.ExecuteQueryResponse, error) ExecuteFetchAsDba(context.Context, *dev.ExecuteFetchAsDbaRequest) (*dev.ExecuteFetchAsDbaResponse, error) ExecuteFetchAsAllPrivs(context.Context, *dev.ExecuteFetchAsAllPrivsRequest) (*dev.ExecuteFetchAsAllPrivsResponse, error) ExecuteFetchAsApp(context.Context, *dev.ExecuteFetchAsAppRequest) (*dev.ExecuteFetchAsAppResponse, error) // ReplicationStatus returns the current replication status. ReplicationStatus(context.Context, *dev.ReplicationStatusRequest) (*dev.ReplicationStatusResponse, error) // PrimaryStatus returns the current primary status. PrimaryStatus(context.Context, *dev.PrimaryStatusRequest) (*dev.PrimaryStatusResponse, error) // PrimaryPosition returns the current primary position PrimaryPosition(context.Context, *dev.PrimaryPositionRequest) (*dev.PrimaryPositionResponse, error) // WaitForPosition waits for the position to be reached WaitForPosition(context.Context, *dev.WaitForPositionRequest) (*dev.WaitForPositionResponse, error) // StopReplication makes mysql stop its replication StopReplication(context.Context, *dev.StopReplicationRequest) (*dev.StopReplicationResponse, error) // StopReplicationMinimum stops the mysql replication after it reaches // the provided minimum point StopReplicationMinimum(context.Context, *dev.StopReplicationMinimumRequest) (*dev.StopReplicationMinimumResponse, error) // StartReplication starts the mysql replication StartReplication(context.Context, *dev.StartReplicationRequest) (*dev.StartReplicationResponse, error) // StartReplicationUnitAfter starts the mysql replication until and including // the provided position StartReplicationUntilAfter(context.Context, *dev.StartReplicationUntilAfterRequest) (*dev.StartReplicationUntilAfterResponse, error) // GetReplicas asks for the list of mysql replicas GetReplicas(context.Context, *dev.GetReplicasRequest) (*dev.GetReplicasResponse, error) // VReplication API CreateVReplicationWorkflow(context.Context, *dev.CreateVReplicationWorkflowRequest) (*dev.CreateVReplicationWorkflowResponse, error) DeleteVReplicationWorkflow(context.Context, *dev.DeleteVReplicationWorkflowRequest) (*dev.DeleteVReplicationWorkflowResponse, error) ReadVReplicationWorkflow(context.Context, *dev.ReadVReplicationWorkflowRequest) (*dev.ReadVReplicationWorkflowResponse, error) VReplicationExec(context.Context, *dev.VReplicationExecRequest) (*dev.VReplicationExecResponse, error) VReplicationWaitForPos(context.Context, *dev.VReplicationWaitForPosRequest) (*dev.VReplicationWaitForPosResponse, error) UpdateVReplicationWorkflow(context.Context, *dev.UpdateVReplicationWorkflowRequest) (*dev.UpdateVReplicationWorkflowResponse, error) // VDiff API VDiff(context.Context, *dev.VDiffRequest) (*dev.VDiffResponse, error) // ResetReplication makes the target not replicating ResetReplication(context.Context, *dev.ResetReplicationRequest) (*dev.ResetReplicationResponse, error) // InitPrimary initializes the tablet as a primary InitPrimary(context.Context, *dev.InitPrimaryRequest) (*dev.InitPrimaryResponse, error) // PopulateReparentJournal tells the tablet to add an entry to its // reparent journal PopulateReparentJournal(context.Context, *dev.PopulateReparentJournalRequest) (*dev.PopulateReparentJournalResponse, error) // InitReplica tells the tablet to reparent to the primary unconditionally InitReplica(context.Context, *dev.InitReplicaRequest) (*dev.InitReplicaResponse, error) // DemotePrimary tells the soon-to-be-former primary it's gonna change DemotePrimary(context.Context, *dev.DemotePrimaryRequest) (*dev.DemotePrimaryResponse, error) // UndoDemotePrimary reverts all changes made by DemotePrimary UndoDemotePrimary(context.Context, *dev.UndoDemotePrimaryRequest) (*dev.UndoDemotePrimaryResponse, error) // ReplicaWasPromoted tells the remote tablet it is now the primary ReplicaWasPromoted(context.Context, *dev.ReplicaWasPromotedRequest) (*dev.ReplicaWasPromotedResponse, error) // ResetReplicationParameters resets the replica replication parameters ResetReplicationParameters(context.Context, *dev.ResetReplicationParametersRequest) (*dev.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, *dev.FullStatusRequest) (*dev.FullStatusResponse, error) // SetReplicationSource tells the replica to reparent SetReplicationSource(context.Context, *dev.SetReplicationSourceRequest) (*dev.SetReplicationSourceResponse, error) // ReplicaWasRestarted tells the remote tablet its primary has changed ReplicaWasRestarted(context.Context, *dev.ReplicaWasRestartedRequest) (*dev.ReplicaWasRestartedResponse, error) // StopReplicationAndGetStatus stops MySQL replication, and returns the // replication status StopReplicationAndGetStatus(context.Context, *dev.StopReplicationAndGetStatusRequest) (*dev.StopReplicationAndGetStatusResponse, error) // PromoteReplica makes the replica the new primary PromoteReplica(context.Context, *dev.PromoteReplicaRequest) (*dev.PromoteReplicaResponse, error) Backup(*dev.BackupRequest, TabletManager_BackupServer) error // RestoreFromBackup deletes all local data and restores it from the latest backup. RestoreFromBackup(*dev.RestoreFromBackupRequest, TabletManager_RestoreFromBackupServer) error // CheckThrottler issues a 'check' on a tablet's throttler CheckThrottler(context.Context, *dev.CheckThrottlerRequest) (*dev.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() (*dev.BackupResponse, error) grpc.ClientStream }
type TabletManager_BackupServer ¶
type TabletManager_BackupServer interface { Send(*dev.BackupResponse) error grpc.ServerStream }
type TabletManager_RestoreFromBackupClient ¶
type TabletManager_RestoreFromBackupClient interface { Recv() (*dev.RestoreFromBackupResponse, error) grpc.ClientStream }
type TabletManager_RestoreFromBackupServer ¶
type TabletManager_RestoreFromBackupServer interface { Send(*dev.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, *dev.ApplySchemaRequest) (*dev.ApplySchemaResponse, error)
func (UnimplementedTabletManagerServer) Backup ¶
func (UnimplementedTabletManagerServer) Backup(*dev.BackupRequest, TabletManager_BackupServer) error
func (UnimplementedTabletManagerServer) ChangeType ¶
func (UnimplementedTabletManagerServer) ChangeType(context.Context, *dev.ChangeTypeRequest) (*dev.ChangeTypeResponse, error)
func (UnimplementedTabletManagerServer) CheckThrottler ¶
func (UnimplementedTabletManagerServer) CheckThrottler(context.Context, *dev.CheckThrottlerRequest) (*dev.CheckThrottlerResponse, error)
func (UnimplementedTabletManagerServer) CreateVReplicationWorkflow ¶
func (UnimplementedTabletManagerServer) CreateVReplicationWorkflow(context.Context, *dev.CreateVReplicationWorkflowRequest) (*dev.CreateVReplicationWorkflowResponse, error)
func (UnimplementedTabletManagerServer) DeleteVReplicationWorkflow ¶
func (UnimplementedTabletManagerServer) DeleteVReplicationWorkflow(context.Context, *dev.DeleteVReplicationWorkflowRequest) (*dev.DeleteVReplicationWorkflowResponse, error)
func (UnimplementedTabletManagerServer) DemotePrimary ¶
func (UnimplementedTabletManagerServer) DemotePrimary(context.Context, *dev.DemotePrimaryRequest) (*dev.DemotePrimaryResponse, error)
func (UnimplementedTabletManagerServer) ExecuteFetchAsAllPrivs ¶
func (UnimplementedTabletManagerServer) ExecuteFetchAsAllPrivs(context.Context, *dev.ExecuteFetchAsAllPrivsRequest) (*dev.ExecuteFetchAsAllPrivsResponse, error)
func (UnimplementedTabletManagerServer) ExecuteFetchAsApp ¶
func (UnimplementedTabletManagerServer) ExecuteFetchAsApp(context.Context, *dev.ExecuteFetchAsAppRequest) (*dev.ExecuteFetchAsAppResponse, error)
func (UnimplementedTabletManagerServer) ExecuteFetchAsDba ¶
func (UnimplementedTabletManagerServer) ExecuteFetchAsDba(context.Context, *dev.ExecuteFetchAsDbaRequest) (*dev.ExecuteFetchAsDbaResponse, error)
func (UnimplementedTabletManagerServer) ExecuteHook ¶
func (UnimplementedTabletManagerServer) ExecuteHook(context.Context, *dev.ExecuteHookRequest) (*dev.ExecuteHookResponse, error)
func (UnimplementedTabletManagerServer) ExecuteQuery ¶
func (UnimplementedTabletManagerServer) ExecuteQuery(context.Context, *dev.ExecuteQueryRequest) (*dev.ExecuteQueryResponse, error)
func (UnimplementedTabletManagerServer) FullStatus ¶
func (UnimplementedTabletManagerServer) FullStatus(context.Context, *dev.FullStatusRequest) (*dev.FullStatusResponse, error)
func (UnimplementedTabletManagerServer) GetPermissions ¶
func (UnimplementedTabletManagerServer) GetPermissions(context.Context, *dev.GetPermissionsRequest) (*dev.GetPermissionsResponse, error)
func (UnimplementedTabletManagerServer) GetReplicas ¶
func (UnimplementedTabletManagerServer) GetReplicas(context.Context, *dev.GetReplicasRequest) (*dev.GetReplicasResponse, error)
func (UnimplementedTabletManagerServer) GetSchema ¶
func (UnimplementedTabletManagerServer) GetSchema(context.Context, *dev.GetSchemaRequest) (*dev.GetSchemaResponse, error)
func (UnimplementedTabletManagerServer) InitPrimary ¶
func (UnimplementedTabletManagerServer) InitPrimary(context.Context, *dev.InitPrimaryRequest) (*dev.InitPrimaryResponse, error)
func (UnimplementedTabletManagerServer) InitReplica ¶
func (UnimplementedTabletManagerServer) InitReplica(context.Context, *dev.InitReplicaRequest) (*dev.InitReplicaResponse, error)
func (UnimplementedTabletManagerServer) LockTables ¶
func (UnimplementedTabletManagerServer) LockTables(context.Context, *dev.LockTablesRequest) (*dev.LockTablesResponse, error)
func (UnimplementedTabletManagerServer) Ping ¶
func (UnimplementedTabletManagerServer) Ping(context.Context, *dev.PingRequest) (*dev.PingResponse, error)
func (UnimplementedTabletManagerServer) PopulateReparentJournal ¶
func (UnimplementedTabletManagerServer) PopulateReparentJournal(context.Context, *dev.PopulateReparentJournalRequest) (*dev.PopulateReparentJournalResponse, error)
func (UnimplementedTabletManagerServer) PreflightSchema ¶
func (UnimplementedTabletManagerServer) PreflightSchema(context.Context, *dev.PreflightSchemaRequest) (*dev.PreflightSchemaResponse, error)
func (UnimplementedTabletManagerServer) PrimaryPosition ¶
func (UnimplementedTabletManagerServer) PrimaryPosition(context.Context, *dev.PrimaryPositionRequest) (*dev.PrimaryPositionResponse, error)
func (UnimplementedTabletManagerServer) PrimaryStatus ¶
func (UnimplementedTabletManagerServer) PrimaryStatus(context.Context, *dev.PrimaryStatusRequest) (*dev.PrimaryStatusResponse, error)
func (UnimplementedTabletManagerServer) PromoteReplica ¶
func (UnimplementedTabletManagerServer) PromoteReplica(context.Context, *dev.PromoteReplicaRequest) (*dev.PromoteReplicaResponse, error)
func (UnimplementedTabletManagerServer) ReadVReplicationWorkflow ¶
func (UnimplementedTabletManagerServer) ReadVReplicationWorkflow(context.Context, *dev.ReadVReplicationWorkflowRequest) (*dev.ReadVReplicationWorkflowResponse, error)
func (UnimplementedTabletManagerServer) RefreshState ¶
func (UnimplementedTabletManagerServer) RefreshState(context.Context, *dev.RefreshStateRequest) (*dev.RefreshStateResponse, error)
func (UnimplementedTabletManagerServer) ReloadSchema ¶
func (UnimplementedTabletManagerServer) ReloadSchema(context.Context, *dev.ReloadSchemaRequest) (*dev.ReloadSchemaResponse, error)
func (UnimplementedTabletManagerServer) ReplicaWasPromoted ¶
func (UnimplementedTabletManagerServer) ReplicaWasPromoted(context.Context, *dev.ReplicaWasPromotedRequest) (*dev.ReplicaWasPromotedResponse, error)
func (UnimplementedTabletManagerServer) ReplicaWasRestarted ¶
func (UnimplementedTabletManagerServer) ReplicaWasRestarted(context.Context, *dev.ReplicaWasRestartedRequest) (*dev.ReplicaWasRestartedResponse, error)
func (UnimplementedTabletManagerServer) ReplicationStatus ¶
func (UnimplementedTabletManagerServer) ReplicationStatus(context.Context, *dev.ReplicationStatusRequest) (*dev.ReplicationStatusResponse, error)
func (UnimplementedTabletManagerServer) ResetReplication ¶
func (UnimplementedTabletManagerServer) ResetReplication(context.Context, *dev.ResetReplicationRequest) (*dev.ResetReplicationResponse, error)
func (UnimplementedTabletManagerServer) ResetReplicationParameters ¶
func (UnimplementedTabletManagerServer) ResetReplicationParameters(context.Context, *dev.ResetReplicationParametersRequest) (*dev.ResetReplicationParametersResponse, error)
func (UnimplementedTabletManagerServer) ResetSequences ¶
func (UnimplementedTabletManagerServer) ResetSequences(context.Context, *dev.ResetSequencesRequest) (*dev.ResetSequencesResponse, error)
func (UnimplementedTabletManagerServer) RestoreFromBackup ¶
func (UnimplementedTabletManagerServer) RestoreFromBackup(*dev.RestoreFromBackupRequest, TabletManager_RestoreFromBackupServer) error
func (UnimplementedTabletManagerServer) RunHealthCheck ¶
func (UnimplementedTabletManagerServer) RunHealthCheck(context.Context, *dev.RunHealthCheckRequest) (*dev.RunHealthCheckResponse, error)
func (UnimplementedTabletManagerServer) SetReadOnly ¶
func (UnimplementedTabletManagerServer) SetReadOnly(context.Context, *dev.SetReadOnlyRequest) (*dev.SetReadOnlyResponse, error)
func (UnimplementedTabletManagerServer) SetReadWrite ¶
func (UnimplementedTabletManagerServer) SetReadWrite(context.Context, *dev.SetReadWriteRequest) (*dev.SetReadWriteResponse, error)
func (UnimplementedTabletManagerServer) SetReplicationSource ¶
func (UnimplementedTabletManagerServer) SetReplicationSource(context.Context, *dev.SetReplicationSourceRequest) (*dev.SetReplicationSourceResponse, error)
func (UnimplementedTabletManagerServer) Sleep ¶
func (UnimplementedTabletManagerServer) Sleep(context.Context, *dev.SleepRequest) (*dev.SleepResponse, error)
func (UnimplementedTabletManagerServer) StartReplication ¶
func (UnimplementedTabletManagerServer) StartReplication(context.Context, *dev.StartReplicationRequest) (*dev.StartReplicationResponse, error)
func (UnimplementedTabletManagerServer) StartReplicationUntilAfter ¶
func (UnimplementedTabletManagerServer) StartReplicationUntilAfter(context.Context, *dev.StartReplicationUntilAfterRequest) (*dev.StartReplicationUntilAfterResponse, error)
func (UnimplementedTabletManagerServer) StopReplication ¶
func (UnimplementedTabletManagerServer) StopReplication(context.Context, *dev.StopReplicationRequest) (*dev.StopReplicationResponse, error)
func (UnimplementedTabletManagerServer) StopReplicationAndGetStatus ¶
func (UnimplementedTabletManagerServer) StopReplicationAndGetStatus(context.Context, *dev.StopReplicationAndGetStatusRequest) (*dev.StopReplicationAndGetStatusResponse, error)
func (UnimplementedTabletManagerServer) StopReplicationMinimum ¶
func (UnimplementedTabletManagerServer) StopReplicationMinimum(context.Context, *dev.StopReplicationMinimumRequest) (*dev.StopReplicationMinimumResponse, error)
func (UnimplementedTabletManagerServer) UndoDemotePrimary ¶
func (UnimplementedTabletManagerServer) UndoDemotePrimary(context.Context, *dev.UndoDemotePrimaryRequest) (*dev.UndoDemotePrimaryResponse, error)
func (UnimplementedTabletManagerServer) UnlockTables ¶
func (UnimplementedTabletManagerServer) UnlockTables(context.Context, *dev.UnlockTablesRequest) (*dev.UnlockTablesResponse, error)
func (UnimplementedTabletManagerServer) UpdateVReplicationWorkflow ¶
func (UnimplementedTabletManagerServer) UpdateVReplicationWorkflow(context.Context, *dev.UpdateVReplicationWorkflowRequest) (*dev.UpdateVReplicationWorkflowResponse, error)
func (UnimplementedTabletManagerServer) VDiff ¶
func (UnimplementedTabletManagerServer) VDiff(context.Context, *dev.VDiffRequest) (*dev.VDiffResponse, error)
func (UnimplementedTabletManagerServer) VReplicationExec ¶
func (UnimplementedTabletManagerServer) VReplicationExec(context.Context, *dev.VReplicationExecRequest) (*dev.VReplicationExecResponse, error)
func (UnimplementedTabletManagerServer) VReplicationWaitForPos ¶
func (UnimplementedTabletManagerServer) VReplicationWaitForPos(context.Context, *dev.VReplicationWaitForPosRequest) (*dev.VReplicationWaitForPosResponse, error)
func (UnimplementedTabletManagerServer) WaitForPosition ¶
func (UnimplementedTabletManagerServer) WaitForPosition(context.Context, *dev.WaitForPositionRequest) (*dev.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.