go-vitess.v1: gopkg.in/src-d/go-vitess.v1/vt/proto/tabletmanagerservice Index | Files

package tabletmanagerservice

import "gopkg.in/src-d/go-vitess.v1/vt/proto/tabletmanagerservice"

Index

Package Files

tabletmanagerservice.pb.go

func RegisterTabletManagerServer Uses

func RegisterTabletManagerServer(s *grpc.Server, srv TabletManagerServer)

type TabletManagerClient Uses

type TabletManagerClient interface {
    // Ping returns the input payload
    Ping(ctx context.Context, in *tabletmanagerdata.PingRequest, opts ...grpc.CallOption) (*tabletmanagerdata.PingResponse, error)
    // Sleep sleeps for the provided duration
    Sleep(ctx context.Context, in *tabletmanagerdata.SleepRequest, opts ...grpc.CallOption) (*tabletmanagerdata.SleepResponse, error)
    // ExecuteHook executes the hook remotely
    ExecuteHook(ctx context.Context, in *tabletmanagerdata.ExecuteHookRequest, opts ...grpc.CallOption) (*tabletmanagerdata.ExecuteHookResponse, error)
    // GetSchema asks the tablet for its schema
    GetSchema(ctx context.Context, in *tabletmanagerdata.GetSchemaRequest, opts ...grpc.CallOption) (*tabletmanagerdata.GetSchemaResponse, error)
    // GetPermissions asks the tablet for its permissions
    GetPermissions(ctx context.Context, in *tabletmanagerdata.GetPermissionsRequest, opts ...grpc.CallOption) (*tabletmanagerdata.GetPermissionsResponse, error)
    SetReadOnly(ctx context.Context, in *tabletmanagerdata.SetReadOnlyRequest, opts ...grpc.CallOption) (*tabletmanagerdata.SetReadOnlyResponse, error)
    SetReadWrite(ctx context.Context, in *tabletmanagerdata.SetReadWriteRequest, opts ...grpc.CallOption) (*tabletmanagerdata.SetReadWriteResponse, error)
    // ChangeType asks the remote tablet to change its type
    ChangeType(ctx context.Context, in *tabletmanagerdata.ChangeTypeRequest, opts ...grpc.CallOption) (*tabletmanagerdata.ChangeTypeResponse, error)
    RefreshState(ctx context.Context, in *tabletmanagerdata.RefreshStateRequest, opts ...grpc.CallOption) (*tabletmanagerdata.RefreshStateResponse, error)
    RunHealthCheck(ctx context.Context, in *tabletmanagerdata.RunHealthCheckRequest, opts ...grpc.CallOption) (*tabletmanagerdata.RunHealthCheckResponse, error)
    IgnoreHealthError(ctx context.Context, in *tabletmanagerdata.IgnoreHealthErrorRequest, opts ...grpc.CallOption) (*tabletmanagerdata.IgnoreHealthErrorResponse, error)
    ReloadSchema(ctx context.Context, in *tabletmanagerdata.ReloadSchemaRequest, opts ...grpc.CallOption) (*tabletmanagerdata.ReloadSchemaResponse, error)
    PreflightSchema(ctx context.Context, in *tabletmanagerdata.PreflightSchemaRequest, opts ...grpc.CallOption) (*tabletmanagerdata.PreflightSchemaResponse, error)
    ApplySchema(ctx context.Context, in *tabletmanagerdata.ApplySchemaRequest, opts ...grpc.CallOption) (*tabletmanagerdata.ApplySchemaResponse, error)
    LockTables(ctx context.Context, in *tabletmanagerdata.LockTablesRequest, opts ...grpc.CallOption) (*tabletmanagerdata.LockTablesResponse, error)
    UnlockTables(ctx context.Context, in *tabletmanagerdata.UnlockTablesRequest, opts ...grpc.CallOption) (*tabletmanagerdata.UnlockTablesResponse, error)
    ExecuteFetchAsDba(ctx context.Context, in *tabletmanagerdata.ExecuteFetchAsDbaRequest, opts ...grpc.CallOption) (*tabletmanagerdata.ExecuteFetchAsDbaResponse, error)
    ExecuteFetchAsAllPrivs(ctx context.Context, in *tabletmanagerdata.ExecuteFetchAsAllPrivsRequest, opts ...grpc.CallOption) (*tabletmanagerdata.ExecuteFetchAsAllPrivsResponse, error)
    ExecuteFetchAsApp(ctx context.Context, in *tabletmanagerdata.ExecuteFetchAsAppRequest, opts ...grpc.CallOption) (*tabletmanagerdata.ExecuteFetchAsAppResponse, error)
    // SlaveStatus returns the current slave status.
    SlaveStatus(ctx context.Context, in *tabletmanagerdata.SlaveStatusRequest, opts ...grpc.CallOption) (*tabletmanagerdata.SlaveStatusResponse, error)
    // MasterPosition returns the current master position
    MasterPosition(ctx context.Context, in *tabletmanagerdata.MasterPositionRequest, opts ...grpc.CallOption) (*tabletmanagerdata.MasterPositionResponse, error)
    // StopSlave makes mysql stop its replication
    StopSlave(ctx context.Context, in *tabletmanagerdata.StopSlaveRequest, opts ...grpc.CallOption) (*tabletmanagerdata.StopSlaveResponse, error)
    // StopSlaveMinimum stops the mysql replication after it reaches
    // the provided minimum point
    StopSlaveMinimum(ctx context.Context, in *tabletmanagerdata.StopSlaveMinimumRequest, opts ...grpc.CallOption) (*tabletmanagerdata.StopSlaveMinimumResponse, error)
    // StartSlave starts the mysql replication
    StartSlave(ctx context.Context, in *tabletmanagerdata.StartSlaveRequest, opts ...grpc.CallOption) (*tabletmanagerdata.StartSlaveResponse, error)
    // StartSlave starts the mysql replication until and including
    // the provided position
    StartSlaveUntilAfter(ctx context.Context, in *tabletmanagerdata.StartSlaveUntilAfterRequest, opts ...grpc.CallOption) (*tabletmanagerdata.StartSlaveUntilAfterResponse, error)
    // TabletExternallyReparented tells a tablet that its underlying MySQL is
    // currently the master. It is only used in environments (tabletmanagerdata.such as Vitess+MoB)
    // in which MySQL is reparented by some agent external to Vitess, and then
    // that agent simply notifies Vitess.
    //
    // This call is idempotent with respect to a single target tablet.
    // However, the tablet assumes there is a cooling-off period following the
    // initial external reparent from A to B, before this call is repeated on any
    // tablet other than B. This assumption is configurable with the vttablet flag
    // "finalize_external_reparent_timeout".
    //
    // For more information, see the design doc at go/vt-fast-failover.
    TabletExternallyReparented(ctx context.Context, in *tabletmanagerdata.TabletExternallyReparentedRequest, opts ...grpc.CallOption) (*tabletmanagerdata.TabletExternallyReparentedResponse, error)
    // TabletExternallyElected is an notification that may be sent in
    // anticipation of potentially later sending TabletExternallyReparented.
    // The tablet can use this extra lead time to prepare to react quickly if
    // TabletExternallyReparented does follow.
    //
    // This call is effectively a no-op if it is not followed by a call to
    // TabletExternallyReparented, so the external agent doing the reparent can
    // still change its mind.
    //
    // The agent does not need to wait for this call or cancel it before calling
    // TabletExternallyReparented if the external reparent operation finishes
    // before TabletExternallyElected returns.
    TabletExternallyElected(ctx context.Context, in *tabletmanagerdata.TabletExternallyElectedRequest, opts ...grpc.CallOption) (*tabletmanagerdata.TabletExternallyElectedResponse, error)
    // GetSlaves asks for the list of mysql slaves
    GetSlaves(ctx context.Context, in *tabletmanagerdata.GetSlavesRequest, opts ...grpc.CallOption) (*tabletmanagerdata.GetSlavesResponse, error)
    // VReplication API
    VReplicationExec(ctx context.Context, in *tabletmanagerdata.VReplicationExecRequest, opts ...grpc.CallOption) (*tabletmanagerdata.VReplicationExecResponse, error)
    VReplicationWaitForPos(ctx context.Context, in *tabletmanagerdata.VReplicationWaitForPosRequest, opts ...grpc.CallOption) (*tabletmanagerdata.VReplicationWaitForPosResponse, error)
    // ResetReplication makes the target not replicating
    ResetReplication(ctx context.Context, in *tabletmanagerdata.ResetReplicationRequest, opts ...grpc.CallOption) (*tabletmanagerdata.ResetReplicationResponse, error)
    // InitMaster initializes the tablet as a master
    InitMaster(ctx context.Context, in *tabletmanagerdata.InitMasterRequest, opts ...grpc.CallOption) (*tabletmanagerdata.InitMasterResponse, error)
    // PopulateReparentJournal tells the tablet to add an entry to its
    // reparent journal
    PopulateReparentJournal(ctx context.Context, in *tabletmanagerdata.PopulateReparentJournalRequest, opts ...grpc.CallOption) (*tabletmanagerdata.PopulateReparentJournalResponse, error)
    // InitSlave tells the tablet to reparent to the master unconditionnally
    InitSlave(ctx context.Context, in *tabletmanagerdata.InitSlaveRequest, opts ...grpc.CallOption) (*tabletmanagerdata.InitSlaveResponse, error)
    // DemoteMaster tells the soon-to-be-former master it's gonna change
    DemoteMaster(ctx context.Context, in *tabletmanagerdata.DemoteMasterRequest, opts ...grpc.CallOption) (*tabletmanagerdata.DemoteMasterResponse, error)
    // UndoDemoteMaster reverts all changes made by DemoteMaster
    UndoDemoteMaster(ctx context.Context, in *tabletmanagerdata.UndoDemoteMasterRequest, opts ...grpc.CallOption) (*tabletmanagerdata.UndoDemoteMasterResponse, error)
    // PromoteSlaveWhenCaughtUp tells the remote tablet to catch up,
    // and then be the master
    PromoteSlaveWhenCaughtUp(ctx context.Context, in *tabletmanagerdata.PromoteSlaveWhenCaughtUpRequest, opts ...grpc.CallOption) (*tabletmanagerdata.PromoteSlaveWhenCaughtUpResponse, error)
    // SlaveWasPromoted tells the remote tablet it is now the master
    SlaveWasPromoted(ctx context.Context, in *tabletmanagerdata.SlaveWasPromotedRequest, opts ...grpc.CallOption) (*tabletmanagerdata.SlaveWasPromotedResponse, error)
    // SetMaster tells the slave to reparent
    SetMaster(ctx context.Context, in *tabletmanagerdata.SetMasterRequest, opts ...grpc.CallOption) (*tabletmanagerdata.SetMasterResponse, error)
    // SlaveWasRestarted tells the remote tablet its master has changed
    SlaveWasRestarted(ctx context.Context, in *tabletmanagerdata.SlaveWasRestartedRequest, opts ...grpc.CallOption) (*tabletmanagerdata.SlaveWasRestartedResponse, error)
    // StopReplicationAndGetStatus stops MySQL replication, and returns the
    // replication status
    StopReplicationAndGetStatus(ctx context.Context, in *tabletmanagerdata.StopReplicationAndGetStatusRequest, opts ...grpc.CallOption) (*tabletmanagerdata.StopReplicationAndGetStatusResponse, error)
    // PromoteSlave makes the slave the new master
    PromoteSlave(ctx context.Context, in *tabletmanagerdata.PromoteSlaveRequest, opts ...grpc.CallOption) (*tabletmanagerdata.PromoteSlaveResponse, error)
    Backup(ctx context.Context, in *tabletmanagerdata.BackupRequest, opts ...grpc.CallOption) (TabletManager_BackupClient, error)
    // RestoreFromBackup deletes all local data and restores it from the latest backup.
    RestoreFromBackup(ctx context.Context, in *tabletmanagerdata.RestoreFromBackupRequest, opts ...grpc.CallOption) (TabletManager_RestoreFromBackupClient, error)
}

TabletManagerClient is the client API for TabletManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTabletManagerClient Uses

func NewTabletManagerClient(cc *grpc.ClientConn) TabletManagerClient

type TabletManagerServer Uses

type TabletManagerServer interface {
    // Ping returns the input payload
    Ping(context.Context, *tabletmanagerdata.PingRequest) (*tabletmanagerdata.PingResponse, error)
    // Sleep sleeps for the provided duration
    Sleep(context.Context, *tabletmanagerdata.SleepRequest) (*tabletmanagerdata.SleepResponse, error)
    // ExecuteHook executes the hook remotely
    ExecuteHook(context.Context, *tabletmanagerdata.ExecuteHookRequest) (*tabletmanagerdata.ExecuteHookResponse, error)
    // GetSchema asks the tablet for its schema
    GetSchema(context.Context, *tabletmanagerdata.GetSchemaRequest) (*tabletmanagerdata.GetSchemaResponse, error)
    // GetPermissions asks the tablet for its permissions
    GetPermissions(context.Context, *tabletmanagerdata.GetPermissionsRequest) (*tabletmanagerdata.GetPermissionsResponse, error)
    SetReadOnly(context.Context, *tabletmanagerdata.SetReadOnlyRequest) (*tabletmanagerdata.SetReadOnlyResponse, error)
    SetReadWrite(context.Context, *tabletmanagerdata.SetReadWriteRequest) (*tabletmanagerdata.SetReadWriteResponse, error)
    // ChangeType asks the remote tablet to change its type
    ChangeType(context.Context, *tabletmanagerdata.ChangeTypeRequest) (*tabletmanagerdata.ChangeTypeResponse, error)
    RefreshState(context.Context, *tabletmanagerdata.RefreshStateRequest) (*tabletmanagerdata.RefreshStateResponse, error)
    RunHealthCheck(context.Context, *tabletmanagerdata.RunHealthCheckRequest) (*tabletmanagerdata.RunHealthCheckResponse, error)
    IgnoreHealthError(context.Context, *tabletmanagerdata.IgnoreHealthErrorRequest) (*tabletmanagerdata.IgnoreHealthErrorResponse, error)
    ReloadSchema(context.Context, *tabletmanagerdata.ReloadSchemaRequest) (*tabletmanagerdata.ReloadSchemaResponse, error)
    PreflightSchema(context.Context, *tabletmanagerdata.PreflightSchemaRequest) (*tabletmanagerdata.PreflightSchemaResponse, error)
    ApplySchema(context.Context, *tabletmanagerdata.ApplySchemaRequest) (*tabletmanagerdata.ApplySchemaResponse, error)
    LockTables(context.Context, *tabletmanagerdata.LockTablesRequest) (*tabletmanagerdata.LockTablesResponse, error)
    UnlockTables(context.Context, *tabletmanagerdata.UnlockTablesRequest) (*tabletmanagerdata.UnlockTablesResponse, error)
    ExecuteFetchAsDba(context.Context, *tabletmanagerdata.ExecuteFetchAsDbaRequest) (*tabletmanagerdata.ExecuteFetchAsDbaResponse, error)
    ExecuteFetchAsAllPrivs(context.Context, *tabletmanagerdata.ExecuteFetchAsAllPrivsRequest) (*tabletmanagerdata.ExecuteFetchAsAllPrivsResponse, error)
    ExecuteFetchAsApp(context.Context, *tabletmanagerdata.ExecuteFetchAsAppRequest) (*tabletmanagerdata.ExecuteFetchAsAppResponse, error)
    // SlaveStatus returns the current slave status.
    SlaveStatus(context.Context, *tabletmanagerdata.SlaveStatusRequest) (*tabletmanagerdata.SlaveStatusResponse, error)
    // MasterPosition returns the current master position
    MasterPosition(context.Context, *tabletmanagerdata.MasterPositionRequest) (*tabletmanagerdata.MasterPositionResponse, error)
    // StopSlave makes mysql stop its replication
    StopSlave(context.Context, *tabletmanagerdata.StopSlaveRequest) (*tabletmanagerdata.StopSlaveResponse, error)
    // StopSlaveMinimum stops the mysql replication after it reaches
    // the provided minimum point
    StopSlaveMinimum(context.Context, *tabletmanagerdata.StopSlaveMinimumRequest) (*tabletmanagerdata.StopSlaveMinimumResponse, error)
    // StartSlave starts the mysql replication
    StartSlave(context.Context, *tabletmanagerdata.StartSlaveRequest) (*tabletmanagerdata.StartSlaveResponse, error)
    // StartSlave starts the mysql replication until and including
    // the provided position
    StartSlaveUntilAfter(context.Context, *tabletmanagerdata.StartSlaveUntilAfterRequest) (*tabletmanagerdata.StartSlaveUntilAfterResponse, error)
    // TabletExternallyReparented tells a tablet that its underlying MySQL is
    // currently the master. It is only used in environments (tabletmanagerdata.such as Vitess+MoB)
    // in which MySQL is reparented by some agent external to Vitess, and then
    // that agent simply notifies Vitess.
    //
    // This call is idempotent with respect to a single target tablet.
    // However, the tablet assumes there is a cooling-off period following the
    // initial external reparent from A to B, before this call is repeated on any
    // tablet other than B. This assumption is configurable with the vttablet flag
    // "finalize_external_reparent_timeout".
    //
    // For more information, see the design doc at go/vt-fast-failover.
    TabletExternallyReparented(context.Context, *tabletmanagerdata.TabletExternallyReparentedRequest) (*tabletmanagerdata.TabletExternallyReparentedResponse, error)
    // TabletExternallyElected is an notification that may be sent in
    // anticipation of potentially later sending TabletExternallyReparented.
    // The tablet can use this extra lead time to prepare to react quickly if
    // TabletExternallyReparented does follow.
    //
    // This call is effectively a no-op if it is not followed by a call to
    // TabletExternallyReparented, so the external agent doing the reparent can
    // still change its mind.
    //
    // The agent does not need to wait for this call or cancel it before calling
    // TabletExternallyReparented if the external reparent operation finishes
    // before TabletExternallyElected returns.
    TabletExternallyElected(context.Context, *tabletmanagerdata.TabletExternallyElectedRequest) (*tabletmanagerdata.TabletExternallyElectedResponse, error)
    // GetSlaves asks for the list of mysql slaves
    GetSlaves(context.Context, *tabletmanagerdata.GetSlavesRequest) (*tabletmanagerdata.GetSlavesResponse, error)
    // VReplication API
    VReplicationExec(context.Context, *tabletmanagerdata.VReplicationExecRequest) (*tabletmanagerdata.VReplicationExecResponse, error)
    VReplicationWaitForPos(context.Context, *tabletmanagerdata.VReplicationWaitForPosRequest) (*tabletmanagerdata.VReplicationWaitForPosResponse, error)
    // ResetReplication makes the target not replicating
    ResetReplication(context.Context, *tabletmanagerdata.ResetReplicationRequest) (*tabletmanagerdata.ResetReplicationResponse, error)
    // InitMaster initializes the tablet as a master
    InitMaster(context.Context, *tabletmanagerdata.InitMasterRequest) (*tabletmanagerdata.InitMasterResponse, error)
    // PopulateReparentJournal tells the tablet to add an entry to its
    // reparent journal
    PopulateReparentJournal(context.Context, *tabletmanagerdata.PopulateReparentJournalRequest) (*tabletmanagerdata.PopulateReparentJournalResponse, error)
    // InitSlave tells the tablet to reparent to the master unconditionnally
    InitSlave(context.Context, *tabletmanagerdata.InitSlaveRequest) (*tabletmanagerdata.InitSlaveResponse, error)
    // DemoteMaster tells the soon-to-be-former master it's gonna change
    DemoteMaster(context.Context, *tabletmanagerdata.DemoteMasterRequest) (*tabletmanagerdata.DemoteMasterResponse, error)
    // UndoDemoteMaster reverts all changes made by DemoteMaster
    UndoDemoteMaster(context.Context, *tabletmanagerdata.UndoDemoteMasterRequest) (*tabletmanagerdata.UndoDemoteMasterResponse, error)
    // PromoteSlaveWhenCaughtUp tells the remote tablet to catch up,
    // and then be the master
    PromoteSlaveWhenCaughtUp(context.Context, *tabletmanagerdata.PromoteSlaveWhenCaughtUpRequest) (*tabletmanagerdata.PromoteSlaveWhenCaughtUpResponse, error)
    // SlaveWasPromoted tells the remote tablet it is now the master
    SlaveWasPromoted(context.Context, *tabletmanagerdata.SlaveWasPromotedRequest) (*tabletmanagerdata.SlaveWasPromotedResponse, error)
    // SetMaster tells the slave to reparent
    SetMaster(context.Context, *tabletmanagerdata.SetMasterRequest) (*tabletmanagerdata.SetMasterResponse, error)
    // SlaveWasRestarted tells the remote tablet its master has changed
    SlaveWasRestarted(context.Context, *tabletmanagerdata.SlaveWasRestartedRequest) (*tabletmanagerdata.SlaveWasRestartedResponse, error)
    // StopReplicationAndGetStatus stops MySQL replication, and returns the
    // replication status
    StopReplicationAndGetStatus(context.Context, *tabletmanagerdata.StopReplicationAndGetStatusRequest) (*tabletmanagerdata.StopReplicationAndGetStatusResponse, error)
    // PromoteSlave makes the slave the new master
    PromoteSlave(context.Context, *tabletmanagerdata.PromoteSlaveRequest) (*tabletmanagerdata.PromoteSlaveResponse, error)
    Backup(*tabletmanagerdata.BackupRequest, TabletManager_BackupServer) error
    // RestoreFromBackup deletes all local data and restores it from the latest backup.
    RestoreFromBackup(*tabletmanagerdata.RestoreFromBackupRequest, TabletManager_RestoreFromBackupServer) error
}

TabletManagerServer is the server API for TabletManager service.

type TabletManager_BackupClient Uses

type TabletManager_BackupClient interface {
    Recv() (*tabletmanagerdata.BackupResponse, error)
    grpc.ClientStream
}

type TabletManager_BackupServer Uses

type TabletManager_BackupServer interface {
    Send(*tabletmanagerdata.BackupResponse) error
    grpc.ServerStream
}

type TabletManager_RestoreFromBackupClient Uses

type TabletManager_RestoreFromBackupClient interface {
    Recv() (*tabletmanagerdata.RestoreFromBackupResponse, error)
    grpc.ClientStream
}

type TabletManager_RestoreFromBackupServer Uses

type TabletManager_RestoreFromBackupServer interface {
    Send(*tabletmanagerdata.RestoreFromBackupResponse) error
    grpc.ServerStream
}

Package tabletmanagerservice imports 6 packages (graph) and is imported by 2 packages. Updated 2019-07-08. Refresh now. Tools for package owners.