Documentation
¶
Index ¶
- func NewTools(s *Service) []types.Tool
- func ParseAgentInstruction(payload string) (instruction string, out xcron.AgentPayload)
- func RegisterAgentTaskHandler(s *xcron.Scheduler, agentExecutor func(input string) error)
- type AgentTaskExecutor
- type DeleteJobTool
- type ListJobsOptions
- 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) ListJobsWithOptions(ctx context.Context, opts ListJobsOptions) ([]*xcron.Job, int64, error)
- func (s *Service) ScheduleJob(ctx context.Context, input ScheduleJobInput) (string, error)
- func (s *Service) SetAgentTaskExecutor(exec AgentTaskExecutor)
- func (s *Service) StopJob(ctx context.Context, jobID string) error
- type StopJobTool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ParseAgentInstruction ¶ added in v1.9.0
func ParseAgentInstruction(payload string) (instruction string, out xcron.AgentPayload)
ParseAgentInstruction extracts user instruction and merged AgentPayload from stored job payload JSON.
Types ¶
type AgentTaskExecutor ¶ added in v1.9.0
type AgentTaskExecutor func(ctx context.Context, job *xcron.Job, instruction string, payload xcron.AgentPayload) error
AgentTaskExecutor runs a scheduled agent task outside the built-in AgentEngine (e.g. Dino / gateway).
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 ListJobsOptions ¶ added in v1.7.0
type ListJobsOptions struct {
Status []string
Type []string
SessionID string
OrderBy string
Limit int
Offset int
}
ListJobsOptions defines filter and sort for listing jobs
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"`
SessionID string `json:"session_id"`
Schedule string `json:"schedule"`
Payload interface{} `json:"payload"`
TaskType string `json:"task_type"`
ExecutionMode string `json:"execution_mode"` // "serial" to run one-at-a-time with other serial jobs
}
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) ListJobsWithOptions ¶ added in v1.7.0
func (s *Service) ListJobsWithOptions(ctx context.Context, opts ListJobsOptions) ([]*xcron.Job, int64, error)
ListJobsWithOptions returns jobs with filter and sort
func (*Service) ScheduleJob ¶
ScheduleJob schedules a new job
func (*Service) SetAgentTaskExecutor ¶ added in v1.9.0
func (s *Service) SetAgentTaskExecutor(exec AgentTaskExecutor)
SetAgentTaskExecutor registers the xcron agent handler to invoke exec instead of AgentEngine. When non-nil, scheduled tasks skip LLM-based AgentEngine and skill planner.
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.