common

Aug 23, 2018

Changes in this version

+ func GetNonduplicateContainerImages(podList []v1.Pod) []string

+ func GetNonduplicateContainerNames(podList []v1.Pod) []string

+ func GetNonduplicateInitContainerImages(podList []v1.Pod) []string

+ func GetNonduplicateInitContainerNames(podList []v1.Pod) []string

Nov 27, 2017

Changes in this version

+ func GetInitContainerImages(podTemplate *v1.PodSpec) []string

+ func GetInitContainerNames(podTemplate *v1.PodSpec) []string

+ type CronJobListChannel struct

+ Error chan error

+ List chan *batch2.CronJobList

+ func GetCronJobListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) CronJobListChannel

type ResourceChannels

+ CronJobList CronJobListChannel

+ type ResourceStatus struct

+ Failed int

+ Pending int

+ Running int

+ Succeeded int

Sep 22, 2017

Changes in this version

+ func FilterPodsByControllerRef(owner metav1.Object, allPods []v1.Pod) []v1.Pod

+ 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 ResourceChannels

+ EndpointList EndpointListChannel

Jul 25, 2017

Changes in this version

+ func FilterPodsForJob(job batch.Job, pods []v1.Pod) []v1.Pod

+ func GetContainerNames(podTemplate *v1.PodSpec) []string

May 16, 2017

Changes in this version

+ const ResourceKindRbacClusterRole

+ const ResourceKindRbacClusterRoleBinding

+ const ResourceKindRbacRole

+ const ResourceKindRbacRoleBinding

+ func EqualIgnoreHash(template1, template2 api.PodTemplateSpec) bool

+ func FilterDeploymentPodsByOwnerReference(deployment extensions.Deployment, allRS []extensions.ReplicaSet, ...) []api.Pod

+ func FilterPodsByOwnerReference(namespace string, uid types.UID, allPods []api.Pod) []api.Pod

+ func LocalizeError(err error) error

+ 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 ResourceChannels

+ ClusterRoleBindingList ClusterRoleBindingListChannel

+ ClusterRoleList ClusterRoleListChannel

+ RoleBindingList RoleBindingListChannel

+ RoleList RoleListChannel

+ type RoleBindingListChannel struct

+ Error chan error

+ List chan *rbac.RoleBindingList

+ func GetRoleBindingListChannel(client client.Interface, numReads int) RoleBindingListChannel

+ type RoleListChannel struct

+ Error chan error

+ List chan *rbac.RoleList

+ func GetRoleListChannel(client client.Interface, numReads int) RoleListChannel

Mar 16, 2017

Changes in this version

+ const ClientTypeStorageClient

+ const ResourceKindStorageClass

+ const ResourceKindThirdPartyResource

type ResourceChannels

+ StorageClassList StorageClassListChannel

+ ThirdPartyResourceList ThirdPartyResourceListChannel

+ type StorageClassListChannel struct

+ Error chan error

+ List chan *storage.StorageClassList

+ func GetStorageClassListChannel(client client.Interface, numReads int) StorageClassListChannel

+ type ThirdPartyResourceListChannel struct

+ Error chan error

+ List chan *extensions.ThirdPartyResourceList

+ func GetThirdPartyResourceListChannel(client client.Interface, numReads int) ThirdPartyResourceListChannel

Nov 30, 2016

Changes in this version

+ const ClientTypeAutoscalingClient

+ const ResourceKindHorizontalPodAutoscaler

+ const ResourceKindStatefulSet

+ type Condition struct

+ LastProbeTime unversioned.Time

+ LastTransitionTime unversioned.Time

+ Message string

+ Reason string

+ Status api.ConditionStatus

+ Type string

+ type HorizontalPodAutoscalerListChannel struct

+ Error chan error

+ List chan *autoscaling.HorizontalPodAutoscalerList

+ func GetHorizontalPodAutoscalerListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) HorizontalPodAutoscalerListChannel

type ResourceChannels

+ HorizontalPodAutoscalerList HorizontalPodAutoscalerListChannel

+ StatefulSetList StatefulSetListChannel

+ type StatefulSetListChannel struct

+ Error chan error

+ List chan *apps.StatefulSetList

+ func GetStatefulSetListChannel(client client.Interface, nsQuery *NamespaceQuery, numReads int) StatefulSetListChannel

Oct 31, 2016

Changes in this version

+ const CpuUsage

+ const MemoryUsage

Oct 7, 2016

Changes in this version

+ const ResourceKindLimitRange

+ type LimitRangeListChannel struct

+ Error chan error

+ List chan *api.LimitRangeList

+ func GetLimitRangeListChannel(client client.LimitRangesNamespacer, nsQuery *NamespaceQuery, numReads int) LimitRangeListChannel

type ResourceChannels

+ LimitRangeList LimitRangeListChannel

Sep 20, 2016

Changes in this version

+ const ResourceKindIngress

+ const ResourceKindPersistentVolumeClaim

+ const ResourceKindResourceQuota

+ type IngressListChannel struct

+ Error chan error

+ List chan *extensions.IngressList

+ func GetIngressListChannel(client client.IngressNamespacer, nsQuery *NamespaceQuery, numReads int) IngressListChannel

+ type NamespaceListChannel struct

+ Error chan error

+ List chan *api.NamespaceList

+ func GetNamespaceListChannel(client client.NamespacesInterface, numReads int) NamespaceListChannel

+ type PersistentVolumeClaimListChannel struct

+ Error chan error

+ List chan *api.PersistentVolumeClaimList

+ func GetPersistentVolumeClaimListChannel(client client.PersistentVolumeClaimsNamespacer, nsQuery *NamespaceQuery, ...) PersistentVolumeClaimListChannel

type ResourceChannels

+ IngressList IngressListChannel

+ NamespaceList NamespaceListChannel

+ PersistentVolumeClaimList PersistentVolumeClaimListChannel

+ ResourceQuotaList ResourceQuotaListChannel

+ SecretList SecretListChannel

+ type ResourceQuotaListChannel struct

+ Error chan error

+ List chan *api.ResourceQuotaList

+ func GetResourceQuotaListChannel(client client.ResourceQuotasNamespacer, nsQuery *NamespaceQuery, numReads int) ResourceQuotaListChannel

+ type SecretListChannel struct

+ Error chan error

+ List chan *api.SecretList

+ func GetSecretListChannel(client client.SecretsNamespacer, nsQuery *NamespaceQuery, numReads int) SecretListChannel

Aug 9, 2016

Changes in this version

+ const ResourceKindConfigMap

+ const ResourceKindNamespace

+ const ResourceKindPersistentVolume

+ const ResourceKindSecret

+ var NoPagination = NewPaginationQuery(-1, -1)

+ func FilterNamespacedServicesBySelector(services []api.Service, namespace string, resourceSelector map[string]string) []api.Service

+ type ConfigMapListChannel struct

+ Error chan error

+ List chan *api.ConfigMapList

+ func GetConfigMapListChannel(client client.ConfigMapsNamespacer, nsQuery *NamespaceQuery, numReads int) ConfigMapListChannel

type EventList

+ ListMeta ListMeta

+ type ListMeta struct

+ TotalItems int

+ type MetricResult struct

+ Timestamp time.Time

+ Value uint64

+ type MetricsByPod struct

+ MetricsMap map[string]map[string]PodMetrics

+ type PaginationQuery struct

+ ItemsPerPage int

+ Page int

+ func NewPaginationQuery(itemsPerPage, page int) *PaginationQuery

+ func (p *PaginationQuery) CanPaginate(itemsCount, startingIndex int) bool

+ func (p *PaginationQuery) GetPaginationSettings(itemsCount int) (startIndex int, endIndex int)

+ type PersistentVolumeListChannel struct

+ Error chan error

+ List chan *api.PersistentVolumeList

+ func GetPersistentVolumeListChannel(client client.PersistentVolumesInterface, numReads int) PersistentVolumeListChannel

+ type PodMetrics struct

+ CPUUsage *uint64

+ CPUUsageHistory []MetricResult

+ MemoryUsage *uint64

+ MemoryUsageHistory []MetricResult

+ type PodMetricsChannel struct

+ Error chan error

+ MetricsByPod chan *MetricsByPod

+ func GetPodListMetricsChannel(heapsterClient kdClient.HeapsterClient, pods []api.Pod, numReads int) PodMetricsChannel

+ func GetPodMetricsChannel(heapsterClient kdClient.HeapsterClient, name string, namespace string) PodMetricsChannel

type ResourceChannels

+ ConfigMapList ConfigMapListChannel

+ PersistentVolumeList PersistentVolumeListChannel

+ PodMetrics PodMetricsChannel

Jun 22, 2016

Changes in this version

+ const ClientTypeAppsClient

+ const ClientTypeBatchClient

+ const ClientTypeDefault

+ const ClientTypeExtensionClient

+ const ResourceKindDaemonSet

+ const ResourceKindDeployment

+ const ResourceKindEvent

+ const ResourceKindJob

+ const ResourceKindNode

+ const ResourceKindPetSet

+ const ResourceKindPod

+ const ResourceKindReplicaSet

+ const ResourceKindReplicationController

+ const ResourceKindService

+ func FilterNamespacedPodsByLabelSelector(pods []api.Pod, namespace string, labelSelector *unversioned.LabelSelector) []api.Pod

+ func FilterNamespacedPodsBySelector(pods []api.Pod, namespace string, resourceSelector map[string]string) []api.Pod

+ func FilterPodsByLabelSelector(pods []api.Pod, labelSelector *unversioned.LabelSelector) []api.Pod

+ func FilterPodsBySelector(pods []api.Pod, resourceSelector map[string]string) []api.Pod

+ func GetContainerImages(podTemplate *api.PodSpec) []string

+ func GetNodeByName(nodes []api.Node, nodeName string) *api.Node

+ func IsLabelSelectorMatching(selector map[string]string, labelSelector *unversioned.LabelSelector) bool

+ func IsSelectorMatching(labelSelector map[string]string, testedObjectLabels map[string]string) bool

+ type ClientType string

+ type DaemonSetListChannel struct

+ Error chan error

+ List chan *extensions.DaemonSetList

+ func GetDaemonSetListChannel(client client.DaemonSetsNamespacer, nsQuery *NamespaceQuery, numReads int) DaemonSetListChannel

+ type DeploymentListChannel struct

+ Error chan error

+ List chan *extensions.DeploymentList

+ func GetDeploymentListChannel(client client.DeploymentsNamespacer, 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 Event struct

+ Count int32

+ FirstSeen unversioned.Time

+ LastSeen unversioned.Time

+ Message string

+ ObjectMeta ObjectMeta

+ Reason string

+ SourceComponent string

+ SourceHost string

+ SubObject string

+ Type string

+ TypeMeta TypeMeta

+ type EventList struct

+ Events []Event

+ Namespace string

+ type EventListChannel struct

+ Error chan error

+ List chan *api.EventList

+ func GetEventListChannel(client client.EventNamespacer, nsQuery *NamespaceQuery, numReads int) EventListChannel

+ func GetEventListChannelWithOptions(client client.EventNamespacer, nsQuery *NamespaceQuery, ...) EventListChannel

+ type JobListChannel struct

+ Error chan error

+ List chan *batch.JobList

+ func GetJobListChannel(client client.JobsNamespacer, nsQuery *NamespaceQuery, numReads int) JobListChannel

+ 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 *api.NodeList

+ func GetNodeListChannel(client client.NodesInterface, numReads int) NodeListChannel

+ type ObjectMeta struct

+ Annotations map[string]string

+ CreationTimestamp unversioned.Time

+ Labels map[string]string

+ Name string

+ Namespace string

+ func NewObjectMeta(k8SObjectMeta api.ObjectMeta) ObjectMeta

+ type PetSetListChannel struct

+ Error chan error

+ List chan *apps.PetSetList

+ func GetPetSetListChannel(client client.PetSetNamespacer, nsQuery *NamespaceQuery, numReads int) PetSetListChannel

+ 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 *api.PodList

+ func GetPodListChannel(client client.PodsNamespacer, nsQuery *NamespaceQuery, numReads int) PodListChannel

+ func GetPodListChannelWithOptions(client client.PodsNamespacer, nsQuery *NamespaceQuery, options api.ListOptions, ...) PodListChannel

+ type RESTClient interface

+ Delete func() *restclient.Request

+ Get func() *restclient.Request

+ Put func() *restclient.Request

+ type ReplicaSetListChannel struct

+ Error chan error

+ List chan *extensions.ReplicaSetList

+ func GetReplicaSetListChannel(client client.ReplicaSetsNamespacer, nsQuery *NamespaceQuery, numReads int) ReplicaSetListChannel

+ func GetReplicaSetListChannelWithOptions(client client.ReplicaSetsNamespacer, nsQuery *NamespaceQuery, ...) ReplicaSetListChannel

+ type ReplicationControllerListChannel struct

+ Error chan error

+ List chan *api.ReplicationControllerList

+ func GetReplicationControllerListChannel(client client.ReplicationControllersNamespacer, nsQuery *NamespaceQuery, ...) ReplicationControllerListChannel

+ type ResourceChannels struct

+ DaemonSetList DaemonSetListChannel

+ DeploymentList DeploymentListChannel

+ EventList EventListChannel

+ JobList JobListChannel

+ NodeList NodeListChannel

+ PetSetList PetSetListChannel

+ PodList PodListChannel

+ ReplicaSetList ReplicaSetListChannel

+ ReplicationControllerList ReplicationControllerListChannel

+ ServiceList ServiceListChannel

+ type ResourceKind string

+ type ResourceVerber struct

+ func NewResourceVerber(client, extensionsClient, appsClient, batchClient RESTClient) ResourceVerber

+ func (verber *ResourceVerber) Delete(kind string, namespace string, name string) error

+ func (verber *ResourceVerber) Get(kind string, namespace string, name string) (runtime.Object, error)

+ func (verber *ResourceVerber) Put(kind string, namespace string, name string, object runtime.Object) error

+ type ServiceListChannel struct

+ Error chan error

+ List chan *api.ServiceList

+ func GetServiceListChannel(client client.ServicesNamespacer, nsQuery *NamespaceQuery, numReads int) ServiceListChannel

+ type ServicePort struct

+ NodePort int32

+ Port int32

+ Protocol api.Protocol

+ func GetServicePorts(apiPorts []api.ServicePort) []ServicePort

+ type TypeMeta struct

+ Kind ResourceKind

+ func NewTypeMeta(kind ResourceKind) TypeMeta