bidengine

Documentation

Index

• Variables
• type BidPricingStrategy
  • func MakeRandomRangePricing() (BidPricingStrategy, error)
  • func MakeScalePricing(cpuScale decimal.Decimal, memoryScale decimal.Decimal, ...) (BidPricingStrategy, error)
  • func MakeShellScriptPricing(path string, processLimit uint, runtimeLimit time.Duration) (BidPricingStrategy, error)
• type Config
• type ProviderAttrSignatureService
• type Service
  • func NewService(ctx context.Context, session session.Session, cluster cluster.Cluster, ...) (Service, error)
• type Status
• type StatusClient

Variables

var ErrBidQuantityInvalid = errors.New("A bid quantity is invalid")

var 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 {
	// contains filtered or unexported methods
}

func MakeRandomRangePricing

func MakeRandomRangePricing() (BidPricingStrategy, error)

func MakeScalePricing

func MakeScalePricing(
	cpuScale decimal.Decimal,
	memoryScale decimal.Decimal,
	storageScale decimal.Decimal,
	endpointScale 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
}

type ProviderAttrSignatureService

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

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, cfg Config) (Service, error)

NewService creates new service instance and returns error incase of failure

type Status

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

Status stores orders

type StatusClient

type StatusClient interface {
	Status(context.Context) (*Status, error)
}

StatusClient interface predefined with Status method