cluster

Documentation

Index

• Constants
• Variables
• func NewNode(id string, available atypes.ResourceUnits) ctypes.Node
• func NewServiceLog(name string, stream io.ReadCloser) *ctypes.ServiceLog
• type Client
  • func NullClient() Client
• type Cluster
• type Config
  • func NewDefaultConfig() Config
• type HostnameServiceClient
• type ReadClient
• type Service
  • func NewService(ctx context.Context, session session.Session, bus pubsub.Bus, client Client, ...) (Service, error)
• type SimpleHostnames
  • func (sh *SimpleHostnames) CanReserveHostnames(hostnames []string, did dtypes.DeploymentID) <-chan error
  • func (sh *SimpleHostnames) ReleaseHostnames(hostnames []string)
  • func (sh *SimpleHostnames) ReserveHostnames(hostnames []string, did dtypes.DeploymentID) <-chan error
• type StatusClient

Constants

const HostnameSeparator = '.'

Variables

var (

	// ErrInsufficientCapacity is the new error when capacity is insufficient
	ErrInsufficientCapacity = errors.New("insufficient capacity")
)

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

ErrNotRunning is the error when service is not running

Functions

func NewNode

func NewNode(id string, available atypes.ResourceUnits) ctypes.Node

NewNode returns new Node instance with provided details

func NewServiceLog

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

NewServiceLog creates and returns a service log with provided details

Types

type Client

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

func NullClient

func NullClient() Client

NullClient returns nullClient instance

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

type Config struct {
	InventoryResourcePollPeriod     time.Duration
	InventoryResourceDebugFrequency uint
	InventoryExternalPortQuantity   uint
	CPUCommitLevel                  float64
	MemoryCommitLevel               float64
	StorageCommitLevel              float64
	BlockedHostnames                []string
}

func NewDefaultConfig

func NewDefaultConfig() Config

type HostnameServiceClient

type HostnameServiceClient interface {
	ReserveHostnames(hostnames []string, did dtypes.DeploymentID) <-chan error
	ReleaseHostnames(hostnames []string)
	CanReserveHostnames(hostnames []string, did dtypes.DeploymentID) <-chan error
}

type ReadClient

type ReadClient interface {
	LeaseStatus(context.Context, mtypes.LeaseID) (*ctypes.LeaseStatus, error)
	LeaseEvents(context.Context, mtypes.LeaseID, string, bool) (ctypes.EventsWatcher, error)
	LeaseLogs(context.Context, mtypes.LeaseID, string, bool, *int64) ([]*ctypes.ServiceLog, error)
	ServiceStatus(context.Context, mtypes.LeaseID, string) (*ctypes.ServiceStatus, error)
}

type Service

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

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

func NewService

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

NewService returns new Service instance

type SimpleHostnames

type SimpleHostnames struct {
	Hostnames map[string]dtypes.DeploymentID
	// contains filtered or unexported fields

} /* Used in test code */

func (*SimpleHostnames) CanReserveHostnames

func (sh *SimpleHostnames) CanReserveHostnames(hostnames []string, did dtypes.DeploymentID) <-chan error

func (*SimpleHostnames) ReleaseHostnames

func (sh *SimpleHostnames) ReleaseHostnames(hostnames []string)

func (*SimpleHostnames) ReserveHostnames

func (sh *SimpleHostnames) ReserveHostnames(hostnames []string, did dtypes.DeploymentID) <-chan error

type StatusClient

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

StatusClient is the interface which includes status of service