kubernetes

Feb 28, 2024

Changes in this version

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

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

type SystemCheckEntry

+ Description string

+ UpgradePattern string

+ VersionAvailable string

+ VersionInstalled string

+ WantsToBeInstalled bool

Nov 17, 2023

Changes in this version

type SystemCheckEntry

+ IsRequired bool

Nov 13, 2023

Changes in this version

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

+ func StatusEmoji(state SystemCheckStatus) string

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

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

type SystemCheckEntry

+ Status SystemCheckStatus

+ UninstallPattern string

+ func CreateSystemCheckEntry(checkName string, alreadyInstalled bool, message string) SystemCheckEntry

+ type SystemCheckStatus string

+ const INSTALLED

+ const INSTALLING

+ const NOT_INSTALLED

+ const UNINSTALLING

+ const UNKNOWN_STATUS

Nov 6, 2023

Changes in this version

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

+ func SystemCheckTerminalString(entries []SystemCheckEntry) string

type SystemCheckEntry

+ InstallPattern string

+ UnistallPattern string

type SystemCheckResponse

+ func GenerateSystemCheckResponse(entries []SystemCheckEntry) SystemCheckResponse

Nov 6, 2023

Changes in this version

+ type SystemCheckEntry struct

+ CheckName string

+ Message string

+ Success bool

+ type SystemCheckResponse struct

+ Entries []SystemCheckEntry

+ TerminalString string

Nov 2, 2023

Changes in this version

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

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

+ func SystemCheck()

Oct 30, 2023

Changes in this version

+ func IsPunqInstalled() (string, error)

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

Oct 17, 2023

Changes in this version

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

Oct 16, 2023

Changes in this version

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

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

Oct 12, 2023

Changes in this version

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

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

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

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

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

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

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

Oct 9, 2023

Changes in this version

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

Oct 6, 2023

Changes in this version

+ func GetCurrentOperatorVersion() (string, error)

Oct 5, 2023

Changes in this version

+ const RES_INGRESS_CLASS

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

+ func AllK8sIngressClasses(contextId *string) utils.K8sWorkloadResult

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

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

+ func DeleteK8sIngressClassBy(name string, contextId *string) error

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

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

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

+ type IngressType int

+ const MULTIPLE

+ const NGINX

+ const NONE

+ const TRAEFIK

+ const UNKNOWN

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

+ func (i IngressType) String() string

type K8sNewWorkload

+ func NewK8sIngressClass() K8sNewWorkload

Oct 4, 2023

Changes in this version

+ func InitKubernetes(runsInCluster bool)

Sep 27, 2023

Changes in this version

+ const RES_CONFIG_MAP

+ const RES_CUSTOM_RESOURCE_DEFINITION

+ const RES_ENDPOINT

+ const RES_LEASE

+ const RES_PRIORITY_CLASS

+ const RES_RESOURCE_QUOTA

+ const RES_STORAGE_CLASS

+ const RES_VOLUME_SNAPSHOT

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

+ func ListAllContexts() []dtos.PunqContext

Sep 18, 2023

Changes in this version

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

Sep 18, 2023

Changes in this version

+ func ContextUpdateLocalCache(ctxs []dtos.PunqContext)

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

Sep 15, 2023

Changes in this version

+ func ClusterInfo(contextId *string) dtos.ClusterInfoDto

+ func KubernetesVersion(contextId *string) *version2.Info

Sep 14, 2023

Changes in this version

+ func ContextAddMany(ctxs []dtos.PunqContext)

+ func ContextAddOne(ctx dtos.PunqContext)

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

+ func ContextFlag(id *string) string

+ func ContextForId(id string) *dtos.PunqContext

+ func ContextList() []dtos.PunqContext

+ func ExecTest() error

Sep 8, 2023

Changes in this version

+ var RunsInCluster bool = false

+ func DeleteK8sCertificateBy(namespace string, name string) error

+ func DeleteK8sCertificateSigningRequestBy(namespace string, name string) error

+ func DeleteK8sClusterIssuerBy(name string) error

+ func DeleteK8sClusterRoleBindingBy(name string) utils.K8sWorkloadResult

+ func DeleteK8sClusterRoleBy(name string) error

+ func DeleteK8sConfigmapBy(data v1.ConfigMap) error

+ func DeleteK8sCronJobBy(namespace string, name string) error

+ func DeleteK8sDaemonSetBy(namespace string, name string) error

+ func DeleteK8sDeploymentBy(namespace string, name string) error

+ func DeleteK8sEndpointBy(namespace string, name string) error

+ func DeleteK8sHpaBy(namespace string, name string) error

+ func DeleteK8sIngressBy(namespace string, name string) error

+ func DeleteK8sIssuerBy(namespace string, name string) error

+ func DeleteK8sJobBy(namespace string, name string) error

+ func DeleteK8sLeaseBy(namespace string, name string) error

+ func DeleteK8sNamespaceBy(name string) error

+ func DeleteK8sNetworkPolicyBy(namespace string, name string) error

+ func DeleteK8sNode(name string) error

+ func DeleteK8sOrderBy(namespace string, name string) error

+ func DeleteK8sPersistentVolumeBy(name string) error

+ func DeleteK8sPersistentVolumeClaimBy(namespace string, name string) error

+ func DeleteK8sPodBy(namespace string, name string) error

+ func DeleteK8sPriorityClassBy(name string) error

+ func DeleteK8sReplicasetBy(namespace string, name string) error

+ func DeleteK8sResourceQuotaBy(namespace string, name string) error

+ func DeleteK8sRoleBindingBy(namespace string, name string) error

+ func DeleteK8sRoleBy(namespace string, name string) error

+ func DeleteK8sSecretBy(namespace string, name string) error

+ func DeleteK8sServiceAccountBy(namespace string, name string) error

+ func DeleteK8sServiceBy(namespace string, name string) error

+ func DeleteK8sStatefulsetBy(namespace string, name string) error

+ func DeleteK8sStorageClassBy(name string) error

+ func DeleteK8sVolumeAttachmentBy(name string) error

+ func DeleteK8sVolumeSnapshotBy(namespace string, name string) error

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

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

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

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

+ func GetCronjob(namespaceName string, name string) (*v1job.CronJob, error)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func Init(runsInCluster bool)

Sep 4, 2023

Changes in this version

+ var ALL_RESOURCES_READER []string = []string

+ var ALL_RESOURCES_USER []string = []string

+ func DEPLOYMENTNAME() string

+ func ListWorkloadsOnTerminal(access dtos.AccessLevel)

+ func WorkloadsForAccesslevel(access dtos.AccessLevel) []string

Aug 24, 2023

Changes in this version

type K8sWorkloadResult

+ func CreateK8sCertificated(data cmapi.Certificate) K8sWorkloadResult

Aug 17, 2023

Changes in this version

+ var NAMESPACE = utils.CONFIG.Kubernetes.OwnNamespace

type KubeProvider

+ func NewKubeProviderInCluster() (*KubeProvider, error)

+ func NewKubeProviderLocal() (*KubeProvider, error)

type KubeProviderCertManager

+ func NewKubeProviderCertManagerInCluster() (*KubeProviderCertManager, error)

+ func NewKubeProviderCertManagerLocal() (*KubeProviderCertManager, error)

type KubeProviderMetrics

+ func NewKubeProviderMetricsInCluster() (*KubeProviderMetrics, error)

+ func NewKubeProviderMetricsLocal() (*KubeProviderMetrics, error)

Aug 28, 2023

Changes in this version

+ const INGRESS_PREFIX

+ const RES_CERTIFICATE

+ const RES_CERTIFICATE_REQUEST

+ const RES_CLUSTER_ISSUER

+ const RES_CLUSTER_ROLE

+ const RES_CLUSTER_ROLE_BINDING

+ const RES_CONFIGMAP

+ const RES_CRON_JOB

+ const RES_CUSTOM_RESOURCE_DEFINITIONS

+ const RES_DAEMON_SET

+ const RES_DEPLOYMENT

+ const RES_ENDPOINTS

+ const RES_EVENT

+ const RES_HORIZONTAL_POD_AUTOSCALER

+ const RES_INGRESS

+ const RES_ISSUER

+ const RES_JOB

+ const RES_LEASES

+ const RES_NAMESPACE

+ const RES_NETWORK_POLICY

+ const RES_NODE

+ const RES_ORDER

+ const RES_PERSISTENT_VOLUME

+ const RES_PERSISTENT_VOLUME_CLAIM

+ const RES_POD

+ const RES_PRIORITYCLASSES

+ const RES_REPLICA_SET

+ const RES_RESOURCEQUOTAS

+ const RES_ROLE

+ const RES_ROLE_BINDING

+ const RES_SECRET

+ const RES_SERVICE

+ const RES_SERVICE_ACCOUNT

+ const RES_STATEFUL_SET

+ const RES_STORAGECLASS

+ const RES_VOLUMESNAPSHOTS

+ const RES_VOLUME_ATTACHMENT

+ var ALL_RESOURCES []string = []string

+ var CLUSTERROLEBINDINGNAME = fmt.Sprintf("%s--cluster-role-binding-app", version.Name)

+ var CLUSTERROLENAME = fmt.Sprintf("%s--cluster-role-app", version.Name)

+ var DEPLOYMENTIMAGE = fmt.Sprintf("ghcr.io/mogenius/%s:v%s", version.Name, version.Ver)

+ var INGRESSNAME = fmt.Sprintf("%s-ingress", version.Name)

+ var RBACRESOURCES = []string

+ var SERVICEACCOUNTNAME = fmt.Sprintf("%s-service-account-app", version.Name)

+ var SERVICENAME = fmt.Sprintf("%s-service", version.Name)

+ func AllCertificates(namespaceName string) []cmapi.Certificate

+ func AllConfigmaps(namespaceName string) []v1.ConfigMap

+ func AllDaemonsets(namespaceName string) []v1.DaemonSet

+ func AllDeployments(namespaceName string) []v1.Deployment

+ func AllIngresses(namespaceName string) []v1.Ingress

+ func AllPersistentVolumeClaims(namespaceName string) []core.PersistentVolumeClaim

+ func AllPodNames() []string

+ func AllPodNamesForLabel(namespace string, labelKey string, labelValue string) []string

+ func AllPods(namespaceName string) []v1.Pod

+ func AllReplicasets(namespaceName string) []v1.ReplicaSet

+ func AllSecrets(namespaceName string) []v1.Secret

+ func AllServices(namespaceName string) []v1.Service

+ func ClusterStatus() dtos.ClusterStatusDto

+ func ConfigMapFor(namespace string, configMapName string) *v1.ConfigMap

+ func CreateClusterSecretIfNotExist(kubeProvider *KubeProvider) (utils.ClusterSecret, error)

+ func CreateContextSecretIfNotExist(kubeProvider *KubeProvider) (*dtos.PunqContext, error)

+ func CreateUserSecretIfNotExist(kubeProvider *KubeProvider) (*dtos.PunqUser, error)

+ func CurrentContextName() string

+ func Deploy(clusterName string, ingressHostname string)

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

+ func GetClusterExternalIps() []string

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

+ func GetIngressControllerIps(useLocalKubeConfig bool) []net.IP

+ func GetNodeStats() []dtos.NodeStat

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

+ func Hostname() string

+ func HumanDuration(d time.Duration) string

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

+ func LastTerminatedStateToString(terminatedState *v1.ContainerStateTerminated) string

+ func ListAllNamespace() []v1.Namespace

+ func ListAllNamespaceNames() []string

+ func ListNodes() []v1.Node

+ func ListPodsTerminal(namespace string)

+ func ListTemplatesTerminal()

+ func ListWorkloads()

+ func MoCreateOptions() metav1.CreateOptions

+ func MoUpdateOptions() metav1.UpdateOptions

+ func NamespaceExists(namespaceName string) (bool, error)

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

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

+ func Remove(clusterName string)

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

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

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

+ func StartPortForward(localPort int, podPort int)

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

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

+ func UpdateServiceWith(service *v1.Service) error

+ type K8sNewWorkload struct

+ Description string

+ Name string

+ YamlString string

+ func ListCreateTemplates() []K8sNewWorkload

+ func NewK8sCertificate() K8sNewWorkload

+ func NewK8sCertificateSigningRequest() K8sNewWorkload

+ func NewK8sClusterIssuer() K8sNewWorkload

+ func NewK8sClusterRole() K8sNewWorkload

+ func NewK8sClusterRoleBinding() K8sNewWorkload

+ func NewK8sConfigmap() K8sNewWorkload

+ func NewK8sCronJob() K8sNewWorkload

+ func NewK8sCustomResourceDefinition() K8sNewWorkload

+ func NewK8sDaemonSet() K8sNewWorkload

+ func NewK8sDeployment() K8sNewWorkload

+ func NewK8sEndpoint() K8sNewWorkload

+ func NewK8sHpa() K8sNewWorkload

+ func NewK8sIngress() K8sNewWorkload

+ func NewK8sIssuer() K8sNewWorkload

+ func NewK8sJob() K8sNewWorkload

+ func NewK8sLease() K8sNewWorkload

+ func NewK8sNamespace() K8sNewWorkload

+ func NewK8sNetPol() K8sNewWorkload

+ func NewK8sOrder() K8sNewWorkload

+ func NewK8sPersistentVolumeClaim() K8sNewWorkload

+ func NewK8sPod() K8sNewWorkload

+ func NewK8sPriorityClass() K8sNewWorkload

+ func NewK8sReplicaSet() K8sNewWorkload

+ func NewK8sResourceQuota() K8sNewWorkload

+ func NewK8sRole() K8sNewWorkload

+ func NewK8sRoleBinding() K8sNewWorkload

+ func NewK8sSecret() K8sNewWorkload

+ func NewK8sService() K8sNewWorkload

+ func NewK8sServiceAccount() K8sNewWorkload

+ func NewK8sStatefulset() K8sNewWorkload

+ func NewK8sStorageClass() K8sNewWorkload

+ func NewK8sVolume() K8sNewWorkload

+ func NewK8sVolumeAttachment() K8sNewWorkload

+ func NewK8sVolumeSnapshots() K8sNewWorkload

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

+ type K8sWorkloadResult struct

+ Error interface{}

+ Result interface{}

+ func AllCertificateSigningRequests(namespaceName string) K8sWorkloadResult

+ func AllClusterIssuers() K8sWorkloadResult

+ func AllClusterRoleBindings() K8sWorkloadResult

+ func AllClusterRoles() K8sWorkloadResult

+ func AllCronjobs(namespaceName string) K8sWorkloadResult

+ func AllCustomResourceDefinitions() K8sWorkloadResult

+ func AllEndpoints(namespaceName string) K8sWorkloadResult

+ func AllEvents(namespaceName string) K8sWorkloadResult

+ func AllHpas(namespaceName string) K8sWorkloadResult

+ func AllIssuer(namespaceName string) K8sWorkloadResult

+ func AllJobs(namespaceName string) K8sWorkloadResult

+ func AllK8sCertificates(namespaceName string) K8sWorkloadResult

+ func AllK8sConfigmaps(namespaceName string) K8sWorkloadResult

+ func AllK8sDaemonsets(namespaceName string) K8sWorkloadResult

+ func AllK8sDeployments(namespaceName string) K8sWorkloadResult

+ func AllK8sIngresses(namespaceName string) K8sWorkloadResult

+ func AllK8sPersistentVolumeClaims(namespaceName string) K8sWorkloadResult

+ func AllK8sPods(namespaceName string) K8sWorkloadResult

+ func AllK8sReplicasets(namespaceName string) K8sWorkloadResult

+ func AllK8sSecrets(namespaceName string) K8sWorkloadResult

+ func AllK8sServices(namespaceName string) K8sWorkloadResult

+ func AllLeases(namespaceName string) K8sWorkloadResult

+ func AllNetworkPolicies(namespaceName string) K8sWorkloadResult

+ func AllOrders(namespaceName string) K8sWorkloadResult

+ func AllPersistentVolumes() K8sWorkloadResult

+ func AllPriorityClasses() K8sWorkloadResult

+ func AllResourceQuotas(namespaceName string) K8sWorkloadResult

+ func AllRoleBindings(namespaceName string) K8sWorkloadResult

+ func AllRoles(namespaceName string) K8sWorkloadResult

+ func AllServiceAccounts(namespaceName string) K8sWorkloadResult

+ func AllStatefulSets(namespaceName string) K8sWorkloadResult

+ func AllStorageClasses() K8sWorkloadResult

+ func AllVolumeAttachments() K8sWorkloadResult

+ func AllVolumeSnapshots(namespace string) K8sWorkloadResult

+ func CreateK8sCertificate(data cmapi.Certificate) K8sWorkloadResult

+ func CreateK8sCertificateSigningRequest(data cmapi.CertificateRequest) K8sWorkloadResult

+ func CreateK8sClusterIssuer(data cmapi.ClusterIssuer) K8sWorkloadResult

+ func CreateK8sClusterRole(data v1.ClusterRole) K8sWorkloadResult

+ func CreateK8sClusterRoleBinding(data v1.ClusterRoleBinding) K8sWorkloadResult

+ func CreateK8sConfigMap(data v1.ConfigMap) K8sWorkloadResult

+ func CreateK8sCronJob(data v1.CronJob) K8sWorkloadResult

+ func CreateK8sCustomResourceDefinition(data apiExt.CustomResourceDefinition) K8sWorkloadResult

+ func CreateK8sDaemonSet(data v1.DaemonSet) K8sWorkloadResult

+ func CreateK8sDeployment(data v1.Deployment) K8sWorkloadResult

+ func CreateK8sEndpoint(data corev1.Endpoints) K8sWorkloadResult

+ func CreateK8sHpa(data v2.HorizontalPodAutoscaler) K8sWorkloadResult

+ func CreateK8sIngress(data v1.Ingress) K8sWorkloadResult

+ func CreateK8sIssuer(data cmapi.Issuer) K8sWorkloadResult

+ func CreateK8sJob(data v1job.Job) K8sWorkloadResult

+ func CreateK8sLease(data v1.Lease) K8sWorkloadResult

+ func CreateK8sNamespace(data v1.Namespace) K8sWorkloadResult

+ func CreateK8sNetworkpolicy(data v1.NetworkPolicy) K8sWorkloadResult

+ func CreateK8sOrder(data v1.Order) K8sWorkloadResult

+ func CreateK8sPersistentVolume(data core.PersistentVolume) K8sWorkloadResult

+ func CreateK8sPersistentVolumeClaim(data core.PersistentVolumeClaim) K8sWorkloadResult

+ func CreateK8sPod(data v1.Pod) K8sWorkloadResult

+ func CreateK8sPriorityClass(data v1.PriorityClass) K8sWorkloadResult

+ func CreateK8sReplicaSet(data v1.ReplicaSet) K8sWorkloadResult

+ func CreateK8sResourceQuota(data core.ResourceQuota) K8sWorkloadResult

+ func CreateK8sRole(data v1.Role) K8sWorkloadResult

+ func CreateK8sRoleBinding(data v1.RoleBinding) K8sWorkloadResult

+ func CreateK8sSecret(data v1.Secret) K8sWorkloadResult

+ func CreateK8sService(data v1.Service) K8sWorkloadResult

+ func CreateK8sServiceAccount(data v1.ServiceAccount) K8sWorkloadResult

+ func CreateK8sStatefulset(data v1.StatefulSet) K8sWorkloadResult

+ func CreateK8sStorageClass(data storage.StorageClass) K8sWorkloadResult

+ func CreateK8sVolumeAttachment(data storage.VolumeAttachment) K8sWorkloadResult

+ func CreateK8sVolumeSnapshot(data snap.VolumeSnapshot) K8sWorkloadResult

+ func DeleteK8sCertificate(data cmapi.Certificate) K8sWorkloadResult

+ func DeleteK8sCertificateSigningRequest(data cmapi.CertificateRequest) K8sWorkloadResult

+ func DeleteK8sClusterIssuer(data cmapi.ClusterIssuer) K8sWorkloadResult

+ func DeleteK8sClusterRole(data v1.ClusterRole) K8sWorkloadResult

+ func DeleteK8sClusterRoleBinding(data v1.ClusterRoleBinding) K8sWorkloadResult

+ func DeleteK8sConfigmap(data v1.ConfigMap) K8sWorkloadResult

+ func DeleteK8sCronJob(data v1job.CronJob) K8sWorkloadResult

+ func DeleteK8sCustomResourceDefinition(data apiExt.CustomResourceDefinition) K8sWorkloadResult

+ func DeleteK8sDaemonSet(data v1.DaemonSet) K8sWorkloadResult

+ func DeleteK8sDeployment(data v1.Deployment) K8sWorkloadResult

+ func DeleteK8sEndpoint(data corev1.Endpoints) K8sWorkloadResult

+ func DeleteK8sHpa(data v2.HorizontalPodAutoscaler) K8sWorkloadResult

+ func DeleteK8sIngress(data v1.Ingress) K8sWorkloadResult

+ func DeleteK8sIssuer(data cmapi.Issuer) K8sWorkloadResult

+ func DeleteK8sJob(data v1job.Job) K8sWorkloadResult

+ func DeleteK8sLease(data v1.Lease) K8sWorkloadResult

+ func DeleteK8sNamespace(data v1.Namespace) K8sWorkloadResult

+ func DeleteK8sNetworkPolicy(data v1.NetworkPolicy) K8sWorkloadResult

+ func DeleteK8sOrder(data v1.Order) K8sWorkloadResult

+ func DeleteK8sPersistentVolume(data core.PersistentVolume) K8sWorkloadResult

+ func DeleteK8sPersistentVolumeClaim(data core.PersistentVolumeClaim) K8sWorkloadResult

+ func DeleteK8sPod(data v1.Pod) K8sWorkloadResult

+ func DeleteK8sPriorityClass(data v1.PriorityClass) K8sWorkloadResult

+ func DeleteK8sReplicaset(data v1.ReplicaSet) K8sWorkloadResult

+ func DeleteK8sResourceQuota(data core.ResourceQuota) K8sWorkloadResult

+ func DeleteK8sRole(data v1.Role) K8sWorkloadResult

+ func DeleteK8sRoleBinding(data v1.RoleBinding) K8sWorkloadResult

+ func DeleteK8sSecret(data v1.Secret) K8sWorkloadResult

+ func DeleteK8sService(data v1.Service) K8sWorkloadResult

+ func DeleteK8sServiceAccount(data v1.ServiceAccount) K8sWorkloadResult

+ func DeleteK8sStatefulset(data v1.StatefulSet) K8sWorkloadResult

+ func DeleteK8sStorageClass(data storage.StorageClass) K8sWorkloadResult

+ func DeleteK8sVolumeAttachment(data storage.VolumeAttachment) K8sWorkloadResult

+ func DeleteK8sVolumeSnapshot(data snap.VolumeSnapshot) K8sWorkloadResult

+ func DescribeK8sCertificate(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sCertificateSigningRequest(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sClusterIssuer(name string) K8sWorkloadResult

+ func DescribeK8sClusterRole(name string) K8sWorkloadResult

+ func DescribeK8sClusterRoleBinding(name string) K8sWorkloadResult

+ func DescribeK8sConfigmap(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sCronJob(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sCustomResourceDefinition(name string) K8sWorkloadResult

+ func DescribeK8sDaemonSet(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sDeployment(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sEndpoint(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sEvent(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sHpa(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sIngress(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sIssuer(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sJob(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sLease(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sNamespace(name string) K8sWorkloadResult

+ func DescribeK8sNetworkPolicy(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sNode(name string) K8sWorkloadResult

+ func DescribeK8sOrder(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sPersistentVolume(name string) K8sWorkloadResult

+ func DescribeK8sPersistentVolumeClaim(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sPod(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sPriorityClass(name string) K8sWorkloadResult

+ func DescribeK8sReplicaset(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sResourceQuota(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sRole(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sRoleBinding(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sSecret(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sService(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sServiceAccount(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sStatefulset(namespace string, name string) K8sWorkloadResult

+ func DescribeK8sStorageClass(name string) K8sWorkloadResult

+ func DescribeK8sVolumeAttachment(name string) K8sWorkloadResult

+ func DescribeK8sVolumeSnapshot(namespace string, name string) K8sWorkloadResult

+ func ListK8sNamespaces(namespaceName string) K8sWorkloadResult

+ func ListK8sNodes() K8sWorkloadResult

+ func UpdateK8sCertificate(data cmapi.Certificate) K8sWorkloadResult

+ func UpdateK8sCertificateSigningRequest(data cmapi.CertificateRequest) K8sWorkloadResult

+ func UpdateK8sClusterIssuer(data cmapi.ClusterIssuer) K8sWorkloadResult

+ func UpdateK8sClusterRole(data v1.ClusterRole) K8sWorkloadResult

+ func UpdateK8sClusterRoleBinding(data v1.ClusterRoleBinding) K8sWorkloadResult

+ func UpdateK8sConfigMap(data v1.ConfigMap) K8sWorkloadResult

+ func UpdateK8sCronJob(data v1.CronJob) K8sWorkloadResult

+ func UpdateK8sCustomResourceDefinition(data apiExt.CustomResourceDefinition) K8sWorkloadResult

+ func UpdateK8sDaemonSet(data v1.DaemonSet) K8sWorkloadResult

+ func UpdateK8sDeployment(data v1.Deployment) K8sWorkloadResult

+ func UpdateK8sEndpoint(data corev1.Endpoints) K8sWorkloadResult

+ func UpdateK8sHpa(data v2.HorizontalPodAutoscaler) K8sWorkloadResult

+ func UpdateK8sIngress(data v1.Ingress) K8sWorkloadResult

+ func UpdateK8sIssuer(data cmapi.Issuer) K8sWorkloadResult

+ func UpdateK8sJob(data v1job.Job) K8sWorkloadResult

+ func UpdateK8sLease(data v1.Lease) K8sWorkloadResult

+ func UpdateK8sNetworkPolicy(data v1.NetworkPolicy) K8sWorkloadResult

+ func UpdateK8sOrder(data v1.Order) K8sWorkloadResult

+ func UpdateK8sPersistentVolume(data core.PersistentVolume) K8sWorkloadResult

+ func UpdateK8sPersistentVolumeClaim(data core.PersistentVolumeClaim) K8sWorkloadResult

+ func UpdateK8sPod(data v1.Pod) K8sWorkloadResult

+ func UpdateK8sPriorityClass(data v1.PriorityClass) K8sWorkloadResult

+ func UpdateK8sReplicaset(data v1.ReplicaSet) K8sWorkloadResult

+ func UpdateK8sResourceQuota(data core.ResourceQuota) K8sWorkloadResult

+ func UpdateK8sRole(data v1.Role) K8sWorkloadResult

+ func UpdateK8sRoleBinding(data v1.RoleBinding) K8sWorkloadResult

+ func UpdateK8sSecret(data v1.Secret) K8sWorkloadResult

+ func UpdateK8sService(data v1.Service) K8sWorkloadResult

+ func UpdateK8sServiceAccount(data v1.ServiceAccount) K8sWorkloadResult

+ func UpdateK8sStatefulset(data v1.StatefulSet) K8sWorkloadResult

+ func UpdateK8sStorageClass(data storage.StorageClass) K8sWorkloadResult

+ func UpdateK8sVolumeAttachment(data storage.VolumeAttachment) K8sWorkloadResult

+ func UpdateK8sVolumeSnapshot(data snap.VolumeSnapshot) K8sWorkloadResult

+ func WorkloadResult(result interface{}, err interface{}) K8sWorkloadResult

+ func WorkloadResultError(error string) K8sWorkloadResult

+ type KubeProvider struct

+ ClientConfig rest.Config

+ ClientSet *kubernetes.Clientset

+ func NewKubeProvider() *KubeProvider

+ type KubeProviderCertManager struct

+ ClientConfig rest.Config

+ ClientSet *cmclientset.Clientset

+ func NewKubeProviderCertManager() *KubeProviderCertManager

+ type KubeProviderMetrics struct

+ ClientConfig rest.Config

+ ClientSet *metricsv.Clientset

+ func NewKubeProviderMetrics() *KubeProviderMetrics

+ type KubeProviderSnapshot struct

+ ClientConfig rest.Config

+ ClientSet *snapClientset.Clientset

+ func NewKubeProviderSnapshot() *KubeProviderSnapshot

+ type MogeniusNfsInstallationStatus struct

+ Error string

+ IsInstalled bool

+ type PortForwardAPodRequest struct

+ ErrOut *bytes.Buffer

+ LocalPort int

+ Out *bytes.Buffer

+ Pod v1.Pod

+ PodPort int

+ ReadyCh chan struct{}

+ StopCh <-chan struct{}

+ type ServiceGetLogErrorResult struct

+ Log string

+ Namespace string

+ PodId string

+ Restarts int32

+ func GetLogError(namespace string, podId string) ServiceGetLogErrorResult

+ type ServiceGetLogResult struct

+ Log string

+ Namespace string

+ PodId string

+ ServerTimestamp time.Time

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

+ type ServicePodExistsResult struct

+ PodExists bool

+ func PodExists(namespace string, name string) ServicePodExistsResult