go-vitess.v1: gopkg.in/src-d/go-vitess.v1/vt/vttablet/faketmclient Index | Files

package faketmclient

import "gopkg.in/src-d/go-vitess.v1/vt/vttablet/faketmclient"

Index

Package Files

fake_client.go

func NewFakeTabletManagerClient Uses

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.

type FakeTabletManagerClient Uses

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 Uses

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 Uses

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 Uses

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 Uses

func (client *FakeTabletManagerClient) Close()

Close is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) DemoteMaster Uses

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

DemoteMaster is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ExecuteFetchAsAllPrivs Uses

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 Uses

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 Uses

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 Uses

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) GetPermissions Uses

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

GetPermissions is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) GetSchema Uses

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) GetSlaves Uses

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

GetSlaves is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) IgnoreHealthError Uses

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

IgnoreHealthError is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) InitMaster Uses

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

InitMaster is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) InitSlave Uses

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

InitSlave is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) LockTables Uses

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

LockTables is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) MasterPosition Uses

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

MasterPosition is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) Ping Uses

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

Ping is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) PopulateReparentJournal Uses

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 Uses

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) PromoteSlave Uses

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

PromoteSlave is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) PromoteSlaveWhenCaughtUp Uses

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

PromoteSlaveWhenCaughtUp is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) RefreshState Uses

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

RefreshState is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ReloadSchema Uses

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

ReloadSchema is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) ResetReplication Uses

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

ResetReplication is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) RestoreFromBackup Uses

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

RestoreFromBackup is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) RunHealthCheck Uses

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

RunHealthCheck is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) SetMaster Uses

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

SetMaster is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) SetReadOnly Uses

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

SetReadOnly is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) SetReadWrite Uses

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

SetReadWrite is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) SlaveStatus Uses

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

SlaveStatus is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) SlaveWasPromoted Uses

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

SlaveWasPromoted is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) SlaveWasRestarted Uses

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

SlaveWasRestarted is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) Sleep Uses

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

Sleep is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) StartSlave Uses

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

StartSlave is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) StartSlaveUntilAfter Uses

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

StartSlaveUntilAfter is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) StopReplicationAndGetStatus Uses

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

StopReplicationAndGetStatus is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) StopSlave Uses

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

StopSlave is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) StopSlaveMinimum Uses

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

StopSlaveMinimum is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) TabletExternallyReparented Uses

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

TabletExternallyReparented is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) UndoDemoteMaster Uses

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

UndoDemoteMaster is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) UnlockTables Uses

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

UnlockTables is part of the tmclient.TabletManagerClient interface.

func (*FakeTabletManagerClient) VReplicationExec Uses

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 Uses

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

VReplicationWaitForPos is part of the tmclient.TabletManagerClient interface.

Package faketmclient imports 13 packages (graph). Updated 2019-06-13. Refresh now. Tools for package owners.