aof

package

v1.2.8 Latest Latest Go to latest Published: May 23, 2022 License: GPL-3.0 Imports: 19 Imported by: 0

Details

This section is empty.

This section is empty.

func EntityToCmd(key string, entity *database.DataEntity) *protocol.MultiBulkReply

EntityToCmd serialize data entity to redis command

func MakeExpireCmd(key string, expireAt time.Time) *protocol.MultiBulkReply

MakeExpireCmd generates command line to set expiration for the given key

type CmdLine = [][]byte

CmdLine is alias for [][]byte, represents a command line

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

Handler receive msgs from channel and write to AOF file

func NewAOFHandler(db database.EmbedDB, tmpDBMaker func() database.EmbedDB) (*Handler, error)

NewAOFHandler creates a new aof.Handler

func (handler *Handler) AddAof(dbIndex int, cmdLine CmdLine)

AddAof send command to aof goroutine through channel

func (handler *Handler) Close()

Close gracefully stops aof persistence procedure

func (handler *Handler) DoRewrite(ctx *RewriteCtx) error

DoRewrite actually rewrite aof file makes DoRewrite public for testing only, please use Rewrite instead

func (handler *Handler) FinishRewrite(ctx *RewriteCtx)

FinishRewrite finish rewrite procedure

func (handler *Handler) LoadAof(maxBytes int)

LoadAof read aof file

func (handler *Handler) Rewrite() error

Rewrite carries out AOF rewrite

func (handler *Handler) Rewrite2RDB() error

func (handler *Handler) StartRewrite() (*RewriteCtx, error)

StartRewrite prepares rewrite procedure

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

RewriteCtx holds context of an AOF rewriting procedure