stream

type CompressionConfig struct {
	Codec  CompressionType `json:"codec"`
	Level  int             `json:"level,omitempty"`
	Window int             `json:"window,omitempty"`
}

type CompressionType string

type Config struct {
	// ShadowDir stores local segments and snapshots before upload.
	ShadowDir string `json:"shadowDir"`

	// SnapshotInterval controls how frequently full snapshots are taken.
	SnapshotInterval time.Duration `json:"snapshotInterval"`

	// Retention governs automatic pruning of old artefacts.
	Retention RetentionConfig `json:"retention"`

	// Compression configures the codec and tuning options for artefacts.
	Compression CompressionConfig `json:"compression"`

	// Replicas defines zero or more remote destinations.
	Replicas []ReplicaConfig `json:"replicas"`

	// Restore enables automatic restore on startup if the database file
	// does not exist or fails validation.
	Restore RestoreConfig `json:"restore"`

	// DataLossWindowThreshold controls the alerting threshold for acceptable
	// replication lag duration. Zero disables warnings.
	DataLossWindowThreshold time.Duration `json:"dataLossWindowThreshold"`
}

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

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

type FileReplicaConfig struct {
	Path string `json:"path"`
}

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

type NATSReplicaConfig struct {
	URL     string   `json:"url"`
	Bucket  string   `json:"bucket"`
	Prefix  string   `json:"prefix"`
	Creds   string   `json:"creds"`
	NKey    string   `json:"nkey"`
	RootCAs []string `json:"rootCAs"`
}

type PageFrame struct {
	ID       uint64
	Overflow uint32
	Data     []byte
}

type Replica interface {
	// Name returns a stable identifier for logs and metrics.
	Name() string
	// PutSnapshot persists a full snapshot blob for the given generation.
	PutSnapshot(ctx context.Context, generation string, snapshot *Snapshot) error

	// PutSegment persists an incremental segment blob.
	PutSegment(ctx context.Context, generation string, segment *Segment) error

	// Prune applies retention rules and deletes expired data.
	Prune(ctx context.Context, generation string, retention RetentionConfig) error

	// FetchSnapshot retrieves the referenced snapshot blob.
	FetchSnapshot(ctx context.Context, generation string, desc *SnapshotDescriptor) (*Snapshot, error)

	// FetchSegment retrieves the referenced segment blob.
	FetchSegment(ctx context.Context, generation string, desc SegmentDescriptor) (*Segment, error)

	// LatestState returns the newest generation snapshot metadata for restores.
	LatestState(ctx context.Context) (*RestoreState, error)

	// Close releases any held resources.
	Close(ctx context.Context) error
}

type ReplicaConfig interface {
	// contains filtered or unexported methods
}

type RestoreConfig struct {
	// Enabled toggles automatic restores.
	Enabled bool `json:"enabled"`

	// TargetPath allows overriding the default database path.
	TargetPath string `json:"targetPath"`

	// TempDir controls where intermediate restore files live.
	TempDir string `json:"tempDir"`
}

type RestoreState struct {
	Generation   string
	Snapshot     *SnapshotDescriptor
	Segments     []SegmentDescriptor
	LastUploaded time.Time
}

type RetentionConfig struct {
	// SnapshotInterval optionally overrides Config.SnapshotInterval for
	// retention enforcement. Zero inherits the controller interval.
	SnapshotInterval time.Duration `json:"snapshotInterval"`

	// SnapshotRetention is the minimum duration to keep snapshots.
	SnapshotRetention time.Duration `json:"snapshotRetention"`

	// CheckInterval configures how often the pruning loop runs.
	CheckInterval time.Duration `json:"checkInterval"`
}

type S3CompatibleConfig struct {
	Endpoint       string `json:"endpoint"`
	Region         string `json:"region"`
	Bucket         string `json:"bucket"`
	Prefix         string `json:"prefix"`
	AccessKey      string `json:"accessKey"`
	SecretKey      string `json:"secretKey"`
	SessionToken   string `json:"sessionToken"`
	Insecure       bool   `json:"insecure"`
	ForcePathStyle bool   `json:"forcePathStyle"`
}

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

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

type SFTPReplicaConfig struct {
	Host     string `json:"host"`
	Port     int    `json:"port"`
	User     string `json:"user"`
	Password string `json:"password"`
	KeyPath  string `json:"keyPath"`
	Path     string `json:"path"`
}

type Segment struct {
	Header SegmentHeader
	Pages  []PageFrame
	Data   []byte
}

type SegmentDescriptor struct {
	Name      string
	FirstTxID uint64
	LastTxID  uint64
	Timestamp time.Time
	Size      int64
}

type SegmentHeader struct {
	Magic             string            `json:"magic" cbor:"magic"`
	Version           int               `json:"version" cbor:"version"`
	TxID              uint64            `json:"txId" cbor:"txId"`
	ParentTxID        uint64            `json:"parentTxId" cbor:"parentTxId"`
	PageCount         int               `json:"pageCount" cbor:"pageCount"`
	PageSize          int               `json:"pageSize" cbor:"pageSize"`
	Checksum          uint64            `json:"checksum" cbor:"checksum"`
	Compression       CompressionType   `json:"compression" cbor:"compression"`
	CompressionLevel  int               `json:"compressionLevel,omitempty" cbor:"compressionLevel,omitempty"`
	CompressionWindow int               `json:"compressionWindow,omitempty" cbor:"compressionWindow,omitempty"`
	CreatedAt         time.Time         `json:"createdAt" cbor:"createdAt"`
	HighWaterMark     uint64            `json:"highWaterMark" cbor:"highWaterMark"`
	AdditionalAttrs   map[string]string `json:"additionalAttrs,omitempty" cbor:"additionalAttrs,omitempty"`
}

type Snapshot struct {
	Header SnapshotHeader
	Data   []byte
}

type SnapshotDescriptor struct {
	Name      string
	Timestamp time.Time
	Size      int64
}

type SnapshotHeader struct {
	Magic             string          `json:"magic" cbor:"magic"`
	Version           int             `json:"version" cbor:"version"`
	TxID              uint64          `json:"txId" cbor:"txId"`
	PageCount         uint64          `json:"pageCount" cbor:"pageCount"`
	PageSize          int             `json:"pageSize" cbor:"pageSize"`
	Compression       CompressionType `json:"compression" cbor:"compression"`
	CompressionLevel  int             `json:"compressionLevel,omitempty" cbor:"compressionLevel,omitempty"`
	CompressionWindow int             `json:"compressionWindow,omitempty" cbor:"compressionWindow,omitempty"`
	CreatedAt         time.Time       `json:"createdAt" cbor:"createdAt"`
}