kubernetes

package
v1.5.8 Latest Latest
Warning

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

Go to latest
Published: Feb 28, 2024 License: Apache-2.0 Imports: 66 Imported by: 0

Documentation

Index

Constants

View Source
const (
	RES_NAMESPACE                  string = "Namespace"
	RES_POD                        string = "Pod"
	RES_DEPLOYMENT                 string = "Deployment"
	RES_SERVICE                    string = "Service"
	RES_INGRESS                    string = "Ingress"
	RES_CONFIG_MAP                 string = "ConfigMap"
	RES_SECRET                     string = "Secret"
	RES_NODE                       string = "Node"
	RES_DAEMON_SET                 string = "DaemonSet"
	RES_STATEFUL_SET               string = "StatefulSet"
	RES_JOB                        string = "Job"
	RES_CRON_JOB                   string = "CronJob"
	RES_REPLICA_SET                string = "ReplicaSet"
	RES_PERSISTENT_VOLUME          string = "PersistentVolume"
	RES_PERSISTENT_VOLUME_CLAIM    string = "PersistentVolumeClaim"
	RES_HORIZONTAL_POD_AUTOSCALER  string = "HorizontalPodAutoscaler"
	RES_EVENT                      string = "Event"
	RES_CERTIFICATE                string = "Certificate"
	RES_CERTIFICATE_REQUEST        string = "CertificateRequest"
	RES_ORDER                      string = "Order"
	RES_ISSUER                     string = "Issuer"
	RES_CLUSTER_ISSUER             string = "ClusterIssuer"
	RES_SERVICE_ACCOUNT            string = "ServiceAccount"
	RES_ROLE                       string = "Role"
	RES_ROLE_BINDING               string = "RoleBinding"
	RES_CLUSTER_ROLE               string = "ClusterRole"
	RES_CLUSTER_ROLE_BINDING       string = "ClusterRoleBinding"
	RES_VOLUME_ATTACHMENT          string = "VolumeAttachment"
	RES_NETWORK_POLICY             string = "NetworkPolicy"
	RES_STORAGE_CLASS              string = "StorageClass"
	RES_CUSTOM_RESOURCE_DEFINITION string = "CustomResourceDefinition"
	RES_ENDPOINT                   string = "Endpoint"
	RES_LEASE                      string = "Lease"
	RES_PRIORITY_CLASS             string = "PriorityClass"
	RES_VOLUME_SNAPSHOT            string = "VolumeSnapshot"
	RES_RESOURCE_QUOTA             string = "ResourceQuota"
	RES_INGRESS_CLASS              string = "IngressClass"
)
View Source
const (
	INGRESS_PREFIX = "ingress"
)

Variables

View Source
var (
	SERVICEACCOUNTNAME     = fmt.Sprintf("%s-service-account-app", version.Name)
	CLUSTERROLENAME        = fmt.Sprintf("%s--cluster-role-app", version.Name)
	CLUSTERROLEBINDINGNAME = fmt.Sprintf("%s--cluster-role-binding-app", version.Name)
	RBACRESOURCES          = []string{"*"}
	SERVICENAME            = fmt.Sprintf("%s-service", version.Name)
	INGRESSNAME            = fmt.Sprintf("%s-ingress", version.Name)
)
View Source
var RunsInCluster bool = false

Functions

func AllCertificateSigningRequests

func AllCertificateSigningRequests(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllCertificates

func AllCertificates(namespaceName string, contextId *string) []cmapi.Certificate

func AllClusterIssuers

func AllClusterIssuers(contextId *string) utils.K8sWorkloadResult

func AllClusterRoleBindings

func AllClusterRoleBindings(contextId *string) utils.K8sWorkloadResult

func AllClusterRoles

func AllClusterRoles(contextId *string) utils.K8sWorkloadResult

func AllConfigmaps

func AllConfigmaps(namespaceName string, contextId *string) []v1.ConfigMap

func AllCronjobs

func AllCronjobs(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllCustomResourceDefinitions

func AllCustomResourceDefinitions() utils.K8sWorkloadResult

func AllDaemonsets

func AllDaemonsets(namespaceName string, contextId *string) []v1.DaemonSet

func AllDeployments

func AllDeployments(namespaceName string, contextId *string) []v1.Deployment

func AllDeploymentsIncludeIgnored added in v1.4.4

func AllDeploymentsIncludeIgnored(namespaceName string, contextId *string) []v1.Deployment

func AllEndpoints

func AllEndpoints(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllEvents

func AllEvents(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllHpas

func AllHpas(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllIngressClasses added in v1.3.2

func AllIngressClasses(contextId *string) []v1.IngressClass

func AllIngresses

func AllIngresses(namespaceName string, contextId *string) []v1.Ingress

func AllIssuer

func AllIssuer(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllJobs

func AllJobs(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllK8sCertificates

func AllK8sCertificates(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllK8sConfigmaps

func AllK8sConfigmaps(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllK8sDaemonsets

func AllK8sDaemonsets(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllK8sDeployments

func AllK8sDeployments(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllK8sIngressClasses added in v1.3.2

func AllK8sIngressClasses(contextId *string) utils.K8sWorkloadResult

func AllK8sIngresses

func AllK8sIngresses(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllK8sPersistentVolumeClaims

func AllK8sPersistentVolumeClaims(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllK8sPods

func AllK8sPods(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllK8sReplicasets

func AllK8sReplicasets(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllK8sSecrets

func AllK8sSecrets(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllK8sServices

func AllK8sServices(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllLeases

func AllLeases(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllNetworkPolicies

func AllNetworkPolicies(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllOrders

func AllOrders(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllPersistentVolumeClaims

func AllPersistentVolumeClaims(namespaceName string, contextId *string) []core.PersistentVolumeClaim

func AllPersistentVolumes

func AllPersistentVolumes(contextId *string) utils.K8sWorkloadResult

func AllPersistentVolumesRaw added in v1.5.7

func AllPersistentVolumesRaw(contextId *string) []core.PersistentVolume

func AllPodNames

func AllPodNames(contextId *string) []string

func AllPodNamesForLabel

func AllPodNamesForLabel(namespace string, labelKey string, labelValue string, contextId *string) []string

func AllPods

func AllPods(namespaceName string, contextId *string) []v1.Pod

func AllPodsOnNode added in v1.5.5

func AllPodsOnNode(nodeName string, contextId *string) []v1.Pod

func AllPriorityClasses

func AllPriorityClasses(contextId *string) utils.K8sWorkloadResult

func AllReplicasets

func AllReplicasets(namespaceName string, contextId *string) []v1.ReplicaSet

func AllResourceQuotas

func AllResourceQuotas(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllResourcesFrom added in v1.4.4

func AllResourcesFrom(namespace string, resourcesToLookFor []string, contextId *string) ([]interface{}, error)

func AllResourcesFromToCombinedYaml added in v1.4.7

func AllResourcesFromToCombinedYaml(namespace string, resourcesToLookFor []string, contextId *string) (string, error)

func AllRoleBindings

func AllRoleBindings(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllRoles

func AllRoles(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllSecrets

func AllSecrets(namespaceName string, contextId *string) []v1.Secret

func AllServiceAccounts

func AllServiceAccounts(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllServices

func AllServices(namespaceName string, contextId *string) []v1.Service

func AllStatefulSets

func AllStatefulSets(namespaceName string, contextId *string) utils.K8sWorkloadResult

func AllStorageClasses

func AllStorageClasses(contextId *string) utils.K8sWorkloadResult

func AllVolumeAttachments

func AllVolumeAttachments(contextId *string) utils.K8sWorkloadResult

func AllVolumeSnapshots

func AllVolumeSnapshots(namespace string, contextId *string) utils.K8sWorkloadResult

func ApiVersions added in v1.4.4

func ApiVersions(contextId *string) ([]string, error)

func CheckContext added in v1.4.5

func CheckContext(ctx dtos.PunqContext) (bool, dtos.KubernetesProvider, error)

func ClusterInfo added in v1.2.15

func ClusterInfo(contextId *string) dtos.ClusterInfoDto

func ClusterStatus

func ClusterStatus(contextId *string) dtos.ClusterStatusDto

func ConfigMapFor

func ConfigMapFor(namespace string, configMapName string, showError bool, contextId *string) *v1.ConfigMap

func ContextAddMany added in v1.2.1

func ContextAddMany(ctxs []dtos.PunqContext)

func ContextAddOne added in v1.2.1

func ContextAddOne(ctx dtos.PunqContext)

func ContextConfigLoader added in v1.2.1

func ContextConfigLoader(contextId *string) (*rest.Config, error)

func ContextFlag added in v1.2.1

func ContextFlag(id *string) string

func ContextForId added in v1.2.1

func ContextForId(id string) *dtos.PunqContext

func ContextList added in v1.2.1

func ContextList() []dtos.PunqContext

func ContextSwitcher added in v1.2.38

func ContextSwitcher(contextId *string) (*rest.Config, error)

func CreateContextSecretIfNotExist

func CreateContextSecretIfNotExist(provider *KubeProvider) (*dtos.PunqContext, error)

func CreateK8sCertificate

func CreateK8sCertificate(data cmapi.Certificate, contextId *string) utils.K8sWorkloadResult

func CreateK8sCertificateSigningRequest

func CreateK8sCertificateSigningRequest(data cmapi.CertificateRequest, contextId *string) utils.K8sWorkloadResult

func CreateK8sClusterIssuer

func CreateK8sClusterIssuer(data cmapi.ClusterIssuer, contextId *string) utils.K8sWorkloadResult

func CreateK8sClusterRole

func CreateK8sClusterRole(data v1.ClusterRole, contextId *string) utils.K8sWorkloadResult

func CreateK8sClusterRoleBinding

func CreateK8sClusterRoleBinding(data v1.ClusterRoleBinding, contextId *string) utils.K8sWorkloadResult

func CreateK8sConfigMap

func CreateK8sConfigMap(data v1.ConfigMap, contextId *string) utils.K8sWorkloadResult

func CreateK8sCronJob

func CreateK8sCronJob(data v1.CronJob, contextId *string) utils.K8sWorkloadResult

func CreateK8sDaemonSet

func CreateK8sDaemonSet(data v1.DaemonSet, contextId *string) utils.K8sWorkloadResult

func CreateK8sDeployment

func CreateK8sDeployment(data v1.Deployment, contextId *string) utils.K8sWorkloadResult

func CreateK8sEndpoint

func CreateK8sEndpoint(data corev1.Endpoints, contextId *string) utils.K8sWorkloadResult

func CreateK8sHpa

func CreateK8sHpa(data v2.HorizontalPodAutoscaler, contextId *string) utils.K8sWorkloadResult

func CreateK8sIngress

func CreateK8sIngress(data v1.Ingress, contextId *string) utils.K8sWorkloadResult

func CreateK8sIngressClass added in v1.3.2

func CreateK8sIngressClass(data v1.IngressClass, contextId *string) utils.K8sWorkloadResult

func CreateK8sIssuer

func CreateK8sIssuer(data cmapi.Issuer, contextId *string) utils.K8sWorkloadResult

func CreateK8sJob

func CreateK8sJob(data v1job.Job, contextId *string) utils.K8sWorkloadResult

func CreateK8sLease

func CreateK8sLease(data v1.Lease, contextId *string) utils.K8sWorkloadResult

func CreateK8sNamespace

func CreateK8sNamespace(data v1.Namespace, contextId *string) utils.K8sWorkloadResult

func CreateK8sNetworkpolicy

func CreateK8sNetworkpolicy(data v1.NetworkPolicy, contextId *string) utils.K8sWorkloadResult

func CreateK8sOrder

func CreateK8sOrder(data v1.Order, contextId *string) utils.K8sWorkloadResult

func CreateK8sPersistentVolume

func CreateK8sPersistentVolume(data core.PersistentVolume, contextId *string) utils.K8sWorkloadResult

func CreateK8sPersistentVolumeClaim

func CreateK8sPersistentVolumeClaim(data core.PersistentVolumeClaim, contextId *string) utils.K8sWorkloadResult

func CreateK8sPod

func CreateK8sPod(data v1.Pod, contextId *string) utils.K8sWorkloadResult

func CreateK8sPriorityClass

func CreateK8sPriorityClass(data v1.PriorityClass, contextId *string) utils.K8sWorkloadResult

func CreateK8sReplicaSet

func CreateK8sReplicaSet(data v1.ReplicaSet, contextId *string) utils.K8sWorkloadResult

func CreateK8sResourceQuota

func CreateK8sResourceQuota(data core.ResourceQuota, contextId *string) utils.K8sWorkloadResult

func CreateK8sRole

func CreateK8sRole(data v1.Role, contextId *string) utils.K8sWorkloadResult

func CreateK8sRoleBinding

func CreateK8sRoleBinding(data v1.RoleBinding, contextId *string) utils.K8sWorkloadResult

func CreateK8sSecret

func CreateK8sSecret(data v1.Secret, contextId *string) utils.K8sWorkloadResult

func CreateK8sService

func CreateK8sService(data v1.Service, contextId *string) utils.K8sWorkloadResult

func CreateK8sServiceAccount

func CreateK8sServiceAccount(data v1.ServiceAccount, contextId *string) utils.K8sWorkloadResult

func CreateK8sStatefulset

func CreateK8sStatefulset(data v1.StatefulSet, contextId *string) utils.K8sWorkloadResult

func CreateK8sStorageClass

func CreateK8sStorageClass(data storage.StorageClass, contextId *string) utils.K8sWorkloadResult

func CreateK8sVolumeAttachment

func CreateK8sVolumeAttachment(data storage.VolumeAttachment, contextId *string) utils.K8sWorkloadResult

func CreateK8sVolumeSnapshot

func CreateK8sVolumeSnapshot(data snap.VolumeSnapshot, contextId *string) utils.K8sWorkloadResult

func CurrentContextName

func CurrentContextName() string

func DeleteK8sCertificate

func DeleteK8sCertificate(data cmapi.Certificate, contextId *string) utils.K8sWorkloadResult

func DeleteK8sCertificateBy added in v1.2.0

func DeleteK8sCertificateBy(namespace string, name string, contextId *string) error

func DeleteK8sCertificateSigningRequest

func DeleteK8sCertificateSigningRequest(data cmapi.CertificateRequest, contextId *string) utils.K8sWorkloadResult

func DeleteK8sCertificateSigningRequestBy added in v1.2.0

func DeleteK8sCertificateSigningRequestBy(namespace string, name string, contextId *string) error

func DeleteK8sClusterIssuer

func DeleteK8sClusterIssuer(data cmapi.ClusterIssuer, contextId *string) utils.K8sWorkloadResult

func DeleteK8sClusterIssuerBy added in v1.2.0

func DeleteK8sClusterIssuerBy(name string, contextId *string) error

func DeleteK8sClusterRole

func DeleteK8sClusterRole(data v1.ClusterRole, contextId *string) utils.K8sWorkloadResult

func DeleteK8sClusterRoleBinding

func DeleteK8sClusterRoleBinding(data v1.ClusterRoleBinding, contextId *string) utils.K8sWorkloadResult

func DeleteK8sClusterRoleBindingBy added in v1.2.0

func DeleteK8sClusterRoleBindingBy(name string, contextId *string) error

func DeleteK8sClusterRoleBy added in v1.2.0

func DeleteK8sClusterRoleBy(name string, contextId *string) error

func DeleteK8sConfigmap

func DeleteK8sConfigmap(data v1.ConfigMap, contextId *string) utils.K8sWorkloadResult

func DeleteK8sConfigmapBy added in v1.2.0

func DeleteK8sConfigmapBy(namespaceName string, name string, contextId *string) error

func DeleteK8sCronJob

func DeleteK8sCronJob(data v1.CronJob, contextId *string) utils.K8sWorkloadResult

func DeleteK8sCronJobBy added in v1.2.0

func DeleteK8sCronJobBy(namespace string, name string, contextId *string) error

func DeleteK8sDaemonSet

func DeleteK8sDaemonSet(data v1.DaemonSet, contextId *string) utils.K8sWorkloadResult

func DeleteK8sDaemonSetBy added in v1.2.0

func DeleteK8sDaemonSetBy(namespace string, name string, contextId *string) error

func DeleteK8sDeployment

func DeleteK8sDeployment(data v1.Deployment, contextId *string) utils.K8sWorkloadResult

func DeleteK8sDeploymentBy added in v1.2.0

func DeleteK8sDeploymentBy(namespace string, name string, contextId *string) error

func DeleteK8sEndpoint

func DeleteK8sEndpoint(data corev1.Endpoints, contextId *string) utils.K8sWorkloadResult

func DeleteK8sEndpointBy added in v1.2.0

func DeleteK8sEndpointBy(namespace string, name string, contextId *string) error

func DeleteK8sHpa

func DeleteK8sHpa(data v2.HorizontalPodAutoscaler, contextId *string) utils.K8sWorkloadResult

func DeleteK8sHpaBy added in v1.2.0

func DeleteK8sHpaBy(namespace string, name string, contextId *string) error

func DeleteK8sIngress

func DeleteK8sIngress(data v1.Ingress, contextId *string) utils.K8sWorkloadResult

func DeleteK8sIngressBy added in v1.2.0

func DeleteK8sIngressBy(namespace string, name string, contextId *string) error

func DeleteK8sIngressClass added in v1.3.2

func DeleteK8sIngressClass(data v1.IngressClass, contextId *string) utils.K8sWorkloadResult

func DeleteK8sIngressClassBy added in v1.3.2

func DeleteK8sIngressClassBy(name string, contextId *string) error

func DeleteK8sIssuer

func DeleteK8sIssuer(data cmapi.Issuer, contextId *string) utils.K8sWorkloadResult

func DeleteK8sIssuerBy added in v1.2.0

func DeleteK8sIssuerBy(namespace string, name string, contextId *string) error

func DeleteK8sJob

func DeleteK8sJob(data v1job.Job, contextId *string) utils.K8sWorkloadResult

func DeleteK8sJobBy added in v1.2.0

func DeleteK8sJobBy(namespace string, name string, contextId *string) error

func DeleteK8sLease

func DeleteK8sLease(data v1.Lease, contextId *string) utils.K8sWorkloadResult

func DeleteK8sLeaseBy added in v1.2.0

func DeleteK8sLeaseBy(namespace string, name string, contextId *string) error

func DeleteK8sNamespace

func DeleteK8sNamespace(data v1.Namespace, contextId *string) utils.K8sWorkloadResult

func DeleteK8sNamespaceBy added in v1.2.0

func DeleteK8sNamespaceBy(name string, contextId *string) error

func DeleteK8sNetworkPolicy

func DeleteK8sNetworkPolicy(data v1.NetworkPolicy, contextId *string) utils.K8sWorkloadResult

func DeleteK8sNetworkPolicyBy added in v1.2.0

func DeleteK8sNetworkPolicyBy(namespace string, name string, contextId *string) error

func DeleteK8sNode added in v1.2.0

func DeleteK8sNode(name string, contextId *string) error

func DeleteK8sOrder

func DeleteK8sOrder(data v1.Order, contextId *string) utils.K8sWorkloadResult

func DeleteK8sOrderBy added in v1.2.0

func DeleteK8sOrderBy(namespace string, name string, contextId *string) error

func DeleteK8sPersistentVolume

func DeleteK8sPersistentVolume(data core.PersistentVolume, contextId *string) utils.K8sWorkloadResult

func DeleteK8sPersistentVolumeBy added in v1.2.0

func DeleteK8sPersistentVolumeBy(name string, contextId *string) error

func DeleteK8sPersistentVolumeClaim

func DeleteK8sPersistentVolumeClaim(data core.PersistentVolumeClaim, contextId *string) utils.K8sWorkloadResult

func DeleteK8sPersistentVolumeClaimBy added in v1.2.0

func DeleteK8sPersistentVolumeClaimBy(namespace string, name string, contextId *string) error

func DeleteK8sPod

func DeleteK8sPod(data v1.Pod, contextId *string) utils.K8sWorkloadResult

func DeleteK8sPodBy added in v1.2.0

func DeleteK8sPodBy(namespace string, name string, contextId *string) error

func DeleteK8sPriorityClass

func DeleteK8sPriorityClass(data v1.PriorityClass, contextId *string) utils.K8sWorkloadResult

func DeleteK8sPriorityClassBy added in v1.2.0

func DeleteK8sPriorityClassBy(name string, contextId *string) error

func DeleteK8sReplicaset

func DeleteK8sReplicaset(data v1.ReplicaSet, contextId *string) utils.K8sWorkloadResult

func DeleteK8sReplicasetBy added in v1.2.0

func DeleteK8sReplicasetBy(namespace string, name string, contextId *string) error

func DeleteK8sResourceQuota

func DeleteK8sResourceQuota(data core.ResourceQuota, contextId *string) utils.K8sWorkloadResult

func DeleteK8sResourceQuotaBy added in v1.2.0

func DeleteK8sResourceQuotaBy(namespace string, name string, contextId *string) error

func DeleteK8sRole

func DeleteK8sRole(data v1.Role, contextId *string) utils.K8sWorkloadResult

func DeleteK8sRoleBinding

func DeleteK8sRoleBinding(data v1.RoleBinding, contextId *string) utils.K8sWorkloadResult

func DeleteK8sRoleBindingBy added in v1.2.0

func DeleteK8sRoleBindingBy(namespace string, name string, contextId *string) error

func DeleteK8sRoleBy added in v1.2.0

func DeleteK8sRoleBy(namespace string, name string, contextId *string) error

func DeleteK8sSecret

func DeleteK8sSecret(data v1.Secret, contextId *string) utils.K8sWorkloadResult

func DeleteK8sSecretBy added in v1.2.0

func DeleteK8sSecretBy(namespace string, name string, contextId *string) error

func DeleteK8sService

func DeleteK8sService(data v1.Service, contextId *string) utils.K8sWorkloadResult

func DeleteK8sServiceAccount

func DeleteK8sServiceAccount(data v1.ServiceAccount, contextId *string) utils.K8sWorkloadResult

func DeleteK8sServiceAccountBy added in v1.2.0

func DeleteK8sServiceAccountBy(namespace string, name string, contextId *string) error

func DeleteK8sServiceBy added in v1.2.0

func DeleteK8sServiceBy(namespace string, name string, contextId *string) error

func DeleteK8sStatefulset

func DeleteK8sStatefulset(data v1.StatefulSet, contextId *string) utils.K8sWorkloadResult

func DeleteK8sStatefulsetBy added in v1.2.0

func DeleteK8sStatefulsetBy(namespace string, name string, contextId *string) error

func DeleteK8sStorageClass

func DeleteK8sStorageClass(data storage.StorageClass, contextId *string) utils.K8sWorkloadResult

func DeleteK8sStorageClassBy added in v1.2.0

func DeleteK8sStorageClassBy(name string, contextId *string) error

func DeleteK8sVolumeAttachment

func DeleteK8sVolumeAttachment(data storage.VolumeAttachment, contextId *string) utils.K8sWorkloadResult

func DeleteK8sVolumeAttachmentBy added in v1.2.0

func DeleteK8sVolumeAttachmentBy(name string, contextId *string) error

func DeleteK8sVolumeSnapshot

func DeleteK8sVolumeSnapshot(data snap.VolumeSnapshot, contextId *string) utils.K8sWorkloadResult

func DeleteK8sVolumeSnapshotBy added in v1.2.0

func DeleteK8sVolumeSnapshotBy(namespace string, name string, contextId *string) error

func Deploy

func Deploy(clusterName string, ingressHostname string)

func DescribeK8sCertificate

func DescribeK8sCertificate(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sCertificateSigningRequest

func DescribeK8sCertificateSigningRequest(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sClusterIssuer

func DescribeK8sClusterIssuer(name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sClusterRole

func DescribeK8sClusterRole(name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sClusterRoleBinding

func DescribeK8sClusterRoleBinding(name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sConfigmap

func DescribeK8sConfigmap(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sCronJob

func DescribeK8sCronJob(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sCustomResourceDefinition

func DescribeK8sCustomResourceDefinition(name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sDaemonSet

func DescribeK8sDaemonSet(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sDeployment

func DescribeK8sDeployment(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sEndpoint

func DescribeK8sEndpoint(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sEvent

func DescribeK8sEvent(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sHpa

func DescribeK8sHpa(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sIngress

func DescribeK8sIngress(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sIngressClass added in v1.3.2

func DescribeK8sIngressClass(name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sIssuer

func DescribeK8sIssuer(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sJob

func DescribeK8sJob(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sLease

func DescribeK8sLease(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sNamespace

func DescribeK8sNamespace(name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sNetworkPolicy

func DescribeK8sNetworkPolicy(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sNode

func DescribeK8sNode(name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sOrder

func DescribeK8sOrder(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sPersistentVolume

func DescribeK8sPersistentVolume(name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sPersistentVolumeClaim

func DescribeK8sPersistentVolumeClaim(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sPod

func DescribeK8sPod(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sPriorityClass

func DescribeK8sPriorityClass(name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sReplicaset

func DescribeK8sReplicaset(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sResourceQuota

func DescribeK8sResourceQuota(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sRole

func DescribeK8sRole(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sRoleBinding

func DescribeK8sRoleBinding(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sSecret

func DescribeK8sSecret(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sService

func DescribeK8sService(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sServiceAccount

func DescribeK8sServiceAccount(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sStatefulset

func DescribeK8sStatefulset(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sStorageClass

func DescribeK8sStorageClass(name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sVolumeAttachment

func DescribeK8sVolumeAttachment(name string, contextId *string) utils.K8sWorkloadResult

func DescribeK8sVolumeSnapshot

func DescribeK8sVolumeSnapshot(namespace string, name string, contextId *string) utils.K8sWorkloadResult

func GetCertificate

func GetCertificate(namespaceName string, resourceName string, contextId *string) (*cmapi.Certificate, error)

func GetCertificateSigningRequest added in v1.2.0

func GetCertificateSigningRequest(namespaceName string, name string, contextId *string) (*cmapi.CertificateRequest, error)

func GetClusterExternalIps

func GetClusterExternalIps(contextId *string) []string

func GetClusterIssuer added in v1.2.0

func GetClusterIssuer(name string, contextId *string) (*cmapi.ClusterIssuer, error)

func GetClusterRole added in v1.2.0

func GetClusterRole(name string, contextId *string) (*v1.ClusterRole, error)

func GetClusterRoleBinding added in v1.2.0

func GetClusterRoleBinding(name string, contextId *string) (*v1.ClusterRoleBinding, error)

func GetCronjob added in v1.2.0

func GetCronjob(namespaceName string, name string, contextId *string) (*v1.CronJob, error)

func GetCurrentOperatorVersion added in v1.3.6

func GetCurrentOperatorVersion() (string, error)

func GetEndpoint added in v1.2.0

func GetEndpoint(namespaceName string, name string, contextId *string) (*corev1.Endpoints, error)

func GetEvent added in v1.2.0

func GetEvent(namespaceName string, name string, contextId *string) (*v1Core.Event, error)

func GetFirstPodForLabelName

func GetFirstPodForLabelName(namespace string, labelName string, contextId *string) *v1.Pod

labelname should look like app=my-app-name (like you defined your label)

func GetHpa added in v1.2.0

func GetHpa(namespaceName string, name string, contextId *string) (*v2.HorizontalPodAutoscaler, error)

func GetIngressControllerIps

func GetIngressControllerIps(useLocalKubeConfig bool, contextId *string) []net.IP

func GetIssuer added in v1.2.0

func GetIssuer(namespaceName string, name string, contextId *string) (*cmapi.Issuer, error)

func GetJob added in v1.2.0

func GetJob(namespaceName string, name string, contextId *string) (*v1job.Job, error)

func GetK8sConfigmap added in v1.2.0

func GetK8sConfigmap(namespaceName string, name string, contextId *string) (*v1.ConfigMap, error)

func GetK8sDaemonset added in v1.2.0

func GetK8sDaemonset(namespaceName string, name string, contextId *string) (*v1.DaemonSet, error)

func GetK8sDeployment added in v1.2.0

func GetK8sDeployment(namespaceName string, name string, contextId *string) (*v1.Deployment, error)

func GetK8sIngress added in v1.2.0

func GetK8sIngress(namespaceName string, name string, contextId *string) (*v1.Ingress, error)

func GetK8sIngressClass added in v1.3.2

func GetK8sIngressClass(name string, contextId *string) (*v1.IngressClass, error)

func GetK8sNode added in v1.2.0

func GetK8sNode(name string, contextId *string) (*v1.Node, error)

func GetLeas added in v1.2.0

func GetLeas(namespaceName string, name string, contextId *string) (*v1.Lease, error)

func GetNamespace added in v1.2.0

func GetNamespace(name string, contextId *string) (*v1.Namespace, error)

func GetNetworkPolicy added in v1.2.0

func GetNetworkPolicy(namespaceName string, name string, contextId *string) (*v1.NetworkPolicy, error)

func GetNodeStats

func GetNodeStats(contextId *string) []dtos.NodeStat

func GetOrder added in v1.2.0

func GetOrder(namespaceName string, name string, contextId *string) (*v1.Order, error)

func GetPersistentVolume added in v1.2.0

func GetPersistentVolume(name string, contextId *string) (*core.PersistentVolume, error)

func GetPersistentVolumeClaim added in v1.2.0

func GetPersistentVolumeClaim(namespaceName string, name string, contextId *string) (*core.PersistentVolumeClaim, error)

func GetPod

func GetPod(namespace string, podName string, contextId *string) *v1.Pod

func GetPodBy added in v1.2.0

func GetPodBy(namespace string, podName string, contextId *string) (*v1.Pod, error)

func GetPriorityClass added in v1.2.0

func GetPriorityClass(name string, contextId *string) (*v1.PriorityClass, error)

func GetReplicaset added in v1.2.0

func GetReplicaset(namespaceName string, name string, contextId *string) (*v1.ReplicaSet, error)

func GetResourceQuota added in v1.2.0

func GetResourceQuota(namespaceName string, name string, contextId *string) (*core.ResourceQuota, error)

func GetRole added in v1.2.0

func GetRole(namespaceName string, name string, contextId *string) (*v1.Role, error)

func GetRoleBinding added in v1.2.0

func GetRoleBinding(namespaceName string, name string, contextId *string) (*v1.RoleBinding, error)

func GetSecret added in v1.2.0

func GetSecret(namespace string, name string, contextId *string) (*v1.Secret, error)

func GetService added in v1.2.0

func GetService(namespace string, serviceName string, contextId *string) (*v1.Service, error)

func GetServiceAccount added in v1.2.0

func GetServiceAccount(namespaceName string, name string, contextId *string) (*v1.ServiceAccount, error)

func GetStatefulSet added in v1.2.0

func GetStatefulSet(namespaceName string, name string, contextId *string) (*v1.StatefulSet, error)

func GetStorageClass added in v1.2.0

func GetStorageClass(name string, contextId *string) (*storage.StorageClass, error)

func GetVolumeAttachment added in v1.2.0

func GetVolumeAttachment(name string, contextId *string) (*storage.VolumeAttachment, error)

func GetVolumeSnapshot added in v1.2.0

func GetVolumeSnapshot(namespace string, name string, contextId *string) (*snap.VolumeSnapshot, error)

func GuessCluserProviderFromNodeList added in v1.4.5

func GuessCluserProviderFromNodeList(nodes *v1.NodeList) (dtos.KubernetesProvider, error)

func GuessClusterProvider added in v1.4.4

func GuessClusterProvider(contextId *string) (dtos.KubernetesProvider, error)

func Hostname

func Hostname(contextId *string) string

func HumanDuration

func HumanDuration(d time.Duration) string

TAKEN FROM Kubernetes apimachineryv0.25.1

func ImagesContain added in v1.5.7

func ImagesContain(images []v1.ContainerImage, str string) bool

func InitKubernetes added in v1.3.0

func InitKubernetes(runsInCluster bool)

func IsDaemonSetInstalled added in v1.5.4

func IsDaemonSetInstalled(namespaceName string, name string) (string, error)

func IsDeploymentInstalled added in v1.5.2

func IsDeploymentInstalled(namespaceName string, name string) (string, error)

func IsMetricsServerAvailable added in v1.4.4

func IsMetricsServerAvailable(contextId *string) (bool, string, error)

func KubernetesVersion added in v1.2.15

func KubernetesVersion(contextId *string) *version2.Info

func LabelsContain added in v1.4.4

func LabelsContain(labels map[string]string, str string) bool

func LastTerminatedStateIfAny

func LastTerminatedStateIfAny(pod *v1.Pod) *v1.ContainerStateTerminated

func LastTerminatedStateToString

func LastTerminatedStateToString(terminatedState *v1.ContainerStateTerminated) string

func ListAllContexts added in v1.2.38

func ListAllContexts() []dtos.PunqContext

func ListAllNamespace

func ListAllNamespace(contextId *string) []v1.Namespace

func ListAllNamespaceNames

func ListAllNamespaceNames(contextId *string) []string

func ListK8sNamespaces

func ListK8sNamespaces(namespaceName string, contextId *string) utils.K8sWorkloadResult

func ListK8sNodes

func ListK8sNodes(contextId *string) utils.K8sWorkloadResult

func ListNodeMetricss added in v1.4.4

func ListNodeMetricss(contextId *string) []v1beta1.NodeMetrics

func ListNodes

func ListNodes(contextId *string) []v1.Node

func ListPodsTerminal

func ListPodsTerminal(namespace string, contextId *string)

func ListTemplatesTerminal

func ListTemplatesTerminal()

func ListWorkloadsOnTerminal added in v1.1.42

func ListWorkloadsOnTerminal(access dtos.AccessLevel)

func MoCreateOptions

func MoCreateOptions() metav1.CreateOptions

func MoUpdateOptions

func MoUpdateOptions() metav1.UpdateOptions

func NamespaceExists

func NamespaceExists(namespaceName string, contextId *string) (bool, error)

func PodIdsFor

func PodIdsFor(namespace string, serviceId *string, contextId *string) []string

func PodStatus

func PodStatus(namespace string, name string, statusOnly bool, contextId *string) *v1.Pod

func Proxy added in v1.5.0

func Proxy(backendUrl string, frontendUrl string, websocketUrl string)

func Remove

func Remove(clusterName string)

func SecretFor

func SecretFor(namespace string, name string, contextId *string) *v1.Secret

func SendData added in v1.4.0

func SendData(cmdStdin io.WriteCloser, cmdStdout io.ReadCloser)

func ServiceFor

func ServiceFor(namespace string, serviceName string, contextId *string) *v1.Service

func ServicePodStatus

func ServicePodStatus(namespace string, serviceName string, contextId *string) []v1.Pod

func StartPortForward

func StartPortForward(localPort int, podPort int, readyChannel chan struct{}, stopChannel chan struct{}, contextId *string)

func StatusEmoji added in v1.5.5

func StatusEmoji(state SystemCheckStatus) string

func StatusMessage added in v1.5.2

func StatusMessage(err error, solution string, successMsg string) string

func StreamLog

func StreamLog(namespace string, podId string, sinceSeconds int64, contextId *string) (*rest.Request, error)

func StreamPreviousLog

func StreamPreviousLog(namespace string, podId string, contextId *string) (*rest.Request, error)

func SumCpuResources added in v1.5.5

func SumCpuResources(pods []v1.Pod) (request float64, limit float64)

func SumMemoryResources added in v1.5.5

func SumMemoryResources(pods []v1.Pod) (request int64, limit int64)

func SystemCheckTerminalString added in v1.5.4

func SystemCheckTerminalString(entries []SystemCheckEntry) string

func UpdateDeploymentImage added in v1.2.20

func UpdateDeploymentImage(namespace string, name string, image string, contextId *string) error

func UpdateK8sCertificate

func UpdateK8sCertificate(data cmapi.Certificate, contextId *string) utils.K8sWorkloadResult

func UpdateK8sCertificateSigningRequest

func UpdateK8sCertificateSigningRequest(data cmapi.CertificateRequest, contextId *string) utils.K8sWorkloadResult

func UpdateK8sClusterIssuer

func UpdateK8sClusterIssuer(data cmapi.ClusterIssuer, contextId *string) utils.K8sWorkloadResult

func UpdateK8sClusterRole

func UpdateK8sClusterRole(data v1.ClusterRole, contextId *string) utils.K8sWorkloadResult

func UpdateK8sClusterRoleBinding

func UpdateK8sClusterRoleBinding(data v1.ClusterRoleBinding, contextId *string) utils.K8sWorkloadResult

func UpdateK8sConfigMap

func UpdateK8sConfigMap(data v1.ConfigMap, contextId *string) utils.K8sWorkloadResult

func UpdateK8sCronJob

func UpdateK8sCronJob(data v1.CronJob, contextId *string) utils.K8sWorkloadResult

func UpdateK8sDaemonSet

func UpdateK8sDaemonSet(data v1.DaemonSet, contextId *string) utils.K8sWorkloadResult

func UpdateK8sDeployment

func UpdateK8sDeployment(data v1.Deployment, contextId *string) utils.K8sWorkloadResult

func UpdateK8sEndpoint

func UpdateK8sEndpoint(data corev1.Endpoints, contextId *string) utils.K8sWorkloadResult

func UpdateK8sHpa

func UpdateK8sHpa(data v2.HorizontalPodAutoscaler, contextId *string) utils.K8sWorkloadResult

func UpdateK8sIngress

func UpdateK8sIngress(data v1.Ingress, contextId *string) utils.K8sWorkloadResult

func UpdateK8sIngressClass added in v1.3.2

func UpdateK8sIngressClass(data v1.IngressClass, contextId *string) utils.K8sWorkloadResult

func UpdateK8sIssuer

func UpdateK8sIssuer(data cmapi.Issuer, contextId *string) utils.K8sWorkloadResult

func UpdateK8sJob

func UpdateK8sJob(data v1job.Job, contextId *string) utils.K8sWorkloadResult

func UpdateK8sLease

func UpdateK8sLease(data v1.Lease, contextId *string) utils.K8sWorkloadResult

func UpdateK8sNamespace added in v1.2.19

func UpdateK8sNamespace(data v1.Namespace, contextId *string) utils.K8sWorkloadResult

func UpdateK8sNetworkPolicy

func UpdateK8sNetworkPolicy(data v1.NetworkPolicy, contextId *string) utils.K8sWorkloadResult

func UpdateK8sOrder

func UpdateK8sOrder(data v1.Order, contextId *string) utils.K8sWorkloadResult

func UpdateK8sPersistentVolume

func UpdateK8sPersistentVolume(data core.PersistentVolume, contextId *string) utils.K8sWorkloadResult

func UpdateK8sPersistentVolumeClaim

func UpdateK8sPersistentVolumeClaim(data core.PersistentVolumeClaim, contextId *string) utils.K8sWorkloadResult

func UpdateK8sPod

func UpdateK8sPod(data v1.Pod, contextId *string) utils.K8sWorkloadResult

func UpdateK8sPriorityClass

func UpdateK8sPriorityClass(data v1.PriorityClass, contextId *string) utils.K8sWorkloadResult

func UpdateK8sReplicaset

func UpdateK8sReplicaset(data v1.ReplicaSet, contextId *string) utils.K8sWorkloadResult

func UpdateK8sResourceQuota

func UpdateK8sResourceQuota(data core.ResourceQuota, contextId *string) utils.K8sWorkloadResult

func UpdateK8sRole

func UpdateK8sRole(data v1.Role, contextId *string) utils.K8sWorkloadResult

func UpdateK8sRoleBinding

func UpdateK8sRoleBinding(data v1.RoleBinding, contextId *string) utils.K8sWorkloadResult

func UpdateK8sSecret

func UpdateK8sSecret(data v1.Secret, contextId *string) utils.K8sWorkloadResult

func UpdateK8sService

func UpdateK8sService(data v1.Service, contextId *string) utils.K8sWorkloadResult

func UpdateK8sServiceAccount

func UpdateK8sServiceAccount(data v1.ServiceAccount, contextId *string) utils.K8sWorkloadResult

func UpdateK8sStatefulset

func UpdateK8sStatefulset(data v1.StatefulSet, contextId *string) utils.K8sWorkloadResult

func UpdateK8sStorageClass

func UpdateK8sStorageClass(data storage.StorageClass, contextId *string) utils.K8sWorkloadResult

func UpdateK8sVolumeAttachment

func UpdateK8sVolumeAttachment(data storage.VolumeAttachment, contextId *string) utils.K8sWorkloadResult

func UpdateK8sVolumeSnapshot

func UpdateK8sVolumeSnapshot(data snap.VolumeSnapshot) utils.K8sWorkloadResult

func UpdateServiceWith

func UpdateServiceWith(service *v1.Service, contextId *string) error

func WorkloadResult

func WorkloadResult(result interface{}, err interface{}) utils.K8sWorkloadResult

func WorkloadResultError

func WorkloadResultError(error string) utils.K8sWorkloadResult

func WorkloadsForAccesslevel added in v1.1.42

func WorkloadsForAccesslevel(access dtos.AccessLevel) []string

Types

type IngressType added in v1.3.2

type IngressType int
const (
	NGINX IngressType = iota
	TRAEFIK
	MULTIPLE
	NONE
	UNKNOWN
)

func DetermineIngressControllerType added in v1.3.2

func DetermineIngressControllerType(contextId *string) (IngressType, error)

func (IngressType) String added in v1.3.2

func (i IngressType) String() string

type K8sNewWorkload

type K8sNewWorkload struct {
	Name        string `json:"name"`
	YamlString  string `json:"yamlString"`
	Description string `json:"description"`
}

func ListCreateTemplates

func ListCreateTemplates() []K8sNewWorkload

func NewK8sCertificate

func NewK8sCertificate() K8sNewWorkload

func NewK8sCertificateSigningRequest

func NewK8sCertificateSigningRequest() K8sNewWorkload

func NewK8sClusterIssuer

func NewK8sClusterIssuer() K8sNewWorkload

func NewK8sClusterRole

func NewK8sClusterRole() K8sNewWorkload

func NewK8sClusterRoleBinding

func NewK8sClusterRoleBinding() K8sNewWorkload

func NewK8sConfigmap

func NewK8sConfigmap() K8sNewWorkload

func NewK8sCronJob

func NewK8sCronJob() K8sNewWorkload

func NewK8sCustomResourceDefinition

func NewK8sCustomResourceDefinition() K8sNewWorkload

func NewK8sDaemonSet

func NewK8sDaemonSet() K8sNewWorkload

func NewK8sDeployment

func NewK8sDeployment() K8sNewWorkload

func NewK8sEndpoint

func NewK8sEndpoint() K8sNewWorkload

func NewK8sHpa

func NewK8sHpa() K8sNewWorkload

func NewK8sIngress

func NewK8sIngress() K8sNewWorkload

func NewK8sIngressClass added in v1.3.2

func NewK8sIngressClass() K8sNewWorkload

func NewK8sIssuer

func NewK8sIssuer() K8sNewWorkload

func NewK8sJob

func NewK8sJob() K8sNewWorkload

func NewK8sLease

func NewK8sLease() K8sNewWorkload

func NewK8sNamespace

func NewK8sNamespace() K8sNewWorkload

func NewK8sNetPol

func NewK8sNetPol() K8sNewWorkload

func NewK8sOrder

func NewK8sOrder() K8sNewWorkload

func NewK8sPersistentVolumeClaim

func NewK8sPersistentVolumeClaim() K8sNewWorkload

func NewK8sPod

func NewK8sPod() K8sNewWorkload

func NewK8sPriorityClass

func NewK8sPriorityClass() K8sNewWorkload

func NewK8sReplicaSet

func NewK8sReplicaSet() K8sNewWorkload

func NewK8sResourceQuota

func NewK8sResourceQuota() K8sNewWorkload

func NewK8sRole

func NewK8sRole() K8sNewWorkload

func NewK8sRoleBinding

func NewK8sRoleBinding() K8sNewWorkload

func NewK8sSecret

func NewK8sSecret() K8sNewWorkload

func NewK8sService

func NewK8sService() K8sNewWorkload

func NewK8sServiceAccount

func NewK8sServiceAccount() K8sNewWorkload

func NewK8sStatefulset

func NewK8sStatefulset() K8sNewWorkload

func NewK8sStorageClass

func NewK8sStorageClass() K8sNewWorkload

func NewK8sVolume

func NewK8sVolume() K8sNewWorkload

func NewK8sVolumeAttachment

func NewK8sVolumeAttachment() K8sNewWorkload

func NewK8sVolumeSnapshots

func NewK8sVolumeSnapshots() K8sNewWorkload

func NewWorkload

func NewWorkload(name string, yaml string, description string) K8sNewWorkload

type KubeProvider

type KubeProvider struct {
	ClientSet    *kubernetes.Clientset
	ClientConfig rest.Config
}

func NewKubeProvider

func NewKubeProvider(contextId *string) (*KubeProvider, error)

type KubeProviderCertManager

type KubeProviderCertManager struct {
	ClientSet    *cmclientset.Clientset
	ClientConfig rest.Config
}

func NewKubeProviderCertManager

func NewKubeProviderCertManager(contextId *string) (*KubeProviderCertManager, error)

type KubeProviderMetrics

type KubeProviderMetrics struct {
	ClientSet    *metricsv.Clientset
	ClientConfig rest.Config
}

func NewKubeProviderMetrics

func NewKubeProviderMetrics(contextId *string) (*KubeProviderMetrics, error)

type KubeProviderSnapshot

type KubeProviderSnapshot struct {
	ClientSet    *snapClientset.Clientset
	ClientConfig rest.Config
}

func NewKubeProviderSnapshot

func NewKubeProviderSnapshot(contextId *string) (*KubeProviderSnapshot, error)

type MogeniusNfsInstallationStatus

type MogeniusNfsInstallationStatus struct {
	Error       string `json:"error,omitempty"`
	IsInstalled bool   `json:"isInstalled"`
}

type PortForwardAPodRequest

type PortForwardAPodRequest struct {
	Pod       v1.Pod
	LocalPort int
	PodPort   int
	Out       *bytes.Buffer
	ErrOut    *bytes.Buffer
	// StopCh is the channel used to manage the port forward lifecycle
	StopCh <-chan struct{}
	// ReadyCh communicates when the tunnel is ready to receive traffic
	ReadyCh chan struct{}
}

type ServiceGetLogErrorResult

type ServiceGetLogErrorResult struct {
	Namespace string `json:"namespace"`
	PodId     string `json:"podId"`
	Restarts  int32  `json:"restarts"`
	Log       string `json:"log"`
}

func GetLogError

func GetLogError(namespace string, podId string, contextId *string) ServiceGetLogErrorResult

type ServiceGetLogResult

type ServiceGetLogResult struct {
	Namespace       string    `json:"namespace"`
	PodId           string    `json:"podId"`
	ServerTimestamp time.Time `json:"serverTimestamp"`
	Log             string    `json:"log"`
}

func GetLog

func GetLog(namespace string, podId string, timestamp *time.Time, contextId *string) ServiceGetLogResult

type ServicePodExistsResult

type ServicePodExistsResult struct {
	PodExists bool `json:"podExists"`
}

func PodExists

func PodExists(namespace string, name string, contextId *string) ServicePodExistsResult

type SystemCheckEntry added in v1.5.3

type SystemCheckEntry struct {
	CheckName          string            `json:"checkName"`
	Status             SystemCheckStatus `json:"status"`
	Message            string            `json:"message"`
	Description        string            `json:"description"`
	InstallPattern     string            `json:"installPattern"`
	UpgradePattern     string            `json:"upgradePattern"`
	UninstallPattern   string            `json:"uninstallPattern"`
	IsRequired         bool              `json:"isRequired"`
	WantsToBeInstalled bool              `json:"wantsToBeInstalled"`
	VersionInstalled   string            `json:"versionInstalled"`
	VersionAvailable   string            `json:"versionAvailable"`
}

func CreateSystemCheckEntry added in v1.5.5

func CreateSystemCheckEntry(checkName string, alreadyInstalled bool, message string, description string, isRequired bool, wantsToBeInstalled bool, versionInstalled string, versionAvailable string) SystemCheckEntry

func SystemCheck added in v1.5.2

func SystemCheck() []SystemCheckEntry

type SystemCheckResponse added in v1.5.3

type SystemCheckResponse struct {
	TerminalString string             `json:"terminalString"`
	Entries        []SystemCheckEntry `json:"entries"`
}

func GenerateSystemCheckResponse added in v1.5.4

func GenerateSystemCheckResponse(entries []SystemCheckEntry) SystemCheckResponse

type SystemCheckStatus added in v1.5.5

type SystemCheckStatus string
const (
	UNKNOWN_STATUS SystemCheckStatus = "UNKNOWN_STATUS"
	INSTALLING     SystemCheckStatus = "INSTALLING"
	UNINSTALLING   SystemCheckStatus = "UNINSTALLING"
	NOT_INSTALLED  SystemCheckStatus = "NOT_INSTALLED"
	INSTALLED      SystemCheckStatus = "INSTALLED"
)

Jump to

Keyboard shortcuts

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