session

type Factory ¶

type Factory func(conf map[string]any, window int) (Store, error)

Factory 按配置构造存储。window 为保留的最近消息条数,<=0 不裁剪 (裁剪只影响 Load 结果,持久化后端应保留全量记录)。

type FullLoader ¶

type FullLoader interface {
	LoadAll(ctx context.Context, sessionID string) ([]*schema.Message, error)
}

FullLoader 是可选扩展:返回不裁剪的全量历史。实现它的后端可享受 滚动摘要持久化与会话内相关性召回;内置 inmemory/file/redis 均已实现。

type Retriever ¶

type Retriever interface {
	Retrieve(ctx context.Context, history []*schema.Message, input string, topK int) []string
}

Retriever 是窗外会话召回的检索策略契约:从历史消息中找出与本轮 输入相关的片段。查询构造(要不要扩展/改写输入)也是实现的职责。

这是 Ring 1 扩展点:检索是"同一契约、多种实现、坏了只降质量"的 纯函数,语义召回(向量/rerank)注册后即可在配置里以名字引用; 织入视图的重建(摘要/锚定/窗口)则是 Ring 0 不变量,不在此开放。 内置词法保底 bigram 在 impl/session/bigram。

func NewRetriever(name string, conf map[string]any) (Retriever, error)

type RetrieverFactory ¶

type RetrieverFactory func(conf map[string]any) (Retriever, error)

RetrieverFactory 按配置构造检索器。

type Store ¶

type Store interface {
	Load(ctx context.Context, sessionID string) ([]*schema.Message, error)
	Append(ctx context.Context, sessionID string, msgs ...*schema.Message) error
	Clear(ctx context.Context, sessionID string) error
}

Store 是会话历史存储的最小契约。Load 返回窗口裁剪后的最近消息。

func New(typ string, conf map[string]any, window int) (Store, error)