tasks

Documentation

Index

• type Service
  • func NewService(resourceManager resmgrsvc.ResourceManagerServiceYARPCClient, ...) Service

Types

type Service

type Service interface {
	// Dequeue fetches some tasks from the service.
	Dequeue(ctx context.Context, taskType resmgr.TaskType, batchSize int, timeout int) (assignments []models.Task)

	// SetPlacements sets successful and unsuccessful placements back to the service.
	SetPlacements(
		ctx context.Context,
		successFullPlacements []models.Task,
		failedAssignments []models.Task,
	)
}

Service will manage gangs/tasks and placements used by any placement strategy.

func NewService

func NewService(
	resourceManager resmgrsvc.ResourceManagerServiceYARPCClient,
	cfg *config.PlacementConfig,
	metrics *metrics.Metrics) Service

NewService will create a new task service.