memory

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 8, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DailyFilesStore added in v0.5.0

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

DailyFilesStore 每天一个文件存储

func NewDailyStore added in v0.5.0

func NewDailyStore(dir string, readDays int) *DailyFilesStore

NewDailyStore 创建 *DailyFilesStore

func (*DailyFilesStore) Read added in v0.5.0

func (s *DailyFilesStore) Read() (string, error)

Read 读取最近一段时间记忆内容

func (*DailyFilesStore) ReadActiveContent added in v0.5.0

func (s *DailyFilesStore) ReadActiveContent() (string, error)

ReadActiveContent 读活跃部分

func (*DailyFilesStore) Update added in v0.5.0

func (s *DailyFilesStore) Update(content string) error

Update 写入当天记忆内容

type FileStore added in v0.5.0

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

FileStore 基于文件的记忆存储

func NewFileStore added in v0.5.0

func NewFileStore(path string) *FileStore

NewFileStore 基于文件的记忆存储

func (*FileStore) Read added in v0.5.0

func (s *FileStore) Read() (string, error)

Read 读取记忆内容

func (*FileStore) ReadActiveContent added in v0.5.0

func (s *FileStore) ReadActiveContent() (string, error)

ReadActiveContent 读活跃部分

func (*FileStore) Update added in v0.5.0

func (s *FileStore) Update(content string) error

Update 更新记忆内容

type Store added in v0.5.0

type Store interface {
	// Read 读取记忆内容
	Read() (string, error)
	// ReadActiveContent 读活跃部分
	ReadActiveContent() (string, error)
	// Update 更新记忆内容
	Update(content string) error
}

Store 记忆存储

type SummarizeFlow

type SummarizeFlow = *core.Flow[SummarizeInput, SummarizeOutput, struct{}]

SummarizeFlow 记忆总结流程

func DefineSummarizeFlow

func DefineSummarizeFlow(g *genkit.Genkit, name string, opts SummarizeOptions) SummarizeFlow

DefineSummarizeFlow 定义记忆总结流程

type SummarizeInput

type SummarizeInput struct {
	CurrentMemory string        `json:"currentMemory"`
	History       []*ai.Message `json:"history"`
}

SummarizeInput 记忆总结流程输入

type SummarizeOptions added in v0.5.0

type SummarizeOptions struct {
	SystemPrompt string
}

SummarizeOptions 记忆总结选项

type SummarizeOutput

type SummarizeOutput struct {
	Memory string `json:"memory"`
}

SummarizeOutput 记忆总结流程输出

type Summarizer

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

Summarizer 异步记忆总结器,统一管理长期记忆和中期记忆的总结

func NewSummarizer

func NewSummarizer(g *genkit.Genkit, dataRoot string) *Summarizer

NewSummarizer 创建记忆总结器

func (*Summarizer) Cancel

func (s *Summarizer) Cancel()

Cancel 取消正在进行的防抖等待或异步总结

func (*Summarizer) DailyMemory added in v0.5.0

func (s *Summarizer) DailyMemory() Store

DailyMemory 返回每日记忆

func (*Summarizer) LongTermMemory added in v0.5.0

func (s *Summarizer) LongTermMemory() Store

LongTermMemory 返回长期记忆

func (*Summarizer) Schedule

func (s *Summarizer) Schedule(ctx context.Context, history []*ai.Message)

Schedule 安排防抖总结。在调用方对话结束后调用。 等待 1 分钟,期间如果被 Cancel 则取消,否则开始异步总结。

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL