adapter

package
v1.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 17, 2025 License: Apache-2.0 Imports: 21 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CalculateUpdatedReplicas added in v1.8.0 

func CalculateUpdatedReplicas(podList []*corev1.Pod, updatedRevision string) (updatedReplicas, updatedReadyReplicas int32)

Types

type Adapter 

type Adapter interface {
	// NewResourceObject creates an empty subset object.
	NewResourceObject() client.Object
	// NewResourceListObject creates an empty subset list object.
	NewResourceListObject() client.ObjectList
	// GetStatusObservedGeneration returns the observed generation of the subset.
	GetStatusObservedGeneration(subset metav1.Object) int64
	// GetSubsetPods returns all pods of the subset workload.
	GetSubsetPods(obj metav1.Object) ([]*corev1.Pod, error)
	// GetSpecReplicas returns the replicas information of the subset workload.
	GetSpecReplicas(obj metav1.Object) *int32
	// GetSpecPartition returns the partition information of the subset workload if possible.
	GetSpecPartition(obj metav1.Object, pods []*corev1.Pod) *int32
	// GetStatusReplicas returns the replicas from the subset workload status.
	GetStatusReplicas(obj metav1.Object) int32
	// GetStatusReadyReplicas returns the ready replicas information from the subset workload status.
	GetStatusReadyReplicas(obj metav1.Object) int32
	// GetSubsetFailure returns failure information of the subset.
	GetSubsetFailure() *string
	// ApplySubsetTemplate updates the subset to the latest revision.
	ApplySubsetTemplate(ud *alpha1.UnitedDeployment, subsetName, revision string, replicas, partition int32, subset runtime.Object) error
	// PostUpdate does some works after subset updated
	PostUpdate(ud *alpha1.UnitedDeployment, subset runtime.Object, revision string, partition int32) error
}

type AdvancedStatefulSetAdapter 

type AdvancedStatefulSetAdapter struct {
	client.Client

	Scheme *runtime.Scheme
}

func (*AdvancedStatefulSetAdapter) ApplySubsetTemplate 

func (a *AdvancedStatefulSetAdapter) ApplySubsetTemplate(ud *alpha1.UnitedDeployment, subsetName, revision string, replicas, partition int32, obj runtime.Object) error

ApplySubsetTemplate updates the subset to the latest revision, depending on the AdvancedStatefulSetTemplate.

func (*AdvancedStatefulSetAdapter) ConvertToResourceList 

func (a *AdvancedStatefulSetAdapter) ConvertToResourceList(obj runtime.Object) []metav1.Object

ConvertToResourceList converts AdvancedStatefulSetList object to AdvancedStatefulSet array.

func (*AdvancedStatefulSetAdapter) GetObjectMeta 

func (a *AdvancedStatefulSetAdapter) GetObjectMeta(obj metav1.Object) *metav1.ObjectMeta

GetObjectMeta returns the ObjectMeta of the subset of AdvancedStatefulSet.

func (*AdvancedStatefulSetAdapter) GetSpecPartition added in v1.8.0 

func (a *AdvancedStatefulSetAdapter) GetSpecPartition(obj metav1.Object, pods []*corev1.Pod) *int32

func (*AdvancedStatefulSetAdapter) GetSpecReplicas added in v1.8.0 

func (a *AdvancedStatefulSetAdapter) GetSpecReplicas(obj metav1.Object) *int32

func (*AdvancedStatefulSetAdapter) GetStatusObservedGeneration 

func (a *AdvancedStatefulSetAdapter) GetStatusObservedGeneration(obj metav1.Object) int64

GetStatusObservedGeneration returns the observed generation of the subset.

func (*AdvancedStatefulSetAdapter) GetStatusReadyReplicas added in v1.8.0 

func (a *AdvancedStatefulSetAdapter) GetStatusReadyReplicas(obj metav1.Object) int32

func (*AdvancedStatefulSetAdapter) GetStatusReplicas added in v1.8.0 

func (a *AdvancedStatefulSetAdapter) GetStatusReplicas(obj metav1.Object) int32

func (*AdvancedStatefulSetAdapter) GetSubsetFailure 

func (a *AdvancedStatefulSetAdapter) GetSubsetFailure() *string

GetSubsetFailure returns the failure information of the subset. AdvancedStatefulSet has no condition.

func (*AdvancedStatefulSetAdapter) GetSubsetPods added in v1.8.0 

func (a *AdvancedStatefulSetAdapter) GetSubsetPods(obj metav1.Object) ([]*corev1.Pod, error)

func (*AdvancedStatefulSetAdapter) NewResourceListObject 

func (a *AdvancedStatefulSetAdapter) NewResourceListObject() client.ObjectList

NewResourceListObject creates a empty AdvancedStatefulSet object.

func (*AdvancedStatefulSetAdapter) NewResourceObject 

func (a *AdvancedStatefulSetAdapter) NewResourceObject() client.Object

NewResourceObject creates a empty AdvancedStatefulSet object.

func (*AdvancedStatefulSetAdapter) PostUpdate 

func (a *AdvancedStatefulSetAdapter) PostUpdate(_ *alpha1.UnitedDeployment, _ runtime.Object, _ string, _ int32) error

PostUpdate does some works after subset updated.

type CloneSetAdapter added in v0.6.1 

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

func (*CloneSetAdapter) ApplySubsetTemplate added in v0.6.1 

func (a *CloneSetAdapter) ApplySubsetTemplate(ud *alpha1.UnitedDeployment, subsetName, revision string, replicas, partition int32, obj runtime.Object) error

func (*CloneSetAdapter) GetObjectMeta added in v0.6.1 

func (a *CloneSetAdapter) GetObjectMeta(obj metav1.Object) *metav1.ObjectMeta

func (*CloneSetAdapter) GetSpecPartition added in v1.8.0 

func (a *CloneSetAdapter) GetSpecPartition(obj metav1.Object, _ []*corev1.Pod) *int32

func (*CloneSetAdapter) GetSpecReplicas added in v1.8.0 

func (a *CloneSetAdapter) GetSpecReplicas(obj metav1.Object) *int32

func (*CloneSetAdapter) GetStatusObservedGeneration added in v0.6.1 

func (a *CloneSetAdapter) GetStatusObservedGeneration(obj metav1.Object) int64

func (*CloneSetAdapter) GetStatusReadyReplicas added in v1.8.0 

func (a *CloneSetAdapter) GetStatusReadyReplicas(obj metav1.Object) int32

func (*CloneSetAdapter) GetStatusReplicas added in v1.8.0 

func (a *CloneSetAdapter) GetStatusReplicas(obj metav1.Object) int32

func (*CloneSetAdapter) GetSubsetFailure added in v0.6.1 

func (a *CloneSetAdapter) GetSubsetFailure() *string

func (*CloneSetAdapter) GetSubsetPods added in v1.8.0 

func (a *CloneSetAdapter) GetSubsetPods(obj metav1.Object) ([]*corev1.Pod, error)

func (*CloneSetAdapter) NewResourceListObject added in v0.6.1 

func (a *CloneSetAdapter) NewResourceListObject() client.ObjectList

func (*CloneSetAdapter) NewResourceObject added in v0.6.1 

func (a *CloneSetAdapter) NewResourceObject() client.Object

func (*CloneSetAdapter) PostUpdate added in v0.6.1 

func (a *CloneSetAdapter) PostUpdate(_ *alpha1.UnitedDeployment, _ runtime.Object, _ string, _ int32) error

type DeploymentAdapter added in v0.8.0 

type DeploymentAdapter struct {
	client.Client

	Scheme *runtime.Scheme
}

DeploymentAdapter implements the Adapter interface for Deployment objects

func (*DeploymentAdapter) ApplySubsetTemplate added in v0.8.0 

func (a *DeploymentAdapter) ApplySubsetTemplate(ud *alpha1.UnitedDeployment, subsetName, revision string, replicas, _ int32, obj runtime.Object) error

ApplySubsetTemplate updates the subset to the latest revision, depending on the DeploymentTemplate.

func (*DeploymentAdapter) GetSpecPartition added in v1.8.0 

func (a *DeploymentAdapter) GetSpecPartition(_ metav1.Object, _ []*corev1.Pod) *int32

func (*DeploymentAdapter) GetSpecReplicas added in v1.8.0 

func (a *DeploymentAdapter) GetSpecReplicas(obj metav1.Object) *int32

func (*DeploymentAdapter) GetStatusObservedGeneration added in v0.8.0 

func (a *DeploymentAdapter) GetStatusObservedGeneration(obj metav1.Object) int64

GetStatusObservedGeneration returns the observed generation of the subset.

func (*DeploymentAdapter) GetStatusReadyReplicas added in v1.8.0 

func (a *DeploymentAdapter) GetStatusReadyReplicas(obj metav1.Object) int32

func (*DeploymentAdapter) GetStatusReplicas added in v1.8.0 

func (a *DeploymentAdapter) GetStatusReplicas(obj metav1.Object) int32

func (*DeploymentAdapter) GetSubsetFailure added in v0.8.0 

func (a *DeploymentAdapter) GetSubsetFailure() *string

GetSubsetFailure returns the failure information of the subset. Deployment has no condition.

func (*DeploymentAdapter) GetSubsetPods added in v1.8.0 

func (a *DeploymentAdapter) GetSubsetPods(obj metav1.Object) ([]*corev1.Pod, error)

func (*DeploymentAdapter) NewResourceListObject added in v0.8.0 

func (a *DeploymentAdapter) NewResourceListObject() client.ObjectList

NewResourceListObject creates a empty DeploymentList object.

func (*DeploymentAdapter) NewResourceObject added in v0.8.0 

func (a *DeploymentAdapter) NewResourceObject() client.Object

NewResourceObject creates a empty Deployment object.

func (*DeploymentAdapter) PostUpdate added in v0.8.0 

func (a *DeploymentAdapter) PostUpdate(_ *alpha1.UnitedDeployment, _ runtime.Object, _ string, _ int32) error

PostUpdate does some works after subset updated. Deployments typically don't have post update operations.

type StatefulSetAdapter 

type StatefulSetAdapter struct {
	client.Client

	Scheme *runtime.Scheme
}

func (*StatefulSetAdapter) ApplySubsetTemplate 

func (a *StatefulSetAdapter) ApplySubsetTemplate(ud *alpha1.UnitedDeployment, subsetName, revision string, replicas, partition int32, obj runtime.Object) error

ApplySubsetTemplate updates the subset to the latest revision, depending on the StatefulSetTemplate.

func (*StatefulSetAdapter) GetSpecPartition added in v1.8.0 

func (a *StatefulSetAdapter) GetSpecPartition(obj metav1.Object, pods []*corev1.Pod) *int32

func (*StatefulSetAdapter) GetSpecReplicas added in v1.8.0 

func (a *StatefulSetAdapter) GetSpecReplicas(obj metav1.Object) *int32

func (*StatefulSetAdapter) GetStatusObservedGeneration 

func (a *StatefulSetAdapter) GetStatusObservedGeneration(obj metav1.Object) int64

GetStatusObservedGeneration returns the observed generation of the subset.

func (*StatefulSetAdapter) GetStatusReadyReplicas added in v1.8.0 

func (a *StatefulSetAdapter) GetStatusReadyReplicas(obj metav1.Object) int32

func (*StatefulSetAdapter) GetStatusReplicas added in v1.8.0 

func (a *StatefulSetAdapter) GetStatusReplicas(obj metav1.Object) int32

func (*StatefulSetAdapter) GetSubsetFailure 

func (a *StatefulSetAdapter) GetSubsetFailure() *string

GetSubsetFailure returns the failure information of the subset. StatefulSet has no condition.

func (*StatefulSetAdapter) GetSubsetPods added in v1.8.0 

func (a *StatefulSetAdapter) GetSubsetPods(obj metav1.Object) ([]*corev1.Pod, error)

func (*StatefulSetAdapter) NewResourceListObject 

func (a *StatefulSetAdapter) NewResourceListObject() client.ObjectList

NewResourceListObject creates a empty StatefulSetList object.

func (*StatefulSetAdapter) NewResourceObject 

func (a *StatefulSetAdapter) NewResourceObject() client.Object

NewResourceObject creates a empty StatefulSet object.

func (*StatefulSetAdapter) PostUpdate 

func (a *StatefulSetAdapter) PostUpdate(_ *alpha1.UnitedDeployment, obj runtime.Object, revision string, partition int32) error

PostUpdate does some works after subset updated. StatefulSet will implement this method to clean stuck pods.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.