Documentation
¶
Index ¶
- type DispatchJob
- type Manager
- func (m *Manager) Channel(name string) contractsnotification.Channel
- func (m *Manager) Extend(ch contractsnotification.Channel)
- func (m *Manager) Route(channel string, route any) contractsnotification.OnDemandNotifiable
- func (m *Manager) Send(notifiable contractsnotification.Notifiable, ...) error
- func (m *Manager) SendNow(notifiable contractsnotification.Notifiable, ...) error
- type ServiceProvider
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DispatchJob ¶
type DispatchJob struct {
// contains filtered or unexported fields
}
func NewDispatchJob ¶
func NewDispatchJob(manager *Manager) *DispatchJob
func (*DispatchJob) Handle ¶
func (j *DispatchJob) Handle(args ...any) error
func (*DispatchJob) ShouldRetry ¶
func (j *DispatchJob) ShouldRetry(err error, attempt, maxTries int) (retryable bool, delay time.Duration)
ShouldRetry controls retries for the queued notification dispatch. A notification-declared Tries wins; without one (Tries <= 0) the queue worker's maxTries governs. Backoff applies to every retry, whoever supplied the cap, and the last value repeats. item == nil (cleared on success/invalid payload) is the safe single-shot fallback — never the worker's tries, so an interleaved concurrent task can't inherit another task's policy.
func (*DispatchJob) Signature ¶
func (j *DispatchJob) Signature() string
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
func (*Manager) Extend ¶
func (m *Manager) Extend(ch contractsnotification.Channel)
func (*Manager) Route ¶
func (m *Manager) Route(channel string, route any) contractsnotification.OnDemandNotifiable
func (*Manager) Send ¶
func (m *Manager) Send( notifiable contractsnotification.Notifiable, n contractsnotification.Notification, ) error
func (*Manager) SendNow ¶
func (m *Manager) SendNow( notifiable contractsnotification.Notifiable, n contractsnotification.Notification, ) error
type ServiceProvider ¶
type ServiceProvider struct{}
func (*ServiceProvider) Boot ¶
func (r *ServiceProvider) Boot(app foundation.Application)
func (*ServiceProvider) Register ¶
func (r *ServiceProvider) Register(app foundation.Application)
func (*ServiceProvider) Relationship ¶
func (r *ServiceProvider) Relationship() binding.Relationship
Click to show internal directories.
Click to hide internal directories.