activermtask

Documentation

Index

• type ActiveRMTasks
  • func NewActiveRMTasks(d *yarpc.Dispatcher, parent tally.Scope) ActiveRMTasks
• type Metrics
  • func NewMetrics(scope tally.Scope) *Metrics

Types

type ActiveRMTasks

type ActiveRMTasks interface {
	// GetTask returns the task entry for the given taskID
	GetTask(taskID string) *resmgrsvc.GetActiveTasksResponse_TaskEntry

	// UpdateActiveTasks fills the cache with all tasks from Resmgr
	UpdateActiveTasks()
}

ActiveRMTasks is the entrypoint object into the cache which store active tasks from ResMgr.

func NewActiveRMTasks

func NewActiveRMTasks(
	d *yarpc.Dispatcher,
	parent tally.Scope,
) ActiveRMTasks

NewActiveRMTasks is the constructor of ActiveTasksCache

type Metrics

type Metrics struct {
	ActiveTaskQuerySuccess tally.Counter
	ActiveTaskQueryFail    tally.Counter
	UpdaterRMTasksDuraion  tally.Timer
}

Metrics is the struct containing all the counters and timers that track

func NewMetrics

func NewMetrics(scope tally.Scope) *Metrics

NewMetrics returns a new Metrics struct, with all metrics initialized and rooted at the given tally.Scope