clients

Documentation

Index

• type Clients
  • func New(cc *controllercmd.ControllerContext) (*Clients, error)
  • func (c *Clients) ClientHolder() *resourceapply.ClientHolder
  • func (c *Clients) StartInformers(ctx context.Context)
• type ClusterCatalogClient
  • func NewClusterCatalogClient(dynClient dynamic.Interface) *ClusterCatalogClient
  • func (cc *ClusterCatalogClient) Get(key types.NamespacedName) (runtime.Object, error)
  • func (cc *ClusterCatalogClient) Informer() cache.SharedIndexInformer
• type ClusterExtensionClient
  • func NewClusterExtensionClient(dynClient dynamic.Interface) *ClusterExtensionClient
  • func (ce ClusterExtensionClient) Informer() informers.GenericInformer
• 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)

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
	ClusterCatalogClient       *ClusterCatalogClient
	ConfigClient               configclient.Interface
	KubeInformerFactory        informers.SharedInformerFactory
	ConfigInformerFactory      configinformer.SharedInformerFactory
	KubeInformersForNamespaces v1helpers.KubeInformersForNamespaces
}

func New

func New(cc *controllercmd.ControllerContext) (*Clients, error)

func (*Clients) ClientHolder

func (c *Clients) ClientHolder() *resourceapply.ClientHolder

func (*Clients) StartInformers

func (c *Clients) StartInformers(ctx context.Context)

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 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, applyConfiguration *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 (o OperatorClient) PatchOperatorStatus(ctx context.Context, jsonPatch *jsonpatch.PatchSet) error

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)