Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dispatcher ¶
type Dispatcher struct {
// contains filtered or unexported fields
}
Dispatcher processes pending webhook deliveries.
func NewDispatcher ¶
func NewDispatcher(q *repo.Queries) *Dispatcher
func (*Dispatcher) ProcessPending ¶
func (d *Dispatcher) ProcessPending()
ProcessPending fetches and delivers pending webhooks with exponential backoff.
type Service ¶
type Service interface {
CreateEndpoint(orgID, url string, events []string) (Endpoint, error)
ListEndpoints(orgID string) ([]Endpoint, error)
UpdateEndpoint(orgID, id, url string, events []string, active bool) error
Dispatch(orgID, event string, payload json.RawMessage) error
TestEndpoint(orgID, endpointID string) error
}
func NewService ¶
Click to show internal directories.
Click to hide internal directories.