Documentation
¶
Index ¶
- func NewTools(s *Service) []types.Tool
- func RegisterAgentTaskHandler(s *xcron.Scheduler, agentExecutor func(input string) error)
- type DeleteJobTool
- type ListJobsTool
- type ScheduleJobInput
- type ScheduleJobTool
- func (t *ScheduleJobTool) Description() string
- func (t *ScheduleJobTool) Execute(ctx context.Context, input map[string]interface{}) (interface{}, error)
- func (t *ScheduleJobTool) Metadata() types.ToolMetadata
- func (t *ScheduleJobTool) Name() string
- func (t *ScheduleJobTool) Schema() map[string]interface{}
- type Service
- func (s *Service) ConfigureAgent(llmProvider types.LLMProvider, config *types.AgentConfig, ...)
- func (s *Service) ConfigureAgentWithMemoryFactory(llmProvider types.LLMProvider, config *types.AgentConfig, ...)
- func (s *Service) DeleteJob(ctx context.Context, jobID string) error
- func (s *Service) ListJobs(ctx context.Context, limit, offset int) ([]*xcron.Job, int64, error)
- func (s *Service) ScheduleJob(ctx context.Context, input ScheduleJobInput) (string, error)
- func (s *Service) StopJob(ctx context.Context, jobID string) error
- type StopJobTool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type DeleteJobTool ¶
type DeleteJobTool struct {
// contains filtered or unexported fields
}
func (*DeleteJobTool) Description ¶
func (t *DeleteJobTool) Description() string
func (*DeleteJobTool) Execute ¶
func (t *DeleteJobTool) Execute(ctx context.Context, input map[string]interface{}) (interface{}, error)
func (*DeleteJobTool) Metadata ¶
func (t *DeleteJobTool) Metadata() types.ToolMetadata
func (*DeleteJobTool) Name ¶
func (t *DeleteJobTool) Name() string
func (*DeleteJobTool) Schema ¶
func (t *DeleteJobTool) Schema() map[string]interface{}
type ListJobsTool ¶
type ListJobsTool struct {
// contains filtered or unexported fields
}
func (*ListJobsTool) Description ¶
func (t *ListJobsTool) Description() string
func (*ListJobsTool) Execute ¶
func (t *ListJobsTool) Execute(ctx context.Context, input map[string]interface{}) (interface{}, error)
func (*ListJobsTool) Metadata ¶
func (t *ListJobsTool) Metadata() types.ToolMetadata
func (*ListJobsTool) Name ¶
func (t *ListJobsTool) Name() string
func (*ListJobsTool) Schema ¶
func (t *ListJobsTool) Schema() map[string]interface{}
type ScheduleJobInput ¶
type ScheduleJobInput struct {
Name string `json:"name"`
Type string `json:"type"` // oneshot, periodic, cron
SessionID string `json:"session_id"` // Optional session ID for memory context
Schedule string `json:"schedule"` // duration or cron expression
Payload interface{} `json:"payload"` // string or object
TaskType string `json:"task_type"`
}
ScheduleJobInput defines the input for scheduling a job
type ScheduleJobTool ¶
type ScheduleJobTool struct {
// contains filtered or unexported fields
}
func (*ScheduleJobTool) Description ¶
func (t *ScheduleJobTool) Description() string
func (*ScheduleJobTool) Execute ¶
func (t *ScheduleJobTool) Execute(ctx context.Context, input map[string]interface{}) (interface{}, error)
func (*ScheduleJobTool) Metadata ¶
func (t *ScheduleJobTool) Metadata() types.ToolMetadata
func (*ScheduleJobTool) Name ¶
func (t *ScheduleJobTool) Name() string
func (*ScheduleJobTool) Schema ¶
func (t *ScheduleJobTool) Schema() map[string]interface{}
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func NewService ¶
NewService creates a new scheduler service
func (*Service) ConfigureAgent ¶
func (s *Service) ConfigureAgent( llmProvider types.LLMProvider, config *types.AgentConfig, memory types.MemoryProvider, toolRegistry *tools.Registry, skillRegistry *skills.Registry, )
ConfigureAgent configures the base components for building agents for scheduled tasks
func (*Service) ConfigureAgentWithMemoryFactory ¶
func (s *Service) ConfigureAgentWithMemoryFactory( llmProvider types.LLMProvider, config *types.AgentConfig, memoryFactory func(sessionID string) types.MemoryProvider, toolRegistry *tools.Registry, skillRegistry *skills.Registry, )
ConfigureAgentWithMemoryFactory allows associating per-session memory via factory
func (*Service) ScheduleJob ¶
ScheduleJob schedules a new job
type StopJobTool ¶
type StopJobTool struct {
// contains filtered or unexported fields
}
func (*StopJobTool) Description ¶
func (t *StopJobTool) Description() string
func (*StopJobTool) Execute ¶
func (t *StopJobTool) Execute(ctx context.Context, input map[string]interface{}) (interface{}, error)
func (*StopJobTool) Metadata ¶
func (t *StopJobTool) Metadata() types.ToolMetadata
func (*StopJobTool) Name ¶
func (t *StopJobTool) Name() string
func (*StopJobTool) Schema ¶
func (t *StopJobTool) Schema() map[string]interface{}
Source Files
Click to show internal directories.
Click to hide internal directories.