Versions in this module Expand all Collapse all v0 v0.5.0 Aug 8, 2018 Changes in this version + 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 struct + func NewBindingLabelsFetcher(siLister scListers.ServiceInstanceLister, ...) *BindingLabelsFetcher + func (c *BindingLabelsFetcher) Fetch(svcBinding *scTypes.ServiceBinding) (map[string]string, error) + type BindingUsageSpecStorage struct + 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 struct + ConflictingResource string + func (e *ConflictError) Error() string + type DeploymentSupervisor struct + 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 struct + 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 interface + ResourceInterface func(namespace string) dynamic.ResourceInterface + type Kind string + const KindDeployment + const KindKubelessFunction + type KubelessFunctionSupervisor struct + 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 interface + EnsureLabelsCreated func(resourceNs, resourceName, usageName string, labels map[string]string) error + EnsureLabelsDeleted func(resourceNs, resourceName, usageName string) error + GetInjectedLabels func(resourceNs, resourceName, usageName string) (map[string]string, error) + HasSynced func() bool + type NotFoundError struct + func NewNotFoundError(format string, args ...interface{}) NotFoundError + func (NotFoundError) NotFound() bool + func (e NotFoundError) Error() string + type PodPresetModifier struct + func NewPodPresetModifier(settingsClient clientSettingsV1alpha1.SettingsV1alpha1Interface) *PodPresetModifier + func (m *PodPresetModifier) EnsurePodPresetDeleted(namespace, name string) error + func (m *PodPresetModifier) UpsertPodPreset(podPreset *k8sSettings.PodPreset) error + type ResourceSupervisorAggregator struct + 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 struct + func NewServiceBindingUsage(appliedSpecStorage appliedSpecStorage, ...) *ServiceBindingUsageController + func (c *ServiceBindingUsageController) Run(stopCh <-chan struct{}) + type UsageSpec struct + Applied bool + UsedBy sbuTypes.LocalReferenceByKindAndName
Go to main page