controller

Documentation

Index

• Constants
• Variables
• func MetaLabelReleaseIndexFunc(obj interface{}) ([]string, error)
• type GroundControl
  • func NewGroundController(factories config.Factories, clients config.Clients, ...) *GroundControl
  • func (op *GroundControl) Run(threadiness int, stopCh <-chan struct{}, wg *sync.WaitGroup)
• type KubernikusOperator
  • func NewKubernikusOperator(options *KubernikusOperatorOptions, logger log.Logger) *KubernikusOperator
  • func (o *KubernikusOperator) Run(stopCh <-chan struct{}, wg *sync.WaitGroup)
• type KubernikusOperatorOptions

Constants

const (
	KLUSTER_RECHECK_INTERVAL = 5 * time.Minute

	//Reason constants for the event recorder
	ConfigurationError = "ConfigurationError"
	FailedCreate       = "FailedCreate"
)

const (
	DEFAULT_WORKERS        = 1
	DEFAULT_RECONCILIATION = 5 * time.Minute
)

Variables

var (
	CONTROLLER_OPTIONS = map[string]int{
		"groundctl":         10,
		"launchctl":         DEFAULT_WORKERS,
		"wormholegenerator": DEFAULT_WORKERS,
	}
)

Functions

func MetaLabelReleaseIndexFunc

func MetaLabelReleaseIndexFunc(obj interface{}) ([]string, error)

MetaLabelReleaseIndexFunc is a default index function that indexes based on an object's release label

Types

type GroundControl

type GroundControl struct {
	config.Clients
	config.Factories
	config.Config
	Recorder record.EventRecorder
	// contains filtered or unexported fields
}

func NewGroundController

func NewGroundController(factories config.Factories, clients config.Clients, recorder record.EventRecorder, config config.Config) *GroundControl

func (*GroundControl) Run

func (op *GroundControl) Run(threadiness int, stopCh <-chan struct{}, wg *sync.WaitGroup)

type KubernikusOperator

type KubernikusOperator struct {
	config.Config
	config.Factories
	config.Clients
	// contains filtered or unexported fields
}

func NewKubernikusOperator

func NewKubernikusOperator(options *KubernikusOperatorOptions, logger log.Logger) *KubernikusOperator

func (*KubernikusOperator) Run

func (o *KubernikusOperator) Run(stopCh <-chan struct{}, wg *sync.WaitGroup)

type KubernikusOperatorOptions

type KubernikusOperatorOptions struct {
	KubeConfig string
	Context    string

	ChartDirectory string

	AuthURL           string
	AuthUsername      string
	AuthPassword      string
	AuthDomain        string
	AuthProject       string
	AuthProjectDomain string

	KubernikusDomain    string
	KubernikusProjectID string
	KubernikusNetworkID string
	Namespace           string
	Controllers         []string
	MetricPort          int
}