queue

package

v0.0.1 Latest Latest Go to latest Published: Jun 27, 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) Start(ctx context.Context) error

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