taskpoller

Dec 22, 2025

Changes in this version

+ type Poller struct

+ func New(ctx context.Context, logger interfaces.Logger) *Poller

+ func (p *Poller) AddTask(client *api.Client, upid, node string, vmid int)

+ func (p *Poller) GetActiveTasksForVM(vmid int) []*TaskInfo

+ func (p *Poller) Stop()

+ func (p *Poller) Subscribe(cb func(task *TaskInfo)) func()

+ type TaskInfo struct

+ ExitStatus string

+ Node string

+ StartTime time.Time

+ Status string

+ UPID string

+ VMID int