Documentation ¶
Index ¶
- func NewFakeTabletManagerClient() tmclient.TabletManagerClient
- type FakeTabletManagerClient
- func (client *FakeTabletManagerClient) ApplySchema(ctx context.Context, tablet *topo.TabletInfo, change *tmutils.SchemaChange) (*tmutils.SchemaChangeResult, error)
- func (client *FakeTabletManagerClient) Backup(ctx context.Context, tablet *topo.TabletInfo, concurrency int) (logutil.EventStream, error)
- func (client *FakeTabletManagerClient) ChangeType(ctx context.Context, tablet *topo.TabletInfo, dbType topodatapb.TabletType) error
- func (client *FakeTabletManagerClient) DemoteMaster(ctx context.Context, tablet *topo.TabletInfo) (string, error)
- func (client *FakeTabletManagerClient) ExecuteFetchAsApp(ctx context.Context, tablet *topo.TabletInfo, query string, maxRows int) (*querypb.QueryResult, error)
- func (client *FakeTabletManagerClient) ExecuteFetchAsDba(ctx context.Context, tablet *topo.TabletInfo, query string, maxRows int, ...) (*querypb.QueryResult, error)
- func (client *FakeTabletManagerClient) ExecuteHook(ctx context.Context, tablet *topo.TabletInfo, hk *hook.Hook) (*hook.HookResult, error)
- func (client *FakeTabletManagerClient) GetPermissions(ctx context.Context, tablet *topo.TabletInfo) (*tabletmanagerdatapb.Permissions, error)
- func (client *FakeTabletManagerClient) GetSchema(ctx context.Context, tablet *topo.TabletInfo, tables, excludeTables []string, ...) (*tabletmanagerdatapb.SchemaDefinition, error)
- func (client *FakeTabletManagerClient) GetSlaves(ctx context.Context, tablet *topo.TabletInfo) ([]string, error)
- func (client *FakeTabletManagerClient) IgnoreHealthError(ctx context.Context, tablet *topo.TabletInfo, pattern string) error
- func (client *FakeTabletManagerClient) InitMaster(ctx context.Context, tablet *topo.TabletInfo) (string, error)
- func (client *FakeTabletManagerClient) InitSlave(ctx context.Context, tablet *topo.TabletInfo, parent *topodatapb.TabletAlias, ...) error
- func (client *FakeTabletManagerClient) IsTimeoutError(err error) bool
- func (client *FakeTabletManagerClient) MasterPosition(ctx context.Context, tablet *topo.TabletInfo) (string, error)
- func (client *FakeTabletManagerClient) Ping(ctx context.Context, tablet *topo.TabletInfo) error
- func (client *FakeTabletManagerClient) PopulateReparentJournal(ctx context.Context, tablet *topo.TabletInfo, timeCreatedNS int64, ...) error
- func (client *FakeTabletManagerClient) PreflightSchema(ctx context.Context, tablet *topo.TabletInfo, change string) (*tmutils.SchemaChangeResult, error)
- func (client *FakeTabletManagerClient) PromoteSlave(ctx context.Context, tablet *topo.TabletInfo) (string, error)
- func (client *FakeTabletManagerClient) PromoteSlaveWhenCaughtUp(ctx context.Context, tablet *topo.TabletInfo, position string) (string, error)
- func (client *FakeTabletManagerClient) RefreshState(ctx context.Context, tablet *topo.TabletInfo) error
- func (client *FakeTabletManagerClient) ReloadSchema(ctx context.Context, tablet *topo.TabletInfo) error
- func (client *FakeTabletManagerClient) ResetReplication(ctx context.Context, tablet *topo.TabletInfo) error
- func (client *FakeTabletManagerClient) RunBlpUntil(ctx context.Context, tablet *topo.TabletInfo, ...) (string, error)
- func (client *FakeTabletManagerClient) RunHealthCheck(ctx context.Context, tablet *topo.TabletInfo, ...) error
- func (client *FakeTabletManagerClient) SetMaster(ctx context.Context, tablet *topo.TabletInfo, parent *topodatapb.TabletAlias, ...) error
- func (client *FakeTabletManagerClient) SetReadOnly(ctx context.Context, tablet *topo.TabletInfo) error
- func (client *FakeTabletManagerClient) SetReadWrite(ctx context.Context, tablet *topo.TabletInfo) error
- func (client *FakeTabletManagerClient) SlaveStatus(ctx context.Context, tablet *topo.TabletInfo) (*replicationdatapb.Status, error)
- func (client *FakeTabletManagerClient) SlaveWasPromoted(ctx context.Context, tablet *topo.TabletInfo) error
- func (client *FakeTabletManagerClient) SlaveWasRestarted(ctx context.Context, tablet *topo.TabletInfo, ...) error
- func (client *FakeTabletManagerClient) Sleep(ctx context.Context, tablet *topo.TabletInfo, duration time.Duration) error
- func (client *FakeTabletManagerClient) StartBlp(ctx context.Context, tablet *topo.TabletInfo) error
- func (client *FakeTabletManagerClient) StartSlave(ctx context.Context, tablet *topo.TabletInfo) error
- func (client *FakeTabletManagerClient) StopBlp(ctx context.Context, tablet *topo.TabletInfo) ([]*tabletmanagerdatapb.BlpPosition, error)
- func (client *FakeTabletManagerClient) StopReplicationAndGetStatus(ctx context.Context, tablet *topo.TabletInfo) (*replicationdatapb.Status, error)
- func (client *FakeTabletManagerClient) StopSlave(ctx context.Context, tablet *topo.TabletInfo) error
- func (client *FakeTabletManagerClient) StopSlaveMinimum(ctx context.Context, tablet *topo.TabletInfo, minPos string, ...) (string, error)
- func (client *FakeTabletManagerClient) TabletExternallyReparented(ctx context.Context, tablet *topo.TabletInfo, externalID string) error
- func (client *FakeTabletManagerClient) WaitBlpPosition(ctx context.Context, tablet *topo.TabletInfo, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFakeTabletManagerClient ¶
func NewFakeTabletManagerClient() tmclient.TabletManagerClient
NewFakeTabletManagerClient should be used to create a new FakeTabletManagerClient. There is intentionally no init in this file with a call to RegisterTabletManagerClientFactory. There shouldn't be any legitimate use-case where we would want to start a vitess cluster with a FakeTMC, and we don't want to do it by accident.
Types ¶
type FakeTabletManagerClient ¶
type FakeTabletManagerClient struct {
// contains filtered or unexported fields
}
FakeTabletManagerClient implements tmclient.TabletManagerClient TODO(aaijazi): this is a pretty complicated and inconsistent implementation. It can't make up its mind on whether it wants to be a fake, a mock, or act like the real thing. We probably want to move it more consistently towards being a mock, once we standardize how we want to do mocks in vitess. We don't currently have a good way to configure specific return values.
func (*FakeTabletManagerClient) ApplySchema ¶
func (client *FakeTabletManagerClient) ApplySchema(ctx context.Context, tablet *topo.TabletInfo, change *tmutils.SchemaChange) (*tmutils.SchemaChangeResult, error)
ApplySchema is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) Backup ¶
func (client *FakeTabletManagerClient) Backup(ctx context.Context, tablet *topo.TabletInfo, concurrency int) (logutil.EventStream, error)
Backup is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) ChangeType ¶
func (client *FakeTabletManagerClient) ChangeType(ctx context.Context, tablet *topo.TabletInfo, dbType topodatapb.TabletType) error
ChangeType is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) DemoteMaster ¶
func (client *FakeTabletManagerClient) DemoteMaster(ctx context.Context, tablet *topo.TabletInfo) (string, error)
DemoteMaster is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) ExecuteFetchAsApp ¶
func (client *FakeTabletManagerClient) ExecuteFetchAsApp(ctx context.Context, tablet *topo.TabletInfo, query string, maxRows int) (*querypb.QueryResult, error)
ExecuteFetchAsApp is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) ExecuteFetchAsDba ¶
func (client *FakeTabletManagerClient) ExecuteFetchAsDba(ctx context.Context, tablet *topo.TabletInfo, query string, maxRows int, disableBinlogs, reloadSchema bool) (*querypb.QueryResult, error)
ExecuteFetchAsDba is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) ExecuteHook ¶
func (client *FakeTabletManagerClient) ExecuteHook(ctx context.Context, tablet *topo.TabletInfo, hk *hook.Hook) (*hook.HookResult, error)
ExecuteHook is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) GetPermissions ¶
func (client *FakeTabletManagerClient) GetPermissions(ctx context.Context, tablet *topo.TabletInfo) (*tabletmanagerdatapb.Permissions, error)
GetPermissions is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) GetSchema ¶
func (client *FakeTabletManagerClient) GetSchema(ctx context.Context, tablet *topo.TabletInfo, tables, excludeTables []string, includeViews bool) (*tabletmanagerdatapb.SchemaDefinition, error)
GetSchema is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) GetSlaves ¶
func (client *FakeTabletManagerClient) GetSlaves(ctx context.Context, tablet *topo.TabletInfo) ([]string, error)
GetSlaves is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) IgnoreHealthError ¶
func (client *FakeTabletManagerClient) IgnoreHealthError(ctx context.Context, tablet *topo.TabletInfo, pattern string) error
IgnoreHealthError is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) InitMaster ¶
func (client *FakeTabletManagerClient) InitMaster(ctx context.Context, tablet *topo.TabletInfo) (string, error)
InitMaster is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) InitSlave ¶
func (client *FakeTabletManagerClient) InitSlave(ctx context.Context, tablet *topo.TabletInfo, parent *topodatapb.TabletAlias, position string, timeCreatedNS int64) error
InitSlave is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) IsTimeoutError ¶
func (client *FakeTabletManagerClient) IsTimeoutError(err error) bool
IsTimeoutError is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) MasterPosition ¶
func (client *FakeTabletManagerClient) MasterPosition(ctx context.Context, tablet *topo.TabletInfo) (string, error)
MasterPosition is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) Ping ¶
func (client *FakeTabletManagerClient) Ping(ctx context.Context, tablet *topo.TabletInfo) error
Ping is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) PopulateReparentJournal ¶
func (client *FakeTabletManagerClient) PopulateReparentJournal(ctx context.Context, tablet *topo.TabletInfo, timeCreatedNS int64, actionName string, masterAlias *topodatapb.TabletAlias, position string) error
PopulateReparentJournal is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) PreflightSchema ¶
func (client *FakeTabletManagerClient) PreflightSchema(ctx context.Context, tablet *topo.TabletInfo, change string) (*tmutils.SchemaChangeResult, error)
PreflightSchema is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) PromoteSlave ¶
func (client *FakeTabletManagerClient) PromoteSlave(ctx context.Context, tablet *topo.TabletInfo) (string, error)
PromoteSlave is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) PromoteSlaveWhenCaughtUp ¶
func (client *FakeTabletManagerClient) PromoteSlaveWhenCaughtUp(ctx context.Context, tablet *topo.TabletInfo, position string) (string, error)
PromoteSlaveWhenCaughtUp is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) RefreshState ¶
func (client *FakeTabletManagerClient) RefreshState(ctx context.Context, tablet *topo.TabletInfo) error
RefreshState is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) ReloadSchema ¶
func (client *FakeTabletManagerClient) ReloadSchema(ctx context.Context, tablet *topo.TabletInfo) error
ReloadSchema is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) ResetReplication ¶
func (client *FakeTabletManagerClient) ResetReplication(ctx context.Context, tablet *topo.TabletInfo) error
ResetReplication is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) RunBlpUntil ¶
func (client *FakeTabletManagerClient) RunBlpUntil(ctx context.Context, tablet *topo.TabletInfo, positions []*tabletmanagerdatapb.BlpPosition, waitTime time.Duration) (string, error)
RunBlpUntil is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) RunHealthCheck ¶
func (client *FakeTabletManagerClient) RunHealthCheck(ctx context.Context, tablet *topo.TabletInfo, targetTabletType topodatapb.TabletType) error
RunHealthCheck is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) SetMaster ¶
func (client *FakeTabletManagerClient) SetMaster(ctx context.Context, tablet *topo.TabletInfo, parent *topodatapb.TabletAlias, timeCreatedNS int64, forceStartSlave bool) error
SetMaster is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) SetReadOnly ¶
func (client *FakeTabletManagerClient) SetReadOnly(ctx context.Context, tablet *topo.TabletInfo) error
SetReadOnly is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) SetReadWrite ¶
func (client *FakeTabletManagerClient) SetReadWrite(ctx context.Context, tablet *topo.TabletInfo) error
SetReadWrite is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) SlaveStatus ¶
func (client *FakeTabletManagerClient) SlaveStatus(ctx context.Context, tablet *topo.TabletInfo) (*replicationdatapb.Status, error)
SlaveStatus is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) SlaveWasPromoted ¶
func (client *FakeTabletManagerClient) SlaveWasPromoted(ctx context.Context, tablet *topo.TabletInfo) error
SlaveWasPromoted is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) SlaveWasRestarted ¶
func (client *FakeTabletManagerClient) SlaveWasRestarted(ctx context.Context, tablet *topo.TabletInfo, args *actionnode.SlaveWasRestartedArgs) error
SlaveWasRestarted is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) Sleep ¶
func (client *FakeTabletManagerClient) Sleep(ctx context.Context, tablet *topo.TabletInfo, duration time.Duration) error
Sleep is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) StartBlp ¶
func (client *FakeTabletManagerClient) StartBlp(ctx context.Context, tablet *topo.TabletInfo) error
StartBlp is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) StartSlave ¶
func (client *FakeTabletManagerClient) StartSlave(ctx context.Context, tablet *topo.TabletInfo) error
StartSlave is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) StopBlp ¶
func (client *FakeTabletManagerClient) StopBlp(ctx context.Context, tablet *topo.TabletInfo) ([]*tabletmanagerdatapb.BlpPosition, error)
StopBlp is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) StopReplicationAndGetStatus ¶
func (client *FakeTabletManagerClient) StopReplicationAndGetStatus(ctx context.Context, tablet *topo.TabletInfo) (*replicationdatapb.Status, error)
StopReplicationAndGetStatus is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) StopSlave ¶
func (client *FakeTabletManagerClient) StopSlave(ctx context.Context, tablet *topo.TabletInfo) error
StopSlave is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) StopSlaveMinimum ¶
func (client *FakeTabletManagerClient) StopSlaveMinimum(ctx context.Context, tablet *topo.TabletInfo, minPos string, waitTime time.Duration) (string, error)
StopSlaveMinimum is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) TabletExternallyReparented ¶
func (client *FakeTabletManagerClient) TabletExternallyReparented(ctx context.Context, tablet *topo.TabletInfo, externalID string) error
TabletExternallyReparented is part of the tmclient.TabletManagerClient interface.
func (*FakeTabletManagerClient) WaitBlpPosition ¶
func (client *FakeTabletManagerClient) WaitBlpPosition(ctx context.Context, tablet *topo.TabletInfo, blpPosition *tabletmanagerdatapb.BlpPosition, waitTime time.Duration) error
WaitBlpPosition is part of the tmclient.TabletManagerClient interface.