Versions in this module Expand all Collapse all v2 v2.1.1 Dec 22, 2021 v2.1.0 Dec 22, 2021 Changes in this version + func EqualIgnoreHash(template1, template2 v1.PodTemplateSpec) bool + func FilterDeploymentPodsByOwnerReference(deployment apps.Deployment, allRS []apps.ReplicaSet, allPods []v1.Pod) []v1.Pod + func FilterNamespacedServicesBySelector(services []v1.Service, namespace string, resourceSelector map[string]string) []v1.Service + func FilterPodsByControllerRef(owner metav1.Object, allPods []v1.Pod) []v1.Pod + func FilterPodsForJob(job batch.Job, pods []v1.Pod) []v1.Pod + func GetContainerImages(podTemplate *v1.PodSpec) []string + func GetContainerNames(podTemplate *v1.PodSpec) []string + func GetInitContainerImages(podTemplate *v1.PodSpec) []string + func GetInitContainerNames(podTemplate *v1.PodSpec) []string + func GetNonduplicateContainerImages(podList []v1.Pod) []string + func GetNonduplicateContainerNames(podList []v1.Pod) []string + func GetNonduplicateInitContainerImages(podList []v1.Pod) []string + func GetNonduplicateInitContainerNames(podList []v1.Pod) []string + type ClusterRoleBindingListChannel struct + Error chan error + List chan *rbac.ClusterRoleBindingList + func GetClusterRoleBindingListChannel(client client.Interface, numReads int) ClusterRoleBindingListChannel + type ClusterRoleListChannel struct + Error chan error + List chan *rbac.ClusterRoleList + func GetClusterRoleListChannel(client client.Interface, numReads int) ClusterRoleListChannel + type Condition struct + LastProbeTime v1.Time + LastTransitionTime v1.Time + Message string + Reason string + Status api.ConditionStatus + Type string + type ConfigMapListChannel struct + Error chan error + List chan *v1.ConfigMapList + func GetConfigMapListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) ConfigMapListChannel + type CronJobListChannel struct + Error chan error + List chan *batch2.CronJobList + func GetCronJobListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) CronJobListChannel + type CustomResourceDefinitionChannelV1 struct + Error chan error + List chan *apiextensions.CustomResourceDefinitionList + func GetCustomResourceDefinitionChannelV1(client apiextensionsclientset.Interface, numReads int) CustomResourceDefinitionChannelV1 + type CustomResourceDefinitionChannelV1beta1 struct + Error chan error + List chan *apiextensionsv1beta1.CustomResourceDefinitionList + func GetCustomResourceDefinitionChannelV1beta1(client apiextensionsclientset.Interface, numReads int) CustomResourceDefinitionChannelV1beta1 + type DaemonSetListChannel struct + Error chan error + List chan *apps.DaemonSetList + func GetDaemonSetListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) DaemonSetListChannel + type DeploymentListChannel struct + Error chan error + List chan *apps.DeploymentList + func GetDeploymentListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) DeploymentListChannel + type Endpoint struct + Host string + Ports []ServicePort + func GetExternalEndpoints(service *api.Service) []Endpoint + func GetInternalEndpoint(serviceName, namespace string, ports []api.ServicePort) Endpoint + type EndpointListChannel struct + Error chan error + List chan *v1.EndpointsList + func GetEndpointListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) EndpointListChannel + func GetEndpointListChannelWithOptions(client client.Interface, nsQuery *NamespaceQuery, opt metaV1.ListOptions, ...) EndpointListChannel + type Event struct + Count int32 + FirstSeen v1.Time + LastSeen v1.Time + Message string + ObjectMeta api.ObjectMeta + Reason string + SourceComponent string + SourceHost string + SubObject string + SubObjectKind string + SubObjectName string + SubObjectNamespace string + Type string + TypeMeta api.TypeMeta + type EventList struct + Errors []error + Events []Event + ListMeta api.ListMeta + type EventListChannel struct + Error chan error + List chan *v1.EventList + func GetEventListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) EventListChannel + func GetEventListChannelWithOptions(client client.Interface, nsQuery *NamespaceQuery, options metaV1.ListOptions, ...) EventListChannel + type HorizontalPodAutoscalerListChannel struct + Error chan error + List chan *autoscaling.HorizontalPodAutoscalerList + func GetHorizontalPodAutoscalerListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) HorizontalPodAutoscalerListChannel + type IngressListChannel struct + Error chan error + List chan *extensions.IngressList + func GetIngressListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) IngressListChannel + type JobListChannel struct + Error chan error + List chan *batch.JobList + func GetJobListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) JobListChannel + type LimitRangeListChannel struct + Error chan error + List chan *v1.LimitRangeList + func GetLimitRangeListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) LimitRangeListChannel + type NamespaceListChannel struct + Error chan error + List chan *v1.NamespaceList + func GetNamespaceListChannel(client client.Interface, numReads int) NamespaceListChannel + type NamespaceQuery struct + func NewNamespaceQuery(namespaces []string) *NamespaceQuery + func NewSameNamespaceQuery(namespace string) *NamespaceQuery + func (n *NamespaceQuery) Matches(namespace string) bool + func (n *NamespaceQuery) ToRequestParam() string + type NodeListChannel struct + Error chan error + List chan *v1.NodeList + func GetNodeListChannel(client client.Interface, numReads int) NodeListChannel + type PersistentVolumeClaimListChannel struct + Error chan error + List chan *v1.PersistentVolumeClaimList + func GetPersistentVolumeClaimListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) PersistentVolumeClaimListChannel + type PersistentVolumeListChannel struct + Error chan error + List chan *v1.PersistentVolumeList + func GetPersistentVolumeListChannel(client client.Interface, numReads int) PersistentVolumeListChannel + type PodInfo struct + Current int32 + Desired *int32 + Failed int32 + Pending int32 + Running int32 + Succeeded int32 + Warnings []Event + func GetPodInfo(current int32, desired *int32, pods []api.Pod) PodInfo + type PodListChannel struct + Error chan error + List chan *v1.PodList + func GetPodListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) PodListChannel + func GetPodListChannelWithOptions(client client.Interface, nsQuery *NamespaceQuery, options metaV1.ListOptions, ...) PodListChannel + type ReplicaSetListChannel struct + Error chan error + List chan *apps.ReplicaSetList + func GetReplicaSetListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) ReplicaSetListChannel + func GetReplicaSetListChannelWithOptions(client client.Interface, nsQuery *NamespaceQuery, options metaV1.ListOptions, ...) ReplicaSetListChannel + type ReplicationControllerListChannel struct + Error chan error + List chan *v1.ReplicationControllerList + func GetReplicationControllerListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) ReplicationControllerListChannel + type ResourceChannels struct + ClusterRoleBindingList ClusterRoleBindingListChannel + ClusterRoleList ClusterRoleListChannel + ConfigMapList ConfigMapListChannel + CronJobList CronJobListChannel + DaemonSetList DaemonSetListChannel + DeploymentList DeploymentListChannel + EndpointList EndpointListChannel + EventList EventListChannel + HorizontalPodAutoscalerList HorizontalPodAutoscalerListChannel + IngressList IngressListChannel + JobList JobListChannel + LimitRangeList LimitRangeListChannel + NamespaceList NamespaceListChannel + NodeList NodeListChannel + PersistentVolumeClaimList PersistentVolumeClaimListChannel + PersistentVolumeList PersistentVolumeListChannel + PodList PodListChannel + ReplicaSetList ReplicaSetListChannel + ReplicationControllerList ReplicationControllerListChannel + ResourceQuotaList ResourceQuotaListChannel + RoleBindingList RoleBindingListChannel + RoleList RoleListChannel + SecretList SecretListChannel + ServiceList ServiceListChannel + StatefulSetList StatefulSetListChannel + StorageClassList StorageClassListChannel + type ResourceQuotaListChannel struct + Error chan error + List chan *v1.ResourceQuotaList + func GetResourceQuotaListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) ResourceQuotaListChannel + type ResourceStatus struct + Failed int + Pending int + Running int + Succeeded int + Terminating int + Unknown int + type RoleBindingListChannel struct + Error chan error + List chan *rbac.RoleBindingList + func GetRoleBindingListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) RoleBindingListChannel + type RoleListChannel struct + Error chan error + List chan *rbac.RoleList + func GetRoleListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) RoleListChannel + type SecretListChannel struct + Error chan error + List chan *v1.SecretList + func GetSecretListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) SecretListChannel + type ServiceListChannel struct + Error chan error + List chan *v1.ServiceList + func GetServiceListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) ServiceListChannel + type ServicePort struct + NodePort int32 + Port int32 + Protocol api.Protocol + func GetServicePorts(apiPorts []api.ServicePort) []ServicePort + type StatefulSetListChannel struct + Error chan error + List chan *apps.StatefulSetList + func GetStatefulSetListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) StatefulSetListChannel + type StorageClassListChannel struct + Error chan error + List chan *storage.StorageClassList + func GetStorageClassListChannel(client client.Interface, numReads int) StorageClassListChannel