memory

type FileStore ¶

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

func NewFileStore(dir string) (*FileStore, error)

func (store *FileStore) Append(ctx context.Context, item Item) (string, error)

func (store *FileStore) Delete(ctx context.Context, id string) error

func (store *FileStore) Get(ctx context.Context, id string) (Item, error)

func (store *FileStore) Query(ctx context.Context, filter Filter) ([]Item, error)

func (store *FileStore) Transact(ctx context.Context, fn func(Store) error) error

type Filter ¶

type Filter struct {
	Tags     []string
	Since    time.Time
	Until    time.Time
	Contains string
	Limit    int
}

type Item ¶

type Item struct {
	ID      string            `json:"id"`
	Time    time.Time         `json:"time"`
	Content string            `json:"content"`
	Tags    []string          `json:"tags,omitempty"`
	Meta    map[string]string `json:"meta,omitempty"`
}

func ParseJournal(content []byte) ([]Item, error)

type Scored ¶

type Scored struct {
	Item
	Score float64
}

type SemanticSearcher ¶

type SemanticSearcher interface {
	Search(context.Context, string, int) ([]Scored, error)
}

SemanticSearcher returns highest-scoring items first and honors positive limit values.

type Store ¶

type Store interface {
	Append(context.Context, Item) (string, error)
	Get(context.Context, string) (Item, error)
	Query(context.Context, Filter) ([]Item, error)
	Delete(context.Context, string) error
}

Store is a tenant-scoped durable memory backend. Implementations must accept concurrent calls. Query returns newest items first, treats Tags as an AND filter, matches Contains case-insensitively, and honors positive Limit values.

type TransactionalStore ¶

type TransactionalStore interface {
	Store
	Transact(context.Context, func(Store) error) error
}

TransactionalStore makes compound profile mutations atomic across runtime instances and processes. The callback must use only the supplied Store.