Documentation
¶
Index ¶
- type Clients
- type ClusterCatalogClient
- type ClusterExtensionClient
- type ClusterObjectSetClient
- type ConfigClientWrapper
- type InfrastructureClient
- type InfrastructureClientInterface
- type OperatorClient
- func (o OperatorClient) ApplyOperatorSpec(ctx context.Context, fieldManager string, ...) error
- func (o OperatorClient) ApplyOperatorStatus(ctx context.Context, fieldManager string, ...) error
- func (o OperatorClient) EnsureFinalizer(ctx context.Context, finalizer string) error
- func (o OperatorClient) GetObjectMeta() (*metav1.ObjectMeta, error)
- func (o OperatorClient) GetOperatorState() (*operatorv1.OperatorSpec, *operatorv1.OperatorStatus, string, error)
- func (o OperatorClient) GetOperatorStateWithQuorum(ctx context.Context) (*operatorv1.OperatorSpec, *operatorv1.OperatorStatus, string, error)
- func (o OperatorClient) Informer() cache.SharedIndexInformer
- func (o OperatorClient) PatchOperatorStatus(ctx context.Context, jsonPatch *jsonpatch.PatchSet) error
- func (o OperatorClient) RemoveFinalizer(ctx context.Context, finalizer string) error
- func (o OperatorClient) UpdateOperatorSpec(ctx context.Context, oldResourceVersion string, in *operatorv1.OperatorSpec) (*operatorv1.OperatorSpec, string, error)
- func (o OperatorClient) UpdateOperatorStatus(ctx context.Context, oldResourceVersion string, in *operatorv1.OperatorStatus) (*operatorv1.OperatorStatus, error)
- type ProxyClient
- type ProxyClientInterface
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Clients ¶
type Clients struct {
KubeClient kubernetes.Interface
APIExtensionsClient apiextensionsclient.Interface
DynamicClient dynamic.Interface
RESTMapper meta.RESTMapper
OperatorClient *OperatorClient
OperatorInformers operatorinformers.SharedInformerFactory
ClusterExtensionClient *ClusterExtensionClient
ClusterObjectSetClient *ClusterObjectSetClient
ClusterCatalogClient *ClusterCatalogClient
ProxyClient *ProxyClient
InfrastructureClient *InfrastructureClient
ConfigClient configclient.Interface
KubeInformerFactory informers.SharedInformerFactory
ConfigInformerFactory configinformer.SharedInformerFactory
KubeInformersForNamespaces v1helpers.KubeInformersForNamespaces
FeatureGatesAccessor featuregates.FeatureGateAccess
FeatureGateMapper internalfeatures.MapperInterface
}
func New ¶
func New(cc *controllercmd.ControllerContext) (*Clients, error)
func (*Clients) ClientHolder ¶
func (c *Clients) ClientHolder() *resourceapply.ClientHolder
func (*Clients) StartInformers ¶
type ClusterCatalogClient ¶
type ClusterCatalogClient struct {
// contains filtered or unexported fields
}
func NewClusterCatalogClient ¶
func NewClusterCatalogClient(dynClient dynamic.Interface) *ClusterCatalogClient
func (*ClusterCatalogClient) Get ¶
func (cc *ClusterCatalogClient) Get(key types.NamespacedName) (runtime.Object, error)
func (*ClusterCatalogClient) Informer ¶
func (cc *ClusterCatalogClient) Informer() cache.SharedIndexInformer
type ClusterExtensionClient ¶
type ClusterExtensionClient struct {
// contains filtered or unexported fields
}
func NewClusterExtensionClient ¶
func NewClusterExtensionClient(dynClient dynamic.Interface) *ClusterExtensionClient
func (ClusterExtensionClient) Informer ¶
func (ce ClusterExtensionClient) Informer() informers.GenericInformer
type ClusterObjectSetClient ¶
type ClusterObjectSetClient struct {
// contains filtered or unexported fields
}
func NewClusterObjectSetClient ¶
func NewClusterObjectSetClient(dynClient dynamic.Interface) *ClusterObjectSetClient
func (ClusterObjectSetClient) Informer ¶
func (c ClusterObjectSetClient) Informer() informers.GenericInformer
type ConfigClientWrapper ¶
type ConfigClientWrapper struct {
configv1client.ConfigV1Interface
// contains filtered or unexported fields
}
ConfigClientWrapper wraps ConfigV1Interface to intercept ClusterOperator status updates
func NewConfigClientWrapper ¶
func NewConfigClientWrapper(configClient configv1client.ConfigV1Interface, coLister configv1listers.ClusterOperatorLister, releaseVersion string, clock clock.PassiveClock) *ConfigClientWrapper
NewConfigClientWrapper creates a new ConfigClientWrapper
func (*ConfigClientWrapper) ClusterOperators ¶
func (w *ConfigClientWrapper) ClusterOperators() configv1client.ClusterOperatorInterface
ClusterOperators returns wrapped ClusterOperatorInterface
type InfrastructureClient ¶
type InfrastructureClient struct {
// contains filtered or unexported fields
}
func NewInfrastructureClient ¶
func NewInfrastructureClient(infFact configinformer.SharedInformerFactory) *InfrastructureClient
func (*InfrastructureClient) Get ¶
func (ic *InfrastructureClient) Get(key string) (*configv1.Infrastructure, error)
func (*InfrastructureClient) Informer ¶
func (ic *InfrastructureClient) Informer() cache.SharedIndexInformer
type InfrastructureClientInterface ¶
type InfrastructureClientInterface interface {
Get(key string) (*configv1.Infrastructure, error)
}
type OperatorClient ¶
type OperatorClient struct {
// contains filtered or unexported fields
}
func (OperatorClient) ApplyOperatorSpec ¶
func (o OperatorClient) ApplyOperatorSpec(ctx context.Context, fieldManager string, applyConfiguration *operatorv1apply.OperatorSpecApplyConfiguration) error
func (OperatorClient) ApplyOperatorStatus ¶
func (o OperatorClient) ApplyOperatorStatus(ctx context.Context, fieldManager string, desiredStatus *operatorv1apply.OperatorStatusApplyConfiguration) error
func (OperatorClient) EnsureFinalizer ¶
func (o OperatorClient) EnsureFinalizer(ctx context.Context, finalizer string) error
func (OperatorClient) GetObjectMeta ¶
func (o OperatorClient) GetObjectMeta() (*metav1.ObjectMeta, error)
func (OperatorClient) GetOperatorState ¶
func (o OperatorClient) GetOperatorState() (*operatorv1.OperatorSpec, *operatorv1.OperatorStatus, string, error)
func (OperatorClient) GetOperatorStateWithQuorum ¶
func (o OperatorClient) GetOperatorStateWithQuorum(ctx context.Context) (*operatorv1.OperatorSpec, *operatorv1.OperatorStatus, string, error)
func (OperatorClient) Informer ¶
func (o OperatorClient) Informer() cache.SharedIndexInformer
func (OperatorClient) PatchOperatorStatus ¶
func (OperatorClient) RemoveFinalizer ¶
func (o OperatorClient) RemoveFinalizer(ctx context.Context, finalizer string) error
func (OperatorClient) UpdateOperatorSpec ¶
func (o OperatorClient) UpdateOperatorSpec(ctx context.Context, oldResourceVersion string, in *operatorv1.OperatorSpec) (*operatorv1.OperatorSpec, string, error)
func (OperatorClient) UpdateOperatorStatus ¶
func (o OperatorClient) UpdateOperatorStatus(ctx context.Context, oldResourceVersion string, in *operatorv1.OperatorStatus) (*operatorv1.OperatorStatus, error)
type ProxyClient ¶
type ProxyClient struct {
// contains filtered or unexported fields
}
func NewProxyClient ¶
func NewProxyClient(infFact configinformer.SharedInformerFactory) *ProxyClient
func (*ProxyClient) Informer ¶
func (pc *ProxyClient) Informer() cache.SharedIndexInformer
Click to show internal directories.
Click to hide internal directories.