bidengine

Documentation

Index

• Constants
• Variables
• type BidPricingStrategy
  • func MakeRandomRangePricing() (BidPricingStrategy, error)
  • func MakeScalePricing(cpuScale decimal.Decimal, memoryScale decimal.Decimal, storageScale Storage, ...) (BidPricingStrategy, error)
  • func MakeShellScriptPricing(path string, processLimit uint, runtimeLimit time.Duration) (BidPricingStrategy, error)
• type Config
• type ProviderAttrSignatureService
• type Request
• type Service
  • func NewService(ctx context.Context, session session.Session, cluster cluster.Cluster, ...) (Service, error)
• type Status
• type StatusClient
• type Storage
  • func (ss Storage) AllLessThenOrEqual(val decimal.Decimal) bool
  • func (ss Storage) IsAnyNegative() bool
  • func (ss Storage) IsAnyZero() bool

Constants

const (
	DefaultPricePrecision = 6
)

Variables

var (
	ErrBidQuantityInvalid = errors.New("A bid quantity is invalid")
	ErrBidZero            = errors.New("A bid of zero was produced")
)

var ErrNotRunning = errors.New("not running")

ErrNotRunning declares new error with message "not running"

Types

type BidPricingStrategy

type BidPricingStrategy interface {
	CalculatePrice(ctx context.Context, req Request) (sdk.DecCoin, error)
}

func MakeRandomRangePricing

func MakeRandomRangePricing() (BidPricingStrategy, error)

func MakeScalePricing

func MakeScalePricing(
	cpuScale decimal.Decimal,
	memoryScale decimal.Decimal,
	storageScale Storage,
	endpointScale decimal.Decimal,
	ipScale decimal.Decimal,
) (BidPricingStrategy, error)

func MakeShellScriptPricing

func MakeShellScriptPricing(path string, processLimit uint, runtimeLimit time.Duration) (BidPricingStrategy, error)

type Config

type Config struct {
	PricingStrategy BidPricingStrategy
	Deposit         sdk.Coin
	BidTimeout      time.Duration
	Attributes      types.Attributes
	MaxGroupVolumes int
}

type ProviderAttrSignatureService

type ProviderAttrSignatureService interface {
	GetAuditorAttributeSignatures(auditor string) ([]atypes.Provider, error)
	GetAttributes() (types.Attributes, error)
}

type Request

type Request struct {
	Owner              string `json:"owner"`
	GSpec              *dtypes.GroupSpec
	AllocatedResources dtypes.ResourceUnits
	PricePrecision     int
}

type Service

type Service interface {
	StatusClient
	Close() error
	Done() <-chan struct{}
}

Service handles bidding on orders.

func NewService

func NewService(ctx context.Context, session session.Session, cluster cluster.Cluster, bus pubsub.Bus, waiter waiter.OperatorWaiter, cfg Config) (Service, error)

NewService creates new service instance and returns error in case of failure

type Status

type Status struct {
	Orders uint32 `json:"orders"`
}

Status stores orders

type StatusClient

type StatusClient interface {
	Status(context.Context) (*Status, error)
	StatusV1(ctx context.Context) (*provider.BidEngineStatus, error)
}

StatusClient interface predefined with Status method

type Storage

type Storage map[string]decimal.Decimal

func (Storage) AllLessThenOrEqual

func (ss Storage) AllLessThenOrEqual(val decimal.Decimal) bool

AllLessThenOrEqual check all storage classes fit into max limits note better have dedicated limits for each class

func (Storage) IsAnyNegative

func (ss Storage) IsAnyNegative() bool

func (Storage) IsAnyZero

func (ss Storage) IsAnyZero() bool