log_buffer

type EachLogEntryFuncType func(logEntry *filer_pb.LogEntry) (isDone bool, err error)

type LogBuffer struct {
	LastFlushTsNs int64

	ReadFromDiskFn LogReadFromDiskFuncType

	LastTsNs int64
	sync.RWMutex
	// contains filtered or unexported fields
}

type LogFlushFuncType func(logBuffer *LogBuffer, startTime, stopTime time.Time, buf []byte)

type LogReadFromDiskFuncType func(startPosition MessagePosition, stopTsNs int64, eachLogEntryFn EachLogEntryFuncType) (lastReadPosition MessagePosition, isDone bool, err error)

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

type MessagePosition struct {
	time.Time        // this is the timestamp of the message
	BatchIndex int64 // this is only used when the timestamp is not enough to identify the next message, when the timestamp is in the previous batch.
}

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