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)
Source Files
Click to show internal directories.
Click to hide internal directories.