workloadcontroller

Documentation

Index

• func CreateNodeSelectorByNodepoolName(nodepool string) map[string]string
• func TaintsToTolerations(taints []corev1.Taint) []corev1.Toleration
• type DeploymentController
  • func (d *DeploymentController) ApplyTemplate(scheme *runtime.Scheme, yad *v1alpha1.YurtAppDaemon, ...) error
  • func (d *DeploymentController) CreateWorkload(yad *v1alpha1.YurtAppDaemon, nodepool v1alpha1.NodePool, revision string) error
  • func (d *DeploymentController) DeleteWorkload(yda *v1alpha1.YurtAppDaemon, load *Workload) error
  • func (d *DeploymentController) GetAllWorkloads(yad *v1alpha1.YurtAppDaemon) ([]*Workload, error)
  • func (d *DeploymentController) GetTemplateType() v1alpha1.TemplateType
  • func (d *DeploymentController) ObjectKey(load *Workload) client.ObjectKey
  • func (d *DeploymentController) UpdateWorkload(load *Workload, yad *v1alpha1.YurtAppDaemon, nodepool v1alpha1.NodePool, ...) error
• type StatefulSetController
• type Workload
  • func (w *Workload) GetKind() string
  • func (w *Workload) GetNodePoolName() string
  • func (w *Workload) GetNodeSelector() map[string]string
  • func (w *Workload) GetRevision() string
  • func (w *Workload) GetToleration() []corev1.Toleration
• type WorkloadController
• type WorkloadSpec
• type WorkloadStatus

Functions

func CreateNodeSelectorByNodepoolName

func CreateNodeSelectorByNodepoolName(nodepool string) map[string]string

func TaintsToTolerations

func TaintsToTolerations(taints []corev1.Taint) []corev1.Toleration

Types

type DeploymentController

type DeploymentController struct {
	client.Client
	Scheme *runtime.Scheme
}

func (*DeploymentController) ApplyTemplate

func (d *DeploymentController) ApplyTemplate(scheme *runtime.Scheme, yad *v1alpha1.YurtAppDaemon, nodepool v1alpha1.NodePool, revision string, set *appsv1.Deployment) error

ApplyTemplate updates the object to the latest revision, depending on the YurtAppDaemon.

func (*DeploymentController) CreateWorkload

func (d *DeploymentController) CreateWorkload(yad *v1alpha1.YurtAppDaemon, nodepool v1alpha1.NodePool, revision string) error

func (*DeploymentController) DeleteWorkload

func (d *DeploymentController) DeleteWorkload(yda *v1alpha1.YurtAppDaemon, load *Workload) error

func (*DeploymentController) GetAllWorkloads

func (d *DeploymentController) GetAllWorkloads(yad *v1alpha1.YurtAppDaemon) ([]*Workload, error)

func (*DeploymentController) GetTemplateType

func (d *DeploymentController) GetTemplateType() v1alpha1.TemplateType

func (*DeploymentController) ObjectKey

func (d *DeploymentController) ObjectKey(load *Workload) client.ObjectKey

func (*DeploymentController) UpdateWorkload

func (d *DeploymentController) UpdateWorkload(load *Workload, yad *v1alpha1.YurtAppDaemon, nodepool v1alpha1.NodePool, revision string) error

type StatefulSetController

type StatefulSetController struct {
	client.Client
}

type Workload

type Workload struct {
	Name      string
	Namespace string
	Kind      string
	Spec      WorkloadSpec
	Status    WorkloadStatus
}

func (*Workload) GetKind

func (w *Workload) GetKind() string

func (*Workload) GetNodePoolName

func (w *Workload) GetNodePoolName() string

func (*Workload) GetNodeSelector

func (w *Workload) GetNodeSelector() map[string]string

func (*Workload) GetRevision

func (w *Workload) GetRevision() string

func (*Workload) GetToleration

func (w *Workload) GetToleration() []corev1.Toleration

type WorkloadController

type WorkloadController interface {
	ObjectKey(load *Workload) client.ObjectKey
	GetAllWorkloads(daemon *v1alpha1.YurtAppDaemon) ([]*Workload, error)
	CreateWorkload(daemon *v1alpha1.YurtAppDaemon, nodepool v1alpha1.NodePool, revision string) error
	UpdateWorkload(load *Workload, daemon *v1alpha1.YurtAppDaemon, nodepool v1alpha1.NodePool, revision string) error
	DeleteWorkload(daemon *v1alpha1.YurtAppDaemon, load *Workload) error
	GetTemplateType() v1alpha1.TemplateType
}

type WorkloadSpec

type WorkloadSpec struct {
	Ref          metav1.Object
	Tolerations  []corev1.Toleration
	NodeSelector map[string]string
}

WorkloadSpec stores the spec details of the workload

type WorkloadStatus

type WorkloadStatus struct {
	Replicas           int32
	ReadyReplicas      int32
	AvailableCondition corev1.ConditionStatus
}

WorkloadStatus stores the observed state of the Workload.