launch

package

v1.5.0 Latest Latest Go to latest Published: Jan 18, 2018 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

proxy-git.cwkhome.fun/sapcc/kubernikus

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewController(factories config.Factories, clients config.Clients, ...) base.Controller
type ConcretePoolManager
type EventingPoolManager
type InstrumentingPoolManager
type LaunchReconciler
- func (lr *LaunchReconciler) Reconcile(kluster *v1.Kluster) (requeue bool, err error)
type LoggingPoolManager
type PoolManager
type PoolStatus

Constants ¶

View Source

const (
	LaunchctlFinalizer = "launchctl"
)

Variables ¶

This section is empty.

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
}

Source Files ¶

controller.go
eventing.go
instrumenting.go
logging.go
pool_manager.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL