tasksvc

Documentation

Index

• func InitServiceHandler(d *yarpc.Dispatcher, parent tally.Scope, ormStore *ormobjects.Store, ...)
• func NewTestServiceHandler() *serviceHandler
• type Metrics
  • func NewMetrics(scope tally.Scope) *Metrics

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