taskpoller

Documentation

Index

• type Poller
  • 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

Types

type Poller

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

Poller handles background task monitoring.

func New

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

New creates a new task poller.

func (*Poller) AddTask

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

AddTask starts monitoring a task.

func (*Poller) GetActiveTasksForVM

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

GetActiveTasksForVM returns a list of active tasks for a specific VM.

func (*Poller) Stop

func (p *Poller) Stop()

Stop stops the poller.

func (*Poller) Subscribe

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

Subscribe adds a callback for task updates and returns an unregister function.

type TaskInfo

type TaskInfo struct {
	UPID       string
	Node       string
	VMID       int
	Status     string
	ExitStatus string
	StartTime  time.Time
	// contains filtered or unexported fields
}

TaskInfo holds information about a monitored task.