worker

package
v0.0.0-...-e2e9b64 Latest Latest
Warning

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

 Go to latest Published: Nov 10, 2025 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	BatchSize  int32         `envDefault:"5"`
	Count      int           `envDefault:"2"`
	Interval   time.Duration `envDefault:"30s"`
	MaxTries   int16         `envDefault:"3"`
	RetryDelay time.Duration `envDefault:"30s"`

	Stopper chan bool
	Waiter  *sync.WaitGroup
}

func (Config) Stop 

func (c Config) Stop()

func (Config) String 

func (c Config) String() string

func (Config) Validate 

func (c Config) Validate() error

type Sender 

type Sender interface {
	Run()
}

func NewSender 

func NewSender(
	id int,
	cfg Config,
	repo db.Repository,
	smtpService smtp.Service,
) Sender

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.