Versions in this module Expand all Collapse all v0 v0.1.0 Sep 7, 2026 Changes in this version + var ErrInvalidSignature = errors.New("invalid signature") + var ErrReplayedRequest = errors.New("replayed request") + func SetSecretResolver(resolver secret.Resolver) + type Config struct + DefaultParams map[string]string + MaxTimestampAge string + ParamMapping map[string]string + Path string + Secret string + SignatureHeader string + SignatureScheme string + TimestampHeader string + type FireOption func(*FireOptions) + func WithPriority(priority string) FireOption + type FireOptions struct + Priority string + type HTTP struct + func New(t *models.Trigger, opts ...Option) (*HTTP, error) + func (h *HTTP) ExtractWebhookParams(ctx context.Context, req *stdhttp.Request, body []byte) (map[string]string, error) + func (h *HTTP) Fire(ctx context.Context) error + func (h *HTTP) FireWithParams(ctx context.Context, params map[string]string, opts ...FireOption) error + func (h *HTTP) ID() uuid.UUID + func (h *HTTP) Listen(ctx context.Context) + func (h *HTTP) MergeParams(params map[string]string) map[string]string + func (h *HTTP) Path() string + type Option func(*HTTP) + func WithListJobs(fn func(context.Context, string) (models.Jobs, error)) Option + func WithNow(fn func() time.Time) Option + func WithRunJob(fn func(context.Context, *models.Job, map[string]string, string) error) Option + func WithSecretResolver(resolver secret.Resolver) Option
Go to main page