queue

package

v0.0.2 Latest Latest Go to latest Published: Aug 1, 2025 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Repo struct {
	// contains filtered or unexported fields
}

Repo предоставляет функциональность асинхронной очереди задач

func New() *Repo

New создает новый экземпляр сервиса очереди

func (s *Repo) Add(fn func())

Add добавляет задачу в очередь

func (s *Repo) Close() error

Close останавливает сервис очереди

func (s *Repo) Len() int

Len возвращает количество задач в очереди

func (s *Repo) StartContext(ctx context.Context) error

StartContext запускает обработчик очереди