controller

Documentation

Index

• func EnsureMapIsInitiated(m map[string]string) map[string]string
• func IsNotFoundError(err error) bool
• func Merge(m1, m2 map[string]string) (map[string]string, error)
• type BindingLabelsFetcher
  • func NewBindingLabelsFetcher(siLister scListers.ServiceInstanceLister, ...) *BindingLabelsFetcher
  • func (c *BindingLabelsFetcher) Fetch(svcBinding *scTypes.ServiceBinding) (map[string]string, error)
• type BindingUsageSpecStorage
  • func NewBindingUsageSpecStorage(cfgMapClient configMapClient, cfgMapName string) *BindingUsageSpecStorage
  • func (c *BindingUsageSpecStorage) Delete(namespace, name string) error
  • func (c *BindingUsageSpecStorage) Get(usageNS, usageName string) (*UsageSpec, bool, error)
  • func (c *BindingUsageSpecStorage) Upsert(bUsage *sbuTypes.ServiceBindingUsage, applied bool) error
• type ConflictError
  • func (e *ConflictError) Error() string
• type DeploymentSupervisor
  • func NewDeploymentSupervisor(deploymentInformer informerV1beta2.DeploymentInformer, ...) *DeploymentSupervisor
  • func (m *DeploymentSupervisor) EnsureLabelsCreated(deployNS, deployName, usageName string, labels map[string]string) error
  • func (m *DeploymentSupervisor) EnsureLabelsDeleted(deployNs, deployName, usageName string) error
  • func (m *DeploymentSupervisor) GetInjectedLabels(deployNS, deployName, usageName string) (map[string]string, error)
  • func (m *DeploymentSupervisor) HasSynced() bool
• type GenericSupervisor
  • func NewGenericSupervisor(interfaceProvider InterfaceProvider, labeler labelDeleteApplier, ...) *GenericSupervisor
  • func (m *GenericSupervisor) EnsureLabelsCreated(namespace, resourceName, usageName string, labels map[string]string) error
  • func (m *GenericSupervisor) EnsureLabelsDeleted(namespace, resourceName, usageName string) error
  • func (m *GenericSupervisor) GetInjectedLabels(namespace, resourceName, usageName string) (map[string]string, error)
  • func (m *GenericSupervisor) HasSynced() bool
• type InterfaceProvider
• type Kind
• type KubelessFunctionSupervisor
  • func NewKubelessFunctionSupervisor(fnInformer kubelessInformer.FunctionInformer, ...) *KubelessFunctionSupervisor
  • func (m *KubelessFunctionSupervisor) EnsureLabelsCreated(fnNs, fnName, usageName string, labels map[string]string) error
  • func (m *KubelessFunctionSupervisor) EnsureLabelsDeleted(fnNs, fnName, usageName string) error
  • func (m *KubelessFunctionSupervisor) GetInjectedLabels(fnNS, fnName, usageName string) (map[string]string, error)
  • func (m *KubelessFunctionSupervisor) HasSynced() bool
• type KubernetesResourceSupervisor
• type NotFoundError
  • func NewNotFoundError(format string, args ...interface{}) NotFoundError
  • func (e NotFoundError) Error() string
  • func (NotFoundError) NotFound() bool
• type PodPresetModifier
  • func NewPodPresetModifier(settingsClient clientSettingsV1alpha1.SettingsV1alpha1Interface) *PodPresetModifier
  • func (m *PodPresetModifier) EnsurePodPresetDeleted(namespace, name string) error
  • func (m *PodPresetModifier) UpsertPodPreset(podPreset *k8sSettings.PodPreset) error
• type ResourceSupervisorAggregator
  • func NewResourceSupervisorAggregator() *ResourceSupervisorAggregator
  • func (f *ResourceSupervisorAggregator) Get(k Kind) (KubernetesResourceSupervisor, error)
  • func (f *ResourceSupervisorAggregator) HasSynced() bool
  • func (f *ResourceSupervisorAggregator) Register(k Kind, supervisor KubernetesResourceSupervisor) error
  • func (f *ResourceSupervisorAggregator) Unregister(k Kind) error
• type ServiceBindingUsageController
  • func NewServiceBindingUsage(appliedSpecStorage appliedSpecStorage, ...) *ServiceBindingUsageController
  • func (c *ServiceBindingUsageController) Run(stopCh <-chan struct{})
• type UsageSpec

Functions

func EnsureMapIsInitiated

func EnsureMapIsInitiated(m map[string]string) map[string]string

EnsureMapIsInitiated ensures that given map is initiated. - returns given map if it's already allocated - otherwise returns empty map

func IsNotFoundError

func IsNotFoundError(err error) bool

IsNotFoundError checks if given error is NotFound error

func Merge

func Merge(m1, m2 map[string]string) (map[string]string, error)

Merge returns map which is union of input maps. In case of of the same key defined in both maps, ConflictError will be returned

Types

type BindingLabelsFetcher

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

BindingLabelsFetcher extracts binding labels defined in ClusterServiceClass for given ServiceBinding

func NewBindingLabelsFetcher

func NewBindingLabelsFetcher(siLister scListers.ServiceInstanceLister,
	scLister scListers.ClusterServiceClassLister) *BindingLabelsFetcher

NewBindingLabelsFetcher returnd BindingLabelsFetcher

func (*BindingLabelsFetcher) Fetch

func (c *BindingLabelsFetcher) Fetch(svcBinding *scTypes.ServiceBinding) (map[string]string, error)

Fetch returns binding labels defined in ClusterServiceClass

type BindingUsageSpecStorage

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

BindingUsageSpecStorage provides functionality to get/delete/save ServiceBindingUsage.Spec

func NewBindingUsageSpecStorage

func NewBindingUsageSpecStorage(cfgMapClient configMapClient, cfgMapName string) *BindingUsageSpecStorage

NewBindingUsageSpecStorage returns new instance of BindingUsageSpecStorage

func (*BindingUsageSpecStorage) Delete

func (c *BindingUsageSpecStorage) Delete(namespace, name string) error

Delete deletes stored spec for given ServiceBindingUsage

func (*BindingUsageSpecStorage) Get

func (c *BindingUsageSpecStorage) Get(usageNS, usageName string) (*UsageSpec, bool, error)

Get returns stored spec for given ServiceBindingUsage

func (*BindingUsageSpecStorage) Upsert

func (c *BindingUsageSpecStorage) Upsert(bUsage *sbuTypes.ServiceBindingUsage, applied bool) error

Upsert upserts spec for given ServiceBindingUsage

type ConflictError

type ConflictError struct {
	ConflictingResource string
}

ConflictError indicates situation when conflict occurs

func (*ConflictError) Error

func (e *ConflictError) Error() string

type DeploymentSupervisor

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

DeploymentSupervisor validates if Deployment can be modified by given ServiceBindingUsage. If yes it can ensure that labels are present or deleted on Deployment

func NewDeploymentSupervisor

func NewDeploymentSupervisor(deploymentInformer informerV1beta2.DeploymentInformer, appsClient clientAppsV1beta2.AppsV1beta2Interface, log logrus.FieldLogger) *DeploymentSupervisor

NewDeploymentSupervisor creates a new DeploymentSupervisor.

func (*DeploymentSupervisor) EnsureLabelsCreated

func (m *DeploymentSupervisor) EnsureLabelsCreated(deployNS, deployName, usageName string, labels map[string]string) error

EnsureLabelsCreated ensures that given labels are added to Deployment

func (*DeploymentSupervisor) EnsureLabelsDeleted

func (m *DeploymentSupervisor) EnsureLabelsDeleted(deployNs, deployName, usageName string) error

EnsureLabelsDeleted ensures that given labels are deleted on Deployment

func (*DeploymentSupervisor) GetInjectedLabels

func (m *DeploymentSupervisor) GetInjectedLabels(deployNS, deployName, usageName string) (map[string]string, error)

GetInjectedLabels returns labels applied on given Deployment by usage controller

func (*DeploymentSupervisor) HasSynced

func (m *DeploymentSupervisor) HasSynced() bool

HasSynced returns true if the shared informer's store has synced

type GenericSupervisor

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

GenericSupervisor ensures that expected labels are present or not on a k8s resource provided by given InterfaceProvider.

func NewGenericSupervisor

func NewGenericSupervisor(interfaceProvider InterfaceProvider, labeler labelDeleteApplier, log logrus.FieldLogger) *GenericSupervisor

NewGenericSupervisor creates a new GenericSupervisor.

func (*GenericSupervisor) EnsureLabelsCreated

func (m *GenericSupervisor) EnsureLabelsCreated(namespace, resourceName, usageName string, labels map[string]string) error

EnsureLabelsCreated ensures that given labels are added to resource

func (*GenericSupervisor) EnsureLabelsDeleted

func (m *GenericSupervisor) EnsureLabelsDeleted(namespace, resourceName, usageName string) error

EnsureLabelsDeleted ensures that given labels are deleted on resource

func (*GenericSupervisor) GetInjectedLabels

func (m *GenericSupervisor) GetInjectedLabels(namespace, resourceName, usageName string) (map[string]string, error)

GetInjectedLabels returns labels applied on given resource by usage controller

func (*GenericSupervisor) HasSynced

func (m *GenericSupervisor) HasSynced() bool

HasSynced returns true, because the GenericSupervisor does not use any informers/caches

type InterfaceProvider

type InterfaceProvider interface {
	ResourceInterface(namespace string) dynamic.ResourceInterface
}

InterfaceProvider provides dynamic.ResourceInterface for given namespace

type Kind

type Kind string

Kind represents Kubernetes Kind name

const (
	// KindDeployment represents Deployment resource
	KindDeployment Kind = "Deployment"
	// KindKubelessFunction represents Kubeless Function resource
	KindKubelessFunction Kind = "Function"
)

type KubelessFunctionSupervisor

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

KubelessFunctionSupervisor validates if Function can be modified by given ServiceBindingUsage. If yes it can ensure that labels are present or deleted on Deployment for given Function

func NewKubelessFunctionSupervisor

func NewKubelessFunctionSupervisor(fnInformer kubelessInformer.FunctionInformer, kubelessClient kubelessClient.KubelessV1beta1Interface, log logrus.FieldLogger) *KubelessFunctionSupervisor

NewKubelessFunctionSupervisor creates a new KubelessFunctionSupervisor.

func (*KubelessFunctionSupervisor) EnsureLabelsCreated

func (m *KubelessFunctionSupervisor) EnsureLabelsCreated(fnNs, fnName, usageName string, labels map[string]string) error

EnsureLabelsCreated ensures that given labels are added to Deployment for given Function

func (*KubelessFunctionSupervisor) EnsureLabelsDeleted

func (m *KubelessFunctionSupervisor) EnsureLabelsDeleted(fnNs, fnName, usageName string) error

EnsureLabelsDeleted ensures that given labels are deleted on Deployment for given Function

func (*KubelessFunctionSupervisor) GetInjectedLabels

func (m *KubelessFunctionSupervisor) GetInjectedLabels(fnNS, fnName, usageName string) (map[string]string, error)

GetInjectedLabels returns labels applied on given Function

func (*KubelessFunctionSupervisor) HasSynced

func (m *KubelessFunctionSupervisor) HasSynced() bool

HasSynced returns true if the shared informer's store has synced

type KubernetesResourceSupervisor

type KubernetesResourceSupervisor interface {
	HasSynced() bool
	EnsureLabelsCreated(resourceNs, resourceName, usageName string, labels map[string]string) error
	EnsureLabelsDeleted(resourceNs, resourceName, usageName string) error
	GetInjectedLabels(resourceNs, resourceName, usageName string) (map[string]string, error)
}

KubernetesResourceSupervisor validates if given Kubernetes resource can be modified by ServiceBindingUsage. If yes it can ensure that labels are present or deleted on previous validated resource.

type NotFoundError

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

NotFoundError indicates situation when given resource was not found

func NewNotFoundError

func NewNotFoundError(format string, args ...interface{}) NotFoundError

NewNotFoundError returns a new not found error with given message

func (NotFoundError) Error

func (e NotFoundError) Error() string

func (NotFoundError) NotFound

func (NotFoundError) NotFound() bool

NotFound returns information if such error should be treated as not found

type PodPresetModifier

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

PodPresetModifier provides functionality needed to create and delete PodPreset

func NewPodPresetModifier

func NewPodPresetModifier(settingsClient clientSettingsV1alpha1.SettingsV1alpha1Interface) *PodPresetModifier

NewPodPresetModifier creates a new PodPresetModifier

func (*PodPresetModifier) EnsurePodPresetDeleted

func (m *PodPresetModifier) EnsurePodPresetDeleted(namespace, name string) error

EnsurePodPresetDeleted deletes a PodPreset if needed

func (*PodPresetModifier) UpsertPodPreset

func (m *PodPresetModifier) UpsertPodPreset(podPreset *k8sSettings.PodPreset) error

UpsertPodPreset creates a new PodPreset or update it if needed

type ResourceSupervisorAggregator

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

ResourceSupervisorAggregator aggregates all defined resources supervisors

func NewResourceSupervisorAggregator

func NewResourceSupervisorAggregator() *ResourceSupervisorAggregator

NewResourceSupervisorAggregator returns new instance of ResourceSupervisorAggregator

func (*ResourceSupervisorAggregator) Get

func (f *ResourceSupervisorAggregator) Get(k Kind) (KubernetesResourceSupervisor, error)

Get returns supervisor for given kind

func (*ResourceSupervisorAggregator) HasSynced

func (f *ResourceSupervisorAggregator) HasSynced() bool

HasSynced returns true if all registered supervisors are synced

func (*ResourceSupervisorAggregator) Register

func (f *ResourceSupervisorAggregator) Register(k Kind, supervisor KubernetesResourceSupervisor) error

Register adds new resource supervisor

func (*ResourceSupervisorAggregator) Unregister

func (f *ResourceSupervisorAggregator) Unregister(k Kind) error

Unregister removes resource supervisor

type ServiceBindingUsageController

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

ServiceBindingUsageController watches ServiceBindingUsage and injects data to given Deployment/Function

func NewServiceBindingUsage

func NewServiceBindingUsage(
	appliedSpecStorage appliedSpecStorage,
	bindingUsageClient sbuClient.ServicecatalogV1alpha1Interface,
	sbuInformer sbuInformer.ServiceBindingUsageInformer,
	bindingInformer scInformer.ServiceBindingInformer,
	kindSupervisors kindsSupervisors,
	podPresetModifier podPresetModifier,
	labelsFetcher bindingLabelsFetcher,
	log logrus.FieldLogger) *ServiceBindingUsageController

NewServiceBindingUsage creates a new ServiceBindingUsageController.

func (*ServiceBindingUsageController) Run

func (c *ServiceBindingUsageController) Run(stopCh <-chan struct{})

Run begins watching and syncing.

type UsageSpec

type UsageSpec struct {
	UsedBy  sbuTypes.LocalReferenceByKindAndName
	Applied bool
}

UsageSpec represents DTO which is used to store information about applied sbu in config map