Function New

internal/taskpoller/poller.go:36–45

New creates a new task poller.

(ctx context.Context, logger interfaces.Logger)

// New creates a new task poller.
func New(ctx context.Context, logger interfaces.Logger) *Poller {
	ctx, cancel := context.WithCancel(ctx)
	return &Poller{
		tasks:     make(map[string]*TaskInfo),
		callbacks: make(map[int]func(task *TaskInfo)),
		logger:    logger,
		ctx:       ctx,
		cancel:    cancel,
	}
}

// Stop stops the poller.
func (p *Poller) Stop() {