aof

type AOF struct {
	// contains filtered or unexported fields
}

type AppendEvent struct {
	Begin int64
	End   int64
	Tail  []byte
	// contains filtered or unexported fields
}

type AppendFunc func(event AppendEvent) (int64, error)

type ClosedEvent struct {
	Tailer *Tailer
	Reason any
}

type Consumer interface {
	PollRead(event ReadEvent) (int64, error)

	PollReadClosed(reason error)
}

type ErrorFunc func(err error)

type FileState int32

type FileStats struct {
	// contains filtered or unexported fields
}

type Geometry struct {
	SizeNow    int64
	SizeUpper  int64
	GrowthStep int64
	PageSize   int64
	Create     bool
}

type Magic struct {
	// Tail is the magic number that marks the tail of the file
	Tail uint64
	// Checkpoint is the magic number that marks the end of a chunk.
	// During recovery if the Magic Tail is not found, it will search
	// for the last Checkpoint
	Checkpoint uint64
}

type Manager struct {
	// contains filtered or unexported fields
}

type ReadEvent struct {
	Time       int64
	Tailer     *Tailer
	Begin, End int64
	Tail       []byte

	FileState FileState
	EOF       bool
	Reason    reactor.PollReason
	// contains filtered or unexported fields
}

type Recovery struct {
	Magic Magic
	Func  RecoveryFunc
	// contains filtered or unexported fields
}

type RecoveryFunc func(
	fileSize int64,
	data []byte,
	magic Magic,
) (result RecoveryResult)

type RecoveryKind int

type RecoveryResult struct {
	Magic      Magic
	Outcome    RecoveryKind
	FileSize   int64
	Checkpoint int64
	Tail       int64
	Err        error
}

type Stats struct {
	Creates               Counter
	CreatesDur            TimeCounter
	Opens                 Counter
	OpensDur              TimeCounter
	OpenErrors            Counter
	OpenErrorsDur         TimeCounter
	OpenFileCount         Counter
	OpenFileDur           TimeCounter
	OpenFileErrors        Counter
	OpenFileErrorsDur     TimeCounter
	Closes                Counter
	CloseDur              TimeCounter
	ActiveMaps            Counter
	ActiveFileSize        Counter
	ActiveMappedMemory    Counter
	ActiveAnonymousMemory Counter
	LifetimeMemory        Counter
	Flushes               Counter
	FlushesDur            TimeCounter
	FlushErrors           Counter
	FlushErrorsDur        TimeCounter
	Finishes              Counter
	FinishesDur           TimeCounter
	FinishErrors          Counter
	FinishErrorsDur       TimeCounter
	Syncs                 Counter
	SyncsDur              TimeCounter
	SyncErrors            Counter
	SyncErrorsDur         TimeCounter
	Maps                  Counter
	MapsDur               TimeCounter
	MapErrors             Counter
	MapErrorsDur          TimeCounter
	Unmaps                Counter
	UnmapsDur             TimeCounter
	UnmapErrors           Counter
	UnmapErrorsDur        TimeCounter
	Finalizes             Counter
	FinalizesDur          TimeCounter
	Truncates             Counter
	TruncatesDur          TimeCounter
	TruncateErrors        Counter
	TruncateErrorsDur     TimeCounter
	Chmods                Counter
	ChmodsDur             TimeCounter
	ChmodErrors           Counter
	ChmodErrorsDur        TimeCounter
}

type Tailer struct {
	reactor.TaskProvider
	// contains filtered or unexported fields
}

type TailerState int32