apiproxy

package
v0.31.0 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2026 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type APIProxy 

type APIProxy interface {
	Client() client.Client

	FetchObject(ctx context.Context, name string, obj client.Object) error
	ListObjects(ctx context.Context, objList client.ObjectList, opts ...client.ListOption) error

	RecordWarning(reason, message string)
	RecordNormal(reason, message string)

	// IsObjectUpdated returns true if annotation of managed object is equal to generation of owner object.
	IsObjectUpdated(obj client.Object) bool

	SyncObject(ctx context.Context, oldObj, newObj client.Object) error
	DeleteObject(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

	// SyncObservedGeneration confirms that current generation was observed.
	// Returns true if generation actually has been changed and status must be saved.
	SyncObservedGeneration() bool

	// SetStatusCondition also updates its own observed generation.
	SetStatusCondition(condition metav1.Condition)

	RemoveStatusCondition(conditionType string)

	GetStatusCondition(conditionType string) *metav1.Condition
	IsStatusConditionTrue(conditionType string) bool
	IsStatusConditionFalse(conditionType string) bool

	// Returns true if condition has met and controller object is not changed since then.
	IsStatusConditionTrueAndObservedGeneration(conditionType string) bool

	UpdateStatus(ctx context.Context) error
}

func NewAPIProxy 

func NewAPIProxy(
	object ControllerObject,
	client client.Client,
	recorder record.EventRecorder,
	scheme *runtime.Scheme,
) APIProxy

type Chyt 

type Chyt struct {
	APIProxy
	// contains filtered or unexported fields
}

func NewChyt 

func NewChyt(
	chyt *ytv1.Chyt,
	client client.Client,
	recorder record.EventRecorder,
	scheme *runtime.Scheme) *Chyt

func (*Chyt) GetResource 

func (c *Chyt) GetResource() *ytv1.Chyt

func (*Chyt) SaveReleaseStatus 

func (c *Chyt) SaveReleaseStatus(ctx context.Context, releaseStatus ytv1.ChytReleaseStatus) error

type ControllerObject added in v0.31.0 

type ControllerObject interface {
	client.Object

	GetStatusObservedGeneration() int64
	SetStatusObservedGeneration(generation int64)
	GetStatusConditions() []metav1.Condition
	SetStatusConditions(conditions []metav1.Condition)
}

type Spyt 

type Spyt struct {
	APIProxy
	// contains filtered or unexported fields
}

func NewSpyt 

func NewSpyt(
	spyt *ytv1.Spyt,
	client client.Client,
	recorder record.EventRecorder,
	scheme *runtime.Scheme,
) *Spyt

func (*Spyt) GetResource 

func (c *Spyt) GetResource() *ytv1.Spyt

func (*Spyt) SaveReleaseStatus 

func (c *Spyt) SaveReleaseStatus(ctx context.Context, releaseStatus ytv1.SpytReleaseStatus) error

type Ytsaurus 

type Ytsaurus struct {
	APIProxy
	// contains filtered or unexported fields
}

func NewYtsaurus 

func NewYtsaurus(
	ytsaurus *ytv1.Ytsaurus,
	client client.Client,
	recorder record.EventRecorder,
	scheme *runtime.Scheme,
) *Ytsaurus

func (*Ytsaurus) ClearUpdateStatus 

func (c *Ytsaurus) ClearUpdateStatus()

func (*Ytsaurus) GetClusterFeatures 

func (c *Ytsaurus) GetClusterFeatures() ytv1.ClusterFeatures

func (*Ytsaurus) GetClusterState 

func (c *Ytsaurus) GetClusterState() ytv1.ClusterState

func (*Ytsaurus) GetCommonPodSpec 

func (c *Ytsaurus) GetCommonPodSpec() *ytv1.PodSpec

func (*Ytsaurus) GetCommonSpec 

func (c *Ytsaurus) GetCommonSpec() *ytv1.CommonSpec

func (*Ytsaurus) GetImageHeater added in v0.31.0 

func (c *Ytsaurus) GetImageHeater(target string) *ytv1.ComponentUpdateSelector

func (*Ytsaurus) GetResource 

func (c *Ytsaurus) GetResource() *ytv1.Ytsaurus

func (*Ytsaurus) GetUpdateState 

func (c *Ytsaurus) GetUpdateState() ytv1.UpdateState

func (*Ytsaurus) GetUpdatingComponents 

func (c *Ytsaurus) GetUpdatingComponents() []ytv1.Component

func (*Ytsaurus) IsInitializing added in v0.31.0 

func (c *Ytsaurus) IsInitializing() bool

func (*Ytsaurus) IsReadyToUpdate added in v0.31.0 

func (c *Ytsaurus) IsReadyToUpdate() bool

func (*Ytsaurus) IsReadyToWork added in v0.31.0 

func (c *Ytsaurus) IsReadyToWork() bool

func (*Ytsaurus) IsUpdateStatusConditionTrue 

func (c *Ytsaurus) IsUpdateStatusConditionTrue(condition string) bool

func (*Ytsaurus) IsUpdating 

func (c *Ytsaurus) IsUpdating() bool

func (*Ytsaurus) IsUpdatingComponent added in v0.31.0 

func (c *Ytsaurus) IsUpdatingComponent(componentType consts.ComponentType, componentName string) bool

func (*Ytsaurus) LogUpdate 

func (c *Ytsaurus) LogUpdate(ctx context.Context, message string)

func (*Ytsaurus) SaveClusterState 

func (c *Ytsaurus) SaveClusterState(ctx context.Context, clusterState ytv1.ClusterState) error

func (*Ytsaurus) SaveUpdateState 

func (c *Ytsaurus) SaveUpdateState(ctx context.Context, updateState ytv1.UpdateState) error

func (*Ytsaurus) SetBlockedComponents 

func (c *Ytsaurus) SetBlockedComponents(components []ytv1.Component) bool

func (*Ytsaurus) SetClusterState added in v0.31.0 

func (c *Ytsaurus) SetClusterState(clusterState ytv1.ClusterState) bool

func (*Ytsaurus) SetUpdateState added in v0.31.0 

func (c *Ytsaurus) SetUpdateState(updateState ytv1.UpdateState)

func (*Ytsaurus) SetUpdateStatusCondition 

func (c *Ytsaurus) SetUpdateStatusCondition(ctx context.Context, condition metav1.Condition)

func (*Ytsaurus) SetUpdatingComponents 

func (c *Ytsaurus) SetUpdatingComponents(canUpdate []ytv1.Component)

func (*Ytsaurus) ShouldRunPreChecks 

func (c *Ytsaurus) ShouldRunPreChecks(componentType consts.ComponentType, componentName string) bool

ShouldRunPreChecks is status-based and can flip to false after successful execution.

func (*Ytsaurus) UpdateOnDeleteComponentsSummary 

func (c *Ytsaurus) UpdateOnDeleteComponentsSummary(ctx context.Context, waitingOnDeleteConditionType string, includeWaitinDuration bool)

UpdateOnDeleteComponentsSummary updates the UpdatingComponentsSummary with waiting time information for components in OnDelete mode

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.