README
¶
VirtEngine Provider Daemon
This folder contains the VirtEngine Provider Daemon. This piece of software listens to events emitted from the VirtEngine blockchain (code in ../app/app.go) and takes actions on a connected Kubernetes cluster to provision compute capacity based on the bids that the configured provider key wins. The following are the pieces of the daemon:
bidengine
The bid engine queries for any existing orders on chain, and based on the on-chain provider configuration, places bids on behalf of the configured provider based on configured selling prices for resources. The daemon listens for changes in the configuration so users can use automation tooling to dynamically change the prices they are charging w/o restarting the daemon. You can see the key management code for provider tx signing in cmd/run.go.
cluster
The cluster package contains the necessary code for interacting with clusters of compute that a provider is offering on the open marketplace to deploy orders on behalf of users creating deployments based on manifests. Right now only kubernetes is supported as a backend, but providers could easily implement other cluster management solutions such as OpenStack, VMWare, OpenShift, etc...
cmd
The cobra command line utility that wraps the rest of the code here and is buildable.
event
Declares the pubsub events that the provider needs to take action on won leases an recieved manifests.
gateway
Contains hanlder code for the rest server exposed by the provider
manifest
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var (
ErrClusterReadTimedout = errors.New("timeout waiting for cluster ready")
)
Functions ¶
This section is empty.
Types ¶
type BalanceCheckerConfig ¶
type Client ¶
type Client interface {
StatusClient
ValidateClient
Manifest() manifest.Client
Cluster() cluster.Client
}
type Config ¶
type Config struct {
ClusterWaitReadyDuration time.Duration
ClusterPublicHostname string
ClusterExternalPortQuantity uint
InventoryResourcePollPeriod time.Duration
InventoryResourceDebugFrequency uint
BidPricingStrategy bidengine.BidPricingStrategy
BidDeposit sdk.Coin
CPUCommitLevel float64
MemoryCommitLevel float64
StorageCommitLevel float64
BlockedHostnames []string
DeploymentIngressStaticHosts bool
BidTimeout time.Duration
ManifestTimeout time.Duration
BalanceCheckerCfg BalanceCheckerConfig
}
func NewDefaultConfig ¶
func NewDefaultConfig() Config
type Service ¶
Service is the interface that includes StatusClient interface. It also wraps ManifestHandler, Close and Done methods.
type Status ¶
type Status struct {
Cluster *ctypes.Status `json:"cluster"`
Bidengine *bidengine.Status `json:"bidengine"`
Manifest *manifest.Status `json:"manifest"`
ClusterPublicHostname string `json:"cluster_public_hostname,omitempty"`
}
Status is the data structure that stores Cluster, Bidengine and Manifest details.
type StatusClient ¶
StatusClient is the interface which includes status of service
type ValidateClient ¶
type ValidateClient interface {
Validate(context.Context, dtypes.GroupSpec) (ValidateGroupSpecResult, error)
}
ValidateClient is the interface to check if provider will bid on given groupspec
Source Files
Directories