gorpctmserver

package
v2.0.0-alpha5+incompat... Latest Latest
Warning

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

Go to latest
Published: Oct 23, 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 TabletManager

type TabletManager struct {
	// contains filtered or unexported fields
}

TabletManager is the Go RPC implementation of the RPC service

func (*TabletManager) ApplySchema

func (tm *TabletManager) ApplySchema(ctx context.Context, args *myproto.SchemaChange, reply *myproto.SchemaChangeResult) error

ApplySchema wraps RPCAgent.ApplySchema

func (*TabletManager) Backup

func (tm *TabletManager) Backup(ctx context.Context, args *gorpcproto.BackupArgs, sendReply func(interface{}) error) error

Backup wraps RPCAgent.Backup

func (*TabletManager) ChangeType

func (tm *TabletManager) ChangeType(ctx context.Context, args *pb.TabletType, reply *rpc.Unused) error

ChangeType wraps RPCAgent.ChangeType

func (*TabletManager) DemoteMaster

func (tm *TabletManager) DemoteMaster(ctx context.Context, args *rpc.Unused, reply *myproto.ReplicationPosition) error

DemoteMaster wraps RPCAgent.DemoteMaster

func (*TabletManager) ExecuteFetchAsApp

func (tm *TabletManager) ExecuteFetchAsApp(ctx context.Context, args *gorpcproto.ExecuteFetchArgs, reply *mproto.QueryResult) error

ExecuteFetchAsApp wraps RPCAgent.ExecuteFetchAsApp

func (*TabletManager) ExecuteFetchAsDba

func (tm *TabletManager) ExecuteFetchAsDba(ctx context.Context, args *gorpcproto.ExecuteFetchArgs, reply *mproto.QueryResult) error

ExecuteFetchAsDba wraps RPCAgent.ExecuteFetchAsDba

func (*TabletManager) ExecuteHook

func (tm *TabletManager) ExecuteHook(ctx context.Context, args *hook.Hook, reply *hook.HookResult) error

ExecuteHook wraps RPCAgent.ExecuteHook

func (*TabletManager) GetPermissions

func (tm *TabletManager) GetPermissions(ctx context.Context, args *rpc.Unused, reply *myproto.Permissions) error

GetPermissions wraps RPCAgent.GetPermissions

func (*TabletManager) GetSchema

GetSchema wraps RPCAgent.GetSchema

func (*TabletManager) GetSlaves

func (tm *TabletManager) GetSlaves(ctx context.Context, args *rpc.Unused, reply *gorpcproto.GetSlavesReply) error

GetSlaves wraps RPCAgent.GetSlaves

func (*TabletManager) InitMaster

func (tm *TabletManager) InitMaster(ctx context.Context, args *rpc.Unused, reply *myproto.ReplicationPosition) error

InitMaster wraps RPCAgent.InitMaster

func (*TabletManager) InitSlave

func (tm *TabletManager) InitSlave(ctx context.Context, args *gorpcproto.InitSlaveArgs, reply *rpc.Unused) error

InitSlave wraps RPCAgent.InitSlave

func (*TabletManager) MasterPosition

func (tm *TabletManager) MasterPosition(ctx context.Context, args *rpc.Unused, reply *myproto.ReplicationPosition) error

MasterPosition wraps RPCAgent.MasterPosition

func (*TabletManager) Ping

func (tm *TabletManager) Ping(ctx context.Context, args, reply *string) error

Ping wraps RPCAgent.Ping

func (*TabletManager) PopulateReparentJournal

func (tm *TabletManager) PopulateReparentJournal(ctx context.Context, args *gorpcproto.PopulateReparentJournalArgs, reply *rpc.Unused) error

PopulateReparentJournal wraps RPCAgent.PopulateReparentJournal

func (*TabletManager) PreflightSchema

func (tm *TabletManager) PreflightSchema(ctx context.Context, args *string, reply *myproto.SchemaChangeResult) error

PreflightSchema wraps RPCAgent.PreflightSchema

func (*TabletManager) PromoteSlave

func (tm *TabletManager) PromoteSlave(ctx context.Context, args *rpc.Unused, reply *myproto.ReplicationPosition) error

PromoteSlave wraps RPCAgent.PromoteSlave

func (*TabletManager) PromoteSlaveWhenCaughtUp

func (tm *TabletManager) PromoteSlaveWhenCaughtUp(ctx context.Context, args *myproto.ReplicationPosition, reply *myproto.ReplicationPosition) error

PromoteSlaveWhenCaughtUp wraps RPCAgent.PromoteSlaveWhenCaughtUp

func (*TabletManager) RefreshState

func (tm *TabletManager) RefreshState(ctx context.Context, args *rpc.Unused, reply *rpc.Unused) error

RefreshState wraps RPCAgent.RefreshState

func (*TabletManager) ReloadSchema

func (tm *TabletManager) ReloadSchema(ctx context.Context, args *rpc.Unused, reply *rpc.Unused) error

ReloadSchema wraps RPCAgent.ReloadSchema

func (*TabletManager) ResetReplication

func (tm *TabletManager) ResetReplication(ctx context.Context, args *rpc.Unused, reply *rpc.Unused) error

ResetReplication wraps RPCAgent.ResetReplication

func (*TabletManager) RunBlpUntil

RunBlpUntil wraps RPCAgent.RunBlpUntil

func (*TabletManager) RunHealthCheck

func (tm *TabletManager) RunHealthCheck(ctx context.Context, args *pb.TabletType, reply *rpc.Unused) error

RunHealthCheck wraps RPCAgent.RunHealthCheck

func (*TabletManager) SetMaster

func (tm *TabletManager) SetMaster(ctx context.Context, args *gorpcproto.SetMasterArgs, reply *rpc.Unused) error

SetMaster wraps RPCAgent.SetMaster

func (*TabletManager) SetReadOnly

func (tm *TabletManager) SetReadOnly(ctx context.Context, args *rpc.Unused, reply *rpc.Unused) error

SetReadOnly wraps RPCAgent.SetReadOnly(true)

func (*TabletManager) SetReadWrite

func (tm *TabletManager) SetReadWrite(ctx context.Context, args *rpc.Unused, reply *rpc.Unused) error

SetReadWrite wraps RPCAgent.SetReadOnly(false)

func (*TabletManager) SlaveStatus

func (tm *TabletManager) SlaveStatus(ctx context.Context, args *rpc.Unused, reply *myproto.ReplicationStatus) error

SlaveStatus wraps RPCAgent.SlaveStatus

func (*TabletManager) SlaveWasPromoted

func (tm *TabletManager) SlaveWasPromoted(ctx context.Context, args *rpc.Unused, reply *rpc.Unused) error

SlaveWasPromoted wraps RPCAgent.SlaveWasPromoted

func (*TabletManager) SlaveWasRestarted

func (tm *TabletManager) SlaveWasRestarted(ctx context.Context, args *actionnode.SlaveWasRestartedArgs, reply *rpc.Unused) error

SlaveWasRestarted wraps RPCAgent.SlaveWasRestarted

func (*TabletManager) Sleep

func (tm *TabletManager) Sleep(ctx context.Context, args *time.Duration, reply *rpc.Unused) error

Sleep wraps RPCAgent.Sleep

func (*TabletManager) StartBlp

func (tm *TabletManager) StartBlp(ctx context.Context, args *rpc.Unused, reply *rpc.Unused) error

StartBlp wraps RPCAgent.StartBlp

func (*TabletManager) StartSlave

func (tm *TabletManager) StartSlave(ctx context.Context, args *rpc.Unused, reply *rpc.Unused) error

StartSlave wraps RPCAgent.StartSlave

func (*TabletManager) StopBlp

func (tm *TabletManager) StopBlp(ctx context.Context, args *rpc.Unused, reply *blproto.BlpPositionList) error

StopBlp wraps RPCAgent.StopBlp

func (*TabletManager) StopReplicationAndGetStatus

func (tm *TabletManager) StopReplicationAndGetStatus(ctx context.Context, args *rpc.Unused, reply *myproto.ReplicationStatus) error

StopReplicationAndGetStatus wraps RPCAgent.StopReplicationAndGetStatus

func (*TabletManager) StopSlave

func (tm *TabletManager) StopSlave(ctx context.Context, args *rpc.Unused, reply *rpc.Unused) error

StopSlave wraps RPCAgent.StopSlave

func (*TabletManager) StopSlaveMinimum

StopSlaveMinimum wraps RPCAgent.StopSlaveMinimum

func (*TabletManager) TabletExternallyReparented

func (tm *TabletManager) TabletExternallyReparented(ctx context.Context, args *gorpcproto.TabletExternallyReparentedArgs, reply *rpc.Unused) error

TabletExternallyReparented wraps RPCAgent.TabletExternallyReparented

func (*TabletManager) WaitBlpPosition

func (tm *TabletManager) WaitBlpPosition(ctx context.Context, args *gorpcproto.WaitBlpPositionArgs, reply *rpc.Unused) error

WaitBlpPosition wraps RPCAgent.WaitBlpPosition

Jump to

Keyboard shortcuts

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