controllers

package
v0.0.0-...-56fb935 Latest Latest
Warning

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

 Go to latest Published: Mar 22, 2020 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsPostgres 

func IsPostgres(s *alpha1.AirflowBaseSpec) bool

IsPostgres return true for postgres

Types

type AirflowBase 

type AirflowBase struct{}

AirflowBase - interface to handle airflowbase

func (*AirflowBase) Objects 

func (s *AirflowBase) Objects(rsrc interface{}, rsrclabels map[string]string, observed, dependent, aggregated []reconciler.Object) ([]reconciler.Object, error)

Objects returns the list of resource/name for those resources created by the operator for this spec and those resources referenced by this operator. Mark resources as owned, referred

func (*AirflowBase) Observables 

func (s *AirflowBase) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable

Observables asd

func (*AirflowBase) UpdateStatus 

func (s *AirflowBase) UpdateStatus(rsrc interface{}, reconciled []reconciler.Object, err error) time.Duration

UpdateStatus use reconciled objects to update component status

type AirflowBaseReconciler 

type AirflowBaseReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
}

AirflowBaseReconciler reconciles a AirflowBase object

func (*AirflowBaseReconciler) Reconcile 

func (r *AirflowBaseReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

Reconcile - Dummy TODO remove this

func (*AirflowBaseReconciler) SetupWithManager 

func (r *AirflowBaseReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager - called by main

type AirflowClusterReconciler 

type AirflowClusterReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
}

AirflowClusterReconciler reconciles a AirflowCluster object

func (*AirflowClusterReconciler) Reconcile 

func (r *AirflowClusterReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

Reconcile - Dummy TODO remove this

func (*AirflowClusterReconciler) SetupWithManager 

func (r *AirflowClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager - called by main

type Cluster 

type Cluster struct{}

Cluster - interface to handle airflowbase

func (*Cluster) DependentResources 

func (c *Cluster) DependentResources(rsrc interface{}) []reconciler.Object

DependentResources - return dependant resources

func (*Cluster) Objects 

func (c *Cluster) Objects(rsrc interface{}, rsrclabels map[string]string, observed, dependent, aggregated []reconciler.Object) ([]reconciler.Object, error)

Objects returns the list of resource/name for those resources created by the operator for this spec and those resources referenced by this operator. Mark resources as owned, referred

func (*Cluster) Observables 

func (c *Cluster) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable

Observables asd

func (*Cluster) UpdateStatus 

func (c *Cluster) UpdateStatus(rsrc interface{}, reconciled []reconciler.Object, err error) time.Duration

UpdateStatus use reconciled objects to update component status

type Flower 

type Flower struct{}

Flower - interface to handle flower

func (*Flower) DependentResources 

func (s *Flower) DependentResources(rsrc interface{}) []reconciler.Object

DependentResources - return dependant resources

func (*Flower) Objects 

func (s *Flower) Objects(rsrc interface{}, rsrclabels map[string]string, observed, dependent, aggregated []reconciler.Object) ([]reconciler.Object, error)

Objects returns the list of resource/name for those resources created by

func (*Flower) Observables 

func (s *Flower) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable

Observables asd

type MemoryStore 

type MemoryStore struct{}

MemoryStore - interface to handle memorystore

func (*MemoryStore) DependentResources 

func (s *MemoryStore) DependentResources(rsrc interface{}) []reconciler.Object

DependentResources - return dependant resources

func (*MemoryStore) Differs 

func (s *MemoryStore) Differs(expected reconciler.Object, observed reconciler.Object) bool

Differs returns true if the resource needs to be updated

func (*MemoryStore) Finalize 

func (s *MemoryStore) Finalize(rsrc interface{}, observed, dependent []reconciler.Object) error

Finalize - finalizes MemoryStore component when it is deleted

func (*MemoryStore) Objects 

func (s *MemoryStore) Objects(rsrc interface{}, rsrclabels map[string]string, observed, dependent, aggregated []reconciler.Object) ([]reconciler.Object, error)

Objects - returns resources

func (*MemoryStore) Observables 

func (s *MemoryStore) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable

Observables for memstore

func (*MemoryStore) UpdateStatus 

func (s *MemoryStore) UpdateStatus(rsrc interface{}, reconciled []reconciler.Object, err error) time.Duration

UpdateStatus - update status block

type MySQL 

type MySQL struct{}

MySQL - interface to handle redis

func (*MySQL) Objects 

func (s *MySQL) Objects(rsrc interface{}, rsrclabels map[string]string, observed, dependent, aggregated []reconciler.Object) ([]reconciler.Object, error)

Objects returns the list of resource/name for those resources created by the operator for this spec and those resources referenced by this operator. Mark resources as owned, referred

func (*MySQL) Observables 

func (s *MySQL) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable

Observables asd

func (*MySQL) UpdateStatus 

func (s *MySQL) UpdateStatus(rsrc interface{}, reconciled []reconciler.Object, err error) time.Duration

UpdateStatus use reconciled objects to update component status

type NFS 

type NFS struct{}

NFS - interface to handle worker

func (*NFS) Objects 

func (s *NFS) Objects(rsrc interface{}, rsrclabels map[string]string, observed, dependent, aggregated []reconciler.Object) ([]reconciler.Object, error)

Objects returns the list of resource/name for those resources created by

func (*NFS) Observables 

func (s *NFS) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable

Observables asd

func (*NFS) UpdateStatus 

func (s *NFS) UpdateStatus(rsrc interface{}, reconciled []reconciler.Object, err error) time.Duration

UpdateStatus use reconciled objects to update component status

type Postgres 

type Postgres struct{}

Postgres - interface to handle flower

func (*Postgres) Objects 

func (s *Postgres) Objects(rsrc interface{}, rsrclabels map[string]string, observed, dependent, aggregated []reconciler.Object) ([]reconciler.Object, error)

Objects returns the list of resource/name for those resources created by the operator for this spec and those resources referenced by this operator. Mark resources as owned, referred

func (*Postgres) Observables 

func (s *Postgres) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable

Observables asd

func (*Postgres) UpdateStatus 

func (s *Postgres) UpdateStatus(rsrc interface{}, reconciled []reconciler.Object, err error) time.Duration

UpdateStatus use reconciled objects to update component status

type Redis 

type Redis struct{}

Redis - interface to handle redis

func (*Redis) DependentResources 

func (s *Redis) DependentResources(rsrc interface{}) []reconciler.Object

DependentResources - return dependant resources

func (*Redis) Objects 

func (s *Redis) Objects(rsrc interface{}, rsrclabels map[string]string, observed, dependent, aggregated []reconciler.Object) ([]reconciler.Object, error)

Objects returns the list of resource/name for those resources created by the operator for this spec and those resources referenced by this operator. Mark resources as owned, referred

func (*Redis) Observables 

func (s *Redis) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable

Observables asd

type SQLProxy 

type SQLProxy struct{}

SQLProxy - interface to handle scheduler

func (*SQLProxy) Objects 

func (s *SQLProxy) Objects(rsrc interface{}, rsrclabels map[string]string, observed, dependent, aggregated []reconciler.Object) ([]reconciler.Object, error)

Objects returns the list of resource/name for those resources created by the operator for this spec and those resources referenced by this operator. Mark resources as owned, referred

func (*SQLProxy) Observables 

func (s *SQLProxy) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable

Observables asd

func (*SQLProxy) UpdateStatus 

func (s *SQLProxy) UpdateStatus(rsrc interface{}, reconciled []reconciler.Object, err error) time.Duration

UpdateStatus use reconciled objects to update component status

type Scheduler 

type Scheduler struct{}

Scheduler - interface to handle scheduler

func (*Scheduler) DependentResources 

func (s *Scheduler) DependentResources(rsrc interface{}) []reconciler.Object

DependentResources - return dependant resources

func (*Scheduler) Objects 

func (s *Scheduler) Objects(rsrc interface{}, rsrclabels map[string]string, observed, dependent, aggregated []reconciler.Object) ([]reconciler.Object, error)

Objects returns the list of resource/name for those resources created by the operator for this spec and those resources referenced by this operator. Mark resources as owned, referred

func (*Scheduler) Observables 

func (s *Scheduler) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable

Observables - get

type UI 

type UI struct{}

UI - interface to handle ui

func (*UI) DependentResources 

func (s *UI) DependentResources(rsrc interface{}) []reconciler.Object

DependentResources - return dependant resources

func (*UI) Objects 

func (s *UI) Objects(rsrc interface{}, rsrclabels map[string]string, observed, dependent, aggregated []reconciler.Object) ([]reconciler.Object, error)

Objects returns the list of resource/name for those resources created by

func (*UI) Observables 

func (s *UI) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable

Observables asd

type Worker 

type Worker struct{}

Worker - interface to handle worker

func (*Worker) DependentResources 

func (s *Worker) DependentResources(rsrc interface{}) []reconciler.Object

DependentResources - return dependant resources

func (*Worker) Objects 

func (s *Worker) Objects(rsrc interface{}, rsrclabels map[string]string, observed, dependent, aggregated []reconciler.Object) ([]reconciler.Object, error)

Objects returns the list of resource/name for those resources created by the operator for this spec and those resources referenced by this operator. Mark resources as owned, referred

func (*Worker) Observables 

func (s *Worker) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable

Observables asd

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.