Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AckManager ¶
type AckManager struct { Dump *storages.Dump Version int64 Lock *sync.RWMutex Rand *rand.Rand Logger *zap.SugaredLogger // contains filtered or unexported fields }
func NewAckTimestampManager ¶
func NewAckTimestampManager(lg *zap.SugaredLogger, dumpFileName string, flushDelay time.Duration) *AckManager
func (*AckManager) Flush ¶
func (a *AckManager) Flush()
func (*AckManager) Get ¶
func (a *AckManager) Get() uint64
func (*AckManager) OnFlushComplete ¶
func (a *AckManager) OnFlushComplete()
func (*AckManager) Set ¶
func (a *AckManager) Set(sequence uint64)
Click to show internal directories.
Click to hide internal directories.