tasksvc

package
v0.0.0-...-ddc1a4a Latest Latest
Warning

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

Go to latest
Published: Dec 9, 2022 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitServiceHandler

func InitServiceHandler(
	d *yarpc.Dispatcher,
	parent tally.Scope,
	ormStore *ormobjects.Store,
	taskStore storage.TaskStore,
	updateStore storage.UpdateStore,
	frameworkInfoStore storage.FrameworkInfoStore,
	jobFactory cached.JobFactory,
	goalStateDriver goalstate.Driver,
	candidate leader.Candidate,
	mesosAgentWorkDir string,
	hostMgrClientName string,
	logManager logmanager.LogManager,
	activeRMTasks activermtask.ActiveRMTasks,
	hmVersion api.Version,
)

InitServiceHandler initializes the TaskManager

func NewTestServiceHandler

func NewTestServiceHandler() *serviceHandler

NewTestServiceHandler returns an empty new ServiceHandler ptr for testing.

Types

type Metrics

type Metrics struct {
	TaskAPIGet        tally.Counter
	TaskGet           tally.Counter
	TaskGetFail       tally.Counter
	TaskAPIGetEvents  tally.Counter
	TaskGetEvents     tally.Counter
	TaskGetEventsFail tally.Counter
	TaskCreate        tally.Counter
	TaskCreateFail    tally.Counter
	TaskAPIList       tally.Counter
	TaskList          tally.Counter
	TaskListFail      tally.Counter
	TaskAPIRefresh    tally.Counter
	TaskRefresh       tally.Counter
	TaskRefreshFail   tally.Counter
	TaskAPIStart      tally.Counter
	TaskStart         tally.Counter
	TaskStartFail     tally.Counter
	TaskAPIStop       tally.Counter
	TaskStop          tally.Counter
	TaskStopFail      tally.Counter
	TaskAPIRestart    tally.Counter
	TaskRestart       tally.Counter
	TaskRestartFail   tally.Counter
	TaskAPIQuery      tally.Counter
	TaskQuery         tally.Counter
	TaskQueryFail     tally.Counter

	TaskAPIListLogs  tally.Counter
	TaskListLogs     tally.Counter
	TaskListLogsFail tally.Counter

	// Timers
	TaskQueryHandlerDuration tally.Timer
}

Metrics is the struct containing all the counters that track internal state of the job service

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

Jump to

Keyboard shortcuts

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