distribution

Documentation

Index

• Variables
• type Distributor
  • func ProvideResourceAwareDistributor(config config.ResourceAwareDistributorConfigModel, meter metric.Meter, ...) Distributor
  • func ProvideRoundRobinDistributor(meter metric.Meter) Distributor
• type DistributorMapper
  • func ProvideDistributorMapper(resourceAwareDistributorConfig config.ResourceAwareDistributorConfigModel, ...) DistributorMapper
• type NodeMapper
• type ResourceAwareDistributor
  • func (r ResourceAwareDistributor) Distribute(ctx context.Context, nodes []NodeMapper, tasks []models.Task) (successTask []models.Task, distributionError []models.DistributeError, ...)
• type RoundRobinDistributor
  • func (r RoundRobinDistributor) Distribute(ctx context.Context, nodes []NodeMapper, tasks []models.Task) (successTask []models.Task, distributionError []models.DistributeError, ...)

Variables

var (
	ErrResourceAwareDistributorTaskDifferenceJob = errors.New("distribution failed due to jobID is not the same")
	ErrNotEnoughResource                         = errors.New("no available node that have enough resource to run this task")
)

Types

type Distributor

type Distributor interface {
	Distribute(ctx context.Context, nodes []NodeMapper, tasks []models.Task) ([]models.Task, []models.DistributeError, error)
}

func ProvideResourceAwareDistributor

func ProvideResourceAwareDistributor(config config.ResourceAwareDistributorConfigModel, meter metric.Meter, taskService service.Task) Distributor

func ProvideRoundRobinDistributor

func ProvideRoundRobinDistributor(meter metric.Meter) Distributor

type DistributorMapper

type DistributorMapper interface {
	GetDistributor(name models.DistributorName) (Distributor, bool)
}

func ProvideDistributorMapper

func ProvideDistributorMapper(resourceAwareDistributorConfig config.ResourceAwareDistributorConfigModel, metric metric.Meter, taskService service.Task) DistributorMapper

type NodeMapper

type NodeMapper struct {
	NodeEntry         models.NodeEntry
	GRPCConnection    proto.WorkerNodeClient
	AvailableResource models.AvailableResource
	Logger            *logrus.Entry
}

type ResourceAwareDistributor

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

func (ResourceAwareDistributor) Distribute

func (r ResourceAwareDistributor) Distribute(ctx context.Context, nodes []NodeMapper, tasks []models.Task) (successTask []models.Task, distributionError []models.DistributeError, err error)

type RoundRobinDistributor

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

func (RoundRobinDistributor) Distribute

func (r RoundRobinDistributor) Distribute(ctx context.Context, nodes []NodeMapper, tasks []models.Task) (successTask []models.Task, distributionError []models.DistributeError, err error)