controller

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 6, 2017 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Index

Constants

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

Variables

View Source
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 Base

type Base struct {
	Clients

	Controller BaseController
	// contains filtered or unexported fields
}

func NewBaseController

func NewBaseController(clients Clients, informer cache.SharedIndexInformer) Base

func (*Base) Run

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

type BaseController

type BaseController interface {
	config.Controller
	// contains filtered or unexported methods
}

type Clients

type Clients struct {
	Kubernikus kubernikus_clientset.Interface
	Kubernetes kubernetes_clientset.Interface
	Satellites *kube.SharedClientFactory
	Openstack  openstack.Client
	Helm       *helm.Client
}

type Factories

type GroundControl

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

func NewGroundController

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

func (*GroundControl) Run

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

type KubernikusOperator

type KubernikusOperator struct {
	Clients
	config.Config
	Factories
}

func NewKubernikusOperator

func NewKubernikusOperator(options *KubernikusOperatorOptions) *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
}

type LaunchControl

type LaunchControl struct {
	Factories
	Clients
	// contains filtered or unexported fields
}

func NewLaunchController

func NewLaunchController(factories Factories, clients Clients) *LaunchControl

func (*LaunchControl) Run

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

Source Files

  • base.go
  • ground.go
  • launch.go
  • operator.go

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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