workers

Documentation

Index

• Constants
• Variables
• func IsReserved(node *corev1.Node) bool
• type Manager
  • func NewManager(clusterName string, nodesClient v1.NodeInterface, provider provider.Provider, ...) (*Manager, error)
  • func (m *Manager) CreateWorker(ctx context.Context, mtype string) (*api.Worker, error)
  • func (m *Manager) DeleteWorker(ctx context.Context, nodeName, id string) (*api.Worker, error)
  • func (m *Manager) GetWorker(ctx context.Context, id string) (*api.Worker, error)
  • func (m *Manager) ListWorkers(ctx context.Context) (*api.WorkerList, error)
  • func (m *Manager) MachineTypes() []*provider.MachineType
  • func (m *Manager) ReserveWorker(ctx context.Context, want *api.Worker) (*api.Worker, error)
• type WInterface

Constants

const (
	LabelReserved = "capacity.supergiant.io/reserved"
	ValTrue       = "true"

	ClusterRole = "worker"

	MinWorkerLifespan = time.Minute * 20

	NodeStateReady   = "ready"
	NodeStateUnknown = "unknown"
)

Variables

var (
	ErrNotFound = errors.New("not found")
)

Functions

func IsReserved

func IsReserved(node *corev1.Node) bool

Types

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func NewManager

func NewManager(clusterName string, nodesClient v1.NodeInterface, provider provider.Provider, userdata string) (*Manager, error)

func (*Manager) CreateWorker

func (m *Manager) CreateWorker(ctx context.Context, mtype string) (*api.Worker, error)

func (*Manager) DeleteWorker

func (m *Manager) DeleteWorker(ctx context.Context, nodeName, id string) (*api.Worker, error)

func (*Manager) GetWorker

func (m *Manager) GetWorker(ctx context.Context, id string) (*api.Worker, error)

func (*Manager) ListWorkers

func (m *Manager) ListWorkers(ctx context.Context) (*api.WorkerList, error)

func (*Manager) MachineTypes

func (m *Manager) MachineTypes() []*provider.MachineType

func (*Manager) ReserveWorker

func (m *Manager) ReserveWorker(ctx context.Context, want *api.Worker) (*api.Worker, error)

type WInterface

type WInterface interface {
	MachineTypes() []*provider.MachineType
	CreateWorker(ctx context.Context, mtype string) (*api.Worker, error)
	GetWorker(ctx context.Context, id string) (*api.Worker, error)
	ListWorkers(ctx context.Context) (*api.WorkerList, error)
	DeleteWorker(ctx context.Context, nodeName, id string) (*api.Worker, error)
	ReserveWorker(ctx context.Context, worker *api.Worker) (*api.Worker, error)
}