memory

type BoundedText struct {
	Text           string `json:"text"`
	OriginalTokens int    `json:"original_tokens"`
	ReturnedTokens int    `json:"returned_tokens"`
	Truncated      bool   `json:"truncated"`
}

type Candidate struct {
	Request RememberRequest `json:"request"`
}

type CandidateExtractor interface {
	Extract(context.Context, ExtractionInput) ([]Candidate, error)
}

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

type CandidateSubmitter interface {
	Submit(ExtractionInput) bool
}

type Conflict struct {
	ID                string    `json:"id"`
	Candidate         Entry     `json:"candidate"`
	Existing          []Entry   `json:"existing"`
	ExistingRevisions []int64   `json:"existing_revisions"`
	Relation          string    `json:"relation"`
	Description       string    `json:"description"`
	StoreRevision     int64     `json:"store_revision"`
	CreatedAt         time.Time `json:"created_at"`
}

type ConflictDecision string

type ConsolidationReport struct {
	CandidateCount   int   `json:"candidate_count"`
	Changed          bool  `json:"changed"`
	Added            int   `json:"added"`
	Duplicates       int   `json:"duplicates"`
	PendingConflicts int   `json:"pending_conflicts"`
	Superseded       int   `json:"superseded"`
	StoreRevision    int64 `json:"store_revision"`
}

type Consolidator interface {
	Consolidate(context.Context, []Candidate) ([]WriteResult, error)
}

type Entry struct {
	ID             string            `json:"id"`
	Scope          Scope             `json:"scope"`
	Tier           Tier              `json:"tier"`
	Kind           Kind              `json:"kind"`
	SemanticKey    string            `json:"semantic_key,omitempty"`
	Subject        string            `json:"subject,omitempty"`
	Predicate      string            `json:"predicate,omitempty"`
	Value          any               `json:"value,omitempty"`
	Qualifiers     map[string]string `json:"qualifiers,omitempty"`
	Cardinality    string            `json:"cardinality,omitempty"`
	Content        string            `json:"content"`
	NormalizedText string            `json:"normalized_content,omitempty"`
	ContentHash    string            `json:"content_hash,omitempty"`
	Status         Status            `json:"status"`
	Importance     int               `json:"importance"`
	Confidence     int               `json:"confidence"`
	Sensitivity    string            `json:"sensitivity,omitempty"`
	SourceType     string            `json:"source_type"`
	SourceSession  string            `json:"source_session_id,omitempty"`
	SourceMessage  string            `json:"source_message_id,omitempty"`
	SourceRef      string            `json:"source_reference,omitempty"`
	SupersedesID   string            `json:"supersedes_id,omitempty"`
	ConflictGroup  string            `json:"conflict_group_id,omitempty"`
	ValidFrom      *time.Time        `json:"valid_from,omitempty"`
	ValidTo        *time.Time        `json:"valid_to,omitempty"`
	ExpiresAt      *time.Time        `json:"expires_at,omitempty"`
	Revision       int64             `json:"revision"`
	CreatedAt      time.Time         `json:"created_at"`
	UpdatedAt      time.Time         `json:"updated_at"`
	LastAccessedAt *time.Time        `json:"last_accessed_at,omitempty"`
	AccessCount    int64             `json:"access_count"`
}

type ExtractionInput struct {
	AgentID           string              `json:"agent_id"`
	SessionID         string              `json:"session_id"`
	Scope             Scope               `json:"scope,omitempty"`
	SourceFingerprint string              `json:"source_fingerprint"`
	Messages          []ExtractionMessage `json:"messages"`
	SkipOnly          bool                `json:"skip_only,omitempty"`
	SkippedThrough    int64               `json:"skipped_through,omitempty"`
}

type ExtractionMessage struct {
	Role       string               `json:"role"`
	Name       string               `json:"name,omitempty"`
	Content    string               `json:"content,omitempty"`
	ToolCallID string               `json:"tool_call_id,omitempty"`
	ToolCalls  []ExtractionToolCall `json:"tool_calls,omitempty"`
}

type ExtractionToolCall struct {
	ID        string `json:"id"`
	Name      string `json:"name"`
	Arguments string `json:"arguments,omitempty"`
}

type Kind string

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

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

type Maintainer interface {
	Maintain(context.Context, Scope, int) (MaintenanceReport, error)
}

type MaintenanceCursor struct {
	AgentID              string    `json:"agent_id"`
	Scope                Scope     `json:"scope"`
	Sequence             int64     `json:"sequence"`
	SourceFingerprint    string    `json:"source_fingerprint"`
	CandidateFingerprint string    `json:"candidate_fingerprint"`
	Revision             int64     `json:"revision"`
	UpdatedAt            time.Time `json:"updated_at"`
}

type MaintenanceOperation struct {
	OperationID          string    `json:"operation_id"`
	AgentID              string    `json:"agent_id"`
	Scope                Scope     `json:"scope"`
	SourceFingerprint    string    `json:"source_fingerprint"`
	CandidateFingerprint string    `json:"candidate_fingerprint"`
	ExpectedCursor       int64     `json:"expected_cursor"`
	NextCursor           int64     `json:"next_cursor"`
	Status               string    `json:"status"`
	CreatedAt            time.Time `json:"created_at"`
	UpdatedAt            time.Time `json:"updated_at"`
}

type MaintenanceReport struct {
	Scope          Scope `json:"scope"`
	CoreBudget     int   `json:"core_budget"`
	DemotedCore    int   `json:"demoted_core"`
	ExpiredEntries int   `json:"expired_entries"`
	Changed        bool  `json:"changed"`
	StoreRevision  int64 `json:"store_revision"`
}

type RecallRequest struct {
	AgentID       string
	Scope         Scope
	RootMessageID string
	QueryText     string
	Limit         int
	TokenBudget   int
	CoreBudget    int
	// ContextTokenBudget is the hard budget for the complete rendered
	// memory_context, including its framing and metadata. TokenBudget and
	// CoreBudget remain the per-tier selection budgets.
	ContextTokenBudget int
	IncludeCore        bool
	Now                time.Time
}

type Reference struct {
	ID        string    `json:"id"`
	Revision  int64     `json:"revision"`
	Tier      Tier      `json:"tier"`
	Kind      Kind      `json:"kind"`
	Content   string    `json:"content"`
	UpdatedAt time.Time `json:"updated_at"`
}

type RememberRequest struct {
	Scope         Scope
	AgentID       string
	Information   string
	Kind          Kind
	Tier          Tier
	SemanticKey   string
	Subject       string
	Predicate     string
	Value         any
	Qualifiers    map[string]string
	Cardinality   string
	Importance    int
	Confidence    int
	Sensitivity   string
	SourceType    string
	SourceSession string
	SourceMessage string
	SourceRef     string
	ValidFrom     *time.Time
	ValidTo       *time.Time
	ExpiresAt     *time.Time
}

type Scope string

type SearchRequest struct {
	Scope           Scope
	Query           string
	Limit           int
	IncludeInactive bool
	Now             time.Time
}

type SearchResult struct {
	Entry Entry   `json:"entry"`
	Score float64 `json:"score,omitempty"`
}

type Service interface {
	Recall(ctx context.Context, req RecallRequest) (Snapshot, error)
	Search(ctx context.Context, req SearchRequest) ([]SearchResult, error)
	Get(ctx context.Context, scope Scope, id string, includeInactive bool) (Entry, error)
	Remember(ctx context.Context, req RememberRequest) (WriteResult, error)
	Forget(ctx context.Context, scope Scope, id, reason string) (WriteResult, error)
	ResolveConflict(ctx context.Context, scope Scope, conflictID string, decision ConflictDecision) (WriteResult, error)
	SetScope(scope Scope)
}

type Snapshot struct {
	ID              string      `json:"id"`
	Scope           Scope       `json:"scope"`
	StoreRevision   int64       `json:"store_revision"`
	RootMessageID   string      `json:"root_message_id"`
	Core            []Reference `json:"core,omitempty"`
	Recalled        []Reference `json:"recalled,omitempty"`
	RenderedContent string      `json:"rendered_content"`
	TokenEstimate   int         `json:"token_estimate"`
	Digest          string      `json:"digest"`
	CreatedAt       time.Time   `json:"created_at"`
}

type Status string

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

type Tier string

type WriteOutcome string

type WriteResult struct {
	Outcome       WriteOutcome `json:"outcome"`
	Entry         *Entry       `json:"entry,omitempty"`
	ExistingID    string       `json:"existing_id,omitempty"`
	Superseded    []string     `json:"superseded,omitempty"`
	Conflict      *Conflict    `json:"conflict,omitempty"`
	StoreRevision int64        `json:"store_revision"`
}