gorpctmserver

Documentation

Index

• type TabletManager
  • func (tm *TabletManager) ChangeType(context *rpcproto.Context, args *topo.TabletType, reply *rpc.UnusedResponse) error
  • func (tm *TabletManager) ExecuteFetch(context *rpcproto.Context, args *gorpcproto.ExecuteFetchArgs, ...) error
  • func (tm *TabletManager) GetPermissions(context *rpcproto.Context, args *rpc.UnusedRequest, reply *myproto.Permissions) error
  • func (tm *TabletManager) GetSchema(context *rpcproto.Context, args *gorpcproto.GetSchemaArgs, ...) error
  • func (tm *TabletManager) GetSlaves(context *rpcproto.Context, args *rpc.UnusedRequest, ...) error
  • func (tm *TabletManager) MasterPosition(context *rpcproto.Context, args *rpc.UnusedRequest, ...) error
  • func (tm *TabletManager) Ping(context *rpcproto.Context, args, reply *string) error
  • func (tm *TabletManager) ReloadSchema(context *rpcproto.Context, args *rpc.UnusedRequest, reply *rpc.UnusedResponse) error
  • func (tm *TabletManager) RunBlpUntil(context *rpcproto.Context, args *gorpcproto.RunBlpUntilArgs, ...) error
  • func (tm *TabletManager) SetBlacklistedTables(context *rpcproto.Context, args *gorpcproto.SetBlacklistedTablesArgs, ...) error
  • func (tm *TabletManager) SlavePosition(context *rpcproto.Context, args *rpc.UnusedRequest, ...) error
  • func (tm *TabletManager) SlaveWasPromoted(context *rpcproto.Context, args *rpc.UnusedRequest, reply *rpc.UnusedResponse) error
  • func (tm *TabletManager) SlaveWasRestarted(context *rpcproto.Context, args *actionnode.SlaveWasRestartedArgs, ...) error
  • func (tm *TabletManager) StartBlp(context *rpcproto.Context, args *rpc.UnusedRequest, reply *rpc.UnusedResponse) error
  • func (tm *TabletManager) StartSlave(context *rpcproto.Context, args *rpc.UnusedRequest, reply *rpc.UnusedResponse) error
  • func (tm *TabletManager) StopBlp(context *rpcproto.Context, args *rpc.UnusedRequest, ...) error
  • func (tm *TabletManager) StopSlave(context *rpcproto.Context, args *rpc.UnusedRequest, reply *rpc.UnusedResponse) error
  • func (tm *TabletManager) StopSlaveMinimum(context *rpcproto.Context, args *gorpcproto.StopSlaveMinimumArgs, ...) error
  • func (tm *TabletManager) WaitBlpPosition(context *rpcproto.Context, args *gorpcproto.WaitBlpPositionArgs, ...) error
  • func (tm *TabletManager) WaitSlavePosition(context *rpcproto.Context, args *gorpcproto.WaitSlavePositionArgs, ...) error

Types

type TabletManager

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

TabletManager is the Go RPC implementation of the RPC service

func (*TabletManager) ChangeType

func (tm *TabletManager) ChangeType(context *rpcproto.Context, args *topo.TabletType, reply *rpc.UnusedResponse) error

func (*TabletManager) ExecuteFetch

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

func (*TabletManager) GetPermissions

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

func (*TabletManager) GetSchema

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

func (*TabletManager) GetSlaves

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

func (*TabletManager) MasterPosition

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

func (*TabletManager) Ping

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

func (*TabletManager) ReloadSchema

func (tm *TabletManager) ReloadSchema(context *rpcproto.Context, args *rpc.UnusedRequest, reply *rpc.UnusedResponse) error

func (*TabletManager) RunBlpUntil

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

func (*TabletManager) SetBlacklistedTables

func (tm *TabletManager) SetBlacklistedTables(context *rpcproto.Context, args *gorpcproto.SetBlacklistedTablesArgs, reply *rpc.UnusedResponse) error

func (*TabletManager) SlavePosition

func (tm *TabletManager) SlavePosition(context *rpcproto.Context, args *rpc.UnusedRequest, reply *myproto.ReplicationPosition) error

func (*TabletManager) SlaveWasPromoted

func (tm *TabletManager) SlaveWasPromoted(context *rpcproto.Context, args *rpc.UnusedRequest, reply *rpc.UnusedResponse) error

func (*TabletManager) SlaveWasRestarted

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

func (*TabletManager) StartBlp

func (tm *TabletManager) StartBlp(context *rpcproto.Context, args *rpc.UnusedRequest, reply *rpc.UnusedResponse) error

func (*TabletManager) StartSlave

func (tm *TabletManager) StartSlave(context *rpcproto.Context, args *rpc.UnusedRequest, reply *rpc.UnusedResponse) error

func (*TabletManager) StopBlp

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

func (*TabletManager) StopSlave

func (tm *TabletManager) StopSlave(context *rpcproto.Context, args *rpc.UnusedRequest, reply *rpc.UnusedResponse) error

func (*TabletManager) StopSlaveMinimum

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

func (*TabletManager) WaitBlpPosition

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

func (*TabletManager) WaitSlavePosition

func (tm *TabletManager) WaitSlavePosition(context *rpcproto.Context, args *gorpcproto.WaitSlavePositionArgs, reply *myproto.ReplicationPosition) error