player

Documentation

Index

• type Player
  • func NewPlayer(ctx context.Context, configPath string, ...) (*Player, error)
  • func NewPlayerWithPoolAndBackend(ctx context.Context, pool tlog.RedisPool, backend nbd.Backend, ...) (*Player, error)
  • func (p *Player) Replay(startTs, endTs uint64) error
  • func (p *Player) ReplayAggregation(agg *schema.TlogAggregation, startTs, endTs uint64) error

Types

type Player

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

Player defines a tlog replay player. It could be used to restore the data based on transactions sent to tlog server

func NewPlayer

func NewPlayer(ctx context.Context, configPath string, serverConfigs []zerodiskcfg.StorageServerConfig,
	vdiskID, privKey, hexNonce string, k, m int) (*Player, error)

NewPlayer creates new tlog player

func NewPlayerWithPoolAndBackend

func NewPlayerWithPoolAndBackend(ctx context.Context, pool tlog.RedisPool, backend nbd.Backend,
	vdiskID, privKey, hexNonce string, k, m int) (*Player, error)

NewPlayerWithPoolAndBackend create new tlog player with given redis pool and nbd backend

func (*Player) Replay

func (p *Player) Replay(startTs, endTs uint64) error

Replay replays the tlog by decoding data from a tlog RedisPool. The replay start from `startTs` timestamp.

func (*Player) ReplayAggregation

func (p *Player) ReplayAggregation(agg *schema.TlogAggregation, startTs, endTs uint64) error

ReplayAggregation replays an aggregation