Versions in this module Expand all Collapse all v0 v0.4.0 May 5, 2022 Changes in this version + type Entry struct + Id uint64 + Payload Payload + func GetEntry(id uint64) *Entry + func (e *Entry) Free() + func (e *Entry) SetDone() + func (e *Entry) WaitDone() + type Payload interface + Marshal func() ([]byte, error) + type Role uint8 + const BrokerRole + const HolderRole + type ShardAwareWal interface + GetAllPendingEntries func() []*shard.ItemsToCheckpointStat + GetAllShardCheckpointId func() map[uint64]uint64 + GetShardCheckpointId func(uint64) uint64 + GetShardCurrSeqNum func(uint64) uint64 + GetShardPendingCnt func(uint64) int + InitShard func(uint64, uint64) error + TryInitShard func(uint64, uint64) error + type ShardWal struct + ShardId uint64 + Wal ShardAwareWal + func NewWalShard(shardId uint64, wal ShardAwareWal) *ShardWal + func (wal *ShardWal) Checkpoint(v interface{}) + func (wal *ShardWal) GetCheckpointId() uint64 + func (wal *ShardWal) GetCurrSeqNum() uint64 + func (wal *ShardWal) GetShardId() uint64 + func (wal *ShardWal) InitWal(index uint64) error + func (wal *ShardWal) Log(payload Payload) (*Entry, error) + func (wal *ShardWal) SyncLog(payload Payload) error + func (wal *ShardWal) TryInitWal(index uint64) error + func (wal *ShardWal) UncheckpointedCnt() int + func (wal *ShardWal) WalEnabled() bool + type Wal interface + Checkpoint func(interface{}) + GetRole func() Role + Log func(Payload) (*Entry, error) + String func() string + SyncLog func(Payload) error
Go to main page