gorpctmclient

package
v0.0.0-...-2166858 Latest Latest
Warning

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

 Go to latest Published: May 28, 2016 License: BSD-3-Clause Imports: 14 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 

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

func (*GoRpcTabletManagerClient) BreakSlaves 

func (client *GoRpcTabletManagerClient) BreakSlaves(ctx context.Context, tablet *topo.TabletInfo) error

func (*GoRpcTabletManagerClient) ChangeType 

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

func (*GoRpcTabletManagerClient) DemoteMaster 

func (client *GoRpcTabletManagerClient) DemoteMaster(ctx context.Context, tablet *topo.TabletInfo) error

func (*GoRpcTabletManagerClient) ExecuteFetch 

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

func (*GoRpcTabletManagerClient) ExecuteHook 

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

func (*GoRpcTabletManagerClient) GetPermissions 

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

func (*GoRpcTabletManagerClient) GetSchema 

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

func (*GoRpcTabletManagerClient) GetSlaves 

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

func (*GoRpcTabletManagerClient) MasterPosition 

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

func (*GoRpcTabletManagerClient) Ping 

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

func (*GoRpcTabletManagerClient) PreflightSchema 

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

func (*GoRpcTabletManagerClient) PromoteSlave 

func (client *GoRpcTabletManagerClient) PromoteSlave(ctx context.Context, tablet *topo.TabletInfo) (*actionnode.RestartSlaveData, error)

func (*GoRpcTabletManagerClient) RefreshState 

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

func (*GoRpcTabletManagerClient) ReloadSchema 

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

func (*GoRpcTabletManagerClient) ReparentPosition 

func (client *GoRpcTabletManagerClient) ReparentPosition(ctx context.Context, tablet *topo.TabletInfo, rp *myproto.ReplicationPosition) (*actionnode.RestartSlaveData, error)

func (*GoRpcTabletManagerClient) ReserveForRestore 

func (client *GoRpcTabletManagerClient) ReserveForRestore(ctx context.Context, tablet *topo.TabletInfo, args *actionnode.ReserveForRestoreArgs) error

func (*GoRpcTabletManagerClient) RestartSlave 

func (client *GoRpcTabletManagerClient) RestartSlave(ctx context.Context, tablet *topo.TabletInfo, rsd *actionnode.RestartSlaveData) error

func (*GoRpcTabletManagerClient) Restore 

func (client *GoRpcTabletManagerClient) Restore(ctx context.Context, tablet *topo.TabletInfo, sa *actionnode.RestoreArgs, waitTime time.Duration) (<-chan *logutil.LoggerEvent, tmclient.ErrFunc, error)

func (*GoRpcTabletManagerClient) RunBlpUntil 

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

func (*GoRpcTabletManagerClient) RunHealthCheck 

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

func (*GoRpcTabletManagerClient) Scrap 

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

func (*GoRpcTabletManagerClient) SetReadOnly 

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

func (*GoRpcTabletManagerClient) SetReadWrite 

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

func (*GoRpcTabletManagerClient) SlaveStatus 

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

func (*GoRpcTabletManagerClient) SlaveWasPromoted 

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

func (*GoRpcTabletManagerClient) SlaveWasRestarted 

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

func (*GoRpcTabletManagerClient) Sleep 

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

func (*GoRpcTabletManagerClient) Snapshot 

func (client *GoRpcTabletManagerClient) Snapshot(ctx context.Context, tablet *topo.TabletInfo, sa *actionnode.SnapshotArgs, waitTime time.Duration) (<-chan *logutil.LoggerEvent, tmclient.SnapshotReplyFunc, error)

func (*GoRpcTabletManagerClient) SnapshotSourceEnd 

func (client *GoRpcTabletManagerClient) SnapshotSourceEnd(ctx context.Context, tablet *topo.TabletInfo, args *actionnode.SnapshotSourceEndArgs) error

func (*GoRpcTabletManagerClient) StartBlp 

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

func (*GoRpcTabletManagerClient) StartSlave 

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

func (*GoRpcTabletManagerClient) StopBlp 

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

func (*GoRpcTabletManagerClient) StopSlave 

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

func (*GoRpcTabletManagerClient) StopSlaveMinimum 

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

func (*GoRpcTabletManagerClient) TabletExternallyReparented 

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

func (*GoRpcTabletManagerClient) WaitBlpPosition 

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

func (*GoRpcTabletManagerClient) WaitSlavePosition 

func (client *GoRpcTabletManagerClient) WaitSlavePosition(ctx context.Context, tablet *topo.TabletInfo, waitPos myproto.ReplicationPosition, waitTime time.Duration) (*myproto.ReplicationStatus, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.