storage

type ArtifactRecord struct {
	Name             string            `json:"name"`
	RelPath          string            `json:"rel_path"`
	MediaType        string            `json:"media_type"`
	Role             core.ArtifactRole `json:"role"`
	SizeBytes        int64             `json:"size_bytes"`
	Checksum         core.Checksum     `json:"checksum"`
	CreatedAt        time.Time         `json:"created_at"`
	UploadedAt       *time.Time        `json:"uploaded_at,omitempty"`        // set after a successful upload/confirm
	RemoteArtifactID string            `json:"remote_artifact_id,omitempty"` // backend-assigned ULID
}

type ArtifactsDocument struct {
	SchemaVersion string           `json:"schema_version"`
	Artifacts     []ArtifactRecord `json:"artifacts"`
}

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

type ManifestDocument struct {
	RunID        string               `json:"run_id"`
	Schema       string               `json:"schema_version"`
	Source       core.SourceMeta      `json:"source"`
	Manifest     core.Manifest        `json:"manifest"`
	Capture      core.CaptureSettings `json:"capture"`
	Started      time.Time            `json:"started"`
	Completed    *time.Time           `json:"completed,omitempty"`
	RecordsCount uint64               `json:"records_count"`
	PrimaryData  string               `json:"primary_data_uri"`
}

type Store interface {
	Start(run *core.Run) error
	Write([]core.Record) error
	Finalize(run *core.Run) error
	Artifacts() []core.Artifact
}