Documentation
¶
Index ¶
- func Add(mgr manager.Manager) error
- func IsPostgres(s *alpha1.AirflowBaseSpec) bool
- type Cluster
- func (c *Cluster) DependentResources(rsrc interface{}) []reconciler.Object
- func (c *Cluster) Objects(rsrc interface{}, rsrclabels map[string]string, ...) ([]reconciler.Object, error)
- func (c *Cluster) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable
- func (c *Cluster) UpdateStatus(rsrc interface{}, reconciled []reconciler.Object, err error) time.Duration
- type Flower
- func (s *Flower) DependentResources(rsrc interface{}) []reconciler.Object
- func (s *Flower) Objects(rsrc interface{}, rsrclabels map[string]string, ...) ([]reconciler.Object, error)
- func (s *Flower) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable
- type MemoryStore
- func (s *MemoryStore) DependentResources(rsrc interface{}) []reconciler.Object
- func (s *MemoryStore) Differs(expected reconciler.Object, observed reconciler.Object) bool
- func (s *MemoryStore) Finalize(rsrc interface{}, observed, dependent []reconciler.Object) error
- func (s *MemoryStore) Objects(rsrc interface{}, rsrclabels map[string]string, ...) ([]reconciler.Object, error)
- func (s *MemoryStore) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable
- func (s *MemoryStore) UpdateStatus(rsrc interface{}, reconciled []reconciler.Object, err error) time.Duration
- type Redis
- func (s *Redis) DependentResources(rsrc interface{}) []reconciler.Object
- func (s *Redis) Objects(rsrc interface{}, rsrclabels map[string]string, ...) ([]reconciler.Object, error)
- func (s *Redis) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable
- type Scheduler
- func (s *Scheduler) DependentResources(rsrc interface{}) []reconciler.Object
- func (s *Scheduler) Objects(rsrc interface{}, rsrclabels map[string]string, ...) ([]reconciler.Object, error)
- func (s *Scheduler) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable
- type UI
- type Worker
- func (s *Worker) DependentResources(rsrc interface{}) []reconciler.Object
- func (s *Worker) Objects(rsrc interface{}, rsrclabels map[string]string, ...) ([]reconciler.Object, error)
- func (s *Worker) Observables(rsrc interface{}, labels map[string]string, dependent []reconciler.Object) []reconciler.Observable
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Add ¶
Add creates a new AirflowBase Controller and adds it to the Manager with default RBAC. The Manager will set fields on the Controller and Start it when the Manager is Started.
func IsPostgres ¶
func IsPostgres(s *alpha1.AirflowBaseSpec) bool
IsPostgres return true for postgres
Types ¶
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 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 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