vttablet

Documentation

Overview

Package vttablet contains the meat of the vttablet binary.

Index

• func CloseAgent()
• func HttpHandleSnapshots(mycnf *mysqlctl.Mycnf, uid uint32)
• func InitAgent(tabletAlias topo.TabletAlias, dbcfgs dbconfigs.DBConfigs, ...) (err error)
• func RegisterBinlogPlayerMap(blm *BinlogPlayerMap)
• func TabletParamToTabletAlias(param string) topo.TabletAlias
• type BinlogPlayerController
  • func NewBinlogPlayerController(ts topo.Server, dbConfig *mysql.ConnectionParams, mysqld *mysqlctl.Mysqld, ...) *BinlogPlayerController
  • func (bpc *BinlogPlayerController) DisableSuperToSetTimestamp()
  • func (bpc *BinlogPlayerController) Iteration() (err error)
  • func (bpc *BinlogPlayerController) Loop()
  • func (bpc *BinlogPlayerController) Start()
  • func (bpc *BinlogPlayerController) Stop()
  • func (bpc *BinlogPlayerController) String() string
• type BinlogPlayerMap
  • func NewBinlogPlayerMap(ts topo.Server, dbConfig mysql.ConnectionParams, mysqld *mysqlctl.Mysqld) *BinlogPlayerMap
  • func (blm *BinlogPlayerMap) EnableSuperToSetTimestamp()
  • func (blm *BinlogPlayerMap) RefreshMap(tablet topo.Tablet)
  • func (blm *BinlogPlayerMap) StopAllPlayers()

Functions

func CloseAgent

func CloseAgent()

func HttpHandleSnapshots

func HttpHandleSnapshots(mycnf *mysqlctl.Mycnf, uid uint32)

HttpHandleSnapshots handles the serving of files from the local tablet

func InitAgent

func InitAgent(
	tabletAlias topo.TabletAlias,
	dbcfgs dbconfigs.DBConfigs,
	mycnf *mysqlctl.Mycnf,
	dbConfigsFile, dbCredentialsFile string,
	port, securePort int,
	mycnfFile, overridesFile string) (err error)

InitAgent initializes the agent within vttablet.

func RegisterBinlogPlayerMap

func RegisterBinlogPlayerMap(blm *BinlogPlayerMap)

func TabletParamToTabletAlias

func TabletParamToTabletAlias(param string) topo.TabletAlias

TabletParamToTabletAlias takes either an old style ZK tablet path or a new style tablet alias as a string, and returns a TabletAlias.

Types

type BinlogPlayerController

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

BinlogPlayerController controls one player

func NewBinlogPlayerController

func NewBinlogPlayerController(ts topo.Server, dbConfig *mysql.ConnectionParams, mysqld *mysqlctl.Mysqld, cell string, keyRange key.KeyRange, sourceShard topo.SourceShard) *BinlogPlayerController

func (*BinlogPlayerController) DisableSuperToSetTimestamp

func (bpc *BinlogPlayerController) DisableSuperToSetTimestamp()

func (*BinlogPlayerController) Iteration

func (bpc *BinlogPlayerController) Iteration() (err error)

func (*BinlogPlayerController) Loop

func (bpc *BinlogPlayerController) Loop()

func (*BinlogPlayerController) Start

func (bpc *BinlogPlayerController) Start()

func (*BinlogPlayerController) Stop

func (bpc *BinlogPlayerController) Stop()

func (*BinlogPlayerController) String

func (bpc *BinlogPlayerController) String() string

type BinlogPlayerMap

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

BinlogPlayerMap controls all the players

func NewBinlogPlayerMap

func NewBinlogPlayerMap(ts topo.Server, dbConfig mysql.ConnectionParams, mysqld *mysqlctl.Mysqld) *BinlogPlayerMap

func (*BinlogPlayerMap) EnableSuperToSetTimestamp

func (blm *BinlogPlayerMap) EnableSuperToSetTimestamp()

After this is called, the clients will need super privileges to set timestamp

func (*BinlogPlayerMap) RefreshMap

func (blm *BinlogPlayerMap) RefreshMap(tablet topo.Tablet)

RefreshMap reads the right data from topo.Server and makes sure we're playing the right logs

func (*BinlogPlayerMap) StopAllPlayers

func (blm *BinlogPlayerMap) StopAllPlayers()