resources

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Dec 8, 2020 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Overview

*

  • Copyright © 2014-2020 The SiteWhere Authors *
  • Licensed under the Apache License, Version 2.0 (the "License");
  • you may not use this file except in compliance with the License.
  • You may obtain a copy of the License at *
  • http://www.apache.org/licenses/LICENSE-2.0 *
  • Unless required by applicable law or agreed to in writing, software
  • distributed under the License is distributed on an "AS IS" BASIS,
  • WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  • See the License for the specific language governing permissions and
  • limitations under the License.

*

  • Copyright © 2014-2020 The SiteWhere Authors *
  • Licensed under the Apache License, Version 2.0 (the "License");
  • you may not use this file except in compliance with the License.
  • You may obtain a copy of the License at *
  • http://www.apache.org/licenses/LICENSE-2.0 *
  • Unless required by applicable law or agreed to in writing, software
  • distributed under the License is distributed on an "AS IS" BASIS,
  • WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  • See the License for the specific language governing permissions and
  • limitations under the License.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateClusterRoleBindingIfNotExists 

func CreateClusterRoleBindingIfNotExists(crb *rbacv1.ClusterRoleBinding, clientset kubernetes.Interface) (*rbacv1.ClusterRoleBinding, error)

CreateClusterRoleBindingIfNotExists Create a ClusterRoleBinding if it does not exists.

func CreateClusterRoleIfNotExists 

func CreateClusterRoleIfNotExists(cr *rbacv1.ClusterRole, clientset kubernetes.Interface) (*rbacv1.ClusterRole, error)

CreateClusterRoleIfNotExists Create a ClusterRole if it does not exists.

func CreateConfigMapIfNotExists 

func CreateConfigMapIfNotExists(cm *v1.ConfigMap, clientset kubernetes.Interface, namespace string) (*v1.ConfigMap, error)

CreateConfigMapIfNotExists Create a Service Account if it does not exists.

func CreateCustomResourceDefinitionIfNotExists 

func CreateCustomResourceDefinitionIfNotExists(crd *apiextv1beta1.CustomResourceDefinition, apiextensionsclientset apiextensionsclientset.Interface) (*apiextv1beta1.CustomResourceDefinition, error)

CreateCustomResourceDefinitionIfNotExists Create a CustomResourceDefinition if it does not exists.

func CreateCustomResourceFromFile 

func CreateCustomResourceFromFile(crName string, statikFS http.FileSystem, config *rest.Config) error

CreateCustomResourceFromFile Reads a File from statik and creates a CustomResource from it.

func CreateDeploymentIfNotExists 

func CreateDeploymentIfNotExists(deploy *appsv1.Deployment, clientset kubernetes.Interface, namespace string) (*appsv1.Deployment, error)

CreateDeploymentIfNotExists Create a Service Account if it does not exists.

func CreateNamespaceIfNotExists 

func CreateNamespaceIfNotExists(namespace string, clientset kubernetes.Interface) (*v1.Namespace, error)

CreateNamespaceIfNotExists Create a Namespace in Kubernetes if it does not exists.

func CreateNetworkPolicyIfNotExists 

func CreateNetworkPolicyIfNotExists(np *networkingv1.NetworkPolicy, clientset kubernetes.Interface, namespace string) (*networkingv1.NetworkPolicy, error)

CreateNetworkPolicyIfNotExists Create a CustomResourceDefinition if it does not exists.

func CreatePersistentVolumeClaimIfNotExists 

func CreatePersistentVolumeClaimIfNotExists(pvc *v1.PersistentVolumeClaim, clientset kubernetes.Interface, namespace string) (*v1.PersistentVolumeClaim, error)

CreatePersistentVolumeClaimIfNotExists Create a Service Account if it does not exists.

func CreatePodDisruptionBudgetIfNotExists 

func CreatePodDisruptionBudgetIfNotExists(rb *policyV1beta1.PodDisruptionBudget, clientset kubernetes.Interface, namespace string) (*policyV1beta1.PodDisruptionBudget, error)

CreatePodDisruptionBudgetIfNotExists Create a PodDisruptionBudget if it does not exists.

func CreatePodIfNotExists 

func CreatePodIfNotExists(pod *v1.Pod, clientset kubernetes.Interface, namespace string) (*v1.Pod, error)

CreatePodIfNotExists Create a Service Account if it does not exists.

func CreateRoleBindingIfNotExists 

func CreateRoleBindingIfNotExists(rb *rbacv1.RoleBinding, clientset kubernetes.Interface, namespace string) (*rbacv1.RoleBinding, error)

CreateRoleBindingIfNotExists Create a RoleBinding if it does not exists.

func CreateRoleIfNotExists 

func CreateRoleIfNotExists(role *rbacv1.Role, clientset kubernetes.Interface, namespace string) (*rbacv1.Role, error)

CreateRoleIfNotExists Create a Role if it does not exists.

func CreateSecretIfNotExists 

func CreateSecretIfNotExists(sec *v1.Secret, clientset kubernetes.Interface, namespace string) (*v1.Secret, error)

CreateSecretIfNotExists Create a Service Account if it does not exists.

func CreateServiceAccountIfNotExists 

func CreateServiceAccountIfNotExists(sa *v1.ServiceAccount, clientset kubernetes.Interface, namespace string) (*v1.ServiceAccount, error)

CreateServiceAccountIfNotExists Create a Service Account if it does not exists.

func CreateServiceIfNotExists 

func CreateServiceIfNotExists(svc *v1.Service, clientset kubernetes.Interface, namespace string) (*v1.Service, error)

CreateServiceIfNotExists Create a Service Account if it does not exists.

func CreateSiteWhereInstanceCR 

func CreateSiteWhereInstanceCR(cr *unstructured.Unstructured, dynamicClient dynamic.Interface) (*unstructured.Unstructured, error)

CreateSiteWhereInstanceCR Creates a Custom Resource for a SiteWhere Instance

func CreateSiteWhereMicroserviceCR 

func CreateSiteWhereMicroserviceCR(cr *unstructured.Unstructured, namespace string, dynamicClient dynamic.Interface) (*unstructured.Unstructured, error)

CreateSiteWhereMicroserviceCR Creates a Custom Resource for a SiteWhere Microservice

func CreateStatefulSetIfNotExists 

func CreateStatefulSetIfNotExists(ss *appsv1.StatefulSet, clientset kubernetes.Interface, namespace string) (*appsv1.StatefulSet, error)

CreateStatefulSetIfNotExists Create a Service Account if it does not exists.

func DeleteClusterRoleBindingIfExists 

func DeleteClusterRoleBindingIfExists(crb *rbacv1.ClusterRoleBinding, clientset kubernetes.Interface) error

DeleteClusterRoleBindingIfExists Delete a ClusterRoleBinding if it exists.

func DeleteClusterRoleIfExists 

func DeleteClusterRoleIfExists(cr *rbacv1.ClusterRole, clientset kubernetes.Interface) error

DeleteClusterRoleIfExists Delete a ClusterRole if it exists.

func DeleteConfigMapIfExists 

func DeleteConfigMapIfExists(cm *v1.ConfigMap, clientset kubernetes.Interface, namespace string) error

DeleteConfigMapIfExists Delete a Service Account if it exists.

func DeleteCustomResourceDefinitionIfExists 

func DeleteCustomResourceDefinitionIfExists(crd *apiextv1beta1.CustomResourceDefinition, apiextensionsclientset apiextensionsclientset.Interface) error

DeleteCustomResourceDefinitionIfExists Delete a CustomResourceDefinition if it exists

func DeleteCustomResourceFromFile 

func DeleteCustomResourceFromFile(crName string, config *rest.Config, statikFS http.FileSystem) error

DeleteCustomResourceFromFile Reads a File from statik and deletes a CustomResource from it.

func DeleteDeploymentIfExists 

func DeleteDeploymentIfExists(deploy *appsv1.Deployment, clientset kubernetes.Interface, namespace string) error

DeleteDeploymentIfExists Delete a Service Account if it does not exists.

func DeleteNamespaceIfExists 

func DeleteNamespaceIfExists(namespace string, clientset kubernetes.Interface) error

DeleteNamespaceIfExists Delete a Namespace in Kubernetes if it does exists.

func DeleteNetworkPolicyIfExists 

func DeleteNetworkPolicyIfExists(np *networkingv1.NetworkPolicy, clientset kubernetes.Interface, namespace string) error

DeleteNetworkPolicyIfExists Delete a NetworkPolicy if it exists

func DeletePersistentVolumeClaimIfExists 

func DeletePersistentVolumeClaimIfExists(pvc *v1.PersistentVolumeClaim, clientset kubernetes.Interface, namespace string) error

DeletePersistentVolumeClaimIfExists Delete a Service Account if it exists.

func DeletePodDisruptionBudgetIfExists 

func DeletePodDisruptionBudgetIfExists(rb *policyV1beta1.PodDisruptionBudget, clientset kubernetes.Interface, namespace string) error

DeletePodDisruptionBudgetIfExists Delete a PodDisruptionBudget if it exists.

func DeletePodIfExists 

func DeletePodIfExists(pod *v1.Pod, clientset kubernetes.Interface, namespace string) error

DeletePodIfExists Delete a Service Account if it exists.

func DeleteRoleBindingIfExists 

func DeleteRoleBindingIfExists(rb *rbacv1.RoleBinding, clientset kubernetes.Interface, namespace string) error

DeleteRoleBindingIfExists Delete a RoleBinding if it exists.

func DeleteRoleIfExists 

func DeleteRoleIfExists(role *rbacv1.Role, clientset kubernetes.Interface, namespace string) error

DeleteRoleIfExists Delete a Role if it does not exists.

func DeleteSecretIfExists 

func DeleteSecretIfExists(sec *v1.Secret, clientset kubernetes.Interface, namespace string) error

DeleteSecretIfExists Delete a Service Account if it exists.

func DeleteServiceAccountIfExists 

func DeleteServiceAccountIfExists(sa *v1.ServiceAccount, clientset kubernetes.Interface, namespace string) error

DeleteServiceAccountIfExists Delete a Service Account if it exists.

func DeleteServiceIfExists 

func DeleteServiceIfExists(svc *v1.Service, clientset kubernetes.Interface, namespace string) error

DeleteServiceIfExists Delete a Service Account if it exists.

func DeleteSiteWhereNamespaceIfExists 

func DeleteSiteWhereNamespaceIfExists(clientset kubernetes.Interface) error

DeleteSiteWhereNamespaceIfExists Delete a Namespace in Kubernetes if it does exists.

func DeleteStatefulSetIfExists 

func DeleteStatefulSetIfExists(ss *appsv1.StatefulSet, clientset kubernetes.Interface, namespace string) error

DeleteStatefulSetIfExists Delete a Service Account if it exists.

func InstallResourceFromFile 

func InstallResourceFromFile(fileName string,
	statikFS http.FileSystem,
	clientset kubernetes.Interface,
	apiextensionsClientset apiextensionsclientset.Interface,
	config *rest.Config) error

InstallResourceFromFile Install a resource from a file name

func ListSitewhereInstacesCR 

func ListSitewhereInstacesCR(dynamicClient dynamic.Interface, clientset kubernetes.Interface) ([]*alpha3.SiteWhereInstance, error)

ListSitewhereInstacesCR List SiteWhere Instance CR installed

func SitewhereSystemNamespace 

func SitewhereSystemNamespace() string

SitewhereSystemNamespace returns the namespace for SiteWhere

func UninstallResourceFromFile 

func UninstallResourceFromFile(fileName string,
	statikFS http.FileSystem,
	clientset kubernetes.Interface,
	apiextensionsClientset apiextensionsclientset.Interface,
	config *rest.Config) error

UninstallResourceFromFile Uninstall a resource from a file name

Types

This section is empty.

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.