Versions in this module Expand all Collapse all v0 v0.3.0 Jan 13, 2026 v0.2.0 Jan 13, 2026 v0.1.0 Jan 13, 2026 Changes in this version + const TypeAIAgentExecution + const TypeCleanup + const TypeCodeDeploy + const TypeCodeParse + const TypeCodeValidate + const TypeDataProcessing + const TypeNotify + const TypeTestSuiteRun + const TypeWebhook + func HandleAIAgentTask(ctx context.Context, t *asynq.Task) error + func HandleCleanupTask(ctx context.Context, t *asynq.Task) error + func HandleDataProcessingTask(ctx context.Context, t *asynq.Task) error + func HandleTestSuiteTask(ctx context.Context, t *asynq.Task) error + func HandleWebhookTask(ctx context.Context, t *asynq.Task) error + type AIAgentHandler struct + func NewAIAgentHandler() *AIAgentHandler + func (h *AIAgentHandler) ProcessTask(ctx context.Context, t *asynq.Task) error + type AIAgentPayload struct + AgentID string + AgentType string + CallbackURL string + Config map[string]any + Input json.RawMessage + Metadata map[string]any + Timeout time.Duration + type AIAgentResult struct + AgentID string + CompletedAt time.Time + Duration time.Duration + Metadata map[string]any + Output any + TokensUsed int + type CleanupHandler struct + func NewCleanupHandler() *CleanupHandler + func (h *CleanupHandler) ProcessTask(ctx context.Context, t *asynq.Task) error + type CleanupPayload struct + BatchSize int + DryRun bool + OlderThan time.Duration + TargetPath string + TargetTable string + Type string + type CleanupResult struct + BytesFreed int64 + CompletedAt time.Time + DryRun bool + Duration time.Duration + Errors []string + ItemsDeleted int + Type string + type DataProcessingHandler struct + func NewDataProcessingHandler() *DataProcessingHandler + func (h *DataProcessingHandler) ProcessTask(ctx context.Context, t *asynq.Task) error + type DataProcessingPayload struct + BatchSize int + DestPath string + DestType string + Format string + OperationType string + Options json.RawMessage + SourcePath string + SourceType string + Timeout time.Duration + type DataProcessingResult struct + BytesProcessed int64 + CompletedAt time.Time + Duration time.Duration + Errors []string + OperationType string + RecordsFailed int + RecordsRead int + RecordsWritten int + type RetryPolicy struct + InitialDelay time.Duration + MaxDelay time.Duration + MaxRetries int + Multiplier float64 + func DefaultRetryPolicy() RetryPolicy + type TaskResult struct + Data any + Error string + Success bool + func NewErrorResult(err error) TaskResult + func NewSuccessResult(data any) TaskResult + type TestResult struct + Duration time.Duration + Error string + Name string + Output string + Status string + TestID string + type TestSuiteHandler struct + func NewTestSuiteHandler() *TestSuiteHandler + func (h *TestSuiteHandler) ProcessTask(ctx context.Context, t *asynq.Task) error + type TestSuitePayload struct + Config map[string]any + Environment string + Parallel bool + SuiteID string + Tags []string + TestIDs []string + Timeout time.Duration + type TestSuiteResult struct + CompletedAt time.Time + Duration time.Duration + Failed int + Passed int + Skipped int + SuiteID string + Summary string + TestResults []TestResult + type WebhookHandler struct + func NewWebhookHandler() *WebhookHandler + func (h *WebhookHandler) ProcessTask(ctx context.Context, t *asynq.Task) error + type WebhookPayload struct + Body json.RawMessage + Headers map[string]string + Method string + RetryPolicy RetryPolicy + Timeout time.Duration + URL string + type WebhookResult struct + CompletedAt time.Time + Duration time.Duration + Error string + Response string + StatusCode int + Success bool + URL string
Go to main page