Documentation ¶
Index ¶
- Constants
- func NewTabletManagerHandler(svc TabletManagerHandler, opts ...connect.HandlerOption) (string, http.Handler)
- type TabletManagerClient
- type TabletManagerHandler
- type UnimplementedTabletManagerHandler
- func (UnimplementedTabletManagerHandler) ApplySchema(context.Context, *connect.Request[v18.ApplySchemaRequest]) (*connect.Response[v18.ApplySchemaResponse], error)
- func (UnimplementedTabletManagerHandler) Backup(context.Context, *connect.Request[v18.BackupRequest], ...) error
- func (UnimplementedTabletManagerHandler) ChangeType(context.Context, *connect.Request[v18.ChangeTypeRequest]) (*connect.Response[v18.ChangeTypeResponse], error)
- func (UnimplementedTabletManagerHandler) CheckThrottler(context.Context, *connect.Request[v18.CheckThrottlerRequest]) (*connect.Response[v18.CheckThrottlerResponse], error)
- func (UnimplementedTabletManagerHandler) CreateVReplicationWorkflow(context.Context, *connect.Request[v18.CreateVReplicationWorkflowRequest]) (*connect.Response[v18.CreateVReplicationWorkflowResponse], error)
- func (UnimplementedTabletManagerHandler) DeleteVReplicationWorkflow(context.Context, *connect.Request[v18.DeleteVReplicationWorkflowRequest]) (*connect.Response[v18.DeleteVReplicationWorkflowResponse], error)
- func (UnimplementedTabletManagerHandler) DemotePrimary(context.Context, *connect.Request[v18.DemotePrimaryRequest]) (*connect.Response[v18.DemotePrimaryResponse], error)
- func (UnimplementedTabletManagerHandler) ExecuteFetchAsAllPrivs(context.Context, *connect.Request[v18.ExecuteFetchAsAllPrivsRequest]) (*connect.Response[v18.ExecuteFetchAsAllPrivsResponse], error)
- func (UnimplementedTabletManagerHandler) ExecuteFetchAsApp(context.Context, *connect.Request[v18.ExecuteFetchAsAppRequest]) (*connect.Response[v18.ExecuteFetchAsAppResponse], error)
- func (UnimplementedTabletManagerHandler) ExecuteFetchAsDba(context.Context, *connect.Request[v18.ExecuteFetchAsDbaRequest]) (*connect.Response[v18.ExecuteFetchAsDbaResponse], error)
- func (UnimplementedTabletManagerHandler) ExecuteHook(context.Context, *connect.Request[v18.ExecuteHookRequest]) (*connect.Response[v18.ExecuteHookResponse], error)
- func (UnimplementedTabletManagerHandler) ExecuteQuery(context.Context, *connect.Request[v18.ExecuteQueryRequest]) (*connect.Response[v18.ExecuteQueryResponse], error)
- func (UnimplementedTabletManagerHandler) FullStatus(context.Context, *connect.Request[v18.FullStatusRequest]) (*connect.Response[v18.FullStatusResponse], error)
- func (UnimplementedTabletManagerHandler) GetPermissions(context.Context, *connect.Request[v18.GetPermissionsRequest]) (*connect.Response[v18.GetPermissionsResponse], error)
- func (UnimplementedTabletManagerHandler) GetReplicas(context.Context, *connect.Request[v18.GetReplicasRequest]) (*connect.Response[v18.GetReplicasResponse], error)
- func (UnimplementedTabletManagerHandler) GetSchema(context.Context, *connect.Request[v18.GetSchemaRequest]) (*connect.Response[v18.GetSchemaResponse], error)
- func (UnimplementedTabletManagerHandler) InitPrimary(context.Context, *connect.Request[v18.InitPrimaryRequest]) (*connect.Response[v18.InitPrimaryResponse], error)
- func (UnimplementedTabletManagerHandler) InitReplica(context.Context, *connect.Request[v18.InitReplicaRequest]) (*connect.Response[v18.InitReplicaResponse], error)
- func (UnimplementedTabletManagerHandler) LockTables(context.Context, *connect.Request[v18.LockTablesRequest]) (*connect.Response[v18.LockTablesResponse], error)
- func (UnimplementedTabletManagerHandler) Ping(context.Context, *connect.Request[v18.PingRequest]) (*connect.Response[v18.PingResponse], error)
- func (UnimplementedTabletManagerHandler) PopulateReparentJournal(context.Context, *connect.Request[v18.PopulateReparentJournalRequest]) (*connect.Response[v18.PopulateReparentJournalResponse], error)
- func (UnimplementedTabletManagerHandler) PreflightSchema(context.Context, *connect.Request[v18.PreflightSchemaRequest]) (*connect.Response[v18.PreflightSchemaResponse], error)
- func (UnimplementedTabletManagerHandler) PrimaryPosition(context.Context, *connect.Request[v18.PrimaryPositionRequest]) (*connect.Response[v18.PrimaryPositionResponse], error)
- func (UnimplementedTabletManagerHandler) PrimaryStatus(context.Context, *connect.Request[v18.PrimaryStatusRequest]) (*connect.Response[v18.PrimaryStatusResponse], error)
- func (UnimplementedTabletManagerHandler) PromoteReplica(context.Context, *connect.Request[v18.PromoteReplicaRequest]) (*connect.Response[v18.PromoteReplicaResponse], error)
- func (UnimplementedTabletManagerHandler) ReadVReplicationWorkflow(context.Context, *connect.Request[v18.ReadVReplicationWorkflowRequest]) (*connect.Response[v18.ReadVReplicationWorkflowResponse], error)
- func (UnimplementedTabletManagerHandler) RefreshState(context.Context, *connect.Request[v18.RefreshStateRequest]) (*connect.Response[v18.RefreshStateResponse], error)
- func (UnimplementedTabletManagerHandler) ReloadSchema(context.Context, *connect.Request[v18.ReloadSchemaRequest]) (*connect.Response[v18.ReloadSchemaResponse], error)
- func (UnimplementedTabletManagerHandler) ReplicaWasPromoted(context.Context, *connect.Request[v18.ReplicaWasPromotedRequest]) (*connect.Response[v18.ReplicaWasPromotedResponse], error)
- func (UnimplementedTabletManagerHandler) ReplicaWasRestarted(context.Context, *connect.Request[v18.ReplicaWasRestartedRequest]) (*connect.Response[v18.ReplicaWasRestartedResponse], error)
- func (UnimplementedTabletManagerHandler) ReplicationStatus(context.Context, *connect.Request[v18.ReplicationStatusRequest]) (*connect.Response[v18.ReplicationStatusResponse], error)
- func (UnimplementedTabletManagerHandler) ResetReplication(context.Context, *connect.Request[v18.ResetReplicationRequest]) (*connect.Response[v18.ResetReplicationResponse], error)
- func (UnimplementedTabletManagerHandler) ResetReplicationParameters(context.Context, *connect.Request[v18.ResetReplicationParametersRequest]) (*connect.Response[v18.ResetReplicationParametersResponse], error)
- func (UnimplementedTabletManagerHandler) ResetSequences(context.Context, *connect.Request[v18.ResetSequencesRequest]) (*connect.Response[v18.ResetSequencesResponse], error)
- func (UnimplementedTabletManagerHandler) RestoreFromBackup(context.Context, *connect.Request[v18.RestoreFromBackupRequest], ...) error
- func (UnimplementedTabletManagerHandler) RunHealthCheck(context.Context, *connect.Request[v18.RunHealthCheckRequest]) (*connect.Response[v18.RunHealthCheckResponse], error)
- func (UnimplementedTabletManagerHandler) SetReadOnly(context.Context, *connect.Request[v18.SetReadOnlyRequest]) (*connect.Response[v18.SetReadOnlyResponse], error)
- func (UnimplementedTabletManagerHandler) SetReadWrite(context.Context, *connect.Request[v18.SetReadWriteRequest]) (*connect.Response[v18.SetReadWriteResponse], error)
- func (UnimplementedTabletManagerHandler) SetReplicationSource(context.Context, *connect.Request[v18.SetReplicationSourceRequest]) (*connect.Response[v18.SetReplicationSourceResponse], error)
- func (UnimplementedTabletManagerHandler) Sleep(context.Context, *connect.Request[v18.SleepRequest]) (*connect.Response[v18.SleepResponse], error)
- func (UnimplementedTabletManagerHandler) StartReplication(context.Context, *connect.Request[v18.StartReplicationRequest]) (*connect.Response[v18.StartReplicationResponse], error)
- func (UnimplementedTabletManagerHandler) StartReplicationUntilAfter(context.Context, *connect.Request[v18.StartReplicationUntilAfterRequest]) (*connect.Response[v18.StartReplicationUntilAfterResponse], error)
- func (UnimplementedTabletManagerHandler) StopReplication(context.Context, *connect.Request[v18.StopReplicationRequest]) (*connect.Response[v18.StopReplicationResponse], error)
- func (UnimplementedTabletManagerHandler) StopReplicationAndGetStatus(context.Context, *connect.Request[v18.StopReplicationAndGetStatusRequest]) (*connect.Response[v18.StopReplicationAndGetStatusResponse], error)
- func (UnimplementedTabletManagerHandler) StopReplicationMinimum(context.Context, *connect.Request[v18.StopReplicationMinimumRequest]) (*connect.Response[v18.StopReplicationMinimumResponse], error)
- func (UnimplementedTabletManagerHandler) UndoDemotePrimary(context.Context, *connect.Request[v18.UndoDemotePrimaryRequest]) (*connect.Response[v18.UndoDemotePrimaryResponse], error)
- func (UnimplementedTabletManagerHandler) UnlockTables(context.Context, *connect.Request[v18.UnlockTablesRequest]) (*connect.Response[v18.UnlockTablesResponse], error)
- func (UnimplementedTabletManagerHandler) UpdateVReplicationWorkflow(context.Context, *connect.Request[v18.UpdateVReplicationWorkflowRequest]) (*connect.Response[v18.UpdateVReplicationWorkflowResponse], error)
- func (UnimplementedTabletManagerHandler) VDiff(context.Context, *connect.Request[v18.VDiffRequest]) (*connect.Response[v18.VDiffResponse], error)
- func (UnimplementedTabletManagerHandler) VReplicationExec(context.Context, *connect.Request[v18.VReplicationExecRequest]) (*connect.Response[v18.VReplicationExecResponse], error)
- func (UnimplementedTabletManagerHandler) VReplicationWaitForPos(context.Context, *connect.Request[v18.VReplicationWaitForPosRequest]) (*connect.Response[v18.VReplicationWaitForPosResponse], error)
- func (UnimplementedTabletManagerHandler) WaitForPosition(context.Context, *connect.Request[v18.WaitForPositionRequest]) (*connect.Response[v18.WaitForPositionResponse], error)
Constants ¶
const ( // TabletManagerPingProcedure is the fully-qualified name of the TabletManager's Ping RPC. TabletManagerPingProcedure = "/tabletmanagerservice.TabletManager/Ping" // TabletManagerSleepProcedure is the fully-qualified name of the TabletManager's Sleep RPC. TabletManagerSleepProcedure = "/tabletmanagerservice.TabletManager/Sleep" // TabletManagerExecuteHookProcedure is the fully-qualified name of the TabletManager's ExecuteHook // RPC. TabletManagerExecuteHookProcedure = "/tabletmanagerservice.TabletManager/ExecuteHook" // TabletManagerGetSchemaProcedure is the fully-qualified name of the TabletManager's GetSchema RPC. TabletManagerGetSchemaProcedure = "/tabletmanagerservice.TabletManager/GetSchema" // TabletManagerGetPermissionsProcedure is the fully-qualified name of the TabletManager's // GetPermissions RPC. TabletManagerGetPermissionsProcedure = "/tabletmanagerservice.TabletManager/GetPermissions" // TabletManagerSetReadOnlyProcedure is the fully-qualified name of the TabletManager's SetReadOnly // RPC. TabletManagerSetReadOnlyProcedure = "/tabletmanagerservice.TabletManager/SetReadOnly" // TabletManagerSetReadWriteProcedure is the fully-qualified name of the TabletManager's // SetReadWrite RPC. TabletManagerSetReadWriteProcedure = "/tabletmanagerservice.TabletManager/SetReadWrite" // TabletManagerChangeTypeProcedure is the fully-qualified name of the TabletManager's ChangeType // RPC. TabletManagerChangeTypeProcedure = "/tabletmanagerservice.TabletManager/ChangeType" // TabletManagerRefreshStateProcedure is the fully-qualified name of the TabletManager's // RefreshState RPC. TabletManagerRefreshStateProcedure = "/tabletmanagerservice.TabletManager/RefreshState" // TabletManagerRunHealthCheckProcedure is the fully-qualified name of the TabletManager's // RunHealthCheck RPC. TabletManagerRunHealthCheckProcedure = "/tabletmanagerservice.TabletManager/RunHealthCheck" // TabletManagerReloadSchemaProcedure is the fully-qualified name of the TabletManager's // ReloadSchema RPC. TabletManagerReloadSchemaProcedure = "/tabletmanagerservice.TabletManager/ReloadSchema" // TabletManagerPreflightSchemaProcedure is the fully-qualified name of the TabletManager's // PreflightSchema RPC. TabletManagerPreflightSchemaProcedure = "/tabletmanagerservice.TabletManager/PreflightSchema" // TabletManagerApplySchemaProcedure is the fully-qualified name of the TabletManager's ApplySchema // RPC. TabletManagerApplySchemaProcedure = "/tabletmanagerservice.TabletManager/ApplySchema" // TabletManagerResetSequencesProcedure is the fully-qualified name of the TabletManager's // ResetSequences RPC. TabletManagerResetSequencesProcedure = "/tabletmanagerservice.TabletManager/ResetSequences" // TabletManagerLockTablesProcedure is the fully-qualified name of the TabletManager's LockTables // RPC. TabletManagerLockTablesProcedure = "/tabletmanagerservice.TabletManager/LockTables" // TabletManagerUnlockTablesProcedure is the fully-qualified name of the TabletManager's // UnlockTables RPC. TabletManagerUnlockTablesProcedure = "/tabletmanagerservice.TabletManager/UnlockTables" // TabletManagerExecuteQueryProcedure is the fully-qualified name of the TabletManager's // ExecuteQuery RPC. TabletManagerExecuteQueryProcedure = "/tabletmanagerservice.TabletManager/ExecuteQuery" // TabletManagerExecuteFetchAsDbaProcedure is the fully-qualified name of the TabletManager's // ExecuteFetchAsDba RPC. TabletManagerExecuteFetchAsDbaProcedure = "/tabletmanagerservice.TabletManager/ExecuteFetchAsDba" // TabletManagerExecuteFetchAsAllPrivsProcedure is the fully-qualified name of the TabletManager's // ExecuteFetchAsAllPrivs RPC. TabletManagerExecuteFetchAsAllPrivsProcedure = "/tabletmanagerservice.TabletManager/ExecuteFetchAsAllPrivs" // TabletManagerExecuteFetchAsAppProcedure is the fully-qualified name of the TabletManager's // ExecuteFetchAsApp RPC. TabletManagerExecuteFetchAsAppProcedure = "/tabletmanagerservice.TabletManager/ExecuteFetchAsApp" // TabletManagerReplicationStatusProcedure is the fully-qualified name of the TabletManager's // ReplicationStatus RPC. TabletManagerReplicationStatusProcedure = "/tabletmanagerservice.TabletManager/ReplicationStatus" // TabletManagerPrimaryStatusProcedure is the fully-qualified name of the TabletManager's // PrimaryStatus RPC. TabletManagerPrimaryStatusProcedure = "/tabletmanagerservice.TabletManager/PrimaryStatus" // TabletManagerPrimaryPositionProcedure is the fully-qualified name of the TabletManager's // PrimaryPosition RPC. TabletManagerPrimaryPositionProcedure = "/tabletmanagerservice.TabletManager/PrimaryPosition" // TabletManagerWaitForPositionProcedure is the fully-qualified name of the TabletManager's // WaitForPosition RPC. TabletManagerWaitForPositionProcedure = "/tabletmanagerservice.TabletManager/WaitForPosition" // TabletManagerStopReplicationProcedure is the fully-qualified name of the TabletManager's // StopReplication RPC. TabletManagerStopReplicationProcedure = "/tabletmanagerservice.TabletManager/StopReplication" // TabletManagerStopReplicationMinimumProcedure is the fully-qualified name of the TabletManager's // StopReplicationMinimum RPC. TabletManagerStopReplicationMinimumProcedure = "/tabletmanagerservice.TabletManager/StopReplicationMinimum" // TabletManagerStartReplicationProcedure is the fully-qualified name of the TabletManager's // StartReplication RPC. TabletManagerStartReplicationProcedure = "/tabletmanagerservice.TabletManager/StartReplication" // TabletManagerStartReplicationUntilAfterProcedure is the fully-qualified name of the // TabletManager's StartReplicationUntilAfter RPC. TabletManagerStartReplicationUntilAfterProcedure = "/tabletmanagerservice.TabletManager/StartReplicationUntilAfter" // TabletManagerGetReplicasProcedure is the fully-qualified name of the TabletManager's GetReplicas // RPC. TabletManagerGetReplicasProcedure = "/tabletmanagerservice.TabletManager/GetReplicas" // TabletManagerCreateVReplicationWorkflowProcedure is the fully-qualified name of the // TabletManager's CreateVReplicationWorkflow RPC. TabletManagerCreateVReplicationWorkflowProcedure = "/tabletmanagerservice.TabletManager/CreateVReplicationWorkflow" // TabletManagerDeleteVReplicationWorkflowProcedure is the fully-qualified name of the // TabletManager's DeleteVReplicationWorkflow RPC. TabletManagerDeleteVReplicationWorkflowProcedure = "/tabletmanagerservice.TabletManager/DeleteVReplicationWorkflow" // TabletManagerReadVReplicationWorkflowProcedure is the fully-qualified name of the TabletManager's // ReadVReplicationWorkflow RPC. TabletManagerReadVReplicationWorkflowProcedure = "/tabletmanagerservice.TabletManager/ReadVReplicationWorkflow" // TabletManagerVReplicationExecProcedure is the fully-qualified name of the TabletManager's // VReplicationExec RPC. TabletManagerVReplicationExecProcedure = "/tabletmanagerservice.TabletManager/VReplicationExec" // TabletManagerVReplicationWaitForPosProcedure is the fully-qualified name of the TabletManager's // VReplicationWaitForPos RPC. TabletManagerVReplicationWaitForPosProcedure = "/tabletmanagerservice.TabletManager/VReplicationWaitForPos" // TabletManagerUpdateVReplicationWorkflowProcedure is the fully-qualified name of the // TabletManager's UpdateVReplicationWorkflow RPC. TabletManagerUpdateVReplicationWorkflowProcedure = "/tabletmanagerservice.TabletManager/UpdateVReplicationWorkflow" // TabletManagerVDiffProcedure is the fully-qualified name of the TabletManager's VDiff RPC. TabletManagerVDiffProcedure = "/tabletmanagerservice.TabletManager/VDiff" // TabletManagerResetReplicationProcedure is the fully-qualified name of the TabletManager's // ResetReplication RPC. TabletManagerResetReplicationProcedure = "/tabletmanagerservice.TabletManager/ResetReplication" // TabletManagerInitPrimaryProcedure is the fully-qualified name of the TabletManager's InitPrimary // RPC. TabletManagerInitPrimaryProcedure = "/tabletmanagerservice.TabletManager/InitPrimary" // TabletManagerPopulateReparentJournalProcedure is the fully-qualified name of the TabletManager's // PopulateReparentJournal RPC. TabletManagerPopulateReparentJournalProcedure = "/tabletmanagerservice.TabletManager/PopulateReparentJournal" // TabletManagerInitReplicaProcedure is the fully-qualified name of the TabletManager's InitReplica // RPC. TabletManagerInitReplicaProcedure = "/tabletmanagerservice.TabletManager/InitReplica" // TabletManagerDemotePrimaryProcedure is the fully-qualified name of the TabletManager's // DemotePrimary RPC. TabletManagerDemotePrimaryProcedure = "/tabletmanagerservice.TabletManager/DemotePrimary" // TabletManagerUndoDemotePrimaryProcedure is the fully-qualified name of the TabletManager's // UndoDemotePrimary RPC. TabletManagerUndoDemotePrimaryProcedure = "/tabletmanagerservice.TabletManager/UndoDemotePrimary" // TabletManagerReplicaWasPromotedProcedure is the fully-qualified name of the TabletManager's // ReplicaWasPromoted RPC. TabletManagerReplicaWasPromotedProcedure = "/tabletmanagerservice.TabletManager/ReplicaWasPromoted" // TabletManagerResetReplicationParametersProcedure is the fully-qualified name of the // TabletManager's ResetReplicationParameters RPC. TabletManagerResetReplicationParametersProcedure = "/tabletmanagerservice.TabletManager/ResetReplicationParameters" // TabletManagerFullStatusProcedure is the fully-qualified name of the TabletManager's FullStatus // RPC. TabletManagerFullStatusProcedure = "/tabletmanagerservice.TabletManager/FullStatus" // TabletManagerSetReplicationSourceProcedure is the fully-qualified name of the TabletManager's // SetReplicationSource RPC. TabletManagerSetReplicationSourceProcedure = "/tabletmanagerservice.TabletManager/SetReplicationSource" // TabletManagerReplicaWasRestartedProcedure is the fully-qualified name of the TabletManager's // ReplicaWasRestarted RPC. TabletManagerReplicaWasRestartedProcedure = "/tabletmanagerservice.TabletManager/ReplicaWasRestarted" // TabletManagerStopReplicationAndGetStatusProcedure is the fully-qualified name of the // TabletManager's StopReplicationAndGetStatus RPC. TabletManagerStopReplicationAndGetStatusProcedure = "/tabletmanagerservice.TabletManager/StopReplicationAndGetStatus" // TabletManagerPromoteReplicaProcedure is the fully-qualified name of the TabletManager's // PromoteReplica RPC. TabletManagerPromoteReplicaProcedure = "/tabletmanagerservice.TabletManager/PromoteReplica" // TabletManagerBackupProcedure is the fully-qualified name of the TabletManager's Backup RPC. TabletManagerBackupProcedure = "/tabletmanagerservice.TabletManager/Backup" // TabletManagerRestoreFromBackupProcedure is the fully-qualified name of the TabletManager's // RestoreFromBackup RPC. TabletManagerRestoreFromBackupProcedure = "/tabletmanagerservice.TabletManager/RestoreFromBackup" // TabletManagerCheckThrottlerProcedure is the fully-qualified name of the TabletManager's // CheckThrottler RPC. TabletManagerCheckThrottlerProcedure = "/tabletmanagerservice.TabletManager/CheckThrottler" )
These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.
Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.
const (
// TabletManagerName is the fully-qualified name of the TabletManager service.
TabletManagerName = "tabletmanagerservice.TabletManager"
)
Variables ¶
This section is empty.
Functions ¶
func NewTabletManagerHandler ¶
func NewTabletManagerHandler(svc TabletManagerHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewTabletManagerHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.
By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.
Types ¶
type TabletManagerClient ¶
type TabletManagerClient interface { // Ping returns the input payload Ping(context.Context, *connect.Request[v18.PingRequest]) (*connect.Response[v18.PingResponse], error) // Sleep sleeps for the provided duration Sleep(context.Context, *connect.Request[v18.SleepRequest]) (*connect.Response[v18.SleepResponse], error) // ExecuteHook executes the hook remotely ExecuteHook(context.Context, *connect.Request[v18.ExecuteHookRequest]) (*connect.Response[v18.ExecuteHookResponse], error) // GetSchema asks the tablet for its schema GetSchema(context.Context, *connect.Request[v18.GetSchemaRequest]) (*connect.Response[v18.GetSchemaResponse], error) // GetPermissions asks the tablet for its permissions GetPermissions(context.Context, *connect.Request[v18.GetPermissionsRequest]) (*connect.Response[v18.GetPermissionsResponse], error) SetReadOnly(context.Context, *connect.Request[v18.SetReadOnlyRequest]) (*connect.Response[v18.SetReadOnlyResponse], error) SetReadWrite(context.Context, *connect.Request[v18.SetReadWriteRequest]) (*connect.Response[v18.SetReadWriteResponse], error) // ChangeType asks the remote tablet to change its type ChangeType(context.Context, *connect.Request[v18.ChangeTypeRequest]) (*connect.Response[v18.ChangeTypeResponse], error) RefreshState(context.Context, *connect.Request[v18.RefreshStateRequest]) (*connect.Response[v18.RefreshStateResponse], error) RunHealthCheck(context.Context, *connect.Request[v18.RunHealthCheckRequest]) (*connect.Response[v18.RunHealthCheckResponse], error) ReloadSchema(context.Context, *connect.Request[v18.ReloadSchemaRequest]) (*connect.Response[v18.ReloadSchemaResponse], error) PreflightSchema(context.Context, *connect.Request[v18.PreflightSchemaRequest]) (*connect.Response[v18.PreflightSchemaResponse], error) ApplySchema(context.Context, *connect.Request[v18.ApplySchemaRequest]) (*connect.Response[v18.ApplySchemaResponse], error) ResetSequences(context.Context, *connect.Request[v18.ResetSequencesRequest]) (*connect.Response[v18.ResetSequencesResponse], error) LockTables(context.Context, *connect.Request[v18.LockTablesRequest]) (*connect.Response[v18.LockTablesResponse], error) UnlockTables(context.Context, *connect.Request[v18.UnlockTablesRequest]) (*connect.Response[v18.UnlockTablesResponse], error) ExecuteQuery(context.Context, *connect.Request[v18.ExecuteQueryRequest]) (*connect.Response[v18.ExecuteQueryResponse], error) ExecuteFetchAsDba(context.Context, *connect.Request[v18.ExecuteFetchAsDbaRequest]) (*connect.Response[v18.ExecuteFetchAsDbaResponse], error) ExecuteFetchAsAllPrivs(context.Context, *connect.Request[v18.ExecuteFetchAsAllPrivsRequest]) (*connect.Response[v18.ExecuteFetchAsAllPrivsResponse], error) ExecuteFetchAsApp(context.Context, *connect.Request[v18.ExecuteFetchAsAppRequest]) (*connect.Response[v18.ExecuteFetchAsAppResponse], error) // ReplicationStatus returns the current replication status. ReplicationStatus(context.Context, *connect.Request[v18.ReplicationStatusRequest]) (*connect.Response[v18.ReplicationStatusResponse], error) // PrimaryStatus returns the current primary status. PrimaryStatus(context.Context, *connect.Request[v18.PrimaryStatusRequest]) (*connect.Response[v18.PrimaryStatusResponse], error) // PrimaryPosition returns the current primary position PrimaryPosition(context.Context, *connect.Request[v18.PrimaryPositionRequest]) (*connect.Response[v18.PrimaryPositionResponse], error) // WaitForPosition waits for the position to be reached WaitForPosition(context.Context, *connect.Request[v18.WaitForPositionRequest]) (*connect.Response[v18.WaitForPositionResponse], error) // StopReplication makes mysql stop its replication StopReplication(context.Context, *connect.Request[v18.StopReplicationRequest]) (*connect.Response[v18.StopReplicationResponse], error) // StopReplicationMinimum stops the mysql replication after it reaches // the provided minimum point StopReplicationMinimum(context.Context, *connect.Request[v18.StopReplicationMinimumRequest]) (*connect.Response[v18.StopReplicationMinimumResponse], error) // StartReplication starts the mysql replication StartReplication(context.Context, *connect.Request[v18.StartReplicationRequest]) (*connect.Response[v18.StartReplicationResponse], error) // StartReplicationUnitAfter starts the mysql replication until and including // the provided position StartReplicationUntilAfter(context.Context, *connect.Request[v18.StartReplicationUntilAfterRequest]) (*connect.Response[v18.StartReplicationUntilAfterResponse], error) // GetReplicas asks for the list of mysql replicas GetReplicas(context.Context, *connect.Request[v18.GetReplicasRequest]) (*connect.Response[v18.GetReplicasResponse], error) // VReplication API CreateVReplicationWorkflow(context.Context, *connect.Request[v18.CreateVReplicationWorkflowRequest]) (*connect.Response[v18.CreateVReplicationWorkflowResponse], error) DeleteVReplicationWorkflow(context.Context, *connect.Request[v18.DeleteVReplicationWorkflowRequest]) (*connect.Response[v18.DeleteVReplicationWorkflowResponse], error) ReadVReplicationWorkflow(context.Context, *connect.Request[v18.ReadVReplicationWorkflowRequest]) (*connect.Response[v18.ReadVReplicationWorkflowResponse], error) VReplicationExec(context.Context, *connect.Request[v18.VReplicationExecRequest]) (*connect.Response[v18.VReplicationExecResponse], error) VReplicationWaitForPos(context.Context, *connect.Request[v18.VReplicationWaitForPosRequest]) (*connect.Response[v18.VReplicationWaitForPosResponse], error) UpdateVReplicationWorkflow(context.Context, *connect.Request[v18.UpdateVReplicationWorkflowRequest]) (*connect.Response[v18.UpdateVReplicationWorkflowResponse], error) // VDiff API VDiff(context.Context, *connect.Request[v18.VDiffRequest]) (*connect.Response[v18.VDiffResponse], error) // ResetReplication makes the target not replicating ResetReplication(context.Context, *connect.Request[v18.ResetReplicationRequest]) (*connect.Response[v18.ResetReplicationResponse], error) // InitPrimary initializes the tablet as a primary InitPrimary(context.Context, *connect.Request[v18.InitPrimaryRequest]) (*connect.Response[v18.InitPrimaryResponse], error) // PopulateReparentJournal tells the tablet to add an entry to its // reparent journal PopulateReparentJournal(context.Context, *connect.Request[v18.PopulateReparentJournalRequest]) (*connect.Response[v18.PopulateReparentJournalResponse], error) // InitReplica tells the tablet to reparent to the primary unconditionally InitReplica(context.Context, *connect.Request[v18.InitReplicaRequest]) (*connect.Response[v18.InitReplicaResponse], error) // DemotePrimary tells the soon-to-be-former primary it's gonna change DemotePrimary(context.Context, *connect.Request[v18.DemotePrimaryRequest]) (*connect.Response[v18.DemotePrimaryResponse], error) // UndoDemotePrimary reverts all changes made by DemotePrimary UndoDemotePrimary(context.Context, *connect.Request[v18.UndoDemotePrimaryRequest]) (*connect.Response[v18.UndoDemotePrimaryResponse], error) // ReplicaWasPromoted tells the remote tablet it is now the primary ReplicaWasPromoted(context.Context, *connect.Request[v18.ReplicaWasPromotedRequest]) (*connect.Response[v18.ReplicaWasPromotedResponse], error) // ResetReplicationParameters resets the replica replication parameters ResetReplicationParameters(context.Context, *connect.Request[v18.ResetReplicationParametersRequest]) (*connect.Response[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, *connect.Request[v18.FullStatusRequest]) (*connect.Response[v18.FullStatusResponse], error) // SetReplicationSource tells the replica to reparent SetReplicationSource(context.Context, *connect.Request[v18.SetReplicationSourceRequest]) (*connect.Response[v18.SetReplicationSourceResponse], error) // ReplicaWasRestarted tells the remote tablet its primary has changed ReplicaWasRestarted(context.Context, *connect.Request[v18.ReplicaWasRestartedRequest]) (*connect.Response[v18.ReplicaWasRestartedResponse], error) // StopReplicationAndGetStatus stops MySQL replication, and returns the // replication status StopReplicationAndGetStatus(context.Context, *connect.Request[v18.StopReplicationAndGetStatusRequest]) (*connect.Response[v18.StopReplicationAndGetStatusResponse], error) // PromoteReplica makes the replica the new primary PromoteReplica(context.Context, *connect.Request[v18.PromoteReplicaRequest]) (*connect.Response[v18.PromoteReplicaResponse], error) Backup(context.Context, *connect.Request[v18.BackupRequest]) (*connect.ServerStreamForClient[v18.BackupResponse], error) // RestoreFromBackup deletes all local data and restores it from the latest backup. RestoreFromBackup(context.Context, *connect.Request[v18.RestoreFromBackupRequest]) (*connect.ServerStreamForClient[v18.RestoreFromBackupResponse], error) // CheckThrottler issues a 'check' on a tablet's throttler CheckThrottler(context.Context, *connect.Request[v18.CheckThrottlerRequest]) (*connect.Response[v18.CheckThrottlerResponse], error) }
TabletManagerClient is a client for the tabletmanagerservice.TabletManager service.
func NewTabletManagerClient ¶
func NewTabletManagerClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) TabletManagerClient
NewTabletManagerClient constructs a client for the tabletmanagerservice.TabletManager service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.
The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).
type TabletManagerHandler ¶
type TabletManagerHandler interface { // Ping returns the input payload Ping(context.Context, *connect.Request[v18.PingRequest]) (*connect.Response[v18.PingResponse], error) // Sleep sleeps for the provided duration Sleep(context.Context, *connect.Request[v18.SleepRequest]) (*connect.Response[v18.SleepResponse], error) // ExecuteHook executes the hook remotely ExecuteHook(context.Context, *connect.Request[v18.ExecuteHookRequest]) (*connect.Response[v18.ExecuteHookResponse], error) // GetSchema asks the tablet for its schema GetSchema(context.Context, *connect.Request[v18.GetSchemaRequest]) (*connect.Response[v18.GetSchemaResponse], error) // GetPermissions asks the tablet for its permissions GetPermissions(context.Context, *connect.Request[v18.GetPermissionsRequest]) (*connect.Response[v18.GetPermissionsResponse], error) SetReadOnly(context.Context, *connect.Request[v18.SetReadOnlyRequest]) (*connect.Response[v18.SetReadOnlyResponse], error) SetReadWrite(context.Context, *connect.Request[v18.SetReadWriteRequest]) (*connect.Response[v18.SetReadWriteResponse], error) // ChangeType asks the remote tablet to change its type ChangeType(context.Context, *connect.Request[v18.ChangeTypeRequest]) (*connect.Response[v18.ChangeTypeResponse], error) RefreshState(context.Context, *connect.Request[v18.RefreshStateRequest]) (*connect.Response[v18.RefreshStateResponse], error) RunHealthCheck(context.Context, *connect.Request[v18.RunHealthCheckRequest]) (*connect.Response[v18.RunHealthCheckResponse], error) ReloadSchema(context.Context, *connect.Request[v18.ReloadSchemaRequest]) (*connect.Response[v18.ReloadSchemaResponse], error) PreflightSchema(context.Context, *connect.Request[v18.PreflightSchemaRequest]) (*connect.Response[v18.PreflightSchemaResponse], error) ApplySchema(context.Context, *connect.Request[v18.ApplySchemaRequest]) (*connect.Response[v18.ApplySchemaResponse], error) ResetSequences(context.Context, *connect.Request[v18.ResetSequencesRequest]) (*connect.Response[v18.ResetSequencesResponse], error) LockTables(context.Context, *connect.Request[v18.LockTablesRequest]) (*connect.Response[v18.LockTablesResponse], error) UnlockTables(context.Context, *connect.Request[v18.UnlockTablesRequest]) (*connect.Response[v18.UnlockTablesResponse], error) ExecuteQuery(context.Context, *connect.Request[v18.ExecuteQueryRequest]) (*connect.Response[v18.ExecuteQueryResponse], error) ExecuteFetchAsDba(context.Context, *connect.Request[v18.ExecuteFetchAsDbaRequest]) (*connect.Response[v18.ExecuteFetchAsDbaResponse], error) ExecuteFetchAsAllPrivs(context.Context, *connect.Request[v18.ExecuteFetchAsAllPrivsRequest]) (*connect.Response[v18.ExecuteFetchAsAllPrivsResponse], error) ExecuteFetchAsApp(context.Context, *connect.Request[v18.ExecuteFetchAsAppRequest]) (*connect.Response[v18.ExecuteFetchAsAppResponse], error) // ReplicationStatus returns the current replication status. ReplicationStatus(context.Context, *connect.Request[v18.ReplicationStatusRequest]) (*connect.Response[v18.ReplicationStatusResponse], error) // PrimaryStatus returns the current primary status. PrimaryStatus(context.Context, *connect.Request[v18.PrimaryStatusRequest]) (*connect.Response[v18.PrimaryStatusResponse], error) // PrimaryPosition returns the current primary position PrimaryPosition(context.Context, *connect.Request[v18.PrimaryPositionRequest]) (*connect.Response[v18.PrimaryPositionResponse], error) // WaitForPosition waits for the position to be reached WaitForPosition(context.Context, *connect.Request[v18.WaitForPositionRequest]) (*connect.Response[v18.WaitForPositionResponse], error) // StopReplication makes mysql stop its replication StopReplication(context.Context, *connect.Request[v18.StopReplicationRequest]) (*connect.Response[v18.StopReplicationResponse], error) // StopReplicationMinimum stops the mysql replication after it reaches // the provided minimum point StopReplicationMinimum(context.Context, *connect.Request[v18.StopReplicationMinimumRequest]) (*connect.Response[v18.StopReplicationMinimumResponse], error) // StartReplication starts the mysql replication StartReplication(context.Context, *connect.Request[v18.StartReplicationRequest]) (*connect.Response[v18.StartReplicationResponse], error) // StartReplicationUnitAfter starts the mysql replication until and including // the provided position StartReplicationUntilAfter(context.Context, *connect.Request[v18.StartReplicationUntilAfterRequest]) (*connect.Response[v18.StartReplicationUntilAfterResponse], error) // GetReplicas asks for the list of mysql replicas GetReplicas(context.Context, *connect.Request[v18.GetReplicasRequest]) (*connect.Response[v18.GetReplicasResponse], error) // VReplication API CreateVReplicationWorkflow(context.Context, *connect.Request[v18.CreateVReplicationWorkflowRequest]) (*connect.Response[v18.CreateVReplicationWorkflowResponse], error) DeleteVReplicationWorkflow(context.Context, *connect.Request[v18.DeleteVReplicationWorkflowRequest]) (*connect.Response[v18.DeleteVReplicationWorkflowResponse], error) ReadVReplicationWorkflow(context.Context, *connect.Request[v18.ReadVReplicationWorkflowRequest]) (*connect.Response[v18.ReadVReplicationWorkflowResponse], error) VReplicationExec(context.Context, *connect.Request[v18.VReplicationExecRequest]) (*connect.Response[v18.VReplicationExecResponse], error) VReplicationWaitForPos(context.Context, *connect.Request[v18.VReplicationWaitForPosRequest]) (*connect.Response[v18.VReplicationWaitForPosResponse], error) UpdateVReplicationWorkflow(context.Context, *connect.Request[v18.UpdateVReplicationWorkflowRequest]) (*connect.Response[v18.UpdateVReplicationWorkflowResponse], error) // VDiff API VDiff(context.Context, *connect.Request[v18.VDiffRequest]) (*connect.Response[v18.VDiffResponse], error) // ResetReplication makes the target not replicating ResetReplication(context.Context, *connect.Request[v18.ResetReplicationRequest]) (*connect.Response[v18.ResetReplicationResponse], error) // InitPrimary initializes the tablet as a primary InitPrimary(context.Context, *connect.Request[v18.InitPrimaryRequest]) (*connect.Response[v18.InitPrimaryResponse], error) // PopulateReparentJournal tells the tablet to add an entry to its // reparent journal PopulateReparentJournal(context.Context, *connect.Request[v18.PopulateReparentJournalRequest]) (*connect.Response[v18.PopulateReparentJournalResponse], error) // InitReplica tells the tablet to reparent to the primary unconditionally InitReplica(context.Context, *connect.Request[v18.InitReplicaRequest]) (*connect.Response[v18.InitReplicaResponse], error) // DemotePrimary tells the soon-to-be-former primary it's gonna change DemotePrimary(context.Context, *connect.Request[v18.DemotePrimaryRequest]) (*connect.Response[v18.DemotePrimaryResponse], error) // UndoDemotePrimary reverts all changes made by DemotePrimary UndoDemotePrimary(context.Context, *connect.Request[v18.UndoDemotePrimaryRequest]) (*connect.Response[v18.UndoDemotePrimaryResponse], error) // ReplicaWasPromoted tells the remote tablet it is now the primary ReplicaWasPromoted(context.Context, *connect.Request[v18.ReplicaWasPromotedRequest]) (*connect.Response[v18.ReplicaWasPromotedResponse], error) // ResetReplicationParameters resets the replica replication parameters ResetReplicationParameters(context.Context, *connect.Request[v18.ResetReplicationParametersRequest]) (*connect.Response[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, *connect.Request[v18.FullStatusRequest]) (*connect.Response[v18.FullStatusResponse], error) // SetReplicationSource tells the replica to reparent SetReplicationSource(context.Context, *connect.Request[v18.SetReplicationSourceRequest]) (*connect.Response[v18.SetReplicationSourceResponse], error) // ReplicaWasRestarted tells the remote tablet its primary has changed ReplicaWasRestarted(context.Context, *connect.Request[v18.ReplicaWasRestartedRequest]) (*connect.Response[v18.ReplicaWasRestartedResponse], error) // StopReplicationAndGetStatus stops MySQL replication, and returns the // replication status StopReplicationAndGetStatus(context.Context, *connect.Request[v18.StopReplicationAndGetStatusRequest]) (*connect.Response[v18.StopReplicationAndGetStatusResponse], error) // PromoteReplica makes the replica the new primary PromoteReplica(context.Context, *connect.Request[v18.PromoteReplicaRequest]) (*connect.Response[v18.PromoteReplicaResponse], error) Backup(context.Context, *connect.Request[v18.BackupRequest], *connect.ServerStream[v18.BackupResponse]) error // RestoreFromBackup deletes all local data and restores it from the latest backup. RestoreFromBackup(context.Context, *connect.Request[v18.RestoreFromBackupRequest], *connect.ServerStream[v18.RestoreFromBackupResponse]) error // CheckThrottler issues a 'check' on a tablet's throttler CheckThrottler(context.Context, *connect.Request[v18.CheckThrottlerRequest]) (*connect.Response[v18.CheckThrottlerResponse], error) }
TabletManagerHandler is an implementation of the tabletmanagerservice.TabletManager service.
type UnimplementedTabletManagerHandler ¶
type UnimplementedTabletManagerHandler struct{}
UnimplementedTabletManagerHandler returns CodeUnimplemented from all methods.
func (UnimplementedTabletManagerHandler) ApplySchema ¶
func (UnimplementedTabletManagerHandler) ApplySchema(context.Context, *connect.Request[v18.ApplySchemaRequest]) (*connect.Response[v18.ApplySchemaResponse], error)
func (UnimplementedTabletManagerHandler) Backup ¶
func (UnimplementedTabletManagerHandler) Backup(context.Context, *connect.Request[v18.BackupRequest], *connect.ServerStream[v18.BackupResponse]) error
func (UnimplementedTabletManagerHandler) ChangeType ¶
func (UnimplementedTabletManagerHandler) ChangeType(context.Context, *connect.Request[v18.ChangeTypeRequest]) (*connect.Response[v18.ChangeTypeResponse], error)
func (UnimplementedTabletManagerHandler) CheckThrottler ¶
func (UnimplementedTabletManagerHandler) CheckThrottler(context.Context, *connect.Request[v18.CheckThrottlerRequest]) (*connect.Response[v18.CheckThrottlerResponse], error)
func (UnimplementedTabletManagerHandler) CreateVReplicationWorkflow ¶
func (UnimplementedTabletManagerHandler) CreateVReplicationWorkflow(context.Context, *connect.Request[v18.CreateVReplicationWorkflowRequest]) (*connect.Response[v18.CreateVReplicationWorkflowResponse], error)
func (UnimplementedTabletManagerHandler) DeleteVReplicationWorkflow ¶
func (UnimplementedTabletManagerHandler) DeleteVReplicationWorkflow(context.Context, *connect.Request[v18.DeleteVReplicationWorkflowRequest]) (*connect.Response[v18.DeleteVReplicationWorkflowResponse], error)
func (UnimplementedTabletManagerHandler) DemotePrimary ¶
func (UnimplementedTabletManagerHandler) DemotePrimary(context.Context, *connect.Request[v18.DemotePrimaryRequest]) (*connect.Response[v18.DemotePrimaryResponse], error)
func (UnimplementedTabletManagerHandler) ExecuteFetchAsAllPrivs ¶
func (UnimplementedTabletManagerHandler) ExecuteFetchAsAllPrivs(context.Context, *connect.Request[v18.ExecuteFetchAsAllPrivsRequest]) (*connect.Response[v18.ExecuteFetchAsAllPrivsResponse], error)
func (UnimplementedTabletManagerHandler) ExecuteFetchAsApp ¶
func (UnimplementedTabletManagerHandler) ExecuteFetchAsApp(context.Context, *connect.Request[v18.ExecuteFetchAsAppRequest]) (*connect.Response[v18.ExecuteFetchAsAppResponse], error)
func (UnimplementedTabletManagerHandler) ExecuteFetchAsDba ¶
func (UnimplementedTabletManagerHandler) ExecuteFetchAsDba(context.Context, *connect.Request[v18.ExecuteFetchAsDbaRequest]) (*connect.Response[v18.ExecuteFetchAsDbaResponse], error)
func (UnimplementedTabletManagerHandler) ExecuteHook ¶
func (UnimplementedTabletManagerHandler) ExecuteHook(context.Context, *connect.Request[v18.ExecuteHookRequest]) (*connect.Response[v18.ExecuteHookResponse], error)
func (UnimplementedTabletManagerHandler) ExecuteQuery ¶
func (UnimplementedTabletManagerHandler) ExecuteQuery(context.Context, *connect.Request[v18.ExecuteQueryRequest]) (*connect.Response[v18.ExecuteQueryResponse], error)
func (UnimplementedTabletManagerHandler) FullStatus ¶
func (UnimplementedTabletManagerHandler) FullStatus(context.Context, *connect.Request[v18.FullStatusRequest]) (*connect.Response[v18.FullStatusResponse], error)
func (UnimplementedTabletManagerHandler) GetPermissions ¶
func (UnimplementedTabletManagerHandler) GetPermissions(context.Context, *connect.Request[v18.GetPermissionsRequest]) (*connect.Response[v18.GetPermissionsResponse], error)
func (UnimplementedTabletManagerHandler) GetReplicas ¶
func (UnimplementedTabletManagerHandler) GetReplicas(context.Context, *connect.Request[v18.GetReplicasRequest]) (*connect.Response[v18.GetReplicasResponse], error)
func (UnimplementedTabletManagerHandler) GetSchema ¶
func (UnimplementedTabletManagerHandler) GetSchema(context.Context, *connect.Request[v18.GetSchemaRequest]) (*connect.Response[v18.GetSchemaResponse], error)
func (UnimplementedTabletManagerHandler) InitPrimary ¶
func (UnimplementedTabletManagerHandler) InitPrimary(context.Context, *connect.Request[v18.InitPrimaryRequest]) (*connect.Response[v18.InitPrimaryResponse], error)
func (UnimplementedTabletManagerHandler) InitReplica ¶
func (UnimplementedTabletManagerHandler) InitReplica(context.Context, *connect.Request[v18.InitReplicaRequest]) (*connect.Response[v18.InitReplicaResponse], error)
func (UnimplementedTabletManagerHandler) LockTables ¶
func (UnimplementedTabletManagerHandler) LockTables(context.Context, *connect.Request[v18.LockTablesRequest]) (*connect.Response[v18.LockTablesResponse], error)
func (UnimplementedTabletManagerHandler) Ping ¶
func (UnimplementedTabletManagerHandler) Ping(context.Context, *connect.Request[v18.PingRequest]) (*connect.Response[v18.PingResponse], error)
func (UnimplementedTabletManagerHandler) PopulateReparentJournal ¶
func (UnimplementedTabletManagerHandler) PopulateReparentJournal(context.Context, *connect.Request[v18.PopulateReparentJournalRequest]) (*connect.Response[v18.PopulateReparentJournalResponse], error)
func (UnimplementedTabletManagerHandler) PreflightSchema ¶
func (UnimplementedTabletManagerHandler) PreflightSchema(context.Context, *connect.Request[v18.PreflightSchemaRequest]) (*connect.Response[v18.PreflightSchemaResponse], error)
func (UnimplementedTabletManagerHandler) PrimaryPosition ¶
func (UnimplementedTabletManagerHandler) PrimaryPosition(context.Context, *connect.Request[v18.PrimaryPositionRequest]) (*connect.Response[v18.PrimaryPositionResponse], error)
func (UnimplementedTabletManagerHandler) PrimaryStatus ¶
func (UnimplementedTabletManagerHandler) PrimaryStatus(context.Context, *connect.Request[v18.PrimaryStatusRequest]) (*connect.Response[v18.PrimaryStatusResponse], error)
func (UnimplementedTabletManagerHandler) PromoteReplica ¶
func (UnimplementedTabletManagerHandler) PromoteReplica(context.Context, *connect.Request[v18.PromoteReplicaRequest]) (*connect.Response[v18.PromoteReplicaResponse], error)
func (UnimplementedTabletManagerHandler) ReadVReplicationWorkflow ¶
func (UnimplementedTabletManagerHandler) ReadVReplicationWorkflow(context.Context, *connect.Request[v18.ReadVReplicationWorkflowRequest]) (*connect.Response[v18.ReadVReplicationWorkflowResponse], error)
func (UnimplementedTabletManagerHandler) RefreshState ¶
func (UnimplementedTabletManagerHandler) RefreshState(context.Context, *connect.Request[v18.RefreshStateRequest]) (*connect.Response[v18.RefreshStateResponse], error)
func (UnimplementedTabletManagerHandler) ReloadSchema ¶
func (UnimplementedTabletManagerHandler) ReloadSchema(context.Context, *connect.Request[v18.ReloadSchemaRequest]) (*connect.Response[v18.ReloadSchemaResponse], error)
func (UnimplementedTabletManagerHandler) ReplicaWasPromoted ¶
func (UnimplementedTabletManagerHandler) ReplicaWasPromoted(context.Context, *connect.Request[v18.ReplicaWasPromotedRequest]) (*connect.Response[v18.ReplicaWasPromotedResponse], error)
func (UnimplementedTabletManagerHandler) ReplicaWasRestarted ¶
func (UnimplementedTabletManagerHandler) ReplicaWasRestarted(context.Context, *connect.Request[v18.ReplicaWasRestartedRequest]) (*connect.Response[v18.ReplicaWasRestartedResponse], error)
func (UnimplementedTabletManagerHandler) ReplicationStatus ¶
func (UnimplementedTabletManagerHandler) ReplicationStatus(context.Context, *connect.Request[v18.ReplicationStatusRequest]) (*connect.Response[v18.ReplicationStatusResponse], error)
func (UnimplementedTabletManagerHandler) ResetReplication ¶
func (UnimplementedTabletManagerHandler) ResetReplication(context.Context, *connect.Request[v18.ResetReplicationRequest]) (*connect.Response[v18.ResetReplicationResponse], error)
func (UnimplementedTabletManagerHandler) ResetReplicationParameters ¶
func (UnimplementedTabletManagerHandler) ResetReplicationParameters(context.Context, *connect.Request[v18.ResetReplicationParametersRequest]) (*connect.Response[v18.ResetReplicationParametersResponse], error)
func (UnimplementedTabletManagerHandler) ResetSequences ¶
func (UnimplementedTabletManagerHandler) ResetSequences(context.Context, *connect.Request[v18.ResetSequencesRequest]) (*connect.Response[v18.ResetSequencesResponse], error)
func (UnimplementedTabletManagerHandler) RestoreFromBackup ¶
func (UnimplementedTabletManagerHandler) RestoreFromBackup(context.Context, *connect.Request[v18.RestoreFromBackupRequest], *connect.ServerStream[v18.RestoreFromBackupResponse]) error
func (UnimplementedTabletManagerHandler) RunHealthCheck ¶
func (UnimplementedTabletManagerHandler) RunHealthCheck(context.Context, *connect.Request[v18.RunHealthCheckRequest]) (*connect.Response[v18.RunHealthCheckResponse], error)
func (UnimplementedTabletManagerHandler) SetReadOnly ¶
func (UnimplementedTabletManagerHandler) SetReadOnly(context.Context, *connect.Request[v18.SetReadOnlyRequest]) (*connect.Response[v18.SetReadOnlyResponse], error)
func (UnimplementedTabletManagerHandler) SetReadWrite ¶
func (UnimplementedTabletManagerHandler) SetReadWrite(context.Context, *connect.Request[v18.SetReadWriteRequest]) (*connect.Response[v18.SetReadWriteResponse], error)
func (UnimplementedTabletManagerHandler) SetReplicationSource ¶
func (UnimplementedTabletManagerHandler) SetReplicationSource(context.Context, *connect.Request[v18.SetReplicationSourceRequest]) (*connect.Response[v18.SetReplicationSourceResponse], error)
func (UnimplementedTabletManagerHandler) Sleep ¶
func (UnimplementedTabletManagerHandler) Sleep(context.Context, *connect.Request[v18.SleepRequest]) (*connect.Response[v18.SleepResponse], error)
func (UnimplementedTabletManagerHandler) StartReplication ¶
func (UnimplementedTabletManagerHandler) StartReplication(context.Context, *connect.Request[v18.StartReplicationRequest]) (*connect.Response[v18.StartReplicationResponse], error)
func (UnimplementedTabletManagerHandler) StartReplicationUntilAfter ¶
func (UnimplementedTabletManagerHandler) StartReplicationUntilAfter(context.Context, *connect.Request[v18.StartReplicationUntilAfterRequest]) (*connect.Response[v18.StartReplicationUntilAfterResponse], error)
func (UnimplementedTabletManagerHandler) StopReplication ¶
func (UnimplementedTabletManagerHandler) StopReplication(context.Context, *connect.Request[v18.StopReplicationRequest]) (*connect.Response[v18.StopReplicationResponse], error)
func (UnimplementedTabletManagerHandler) StopReplicationAndGetStatus ¶
func (UnimplementedTabletManagerHandler) StopReplicationAndGetStatus(context.Context, *connect.Request[v18.StopReplicationAndGetStatusRequest]) (*connect.Response[v18.StopReplicationAndGetStatusResponse], error)
func (UnimplementedTabletManagerHandler) StopReplicationMinimum ¶
func (UnimplementedTabletManagerHandler) StopReplicationMinimum(context.Context, *connect.Request[v18.StopReplicationMinimumRequest]) (*connect.Response[v18.StopReplicationMinimumResponse], error)
func (UnimplementedTabletManagerHandler) UndoDemotePrimary ¶
func (UnimplementedTabletManagerHandler) UndoDemotePrimary(context.Context, *connect.Request[v18.UndoDemotePrimaryRequest]) (*connect.Response[v18.UndoDemotePrimaryResponse], error)
func (UnimplementedTabletManagerHandler) UnlockTables ¶
func (UnimplementedTabletManagerHandler) UnlockTables(context.Context, *connect.Request[v18.UnlockTablesRequest]) (*connect.Response[v18.UnlockTablesResponse], error)
func (UnimplementedTabletManagerHandler) UpdateVReplicationWorkflow ¶
func (UnimplementedTabletManagerHandler) UpdateVReplicationWorkflow(context.Context, *connect.Request[v18.UpdateVReplicationWorkflowRequest]) (*connect.Response[v18.UpdateVReplicationWorkflowResponse], error)
func (UnimplementedTabletManagerHandler) VDiff ¶
func (UnimplementedTabletManagerHandler) VDiff(context.Context, *connect.Request[v18.VDiffRequest]) (*connect.Response[v18.VDiffResponse], error)
func (UnimplementedTabletManagerHandler) VReplicationExec ¶
func (UnimplementedTabletManagerHandler) VReplicationExec(context.Context, *connect.Request[v18.VReplicationExecRequest]) (*connect.Response[v18.VReplicationExecResponse], error)
func (UnimplementedTabletManagerHandler) VReplicationWaitForPos ¶
func (UnimplementedTabletManagerHandler) VReplicationWaitForPos(context.Context, *connect.Request[v18.VReplicationWaitForPosRequest]) (*connect.Response[v18.VReplicationWaitForPosResponse], error)
func (UnimplementedTabletManagerHandler) WaitForPosition ¶
func (UnimplementedTabletManagerHandler) WaitForPosition(context.Context, *connect.Request[v18.WaitForPositionRequest]) (*connect.Response[v18.WaitForPositionResponse], error)