webhook

package module

Go to main page

Versions in this module

v0

deprecated

v0.4.1

Oct 15, 2026

v0.4.0

Oct 15, 2026

Changes in this version

+ const MaxDisabledReason

+ func HeadersDigest(h http.Header) string

type Call

+ HeadersSHA256 string

+ RemoteAddr string

+ func (c Call) ReceivedHeaders() http.Header

type EndpointService

+ func (s *EndpointService) DisableWithReason(ctx context.Context, actor security.Subject, id, reason string) (*Endpoint, error)

type ImportRequest

+ ConsecutiveFailures int

+ DisabledAt *time.Time

+ DisabledReason string

type Receiver

+ RefusalBody RefusalMode

+ URL URLMode

+ type RefusalMode string

+ const RefusalEmpty

+ const RefusalText

type Server

+ AllowEmptySubscription bool

+ type URLMode string

+ const URLFull

+ const URLNone

+ const URLRoute

v0.3.0

Oct 15, 2026

Changes in this version

+ const DefaultBadRequestStatus

+ const DefaultFailedStatus

+ const DefaultInvalidSignatureStatus

+ const DefaultTooLargeStatus

+ const DefaultUnavailableStatus

+ const DefaultUnresolvedStatus

+ var ErrReceiverUnavailable = errors.New("webhook: the receiver cannot resolve calls right now")

type Call

+ Reference string

+ type HeaderSecret struct

+ Header string

+ func (v HeaderSecret) Valid(r *http.Request, _ []byte, secrets hwebhook.SecretSet) bool

type Module

+ func (m *Module) ReceivePaths() []string

+ type ProcessResult struct

+ Body []byte

+ ContentType string

+ Status int

type Receiver

+ Mount string

+ Path string

+ ProcessSync SyncProcessor

+ ReencodeForm bool

+ Resolve Resolver

+ Statuses Statuses

+ type Resolution struct

+ PreviousSecrets []string

+ Reference string

+ Secret string

+ Tenant string

+ Validator SignatureValidator

+ type Resolver interface

+ Resolve func(r *http.Request) (Resolution, error)

+ type ResolverFunc func(r *http.Request) (Resolution, error)

+ func (f ResolverFunc) Resolve(r *http.Request) (Resolution, error)

+ type StandardWebhooks struct

+ Now func() time.Time

+ Tolerance time.Duration

+ func (v StandardWebhooks) Valid(r *http.Request, body []byte, secrets hwebhook.SecretSet) bool

+ type Statuses struct

+ BadRequest int

+ EmptyBody int

+ Failed int

+ InvalidSignature int

+ TooLarge int

+ Unavailable int

+ Unresolved int

+ type SyncProcessor interface

+ ProcessNow func(ctx context.Context, g security.Grant, call *Call) (ProcessResult, error)

+ type SyncProcessorFunc func(ctx context.Context, g security.Grant, call *Call) (ProcessResult, error)

+ func (f SyncProcessorFunc) ProcessNow(ctx context.Context, g security.Grant, call *Call) (ProcessResult, error)

v0.2.0

Oct 15, 2026

Changes in this version

+ const AttemptManual

+ const AttemptScheduled

+ const DefaultRetention

+ const DefaultRotationOverlap

+ const DeliverJob

+ const DeliveryClean

+ const DeliveryDelivered

+ const DeliveryDispatch

+ const DeliveryFailed

+ const DeliveryPending

+ const DeliveryProcessing

+ const DeliveryRedeliver

+ const DialectArandu

+ const DialectHMAC

+ const DialectStandardWebhooks

+ const DisabledByFailures

+ const EndpointImport

+ const EndpointRotate

+ const EventCallReprocessed

+ const EventDeliveryRedelivered

+ const EventEndpointCreated

+ const EventEndpointDeleted

+ const EventEndpointDisabled

+ const EventEndpointEnabled

+ const EventEndpointImported

+ const EventEndpointTested

+ const EventEndpointUpdated

+ const EventSecretRevealed

+ const EventSecretRotated

+ const FailureEndpointDeleted

+ const FailureRequestTooLarge

+ const FailureSecretUnavailable

+ const FailureTimeout

+ const FailureTooManyRedirects

+ const FailureTransport

+ const FailureUnsafeDestination

+ const FailureUnsupportedScheme

+ const MaxBackoff

+ const MaxPreviousSecrets

+ const MaxRedirects

+ const MaxRequestBytes

+ const MaxResponseBytes

+ const MaxTimeout

+ const MaxTries

+ const StandardHeaderID

+ const StandardHeaderSignature

+ const StandardHeaderTimestamp

+ const StandardSecretPrefix

+ var ErrDeliveryIDTaken = statusError

+ var ErrDeliveryInProgress = statusError

+ var ErrEndpointExists = statusError

+ var ErrHTTPSRequired = errors.New("webhook: the policy sends to https addresses only")

+ var ErrInvalidMessage = errors.New(...)

+ var ErrNotRedeliverable = statusError

+ var ErrPayloadTooLarge = errors.New("webhook: the body is larger than the policy's MaxRequestBytes")

+ var ErrStandardSecret = errors.New(...)

+ func SignStandard(secrets []string, id string, timestamp int64, body []byte) (string, error)

type Delivery

+ AranduHeaders Flag

+ Backoff string

+ Body string

+ BodySHA256 string

+ ClaimToken *string

+ Dialect string

+ Headers string

+ LeaseUntil *time.Time

+ MaxAttempts int64

+ NextAttemptAt *time.Time

+ SecretRef string

+ SignatureHeader string

+ func (d Delivery) Spent() bool

+ func (d Delivery) WaitAfter(n int64) time.Duration

+ func (d Delivery) Waits() []time.Duration

+ type DeliveryAttempt struct

+ Attempt int64

+ CreatedAt time.Time

+ DeliveryID string

+ DurationMS int64

+ EndpointID string

+ Error string

+ ID string

+ Response string

+ ResponseStatus *int64

+ SignedAt time.Time

+ Succeeded Flag

+ TenantID string

+ Trigger string

+ func (row *DeliveryAttempt) Fresh(ctx context.Context, g auth.Grant, with ...string) (*DeliveryAttempt, error)

+ func (row *DeliveryAttempt) Replicate(except ...string) (*DeliveryAttempt, error)

+ type DeliveryAttemptCollection []*DeliveryAttempt

+ func DeliveryAttemptCollectionOf(rows model.Rows) DeliveryAttemptCollection

+ func (c DeliveryAttemptCollection) Contains(key any) bool

+ func (c DeliveryAttemptCollection) Except(keys ...any) DeliveryAttemptCollection

+ func (c DeliveryAttemptCollection) Find(key any) *DeliveryAttempt

+ func (c DeliveryAttemptCollection) FindOrFail(key any) (*DeliveryAttempt, error)

+ func (c DeliveryAttemptCollection) Fresh(ctx context.Context, g auth.Grant, with ...string) (DeliveryAttemptCollection, error)

+ func (c DeliveryAttemptCollection) Load(ctx context.Context, g auth.Grant, relations ...string) error

+ func (c DeliveryAttemptCollection) LoadCount(ctx context.Context, g auth.Grant, relations ...string) error

+ func (c DeliveryAttemptCollection) LoadMissing(ctx context.Context, g auth.Grant, relations ...string) error

+ func (c DeliveryAttemptCollection) ModelKeys() []any

+ func (c DeliveryAttemptCollection) Only(keys ...any) DeliveryAttemptCollection

+ func (c DeliveryAttemptCollection) Pluck(column string) []any

+ func (c DeliveryAttemptCollection) Rows() model.Rows

+ func (c DeliveryAttemptCollection) ToArray() []map[string]any

+ func (c DeliveryAttemptCollection) Unique() DeliveryAttemptCollection

+ type DeliveryAttemptQuery struct

+ func DeliveryAttempts(db model.DB) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) AddSelect(columns ...any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) Avg(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *DeliveryAttemptQuery) Base() *model.Builder

+ func (q *DeliveryAttemptQuery) Chunk(ctx context.Context, g auth.Grant, count int, ...) error

+ func (q *DeliveryAttemptQuery) Clone() *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) Count(ctx context.Context, g auth.Grant, columns ...any) (int64, error)

+ func (q *DeliveryAttemptQuery) Create(ctx context.Context, g auth.Grant, attributes map[string]any) (*DeliveryAttempt, error)

+ func (q *DeliveryAttemptQuery) Cursor(ctx context.Context, g auth.Grant) iter.Seq2[*DeliveryAttempt, error]

+ func (q *DeliveryAttemptQuery) CursorPaginate(ctx context.Context, g auth.Grant, perPage int, cursor *pagination.Cursor, ...) (DeliveryAttemptCollection, *pagination.CursorPage, error)

+ func (q *DeliveryAttemptQuery) Decrement(ctx context.Context, g auth.Grant, column string, amount any, ...) (int64, error)

+ func (q *DeliveryAttemptQuery) Delete(ctx context.Context, g auth.Grant) (int64, error)

+ func (q *DeliveryAttemptQuery) DoesntExist(ctx context.Context, g auth.Grant) (bool, error)

+ func (q *DeliveryAttemptQuery) DoesntHave(relation, boolean string, callback func(*query.Builder)) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) Each(ctx context.Context, g auth.Grant, count int, ...) error

+ func (q *DeliveryAttemptQuery) Exists(ctx context.Context, g auth.Grant) (bool, error)

+ func (q *DeliveryAttemptQuery) Find(ctx context.Context, g auth.Grant, id any, columns ...any) (*DeliveryAttempt, error)

+ func (q *DeliveryAttemptQuery) FindMany(ctx context.Context, g auth.Grant, ids []any, columns ...any) (DeliveryAttemptCollection, error)

+ func (q *DeliveryAttemptQuery) FindOrFail(ctx context.Context, g auth.Grant, id any, columns ...any) (*DeliveryAttempt, error)

+ func (q *DeliveryAttemptQuery) FindOrNew(ctx context.Context, g auth.Grant, id any, columns ...any) (*DeliveryAttempt, error)

+ func (q *DeliveryAttemptQuery) First(ctx context.Context, g auth.Grant, columns ...any) (*DeliveryAttempt, error)

+ func (q *DeliveryAttemptQuery) FirstOrCreate(ctx context.Context, g auth.Grant, attributes, values map[string]any) (*DeliveryAttempt, error)

+ func (q *DeliveryAttemptQuery) FirstOrFail(ctx context.Context, g auth.Grant, columns ...any) (*DeliveryAttempt, error)

+ func (q *DeliveryAttemptQuery) FirstOrNew(ctx context.Context, g auth.Grant, attributes, values map[string]any) (*DeliveryAttempt, error)

+ func (q *DeliveryAttemptQuery) FirstWhere(ctx context.Context, g auth.Grant, column any, args ...any) (*DeliveryAttempt, error)

+ func (q *DeliveryAttemptQuery) ForPage(page, perPage int) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) ForceCreate(ctx context.Context, g auth.Grant, attributes map[string]any) (*DeliveryAttempt, error)

+ func (q *DeliveryAttemptQuery) Get(ctx context.Context, g auth.Grant, columns ...any) (DeliveryAttemptCollection, error)

+ func (q *DeliveryAttemptQuery) GroupBy(groups ...any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) Has(relation, operator string, count int, boolean string, ...) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) Increment(ctx context.Context, g auth.Grant, column string, amount any, ...) (int64, error)

+ func (q *DeliveryAttemptQuery) Insert(ctx context.Context, g auth.Grant, values ...map[string]any) (bool, error)

+ func (q *DeliveryAttemptQuery) InsertOrIgnore(ctx context.Context, g auth.Grant, values ...map[string]any) (bool, error)

+ func (q *DeliveryAttemptQuery) Join(table any, first any, args ...any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) Latest(column ...string) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) Limit(value int) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) Max(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *DeliveryAttemptQuery) Min(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *DeliveryAttemptQuery) New() (*DeliveryAttempt, error)

+ func (q *DeliveryAttemptQuery) Offset(value int) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) Oldest(column ...string) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) OrDoesntHave(relation string) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) OrHas(relation, operator string, count int) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) OrWhere(column any, args ...any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) OrWhereDoesntHave(relation string, callback func(*query.Builder)) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) OrWhereHas(relation string, callback func(*query.Builder)) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) OrWhereNot(column any, args ...any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) OrWhereRelation(relation string, column any, args ...any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) OrderBy(column any, direction ...string) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) OrderByDesc(column any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) Paginate(ctx context.Context, g auth.Grant, perPage, page int, opts pagination.Options, ...) (DeliveryAttemptCollection, *pagination.LengthAwarePage, error)

+ func (q *DeliveryAttemptQuery) Pluck(ctx context.Context, g auth.Grant, column string) ([]any, error)

+ func (q *DeliveryAttemptQuery) Select(columns ...any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) SelectRaw(expression string, bindings ...any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) SimplePaginate(ctx context.Context, g auth.Grant, perPage, page int, opts pagination.Options, ...) (DeliveryAttemptCollection, *pagination.Page, error)

+ func (q *DeliveryAttemptQuery) Sole(ctx context.Context, g auth.Grant, columns ...any) (*DeliveryAttempt, error)

+ func (q *DeliveryAttemptQuery) SoleValue(ctx context.Context, g auth.Grant, column string) (any, error)

+ func (q *DeliveryAttemptQuery) Sum(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *DeliveryAttemptQuery) Touch(ctx context.Context, g auth.Grant, column ...string) (int64, error)

+ func (q *DeliveryAttemptQuery) Update(ctx context.Context, g auth.Grant, values map[string]any) (int64, error)

+ func (q *DeliveryAttemptQuery) UpdateOrCreate(ctx context.Context, g auth.Grant, attributes, values map[string]any) (*DeliveryAttempt, error)

+ func (q *DeliveryAttemptQuery) Upsert(ctx context.Context, g auth.Grant, values []map[string]any, ...) (int64, error)

+ func (q *DeliveryAttemptQuery) Value(ctx context.Context, g auth.Grant, column string) (any, error)

+ func (q *DeliveryAttemptQuery) ValueOrFail(ctx context.Context, g auth.Grant, column string) (any, error)

+ func (q *DeliveryAttemptQuery) Where(column any, args ...any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WhereBelongsTo(relationshipName string, related ...model.Entity) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WhereBetween(column any, from, to any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WhereColumn(first any, args ...any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WhereDoesntHave(relation string, callback func(*query.Builder)) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WhereExists(callback func(*query.Builder)) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WhereHas(relation string, callback func(*query.Builder)) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WhereHasCount(relation string, callback func(*query.Builder), operator string, count int) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WhereIn(column any, values []any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WhereKey(id any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WhereNot(column any, args ...any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WhereNotExists(callback func(*query.Builder)) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WhereNotIn(column any, values []any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WhereNotNull(columns ...any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WhereNull(columns ...any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WhereRelation(relation string, column any, args ...any) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) With(relations ...string) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WithAvg(relation, column string) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WithCount(relations ...string) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WithExists(relation string) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WithMax(relation, column string) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WithMin(relation, column string) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WithSum(relation, column string) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) Without(relations ...string) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WithoutGlobalScope(identifier string) *DeliveryAttemptQuery

+ func (q *DeliveryAttemptQuery) WithoutGlobalScopes(identifiers ...string) *DeliveryAttemptQuery

+ type DeliveryAttemptResource struct

+ func NewDeliveryAttemptResource(a *DeliveryAttempt) DeliveryAttemptResource

+ func (r DeliveryAttemptResource) ToArray() map[string]any

+ func (r DeliveryAttemptResource) With() map[string]any

type Endpoint

+ AranduHeaders Flag

+ ConsecutiveFailures int

+ Dialect string

+ DisabledAt *time.Time

+ DisabledReason string

+ Policy string

+ PreviousSecrets string

+ func (e *Endpoint) Disable(reason string, now time.Time)

+ func (e *Endpoint) Enable(now time.Time)

+ func (e Endpoint) ShouldDisable(disableAfter int) bool

type EndpointRequest

+ Dialect string

+ Policy *Policy

+ ResetPolicy bool

+ WithoutAranduHeaders bool

type EndpointService

+ func (s *EndpointService) Attempts(ctx context.Context, actor security.Subject, deliveryID string) ([]*DeliveryAttempt, error)

+ func (s *EndpointService) Delivery(ctx context.Context, actor security.Subject, deliveryID string) (*Delivery, error)

+ func (s *EndpointService) Disable(ctx context.Context, actor security.Subject, id string) (*Endpoint, error)

+ func (s *EndpointService) Enable(ctx context.Context, actor security.Subject, id string) (*Endpoint, error)

+ func (s *EndpointService) Import(ctx context.Context, actor security.Subject, in ImportRequest) (*Endpoint, error)

+ func (s *EndpointService) Redeliver(ctx context.Context, actor security.Subject, deliveryID string) (*Delivery, error)

+ func (s *EndpointService) Rotate(ctx context.Context, actor security.Subject, id string, overlap time.Duration) (string, error)

+ type ImportRequest struct

+ CreatedAt time.Time

+ ID string

+ PreviousSecrets []PreviousSecret

+ Secret string

+ type Message struct

+ Body []byte

+ Event string

+ EventID string

+ ID string

type Module

+ func (m *Module) Send(ctx context.Context, g security.Grant, endpointID string, msg Message) (*Delivery, error)

type Outgoing

+ func (o *Outgoing) WithoutAranduHeaders() *Outgoing

+ type Policy struct

+ Backoff []time.Duration

+ DisableAfter int

+ HTTPSOnly bool

+ HonorRetryAfter bool

+ MaxRedirects int

+ MaxRequestBytes int64

+ MaxResponseBytes int64

+ Retry RetryMode

+ Timeout time.Duration

+ Tries int

+ UserAgent string

+ func DefaultPolicy() Policy

+ func (p Policy) Validate() error

+ type PreviousSecret struct

+ RetiresAt time.Time

+ Secret string

+ type RetryMode string

+ const RetryEveryFailure

+ const RetryTransient

type Server

+ Now func() time.Time

+ Policy *Policy

v0.1.0

Oct 14, 2026

Changes in this version

+ const AllEvents

+ const CallClean

+ const CallList

+ const CallProcess

+ const CallReceive

+ const CallView

+ const DefaultCleanSpec

+ const DefaultDeleteAfterDays

+ const DefaultEvent

+ const DefaultMaxBodyBytes

+ const DefaultPageSize

+ const DefaultPrefix

+ const DefaultQueue

+ const DefaultReceivePrefix

+ const DefaultSignatureHeader

+ const DefaultTimeout

+ const DefaultTolerance

+ const DefaultTries

+ const DefaultUserAgent

+ const EndpointCreate

+ const EndpointDelete

+ const EndpointList

+ const EndpointSecret

+ const EndpointTest

+ const EndpointUpdate

+ const EndpointView

+ const MaxHeaders

+ const MaxPageSize

+ const MinSecretBytes

+ const ProcessJob

+ const SignerArandu

+ const SignerHMAC

+ const TestEvent

+ var ErrBodyTooLarge = statusError

+ var ErrInvalidSignature = statusError

+ var ErrNoReceiver = errors.New("webhook: the call's receiver is not configured any more")

+ var ErrNotFound = fmt.Errorf("webhook: record not found: %w", model.ErrModelNotFound)

+ var ErrReservedHeader = errors.New("webhook: the header is written by the delivery itself")

+ var ErrSecretNotSet = errors.New(...)

+ var ErrURLNotSet = errors.New("webhook: the call has no URL")

+ var ErrUnknownSecret = errors.New("webhook: no secret of that name in Config.Server.Secrets")

+ func Actions() []security.Action

+ func SignBody(secret []byte, body []byte) string

+ type Arandu struct

+ HeaderPrefix string

+ Now func() time.Time

+ Tolerance time.Duration

+ func (v Arandu) Valid(r *http.Request, body []byte, secrets hwebhook.SecretSet) bool

+ type Call struct

+ Attempts int

+ CreatedAt time.Time

+ Exception string

+ HeaderData string

+ ID string

+ Method string

+ Name string

+ Payload string

+ ProcessedAt time.Time

+ Status CallStatus

+ TenantID string

+ URL string

+ UpdatedAt time.Time

+ func (c *Call) Failed(err error, now time.Time)

+ func (c *Call) Processed(now time.Time)

+ func (c Call) Body() []byte

+ func (c Call) Form() (url.Values, error)

+ func (c Call) Header(name string) string

+ func (c Call) Headers() map[string][]string

+ func (c Call) JSON(v any) error

+ func (row *Call) Fresh(ctx context.Context, g auth.Grant, with ...string) (*Call, error)

+ func (row *Call) Replicate(except ...string) (*Call, error)

+ type CallCollection []*Call

+ func CallCollectionOf(rows model.Rows) CallCollection

+ func (c CallCollection) Contains(key any) bool

+ func (c CallCollection) Except(keys ...any) CallCollection

+ func (c CallCollection) Find(key any) *Call

+ func (c CallCollection) FindOrFail(key any) (*Call, error)

+ func (c CallCollection) Fresh(ctx context.Context, g auth.Grant, with ...string) (CallCollection, error)

+ func (c CallCollection) Load(ctx context.Context, g auth.Grant, relations ...string) error

+ func (c CallCollection) LoadCount(ctx context.Context, g auth.Grant, relations ...string) error

+ func (c CallCollection) LoadMissing(ctx context.Context, g auth.Grant, relations ...string) error

+ func (c CallCollection) ModelKeys() []any

+ func (c CallCollection) Only(keys ...any) CallCollection

+ func (c CallCollection) Pluck(column string) []any

+ func (c CallCollection) Rows() model.Rows

+ func (c CallCollection) ToArray() []map[string]any

+ func (c CallCollection) Unique() CallCollection

+ type CallFilter struct

+ Name string

+ Status CallStatus

+ type CallPolicy struct

+ func (CallPolicy) Can(_ context.Context, s security.Subject, a security.Action, record Call) error

+ type CallQuery struct

+ func Calls(db model.DB) *CallQuery

+ func (q *CallQuery) AddSelect(columns ...any) *CallQuery

+ func (q *CallQuery) Avg(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *CallQuery) Base() *model.Builder

+ func (q *CallQuery) Chunk(ctx context.Context, g auth.Grant, count int, ...) error

+ func (q *CallQuery) Clone() *CallQuery

+ func (q *CallQuery) Count(ctx context.Context, g auth.Grant, columns ...any) (int64, error)

+ func (q *CallQuery) Create(ctx context.Context, g auth.Grant, attributes map[string]any) (*Call, error)

+ func (q *CallQuery) Cursor(ctx context.Context, g auth.Grant) iter.Seq2[*Call, error]

+ func (q *CallQuery) CursorPaginate(ctx context.Context, g auth.Grant, perPage int, cursor *pagination.Cursor, ...) (CallCollection, *pagination.CursorPage, error)

+ func (q *CallQuery) Decrement(ctx context.Context, g auth.Grant, column string, amount any, ...) (int64, error)

+ func (q *CallQuery) Delete(ctx context.Context, g auth.Grant) (int64, error)

+ func (q *CallQuery) DoesntExist(ctx context.Context, g auth.Grant) (bool, error)

+ func (q *CallQuery) DoesntHave(relation, boolean string, callback func(*query.Builder)) *CallQuery

+ func (q *CallQuery) Each(ctx context.Context, g auth.Grant, count int, ...) error

+ func (q *CallQuery) Exists(ctx context.Context, g auth.Grant) (bool, error)

+ func (q *CallQuery) Find(ctx context.Context, g auth.Grant, id any, columns ...any) (*Call, error)

+ func (q *CallQuery) FindMany(ctx context.Context, g auth.Grant, ids []any, columns ...any) (CallCollection, error)

+ func (q *CallQuery) FindOrFail(ctx context.Context, g auth.Grant, id any, columns ...any) (*Call, error)

+ func (q *CallQuery) FindOrNew(ctx context.Context, g auth.Grant, id any, columns ...any) (*Call, error)

+ func (q *CallQuery) First(ctx context.Context, g auth.Grant, columns ...any) (*Call, error)

+ func (q *CallQuery) FirstOrCreate(ctx context.Context, g auth.Grant, attributes, values map[string]any) (*Call, error)

+ func (q *CallQuery) FirstOrFail(ctx context.Context, g auth.Grant, columns ...any) (*Call, error)

+ func (q *CallQuery) FirstOrNew(ctx context.Context, g auth.Grant, attributes, values map[string]any) (*Call, error)

+ func (q *CallQuery) FirstWhere(ctx context.Context, g auth.Grant, column any, args ...any) (*Call, error)

+ func (q *CallQuery) ForPage(page, perPage int) *CallQuery

+ func (q *CallQuery) ForceCreate(ctx context.Context, g auth.Grant, attributes map[string]any) (*Call, error)

+ func (q *CallQuery) Get(ctx context.Context, g auth.Grant, columns ...any) (CallCollection, error)

+ func (q *CallQuery) GroupBy(groups ...any) *CallQuery

+ func (q *CallQuery) Has(relation, operator string, count int, boolean string, ...) *CallQuery

+ func (q *CallQuery) Increment(ctx context.Context, g auth.Grant, column string, amount any, ...) (int64, error)

+ func (q *CallQuery) Insert(ctx context.Context, g auth.Grant, values ...map[string]any) (bool, error)

+ func (q *CallQuery) InsertOrIgnore(ctx context.Context, g auth.Grant, values ...map[string]any) (bool, error)

+ func (q *CallQuery) Join(table any, first any, args ...any) *CallQuery

+ func (q *CallQuery) Latest(column ...string) *CallQuery

+ func (q *CallQuery) Limit(value int) *CallQuery

+ func (q *CallQuery) Max(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *CallQuery) Min(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *CallQuery) New() (*Call, error)

+ func (q *CallQuery) Offset(value int) *CallQuery

+ func (q *CallQuery) Oldest(column ...string) *CallQuery

+ func (q *CallQuery) OrDoesntHave(relation string) *CallQuery

+ func (q *CallQuery) OrHas(relation, operator string, count int) *CallQuery

+ func (q *CallQuery) OrWhere(column any, args ...any) *CallQuery

+ func (q *CallQuery) OrWhereDoesntHave(relation string, callback func(*query.Builder)) *CallQuery

+ func (q *CallQuery) OrWhereHas(relation string, callback func(*query.Builder)) *CallQuery

+ func (q *CallQuery) OrWhereNot(column any, args ...any) *CallQuery

+ func (q *CallQuery) OrWhereRelation(relation string, column any, args ...any) *CallQuery

+ func (q *CallQuery) OrderBy(column any, direction ...string) *CallQuery

+ func (q *CallQuery) OrderByDesc(column any) *CallQuery

+ func (q *CallQuery) Paginate(ctx context.Context, g auth.Grant, perPage, page int, opts pagination.Options, ...) (CallCollection, *pagination.LengthAwarePage, error)

+ func (q *CallQuery) Pluck(ctx context.Context, g auth.Grant, column string) ([]any, error)

+ func (q *CallQuery) Select(columns ...any) *CallQuery

+ func (q *CallQuery) SelectRaw(expression string, bindings ...any) *CallQuery

+ func (q *CallQuery) SimplePaginate(ctx context.Context, g auth.Grant, perPage, page int, opts pagination.Options, ...) (CallCollection, *pagination.Page, error)

+ func (q *CallQuery) Sole(ctx context.Context, g auth.Grant, columns ...any) (*Call, error)

+ func (q *CallQuery) SoleValue(ctx context.Context, g auth.Grant, column string) (any, error)

+ func (q *CallQuery) Sum(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *CallQuery) Touch(ctx context.Context, g auth.Grant, column ...string) (int64, error)

+ func (q *CallQuery) Update(ctx context.Context, g auth.Grant, values map[string]any) (int64, error)

+ func (q *CallQuery) UpdateOrCreate(ctx context.Context, g auth.Grant, attributes, values map[string]any) (*Call, error)

+ func (q *CallQuery) Upsert(ctx context.Context, g auth.Grant, values []map[string]any, ...) (int64, error)

+ func (q *CallQuery) Value(ctx context.Context, g auth.Grant, column string) (any, error)

+ func (q *CallQuery) ValueOrFail(ctx context.Context, g auth.Grant, column string) (any, error)

+ func (q *CallQuery) Where(column any, args ...any) *CallQuery

+ func (q *CallQuery) WhereBelongsTo(relationshipName string, related ...model.Entity) *CallQuery

+ func (q *CallQuery) WhereBetween(column any, from, to any) *CallQuery

+ func (q *CallQuery) WhereColumn(first any, args ...any) *CallQuery

+ func (q *CallQuery) WhereDoesntHave(relation string, callback func(*query.Builder)) *CallQuery

+ func (q *CallQuery) WhereExists(callback func(*query.Builder)) *CallQuery

+ func (q *CallQuery) WhereHas(relation string, callback func(*query.Builder)) *CallQuery

+ func (q *CallQuery) WhereHasCount(relation string, callback func(*query.Builder), operator string, count int) *CallQuery

+ func (q *CallQuery) WhereIn(column any, values []any) *CallQuery

+ func (q *CallQuery) WhereKey(id any) *CallQuery

+ func (q *CallQuery) WhereNot(column any, args ...any) *CallQuery

+ func (q *CallQuery) WhereNotExists(callback func(*query.Builder)) *CallQuery

+ func (q *CallQuery) WhereNotIn(column any, values []any) *CallQuery

+ func (q *CallQuery) WhereNotNull(columns ...any) *CallQuery

+ func (q *CallQuery) WhereNull(columns ...any) *CallQuery

+ func (q *CallQuery) WhereRelation(relation string, column any, args ...any) *CallQuery

+ func (q *CallQuery) With(relations ...string) *CallQuery

+ func (q *CallQuery) WithAvg(relation, column string) *CallQuery

+ func (q *CallQuery) WithCount(relations ...string) *CallQuery

+ func (q *CallQuery) WithExists(relation string) *CallQuery

+ func (q *CallQuery) WithMax(relation, column string) *CallQuery

+ func (q *CallQuery) WithMin(relation, column string) *CallQuery

+ func (q *CallQuery) WithSum(relation, column string) *CallQuery

+ func (q *CallQuery) Without(relations ...string) *CallQuery

+ func (q *CallQuery) WithoutGlobalScope(identifier string) *CallQuery

+ func (q *CallQuery) WithoutGlobalScopes(identifiers ...string) *CallQuery

+ type CallResource struct

+ func NewCallResource(c *Call) CallResource

+ func (r CallResource) ToArray() map[string]any

+ func (r CallResource) With() map[string]any

+ type CallService struct

+ func (s *CallService) Find(ctx context.Context, actor security.Subject, id string) (*Call, error)

+ func (s *CallService) List(ctx context.Context, actor security.Subject, filter CallFilter, q data.Query) ([]*Call, error)

+ func (s *CallService) Process(ctx context.Context, actor security.Subject, id string) error

+ type CallStatus string

+ const CallFailed

+ const CallProcessed

+ const CallReceived

+ type Config struct

+ CleanSpec string

+ DeleteAfterDays int

+ Key []byte

+ PageSize int

+ Prefix string

+ ReceivePrefix string

+ Receivers []Receiver

+ Server Server

+ func (c Config) Validate() error

+ type Delivery struct

+ Attempts int64

+ CreatedAt time.Time

+ DeliveredAt *time.Time

+ EndpointID string

+ EventID string

+ EventName string

+ ID string

+ LastError *string

+ Permanent Flag

+ ResponseStatus *int64

+ Status string

+ TenantID string

+ URL string

+ UpdatedAt time.Time

+ func (row *Delivery) Fresh(ctx context.Context, g auth.Grant, with ...string) (*Delivery, error)

+ func (row *Delivery) Replicate(except ...string) (*Delivery, error)

+ type DeliveryCollection []*Delivery

+ func DeliveryCollectionOf(rows model.Rows) DeliveryCollection

+ func (c DeliveryCollection) Contains(key any) bool

+ func (c DeliveryCollection) Except(keys ...any) DeliveryCollection

+ func (c DeliveryCollection) Find(key any) *Delivery

+ func (c DeliveryCollection) FindOrFail(key any) (*Delivery, error)

+ func (c DeliveryCollection) Fresh(ctx context.Context, g auth.Grant, with ...string) (DeliveryCollection, error)

+ func (c DeliveryCollection) Load(ctx context.Context, g auth.Grant, relations ...string) error

+ func (c DeliveryCollection) LoadCount(ctx context.Context, g auth.Grant, relations ...string) error

+ func (c DeliveryCollection) LoadMissing(ctx context.Context, g auth.Grant, relations ...string) error

+ func (c DeliveryCollection) ModelKeys() []any

+ func (c DeliveryCollection) Only(keys ...any) DeliveryCollection

+ func (c DeliveryCollection) Pluck(column string) []any

+ func (c DeliveryCollection) Rows() model.Rows

+ func (c DeliveryCollection) ToArray() []map[string]any

+ func (c DeliveryCollection) Unique() DeliveryCollection

+ type DeliveryQuery struct

+ func Deliveries(db model.DB) *DeliveryQuery

+ func (q *DeliveryQuery) AddSelect(columns ...any) *DeliveryQuery

+ func (q *DeliveryQuery) Avg(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *DeliveryQuery) Base() *model.Builder

+ func (q *DeliveryQuery) Chunk(ctx context.Context, g auth.Grant, count int, ...) error

+ func (q *DeliveryQuery) Clone() *DeliveryQuery

+ func (q *DeliveryQuery) Count(ctx context.Context, g auth.Grant, columns ...any) (int64, error)

+ func (q *DeliveryQuery) Create(ctx context.Context, g auth.Grant, attributes map[string]any) (*Delivery, error)

+ func (q *DeliveryQuery) Cursor(ctx context.Context, g auth.Grant) iter.Seq2[*Delivery, error]

+ func (q *DeliveryQuery) CursorPaginate(ctx context.Context, g auth.Grant, perPage int, cursor *pagination.Cursor, ...) (DeliveryCollection, *pagination.CursorPage, error)

+ func (q *DeliveryQuery) Decrement(ctx context.Context, g auth.Grant, column string, amount any, ...) (int64, error)

+ func (q *DeliveryQuery) Delete(ctx context.Context, g auth.Grant) (int64, error)

+ func (q *DeliveryQuery) DoesntExist(ctx context.Context, g auth.Grant) (bool, error)

+ func (q *DeliveryQuery) DoesntHave(relation, boolean string, callback func(*query.Builder)) *DeliveryQuery

+ func (q *DeliveryQuery) Each(ctx context.Context, g auth.Grant, count int, ...) error

+ func (q *DeliveryQuery) Exists(ctx context.Context, g auth.Grant) (bool, error)

+ func (q *DeliveryQuery) Find(ctx context.Context, g auth.Grant, id any, columns ...any) (*Delivery, error)

+ func (q *DeliveryQuery) FindMany(ctx context.Context, g auth.Grant, ids []any, columns ...any) (DeliveryCollection, error)

+ func (q *DeliveryQuery) FindOrFail(ctx context.Context, g auth.Grant, id any, columns ...any) (*Delivery, error)

+ func (q *DeliveryQuery) FindOrNew(ctx context.Context, g auth.Grant, id any, columns ...any) (*Delivery, error)

+ func (q *DeliveryQuery) First(ctx context.Context, g auth.Grant, columns ...any) (*Delivery, error)

+ func (q *DeliveryQuery) FirstOrCreate(ctx context.Context, g auth.Grant, attributes, values map[string]any) (*Delivery, error)

+ func (q *DeliveryQuery) FirstOrFail(ctx context.Context, g auth.Grant, columns ...any) (*Delivery, error)

+ func (q *DeliveryQuery) FirstOrNew(ctx context.Context, g auth.Grant, attributes, values map[string]any) (*Delivery, error)

+ func (q *DeliveryQuery) FirstWhere(ctx context.Context, g auth.Grant, column any, args ...any) (*Delivery, error)

+ func (q *DeliveryQuery) ForPage(page, perPage int) *DeliveryQuery

+ func (q *DeliveryQuery) ForceCreate(ctx context.Context, g auth.Grant, attributes map[string]any) (*Delivery, error)

+ func (q *DeliveryQuery) Get(ctx context.Context, g auth.Grant, columns ...any) (DeliveryCollection, error)

+ func (q *DeliveryQuery) GroupBy(groups ...any) *DeliveryQuery

+ func (q *DeliveryQuery) Has(relation, operator string, count int, boolean string, ...) *DeliveryQuery

+ func (q *DeliveryQuery) Increment(ctx context.Context, g auth.Grant, column string, amount any, ...) (int64, error)

+ func (q *DeliveryQuery) Insert(ctx context.Context, g auth.Grant, values ...map[string]any) (bool, error)

+ func (q *DeliveryQuery) InsertOrIgnore(ctx context.Context, g auth.Grant, values ...map[string]any) (bool, error)

+ func (q *DeliveryQuery) Join(table any, first any, args ...any) *DeliveryQuery

+ func (q *DeliveryQuery) Latest(column ...string) *DeliveryQuery

+ func (q *DeliveryQuery) Limit(value int) *DeliveryQuery

+ func (q *DeliveryQuery) Max(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *DeliveryQuery) Min(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *DeliveryQuery) New() (*Delivery, error)

+ func (q *DeliveryQuery) Offset(value int) *DeliveryQuery

+ func (q *DeliveryQuery) Oldest(column ...string) *DeliveryQuery

+ func (q *DeliveryQuery) OrDoesntHave(relation string) *DeliveryQuery

+ func (q *DeliveryQuery) OrHas(relation, operator string, count int) *DeliveryQuery

+ func (q *DeliveryQuery) OrWhere(column any, args ...any) *DeliveryQuery

+ func (q *DeliveryQuery) OrWhereDoesntHave(relation string, callback func(*query.Builder)) *DeliveryQuery

+ func (q *DeliveryQuery) OrWhereHas(relation string, callback func(*query.Builder)) *DeliveryQuery

+ func (q *DeliveryQuery) OrWhereNot(column any, args ...any) *DeliveryQuery

+ func (q *DeliveryQuery) OrWhereRelation(relation string, column any, args ...any) *DeliveryQuery

+ func (q *DeliveryQuery) OrderBy(column any, direction ...string) *DeliveryQuery

+ func (q *DeliveryQuery) OrderByDesc(column any) *DeliveryQuery

+ func (q *DeliveryQuery) Paginate(ctx context.Context, g auth.Grant, perPage, page int, opts pagination.Options, ...) (DeliveryCollection, *pagination.LengthAwarePage, error)

+ func (q *DeliveryQuery) Pluck(ctx context.Context, g auth.Grant, column string) ([]any, error)

+ func (q *DeliveryQuery) Select(columns ...any) *DeliveryQuery

+ func (q *DeliveryQuery) SelectRaw(expression string, bindings ...any) *DeliveryQuery

+ func (q *DeliveryQuery) SimplePaginate(ctx context.Context, g auth.Grant, perPage, page int, opts pagination.Options, ...) (DeliveryCollection, *pagination.Page, error)

+ func (q *DeliveryQuery) Sole(ctx context.Context, g auth.Grant, columns ...any) (*Delivery, error)

+ func (q *DeliveryQuery) SoleValue(ctx context.Context, g auth.Grant, column string) (any, error)

+ func (q *DeliveryQuery) Sum(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *DeliveryQuery) Touch(ctx context.Context, g auth.Grant, column ...string) (int64, error)

+ func (q *DeliveryQuery) Update(ctx context.Context, g auth.Grant, values map[string]any) (int64, error)

+ func (q *DeliveryQuery) UpdateOrCreate(ctx context.Context, g auth.Grant, attributes, values map[string]any) (*Delivery, error)

+ func (q *DeliveryQuery) Upsert(ctx context.Context, g auth.Grant, values []map[string]any, ...) (int64, error)

+ func (q *DeliveryQuery) Value(ctx context.Context, g auth.Grant, column string) (any, error)

+ func (q *DeliveryQuery) ValueOrFail(ctx context.Context, g auth.Grant, column string) (any, error)

+ func (q *DeliveryQuery) Where(column any, args ...any) *DeliveryQuery

+ func (q *DeliveryQuery) WhereBelongsTo(relationshipName string, related ...model.Entity) *DeliveryQuery

+ func (q *DeliveryQuery) WhereBetween(column any, from, to any) *DeliveryQuery

+ func (q *DeliveryQuery) WhereColumn(first any, args ...any) *DeliveryQuery

+ func (q *DeliveryQuery) WhereDoesntHave(relation string, callback func(*query.Builder)) *DeliveryQuery

+ func (q *DeliveryQuery) WhereExists(callback func(*query.Builder)) *DeliveryQuery

+ func (q *DeliveryQuery) WhereHas(relation string, callback func(*query.Builder)) *DeliveryQuery

+ func (q *DeliveryQuery) WhereHasCount(relation string, callback func(*query.Builder), operator string, count int) *DeliveryQuery

+ func (q *DeliveryQuery) WhereIn(column any, values []any) *DeliveryQuery

+ func (q *DeliveryQuery) WhereKey(id any) *DeliveryQuery

+ func (q *DeliveryQuery) WhereNot(column any, args ...any) *DeliveryQuery

+ func (q *DeliveryQuery) WhereNotExists(callback func(*query.Builder)) *DeliveryQuery

+ func (q *DeliveryQuery) WhereNotIn(column any, values []any) *DeliveryQuery

+ func (q *DeliveryQuery) WhereNotNull(columns ...any) *DeliveryQuery

+ func (q *DeliveryQuery) WhereNull(columns ...any) *DeliveryQuery

+ func (q *DeliveryQuery) WhereRelation(relation string, column any, args ...any) *DeliveryQuery

+ func (q *DeliveryQuery) With(relations ...string) *DeliveryQuery

+ func (q *DeliveryQuery) WithAvg(relation, column string) *DeliveryQuery

+ func (q *DeliveryQuery) WithCount(relations ...string) *DeliveryQuery

+ func (q *DeliveryQuery) WithExists(relation string) *DeliveryQuery

+ func (q *DeliveryQuery) WithMax(relation, column string) *DeliveryQuery

+ func (q *DeliveryQuery) WithMin(relation, column string) *DeliveryQuery

+ func (q *DeliveryQuery) WithSum(relation, column string) *DeliveryQuery

+ func (q *DeliveryQuery) Without(relations ...string) *DeliveryQuery

+ func (q *DeliveryQuery) WithoutGlobalScope(identifier string) *DeliveryQuery

+ func (q *DeliveryQuery) WithoutGlobalScopes(identifiers ...string) *DeliveryQuery

+ type DeliveryResource struct

+ func NewDeliveryResource(d *Delivery) DeliveryResource

+ func (r DeliveryResource) ToArray() map[string]any

+ func (r DeliveryResource) With() map[string]any

+ type Endpoint struct

+ Active Flag

+ CreatedAt time.Time

+ Events string

+ Headers string

+ ID string

+ Name string

+ Secret string

+ SignatureHeader string

+ Signer string

+ TenantID string

+ URL string

+ UpdatedAt time.Time

+ func (e Endpoint) EventList() []string

+ func (e Endpoint) Receives(event string) bool

+ func (row *Endpoint) Fresh(ctx context.Context, g auth.Grant, with ...string) (*Endpoint, error)

+ func (row *Endpoint) Replicate(except ...string) (*Endpoint, error)

+ type EndpointCollection []*Endpoint

+ func EndpointCollectionOf(rows model.Rows) EndpointCollection

+ func (c EndpointCollection) Contains(key any) bool

+ func (c EndpointCollection) Except(keys ...any) EndpointCollection

+ func (c EndpointCollection) Find(key any) *Endpoint

+ func (c EndpointCollection) FindOrFail(key any) (*Endpoint, error)

+ func (c EndpointCollection) Fresh(ctx context.Context, g auth.Grant, with ...string) (EndpointCollection, error)

+ func (c EndpointCollection) Load(ctx context.Context, g auth.Grant, relations ...string) error

+ func (c EndpointCollection) LoadCount(ctx context.Context, g auth.Grant, relations ...string) error

+ func (c EndpointCollection) LoadMissing(ctx context.Context, g auth.Grant, relations ...string) error

+ func (c EndpointCollection) ModelKeys() []any

+ func (c EndpointCollection) Only(keys ...any) EndpointCollection

+ func (c EndpointCollection) Pluck(column string) []any

+ func (c EndpointCollection) Rows() model.Rows

+ func (c EndpointCollection) ToArray() []map[string]any

+ func (c EndpointCollection) Unique() EndpointCollection

+ type EndpointPolicy struct

+ func (EndpointPolicy) Can(_ context.Context, s security.Subject, a security.Action, record Endpoint) error

+ type EndpointQuery struct

+ func Endpoints(db model.DB) *EndpointQuery

+ func (q *EndpointQuery) AddSelect(columns ...any) *EndpointQuery

+ func (q *EndpointQuery) Avg(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *EndpointQuery) Base() *model.Builder

+ func (q *EndpointQuery) Chunk(ctx context.Context, g auth.Grant, count int, ...) error

+ func (q *EndpointQuery) Clone() *EndpointQuery

+ func (q *EndpointQuery) Count(ctx context.Context, g auth.Grant, columns ...any) (int64, error)

+ func (q *EndpointQuery) Create(ctx context.Context, g auth.Grant, attributes map[string]any) (*Endpoint, error)

+ func (q *EndpointQuery) Cursor(ctx context.Context, g auth.Grant) iter.Seq2[*Endpoint, error]

+ func (q *EndpointQuery) CursorPaginate(ctx context.Context, g auth.Grant, perPage int, cursor *pagination.Cursor, ...) (EndpointCollection, *pagination.CursorPage, error)

+ func (q *EndpointQuery) Decrement(ctx context.Context, g auth.Grant, column string, amount any, ...) (int64, error)

+ func (q *EndpointQuery) Delete(ctx context.Context, g auth.Grant) (int64, error)

+ func (q *EndpointQuery) DoesntExist(ctx context.Context, g auth.Grant) (bool, error)

+ func (q *EndpointQuery) DoesntHave(relation, boolean string, callback func(*query.Builder)) *EndpointQuery

+ func (q *EndpointQuery) Each(ctx context.Context, g auth.Grant, count int, ...) error

+ func (q *EndpointQuery) Exists(ctx context.Context, g auth.Grant) (bool, error)

+ func (q *EndpointQuery) Find(ctx context.Context, g auth.Grant, id any, columns ...any) (*Endpoint, error)

+ func (q *EndpointQuery) FindMany(ctx context.Context, g auth.Grant, ids []any, columns ...any) (EndpointCollection, error)

+ func (q *EndpointQuery) FindOrFail(ctx context.Context, g auth.Grant, id any, columns ...any) (*Endpoint, error)

+ func (q *EndpointQuery) FindOrNew(ctx context.Context, g auth.Grant, id any, columns ...any) (*Endpoint, error)

+ func (q *EndpointQuery) First(ctx context.Context, g auth.Grant, columns ...any) (*Endpoint, error)

+ func (q *EndpointQuery) FirstOrCreate(ctx context.Context, g auth.Grant, attributes, values map[string]any) (*Endpoint, error)

+ func (q *EndpointQuery) FirstOrFail(ctx context.Context, g auth.Grant, columns ...any) (*Endpoint, error)

+ func (q *EndpointQuery) FirstOrNew(ctx context.Context, g auth.Grant, attributes, values map[string]any) (*Endpoint, error)

+ func (q *EndpointQuery) FirstWhere(ctx context.Context, g auth.Grant, column any, args ...any) (*Endpoint, error)

+ func (q *EndpointQuery) ForPage(page, perPage int) *EndpointQuery

+ func (q *EndpointQuery) ForceCreate(ctx context.Context, g auth.Grant, attributes map[string]any) (*Endpoint, error)

+ func (q *EndpointQuery) Get(ctx context.Context, g auth.Grant, columns ...any) (EndpointCollection, error)

+ func (q *EndpointQuery) GroupBy(groups ...any) *EndpointQuery

+ func (q *EndpointQuery) Has(relation, operator string, count int, boolean string, ...) *EndpointQuery

+ func (q *EndpointQuery) Increment(ctx context.Context, g auth.Grant, column string, amount any, ...) (int64, error)

+ func (q *EndpointQuery) Insert(ctx context.Context, g auth.Grant, values ...map[string]any) (bool, error)

+ func (q *EndpointQuery) InsertOrIgnore(ctx context.Context, g auth.Grant, values ...map[string]any) (bool, error)

+ func (q *EndpointQuery) Join(table any, first any, args ...any) *EndpointQuery

+ func (q *EndpointQuery) Latest(column ...string) *EndpointQuery

+ func (q *EndpointQuery) Limit(value int) *EndpointQuery

+ func (q *EndpointQuery) Max(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *EndpointQuery) Min(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *EndpointQuery) New() (*Endpoint, error)

+ func (q *EndpointQuery) Offset(value int) *EndpointQuery

+ func (q *EndpointQuery) Oldest(column ...string) *EndpointQuery

+ func (q *EndpointQuery) OrDoesntHave(relation string) *EndpointQuery

+ func (q *EndpointQuery) OrHas(relation, operator string, count int) *EndpointQuery

+ func (q *EndpointQuery) OrWhere(column any, args ...any) *EndpointQuery

+ func (q *EndpointQuery) OrWhereDoesntHave(relation string, callback func(*query.Builder)) *EndpointQuery

+ func (q *EndpointQuery) OrWhereHas(relation string, callback func(*query.Builder)) *EndpointQuery

+ func (q *EndpointQuery) OrWhereNot(column any, args ...any) *EndpointQuery

+ func (q *EndpointQuery) OrWhereRelation(relation string, column any, args ...any) *EndpointQuery

+ func (q *EndpointQuery) OrderBy(column any, direction ...string) *EndpointQuery

+ func (q *EndpointQuery) OrderByDesc(column any) *EndpointQuery

+ func (q *EndpointQuery) Paginate(ctx context.Context, g auth.Grant, perPage, page int, opts pagination.Options, ...) (EndpointCollection, *pagination.LengthAwarePage, error)

+ func (q *EndpointQuery) Pluck(ctx context.Context, g auth.Grant, column string) ([]any, error)

+ func (q *EndpointQuery) Select(columns ...any) *EndpointQuery

+ func (q *EndpointQuery) SelectRaw(expression string, bindings ...any) *EndpointQuery

+ func (q *EndpointQuery) SimplePaginate(ctx context.Context, g auth.Grant, perPage, page int, opts pagination.Options, ...) (EndpointCollection, *pagination.Page, error)

+ func (q *EndpointQuery) Sole(ctx context.Context, g auth.Grant, columns ...any) (*Endpoint, error)

+ func (q *EndpointQuery) SoleValue(ctx context.Context, g auth.Grant, column string) (any, error)

+ func (q *EndpointQuery) Sum(ctx context.Context, g auth.Grant, column any) (any, error)

+ func (q *EndpointQuery) Touch(ctx context.Context, g auth.Grant, column ...string) (int64, error)

+ func (q *EndpointQuery) Update(ctx context.Context, g auth.Grant, values map[string]any) (int64, error)

+ func (q *EndpointQuery) UpdateOrCreate(ctx context.Context, g auth.Grant, attributes, values map[string]any) (*Endpoint, error)

+ func (q *EndpointQuery) Upsert(ctx context.Context, g auth.Grant, values []map[string]any, ...) (int64, error)

+ func (q *EndpointQuery) Value(ctx context.Context, g auth.Grant, column string) (any, error)

+ func (q *EndpointQuery) ValueOrFail(ctx context.Context, g auth.Grant, column string) (any, error)

+ func (q *EndpointQuery) Where(column any, args ...any) *EndpointQuery

+ func (q *EndpointQuery) WhereBelongsTo(relationshipName string, related ...model.Entity) *EndpointQuery

+ func (q *EndpointQuery) WhereBetween(column any, from, to any) *EndpointQuery

+ func (q *EndpointQuery) WhereColumn(first any, args ...any) *EndpointQuery

+ func (q *EndpointQuery) WhereDoesntHave(relation string, callback func(*query.Builder)) *EndpointQuery

+ func (q *EndpointQuery) WhereExists(callback func(*query.Builder)) *EndpointQuery

+ func (q *EndpointQuery) WhereHas(relation string, callback func(*query.Builder)) *EndpointQuery

+ func (q *EndpointQuery) WhereHasCount(relation string, callback func(*query.Builder), operator string, count int) *EndpointQuery

+ func (q *EndpointQuery) WhereIn(column any, values []any) *EndpointQuery

+ func (q *EndpointQuery) WhereKey(id any) *EndpointQuery

+ func (q *EndpointQuery) WhereNot(column any, args ...any) *EndpointQuery

+ func (q *EndpointQuery) WhereNotExists(callback func(*query.Builder)) *EndpointQuery

+ func (q *EndpointQuery) WhereNotIn(column any, values []any) *EndpointQuery

+ func (q *EndpointQuery) WhereNotNull(columns ...any) *EndpointQuery

+ func (q *EndpointQuery) WhereNull(columns ...any) *EndpointQuery

+ func (q *EndpointQuery) WhereRelation(relation string, column any, args ...any) *EndpointQuery

+ func (q *EndpointQuery) With(relations ...string) *EndpointQuery

+ func (q *EndpointQuery) WithAvg(relation, column string) *EndpointQuery

+ func (q *EndpointQuery) WithCount(relations ...string) *EndpointQuery

+ func (q *EndpointQuery) WithExists(relation string) *EndpointQuery

+ func (q *EndpointQuery) WithMax(relation, column string) *EndpointQuery

+ func (q *EndpointQuery) WithMin(relation, column string) *EndpointQuery

+ func (q *EndpointQuery) WithSum(relation, column string) *EndpointQuery

+ func (q *EndpointQuery) Without(relations ...string) *EndpointQuery

+ func (q *EndpointQuery) WithoutGlobalScope(identifier string) *EndpointQuery

+ func (q *EndpointQuery) WithoutGlobalScopes(identifiers ...string) *EndpointQuery

+ type EndpointRequest struct

+ Active bool

+ Events []string

+ Headers string

+ Name string

+ SignatureHeader string

+ Signer string

+ URL string

+ type EndpointResource struct

+ func NewEndpointResource(e *Endpoint) EndpointResource

+ func (r EndpointResource) ToArray() map[string]any

+ func (r EndpointResource) With() map[string]any

+ type EndpointService struct

+ func (s *EndpointService) Create(ctx context.Context, actor security.Subject, in EndpointRequest) (*Endpoint, string, error)

+ func (s *EndpointService) Delete(ctx context.Context, actor security.Subject, id string) error

+ func (s *EndpointService) Deliveries(ctx context.Context, actor security.Subject, id string, limit int) ([]*Delivery, error)

+ func (s *EndpointService) Find(ctx context.Context, actor security.Subject, id string) (*Endpoint, error)

+ func (s *EndpointService) HeaderNames(ctx context.Context, actor security.Subject, id string) ([]string, error)

+ func (s *EndpointService) List(ctx context.Context, actor security.Subject, q data.Query) ([]*Endpoint, error)

+ func (s *EndpointService) Secret(ctx context.Context, actor security.Subject, id string) (string, error)

+ func (s *EndpointService) Test(ctx context.Context, actor security.Subject, id string) error

+ func (s *EndpointService) Update(ctx context.Context, actor security.Subject, id string, in EndpointRequest) (*Endpoint, error)

+ type Flag bool

+ func (f *Flag) Scan(value any) error

+ func (f Flag) Value() (driver.Value, error)

+ type HMAC struct

+ Header string

+ Prefix string

+ func (v HMAC) Valid(r *http.Request, body []byte, secrets hwebhook.SecretSet) bool

+ type Module struct

+ func New(cfg Config, db *data.DB, sessions *security.SessionStore) (*Module, error)

+ func (m *Module) CallService() *CallService

+ func (m *Module) EndpointService() *EndpointService

+ func (m *Module) Manager() *hwebhook.Manager

+ func (m *Module) Migrations() []foundation.Migration

+ func (m *Module) Name() string

+ func (m *Module) Outgoing() *Outgoing

+ func (m *Module) Publisher() events.Publisher

+ func (m *Module) ReceivePrefix() string

+ func (m *Module) RegisterJobHandlers(worker *queue.Worker) error

+ func (m *Module) Routes(r *fhttp.Router)

+ func (m *Module) Schedule() []foundation.Task

+ type Outgoing struct

+ func (o *Outgoing) Dispatch(ctx context.Context, g security.Grant) error

+ func (o *Outgoing) DispatchIf(ctx context.Context, cond bool, g security.Grant) error

+ func (o *Outgoing) DispatchUnless(ctx context.Context, cond bool, g security.Grant) error

+ func (o *Outgoing) Event(name string) *Outgoing

+ func (o *Outgoing) Payload(v any) *Outgoing

+ func (o *Outgoing) RawBody(body []byte) *Outgoing

+ func (o *Outgoing) SignWithHMAC(header string) *Outgoing

+ func (o *Outgoing) URL(u string) *Outgoing

+ func (o *Outgoing) UUID(id string) *Outgoing

+ func (o *Outgoing) UseSecret(name string) *Outgoing

+ func (o *Outgoing) WithHeaders(headers map[string]string) *Outgoing

+ type ProcessEverything struct

+ func (ProcessEverything) ShouldProcess(*http.Request, []byte) bool

+ type Processor interface

+ Process func(ctx context.Context, g security.Grant, call *Call) error

+ type ProcessorFunc func(ctx context.Context, g security.Grant, call *Call) error

+ func (f ProcessorFunc) Process(ctx context.Context, g security.Grant, call *Call) error

+ type Profile interface

+ ShouldProcess func(r *http.Request, body []byte) bool

+ type ProfileFunc func(r *http.Request, body []byte) bool

+ func (f ProfileFunc) ShouldProcess(r *http.Request, body []byte) bool

+ type Receiver struct

+ MaxBodyBytes int64

+ Methods []string

+ Name string

+ OnInvalidSignature func(r *http.Request, receiver string)

+ PreviousSecrets []string

+ Process Processor

+ Profile Profile

+ Respond Responder

+ Secret string

+ StoreHeaders []string

+ Tenant string

+ Tries int

+ Validator SignatureValidator

+ type RespondOK struct

+ func (RespondOK) Respond(w http.ResponseWriter, _ *http.Request, _ *Call) error

+ type Responder interface

+ Respond func(w http.ResponseWriter, r *http.Request, call *Call) error

+ type ResponderFunc func(w http.ResponseWriter, r *http.Request, call *Call) error

+ func (f ResponderFunc) Respond(w http.ResponseWriter, r *http.Request, call *Call) error

+ type Server struct

+ Events []string

+ HTTPClient *http.Client

+ HeaderPrefix string

+ Queue string

+ Retention time.Duration

+ Secrets map[string]string

+ Timeout time.Duration

+ UserAgent string

+ type SignatureValidator interface

+ Valid func(r *http.Request, body []byte, secrets hwebhook.SecretSet) bool

+ type SignatureValidatorFunc func(r *http.Request, body []byte, secrets hwebhook.SecretSet) bool

+ func (f SignatureValidatorFunc) Valid(r *http.Request, body []byte, secrets hwebhook.SecretSet) bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL