actor

Documentation

Overview

Package actor contains the code for all the actions executed remotely on a tablet. These actions can be executed as: - RPCs: called directly from vttablet - ActionNodes: executed from within vtaction

Index

• func CheckTabletMysqlPort(ts topo.Server, mysqlDaemon mysqlctl.MysqlDaemon, tablet *topo.TabletInfo) *topo.TabletInfo
• func SetBlacklistedTables(ts topo.Server, tabletAlias topo.TabletAlias, tables []string) error
• func SlaveWasPromoted(ts topo.Server, tabletAlias topo.TabletAlias) error
• func SlaveWasRestarted(ts topo.Server, tabletAlias topo.TabletAlias, ...) error
• func StoreActionResponse(ts topo.Server, actionNode *actionnode.ActionNode, actionPath string, ...) error
• type TabletActor
  • func NewTabletActor(mysqld *mysqlctl.Mysqld, mysqlDaemon mysqlctl.MysqlDaemon, ...) *TabletActor
  • func (ta *TabletActor) HandleAction(actionPath, action, actionGuid string, forceRerun bool) error
• type TabletActorError
  • func (e TabletActorError) Error() string

Functions

func CheckTabletMysqlPort

func CheckTabletMysqlPort(ts topo.Server, mysqlDaemon mysqlctl.MysqlDaemon, tablet *topo.TabletInfo) *topo.TabletInfo

ChecktabletMysqlPort will check the mysql port for the tablet is good, and if not will try to update it

func SetBlacklistedTables

func SetBlacklistedTables(ts topo.Server, tabletAlias topo.TabletAlias, tables []string) error

Make this external, since these transitions need to be forced from time to time.

func SlaveWasPromoted

func SlaveWasPromoted(ts topo.Server, tabletAlias topo.TabletAlias) error

func SlaveWasRestarted

func SlaveWasRestarted(ts topo.Server, tabletAlias topo.TabletAlias, swrd *actionnode.SlaveWasRestartedArgs) error

func StoreActionResponse

func StoreActionResponse(ts topo.Server, actionNode *actionnode.ActionNode, actionPath string, actionErr error) error

Write the result of an action into topology server

Types

type TabletActor

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

TabletActor is the main object for this package.

func NewTabletActor

func NewTabletActor(mysqld *mysqlctl.Mysqld, mysqlDaemon mysqlctl.MysqlDaemon, topoServer topo.Server, tabletAlias topo.TabletAlias) *TabletActor

func (*TabletActor) HandleAction

func (ta *TabletActor) HandleAction(actionPath, action, actionGuid string, forceRerun bool) error

This function should be protected from unforseen panics, as dispatchAction will catch everything. The rest of the code in this function should not panic.

type TabletActorError

type TabletActorError string

func (TabletActorError) Error

func (e TabletActorError) Error() string