bidengine

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

type Config struct {
	PricingStrategy BidPricingStrategy
	Deposit         sdk.Coin
	BidTimeout      time.Duration
	Attributes      atttypes.Attributes
	MaxGroupVolumes int
	// Rescan configures the periodic order rescan loop; nil means
	// DefaultOrderRescanConfig()
	Rescan *OrderRescanConfig
}

type OrderRescanConfig struct {
	// Enabled controls whether periodic rescan is active
	Enabled bool `json:"enabled" yaml:"enabled"`
	// Interval between rescans
	Interval time.Duration `json:"interval" yaml:"interval"`
	// PageSize for pagination when querying orders
	PageSize int `json:"page_size" yaml:"page_size"`
}

type ProviderAttrSignatureService interface {
	GetAuditorAttributeSignatures(auditor string) (atypes.AuditedProviders, error)
	GetAttributes() (atrtypes.Attributes, error)
}

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

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

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

type Storage map[string]decimal.Decimal