faketmclient

package

v2.0.0-beta.1+incompat... Latest Latest Go to latest Published: Mar 3, 2016 License: BSD-3-Clause Imports: 12 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/gitql/vitess

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 *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) (<-chan *logutilpb.Event, tmclient.ErrFunc, 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) 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

Source Files ¶

View all Source files

fake_client.go

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