status

Documentation

Overview

Package status provides system-wide status.

Index

• func NewManager(traverserRepo cmap.ConcurrentMap) *manager
• type FinishedJobs
  • func (f FinishedJobs) Update()
• type Manager

Functions

func NewManager

func NewManager(traverserRepo cmap.ConcurrentMap) *manager

Types

type FinishedJobs

type FinishedJobs struct {
	ChainRepo chain.Repo
	RMC       rm.Client
}

FinishedJobs sends updated finished jobs counts to the Request Manager. This is a singleton service that's ran in Server.Run(). Updates are best-effort. The final finished jobs count for a chain is sent with FinishRequest in a reaper when the chain is done.

func (FinishedJobs) Update

func (f FinishedJobs) Update()

type Manager

type Manager interface {
	Running(proto.StatusFilter) ([]proto.JobStatus, error)
}