wal

type Entry struct {
	Id      uint64
	Payload Payload
	// contains filtered or unexported fields
}

type Payload interface {
	Marshal() ([]byte, error)
}

type Role uint8

type ShardAwareWal interface {
	Wal
	InitShard(uint64, uint64) error
	TryInitShard(uint64, uint64) error
	GetAllShardCheckpointId() map[uint64]uint64
	GetShardCheckpointId(uint64) uint64
	GetShardCurrSeqNum(uint64) uint64
	GetShardPendingCnt(uint64) int
	GetAllPendingEntries() []*shard.ItemsToCheckpointStat
}

type ShardWal struct {
	Wal     ShardAwareWal
	ShardId uint64
}

type Wal interface {
	io.Closer
	Log(Payload) (*Entry, error)
	SyncLog(Payload) error
	Checkpoint(interface{})
	String() string
	GetRole() Role
}