primecache

Documentation

Overview

primecache primes the MySQL buffer cache with the rows that are going to be modified by the replication stream. It only activates if we're falling behind on replication.

Index

• type PrimeCache
  • func NewPrimeCache(dbcfgs *dbconfigs.DBConfigs, relayLogsPath string) *PrimeCache
  • func (pc *PrimeCache) Cleanup()
  • func (pc *PrimeCache) Loop()
  • func (pc *PrimeCache) OneRun()

Types

type PrimeCache

type PrimeCache struct {

	// parameters with default values that can be changed by client
	WorkerCount   int
	SleepDuration time.Duration
	// contains filtered or unexported fields
}

PrimeCache is the main object for this module: it handles a player that will run in a loop to prime the MySQL cache.

func NewPrimeCache

func NewPrimeCache(dbcfgs *dbconfigs.DBConfigs, relayLogsPath string) *PrimeCache

NewPrimeCache creates a PrimeCache object with default parameters. The user can modify the public values before running the loop.

func (*PrimeCache) Cleanup

func (pc *PrimeCache) Cleanup()

Cleanup will release all resources help by this object. Closing pc.workerChannel will end up finishing the consumer tasks.

func (*PrimeCache) Loop

func (pc *PrimeCache) Loop()

Loop runs the primecache loop and never returns.

func (*PrimeCache) OneRun

func (pc *PrimeCache) OneRun()

OneRun tries a single cycle connecting to MySQL, and if behind on replication, starts playing the logs ahead to prime the cache.