collaset

package
v0.7.4 Latest Latest
Warning

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

 Go to latest Published: Jun 30, 2026 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	UpdateOpsLifecycleAdapter  = &CollaSetUpdateOpsLifecycleAdapter{}
	ScaleInOpsLifecycleAdapter = &CollaSetScaleInOpsLifecycleAdapter{}
)

Functions

func Add 

func Add(mgr manager.Manager) error

func NewInPlaceIfPossibleUpdater added in v0.7.1 

func NewInPlaceIfPossibleUpdater() synccontrols.TargetUpdater

Types

type CollaSetController added in v0.7.0 

type CollaSetController struct {
	XSetOperation
	XOperation
	LifecycleAdapterGetter
	GetLabelManagerAdapterGetter
	SubResourcePvcAdapter
	DecorationAdapter
	ResourceContextAdapterGetter
}

func (*CollaSetController) ControllerName added in v0.7.0 

func (m *CollaSetController) ControllerName() string

func (*CollaSetController) FinalizerName added in v0.7.0 

func (m *CollaSetController) FinalizerName() string

func (*CollaSetController) NewXObject added in v0.7.0 

func (m *CollaSetController) NewXObject() client.Object

func (*CollaSetController) NewXObjectList added in v0.7.0 

func (m *CollaSetController) NewXObjectList() client.ObjectList

func (*CollaSetController) NewXSetObject added in v0.7.0 

func (m *CollaSetController) NewXSetObject() xsetapi.XSetObject

func (*CollaSetController) XMeta added in v0.7.0 

func (m *CollaSetController) XMeta() metav1.TypeMeta

func (*CollaSetController) XSetMeta added in v0.7.0 

func (m *CollaSetController) XSetMeta() metav1.TypeMeta

type CollaSetScaleInOpsLifecycleAdapter added in v0.7.0 

type CollaSetScaleInOpsLifecycleAdapter struct{}

CollaSetScaleInOpsLifecycleAdapter tells PodOpsLifecycle the basic workload scaling in ops info

func (*CollaSetScaleInOpsLifecycleAdapter) AllowMultiType added in v0.7.0 

func (a *CollaSetScaleInOpsLifecycleAdapter) AllowMultiType() bool

AllowMultiType indicates whether multiple IDs which have the same Type are allowed

func (*CollaSetScaleInOpsLifecycleAdapter) GetID added in v0.7.0 

func (a *CollaSetScaleInOpsLifecycleAdapter) GetID() string

GetID indicates ID of one PodOpsLifecycle

func (*CollaSetScaleInOpsLifecycleAdapter) GetType added in v0.7.0 

func (a *CollaSetScaleInOpsLifecycleAdapter) GetType() xsetapi.OperationType

GetType indicates type for an Operator

func (*CollaSetScaleInOpsLifecycleAdapter) WhenBegin added in v0.7.0 

func (a *CollaSetScaleInOpsLifecycleAdapter) WhenBegin(pod client.Object) (bool, error)

WhenBegin will be executed when begin a lifecycle

func (*CollaSetScaleInOpsLifecycleAdapter) WhenFinish added in v0.7.0 

func (a *CollaSetScaleInOpsLifecycleAdapter) WhenFinish(_ client.Object) (bool, error)

WhenFinish will be executed when finish a lifecycle

type CollaSetUpdateOpsLifecycleAdapter added in v0.7.0 

type CollaSetUpdateOpsLifecycleAdapter struct{}

CollaSetUpdateOpsLifecycleAdapter tells PodOpsLifecycle the basic workload update ops info

func (*CollaSetUpdateOpsLifecycleAdapter) AllowMultiType added in v0.7.0 

func (a *CollaSetUpdateOpsLifecycleAdapter) AllowMultiType() bool

AllowMultiType indicates whether multiple IDs which have the same Type are allowed

func (*CollaSetUpdateOpsLifecycleAdapter) GetID added in v0.7.0 

func (a *CollaSetUpdateOpsLifecycleAdapter) GetID() string

GetID indicates ID of one PodOpsLifecycle

func (*CollaSetUpdateOpsLifecycleAdapter) GetType added in v0.7.0 

func (a *CollaSetUpdateOpsLifecycleAdapter) GetType() xsetapi.OperationType

GetType indicates type for an Operator

func (*CollaSetUpdateOpsLifecycleAdapter) WhenBegin added in v0.7.0 

func (a *CollaSetUpdateOpsLifecycleAdapter) WhenBegin(_ client.Object) (bool, error)

WhenBegin will be executed when begin a lifecycle

func (*CollaSetUpdateOpsLifecycleAdapter) WhenFinish added in v0.7.0 

func (a *CollaSetUpdateOpsLifecycleAdapter) WhenFinish(pod client.Object) (bool, error)

WhenFinish will be executed when finish a lifecycle

type ContainerStatus added in v0.7.0 

type ContainerStatus struct {
	LatestImage string `json:"latestImage,omitempty"`
	LastImageID string `json:"lastImageID,omitempty"`
}

type DecorationAdapter added in v0.7.0 

type DecorationAdapter struct{}

func (*DecorationAdapter) GetDecorationGroupVersionKind added in v0.7.0 

func (d *DecorationAdapter) GetDecorationGroupVersionKind() metav1.GroupVersionKind

func (*DecorationAdapter) GetDecorationPatcherByRevisions added in v0.7.0 

func (d *DecorationAdapter) GetDecorationPatcherByRevisions(ctx context.Context, c client.Client, target client.Object, revision string) (func(client.Object) error, error)

func (*DecorationAdapter) GetTargetCurrentDecorationRevisions added in v0.7.0 

func (d *DecorationAdapter) GetTargetCurrentDecorationRevisions(ctx context.Context, c client.Client, target client.Object) (string, error)

func (*DecorationAdapter) GetTargetUpdatedDecorationRevisions added in v0.7.0 

func (d *DecorationAdapter) GetTargetUpdatedDecorationRevisions(ctx context.Context, c client.Client, target client.Object) (string, error)

func (*DecorationAdapter) IsTargetDecorationChanged added in v0.7.0 

func (d *DecorationAdapter) IsTargetDecorationChanged(current, updated string) (bool, error)

func (*DecorationAdapter) WatchDecoration added in v0.7.0 

func (d *DecorationAdapter) WatchDecoration(c controller.Controller) error

type GetLabelManagerAdapterGetter added in v0.7.0 

type GetLabelManagerAdapterGetter struct{}

func (*GetLabelManagerAdapterGetter) GetLabelManagerAdapter added in v0.7.0 

func (g *GetLabelManagerAdapterGetter) GetLabelManagerAdapter() map[xsetapi.XSetLabelAnnotationEnum]string

type LifecycleAdapterGetter added in v0.7.0 

type LifecycleAdapterGetter struct{}

func (*LifecycleAdapterGetter) GetScaleInOpsLifecycleAdapter added in v0.7.0 

func (l *LifecycleAdapterGetter) GetScaleInOpsLifecycleAdapter() xsetapi.LifecycleAdapter

func (*LifecycleAdapterGetter) GetUpdateOpsLifecycleAdapter added in v0.7.0 

func (l *LifecycleAdapterGetter) GetUpdateOpsLifecycleAdapter() xsetapi.LifecycleAdapter

type PodStatus added in v0.7.0 

type PodStatus struct {
	ContainerStates map[string]*ContainerStatus `json:"containerStates,omitempty"`
}

type ResourceContextAdapter added in v0.7.0 

type ResourceContextAdapter struct{}

ResourceContextAdapter is the adapter to xsetapi apps.kusionstack.io.resourcecontexts

func (*ResourceContextAdapter) GetContextKeys added in v0.7.0 

func (*ResourceContextAdapter) GetContextKeys() map[xsetapi.ResourceContextKeyEnum]string

func (*ResourceContextAdapter) GetResourceContextSpec added in v0.7.0 

func (*ResourceContextAdapter) GetResourceContextSpec(object xsetapi.ResourceContextObject) *xsetapi.ResourceContextSpec

func (*ResourceContextAdapter) NewResourceContext added in v0.7.0 

func (*ResourceContextAdapter) NewResourceContext() xsetapi.ResourceContextObject

func (*ResourceContextAdapter) ResourceContextMeta added in v0.7.0 

func (*ResourceContextAdapter) ResourceContextMeta() metav1.TypeMeta

func (*ResourceContextAdapter) SetResourceContextSpec added in v0.7.0 

func (*ResourceContextAdapter) SetResourceContextSpec(spec *xsetapi.ResourceContextSpec, object xsetapi.ResourceContextObject)

type ResourceContextAdapterGetter added in v0.7.0 

type ResourceContextAdapterGetter struct{}

func (*ResourceContextAdapterGetter) GetResourceContextAdapter added in v0.7.0 

func (r *ResourceContextAdapterGetter) GetResourceContextAdapter() xsetapi.ResourceContextAdapter

type SubResourcePvcAdapter added in v0.7.0 

type SubResourcePvcAdapter struct{}

func (*SubResourcePvcAdapter) GetXSetPvcTemplate added in v0.7.0 

func (p *SubResourcePvcAdapter) GetXSetPvcTemplate(object xsetapi.XSetObject) []corev1.PersistentVolumeClaim

GetXSetPvcTemplate returns pvc template from XSet object.

func (*SubResourcePvcAdapter) GetXSpecVolumes added in v0.7.0 

func (p *SubResourcePvcAdapter) GetXSpecVolumes(object client.Object) []corev1.Volume

GetXSpecVolumes returns spec.volumes from X object.

func (*SubResourcePvcAdapter) GetXVolumeMounts added in v0.7.0 

func (p *SubResourcePvcAdapter) GetXVolumeMounts(object client.Object) []corev1.VolumeMount

GetXVolumeMounts returns containers volumeMounts from X (pod) object.

func (*SubResourcePvcAdapter) RetainPvcWhenXSetDeleted added in v0.7.0 

func (p *SubResourcePvcAdapter) RetainPvcWhenXSetDeleted(object xsetapi.XSetObject) bool

RetainPvcWhenXSetDeleted returns true if pvc should be retained when XSet is deleted.

func (*SubResourcePvcAdapter) RetainPvcWhenXSetScaled added in v0.7.0 

func (p *SubResourcePvcAdapter) RetainPvcWhenXSetScaled(object xsetapi.XSetObject) bool

RetainPvcWhenXSetScaled returns true if pvc should be retained when XSet replicas is scaledIn.

func (*SubResourcePvcAdapter) SetXSpecVolumes added in v0.7.0 

func (p *SubResourcePvcAdapter) SetXSpecVolumes(object client.Object, pvcs []corev1.Volume)

SetXSpecVolumes sets spec.volumes to X object.

type XOperation added in v0.7.0 

type XOperation struct{}

func (*XOperation) CheckAvailable added in v0.7.0 

func (o *XOperation) CheckAvailable(object client.Object) bool

func (*XOperation) CheckInactive added in v0.7.0 

func (o *XOperation) CheckInactive(object client.Object) bool

func (*XOperation) CheckReadyTime added in v0.7.0 

func (o *XOperation) CheckReadyTime(object client.Object) (bool, *metav1.Time)

func (*XOperation) CheckScheduled added in v0.7.0 

func (o *XOperation) CheckScheduled(object client.Object) bool

func (*XOperation) GetXObjectFromRevision added in v0.7.0 

func (o *XOperation) GetXObjectFromRevision(revision *appsv1.ControllerRevision) (client.Object, error)

func (*XOperation) GetXOpsPriority added in v0.7.0 

func (o *XOperation) GetXOpsPriority(_ context.Context, _ client.Client, _ client.Object) (*xsetapi.OpsPriority, error)

type XSetOperation added in v0.7.0 

type XSetOperation struct{}

func (*XSetOperation) GetPostCreateFunc added in v0.7.2 

func (s *XSetOperation) GetPostCreateFunc(xset xsetapi.XSetObject) func(client.Object) error

func (*XSetOperation) GetXSetPatch added in v0.7.0 

func (s *XSetOperation) GetXSetPatch(object metav1.Object) ([]byte, error)

func (*XSetOperation) GetXSetSpec added in v0.7.0 

func (s *XSetOperation) GetXSetSpec(xset xsetapi.XSetObject) *xsetapi.XSetSpec

func (*XSetOperation) GetXSetStatus added in v0.7.0 

func (s *XSetOperation) GetXSetStatus(object xsetapi.XSetObject) *xsetapi.XSetStatus

func (*XSetOperation) GetXSetTemplatePatcher added in v0.7.0 

func (s *XSetOperation) GetXSetTemplatePatcher(_ metav1.Object) func(client.Object) error

func (*XSetOperation) SetXSetStatus added in v0.7.0 

func (s *XSetOperation) SetXSetStatus(object xsetapi.XSetObject, xSetStatus *xsetapi.XSetStatus)

func (*XSetOperation) UpdateScaleStrategy added in v0.7.0 

func (s *XSetOperation) UpdateScaleStrategy(ctx context.Context, c client.Client, object xsetapi.XSetObject, scaleStrategy *xsetapi.ScaleStrategy) (err error)

Source Files

View all Source files

Directories

Path Synopsis

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.