Documentation
¶
Index ¶
- func DeleteDaemonSet(client k8sClient.Interface, namespace, name string, deleteServices bool) error
- func DeleteDaemonSetServices(client k8sClient.Interface, namespace, name string) error
- func FromCells(cells []dataselect.DataCell) []extensions.DaemonSet
- func GetDaemonSetEvents(client client.Interface, dsQuery *dataselect.DataSelectQuery, ...) (*common.EventList, error)
- func GetDaemonSetPods(client k8sClient.Interface, heapsterClient client.HeapsterClient, ...) (*pod.PodList, error)
- func GetDaemonSetPodsEvents(client client.Interface, namespace, daemonSetName string) ([]api.Event, error)
- func GetDaemonSetServices(client client.Interface, dsQuery *dataselect.DataSelectQuery, ...) (*service.ServiceList, error)
- func GetServicesForDSDeletion(client client.Interface, labelSelector labels.Selector, namespace string) ([]api.Service, error)
- func ToCells(std []extensions.DaemonSet) []dataselect.DataCell
- type DaemonSet
- type DaemonSetCell
- type DaemonSetDetail
- type DaemonSetList
- func CreateDaemonSetList(daemonSets []extensions.DaemonSet, pods []api.Pod, events []api.Event, ...) *DaemonSetList
- func GetDaemonSetList(client *client.Clientset, nsQuery *common.NamespaceQuery, ...) (*DaemonSetList, error)
- func GetDaemonSetListFromChannels(channels *common.ResourceChannels, dsQuery *dataselect.DataSelectQuery, ...) (*DaemonSetList, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeleteDaemonSet ¶
TODO(floreks): This should be transactional to make sure that DS will not be deleted without pods Deletes daemon set with given name in given namespace and related pods. Also deletes services related to daemon set if deleteServices is true.
func DeleteDaemonSetServices ¶
DeleteDaemonSetServices deletes services related to daemon set with given name in given namespace.
func FromCells ¶ added in v1.5.0
func FromCells(cells []dataselect.DataCell) []extensions.DaemonSet
func GetDaemonSetEvents ¶ added in v1.1.1
func GetDaemonSetEvents(client client.Interface, dsQuery *dataselect.DataSelectQuery, namespace, daemonSetName string) (*common.EventList, error)
GetDaemonSetEvents gets events associated to daemon set.
func GetDaemonSetPods ¶ added in v1.1.1
func GetDaemonSetPods(client k8sClient.Interface, heapsterClient client.HeapsterClient, dsQuery *dataselect.DataSelectQuery, daemonSetName, namespace string) (*pod.PodList, error)
GetDaemonSetPods return list of pods targeting daemon set.
func GetDaemonSetPodsEvents ¶ added in v1.1.1
func GetDaemonSetPodsEvents(client client.Interface, namespace, daemonSetName string) ( []api.Event, error)
GetDaemonSetPodsEvents gets events associated to pods in daemon set.
func GetDaemonSetServices ¶ added in v1.1.1
func GetDaemonSetServices(client client.Interface, dsQuery *dataselect.DataSelectQuery, namespace, name string) (*service.ServiceList, error)
GetDaemonSetServices returns list of services that are related to daemon set targeted by given name.
func GetServicesForDSDeletion ¶ added in v1.5.0
func GetServicesForDSDeletion(client client.Interface, labelSelector labels.Selector, namespace string) ([]api.Service, error)
Based on given selector returns list of services that are candidates for deletion. Services are matched by daemon sets' label selector. They are deleted if given label selector is targeting only 1 daemon set.
func ToCells ¶ added in v1.5.0
func ToCells(std []extensions.DaemonSet) []dataselect.DataCell
Types ¶
type DaemonSet ¶
type DaemonSet struct { ObjectMeta common.ObjectMeta `json:"objectMeta"` TypeMeta common.TypeMeta `json:"typeMeta"` // Aggregate information about pods belonging to this Daemon Set. Pods common.PodInfo `json:"pods"` // Container images of the Daemon Set. ContainerImages []string `json:"containerImages"` }
DaemonSet (aka. Daemon Set) plus zero or more Kubernetes services that target the Daemon Set.
type DaemonSetCell ¶ added in v1.4.0
type DaemonSetCell extensions.DaemonSet
func (DaemonSetCell) GetProperty ¶ added in v1.4.0
func (self DaemonSetCell) GetProperty(name dataselect.PropertyName) dataselect.ComparableValue
func (DaemonSetCell) GetResourceSelector ¶ added in v1.4.0
func (self DaemonSetCell) GetResourceSelector() *metric.ResourceSelector
type DaemonSetDetail ¶
type DaemonSetDetail struct { ObjectMeta common.ObjectMeta `json:"objectMeta"` TypeMeta common.TypeMeta `json:"typeMeta"` // Label selector of the Daemon Set. LabelSelector *v1.LabelSelector `json:"labelSelector,omitempty"` // Container image list of the pod template specified by this Daemon Set. ContainerImages []string `json:"containerImages"` // Aggregate information about pods of this daemon set. PodInfo common.PodInfo `json:"podInfo"` // Detailed information about Pods belonging to this Daemon Set. PodList pod.PodList `json:"podList"` // Detailed information about service related to Daemon Set. ServiceList resourceService.ServiceList `json:"serviceList"` // True when the data contains at least one pod with metrics information, false otherwise. HasMetrics bool `json:"hasMetrics"` // List of events related to this daemon set EventList common.EventList `json:"eventList"` }
DaemonSeDetail represents detailed information about a Daemon Set.
func GetDaemonSetDetail ¶
func GetDaemonSetDetail(client k8sClient.Interface, heapsterClient client.HeapsterClient, namespace, name string) (*DaemonSetDetail, error)
Returns detailed information about the given daemon set in the given namespace.
type DaemonSetList ¶
type DaemonSetList struct { ListMeta common.ListMeta `json:"listMeta"` // Unordered list of Daemon Sets DaemonSets []DaemonSet `json:"daemonSets"` CumulativeMetrics []metric.Metric `json:"cumulativeMetrics"` }
DaemonSetList contains a list of Daemon Sets in the cluster.
func CreateDaemonSetList ¶ added in v1.1.1
func CreateDaemonSetList(daemonSets []extensions.DaemonSet, pods []api.Pod, events []api.Event, dsQuery *dataselect.DataSelectQuery, heapsterClient *heapster.HeapsterClient) *DaemonSetList
CreateDaemonSetList returns a list of all Daemon Set model objects in the cluster, based on all Kubernetes Daemon Set API objects.
func GetDaemonSetList ¶
func GetDaemonSetList(client *client.Clientset, nsQuery *common.NamespaceQuery, dsQuery *dataselect.DataSelectQuery, heapsterClient *heapster.HeapsterClient) (*DaemonSetList, error)
GetDaemonSetList returns a list of all Daemon Set in the cluster.
func GetDaemonSetListFromChannels ¶
func GetDaemonSetListFromChannels(channels *common.ResourceChannels, dsQuery *dataselect.DataSelectQuery, heapsterClient *heapster.HeapsterClient) (*DaemonSetList, error)
GetDaemonSetListFromChannels returns a list of all Daemon Seet in the cluster reading required resource list once from the channels.