cf

package
v1.1.1 Latest Latest
Warning

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

Go to latest
Published: Mar 13, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ENV_REGISTRY_AUTH_ENABLED           = "AUTH_ENABLED"
	ENV_REGISTRY_KEYCLOAK_URL           = "KEYCLOAK_URL"
	ENV_REGISTRY_KEYCLOAK_REALM         = "KEYCLOAK_REALM"
	ENV_REGISTRY_KEYCLOAK_API_CLIENT_ID = "KEYCLOAK_API_CLIENT_ID"
	ENV_REGISTRY_KEYCLOAK_UI_CLIENT_ID  = "KEYCLOAK_UI_CLIENT_ID"

	DEFAULT_REGISTRY_KEYCLOAK_API_CLIENT_ID = "registry-client-api"
	DEFAULT_REGISTRY_KEYCLOAK_UI_CLIENT_ID  = "registry-client-ui"
)
View Source
const ENV_CORS = "CORS_ALLOWED_ORIGINS"
View Source
const ENV_OPERATOR_REGISTRY_IMAGE_KAFKASQL = "REGISTRY_IMAGE_KAFKASQL"
View Source
const ENV_OPERATOR_REGISTRY_IMAGE_MEM = "REGISTRY_IMAGE_MEM"
View Source
const ENV_OPERATOR_REGISTRY_IMAGE_PULL_POLICY = "REGISTRY_IMAGE_PULL_POLICY"
View Source
const ENV_OPERATOR_REGISTRY_IMAGE_SQL = "REGISTRY_IMAGE_SQL"
View Source
const ENV_QUARKUS_PROFILE = "QUARKUS_PROFILE"
View Source
const ENV_REGISTRY_DATASOURCE_PASSWORD = "REGISTRY_DATASOURCE_PASSWORD"
View Source
const ENV_REGISTRY_DATASOURCE_URL = "REGISTRY_DATASOURCE_URL"
View Source
const ENV_REGISTRY_DATASOURCE_USERNAME = "REGISTRY_DATASOURCE_USERNAME"
View Source
const ENV_REGISTRY_LOG_LEVEL = "LOG_LEVEL"
View Source
const ENV_REGISTRY_LOG_LEVEL2 = "REGISTRY_LOG_LEVEL"
View Source
const ENV_UI_READ_ONLY = "REGISTRY_UI_FEATURES_READONLY"
View Source
const HttpPort = 8080
View Source
const HttpsPort = 8443
View Source
const TlsCertMountPath = "/certs"

Variables

This section is empty.

Functions

func ConvertToPodTemplateSpec added in v1.1.0

func ConvertToPodTemplateSpec(source *ar.ApicurioRegistryPodTemplateSpec) (*core.PodTemplateSpec, error)

Do a magic using JSON to conver these values. They MUST have the equivalent field names. We are only doing this because we don't have some ommitempty tags in PodSpec.

func NewAffinityCF

func NewAffinityCF(ctx context.LoopContext) loop.ControlFunction

func NewAnnotationsCF added in v1.1.0

func NewAnnotationsCF(ctx context.LoopContext) loop.ControlFunction

func NewCorsCF added in v1.1.0

func NewCorsCF(ctx context.LoopContext) loop.ControlFunction

This CF makes sure the CORS_ALLOWED_ORIGINS env. variable is set properly

func NewDeploymentCF

func NewDeploymentCF(ctx context.LoopContext, services services.LoopServices) loop.ControlFunction

func NewEnvApplyCF added in v1.1.0

func NewEnvApplyCF(ctx context.LoopContext) loop.ControlFunction

Is responsible for managing environment variables from the env cache

func NewEnvCF

NewEnvCF creates a new instance of `Env` control function. This control function is responsible for reading custom environment variables from the spec, and saving them into the environment cache.

func NewHostCF

This CF makes sure number of host is aligned If there is some other way of determining the number of host needed outside of CR, modify the Sense stage so this CF knows about it

func NewHostInitCF

func NewHostInitCF(ctx context.LoopContext) loop.ControlFunction

This CF makes sure number of host is aligned If there is some other way of determining the number of host needed outside of CR, modify the Sense stage so this CF knows about it

func NewHostInitRouteOcpCF

func NewHostInitRouteOcpCF(ctx context.LoopContext) loop.ControlFunction

func NewHttpsCF added in v1.1.0

func NewHttpsCF(ctx context.LoopContext, services services.LoopServices) loop.ControlFunction

func NewImagePullPolicyCF added in v1.1.0

func NewImagePullPolicyCF(ctx context.LoopContext) loop.ControlFunction

func NewImagePullSecretsCF added in v1.1.0

func NewImagePullSecretsCF(ctx context.LoopContext) loop.ControlFunction

func NewKeycloakCF

func NewKeycloakCF(ctx context.LoopContext) loop.ControlFunction

func NewLabelsCF

func NewLabelsCF(ctx context.LoopContext, services services.LoopServices) loop.ControlFunction

Update labels on some managed resources

func NewLogLevelCF

func NewLogLevelCF(ctx context.LoopContext) loop.ControlFunction

func NewNetworkPolicyCF added in v1.1.0

func NewNetworkPolicyCF(ctx context.LoopContext, services services.LoopServices) loop.ControlFunction

func NewPodDisruptionBudgetV1CF added in v1.1.0

func NewPodDisruptionBudgetV1CF(ctx context.LoopContext, services services.LoopServices) loop.ControlFunction

func NewPodDisruptionBudgetV1beta1CF added in v1.1.0

func NewPodDisruptionBudgetV1beta1CF(ctx context.LoopContext, services services.LoopServices) loop.ControlFunction

func NewPodTemplateSpecCF added in v1.1.0

func NewPodTemplateSpecCF(ctx context.LoopContext, services services.LoopServices) loop.ControlFunction

func NewProfileCF

func NewProfileCF(ctx context.LoopContext) loop.ControlFunction

Is responsible for managing environment variables from the env cache

func NewReplicasCF

func NewReplicasCF(ctx context.LoopContext, services services.LoopServices) loop.ControlFunction

This CF makes sure number of replicas is aligned If there is some other way of determining the number of replicas needed outside of CR, modify the Sense stage so this CF knows about it

func NewSecretVolume added in v1.1.0

func NewSecretVolume(name string) *core.Volume

func NewSecretVolumeMount added in v1.1.0

func NewSecretVolumeMount(name string) *core.VolumeMount

func NewServiceMonitorCF

func NewServiceMonitorCF(ctx context.LoopContext, services services.LoopServices) loop.ControlFunction

TODO service monitor should be using resource cache

func NewTolerationCF

func NewTolerationCF(ctx context.LoopContext) loop.ControlFunction

func NewUpgradeCF added in v1.1.0

func NewUpgradeCF(ctx context.LoopContext) loop.ControlFunction

func SanitizeBasePodSpec added in v1.1.0

Reserved:

- metadata

  • metadata.annotations [alternative exists]
  • metadata.labels [alternative exists]

- spec

  • spec.affinity [alternative exists]
  • spec.containers[*]
  • spec.containers[name = "registry"].env [alternative exists]
  • spec.containers[name = "registry"].image [alternative exists]
  • spec.imagePullSecrets [alternative exists]
  • spec.tolerations [alternative exists]

Types

type AffinityCF

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

func (*AffinityCF) Cleanup

func (this *AffinityCF) Cleanup() bool

func (*AffinityCF) Compare

func (this *AffinityCF) Compare() bool

func (*AffinityCF) Describe

func (this *AffinityCF) Describe() string

func (*AffinityCF) Respond

func (this *AffinityCF) Respond()

func (*AffinityCF) Sense

func (this *AffinityCF) Sense()

type AnnotationsCF added in v1.1.0

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

func (*AnnotationsCF) Cleanup added in v1.1.0

func (this *AnnotationsCF) Cleanup() bool

func (*AnnotationsCF) Compare added in v1.1.0

func (this *AnnotationsCF) Compare() bool

func (*AnnotationsCF) Describe added in v1.1.0

func (this *AnnotationsCF) Describe() string

func (*AnnotationsCF) Respond added in v1.1.0

func (this *AnnotationsCF) Respond()

func (*AnnotationsCF) Sense added in v1.1.0

func (this *AnnotationsCF) Sense()

type CorsCF added in v1.1.0

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

func (*CorsCF) Cleanup added in v1.1.0

func (this *CorsCF) Cleanup() bool

func (*CorsCF) Compare added in v1.1.0

func (this *CorsCF) Compare() bool

func (*CorsCF) Describe added in v1.1.0

func (this *CorsCF) Describe() string

func (*CorsCF) Respond added in v1.1.0

func (this *CorsCF) Respond()

func (*CorsCF) Sense added in v1.1.0

func (this *CorsCF) Sense()

type DeploymentCF

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

func (*DeploymentCF) Cleanup

func (this *DeploymentCF) Cleanup() bool

func (*DeploymentCF) Compare

func (this *DeploymentCF) Compare() bool

func (*DeploymentCF) Describe

func (this *DeploymentCF) Describe() string

func (*DeploymentCF) Respond

func (this *DeploymentCF) Respond()

func (*DeploymentCF) Sense

func (this *DeploymentCF) Sense()

type EnvApplyCF added in v1.1.0

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

func (*EnvApplyCF) Cleanup added in v1.1.0

func (this *EnvApplyCF) Cleanup() bool

func (*EnvApplyCF) Compare added in v1.1.0

func (this *EnvApplyCF) Compare() bool

func (*EnvApplyCF) Describe added in v1.1.0

func (this *EnvApplyCF) Describe() string

func (*EnvApplyCF) Respond added in v1.1.0

func (this *EnvApplyCF) Respond()

func (*EnvApplyCF) Sense added in v1.1.0

func (this *EnvApplyCF) Sense()

type EnvCF

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

func (*EnvCF) Cleanup

func (this *EnvCF) Cleanup() bool

func (*EnvCF) Compare

func (this *EnvCF) Compare() bool

func (*EnvCF) Describe

func (this *EnvCF) Describe() string

func (*EnvCF) Respond

func (this *EnvCF) Respond()

func (*EnvCF) Sense

func (this *EnvCF) Sense()

type HostCF

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

func (*HostCF) Cleanup

func (this *HostCF) Cleanup() bool

func (*HostCF) Compare

func (this *HostCF) Compare() bool

func (*HostCF) Describe

func (this *HostCF) Describe() string

func (*HostCF) Respond

func (this *HostCF) Respond()

func (*HostCF) Sense

func (this *HostCF) Sense()

type HostInitCF

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

func (*HostInitCF) Cleanup

func (this *HostInitCF) Cleanup() bool

func (*HostInitCF) Compare

func (this *HostInitCF) Compare() bool

func (*HostInitCF) Describe

func (this *HostInitCF) Describe() string

func (*HostInitCF) Respond

func (this *HostInitCF) Respond()

func (*HostInitCF) Sense

func (this *HostInitCF) Sense()

type HostInitRouteOcpCF

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

func (*HostInitRouteOcpCF) Cleanup

func (this *HostInitRouteOcpCF) Cleanup() bool

func (*HostInitRouteOcpCF) Compare

func (this *HostInitRouteOcpCF) Compare() bool

func (*HostInitRouteOcpCF) Describe

func (this *HostInitRouteOcpCF) Describe() string

func (*HostInitRouteOcpCF) Respond

func (this *HostInitRouteOcpCF) Respond()

func (*HostInitRouteOcpCF) Sense

func (this *HostInitRouteOcpCF) Sense()

type HttpsCF added in v1.1.0

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

func (*HttpsCF) Cleanup added in v1.1.0

func (this *HttpsCF) Cleanup() bool

func (*HttpsCF) Compare added in v1.1.0

func (this *HttpsCF) Compare() bool

func (*HttpsCF) Describe added in v1.1.0

func (this *HttpsCF) Describe() string

func (*HttpsCF) Respond added in v1.1.0

func (this *HttpsCF) Respond()

func (*HttpsCF) Sense added in v1.1.0

func (this *HttpsCF) Sense()

type ImageCF

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

This CF takes care of keeping the "image" section of the CRD applied.

func (*ImageCF) Cleanup

func (this *ImageCF) Cleanup() bool

func (*ImageCF) Compare

func (this *ImageCF) Compare() bool

func (*ImageCF) Describe

func (this *ImageCF) Describe() string

func (*ImageCF) Respond

func (this *ImageCF) Respond()

func (*ImageCF) Sense

func (this *ImageCF) Sense()

type ImagePullPolicyCF added in v1.1.0

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

func (*ImagePullPolicyCF) Cleanup added in v1.1.0

func (this *ImagePullPolicyCF) Cleanup() bool

func (*ImagePullPolicyCF) Compare added in v1.1.0

func (this *ImagePullPolicyCF) Compare() bool

func (*ImagePullPolicyCF) Describe added in v1.1.0

func (this *ImagePullPolicyCF) Describe() string

func (*ImagePullPolicyCF) Respond added in v1.1.0

func (this *ImagePullPolicyCF) Respond()

func (*ImagePullPolicyCF) Sense added in v1.1.0

func (this *ImagePullPolicyCF) Sense()

type ImagePullSecretsCF added in v1.1.0

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

func (*ImagePullSecretsCF) Cleanup added in v1.1.0

func (this *ImagePullSecretsCF) Cleanup() bool

func (*ImagePullSecretsCF) Compare added in v1.1.0

func (this *ImagePullSecretsCF) Compare() bool

func (*ImagePullSecretsCF) Describe added in v1.1.0

func (this *ImagePullSecretsCF) Describe() string

func (*ImagePullSecretsCF) Respond added in v1.1.0

func (this *ImagePullSecretsCF) Respond()

func (*ImagePullSecretsCF) Sense added in v1.1.0

func (this *ImagePullSecretsCF) Sense()

type IngressCF

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

func (*IngressCF) Cleanup

func (this *IngressCF) Cleanup() bool

func (*IngressCF) Compare

func (this *IngressCF) Compare() bool

func (*IngressCF) Describe

func (this *IngressCF) Describe() string

func (*IngressCF) Respond

func (this *IngressCF) Respond()

func (*IngressCF) Sense

func (this *IngressCF) Sense()

type KeycloakCF

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

func (*KeycloakCF) Cleanup

func (this *KeycloakCF) Cleanup() bool

func (*KeycloakCF) Compare

func (this *KeycloakCF) Compare() bool

func (*KeycloakCF) Describe

func (this *KeycloakCF) Describe() string

func (*KeycloakCF) Respond

func (this *KeycloakCF) Respond()

func (*KeycloakCF) Sense

func (this *KeycloakCF) Sense()

type LabelsCF

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

func (*LabelsCF) Cleanup

func (this *LabelsCF) Cleanup() bool

func (*LabelsCF) Compare

func (this *LabelsCF) Compare() bool

func (*LabelsCF) Describe

func (this *LabelsCF) Describe() string

func (*LabelsCF) GetCommonApplicationLabels

func (this *LabelsCF) GetCommonApplicationLabels() map[string]string

func (*LabelsCF) GetTargetDeploymentPodLabels added in v1.1.0

func (this *LabelsCF) GetTargetDeploymentPodLabels() map[string]string

func (*LabelsCF) Respond

func (this *LabelsCF) Respond()

func (*LabelsCF) Sense

func (this *LabelsCF) Sense()

type LogLevelCF

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

func (*LogLevelCF) Cleanup

func (this *LogLevelCF) Cleanup() bool

func (*LogLevelCF) Compare

func (this *LogLevelCF) Compare() bool

func (*LogLevelCF) Describe

func (this *LogLevelCF) Describe() string

func (*LogLevelCF) Respond

func (this *LogLevelCF) Respond()

func (*LogLevelCF) Sense

func (this *LogLevelCF) Sense()

type NetworkPolicyCF added in v1.1.0

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

func (*NetworkPolicyCF) Cleanup added in v1.1.0

func (this *NetworkPolicyCF) Cleanup() bool

func (*NetworkPolicyCF) Compare added in v1.1.0

func (this *NetworkPolicyCF) Compare() bool

func (*NetworkPolicyCF) Describe added in v1.1.0

func (this *NetworkPolicyCF) Describe() string

func (*NetworkPolicyCF) Respond added in v1.1.0

func (this *NetworkPolicyCF) Respond()

func (*NetworkPolicyCF) Sense added in v1.1.0

func (this *NetworkPolicyCF) Sense()

type PodDisruptionBudgetV1CF added in v1.1.0

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

func (*PodDisruptionBudgetV1CF) Cleanup added in v1.1.0

func (this *PodDisruptionBudgetV1CF) Cleanup() bool

func (*PodDisruptionBudgetV1CF) Compare added in v1.1.0

func (this *PodDisruptionBudgetV1CF) Compare() bool

func (*PodDisruptionBudgetV1CF) Describe added in v1.1.0

func (this *PodDisruptionBudgetV1CF) Describe() string

func (*PodDisruptionBudgetV1CF) Respond added in v1.1.0

func (this *PodDisruptionBudgetV1CF) Respond()

func (*PodDisruptionBudgetV1CF) Sense added in v1.1.0

func (this *PodDisruptionBudgetV1CF) Sense()

type PodDisruptionBudgetV1beta1CF added in v1.1.0

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

func (*PodDisruptionBudgetV1beta1CF) Cleanup added in v1.1.0

func (this *PodDisruptionBudgetV1beta1CF) Cleanup() bool

func (*PodDisruptionBudgetV1beta1CF) Compare added in v1.1.0

func (this *PodDisruptionBudgetV1beta1CF) Compare() bool

func (*PodDisruptionBudgetV1beta1CF) Describe added in v1.1.0

func (this *PodDisruptionBudgetV1beta1CF) Describe() string

func (*PodDisruptionBudgetV1beta1CF) Respond added in v1.1.0

func (this *PodDisruptionBudgetV1beta1CF) Respond()

func (*PodDisruptionBudgetV1beta1CF) Sense added in v1.1.0

func (this *PodDisruptionBudgetV1beta1CF) Sense()

type PodTemplateSpecCF added in v1.1.0

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

func (*PodTemplateSpecCF) Cleanup added in v1.1.0

func (this *PodTemplateSpecCF) Cleanup() bool

func (*PodTemplateSpecCF) Compare added in v1.1.0

func (this *PodTemplateSpecCF) Compare() bool

func (*PodTemplateSpecCF) Describe added in v1.1.0

func (this *PodTemplateSpecCF) Describe() string

func (*PodTemplateSpecCF) Respond added in v1.1.0

func (this *PodTemplateSpecCF) Respond()

func (*PodTemplateSpecCF) Sense added in v1.1.0

func (this *PodTemplateSpecCF) Sense()

type ProfileCF

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

func (*ProfileCF) Cleanup

func (this *ProfileCF) Cleanup() bool

func (*ProfileCF) Compare

func (this *ProfileCF) Compare() bool

func (*ProfileCF) Describe

func (this *ProfileCF) Describe() string

func (*ProfileCF) Respond

func (this *ProfileCF) Respond()

func (*ProfileCF) Sense

func (this *ProfileCF) Sense()

type ReplicasCF

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

func (*ReplicasCF) Cleanup

func (this *ReplicasCF) Cleanup() bool

func (*ReplicasCF) Compare

func (this *ReplicasCF) Compare() bool

func (*ReplicasCF) Describe

func (this *ReplicasCF) Describe() string

func (*ReplicasCF) Respond

func (this *ReplicasCF) Respond()

func (*ReplicasCF) Sense

func (this *ReplicasCF) Sense()

type ServiceCF

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

func (*ServiceCF) Cleanup

func (this *ServiceCF) Cleanup() bool

func (*ServiceCF) Compare

func (this *ServiceCF) Compare() bool

func (*ServiceCF) Describe

func (this *ServiceCF) Describe() string

func (*ServiceCF) Respond

func (this *ServiceCF) Respond()

func (*ServiceCF) Sense

func (this *ServiceCF) Sense()

type ServiceMonitorCF

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

func (*ServiceMonitorCF) Cleanup

func (this *ServiceMonitorCF) Cleanup() bool

func (*ServiceMonitorCF) Compare

func (this *ServiceMonitorCF) Compare() bool

func (*ServiceMonitorCF) Describe

func (this *ServiceMonitorCF) Describe() string

func (*ServiceMonitorCF) Respond

func (this *ServiceMonitorCF) Respond()

func (*ServiceMonitorCF) Sense

func (this *ServiceMonitorCF) Sense()

type SqlCF

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

func (*SqlCF) Cleanup

func (this *SqlCF) Cleanup() bool

func (*SqlCF) Compare

func (this *SqlCF) Compare() bool

func (*SqlCF) Describe

func (this *SqlCF) Describe() string

func (*SqlCF) Respond

func (this *SqlCF) Respond()

func (*SqlCF) Sense

func (this *SqlCF) Sense()

type TolerationCF

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

func (*TolerationCF) Cleanup

func (this *TolerationCF) Cleanup() bool

func (*TolerationCF) Compare

func (this *TolerationCF) Compare() bool

func (*TolerationCF) Describe

func (this *TolerationCF) Describe() string

func (*TolerationCF) Respond

func (this *TolerationCF) Respond()

func (*TolerationCF) Sense

func (this *TolerationCF) Sense()

type UICF

type UICF struct {
	UIReadOnly bool
	// contains filtered or unexported fields
}

func (*UICF) Cleanup

func (this *UICF) Cleanup() bool

func (*UICF) Compare

func (this *UICF) Compare() bool

func (*UICF) Describe

func (this *UICF) Describe() string

func (*UICF) Respond

func (this *UICF) Respond()

func (*UICF) Sense

func (this *UICF) Sense()

type UpgradeCF added in v1.1.0

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

func (*UpgradeCF) Cleanup added in v1.1.0

func (this *UpgradeCF) Cleanup() bool

func (*UpgradeCF) Compare added in v1.1.0

func (this *UpgradeCF) Compare() bool

func (*UpgradeCF) Describe added in v1.1.0

func (this *UpgradeCF) Describe() string

func (*UpgradeCF) Respond added in v1.1.0

func (this *UpgradeCF) Respond()

func (*UpgradeCF) Sense added in v1.1.0

func (this *UpgradeCF) Sense()

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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