operatorclient

package
v0.0.0-...-633c2b7 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
const (
	OperatorConfigName = "cluster"
	OperandName        = "kueue-controller-manager"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type KueueClient

type KueueClient struct {
	Ctx            context.Context
	SharedInformer cache.SharedIndexInformer
	OperatorClient operatorconfigclientv1.KueueV1Interface
}

func (*KueueClient) ApplyOperatorSpec

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

func (*KueueClient) ApplyOperatorStatus

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

func (*KueueClient) GetObjectMeta

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

func (KueueClient) GetOperatorState

func (c KueueClient) GetOperatorState() (spec *operatorv1.OperatorSpec, status *operatorv1.OperatorStatus, resourceVersion string, err error)

func (KueueClient) GetOperatorStateWithQuorum

func (c KueueClient) GetOperatorStateWithQuorum(ctx context.Context) (*operatorv1.OperatorSpec, *operatorv1.OperatorStatus, string, error)

func (KueueClient) Informer

func (c KueueClient) Informer() cache.SharedIndexInformer

func (KueueClient) PatchOperatorStatus

func (c KueueClient) PatchOperatorStatus(ctx context.Context, patch *jsonpatch.PatchSet) error

func (*KueueClient) UpdateOperatorSpec

func (c *KueueClient) UpdateOperatorSpec(ctx context.Context, resourceVersion string, spec *operatorv1.OperatorSpec) (out *operatorv1.OperatorSpec, newResourceVersion string, err error)

func (*KueueClient) UpdateOperatorStatus

func (c *KueueClient) UpdateOperatorStatus(ctx context.Context, resourceVersion string, status *operatorv1.OperatorStatus) (out *operatorv1.OperatorStatus, err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL