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 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

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 models.JobSelectionDataLocality
	Storages storage.StorageProvider
}

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
}