kuber

package

Go to main page

Versions in this module

v3

v3.6.3

Aug 4, 2021

v3.6.2

Jun 9, 2021

v3.6.1

May 17, 2021

v3.6.0

May 10, 2021

v3.5.0

Apr 12, 2021

v3.4.0

Apr 8, 2021

Changes in this version

type GroupVersionResourceKind

+ func KindToGVRK(kind string) (*GroupVersionResourceKind, error)

v3.3.1

Feb 18, 2021

Changes in this version

type Kube

+ func (kube *Kube) GetNamespace(name string) (*kv1.Namespace, error)

+ func (kube *Kube) UpdateValidatingWebhookCaBundle(name string, certPem []byte) error

v3.2.1

Mar 1, 2021

Changes in this version

+ var ClusterRoleBindings = GroupVersionResourceKind

+ var ClusterRoles = GroupVersionResourceKind

+ var CronJobs = GroupVersionResourceKind

+ var DaemonSets = GroupVersionResourceKind

+ var Deployments = GroupVersionResourceKind

+ var IngressClasses = GroupVersionResourceKind

+ var Ingresses = GroupVersionResourceKind

+ var Jobs = GroupVersionResourceKind

+ var LimitRanges = GroupVersionResourceKind

+ var Namespaces = GroupVersionResourceKind

+ var NetworkPolicies = GroupVersionResourceKind

+ var Nodes = GroupVersionResourceKind

+ var PersistentVolumeClaims = GroupVersionResourceKind

+ var PersistentVolumes = GroupVersionResourceKind

+ var Pods = GroupVersionResourceKind

+ var ReplicaSets = GroupVersionResourceKind

+ var ReplicationControllers = GroupVersionResourceKind

+ var RoleBindings = GroupVersionResourceKind

+ var Roles = GroupVersionResourceKind

+ var ServiceAccounts = GroupVersionResourceKind

+ var Services = GroupVersionResourceKind

+ var StatefulSets = GroupVersionResourceKind

+ var StorageClasses = GroupVersionResourceKind

+ func GetEntityKey(namespace string, kind string, name string) string

+ type ContainerResourcesRequirements struct

+ Limits *RequestLimit

+ Name string

+ Requests *RequestLimit

+ type GetWatcherFromKindFunc func(kind string) (Watcher, bool)

+ type GroupVersionResourceKind struct

+ Kind string

+ func KindToGvrk(kind string) (*GroupVersionResourceKind, error)

+ func (gvrk GroupVersionResourceKind) String() string

+ type Identifiable interface

+ GetAPIVersion func() string

+ GetKind func() string

+ GetName func() string

+ GetNamespace func() string

+ GetOwnerReferences func() []apisv1.OwnerReference

+ type Kube struct

+ ClientBatch *batch.BatchV1beta1Client

+ ClientV1 *kapps.AppsV1Client

+ Clientset *kubernetes.Clientset

+ func InitKubernetes(config *krest.Config) (*Kube, error)

+ func (kube *Kube) GetAgentPermissions() (string, error)

+ func (kube *Kube) GetCronJob(namespace, name string) (*kbeta1.CronJob, error)

+ func (kube *Kube) GetCronJobs() (*kbeta1.CronJobList, error)

+ func (kube *Kube) GetDaemonSet(namespace, name string) (*v1.DaemonSet, error)

+ func (kube *Kube) GetDaemonSets() (*appsV1.DaemonSetList, error)

+ func (kube *Kube) GetDeploymentByName(namespace, name string) (*appsV1.Deployment, error)

+ func (kube *Kube) GetDeployments() (*appsV1.DeploymentList, error)

+ func (kube *Kube) GetLimitRanges() (*kv1.LimitRangeList, error)

+ func (kube *Kube) GetNameSpacePods(namespace string) (*kv1.PodList, error)

+ func (kube *Kube) GetNamespaceReplicaSets(namespace string) (*appsV1.ReplicaSetList, error)

+ func (kube *Kube) GetNodes() (*kv1.NodeList, error)

+ func (kube *Kube) GetPods() (*kv1.PodList, error)

+ func (kube *Kube) GetReplicaSets() (*appsV1.ReplicaSetList, error)

+ func (kube *Kube) GetReplicationControllers() (*kv1.ReplicationControllerList, error)

+ func (kube *Kube) GetResources() (pods []kv1.Pod, limitRanges []kv1.LimitRange, resources []Resource, ...)

+ func (kube *Kube) GetServerMinorVersion() (int, error)

+ func (kube *Kube) GetServerVersion() (string, error)

+ func (kube *Kube) GetStatefulSet(namespace, name string) (*v1.StatefulSet, error)

+ func (kube *Kube) GetStatefulSets() (*appsV1.StatefulSetList, error)

+ func (kube *Kube) SetResources(kind string, name string, namespace string, totalResources TotalResources) (skipped bool, err error)

+ type Observer struct

+ ParentsStore *ParentsStore

+ func NewObserver(client dynamic.Interface, parentsStore *ParentsStore, stopCh chan struct{}, ...) *Observer

+ func (observer *Observer) FindContainer(namespaceName string, controllerKind string, controllerName string, ...) (*corev1.Container, error)

+ func (observer *Observer) FindController(namespaceName string, controllerKind string, controllerName string) (*unstructured.Unstructured, error)

+ func (observer *Observer) FindPodController(namespaceName string, podName string) (string, string, error)

+ func (observer *Observer) GetNodes() ([]corev1.Node, error)

+ func (observer *Observer) GetPods() ([]corev1.Pod, error)

+ func (observer *Observer) Start()

+ func (observer *Observer) Stop()

+ func (observer *Observer) WaitForCacheSync() error

+ func (observer *Observer) Watch(gvrk GroupVersionResourceKind) *watcher

+ func (observer *Observer) WatchAndWaitForSync(gvrk GroupVersionResourceKind) (*watcher, error)

+ func (observer *Observer) WatcherFor(gvrk GroupVersionResourceKind) *watcher

+ type ParentController struct

+ APIVersion string

+ IsWatched bool

+ Kind string

+ Name string

+ Parent *ParentController

+ func GetParents(obj Identifiable, parentsStore *ParentsStore, ...) (*ParentController, error)

+ func RootParent(parent *ParentController) *ParentController

+ type ParentsStore struct

+ func NewParentsStore() *ParentsStore

+ func (s *ParentsStore) Delete(namespace string, kind string, name string)

+ func (s *ParentsStore) GetParents(namespace string, kind string, name string) (*ParentController, bool)

+ func (s *ParentsStore) SetParents(namespace string, kind string, name string, parent *ParentController)

+ type RawResources struct

+ CronJobList *kbeta1.CronJobList

+ DaemonSetList *appsV1.DaemonSetList

+ DeploymentList *appsV1.DeploymentList

+ LimitRangeList *kv1.LimitRangeList

+ PodList *kv1.PodList

+ ReplicaSetList *appsV1.ReplicaSetList

+ StatefulSetList *appsV1.StatefulSetList

+ type RequestLimit struct

+ CPU *int64

+ Memory *int64

+ type Resource struct

+ Annotations map[string]string

+ Containers []kv1.Container

+ Kind string

+ Name string

+ Namespace string

+ PodRegexp *regexp.Regexp

+ ReplicasStatus proto.ReplicasStatus

+ type ResourceEventHandler interface

+ OnAdd func(gvrk GroupVersionResourceKind, obj unstructured.Unstructured)

+ OnDelete func(gvrk GroupVersionResourceKind, obj unstructured.Unstructured)

+ OnUpdate func(gvrk GroupVersionResourceKind, oldObj, newObj unstructured.Unstructured)

+ type ResourceEventHandlerFuncs struct

+ AddFunc func(gvrk GroupVersionResourceKind, obj unstructured.Unstructured)

+ DeleteFunc func(gvrk GroupVersionResourceKind, obj unstructured.Unstructured)

+ Observer *Observer

+ UpdateFunc func(gvrk GroupVersionResourceKind, oldObj, newObj unstructured.Unstructured)

+ func (r ResourceEventHandlerFuncs) OnAdd(gvrk GroupVersionResourceKind, obj unstructured.Unstructured)

+ func (r ResourceEventHandlerFuncs) OnDelete(gvrk GroupVersionResourceKind, obj unstructured.Unstructured)

+ func (r ResourceEventHandlerFuncs) OnUpdate(gvrk GroupVersionResourceKind, oldObj, newObj unstructured.Unstructured)

+ type TotalResources struct

+ Containers []ContainerResourcesRequirements

+ type Watcher interface

+ AddEventHandler func(handler ResourceEventHandler)

+ AddEventHandlerWithResyncPeriod func(handler ResourceEventHandler, resyncPeriod time.Duration)

+ GetGroupVersionResourceKind func() GroupVersionResourceKind

+ HasSynced func() bool

+ LastSyncResourceVersion func() string

+ Lister func() cache.GenericLister

Other modules containing this package

github.com/MagalixCorp/magalix-agent

github.com/MagalixCorp/magalix-agent/v2

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