gorpctmclient

package

v2.0.0-alpha5+incompat... Latest Latest Go to latest Published: Oct 23, 2015 License: BSD-3-Clause Imports: 15 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/talkdesk/vitess

Documentation ¶

Index ¶

type GoRPCTabletManagerClient

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type GoRPCTabletManagerClient ¶

type GoRPCTabletManagerClient struct{}

GoRPCTabletManagerClient implements tmclient.TabletManagerClient

func (*GoRPCTabletManagerClient) ApplySchema ¶

func (client *GoRPCTabletManagerClient) ApplySchema(ctx context.Context, tablet *topo.TabletInfo, change *myproto.SchemaChange) (*myproto.SchemaChangeResult, error)

ApplySchema is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) Backup ¶

func (client *GoRPCTabletManagerClient) Backup(ctx context.Context, tablet *topo.TabletInfo, concurrency int) (<-chan *logutil.LoggerEvent, tmclient.ErrFunc, error)

Backup is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) ChangeType ¶

func (client *GoRPCTabletManagerClient) ChangeType(ctx context.Context, tablet *topo.TabletInfo, dbType pb.TabletType) error

ChangeType is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) DemoteMaster ¶

func (client *GoRPCTabletManagerClient) DemoteMaster(ctx context.Context, tablet *topo.TabletInfo) (myproto.ReplicationPosition, error)

DemoteMaster is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) ExecuteFetchAsApp ¶

func (client *GoRPCTabletManagerClient) ExecuteFetchAsApp(ctx context.Context, tablet *topo.TabletInfo, query string, maxRows int, wantFields bool) (*mproto.QueryResult, error)

ExecuteFetchAsApp is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) ExecuteFetchAsDba ¶

func (client *GoRPCTabletManagerClient) ExecuteFetchAsDba(ctx context.Context, tablet *topo.TabletInfo, query string, maxRows int, wantFields, disableBinlogs, reloadSchema bool) (*mproto.QueryResult, error)

ExecuteFetchAsDba is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) ExecuteHook ¶

func (client *GoRPCTabletManagerClient) ExecuteHook(ctx context.Context, tablet *topo.TabletInfo, hk *hook.Hook) (*hook.HookResult, error)

ExecuteHook is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) GetPermissions ¶

func (client *GoRPCTabletManagerClient) GetPermissions(ctx context.Context, tablet *topo.TabletInfo) (*myproto.Permissions, error)

GetPermissions is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) GetSchema ¶

func (client *GoRPCTabletManagerClient) GetSchema(ctx context.Context, tablet *topo.TabletInfo, tables, excludeTables []string, includeViews bool) (*myproto.SchemaDefinition, error)

GetSchema is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) GetSlaves ¶

func (client *GoRPCTabletManagerClient) GetSlaves(ctx context.Context, tablet *topo.TabletInfo) ([]string, error)

GetSlaves is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) InitMaster ¶

func (client *GoRPCTabletManagerClient) InitMaster(ctx context.Context, tablet *topo.TabletInfo) (myproto.ReplicationPosition, error)

InitMaster is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) InitSlave ¶

func (client *GoRPCTabletManagerClient) InitSlave(ctx context.Context, tablet *topo.TabletInfo, parent *pb.TabletAlias, replicationPosition myproto.ReplicationPosition, timeCreatedNS int64) error

InitSlave is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) IsTimeoutError ¶

func (client *GoRPCTabletManagerClient) IsTimeoutError(err error) bool

IsTimeoutError is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) MasterPosition ¶

func (client *GoRPCTabletManagerClient) MasterPosition(ctx context.Context, tablet *topo.TabletInfo) (myproto.ReplicationPosition, error)

MasterPosition is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) Ping ¶

func (client *GoRPCTabletManagerClient) Ping(ctx context.Context, tablet *topo.TabletInfo) error

Ping is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) PopulateReparentJournal ¶

func (client *GoRPCTabletManagerClient) PopulateReparentJournal(ctx context.Context, tablet *topo.TabletInfo, timeCreatedNS int64, actionName string, masterAlias *pb.TabletAlias, pos myproto.ReplicationPosition) error

PopulateReparentJournal is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) PreflightSchema ¶

func (client *GoRPCTabletManagerClient) PreflightSchema(ctx context.Context, tablet *topo.TabletInfo, change string) (*myproto.SchemaChangeResult, error)

PreflightSchema is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) PromoteSlave ¶

func (client *GoRPCTabletManagerClient) PromoteSlave(ctx context.Context, tablet *topo.TabletInfo) (myproto.ReplicationPosition, error)

PromoteSlave is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) PromoteSlaveWhenCaughtUp ¶

func (client *GoRPCTabletManagerClient) PromoteSlaveWhenCaughtUp(ctx context.Context, tablet *topo.TabletInfo, pos myproto.ReplicationPosition) (myproto.ReplicationPosition, error)

PromoteSlaveWhenCaughtUp is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) RefreshState ¶

func (client *GoRPCTabletManagerClient) RefreshState(ctx context.Context, tablet *topo.TabletInfo) error

RefreshState is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) ReloadSchema ¶

func (client *GoRPCTabletManagerClient) ReloadSchema(ctx context.Context, tablet *topo.TabletInfo) error

ReloadSchema is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) ResetReplication ¶

func (client *GoRPCTabletManagerClient) ResetReplication(ctx context.Context, tablet *topo.TabletInfo) error

ResetReplication is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) RunBlpUntil ¶

func (client *GoRPCTabletManagerClient) RunBlpUntil(ctx context.Context, tablet *topo.TabletInfo, positions *blproto.BlpPositionList, waitTime time.Duration) (myproto.ReplicationPosition, error)

RunBlpUntil is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) RunHealthCheck ¶

func (client *GoRPCTabletManagerClient) RunHealthCheck(ctx context.Context, tablet *topo.TabletInfo, targetTabletType pb.TabletType) error

RunHealthCheck is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) SetMaster ¶

func (client *GoRPCTabletManagerClient) SetMaster(ctx context.Context, tablet *topo.TabletInfo, parent *pb.TabletAlias, timeCreatedNS int64, forceStartSlave bool) error

SetMaster is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) SetReadOnly ¶

func (client *GoRPCTabletManagerClient) SetReadOnly(ctx context.Context, tablet *topo.TabletInfo) error

SetReadOnly is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) SetReadWrite ¶

func (client *GoRPCTabletManagerClient) SetReadWrite(ctx context.Context, tablet *topo.TabletInfo) error

SetReadWrite is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) SlaveStatus ¶

func (client *GoRPCTabletManagerClient) SlaveStatus(ctx context.Context, tablet *topo.TabletInfo) (myproto.ReplicationStatus, error)

SlaveStatus is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) SlaveWasPromoted ¶

func (client *GoRPCTabletManagerClient) SlaveWasPromoted(ctx context.Context, tablet *topo.TabletInfo) error

SlaveWasPromoted is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) SlaveWasRestarted ¶

func (client *GoRPCTabletManagerClient) SlaveWasRestarted(ctx context.Context, tablet *topo.TabletInfo, args *actionnode.SlaveWasRestartedArgs) error

SlaveWasRestarted is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) Sleep ¶

func (client *GoRPCTabletManagerClient) Sleep(ctx context.Context, tablet *topo.TabletInfo, duration time.Duration) error

Sleep is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) StartBlp ¶

func (client *GoRPCTabletManagerClient) StartBlp(ctx context.Context, tablet *topo.TabletInfo) error

StartBlp is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) StartSlave ¶

func (client *GoRPCTabletManagerClient) StartSlave(ctx context.Context, tablet *topo.TabletInfo) error

StartSlave is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) StopBlp ¶

func (client *GoRPCTabletManagerClient) StopBlp(ctx context.Context, tablet *topo.TabletInfo) (*blproto.BlpPositionList, error)

StopBlp is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) StopReplicationAndGetStatus ¶

func (client *GoRPCTabletManagerClient) StopReplicationAndGetStatus(ctx context.Context, tablet *topo.TabletInfo) (myproto.ReplicationStatus, error)

StopReplicationAndGetStatus is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) StopSlave ¶

func (client *GoRPCTabletManagerClient) StopSlave(ctx context.Context, tablet *topo.TabletInfo) error

StopSlave is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) StopSlaveMinimum ¶

func (client *GoRPCTabletManagerClient) StopSlaveMinimum(ctx context.Context, tablet *topo.TabletInfo, minPos myproto.ReplicationPosition, waitTime time.Duration) (myproto.ReplicationPosition, error)

StopSlaveMinimum is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) TabletExternallyReparented ¶

func (client *GoRPCTabletManagerClient) TabletExternallyReparented(ctx context.Context, tablet *topo.TabletInfo, externalID string) error

TabletExternallyReparented is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) WaitBlpPosition ¶

func (client *GoRPCTabletManagerClient) WaitBlpPosition(ctx context.Context, tablet *topo.TabletInfo, blpPosition blproto.BlpPosition, waitTime time.Duration) error

WaitBlpPosition is part of the tmclient.TabletManagerClient interface

Source Files ¶

View all Source files

gorpc_client.go

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