compression

type ActiveProfile struct {
	DictHash         uint64
	DictBytes        int
	Dict             []byte
	HistoryBytes     int
	K                int
	PayloadRatio     float64
	TotalRatio       float64
	DecodeNsEstimate int64
	EncodeNsEstimate int64
	AvgSampleBytes   int
	Samples          int
	Timestamp        time.Time
}

type ChooseKOptions struct {
	CandidateK        []int
	IoNsPerStoredByte float64
	// Deterministic timing overrides (ns per raw byte).
	EncodeNsPerRawByte float64
	DecodeNsPerRawByte float64
}

type Config struct {
	Kind       Kind
	MinBytes   int
	MinSavings int
	Level      zstd.EncoderLevel
	ZstdEncs   *sync.Pool
	ZstdDecs   *sync.Pool
	BufferPool *sync.Pool
}

type DictUseFlag uint8

type Kind uint8

type Metrics struct {
	Enabled          bool
	LogWindows       bool
	WindowBytes      uint64
	SlabID           uint32
	PauseThreshold   float64
	PauseBytes       uint64
	MinRecords       uint64
	WindowRaw        uint64
	WindowStored     uint64
	WindowRecords    uint64
	WindowCompressed uint64
	WindowFull       uint64
	TotalRaw         uint64
	TotalStored      uint64
	TotalRecords     uint64
	TotalCompressed  uint64
	TotalFull        uint64
	TotalDegraded    uint64
	// contains filtered or unexported fields
}

type MetricsOptions struct {
	MetricsEnabled bool
	AdaptiveRatio  float64
	WindowBytes    int
	MinRecords     int
	PauseBytes     int
}

type Options struct {
	Kind            Kind
	MinBytes        int
	MinSavingsBytes int
	Level           int
}

type TrainConfig struct {
	TrainBytes     int
	DictBytes      int
	MinRecords     int
	MaxRecordBytes int
	SampleStride   int
	DedupWindow    int
	Level          int
	// Deterministic cost modeling (tests/benches only). When >0, overrides
	// encode/decode timing estimates in training evaluation.
	EncodeNsPerRawByte float64
	DecodeNsPerRawByte float64
}

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

type TrainerStats struct {
	Enabled              bool
	Collecting           bool
	Training             bool
	QueueLen             int
	QueueCap             int
	Enqueued             uint64
	Dropped              uint64
	MaxQueueLen          uint64
	TrainCount           uint64
	LastTrainRatio       float64
	LastTrainSamples     uint64
	LastTrainDict        uint64
	LastTrainDictHash    uint64
	LastTrainDedupMode   string
	LastTrainDedupFlag   string
	LastTrainDedupRef    uint64
	DictDedupLookups     uint64
	DictDedupHits        uint64
	DictDedupGlobal      uint64
	DictDedupRef         uint64
	DictDedupCache       uint64
	DictDedupBytes       uint64
	DictDedupBytesGlobal uint64
	DictDedupBytesRef    uint64
	DictDedupBytesCache  uint64
	CollectCount         uint64
	CollectNanos         uint64
	CollectMaxNanos      uint64
	ProfileK             int
	ProfileTotalRatio    float64
	ProfilePayloadRatio  float64
	ProfileTimestamp     time.Time
	ProfileAttempts      uint64
	ProfileAccepts       uint64
	ProfileRejects       uint64
	ProfileRejectReason  string
	RollingRatioBaseline float64
	RollingRatioCurrent  float64
	LastAcceptBytes      uint64
	LastAcceptRecords    uint64
	LastAcceptTimestamp  time.Time
}