Versions in this module Expand all Collapse all v1 v1.0.2 May 5, 2022 Changes in this version + func FilterDeploymentPodsByOwnerReference(deployment apps.Deployment, allRS []apps.ReplicaSet, allPods []v1.Pod) []v1.Pod + 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 Condition struct + LastProbeTime v1.Time + LastTransitionTime v1.Time + Message string + Reason string + Status v1.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 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 k8s.ObjectMeta + Reason string + SourceComponent string + SourceHost string + SubObject string + SubObjectKind string + SubObjectName string + SubObjectNamespace string + Type string + TypeMeta k8s.TypeMeta + type EventList struct + Events []Event + ListMeta k8s.ListMeta + type EventListChannel struct + Error chan error + List chan *v1.EventList + func GetEventListChannel(client *client.Clientset, nsQuery *NamespaceQuery, numReads int) EventListChannel + func GetEventListChannelWithOptions(client *client.Clientset, nsQuery *NamespaceQuery, options metaV1.ListOptions, ...) EventListChannel + 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 NamespaceQuery struct + Namespaces []string + func NewNamespaceQuery(namespaces []string) *NamespaceQuery + func NewSameNamespaceQuery(namespace string) *NamespaceQuery + func (n *NamespaceQuery) Matches(namespace string) bool + func (n *NamespaceQuery) ToRequestParam() string + 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 ResourceChannels struct + ConfigMapList ConfigMapListChannel + CronJobList CronJobListChannel + DaemonSetList DaemonSetListChannel + DeploymentList DeploymentListChannel + EndpointList EndpointListChannel + EventList EventListChannel + JobList JobListChannel + PersistentVolumeClaimList PersistentVolumeClaimListChannel + PersistentVolumeList PersistentVolumeListChannel + PodList PodListChannel + ReplicaSetList ReplicaSetListChannel + SecretList SecretListChannel + ServiceList ServiceListChannel + StatefulSetList StatefulSetListChannel + StorageClassList StorageClassListChannel + type ResourceStatus struct + Failed int + Pending int + Running int + Succeeded int + Terminating int + Unknown int + 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