importer

type DedupResult struct {
	Namespaces    int `json:"namespaces"`
	ClustersFound int `json:"clusters_found"`
	Tombstoned    int `json:"tombstoned"`
}

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

type Options struct {
	// DefaultNamespace scopes records whose source carried no namespace.
	DefaultNamespace string
	// ForceNamespace, when set, overrides every record's namespace (the explicit
	// "merge everything into one pool" opt-in). The original namespace is
	// preserved in metadata["import_source_namespace"] so the merge is reversible
	// with `memini namespace split`.
	ForceNamespace string
	// Source names the export format, used to stamp a provenance tag
	// (import:<source>:<date>) and to seed deterministic record IDs.
	Source Source
	// DefaultImportance is applied to records whose source carried no importance
	// (reported as 0), so bulk imports rank below curated, source-scored
	// memories. 0 disables the floor.
	DefaultImportance float64
	// Confidence overrides the seed corroboration for durable imported facts
	// (e.g. a trusted re-import). nil uses the low default import seed.
	Confidence *float64
	// SkipExisting checks the store for a record's ID before writing and counts
	// it as a duplicate instead of clobbering an existing memory's access
	// counters. Combined with deterministic IDs this makes re-imports idempotent.
	// Only honored by the local backend.
	SkipExisting bool
	// DryRun resolves namespaces and runs the quality gates but writes nothing;
	// the Report's namespace histogram still reflects where records would land.
	DryRun bool
	// BatchSize bounds how many records are written per batch.
	BatchSize int
	// OnProgress is called after each batch with (processed, total).
	// It may be nil.
	OnProgress func(done, total int)
	// MinContentLen drops records whose trimmed content is shorter than this,
	// filtering out stubs from a low-quality bulk import. 0 disables the gate.
	MinContentLen int
	// MinImportance drops records below this importance. 0 disables the gate;
	// note sources that carry no importance report 0, so any positive value
	// skips them.
	MinImportance float64
}

type Record struct {
	ID         string
	Namespace  string
	Tier       memory.Tier
	Content    string
	Summary    string
	Tags       []string
	Metadata   map[string]any
	Importance float64
	CreatedAt  time.Time  // zero -> import time
	UpdatedAt  time.Time  // zero -> CreatedAt
	ExpiresAt  *time.Time // nil -> tier default measured from CreatedAt
}

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

type Report struct {
	Total      int            `json:"total"`
	Imported   int            `json:"imported"`
	Skipped    int            `json:"skipped"`              // dropped before write (failed a quality gate)
	Duplicates int            `json:"duplicates,omitempty"` // already present, left untouched (SkipExisting)
	Namespaces map[string]int `json:"namespaces,omitempty"` // records resolved per destination namespace
	Errors     []string       `json:"errors,omitempty"`
}

type Source string

type TypedKind string