store

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

type ReplayHistoryEntry struct {
	FlowID          string    // Same as replay_id from replay_send
	CreatedAt       time.Time // When replay was executed
	ReferenceOffset uint32    // Max proxy offset at time of replay (for ordering)

	// Request data (for display and export)
	RawRequest []byte
	Method     string
	Host       string
	Path       string
	Protocol   string // "http/1.1" or "h2"

	// Response data
	RespHeaders []byte
	RespBody    []byte
	RespStatus  int
	Duration    time.Duration

	// Lineage
	SourceFlowID string // Original flow_id that was replayed (empty for request_send)
}

type ReplayHistoryMeta struct {
	FlowID          string        `msgpack:"fid"`
	Method          string        `msgpack:"m"`
	Host            string        `msgpack:"h"`
	Path            string        `msgpack:"p"`
	Protocol        string        `msgpack:"pr"`
	SourceFlowID    string        `msgpack:"sf"`
	CreatedAt       time.Time     `msgpack:"ca"`
	ReferenceOffset uint32        `msgpack:"ro"`
	RespStatus      int           `msgpack:"rs"`
	RespLen         int           `msgpack:"rl"`
	Duration        time.Duration `msgpack:"d"`
}

type ReplayHistoryPayload struct {
	RawRequest  []byte `msgpack:"rq"`
	RespHeaders []byte `msgpack:"rh"`
	RespBody    []byte `msgpack:"rb"`
}

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

type SpillStoreConfig struct {
	Dir                 string  // optional, auto-created if empty
	FilePrefix          string  // optional prefix for data file name (e.g. "hist" → "hist.spill.bin")
	MaxHotBytes         int64   // max value bytes in hot cache
	EvictTargetRatio    float64 // evict to this ratio, higher values evict less
	CompactionThreshold int64   // rewrite file when dead bytes exceed this
	ZSTDLevel           int     // compression level (1-21)
}

type Storage interface {
	Set(key string, blob []byte) error
	Get(key string) ([]byte, bool, error)
	KeySet() []string
	Size() int
	Delete(key string) error
	DeleteAll() error
	Close() error
}