cortex

Apr 11, 2026

Changes in this version

+ const FederationModePublish

+ const FederationModeSubscribe

+ const FederationModeSync

+ const PeerModePaused

+ const PeerModeSync

+ var ErrSourceLocked = errors.New("trace is source-locked")

type Cortex

+ func (c *Cortex) CheckSourceLock(id string) error

+ func (c *Cortex) SetForceSourceLock(v bool)

type FederationConfig

+ Mode string

+ func (fc *FederationConfig) EffectiveMode() string

type Manifest

+ func (m Manifest) ValidateFederation() error

type PeerEntry

+ Mode string

+ func (pe PeerEntry) EffectiveMode() string

type Row

+ ContentHash string

+ SourceHash string

+ SourceLocked bool

Apr 9, 2026

Changes in this version

+ const AccessKeyEnvVar

+ const ManifestVersion

+ func KeyFingerprint(key string) string

+ func WriteManifest(dir string, m Manifest) error

+ type AccessConfig struct

+ SharedKeyFile string

+ type AccessKey struct

+ Fingerprint string

+ Path string

+ Source string

+ Value string

+ func LoadAccessKey(cortexDir string, cfg *AccessConfig) (AccessKey, error)

+ func (k AccessKey) EnvOverride() bool

+ func (k AccessKey) Keyed() bool

+ type BackfillResult struct

+ BackfilledIDs []string

+ SkippedIDs []string

type Cortex

+ ID string

+ func (c *Cortex) BackfillCreateEvents(dryRun bool) (BackfillResult, error)

+ func (c *Cortex) DerivedBy(id string) ([]string, error)

+ func (c *Cortex) DivergenceCount() (int, error)

+ func (c *Cortex) Events(traceID string) ([]event.Event, error)

+ func (c *Cortex) EventsSince(afterID string, limit int) ([]event.Event, error)

+ func (c *Cortex) GetClock() (federation.VClock, error)

+ func (c *Cortex) MergeClock(remote federation.VClock) error

+ func (c *Cortex) ReplayEvent(e event.Event) error

+ func (c *Cortex) ResolveDivergence(divergenceID, acceptOrigin, customBody string) error

+ func (c *Cortex) SyncWithOptions(opts SyncOptions) (SyncResult, error)

+ type FederationConfig struct

+ Interval string

+ Peers []PeerEntry

type ListOptions

+ Origin string

type Manifest

+ Access *AccessConfig

+ Federation *FederationConfig

+ ID string

+ func (m Manifest) PeerLabelCollidesWithSelf(peerLabel string) bool

+ type PeerEntry struct

+ CA string

+ Endpoint string

+ Name string

type Row

+ DerivedFrom []string

+ Origin string

+ type SyncOptions struct

+ Recover bool

type SyncResult

+ Recovered int

Mar 30, 2026

Changes in this version

type Cortex

+ func (c *Cortex) Sync() (SyncResult, error)

type Manifest

+ func ReadManifest(dir string) (Manifest, error)

+ type SyncResult struct

+ Added int

+ Orphaned int

+ Updated int

Mar 30, 2026

Changes in this version

type Cortex

+ func (c *Cortex) Purge(days int) error

+ func (c *Cortex) Recover(id string) error

+ func (c *Cortex) Trash(id string) error

+ func (c *Cortex) TrashDir() string

+ func (c *Cortex) TrashFile(id string) string

type ListOptions

+ Trashed bool

type Row

+ TrashedAt string

Mar 29, 2026

Changes in this version

+ func Create(name, dir string) error

+ type Cortex struct

+ DB *db.DB

+ Dir string

+ Name string

+ func Open(name, dir string) (*Cortex, error)

+ func (c *Cortex) Add(t *trace.Trace) error

+ func (c *Cortex) Archive(id string) error

+ func (c *Cortex) ArchiveDir() string

+ func (c *Cortex) Close() error

+ func (c *Cortex) Get(id string) (*Row, error)

+ func (c *Cortex) List(opts ListOptions) ([]Row, error)

+ func (c *Cortex) Remove(id string) error

+ func (c *Cortex) Search(query string, opts ListOptions) ([]Row, error)

+ func (c *Cortex) TraceFile(id string, archived bool) string

+ func (c *Cortex) TracesDir() string

+ func (c *Cortex) Unarchive(id string) error

+ func (c *Cortex) Update(id string) error

+ type ListOptions struct

+ All bool

+ Archived bool

+ Author string

+ Tag string

+ Type string

+ type Manifest struct

+ Created string

+ Name string

+ Owner string

+ Purpose string

+ Version int

+ type Row struct

+ ArchivedAt string

+ Author string

+ CreatedAt string

+ ID string

+ Tags []string

+ Title string

+ Type string

+ UpdatedAt string