controller

package
v0.0.99 Latest Latest
Warning

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

Go to latest
Published: Sep 25, 2020 License: UPL-1.0 Imports: 44 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateModelBindingPair

func CreateModelBindingPair(model *v1beta1v8o.VerrazzanoModel, binding *v1beta1v8o.VerrazzanoBinding, VerrazzanoURI string, imagePullSecrets []corev1.LocalObjectReference) *types.ModelBindingPair

CreateModelBindingPair creates a unique pairing of a model and binding.

func UpdateModelBindingPair

func UpdateModelBindingPair(mbPair *types.ModelBindingPair, model *v1beta1v8o.VerrazzanoModel, binding *v1beta1v8o.VerrazzanoBinding, VerrazzanoURI string, imagePullSecrets []corev1.LocalObjectReference)

UpdateModelBindingPair updates a model/binding pair by rebuilding it.

Types

type Controller

type Controller struct {
	VerrazzanoModelLister     listers.VerrazzanoModelLister
	VerrazzanoModelInformer   cache.SharedIndexInformer
	VerrazzanoBindingLister   listers.VerrazzanoBindingLister
	VerrazzanoBindingInformer cache.SharedIndexInformer

	Manifest *util.Manifest
	// contains filtered or unexported fields
}

Controller represents the primary controller structure.

func NewController

func NewController(kubeconfig string, manifest *util.Manifest, masterURL string, watchNamespace string, verrazzanoURI string, enableMonitoringStorage string) (*Controller, error)

NewController returns a new Verrazzano Operator controller

func (*Controller) CreateUpdateGlobalEntities

func (c *Controller) CreateUpdateGlobalEntities() error

CreateUpdateGlobalEntities installs global entities

func (*Controller) ListerSet

func (c *Controller) ListerSet() Listers

ListerSet returns a list of listers used by the controller.

func (*Controller) Run

func (c *Controller) Run(threadiness int) error

Run will set up the event handlers for types we are interested in, as well as syncing informer caches and starting workers. It will block until stopCh is closed, at which point it will shutdown the workqueue and wait for workers to finish processing their current work items.

type KubeSecrets

type KubeSecrets struct {
	// contains filtered or unexported fields
}

KubeSecrets type used for CRUD operations related to secrets

func (*KubeSecrets) Create

func (ks *KubeSecrets) Create(newSecret *corev1.Secret) (*corev1.Secret, error)

Create creates a secret for a given secret name and namespace.

func (*KubeSecrets) Delete

func (ks *KubeSecrets) Delete(ns, name string) error

Delete deletes a secret for a given secret name and namespace.

func (*KubeSecrets) Get

func (ks *KubeSecrets) Get(name string) (*corev1.Secret, error)

Get returns a secret for a given secret name and namespace.

func (*KubeSecrets) GetVmiPassword

func (ks *KubeSecrets) GetVmiPassword() (string, error)

GetVmiPassword returns a Verrazzano Monitoring Instance password for given namespace.

func (*KubeSecrets) List

func (ks *KubeSecrets) List(ns string, selector labels.Selector) (ret []*corev1.Secret, err error)

List returns a list of secrets for given namespace and selector.

func (*KubeSecrets) Update

func (ks *KubeSecrets) Update(newSecret *corev1.Secret) (*corev1.Secret, error)

Update updates a secret for a given secret name and namespace.

type Listers

type Listers struct {
	ManagedClusterLister *listers.VerrazzanoManagedClusterLister
	ModelLister          *listers.VerrazzanoModelLister
	BindingLister        *listers.VerrazzanoBindingLister
	ModelBindingPairs    *map[string]*types.ModelBindingPair
	KubeClientSet        *kubernetes.Interface
}

Listers represents listers used by the controller.

Jump to

Keyboard shortcuts

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