Documentation
¶
Index ¶
- type MockScheduler
- func (m *MockScheduler) AddTask(ctx context.Context, task *db.ScheduledTask) (int64, error)
- func (m *MockScheduler) EditTask(ctx context.Context, taskID int64, schedule, taskType, prompt *string, ...) error
- func (m *MockScheduler) GetTask(ctx context.Context, taskID int64) (*db.ScheduledTask, error)
- func (m *MockScheduler) ListTasks(ctx context.Context, channelID string) ([]*db.ScheduledTask, error)
- func (m *MockScheduler) RemoveTask(ctx context.Context, taskID int64) error
- func (m *MockScheduler) SetTaskEnabled(ctx context.Context, taskID int64, enabled bool) error
- func (m *MockScheduler) Start(ctx context.Context) error
- func (m *MockScheduler) Stop() error
- func (m *MockScheduler) ToggleTask(ctx context.Context, taskID int64) (bool, error)
- type MockStore
- func (m *MockStore) Close() error
- func (m *MockStore) CreateScheduledTask(ctx context.Context, task *db.ScheduledTask) (int64, error)
- func (m *MockStore) DeleteChannel(ctx context.Context, channelID string) error
- func (m *MockStore) DeleteChannelsByParentID(ctx context.Context, parentID string) error
- func (m *MockStore) DeleteMemoryFile(ctx context.Context, filePath, dirPath string) error
- func (m *MockStore) DeleteScheduledTask(ctx context.Context, id int64) error
- func (m *MockStore) GetChannel(ctx context.Context, channelID string) (*db.Channel, error)
- func (m *MockStore) GetChannelByDirPath(ctx context.Context, dirPath string, platform types.Platform) (*db.Channel, error)
- func (m *MockStore) GetDueTasks(ctx context.Context, now time.Time) ([]*db.ScheduledTask, error)
- func (m *MockStore) GetMemoryFileHash(ctx context.Context, filePath, dirPath string) (string, error)
- func (m *MockStore) GetMemoryFilesByDirPath(ctx context.Context, dirPath string) ([]*db.MemoryFile, error)
- func (m *MockStore) GetRecentMessages(ctx context.Context, channelID string, limit int) ([]*db.Message, error)
- func (m *MockStore) GetScheduledTask(ctx context.Context, id int64) (*db.ScheduledTask, error)
- func (m *MockStore) GetScheduledTaskByTemplateName(ctx context.Context, channelID, templateName string) (*db.ScheduledTask, error)
- func (m *MockStore) InsertMessage(ctx context.Context, msg *db.Message) error
- func (m *MockStore) InsertTaskRunLog(ctx context.Context, trl *db.TaskRunLog) (int64, error)
- func (m *MockStore) IsChannelActive(ctx context.Context, channelID string) (bool, error)
- func (m *MockStore) ListChannels(ctx context.Context) ([]*db.Channel, error)
- func (m *MockStore) ListScheduledTasks(ctx context.Context, channelID string) ([]*db.ScheduledTask, error)
- func (m *MockStore) MarkMessagesProcessed(ctx context.Context, ids []int64) error
- func (m *MockStore) UpdateChannelPermissions(ctx context.Context, channelID string, perms types.Permissions) error
- func (m *MockStore) UpdateScheduledTask(ctx context.Context, task *db.ScheduledTask) error
- func (m *MockStore) UpdateScheduledTaskEnabled(ctx context.Context, id int64, enabled bool) error
- func (m *MockStore) UpdateSessionID(ctx context.Context, channelID string, sessionID string) error
- func (m *MockStore) UpdateTaskRunLog(ctx context.Context, trl *db.TaskRunLog) error
- func (m *MockStore) UpsertChannel(ctx context.Context, ch *db.Channel) error
- func (m *MockStore) UpsertMemoryFile(ctx context.Context, file *db.MemoryFile) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockScheduler ¶
MockScheduler implements the scheduler.Scheduler / orchestrator.Scheduler interface for testing.
func (*MockScheduler) AddTask ¶
func (m *MockScheduler) AddTask(ctx context.Context, task *db.ScheduledTask) (int64, error)
func (*MockScheduler) GetTask ¶ added in v0.1.59
func (m *MockScheduler) GetTask(ctx context.Context, taskID int64) (*db.ScheduledTask, error)
func (*MockScheduler) ListTasks ¶
func (m *MockScheduler) ListTasks(ctx context.Context, channelID string) ([]*db.ScheduledTask, error)
func (*MockScheduler) RemoveTask ¶
func (m *MockScheduler) RemoveTask(ctx context.Context, taskID int64) error
func (*MockScheduler) SetTaskEnabled ¶
func (*MockScheduler) Stop ¶
func (m *MockScheduler) Stop() error
func (*MockScheduler) ToggleTask ¶
type MockStore ¶
MockStore implements the db.Store interface for testing.
func (*MockStore) CreateScheduledTask ¶
func (*MockStore) DeleteChannel ¶
func (*MockStore) DeleteChannelsByParentID ¶
func (*MockStore) DeleteMemoryFile ¶
func (*MockStore) DeleteScheduledTask ¶
func (*MockStore) GetChannel ¶
func (*MockStore) GetChannelByDirPath ¶
func (*MockStore) GetDueTasks ¶
func (*MockStore) GetMemoryFileHash ¶
func (*MockStore) GetMemoryFilesByDirPath ¶
func (*MockStore) GetRecentMessages ¶
func (*MockStore) GetScheduledTask ¶
func (*MockStore) GetScheduledTaskByTemplateName ¶
func (*MockStore) InsertMessage ¶
func (*MockStore) InsertTaskRunLog ¶
func (*MockStore) IsChannelActive ¶
func (*MockStore) ListChannels ¶
func (*MockStore) ListScheduledTasks ¶
func (*MockStore) MarkMessagesProcessed ¶
func (*MockStore) UpdateChannelPermissions ¶
func (*MockStore) UpdateScheduledTask ¶
func (*MockStore) UpdateScheduledTaskEnabled ¶
func (*MockStore) UpdateSessionID ¶
func (*MockStore) UpdateTaskRunLog ¶
func (*MockStore) UpsertChannel ¶
func (*MockStore) UpsertMemoryFile ¶
Click to show internal directories.
Click to hide internal directories.