Documentation
¶
Index ¶
- Constants
- type KueueClient
- func (c *KueueClient) ApplyOperatorSpec(ctx context.Context, fieldManager string, ...) error
- func (c *KueueClient) ApplyOperatorStatus(ctx context.Context, fieldManager string, ...) error
- func (c *KueueClient) GetObjectMeta() (meta *metav1.ObjectMeta, err error)
- func (c KueueClient) GetOperatorState() (spec *operatorv1.OperatorSpec, status *operatorv1.OperatorStatus, ...)
- func (c KueueClient) GetOperatorStateWithQuorum(ctx context.Context) (*operatorv1.OperatorSpec, *operatorv1.OperatorStatus, string, error)
- func (c KueueClient) Informer() cache.SharedIndexInformer
- func (c KueueClient) PatchOperatorStatus(ctx context.Context, patch *jsonpatch.PatchSet) error
- func (c *KueueClient) UpdateOperatorSpec(ctx context.Context, resourceVersion string, spec *operatorv1.OperatorSpec) (out *operatorv1.OperatorSpec, newResourceVersion string, err error)
- func (c *KueueClient) UpdateOperatorStatus(ctx context.Context, resourceVersion string, status *operatorv1.OperatorStatus) (out *operatorv1.OperatorStatus, err error)
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
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 (*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)
Click to show internal directories.
Click to hide internal directories.