launch

Documentation

Index

• Constants
• func NewController(factories config.Factories, clients config.Clients, ...) base.Controller
• type ConcretePoolManager
  • func (cpm *ConcretePoolManager) CreateNode() (id string, err error)
  • func (cpm *ConcretePoolManager) DeleteNode(id string) (err error)
  • func (cpm *ConcretePoolManager) GetStatus() (status *PoolStatus, err error)
  • func (cpm *ConcretePoolManager) SetStatus(status *PoolStatus) error
• type EventingPoolManager
  • func (epm *EventingPoolManager) CreateNode() (id string, err error)
  • func (epm *EventingPoolManager) DeleteNode(id string) (err error)
  • func (epm *EventingPoolManager) GetStatus() (status *PoolStatus, err error)
  • func (epm *EventingPoolManager) SetStatus(status *PoolStatus) (err error)
• type InstrumentingPoolManager
  • func (pm *InstrumentingPoolManager) CreateNode() (id string, err error)
  • func (pm *InstrumentingPoolManager) DeleteNode(id string) (err error)
  • func (pm *InstrumentingPoolManager) GetStatus() (status *PoolStatus, err error)
  • func (pm *InstrumentingPoolManager) SetStatus(status *PoolStatus) (err error)
• type LaunchReconciler
  • func (lr *LaunchReconciler) Reconcile(kluster *v1.Kluster) (requeue bool, err error)
• type LoggingPoolManager
  • func (npm *LoggingPoolManager) CreateNode() (id string, err error)
  • func (npm *LoggingPoolManager) DeleteNode(id string) (err error)
  • func (npm *LoggingPoolManager) GetStatus() (status *PoolStatus, err error)
  • func (npm *LoggingPoolManager) SetStatus(status *PoolStatus) (err error)
• type PoolManager
• type PoolStatus

Constants

const (
	LaunchctlFinalizer = "launchctl"
)

Functions

func NewController

func NewController(factories config.Factories, clients config.Clients, recorder record.EventRecorder, logger log.Logger) base.Controller

Types

type ConcretePoolManager

type ConcretePoolManager struct {
	config.Clients

	Kluster *v1.Kluster
	Pool    *models.NodePool
	Logger  log.Logger
}

func (*ConcretePoolManager) CreateNode

func (cpm *ConcretePoolManager) CreateNode() (id string, err error)

func (*ConcretePoolManager) DeleteNode

func (cpm *ConcretePoolManager) DeleteNode(id string) (err error)

func (*ConcretePoolManager) GetStatus

func (cpm *ConcretePoolManager) GetStatus() (status *PoolStatus, err error)

func (*ConcretePoolManager) SetStatus

func (cpm *ConcretePoolManager) SetStatus(status *PoolStatus) error

type EventingPoolManager

type EventingPoolManager struct {
	PoolManager PoolManager
	Kluster     *v1.Kluster
	Recorder    record.EventRecorder
}

func (*EventingPoolManager) CreateNode

func (epm *EventingPoolManager) CreateNode() (id string, err error)

func (*EventingPoolManager) DeleteNode

func (epm *EventingPoolManager) DeleteNode(id string) (err error)

func (*EventingPoolManager) GetStatus

func (epm *EventingPoolManager) GetStatus() (status *PoolStatus, err error)

func (*EventingPoolManager) SetStatus

func (epm *EventingPoolManager) SetStatus(status *PoolStatus) (err error)

type InstrumentingPoolManager

type InstrumentingPoolManager struct {
	PoolManager PoolManager

	Latency    *prometheus.SummaryVec
	Total      *prometheus.CounterVec
	Successful *prometheus.CounterVec
	Failed     *prometheus.CounterVec
}

func (*InstrumentingPoolManager) CreateNode

func (pm *InstrumentingPoolManager) CreateNode() (id string, err error)

func (*InstrumentingPoolManager) DeleteNode

func (pm *InstrumentingPoolManager) DeleteNode(id string) (err error)

func (*InstrumentingPoolManager) GetStatus

func (pm *InstrumentingPoolManager) GetStatus() (status *PoolStatus, err error)

func (*InstrumentingPoolManager) SetStatus

func (pm *InstrumentingPoolManager) SetStatus(status *PoolStatus) (err error)

type LaunchReconciler

type LaunchReconciler struct {
	config.Clients

	Recorder record.EventRecorder
	Logger   log.Logger
}

func (*LaunchReconciler) Reconcile

func (lr *LaunchReconciler) Reconcile(kluster *v1.Kluster) (requeue bool, err error)

type LoggingPoolManager

type LoggingPoolManager struct {
	PoolManager PoolManager
	Logger      log.Logger
}

func (*LoggingPoolManager) CreateNode

func (npm *LoggingPoolManager) CreateNode() (id string, err error)

func (*LoggingPoolManager) DeleteNode

func (npm *LoggingPoolManager) DeleteNode(id string) (err error)

func (*LoggingPoolManager) GetStatus

func (npm *LoggingPoolManager) GetStatus() (status *PoolStatus, err error)

func (*LoggingPoolManager) SetStatus

func (npm *LoggingPoolManager) SetStatus(status *PoolStatus) (err error)

type PoolManager

type PoolManager interface {
	GetStatus() (*PoolStatus, error)
	SetStatus(*PoolStatus) error
	CreateNode() (string, error)
	DeleteNode(string) error
}

type PoolStatus

type PoolStatus struct {
	Nodes    []string
	Running  int
	Starting int
	Stopping int
	Needed   int
	UnNeeded int
}