task

Documentation

Index

• type Metrics
  • func NewMetrics(scope tally.Scope) *Metrics
• type StateManager
  • func NewStateManager(d *yarpc.Dispatcher, schedulerClient mpb.SchedulerClient, ...) StateManager

Types

type Metrics

type Metrics struct {
	// contains filtered or unexported fields
}

Metrics tracks various metrics at task state level.

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

type StateManager

type StateManager interface {
	// Update is the mesos callback to framework to notify mesos task status update change.
	Update(ctx context.Context, body *sched.Event) error

	// UpdateCounters manages counters of task status update & ack counts.
	UpdateCounters(_ *uatomic.Bool)

	// EventPurged is for implementing PurgedEventsProcessor interface.
	EventPurged(events []*cirbuf.CircularBufferItem)
}

StateManager is the interface for mesos task status updates stream.

func NewStateManager

func NewStateManager(
	d *yarpc.Dispatcher,
	schedulerClient mpb.SchedulerClient,
	watchProcessor watchevent.WatchProcessor,
	updateBufferSize int,
	updateAckConcurrency int,
	resmgrClient resmgrsvc.ResourceManagerServiceYARPCClient,
	parentScope tally.Scope) StateManager

NewStateManager init the task state manager by setting up input stream to receive mesos task status update, and outgoing event stream for Job Manager & Resource Manager for consumption of these task status updates.