strategy

Documentation

Index

• type NodeItem
  • func NewNodeItem(node *corev1.Node, edsNode *datadoghqv1alpha1.ExtendedDaemonsetSetting) *NodeItem
• type NodeList
• type Parameters
• type ReplicaSetStatus
• type Result
  • func ManageCanaryDeployment(client client.Client, daemonset *v1alpha1.ExtendedDaemonSet, ...) (*Result, error)
  • func ManageDeployment(client client.Client, params *Parameters) (*Result, error)
  • func ManageUnknown(client client.Client, params *Parameters) (*Result, error)

Types

type NodeItem

type NodeItem struct {
	Node                     *corev1.Node
	ExtendedDaemonsetSetting *datadoghqv1alpha1.ExtendedDaemonsetSetting
}

NodeItem used to store all informations needs to create or delete a pod

func NewNodeItem

func NewNodeItem(node *corev1.Node, edsNode *datadoghqv1alpha1.ExtendedDaemonsetSetting) *NodeItem

NewNodeItem used to create new NodeItem instance

type NodeList

type NodeList struct {
	Items []*NodeItem
}

NodeList list of NodeItem

type Parameters

type Parameters struct {
	MinPodUpdate int32
	MaxPodUpdate int32

	EDSName          string
	Strategy         *datadoghqv1alpha1.ExtendedDaemonSetSpecStrategy
	Replicaset       *datadoghqv1alpha1.ExtendedDaemonSetReplicaSet
	ReplicaSetStatus string

	NewStatus *datadoghqv1alpha1.ExtendedDaemonSetReplicaSetStatus

	CanaryNodes []string

	NodeByName      map[string]*NodeItem
	PodByNodeName   map[*NodeItem]*corev1.Pod
	PodToCleanUp    []*corev1.Pod
	UnscheduledPods []*corev1.Pod

	Logger logr.Logger
}

Parameters use to store all the parameter need to a strategy

type ReplicaSetStatus

type ReplicaSetStatus string

ReplicaSetStatus repesent the status of a ReplicaSet

const (
	// ReplicaSetStatusActive the ReplicaSet is currently active
	ReplicaSetStatusActive ReplicaSetStatus = "active"
	// ReplicaSetStatusCanary the ReplicaSet is currently in canary mode
	ReplicaSetStatusCanary ReplicaSetStatus = "canary"
	// ReplicaSetStatusUnknown the controller is not able to define the ReplicaSet status
	ReplicaSetStatusUnknown ReplicaSetStatus = "unknown"
)

type Result

type Result struct {
	// PodsToCreate list of NodeItem for Pods creation
	PodsToCreate []*NodeItem
	// PodsToDelete list of NodeItem for Pods deletion
	PodsToDelete []*NodeItem

	UnscheduledNodesDueToResourcesConstraints []string

	NewStatus *datadoghqv1alpha1.ExtendedDaemonSetReplicaSetStatus
	Result    reconcile.Result
}

Result information returns by a strategy

func ManageCanaryDeployment

func ManageCanaryDeployment(client client.Client, daemonset *v1alpha1.ExtendedDaemonSet, params *Parameters) (*Result, error)

ManageCanaryDeployment used to manage ReplicaSet in Canary state

func ManageDeployment

func ManageDeployment(client client.Client, params *Parameters) (*Result, error)

ManageDeployment used to manage ReplicaSet in rollingupdate state

func ManageUnknown

func ManageUnknown(client client.Client, params *Parameters) (*Result, error)

ManageUnknown use to manage ReplicaSet with unknown status