executions

Documentation

Index

• type GetQualityOfServiceInput
• type QualityOfServiceAllocator
  • func NewQualityOfServiceAllocator(config runtimeInterfaces.Configuration, ...) QualityOfServiceAllocator
• type QualityOfServiceSpec
• type QueueAllocator
  • func NewQueueAllocator(config runtimeInterfaces.Configuration, db repoInterfaces.Repository) QueueAllocator

Types

type GetQualityOfServiceInput

type GetQualityOfServiceInput struct {
	Workflow               *admin.Workflow
	LaunchPlan             *admin.LaunchPlan
	ExecutionCreateRequest *admin.ExecutionCreateRequest
}

type QualityOfServiceAllocator

type QualityOfServiceAllocator interface {
	GetQualityOfService(ctx context.Context, input GetQualityOfServiceInput) (QualityOfServiceSpec, error)
}

func NewQualityOfServiceAllocator

func NewQualityOfServiceAllocator(config runtimeInterfaces.Configuration, resourceManager interfaces.ResourceInterface) QualityOfServiceAllocator

type QualityOfServiceSpec

type QualityOfServiceSpec struct {
	QueuingBudget time.Duration
}

type QueueAllocator

type QueueAllocator interface {
	GetQueue(ctx context.Context, identifier core.Identifier) singleQueueConfiguration
}

func NewQueueAllocator

func NewQueueAllocator(config runtimeInterfaces.Configuration, db repoInterfaces.Repository) QueueAllocator