gorpctmclient

package

v0.0.0-...-bc668d9 Latest Latest Go to latest Published: Feb 3, 2015 License: BSD-3-Clause Imports: 14 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/okmeter/vitess

Links

Open Source Insights

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) BreakSlaves ¶

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

BreakSlaves is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) ChangeType ¶

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

ChangeType is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) DemoteMaster ¶

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

DemoteMaster is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) ExecuteFetch ¶

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

ExecuteFetch 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) HealthStream ¶

func (client *GoRPCTabletManagerClient) HealthStream(ctx context.Context, tablet *topo.TabletInfo) (<-chan *actionnode.HealthStreamReply, tmclient.ErrFunc, error)

HealthStream 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) 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) (*actionnode.RestartSlaveData, error)

PromoteSlave 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) ReparentPosition ¶

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

ReparentPosition is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) ReserveForRestore ¶

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

ReserveForRestore is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) RestartSlave ¶

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

RestartSlave is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) Restore ¶

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

Restore 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 topo.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) 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) Snapshot ¶

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

Snapshot is part of the tmclient.TabletManagerClient interface

func (*GoRPCTabletManagerClient) SnapshotSourceEnd ¶

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

SnapshotSourceEnd 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) 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.ReplicationStatus, 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

func (*GoRPCTabletManagerClient) WaitSlavePosition ¶

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

WaitSlavePosition 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