gorpctmclient

package
v0.0.0-...-5f7613f Latest Latest
Warning

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

Go to latest
Published: Aug 28, 2015 License: BSD-3-Clause Imports: 15 Imported by: 0

Documentation

Index

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

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

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

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

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

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

Scrap 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

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

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

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

Jump to

Keyboard shortcuts

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