ackmanager

Documentation

Index

• type AckManager
  • func NewAckTimestampManager(lg *zap.SugaredLogger, dumpFileName string, flushDelay time.Duration) *AckManager
  • func (a *AckManager) Flush()
  • func (a *AckManager) Get() uint64
  • func (a *AckManager) OnFlushComplete()
  • func (a *AckManager) Set(sequence uint64)

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)