deployment

Documentation

Index

• func GetDeploymentEvents(client client.Interface, dsQuery *dataselect.DataSelectQuery, namespace string, ...) (*common.EventList, error)
• func GetDeploymentOldReplicaSets(client client.Interface, dsQuery *dataselect.DataSelectQuery, namespace string, ...) (*replicaset.ReplicaSetList, error)
• func GetDeploymentPods(client client.Interface, heapsterClient heapster.HeapsterClient, ...) (*pod.PodList, error)
• type Deployment
• type DeploymentCell
  • func (self DeploymentCell) GetProperty(name dataselect.PropertyName) dataselect.ComparableValue
  • func (self DeploymentCell) GetResourceSelector() *metric.ResourceSelector
• type DeploymentDetail
  • func GetDeploymentDetail(client client.Interface, heapsterClient heapster.HeapsterClient, ...) (*DeploymentDetail, error)
• type DeploymentList
  • func CreateDeploymentList(deployments []extensions.Deployment, pods []api.Pod, events []api.Event, ...) *DeploymentList
  • func GetDeploymentList(client client.Interface, nsQuery *common.NamespaceQuery, ...) (*DeploymentList, error)
  • func GetDeploymentListFromChannels(channels *common.ResourceChannels, dsQuery *dataselect.DataSelectQuery, ...) (*DeploymentList, error)
• type RollingUpdateStrategy
• type StatusInfo
  • func GetStatusInfo(deploymentStatus *extensions.DeploymentStatus) StatusInfo

Functions

func GetDeploymentEvents

func GetDeploymentEvents(client client.Interface, dsQuery *dataselect.DataSelectQuery, namespace string, deploymentName string) (
	*common.EventList, error)

GetDeploymentEvents returns model events for a deployment with the given name in the given namespace

func GetDeploymentOldReplicaSets

func GetDeploymentOldReplicaSets(client client.Interface, dsQuery *dataselect.DataSelectQuery,
	namespace string, deploymentName string) (*replicaset.ReplicaSetList, error)

GetDeploymentEvents returns model events for a deployment with the given name in the given namespace

func GetDeploymentPods

func GetDeploymentPods(client client.Interface, heapsterClient heapster.HeapsterClient,
	dsQuery *dataselect.DataSelectQuery, namespace string, deploymentName string) (*pod.PodList, error)

getJobPods returns list of pods targeting deployment.

Types

type Deployment

type Deployment struct {
	ObjectMeta common.ObjectMeta `json:"objectMeta"`
	TypeMeta   common.TypeMeta   `json:"typeMeta"`

	// Aggregate information about pods belonging to this Deployment.
	Pods common.PodInfo `json:"pods"`

	// Container images of the Deployment.
	ContainerImages []string `json:"containerImages"`
}

Deployment is a presentation layer view of Kubernetes Deployment resource. This means it is Deployment plus additional augumented data we can get from other sources (like services that target the same pods).

type DeploymentCell

type DeploymentCell extensions.Deployment

func (DeploymentCell) GetProperty

func (self DeploymentCell) GetProperty(name dataselect.PropertyName) dataselect.ComparableValue

func (DeploymentCell) GetResourceSelector

func (self DeploymentCell) GetResourceSelector() *metric.ResourceSelector

type DeploymentDetail

type DeploymentDetail struct {
	ObjectMeta common.ObjectMeta `json:"objectMeta"`
	TypeMeta   common.TypeMeta   `json:"typeMeta"`

	// Detailed information about Pods belonging to this Deployment.
	PodList pod.PodList `json:"podList"`

	// Label selector of the service.
	Selector map[string]string `json:"selector"`

	// Status information on the deployment
	StatusInfo `json:"statusInfo"`

	// The deployment strategy to use to replace existing pods with new ones.
	// Valid options: Recreate, RollingUpdate
	Strategy extensions.DeploymentStrategyType `json:"strategy"`

	// Min ready seconds
	MinReadySeconds int32 `json:"minReadySeconds"`

	// Rolling update strategy containing maxSurge and maxUnavailable
	RollingUpdateStrategy *RollingUpdateStrategy `json:"rollingUpdateStrategy,omitempty"`

	// RepliaSetList containing old replica sets from the deployment
	OldReplicaSetList replicaset.ReplicaSetList `json:"oldReplicaSetList"`

	// New replica set used by this deployment
	NewReplicaSet replicaset.ReplicaSet `json:"newReplicaSet"`

	// Optional field that specifies the number of old Replica Sets to retain to allow rollback.
	RevisionHistoryLimit *int32 `json:"revisionHistoryLimit"`

	// List of events related to this Deployment
	EventList common.EventList `json:"eventList"`
}

DeploymentDetail is a presentation layer view of Kubernetes Deployment resource.

func GetDeploymentDetail

func GetDeploymentDetail(client client.Interface, heapsterClient heapster.HeapsterClient, namespace string,
	deploymentName string) (*DeploymentDetail, error)

GetDeploymentDetail returns model object of deployment and error, if any.

type DeploymentList

type DeploymentList struct {
	ListMeta common.ListMeta `json:"listMeta"`

	// Unordered list of Deployments.
	Deployments       []Deployment    `json:"deployments"`
	CumulativeMetrics []metric.Metric `json:"cumulativeMetrics"`
}

ReplicationSetList contains a list of Deployments in the cluster.

func CreateDeploymentList

func CreateDeploymentList(deployments []extensions.Deployment, pods []api.Pod,
	events []api.Event, dsQuery *dataselect.DataSelectQuery, heapsterClient *heapster.HeapsterClient) *DeploymentList

CreateDeploymentList returns a list of all Deployment model objects in the cluster, based on all Kubernetes Deployment API objects.

func GetDeploymentList

func GetDeploymentList(client client.Interface, nsQuery *common.NamespaceQuery,
	dsQuery *dataselect.DataSelectQuery, heapsterClient *heapster.HeapsterClient) (*DeploymentList, error)

GetDeploymentList returns a list of all Deployments in the cluster.

func GetDeploymentListFromChannels

func GetDeploymentListFromChannels(channels *common.ResourceChannels,
	dsQuery *dataselect.DataSelectQuery, heapsterClient *heapster.HeapsterClient) (*DeploymentList, error)

GetDeploymentList returns a list of all Deployments in the cluster reading required resource list once from the channels.

type RollingUpdateStrategy

type RollingUpdateStrategy struct {
	MaxSurge       int `json:"maxSurge"`
	MaxUnavailable int `json:"maxUnavailable"`
}

RollingUpdateStrategy is behavior of a rolling update. See RollingUpdateDeployment K8s object.

type StatusInfo

type StatusInfo struct {
	// Total number of desired replicas on the deployment
	Replicas int32 `json:"replicas"`

	// Number of non-terminated pods that have the desired template spec
	Updated int32 `json:"updated"`

	// Number of available pods (ready for at least minReadySeconds)
	// targeted by this deployment
	Available int32 `json:"available"`

	// Total number of unavailable pods targeted by this deployment.
	Unavailable int32 `json:"unavailable"`
}

func GetStatusInfo

func GetStatusInfo(deploymentStatus *extensions.DeploymentStatus) StatusInfo