Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrInsufficientCapacity is the new error when capacity is insufficient ErrInsufficientCapacity = errors.New("insufficient capacity") )
View Source
var ErrNoDeployments = errors.New("no deployments")
ErrNoDeployments indicates no deployments exist
View Source
var ErrNotRunning = errors.New("not running")
ErrNotRunning is the error when service is not running
Functions ¶
func NewNode ¶ added in v0.2.4
func NewNode(id string, available atypes.ResourceUnits) ctypes.Node
NewNode returns new Node instance with provided details
func NewServiceLog ¶ added in v0.2.2
func NewServiceLog(name string, stream io.ReadCloser) *ctypes.ServiceLog
NewServiceLog creates and returns a service log with provided details
Types ¶
type Client ¶ added in v0.0.8
type Client interface { ReadClient Deploy(context.Context, mtypes.LeaseID, *manifest.Group) error TeardownLease(context.Context, mtypes.LeaseID) error Deployments(context.Context) ([]ctypes.Deployment, error) Inventory(context.Context) ([]ctypes.Node, error) }
Client interface lease and deployment methods
type Cluster ¶
type Cluster interface { Reserve(mtypes.OrderID, atypes.ResourceGroup) (ctypes.Reservation, error) Unreserve(mtypes.OrderID) error }
Cluster is the interface that wraps Reserve and Unreserve methods
type Config ¶ added in v0.9.1
type Config struct { InventoryResourcePollPeriod time.Duration InventoryResourceDebugFrequency uint InventoryExternalPortQuantity uint }
func NewDefaultConfig ¶ added in v0.9.1
func NewDefaultConfig() Config
type ReadClient ¶ added in v0.7.3
type Service ¶
type Service interface { StatusClient Cluster Close() error Ready() <-chan struct{} Done() <-chan struct{} }
Service manage compute cluster for the provider. Will eventually integrate with kubernetes, etc...
Source Files ¶
Click to show internal directories.
Click to hide internal directories.