Help us shape the future of Go! Take the 2026 Go Developer Survey

notification

package
v1.20.0-alpha.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 29, 2026 License: MIT Imports: 13 Imported by: 0

Documentation

Index

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 NewManager

func NewManager(logger log.Log, q queue.Queue) *Manager

func (*Manager) Channel

func (m *Manager) Channel(name string) contractsnotification.Channel

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 (*Manager) SendNow

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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