Versions in this module Expand all Collapse all v0 v0.1.2 Nov 16, 2018 Changes in this version + type DelivererPool struct + func NewDelivererPool(d DeliveryOptions) *DelivererPool + func (d *DelivererPool) Do(b []byte, to *url.URL, sendFn func([]byte, *url.URL) error) + func (d *DelivererPool) Errors() <-chan error + func (d *DelivererPool) Restart(b []byte, to *url.URL, id string, sendFn func([]byte, *url.URL) error) + func (d *DelivererPool) Stop() + type DeliveryOptions struct + BackoffFactor float64 + InitialRetryTime time.Duration + MaxRetries int + MaximumRetryTime time.Duration + Persister DeliveryPersister + RateLimit *rate.Limiter + type DeliveryPersister interface + Cancel func(id string) + Retrying func(id string) + Sending func(b []byte, to *url.URL) string + Successful func(id string) + Undeliverable func(id string)
Go to main page