webhook

type Algorithm string

type DeadLetterFunc func(ctx context.Context, result DeliveryResult) error

type Deliverer struct {
	// contains filtered or unexported fields
}

type DeliveryAttempt struct {
	ID             string
	Number         int
	StartedAt      time.Time
	CompletedAt    time.Time
	StatusCode     int
	Classification FailureClassification
	RetryAfter     time.Duration
	Diagnostic     string
}

type DeliveryConfig struct {
	Client           HTTPDoer
	Signer           *Signer
	EndpointPolicy   EndpointPolicy
	Retry            RetryPolicy
	Clock            func() time.Time
	Sleep            SleepFunc
	IDGenerator      func() (string, error)
	MaxRequestBytes  int64
	MaxResponseBytes int64
	MaxFanOut        int
	HeaderLimits     HeaderLimits
	DeadLetter       DeadLetterFunc
	ReplayHook       ReplayHook
	Observer         Observer
}

type DeliveryRequest struct {
	Endpoint       *url.URL
	Body           []byte
	EventID        string
	IdempotencyKey string
	Headers        http.Header
	Metadata       map[string]string
}

type DeliveryResult struct {
	ID           string
	EventID      string
	Attempts     []DeliveryAttempt
	ResponseBody []byte
}

type EndpointPolicy interface {
	Validate(ctx context.Context, endpoint *url.URL) error
}

type EndpointPolicyFunc func(ctx context.Context, endpoint *url.URL) error

type Envelope struct {
	ID       string
	Type     string
	Source   string
	Subject  string
	Time     time.Time
	Data     json.RawMessage
	Metadata map[string]string
}

type ErrorHook func(ctx context.Context, err error)

type EventIDExtractor func(request *http.Request, body []byte) (string, error)

type FailureClassification string

type FanOutResult struct {
	Result DeliveryResult
	Err    error
}

type HTTPDoer interface {
	Do(request *http.Request) (*http.Response, error)
}

type HeaderLimits struct {
	MaxSignatures int
	MaxBytes      int
}

type Message struct {
	Timestamp      time.Time
	Nonce          string
	Method         string
	Path           string
	RawQuery       string
	Host           string
	ContentType    string
	IdempotencyKey string
	Body           []byte
	Metadata       map[string]string
}

type MiddlewareConfig struct {
	Request       RequestOptions
	FailureStatus int
	OnError       ErrorHook
}

type NetIPResolver interface {
	LookupNetIP(ctx context.Context, network, host string) ([]netip.Addr, error)
}

type NonceGenerator func() (string, error)

type Observation struct {
	Operation      Operation
	Outcome        Outcome
	Reason         Reason
	Duration       time.Duration
	Algorithm      Algorithm
	StatusCode     int
	Attempt        int
	Classification FailureClassification
}

type Observer interface {
	Observe(ctx context.Context, observation Observation)
}

type ObserverFunc func(ctx context.Context, observation Observation)

type Operation string

type Outcome string

type Reason string

type ReplayHook func(ctx context.Context, originalDeliveryID, eventID string) error

type ReplayStore interface {
	CheckAndRecord(ctx context.Context, key string, expiresAt time.Time) (recorded bool, err error)
}

type RequestOptions struct {
	MaxBodyBytes int64
	HeaderLimits HeaderLimits
	Metadata     map[string]string
	EventID      EventIDExtractor
}

type RetryPolicy struct {
	MaxAttempts int
	BaseDelay   time.Duration
	MaxDelay    time.Duration
}

type SSRFPolicy struct {
	// contains filtered or unexported fields
}

type SSRFPolicyConfig struct {
	Resolver        NetIPResolver
	AllowHTTP       bool
	AllowedPrefixes []netip.Prefix
	DeniedPrefixes  []netip.Prefix
	MaxAddresses    int
}

type Signature struct {
	Version   string
	Algorithm Algorithm
	KeyID     string
	Timestamp time.Time
	Nonce     string
	Value     string
}

type Signer struct {
	// contains filtered or unexported fields
}

type SignerConfig struct {
	Algorithm      Algorithm
	Keys           []SigningKey
	Clock          func() time.Time
	NonceGenerator NonceGenerator
}

type SigningKey struct {
	ID        string
	Secret    []byte
	NotBefore time.Time
	NotAfter  time.Time
	Revoked   bool
}

type SleepFunc func(ctx context.Context, duration time.Duration) error

type Verification struct {
	KeyID     string
	Algorithm Algorithm
	Timestamp time.Time
	Nonce     string
}

type VerificationError struct {
	Kind       error
	Diagnostic string
}

type VerificationKey struct {
	ID        string
	Secret    []byte
	NotBefore time.Time
	NotAfter  time.Time
	Revoked   bool
}

type Verifier struct {
	// contains filtered or unexported fields
}

type VerifierConfig struct {
	Algorithm       Algorithm
	Keys            []VerificationKey
	Clock           func() time.Time
	Tolerance       time.Duration
	ReplayStore     ReplayStore
	ReplayTTL       time.Duration
	ReplayNamespace string
	Observer        Observer
}