status

package
Version: v2.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 19, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package status provides system-wide status.

Index

Constants

This section is empty.

Variables

This section is empty.

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)
}

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL