faketmclient

package
v0.15.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 31, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

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

ApplySchema is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) Backup

Backup is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ChangeType

func (client *FakeTabletManagerClient) ChangeType(ctx context.Context, tablet *topodatapb.Tablet, dbType topodatapb.TabletType, semiSync bool) 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) DemotePrimary

DemotePrimary is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ExecuteFetchAsAllPrivs

ExecuteFetchAsAllPrivs is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ExecuteFetchAsApp

ExecuteFetchAsApp is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ExecuteFetchAsDba

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) ExecuteMultiFetchAsDba

FakeTabletManagerClient is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ExecuteQuery

ExecuteQuery is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) FullStatus

FullStatus is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) GetGlobalStatusVars

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

GetGlobalStatusVars is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) GetPermissions

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

GetSchema is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) InitPrimary

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

InitPrimary 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, semiSync bool) 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) 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) PrimaryPosition

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

PrimaryPosition is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) PrimaryStatus

PrimaryStatus is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) PromoteReplica

func (client *FakeTabletManagerClient) PromoteReplica(ctx context.Context, tablet *topodatapb.Tablet, semiSync bool) (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) ResetReplicationParameters

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

ResetReplicationParameters is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ResetSequences

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

func (*FakeTabletManagerClient) RestoreFromBackup

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) 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) SetReplicationSource

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

SetReplicationSource 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, semiSync bool) 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.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) UndoDemotePrimary

func (client *FakeTabletManagerClient) UndoDemotePrimary(ctx context.Context, tablet *topodatapb.Tablet, semiSync bool) error

UndoDemotePrimary 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) VDiff

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 int32, 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.

Jump to

Keyboard shortcuts

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