cluster

Documentation

Index

• Variables
• type Client
  • func NullClient() Client
• type Cluster
• type Deployment
• type Reservation
• type Service
  • func NewService(log log.Logger, ctx context.Context, bus event.Bus, client Client) (Service, error)

Variables

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

Types

type Client

type Client interface {
	Deploy(types.LeaseID, *types.ManifestGroup) error
	Teardown(types.LeaseID) error

	Deployments() ([]Deployment, error)
}

func NullClient

func NullClient() Client

type Cluster

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

type Deployment

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

type Reservation

type Reservation interface {
	OrderID() types.OrderID
	Group() *types.DeploymentGroup
}

type Service

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

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

func NewService

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