segment

type ActiveWriterStats struct {
	BaseOffset      uint64
	BytesWritten    uint64
	MessagesWritten uint64
	Age             time.Duration
}

type CompactionResult struct {
	// SegmentsRemoved is the number of segments removed
	SegmentsRemoved int

	// BytesFreed is the total bytes freed
	BytesFreed int64

	// OldestSegmentAge is the age of the oldest remaining segment
	OldestSegmentAge time.Duration
}

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

type ManagerOptions struct {
	// Directory where segments are stored
	Directory string

	// RotationPolicy determines when to rotate segments
	RotationPolicy RotationPolicy

	// MaxSegmentSize is the max size in bytes before rotation (for RotateBySize, RotateByBoth)
	MaxSegmentSize uint64

	// MaxSegmentMessages is the max message count before rotation (for RotateByCount, RotateByBoth)
	MaxSegmentMessages uint64

	// MaxSegmentAge is the max duration before rotation (for RotateByTime)
	MaxSegmentAge time.Duration

	// WriterOptions for creating new segments
	WriterOptions *WriterOptions

	// RetentionPolicy for cleaning up old segments
	RetentionPolicy *RetentionPolicy
}

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

type RetentionPolicy struct {
	// MaxAge is the max age of segments to keep (0 = no age limit)
	MaxAge time.Duration

	// MaxSize is the max total size of all segments (0 = no size limit)
	MaxSize uint64

	// MaxSegments is the max number of segments to keep (0 = no count limit)
	MaxSegments int

	// MinSegments is the minimum number of segments to always keep (even if they exceed limits)
	MinSegments int
}

type RotationPolicy int

type SegmentInfo struct {
	// BaseOffset is the first message ID in this segment
	BaseOffset uint64

	// Path is the absolute path to the segment file
	Path string

	// IndexPath is the absolute path to the index file (may not exist)
	IndexPath string

	// Size is the segment file size in bytes
	Size int64
}

type SyncPolicy int

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

type WriterOptions struct {
	// SyncPolicy determines when data is fsynced to disk
	SyncPolicy SyncPolicy

	// SyncInterval is the duration between automatic fsyncs (for SyncInterval policy)
	SyncInterval time.Duration

	// BufferSize is the size of the write buffer in bytes
	BufferSize int

	// IndexInterval is the number of bytes between sparse index entries
	IndexInterval int
}