cluster

Documentation

Index

• Variables
• type Client
  • func NullClient() Client
• type Cluster
• type Deployment
• type Node
  • func NewNode(id string, available types.ResourceUnit) Node
• type Reservation
• type Service
  • func NewService(ctx context.Context, session session.Session, bus event.Bus, client Client) (Service, error)
• type ServiceLog
  • func NewServiceLog(name string, stream io.ReadCloser) *ServiceLog
• type StatusClient

Variables

var (
	ErrInsufficientCapacity = errors.New("insufficient capacity")
)

var ErrNoDeployments = errors.New("no deployments")

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

Types

type Client

type Client interface {
	Deploy(types.LeaseID, *types.ManifestGroup) error
	TeardownLease(types.LeaseID) error
	Deployments() ([]Deployment, error)
	LeaseStatus(types.LeaseID) (*types.LeaseStatusResponse, error)
	ServiceStatus(types.LeaseID, string) (*types.ServiceStatusResponse, error)
	ServiceLogs(context.Context, types.LeaseID, int64, bool) ([]*ServiceLog, error)
	Inventory() ([]Node, error)
}

func NullClient

func NullClient() Client

type Cluster

type Cluster interface {
	Reserve(types.OrderID, *types.DeploymentGroup) (Reservation, error)
	Unreserve(types.OrderID, types.ResourceList) error
}

type Deployment

type Deployment interface {
	LeaseID() types.LeaseID
	ManifestGroup() *types.ManifestGroup
}

type Node

type Node interface {
	ID() string
	Available() types.ResourceUnit
}

func NewNode

func NewNode(id string, available types.ResourceUnit) Node

type Reservation

type Reservation interface {
	OrderID() types.OrderID
	Resources() types.ResourceList
}

type Service

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

Manage compute cluster for the provider. Will eventually integrate with kubernetes, etc...

func NewService

func NewService(ctx context.Context, session session.Session, bus event.Bus, client Client) (Service, error)

type ServiceLog

type ServiceLog struct {
	Name    string
	Stream  io.ReadCloser
	Scanner *bufio.Scanner
}

func NewServiceLog

func NewServiceLog(name string, stream io.ReadCloser) *ServiceLog

type StatusClient

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