client

package

v0.0.0-...-f3f2784 Latest Latest Go to latest Published: Apr 29, 2024 License: Apache-2.0 Imports: 31 Imported by: 14

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/openshift/cluster-image-registry-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetConfig() (*rest.Config, error)
func GetOperatorName() (string, error)
func GetWatchNamespace() (string, error)
type Clients
type ConfigOperatorClient
- func NewConfigOperatorClient(client imageregistryv1client.ConfigInterface, ...) *ConfigOperatorClient
type ImagePrunerControllerListers
type Listers
type StorageListers
- func NewStorageListers(infrastructures configlisters.InfrastructureLister, ...) *StorageListers

Constants ¶

View Source

const (
	// WatchNamespaceEnvVar is the constant for env variable WATCH_NAMESPACE
	// which is the namespace that the pod is currently running in.
	WatchNamespaceEnvVar = "WATCH_NAMESPACE"

	// OperatorNameEnvVar is the constant for env variable OPERATOR_NAME
	// which is the name of the current operator
	OperatorNameEnvVar = "OPERATOR_NAME"
)

Variables ¶

This section is empty.

Functions ¶

func GetConfig ¶

func GetConfig() (*rest.Config, error)

GetConfig creates a *rest.Config for talking to a Kubernetes apiserver. Otherwise will assume running in cluster and use the cluster provided kubeconfig.

Config precedence ¶

* KUBECONFIG environment variable pointing at a file

* In-cluster config if running in cluster

* $HOME/.kube/config if exists

func GetOperatorName ¶

func GetOperatorName() (string, error)

GetOperatorName return the operator name

func GetWatchNamespace ¶

func GetWatchNamespace() (string, error)

GetWatchNamespace returns the namespace the operator should be watching for changes

Types ¶

type Clients ¶

type Clients struct {
	Kube   kubeset.Interface
	Route  routeset.RouteV1Interface
	Config configset.ConfigV1Interface
	RegOp  regopset.Interface
	Core   coreset.CoreV1Interface
	Apps   appsset.AppsV1Interface
	RBAC   rbacset.RbacV1Interface
	Batch  batchset.BatchV1Interface
	Job    jobset.BatchV1Interface
}

type ConfigOperatorClient ¶

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

func NewConfigOperatorClient ¶

func NewConfigOperatorClient(client imageregistryv1client.ConfigInterface, informer imageregistryv1informers.ConfigInformer) *ConfigOperatorClient

func (*ConfigOperatorClient) GetObjectMeta ¶

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

func (*ConfigOperatorClient) GetOperatorState ¶

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

func (*ConfigOperatorClient) Informer ¶

func (c *ConfigOperatorClient) Informer() cache.SharedIndexInformer

func (*ConfigOperatorClient) UpdateOperatorSpec ¶

func (c *ConfigOperatorClient) UpdateOperatorSpec(ctx context.Context, oldResourceVersion string, in *operatorv1.OperatorSpec) (out *operatorv1.OperatorSpec, newResourceVersion string, err error)

func (*ConfigOperatorClient) UpdateOperatorStatus ¶

func (c *ConfigOperatorClient) UpdateOperatorStatus(ctx context.Context, oldResourceVersion string, in *operatorv1.OperatorStatus) (out *operatorv1.OperatorStatus, err error)

type ImagePrunerControllerListers ¶

type ImagePrunerControllerListers struct {
	Jobs                kjoblisters.JobNamespaceLister
	CronJobs            kbatchlisters.CronJobNamespaceLister
	ServiceAccounts     kcorelisters.ServiceAccountNamespaceLister
	ClusterRoles        krbaclisters.ClusterRoleLister
	ClusterRoleBindings krbaclisters.ClusterRoleBindingLister
	RegistryConfigs     regoplisters.ConfigLister
	ImagePrunerConfigs  regoplisters.ImagePrunerLister
	ConfigMaps          kcorelisters.ConfigMapNamespaceLister
	ImageConfigs        configlisters.ImageLister
}

type Listers ¶

type Listers struct {
	StorageListers
	Deployments          kappslisters.DeploymentNamespaceLister
	Services             kcorelisters.ServiceNamespaceLister
	ConfigMaps           kcorelisters.ConfigMapNamespaceLister
	ServiceAccounts      kcorelisters.ServiceAccountNamespaceLister
	PodDisruptionBudgets kpolicylisters.PodDisruptionBudgetNamespaceLister
	Routes               routelisters.RouteNamespaceLister
	ClusterRoles         krbaclisters.ClusterRoleLister
	ClusterRoleBindings  krbaclisters.ClusterRoleBindingLister
	RegistryConfigs      regoplisters.ConfigLister
	ProxyConfigs         configlisters.ProxyLister
}

type StorageListers ¶

type StorageListers struct {
	Infrastructures        configlisters.InfrastructureLister
	OpenShiftConfig        kcorelisters.ConfigMapNamespaceLister
	OpenShiftConfigManaged kcorelisters.ConfigMapNamespaceLister
	Secrets                kcorelisters.SecretNamespaceLister
}

StorageListers is a set of listers that can be used by storage drivers.

func NewStorageListers ¶

func NewStorageListers(
	infrastructures configlisters.InfrastructureLister,
	openshiftConfig kcorelisters.ConfigMapNamespaceLister,
	openshiftConfigManaged kcorelisters.ConfigMapNamespaceLister,
	secrets kcorelisters.SecretNamespaceLister,
) *StorageListers

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
fake

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