faketmclient

package

v0.11.1 Latest Latest Go to latest Published: Sep 9, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/vitessio/vitess

Links

Open Source Insights

Documentation ¶

Index ¶

func NewFakeTabletManagerClient() tmclient.TabletManagerClient
type FakeTabletManagerClient

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 *topodatapb.Tablet, change *tmutils.SchemaChange) (*tabletmanagerdatapb.SchemaChangeResult, error)

ApplySchema is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) Backup ¶

func (client *FakeTabletManagerClient) Backup(ctx context.Context, tablet *topodatapb.Tablet, concurrency int, allowMaster bool) (logutil.EventStream, error)

Backup is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ChangeType ¶

func (client *FakeTabletManagerClient) ChangeType(ctx context.Context, tablet *topodatapb.Tablet, dbType topodatapb.TabletType) error

ChangeType is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) Close ¶

func (client *FakeTabletManagerClient) Close()

Close is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) DemoteMaster ¶

func (client *FakeTabletManagerClient) DemoteMaster(ctx context.Context, tablet *topodatapb.Tablet) (*replicationdatapb.MasterStatus, error)

DemoteMaster is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ExecuteFetchAsAllPrivs ¶

func (client *FakeTabletManagerClient) ExecuteFetchAsAllPrivs(ctx context.Context, tablet *topodatapb.Tablet, query []byte, maxRows int, reloadSchema bool) (*querypb.QueryResult, error)

ExecuteFetchAsAllPrivs is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ExecuteFetchAsApp ¶

func (client *FakeTabletManagerClient) ExecuteFetchAsApp(ctx context.Context, tablet *topodatapb.Tablet, usePool bool, query []byte, maxRows int) (*querypb.QueryResult, error)

ExecuteFetchAsApp is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ExecuteFetchAsDba ¶

func (client *FakeTabletManagerClient) ExecuteFetchAsDba(ctx context.Context, tablet *topodatapb.Tablet, usePool bool, query []byte, 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 *topodatapb.Tablet, hk *hook.Hook) (*hook.HookResult, error)

ExecuteHook is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ExecuteQuery ¶ added in v0.11.0

func (client *FakeTabletManagerClient) ExecuteQuery(ctx context.Context, tablet *topodatapb.Tablet, query []byte, maxrows int) (*querypb.QueryResult, error)

ExecuteQuery is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) GetPermissions ¶

func (client *FakeTabletManagerClient) GetPermissions(ctx context.Context, tablet *topodatapb.Tablet) (*tabletmanagerdatapb.Permissions, error)

GetPermissions is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) GetReplicas ¶

func (client *FakeTabletManagerClient) GetReplicas(ctx context.Context, tablet *topodatapb.Tablet) ([]string, error)

GetReplicas is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) GetSchema ¶

func (client *FakeTabletManagerClient) GetSchema(ctx context.Context, tablet *topodatapb.Tablet, tables, excludeTables []string, includeViews bool) (*tabletmanagerdatapb.SchemaDefinition, error)

GetSchema is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) IgnoreHealthError ¶

func (client *FakeTabletManagerClient) IgnoreHealthError(ctx context.Context, tablet *topodatapb.Tablet, pattern string) error

IgnoreHealthError is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) InitMaster ¶

func (client *FakeTabletManagerClient) InitMaster(ctx context.Context, tablet *topodatapb.Tablet) (string, error)

InitMaster is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) InitReplica ¶

func (client *FakeTabletManagerClient) InitReplica(ctx context.Context, tablet *topodatapb.Tablet, parent *topodatapb.TabletAlias, replicationPosition string, timeCreatedNS int64) error

InitReplica is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) LockTables ¶

func (client *FakeTabletManagerClient) LockTables(ctx context.Context, tablet *topodatapb.Tablet) error

LockTables is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) MasterPosition ¶

func (client *FakeTabletManagerClient) MasterPosition(ctx context.Context, tablet *topodatapb.Tablet) (string, error)

MasterPosition is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) MasterStatus ¶

func (client *FakeTabletManagerClient) MasterStatus(ctx context.Context, tablet *topodatapb.Tablet) (*replicationdatapb.MasterStatus, error)

MasterStatus is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) Ping ¶

func (client *FakeTabletManagerClient) Ping(ctx context.Context, tablet *topodatapb.Tablet) error

Ping is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) PopulateReparentJournal ¶

func (client *FakeTabletManagerClient) PopulateReparentJournal(ctx context.Context, tablet *topodatapb.Tablet, 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 *topodatapb.Tablet, changes []string) ([]*tabletmanagerdatapb.SchemaChangeResult, error)

PreflightSchema is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) PromoteReplica ¶

func (client *FakeTabletManagerClient) PromoteReplica(ctx context.Context, tablet *topodatapb.Tablet) (string, error)

PromoteReplica is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) RefreshState ¶

func (client *FakeTabletManagerClient) RefreshState(ctx context.Context, tablet *topodatapb.Tablet) error

RefreshState is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ReloadSchema ¶

func (client *FakeTabletManagerClient) ReloadSchema(ctx context.Context, tablet *topodatapb.Tablet, waitPosition string) error

ReloadSchema is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ReplicaWasPromoted ¶

func (client *FakeTabletManagerClient) ReplicaWasPromoted(ctx context.Context, tablet *topodatapb.Tablet) error

ReplicaWasPromoted is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ReplicaWasRestarted ¶

func (client *FakeTabletManagerClient) ReplicaWasRestarted(ctx context.Context, tablet *topodatapb.Tablet, parent *topodatapb.TabletAlias) error

ReplicaWasRestarted is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ReplicationStatus ¶

func (client *FakeTabletManagerClient) ReplicationStatus(ctx context.Context, tablet *topodatapb.Tablet) (*replicationdatapb.Status, error)

ReplicationStatus is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ResetReplication ¶

func (client *FakeTabletManagerClient) ResetReplication(ctx context.Context, tablet *topodatapb.Tablet) error

ResetReplication is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) RestoreFromBackup ¶

func (client *FakeTabletManagerClient) RestoreFromBackup(ctx context.Context, tablet *topodatapb.Tablet) (logutil.EventStream, error)

RestoreFromBackup is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) RunHealthCheck ¶

func (client *FakeTabletManagerClient) RunHealthCheck(ctx context.Context, tablet *topodatapb.Tablet) error

RunHealthCheck is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) SetMaster ¶

func (client *FakeTabletManagerClient) SetMaster(ctx context.Context, tablet *topodatapb.Tablet, parent *topodatapb.TabletAlias, timeCreatedNS int64, waitPosition string, forceStartReplication bool) error

SetMaster is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) SetReadOnly ¶

func (client *FakeTabletManagerClient) SetReadOnly(ctx context.Context, tablet *topodatapb.Tablet) error

SetReadOnly is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) SetReadWrite ¶

func (client *FakeTabletManagerClient) SetReadWrite(ctx context.Context, tablet *topodatapb.Tablet) error

SetReadWrite is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) Sleep ¶

func (client *FakeTabletManagerClient) Sleep(ctx context.Context, tablet *topodatapb.Tablet, duration time.Duration) error

Sleep is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) StartReplication ¶

func (client *FakeTabletManagerClient) StartReplication(ctx context.Context, tablet *topodatapb.Tablet) error

StartReplication is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) StartReplicationUntilAfter ¶

func (client *FakeTabletManagerClient) StartReplicationUntilAfter(ctx context.Context, tablet *topodatapb.Tablet, position string, duration time.Duration) error

StartReplicationUntilAfter is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) StopReplication ¶

func (client *FakeTabletManagerClient) StopReplication(ctx context.Context, tablet *topodatapb.Tablet) error

StopReplication is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) StopReplicationAndGetStatus ¶

func (client *FakeTabletManagerClient) StopReplicationAndGetStatus(ctx context.Context, tablet *topodatapb.Tablet, stopReplicationMode replicationdatapb.StopReplicationMode) (*replicationdatapb.Status, *replicationdatapb.StopReplicationStatus, error)

StopReplicationAndGetStatus is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) StopReplicationMinimum ¶

func (client *FakeTabletManagerClient) StopReplicationMinimum(ctx context.Context, tablet *topodatapb.Tablet, stopPos string, waitTime time.Duration) (string, error)

StopReplicationMinimum is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) UndoDemoteMaster ¶

func (client *FakeTabletManagerClient) UndoDemoteMaster(ctx context.Context, tablet *topodatapb.Tablet) error

UndoDemoteMaster is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) UnlockTables ¶

func (client *FakeTabletManagerClient) UnlockTables(ctx context.Context, tablet *topodatapb.Tablet) error

UnlockTables is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) VExec ¶ added in v0.8.0

func (client *FakeTabletManagerClient) VExec(ctx context.Context, tablet *topodatapb.Tablet, query, workflow, keyspace string) (*querypb.QueryResult, error)

VExec is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) VReplicationExec ¶

func (client *FakeTabletManagerClient) VReplicationExec(ctx context.Context, tablet *topodatapb.Tablet, query string) (*querypb.QueryResult, error)

VReplicationExec is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) VReplicationWaitForPos ¶

func (client *FakeTabletManagerClient) VReplicationWaitForPos(ctx context.Context, tablet *topodatapb.Tablet, id int, pos string) error

VReplicationWaitForPos is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) WaitForPosition ¶

func (client *FakeTabletManagerClient) WaitForPosition(ctx context.Context, tablet *topodatapb.Tablet, pos string) error

WaitForPosition is part of the tmclient.TabletManagerClient interface.

Source Files ¶

View all Source files

fake_client.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL