pool

Documentation

Index

• func New(ctx context.Context, cfg *config.Config, cache interfaces.CacheLoader, ...) (interfaces.RunnerNotifier, error)
• type Pool
  • func (p *Pool) Notify() <-chan error
  • func (p *Pool) PublishStatistics(ctx context.Context) error
  • func (p *Pool) Run(ctx context.Context)
  • func (p *Pool) Stop(ctx context.Context)

Functions

func New

func New(ctx context.Context, cfg *config.Config, cache interfaces.CacheLoader, log *slog.Logger, rabbit *rabbitmq.Rabbit) (interfaces.RunnerNotifier, error)

Types

type Pool

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

func (*Pool) Notify

func (p *Pool) Notify() <-chan error

func (*Pool) PublishStatistics

func (p *Pool) PublishStatistics(ctx context.Context) error

func (*Pool) Run

func (p *Pool) Run(ctx context.Context)

func (*Pool) Stop

func (p *Pool) Stop(ctx context.Context)