operatorclient

package
v0.0.0-...-56c20cb Latest Latest
Warning

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

 Go to latest Published: Feb 21, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

README

Operator Client

This package provides the RunOnceDurationOverrideOperatorClient interface for interacting with the RunOnceDurationOverride custom resource.

GetOperatorState vs GetOperatorStateWithQuorum

  • GetOperatorState() uses the informer to read cached data (fast, may be stale)
  • GetOperatorStateWithQuorum() uses the client to read from the API server (live, guaranteed fresh)

Documentation

Index

Constants

View Source 
const (
	OperatorName            = "runoncedurationoverride"
	OperatorNamespace       = "openshift-run-once-duration-override-operator"
	OperatorConfigName      = "cluster"
	OperatorOwnerAnnotation = "runoncedurationoverride.operator.openshift.io/owner"
)

Variables

This section is empty.

Functions

func UpdateStatus 

func UpdateStatus(ctx context.Context, client *RunOnceDurationOverrideClient, updateFuncs ...UpdateRunOnceDurationOverrideStatusFunc) (*runoncedurationoverridev1.RunOnceDurationOverrideStatus, bool, error)

UpdateStatus applies the update functions to the full RunOnceDurationOverrideStatus and persists it. This is similar to v1helpers.UpdateStatus but works with the complete custom status structure including Hash, Resources, Image, and CertsRotateAt fields that handlers modify.

Types

type OperatorClientWrapper 

type OperatorClientWrapper struct {
	// contains filtered or unexported fields
}

OperatorClientWrapper wraps RunOnceDurationOverrideClient to implement v1helpers.OperatorClient by translating between custom RunOnceDurationOverride types and generic operatorv1 types.

func NewOperatorClientWrapper 

func NewOperatorClientWrapper(client *RunOnceDurationOverrideClient) *OperatorClientWrapper

NewOperatorClientWrapper creates a wrapper around RunOnceDurationOverrideClient that implements v1helpers.OperatorClient interface.

func (*OperatorClientWrapper) ApplyOperatorSpec 

func (w *OperatorClientWrapper) ApplyOperatorSpec(ctx context.Context, fieldManager string, applyConfiguration *applyconfiguration.OperatorSpecApplyConfiguration) error

func (*OperatorClientWrapper) ApplyOperatorStatus 

func (w *OperatorClientWrapper) ApplyOperatorStatus(ctx context.Context, fieldManager string, applyConfiguration *applyconfiguration.OperatorStatusApplyConfiguration) error

func (*OperatorClientWrapper) GetObjectMeta 

func (w *OperatorClientWrapper) GetObjectMeta() (*metav1.ObjectMeta, error)

func (*OperatorClientWrapper) GetOperatorState 

func (w *OperatorClientWrapper) GetOperatorState() (*operatorv1.OperatorSpec, *operatorv1.OperatorStatus, string, error)

func (*OperatorClientWrapper) GetOperatorStateWithQuorum 

func (w *OperatorClientWrapper) GetOperatorStateWithQuorum(ctx context.Context) (*operatorv1.OperatorSpec, *operatorv1.OperatorStatus, string, error)

func (*OperatorClientWrapper) Informer 

func (w *OperatorClientWrapper) Informer() cache.SharedIndexInformer

func (*OperatorClientWrapper) PatchOperatorStatus 

func (w *OperatorClientWrapper) PatchOperatorStatus(ctx context.Context, jsonPatch *jsonpatch.PatchSet) error

func (*OperatorClientWrapper) UpdateOperatorSpec 

func (w *OperatorClientWrapper) UpdateOperatorSpec(ctx context.Context, oldResourceVersion string, in *operatorv1.OperatorSpec) (*operatorv1.OperatorSpec, string, error)

func (*OperatorClientWrapper) UpdateOperatorStatus 

func (w *OperatorClientWrapper) UpdateOperatorStatus(ctx context.Context, oldResourceVersion string, in *operatorv1.OperatorStatus) (*operatorv1.OperatorStatus, error)

type RunOnceDurationOverrideClient 

type RunOnceDurationOverrideClient struct {
	Ctx                             context.Context
	RunOnceDurationOverrideInformer runoncedurationoverrideinformerv1.RunOnceDurationOverrideInformer
	OperatorClient                  operatorconfigclientv1.RunOnceDurationOverrideV1Interface
}

func (*RunOnceDurationOverrideClient) ApplyOperatorSpec 

func (c *RunOnceDurationOverrideClient) ApplyOperatorSpec(ctx context.Context, fieldManager string, desiredConfiguration *applyconfiguration.OperatorSpecApplyConfiguration) error

func (*RunOnceDurationOverrideClient) ApplyOperatorStatus 

func (c *RunOnceDurationOverrideClient) ApplyOperatorStatus(ctx context.Context, fieldManager string, desiredConfiguration *applyconfiguration.OperatorStatusApplyConfiguration) error

func (*RunOnceDurationOverrideClient) GetObjectMeta 

func (c *RunOnceDurationOverrideClient) GetObjectMeta() (meta *metav1.ObjectMeta, err error)

func (RunOnceDurationOverrideClient) GetOperatorState 

func (c RunOnceDurationOverrideClient) GetOperatorState() (spec *runoncedurationoverridev1.RunOnceDurationOverrideSpec, status *runoncedurationoverridev1.RunOnceDurationOverrideStatus, resourceVersion string, err error)

func (RunOnceDurationOverrideClient) GetOperatorStateWithQuorum 

func (c RunOnceDurationOverrideClient) GetOperatorStateWithQuorum(ctx context.Context) (*runoncedurationoverridev1.RunOnceDurationOverrideSpec, *runoncedurationoverridev1.RunOnceDurationOverrideStatus, string, error)

func (RunOnceDurationOverrideClient) Informer 

func (c RunOnceDurationOverrideClient) Informer() cache.SharedIndexInformer

func (*RunOnceDurationOverrideClient) PatchOperatorStatus 

func (c *RunOnceDurationOverrideClient) PatchOperatorStatus(ctx context.Context, jsonPatch *jsonpatch.PatchSet) (err error)

func (*RunOnceDurationOverrideClient) UpdateOperatorSpec 

func (c *RunOnceDurationOverrideClient) UpdateOperatorSpec(ctx context.Context, resourceVersion string, spec *runoncedurationoverridev1.RunOnceDurationOverrideSpec) (out *runoncedurationoverridev1.RunOnceDurationOverrideSpec, newResourceVersion string, err error)

func (*RunOnceDurationOverrideClient) UpdateOperatorStatus 

func (c *RunOnceDurationOverrideClient) UpdateOperatorStatus(ctx context.Context, resourceVersion string, status *runoncedurationoverridev1.RunOnceDurationOverrideStatus) (out *runoncedurationoverridev1.RunOnceDurationOverrideStatus, err error)

type RunOnceDurationOverrideOperatorClient 

type RunOnceDurationOverrideOperatorClient interface {
	Informer() cache.SharedIndexInformer
	GetObjectMeta() (meta *metav1.ObjectMeta, err error)
	GetOperatorState() (spec *runoncedurationoverridev1.RunOnceDurationOverrideSpec, status *runoncedurationoverridev1.RunOnceDurationOverrideStatus, resourceVersion string, err error)
	GetOperatorStateWithQuorum(ctx context.Context) (*runoncedurationoverridev1.RunOnceDurationOverrideSpec, *runoncedurationoverridev1.RunOnceDurationOverrideStatus, string, error)
	UpdateOperatorSpec(ctx context.Context, oldResourceVersion string, in *runoncedurationoverridev1.RunOnceDurationOverrideSpec) (out *runoncedurationoverridev1.RunOnceDurationOverrideSpec, newResourceVersion string, err error)
	UpdateOperatorStatus(ctx context.Context, oldResourceVersion string, in *runoncedurationoverridev1.RunOnceDurationOverrideStatus) (out *runoncedurationoverridev1.RunOnceDurationOverrideStatus, err error)
	ApplyOperatorSpec(ctx context.Context, fieldManager string, applyConfiguration *applyconfiguration.OperatorSpecApplyConfiguration) (err error)
	ApplyOperatorStatus(ctx context.Context, fieldManager string, applyConfiguration *applyconfiguration.OperatorStatusApplyConfiguration) (err error)
	PatchOperatorStatus(ctx context.Context, jsonPatch *jsonpatch.PatchSet) (err error)
}

type UpdateRunOnceDurationOverrideStatusFunc 

type UpdateRunOnceDurationOverrideStatusFunc func(status *runoncedurationoverridev1.RunOnceDurationOverrideStatus) error

UpdateRunOnceDurationOverrideStatusFunc is a function that modifies the RunOnceDurationOverrideStatus.

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.