semantic

Documentation

Index

• func NewStorageInstalledBidStrategy(storages storage.StorageProvider) bidstrategy.SemanticBidStrategy
• type ExternalCommandStrategy
  • func NewExternalCommandStrategy(params ExternalCommandStrategyParams) *ExternalCommandStrategy
  • func (s *ExternalCommandStrategy) ShouldBid(ctx context.Context, request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)
• type ExternalCommandStrategyParams
• type ExternalHTTPStrategy
  • func NewExternalHTTPStrategy(params ExternalHTTPStrategyParams) *ExternalHTTPStrategy
  • func (s *ExternalHTTPStrategy) ShouldBid(ctx context.Context, request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)
• type ExternalHTTPStrategyParams
• type InputLocalityStrategy
  • func NewInputLocalityStrategy(params InputLocalityStrategyParams) *InputLocalityStrategy
  • func (s *InputLocalityStrategy) ShouldBid(ctx context.Context, request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)
• type InputLocalityStrategyParams
• type JobSelectionDataLocality
  • func ParseJobSelectionDataLocality(s string) (ret JobSelectionDataLocality, err error)
  • func (i JobSelectionDataLocality) MarshalYAML() (interface{}, error)
  • func (i JobSelectionDataLocality) String() string
  • func (i *JobSelectionDataLocality) UnmarshalYAML(value *yaml.Node) error
• type NetworkingStrategy
  • func NewNetworkingStrategy(accept bool) *NetworkingStrategy
  • func (s *NetworkingStrategy) ShouldBid(ctx context.Context, request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)
• type ProviderInstalledStrategy
  • func NewProviderInstalledArrayStrategy[P provider.Providable](provider provider.Provider[P], getter func(*models.Job) []string) *ProviderInstalledStrategy[P]
  • func NewProviderInstalledStrategy[P provider.Providable](provider provider.Provider[P], getter func(*models.Job) string) *ProviderInstalledStrategy[P]
  • func (s *ProviderInstalledStrategy[P]) ShouldBid(ctx context.Context, request bidstrategy.BidStrategyRequest) (resp bidstrategy.BidStrategyResponse, err error)
• type StatelessJobStrategy
  • func NewStatelessJobStrategy(params StatelessJobStrategyParams) *StatelessJobStrategy
  • func (s *StatelessJobStrategy) ShouldBid(ctx context.Context, request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)
• type StatelessJobStrategyParams
• type TimeoutStrategy
  • func NewTimeoutStrategy(params TimeoutStrategyParams) *TimeoutStrategy
  • func (s *TimeoutStrategy) ShouldBid(_ context.Context, request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)
• type TimeoutStrategyParams

Functions

func NewStorageInstalledBidStrategy

func NewStorageInstalledBidStrategy(storages storage.StorageProvider) bidstrategy.SemanticBidStrategy

Types

type ExternalCommandStrategy

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

func NewExternalCommandStrategy

func NewExternalCommandStrategy(params ExternalCommandStrategyParams) *ExternalCommandStrategy

func (*ExternalCommandStrategy) ShouldBid

func (s *ExternalCommandStrategy) ShouldBid(
	ctx context.Context,
	request bidstrategy.BidStrategyRequest,
) (bidstrategy.BidStrategyResponse, error)

type ExternalCommandStrategyParams

type ExternalCommandStrategyParams struct {
	Command string
}

type ExternalHTTPStrategy

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

func NewExternalHTTPStrategy

func NewExternalHTTPStrategy(params ExternalHTTPStrategyParams) *ExternalHTTPStrategy

func (*ExternalHTTPStrategy) ShouldBid

func (s *ExternalHTTPStrategy) ShouldBid(
	ctx context.Context,
	request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)

type ExternalHTTPStrategyParams

type ExternalHTTPStrategyParams struct {
	URL string
}

type InputLocalityStrategy

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

func NewInputLocalityStrategy

func NewInputLocalityStrategy(params InputLocalityStrategyParams) *InputLocalityStrategy

func (*InputLocalityStrategy) ShouldBid

func (s *InputLocalityStrategy) ShouldBid(
	ctx context.Context,
	request bidstrategy.BidStrategyRequest,
) (bidstrategy.BidStrategyResponse, error)

type InputLocalityStrategyParams

type InputLocalityStrategyParams struct {
	Locality JobSelectionDataLocality
	Storages storage.StorageProvider
}

type JobSelectionDataLocality

type JobSelectionDataLocality int64

const (
	Local    JobSelectionDataLocality = 0 // local
	Anywhere JobSelectionDataLocality = 1 // anywhere
)

func ParseJobSelectionDataLocality

func ParseJobSelectionDataLocality(s string) (ret JobSelectionDataLocality, err error)

func (JobSelectionDataLocality) MarshalYAML

func (i JobSelectionDataLocality) MarshalYAML() (interface{}, error)

func (JobSelectionDataLocality) String

func (i JobSelectionDataLocality) String() string

func (*JobSelectionDataLocality) UnmarshalYAML

func (i *JobSelectionDataLocality) UnmarshalYAML(value *yaml.Node) error

type NetworkingStrategy

type NetworkingStrategy struct {
	Accept bool
}

func NewNetworkingStrategy

func NewNetworkingStrategy(accept bool) *NetworkingStrategy

func (*NetworkingStrategy) ShouldBid

func (s *NetworkingStrategy) ShouldBid(
	ctx context.Context,
	request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)

ShouldBid implements BidStrategy

type ProviderInstalledStrategy

type ProviderInstalledStrategy[P provider.Providable] struct {
	// contains filtered or unexported fields
}

func NewProviderInstalledArrayStrategy

func NewProviderInstalledArrayStrategy[P provider.Providable](
	provider provider.Provider[P],
	getter func(*models.Job) []string,
) *ProviderInstalledStrategy[P]

func NewProviderInstalledStrategy

func NewProviderInstalledStrategy[P provider.Providable](
	provider provider.Provider[P],
	getter func(*models.Job) string,
) *ProviderInstalledStrategy[P]

func (*ProviderInstalledStrategy[P]) ShouldBid

func (s *ProviderInstalledStrategy[P]) ShouldBid(
	ctx context.Context,
	request bidstrategy.BidStrategyRequest,
) (resp bidstrategy.BidStrategyResponse, err error)

type StatelessJobStrategy

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

func NewStatelessJobStrategy

func NewStatelessJobStrategy(params StatelessJobStrategyParams) *StatelessJobStrategy

func (*StatelessJobStrategy) ShouldBid

func (s *StatelessJobStrategy) ShouldBid(
	ctx context.Context,
	request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)

type StatelessJobStrategyParams

type StatelessJobStrategyParams struct {
	RejectStatelessJobs bool
}

type TimeoutStrategy

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

func NewTimeoutStrategy

func NewTimeoutStrategy(params TimeoutStrategyParams) *TimeoutStrategy

func (*TimeoutStrategy) ShouldBid

func (s *TimeoutStrategy) ShouldBid(_ context.Context, request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)

type TimeoutStrategyParams

type TimeoutStrategyParams struct {
	MaxJobExecutionTimeout time.Duration
	MinJobExecutionTimeout time.Duration

	JobExecutionTimeoutClientIDBypassList []string
}