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 (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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CloseAgent ¶
func CloseAgent()
func HttpHandleSnapshots ¶
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()
Source Files
Click to show internal directories.
Click to hide internal directories.