trigger

Apr 15, 2026

Changes in this version

+ func ContextIDFromContext(ctx context.Context) string

+ func WithContextID(ctx context.Context, contextID string) context.Context

+ type AgentEnqueuer func(ctx context.Context, appName, agentName, input, contextID string) error

type Option

+ func WithAppName(appName string) Option

+ func WithEnqueuer(enqueuer AgentEnqueuer) Option

Dec 27, 2025

Changes in this version

+ type Option func(*WebhookHandler)

+ func WithResultProvider(rp func(ctx context.Context, taskID string) (string, error)) Option

Dec 25, 2025

Changes in this version

+ type WebhookHandler struct

+ func NewWebhookHandler(agentName string, cfg *config.TriggerConfig, invoker AgentInvoker) (*WebhookHandler, error)

+ func (h *WebhookHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type WebhookPayloadContext struct

+ Body map[string]any

+ Fields map[string]any

+ Headers map[string]string

+ Query map[string]string

+ type WebhookResult struct

+ AgentName string

+ Error string

+ Result string

+ Status string

+ TaskID string

Dec 24, 2025

Changes in this version

+ type AgentInvoker func(ctx context.Context, agentName, input string) error

+ type Scheduler struct

+ func NewScheduler(invoker AgentInvoker) *Scheduler

+ func (s *Scheduler) RegisterAgent(agentName string, ag agent.Agent, cfg *config.TriggerConfig) error

+ func (s *Scheduler) Start()

+ func (s *Scheduler) Stop() context.Context