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 

func (tm *TabletManager) GetSchema(ctx context.Context, args *gorpcproto.GetSchemaArgs, reply *myproto.SchemaDefinition) error

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 

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

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 

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

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

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.