Documentation ¶
Overview ¶
Package v1 contains API Schema definitions for the infinispan v1 API group +kubebuilder:object:generate=true +groupName=infinispan.org
Index ¶
- Constants
- Variables
- func GetRequestLimits(str string) (requests resource.Quantity, limits resource.Quantity, err error)
- func LoadDefaultLabelsAndAnnotations() (labels map[string]string, annotations map[string]string, err error)
- type Authorization
- type AuthorizationRole
- type Autoscale
- type CertificateSourceType
- type ClientCertType
- type ConditionType
- type ConfigListenerLogLevel
- type ConfigListenerLoggingSpec
- type ConfigListenerSpec
- func (spec *ConfigListenerSpec) CpuResources() (requests resource.Quantity, limits resource.Quantity, err error)
- func (in *ConfigListenerSpec) DeepCopy() *ConfigListenerSpec
- func (in *ConfigListenerSpec) DeepCopyInto(out *ConfigListenerSpec)
- func (spec *ConfigListenerSpec) MemoryResources() (requests resource.Quantity, limits resource.Quantity, err error)
- type ContainerProbeSpec
- type CrossSiteExposeSpec
- type CrossSiteExposeType
- type CrossSiteKeyStore
- type CrossSiteSchemeType
- type CrossSiteTrustStore
- type DeploymentStatus
- type DiscoverySiteSpec
- func (spec *DiscoverySiteSpec) CpuResources() (requests resource.Quantity, limits resource.Quantity, err error)
- func (in *DiscoverySiteSpec) DeepCopy() *DiscoverySiteSpec
- func (in *DiscoverySiteSpec) DeepCopyInto(out *DiscoverySiteSpec)
- func (spec *DiscoverySiteSpec) MemoryResources() (requests resource.Quantity, limits resource.Quantity, err error)
- type DiscoverySiteType
- type EncryptionSiteSpec
- type EndpointEncryption
- type ExposeSpec
- type ExposeType
- type ExternalArtifactType
- type ExternalDependencyType
- type GossipRouterHeartbeatSpec
- type HotRodRollingUpgradeStage
- type HotRodRollingUpgradeStatus
- type ImageType
- type Infinispan
- func (ispn *Infinispan) Affinity() *corev1.Affinity
- func (ispn *Infinispan) ApplyEndpointEncryptionSettings(servingCertsMode string)
- func (ispn *Infinispan) ApplyMonitoringAnnotation()
- func (i *Infinispan) ApplyOperatorMeta(defaultLabels, defaultAnnotations map[string]string)
- func (ispn *Infinispan) CrossSiteDiscoveryType() DiscoverySiteType
- func (in *Infinispan) DeepCopy() *Infinispan
- func (in *Infinispan) DeepCopyInto(out *Infinispan)
- func (in *Infinispan) DeepCopyObject() runtime.Object
- func (i *Infinispan) Default()
- func (ispn *Infinispan) EnsureClusterStability() error
- func (ispn *Infinispan) ExpectConditionStatus(expected map[ConditionType]metav1.ConditionStatus) error
- func (ispn *Infinispan) ExternalServiceLabels() map[string]string
- func (ispn *Infinispan) ExternalServiceSelectorLabels() map[string]string
- func (ispn *Infinispan) GenerateSecretName() string
- func (ispn *Infinispan) GetAdminSecretName() string
- func (ispn *Infinispan) GetAdminServiceName() string
- func (ispn *Infinispan) GetAuthorizationRoles() []AuthorizationRole
- func (ispn *Infinispan) GetCondition(condition ConditionType) InfinispanCondition
- func (ispn *Infinispan) GetConfigListenerName() string
- func (ispn *Infinispan) GetConfigName() string
- func (ispn *Infinispan) GetCredentialStoreSecretName() string
- func (ispn *Infinispan) GetCrossSiteExposeType() CrossSiteExposeType
- func (ispn *Infinispan) GetEndpointScheme() string
- func (ispn *Infinispan) GetExposeHost() string
- func (ispn *Infinispan) GetExposeType() ExposeType
- func (ispn *Infinispan) GetGossipRouterDeploymentName() string
- func (ispn *Infinispan) GetInfinispanSecuritySecretName() string
- func (ispn *Infinispan) GetJavaOptions() string
- func (ispn *Infinispan) GetKeystoreSecretName() string
- func (ispn *Infinispan) GetLogCategoriesForConfig() map[string]string
- func (ispn *Infinispan) GetLogPatternForConfig() string
- func (ispn *Infinispan) GetOperatorUser() string
- func (ispn *Infinispan) GetPingServiceName() string
- func (ispn *Infinispan) GetRemoteSiteClusterName(locationName string) string
- func (ispn *Infinispan) GetRemoteSiteLocations() (remoteLocations map[string]InfinispanSiteLocationSpec)
- func (ispn *Infinispan) GetRemoteSiteNamespace(locationName string) string
- func (ispn *Infinispan) GetRemoteSiteRouteName(locationName string) string
- func (ispn *Infinispan) GetRemoteSiteServiceFQN(locationName string) string
- func (ispn *Infinispan) GetRemoteSiteServiceName(locationName string) string
- func (ispn *Infinispan) GetSecretName() string
- func (ispn *Infinispan) GetServiceExternalName() string
- func (ispn *Infinispan) GetServiceMonitorName() string
- func (ispn *Infinispan) GetServiceName() string
- func (ispn *Infinispan) GetSiteLocationsName() (locations []string)
- func (ispn *Infinispan) GetSiteRouteName() string
- func (ispn *Infinispan) GetSiteRouterKeyStoreAlias() string
- func (ispn *Infinispan) GetSiteRouterKeyStoreFileName() string
- func (ispn *Infinispan) GetSiteRouterSecretName() string
- func (ispn *Infinispan) GetSiteServiceName() string
- func (ispn *Infinispan) GetSiteTLSProtocol() string
- func (ispn *Infinispan) GetSiteTransportKeyStoreAlias() string
- func (ispn *Infinispan) GetSiteTransportKeyStoreFileName() string
- func (ispn *Infinispan) GetSiteTransportSecretName() string
- func (ispn *Infinispan) GetSiteTrustStoreFileName() string
- func (ispn *Infinispan) GetSiteTrustoreSecretName() string
- func (ispn *Infinispan) GetStatefulSetName() string
- func (ispn *Infinispan) GetTruststoreSecretName() string
- func (ispn *Infinispan) GossipRouterAnnotations() map[string]string
- func (ispn *Infinispan) GossipRouterPodLabels() map[string]string
- func (ispn *Infinispan) GossipRouterPodSelectorLabels() map[string]string
- func (ispn *Infinispan) GracefulShutdownUpgrades() bool
- func (ispn *Infinispan) HasCondition(condition ConditionType) bool
- func (ispn *Infinispan) HasDependenciesVolume() bool
- func (ispn *Infinispan) HasExternalArtifacts() bool
- func (ispn *Infinispan) HasSites() bool
- func (ispn *Infinispan) HotRodRollingUpgrades() bool
- func (ispn *Infinispan) ImageName() string
- func (ispn *Infinispan) ImageType() ImageType
- func (ispn *Infinispan) InitServiceContainer()
- func (ispn *Infinispan) IsAuthenticationEnabled() bool
- func (ispn *Infinispan) IsAuthorizationEnabled() bool
- func (ispn *Infinispan) IsCache() bool
- func (ispn *Infinispan) IsClientCertEnabled() bool
- func (ispn *Infinispan) IsConditionFalse(name ConditionType) bool
- func (ispn *Infinispan) IsConditionTrue(name ConditionType) bool
- func (ispn *Infinispan) IsConfigListenerEnabled() bool
- func (ispn *Infinispan) IsCredentialStoreSecretDefined() bool
- func (ispn *Infinispan) IsDataGrid() bool
- func (ispn *Infinispan) IsEncryptionCertFromService() bool
- func (ispn *Infinispan) IsEncryptionCertSourceDefined() bool
- func (ispn *Infinispan) IsEncryptionEnabled() bool
- func (ispn *Infinispan) IsEphemeralStorage() bool
- func (ispn *Infinispan) IsExposed() bool
- func (ispn *Infinispan) IsGeneratedSecret() bool
- func (ispn *Infinispan) IsGossipRouterEnabled() bool
- func (ispn *Infinispan) IsHotRodUpgrade() bool
- func (ispn *Infinispan) IsJmxExposed() bool
- func (ispn *Infinispan) IsServiceMonitorEnabled() bool
- func (ispn *Infinispan) IsSiteTLSEnabled() bool
- func (ispn *Infinispan) IsUpgradeCondition() bool
- func (ispn *Infinispan) IsUpgradeNeeded(logger logr.Logger) bool
- func (ispn *Infinispan) IsWellFormed() bool
- func (ispn *Infinispan) Labels(app string) map[string]string
- func (ispn *Infinispan) LaunchGossipRouterEnabled() bool
- func (ispn *Infinispan) NotClusterFormed(pods, replicas int) bool
- func (ispn *Infinispan) PodAnnotations() map[string]string
- func (ispn *Infinispan) PodLabels() map[string]string
- func (ispn *Infinispan) PodSelectorLabels() map[string]string
- func (ispn *Infinispan) PriorityClassName() string
- func (ispn *Infinispan) RemoveCondition(condition ConditionType) bool
- func (ispn *Infinispan) ServiceAnnotations() map[string]string
- func (ispn *Infinispan) ServiceLabels(app string) map[string]string
- func (ispn *Infinispan) ServiceMonitorTargetLabels() []string
- func (ispn *Infinispan) ServiceSelectorLabels() map[string]string
- func (ispn *Infinispan) SetCondition(condition ConditionType, status metav1.ConditionStatus, message string) bool
- func (ispn *Infinispan) SetConditions(conds ...InfinispanCondition) bool
- func (i *Infinispan) SetupWebhookWithManager(mgr ctrl.Manager) (err error)
- func (ispn *Infinispan) StorageClassName() string
- func (ispn *Infinispan) StorageSize() string
- func (ispn *Infinispan) Tolerations() []corev1.Toleration
- func (ispn *Infinispan) TopologySpreadConstraints() []corev1.TopologySpreadConstraint
- func (ispn *Infinispan) UserConfigDefined() bool
- func (i *Infinispan) ValidateCreate() error
- func (i *Infinispan) ValidateDelete() error
- func (i *Infinispan) ValidateUpdate(oldRuntimeObj runtime.Object) error
- type InfinispanCloudEvents
- type InfinispanCondition
- type InfinispanContainerSpec
- func (in *InfinispanContainerSpec) DeepCopy() *InfinispanContainerSpec
- func (in *InfinispanContainerSpec) DeepCopyInto(out *InfinispanContainerSpec)
- func (spec *InfinispanContainerSpec) GetCpuResources() (requests resource.Quantity, limits resource.Quantity, err error)
- func (spec *InfinispanContainerSpec) GetMemoryResources() (requests resource.Quantity, limits resource.Quantity, err error)
- type InfinispanExternalArtifacts
- type InfinispanExternalDependencies
- type InfinispanList
- type InfinispanLoggingSpec
- type InfinispanSecurity
- type InfinispanServiceContainerSpec
- type InfinispanServiceSpec
- type InfinispanSiteLocationSpec
- type InfinispanSitesLocalSpec
- type InfinispanSitesSpec
- type InfinispanSpec
- type InfinispanStatus
- type InfinispanUpgradesSpec
- type InitDependenciesContainerSpec
- func (spec *InitDependenciesContainerSpec) CpuResources() (requests resource.Quantity, limits resource.Quantity, err error)
- func (in *InitDependenciesContainerSpec) DeepCopy() *InitDependenciesContainerSpec
- func (in *InitDependenciesContainerSpec) DeepCopyInto(out *InitDependenciesContainerSpec)
- func (spec *InitDependenciesContainerSpec) MemoryResources() (requests resource.Quantity, limits resource.Quantity, err error)
- type JmxSpec
- type LoggingLevelType
- type OperandPhase
- type OperandStatus
- type Operator
- type SchedulingSpec
- type ServiceType
- type TLSProtocol
- type UpgradeType
Constants ¶
const ( // ExposeTypeNodePort means a service will be exposed on one port of // every node, in addition to 'ClusterIP' type. ExposeTypeNodePort = ExposeType(corev1.ServiceTypeNodePort) // ExposeTypeLoadBalancer means a service will be exposed via an // external load balancer (if the cloud provider supports it), in addition // to 'NodePort' type. ExposeTypeLoadBalancer = ExposeType(corev1.ServiceTypeLoadBalancer) // ExposeTypeRoute means the service will be exposed via // `Route` on Openshift or via `Ingress` on Kubernetes ExposeTypeRoute ExposeType = "Route" )
const ( // CrossSiteExposeTypeNodePort means a service will be exposed on one port of // every node, in addition to 'ClusterIP' type. CrossSiteExposeTypeNodePort = CrossSiteExposeType(corev1.ServiceTypeNodePort) // CrossSiteExposeTypeLoadBalancer means a service will be exposed via an // external load balancer (if the cloud provider supports it), in addition // to 'NodePort' type. CrossSiteExposeTypeLoadBalancer = CrossSiteExposeType(corev1.ServiceTypeLoadBalancer) // CrossSiteExposeTypeClusterIP means an internal 'ClusterIP' // service will be created without external exposition CrossSiteExposeTypeClusterIP = CrossSiteExposeType(corev1.ServiceTypeClusterIP) // CrossSiteExposeTypeRoute route CrossSiteExposeTypeRoute = "Route" )
const ( CrossSiteSchemeTypeKubernetes = "kubernetes" CrossSiteSchemeTypeMinikube = "minikube" CrossSiteSchemeTypeOpenShift = "openshift" )
const ( // PodTargetLabels labels propagated to pods PodTargetLabels string = "infinispan.org/podTargetLabels" // TargetLabels labels propagated to services/ingresses/routes TargetLabels string = "infinispan.org/targetLabels" // ServiceMonitorTargetLabels labels propagated to ServiceMonitor targetLabel for the label retainment ServiceMonitorTargetLabels string = "infinispan.org/serviceMonitorTargetLabels" // OperatorPodTargetLabels labels propagated by the operator to pods OperatorPodTargetLabels string = "infinispan.org/operatorPodTargetLabels" // OperatorTargetLabels labels propagated by the operator to services/ingresses/routes OperatorTargetLabels string = "infinispan.org/operatorTargetLabels" // OperatorTargetLabelsEnvVarName is the name of the envvar containing operator label/value map for services/ingresses/routes OperatorTargetLabelsEnvVarName string = "INFINISPAN_OPERATOR_TARGET_LABELS" // OperatorPodTargetLabelsEnvVarName is the name of the envvar containing operator label/value map for pods OperatorPodTargetLabelsEnvVarName string = "INFINISPAN_OPERATOR_POD_TARGET_LABELS" // PodTargetAnnotations annotations propagated to pods PodTargetAnnotations string = "infinispan.org/podTargetAnnotations" // TargetAnnotations annotations propagated to services/ingresses/routes TargetAnnotations string = "infinispan.org/targetAnnotations" // OperatorPodTargetAnnotations annotations propagated by the operator to pods OperatorPodTargetAnnotations string = "infinispan.org/operatorPodTargetAnnotations" // OperatorTargetAnnotations annotations propagated by the operator to services/ingresses/routes OperatorTargetAnnotations string = "infinispan.org/operatorTargetAnnotations" // OperatorTargetAnnotationsEnvVarName is the name of the envvar containing operator label/value map for services/ingresses/routes OperatorTargetAnnotationsEnvVarName string = "INFINISPAN_OPERATOR_TARGET_ANNOTATIONS" // OperatorPodTargetAnnotationsEnvVarName is the name of the envvar containing operator label/value map for pods OperatorPodTargetAnnotationsEnvVarName string = "INFINISPAN_OPERATOR_POD_TARGET_ANNOTATIONS" // OperatorOperandVersionEnvVarName is the name of the envvar containing the supported operand json OperatorOperandVersionEnvVarName string = "INFINISPAN_OPERAND_VERSIONS" // RouterAnnotations annotations for GossipRouter deployment RouterAnnotations string = "infinispan.org/routerAnnotations" MaxRouteObjectNameLength = 63 // ServiceMonitoringAnnotation defines if we need to create ServiceMonitor or not ServiceMonitoringAnnotation string = "infinispan.org/monitoring" SiteServiceNameTemplate = "%v-site" SiteRouteNameSuffix = "-route-site" SiteServiceFQNTemplate = "%s.%s.svc.cluster.local" GossipRouterDeploymentNameTemplate = "%s-router" DefaultLoggingPattern = "%d{HH:mm:ss,SSS} %-5p (%t) [%c] %m%throwable%n" )
Variables ¶
var ( // GroupVersion is group version used to register these objects GroupVersion = schema.GroupVersion{Group: "infinispan.org", Version: "v1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion} // AddToScheme adds the types in this group-version to the given scheme. AddToScheme = SchemeBuilder.AddToScheme )
var (
ServingCertsMode string
)
Functions ¶
func GetRequestLimits ¶
func LoadDefaultLabelsAndAnnotations ¶
func LoadDefaultLabelsAndAnnotations() (labels map[string]string, annotations map[string]string, err error)
LoadDefaultLabelsAndAnnotations initialises default operator labels to be propagated to pods and services Env vars INFINISPAN_OPERATOR_TARGET_LABELS, INFINISPAN_OPERATOR_POD_TARGET_LABELS must contain a json map of labels, the former will be applied to services/ingresses/routes, the latter to pods
Types ¶
type Authorization ¶
type Authorization struct { // +optional Enabled bool `json:"enabled,omitempty"` // +optional Roles []AuthorizationRole `json:"roles,omitempty"` }
func (*Authorization) DeepCopy ¶
func (in *Authorization) DeepCopy() *Authorization
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Authorization.
func (*Authorization) DeepCopyInto ¶
func (in *Authorization) DeepCopyInto(out *Authorization)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AuthorizationRole ¶
type AuthorizationRole struct { Name string `json:"name"` Permissions []string `json:"permissions"` }
func (*AuthorizationRole) DeepCopy ¶
func (in *AuthorizationRole) DeepCopy() *AuthorizationRole
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AuthorizationRole.
func (*AuthorizationRole) DeepCopyInto ¶
func (in *AuthorizationRole) DeepCopyInto(out *AuthorizationRole)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Autoscale ¶
type Autoscale struct { MaxReplicas int32 `json:"maxReplicas"` MinReplicas int32 `json:"minReplicas"` MaxMemUsagePercent int `json:"maxMemUsagePercent"` MinMemUsagePercent int `json:"minMemUsagePercent"` // +optional Disabled bool `json:"disabled,omitempty"` }
Autoscale describe autoscaling configuration for the cluster
func (*Autoscale) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Autoscale.
func (*Autoscale) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CertificateSourceType ¶
type CertificateSourceType string
CertificateSourceType specifies all the possible sources for the encryption certificate +kubebuilder:validation:Enum=Service;service;Secret;secret;None
const ( // CertificateSourceTypeService certificate coming from a cluster service CertificateSourceTypeService CertificateSourceType = "Service" // CertificateSourceTypeServiceLowCase certificate coming from a cluster service CertificateSourceTypeServiceLowCase CertificateSourceType = "service" // CertificateSourceTypeSecret certificate coming from a user provided secret CertificateSourceTypeSecret CertificateSourceType = "Secret" // CertificateSourceTypeSecretLowCase certificate coming from a user provided secret CertificateSourceTypeSecretLowCase CertificateSourceType = "secret" // CertificateSourceTypeNoneNoEncryption no certificate encryption disabled CertificateSourceTypeNoneNoEncryption CertificateSourceType = "None" )
type ClientCertType ¶
type ClientCertType string
ClientCertType specifies a client certificate validation mechanism. +kubebuilder:validation:Enum=None;Authenticate;Validate
const ( // No client certificates required ClientCertNone ClientCertType = "None" // All client certificates must be in the configured truststore. ClientCertAuthenticate ClientCertType = "Authenticate" // Client certificates are validated against the CA in the truststore. It is not required for all client certificates to be contained in the trustore. ClientCertValidate ClientCertType = "Validate" )
type ConditionType ¶
type ConditionType string
const ( ConditionPrelimChecksPassed ConditionType = "PreliminaryChecksPassed" ConditionGracefulShutdown ConditionType = "GracefulShutdown" ConditionScalingDown ConditionType = "ScalingDown" ConditionScalingUp ConditionType = "ScalingUp" ConditionStopping ConditionType = "Stopping" ConditionUpgrade ConditionType = "Upgrade" ConditionWellFormed ConditionType = "WellFormed" ConditionCrossSiteViewFormed ConditionType = "CrossSiteViewFormed" ConditionGossipRouterReady ConditionType = "GossipRouterReady" ConditionTLSSecretValid ConditionType = "TLSSecretValid" )
type ConfigListenerLogLevel ¶
type ConfigListenerLogLevel string
+kubebuilder:validation:Enum=debug;info;error
const ( ConfigListenerLoggingDebug ConfigListenerLogLevel = "debug" ConfigListenerLoggingInfo ConfigListenerLogLevel = "info" ConfigListenerLoggingError ConfigListenerLogLevel = "error" )
type ConfigListenerLoggingSpec ¶
type ConfigListenerLoggingSpec struct { // The logging level to be used by the ConfigListener pod // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Logging Level",xDescriptors={"urn:alm:descriptor:com.tectonic.ui:select:debug", "urn:alm:descriptor:com.tectonic.ui:select:info", "urn:alm:descriptor:com.tectonic.ui:select:error"} Level ConfigListenerLogLevel `json:"level"` }
func (*ConfigListenerLoggingSpec) DeepCopy ¶
func (in *ConfigListenerLoggingSpec) DeepCopy() *ConfigListenerLoggingSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigListenerLoggingSpec.
func (*ConfigListenerLoggingSpec) DeepCopyInto ¶
func (in *ConfigListenerLoggingSpec) DeepCopyInto(out *ConfigListenerLoggingSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigListenerSpec ¶
type ConfigListenerSpec struct { // If true, a dedicated pod is used to ensure that all config resources created on the Infinispan server have a matching CR resource // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Toggle Config Listener",xDescriptors="urn:alm:descriptor:com.tectonic.ui:booleanSwitch" Enabled bool `json:"enabled"` // ConfigListener logging configuration // +optional Logging *ConfigListenerLoggingSpec `json:"logging,omitempty"` // +optional Memory string `json:"memory,omitempty"` // +optional CPU string `json:"cpu,omitempty"` }
func (*ConfigListenerSpec) CpuResources ¶
func (spec *ConfigListenerSpec) CpuResources() (requests resource.Quantity, limits resource.Quantity, err error)
CpuResources returns the CPU request and limit values to be used by pods
func (*ConfigListenerSpec) DeepCopy ¶
func (in *ConfigListenerSpec) DeepCopy() *ConfigListenerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigListenerSpec.
func (*ConfigListenerSpec) DeepCopyInto ¶
func (in *ConfigListenerSpec) DeepCopyInto(out *ConfigListenerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ConfigListenerSpec) MemoryResources ¶
func (spec *ConfigListenerSpec) MemoryResources() (requests resource.Quantity, limits resource.Quantity, err error)
MemoryResources returns the Memory request and limit values to be used by pods
type ContainerProbeSpec ¶
type ContainerProbeSpec struct { // Number of seconds after the container has started before liveness probes are initiated. // +optional InitialDelaySeconds *int32 `json:"initialDelaySeconds,omitempty"` // Number of seconds after which the probe times out. // +optional TimeoutSeconds *int32 `json:"timeoutSeconds,omitempty"` // How often (in seconds) to perform the probe. // +optional PeriodSeconds *int32 `json:"periodSeconds,omitempty"` // Minimum consecutive successes for the probe to be considered successful after having failed. // +optional SuccessThreshold *int32 `json:"successThreshold,omitempty"` // Minimum consecutive failures for the probe to be considered failed after having succeeded. // +optional FailureThreshold *int32 `json:"failureThreshold,omitempty"` }
func (*ContainerProbeSpec) AssignDefaults ¶
func (c *ContainerProbeSpec) AssignDefaults(failureThreshold, initialDelay, period, successThreshold, timeout int32)
func (*ContainerProbeSpec) DeepCopy ¶
func (in *ContainerProbeSpec) DeepCopy() *ContainerProbeSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ContainerProbeSpec.
func (*ContainerProbeSpec) DeepCopyInto ¶
func (in *ContainerProbeSpec) DeepCopyInto(out *ContainerProbeSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CrossSiteExposeSpec ¶
type CrossSiteExposeSpec struct { // Type specifies different exposition methods for data grid Type CrossSiteExposeType `json:"type"` // +optional NodePort int32 `json:"nodePort,omitempty"` // +optional Port int32 `json:"port,omitempty"` // RouteHostName optionally, specifies a custom hostname to be used by Openshift Route. // +optional RouteHostName string `json:"routeHostName,omitempty"` // +optional Annotations map[string]string `json:"annotations,omitempty"` }
CrossSiteExposeSpec describe how Infinispan Cross-Site service will be exposed externally
func (*CrossSiteExposeSpec) DeepCopy ¶
func (in *CrossSiteExposeSpec) DeepCopy() *CrossSiteExposeSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CrossSiteExposeSpec.
func (*CrossSiteExposeSpec) DeepCopyInto ¶
func (in *CrossSiteExposeSpec) DeepCopyInto(out *CrossSiteExposeSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CrossSiteExposeType ¶
type CrossSiteExposeType string
CrossSiteExposeType describe different exposition methods for Infinispan Cross-Site service +kubebuilder:validation:Enum=NodePort;LoadBalancer;ClusterIP;Route
type CrossSiteKeyStore ¶
type CrossSiteKeyStore struct { SecretName string `json:"secretName"` // +optional Alias string `json:"alias,omitempty"` // +optional Filename string `json:"filename,omitempty"` }
CrossSiteKeyStore keystore configuration for cross-site replication with TLS
func (*CrossSiteKeyStore) DeepCopy ¶
func (in *CrossSiteKeyStore) DeepCopy() *CrossSiteKeyStore
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CrossSiteKeyStore.
func (*CrossSiteKeyStore) DeepCopyInto ¶
func (in *CrossSiteKeyStore) DeepCopyInto(out *CrossSiteKeyStore)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CrossSiteSchemeType ¶
type CrossSiteSchemeType string
CrossSiteSchemeType specifies the supported url scheme's allowed in InfinispanSiteLocationSpec.URL
type CrossSiteTrustStore ¶
type CrossSiteTrustStore struct { SecretName string `json:"secretName"` // +optional Filename string `json:"filename,omitempty"` }
CrossSiteTrustStore truststore configuration for cross-site replication with TLS
func (*CrossSiteTrustStore) DeepCopy ¶
func (in *CrossSiteTrustStore) DeepCopy() *CrossSiteTrustStore
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CrossSiteTrustStore.
func (*CrossSiteTrustStore) DeepCopyInto ¶
func (in *CrossSiteTrustStore) DeepCopyInto(out *CrossSiteTrustStore)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeploymentStatus ¶
type DeploymentStatus struct { // Deployments are ready to serve requests Ready []string `json:"ready,omitempty"` // Deployments are starting, may or may not succeed Starting []string `json:"starting,omitempty"` // Deployments are not starting, unclear what next step will be Stopped []string `json:"stopped,omitempty"` }
func (*DeploymentStatus) DeepCopy ¶
func (in *DeploymentStatus) DeepCopy() *DeploymentStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeploymentStatus.
func (*DeploymentStatus) DeepCopyInto ¶
func (in *DeploymentStatus) DeepCopyInto(out *DeploymentStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DiscoverySiteSpec ¶
type DiscoverySiteSpec struct { // Configures the discovery mode for cross-site replication // +optional Type DiscoverySiteType `json:"type,omitempty"` // Enables (default) or disables the Gossip Router pod and cross-site services // +optional LaunchGossipRouter *bool `json:"launchGossipRouter,omitempty"` // Memory resource request for Gossip Router if enabled // +optional Memory string `json:"memory,omitempty"` // CPU resource request for Gossip Router if enabled // +optional CPU string `json:"cpu,omitempty"` // Enables the JGroups suspect events if the Gossip Router detects a connection closed // +optional SuspectEvents bool `json:"suspectEvents,omitempty"` // Configures the Gossip Router heartbeats to keep the connection open // +optional Heartbeats *GossipRouterHeartbeatSpec `json:"heartbeats,omitempty"` }
DiscoverySiteSpec configures the corss-site replication discovery
func (*DiscoverySiteSpec) CpuResources ¶
func (spec *DiscoverySiteSpec) CpuResources() (requests resource.Quantity, limits resource.Quantity, err error)
CpuResources returns the CPU request and limit values to be used by by Gossip Router pod
func (*DiscoverySiteSpec) DeepCopy ¶
func (in *DiscoverySiteSpec) DeepCopy() *DiscoverySiteSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DiscoverySiteSpec.
func (*DiscoverySiteSpec) DeepCopyInto ¶
func (in *DiscoverySiteSpec) DeepCopyInto(out *DiscoverySiteSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DiscoverySiteSpec) MemoryResources ¶
func (spec *DiscoverySiteSpec) MemoryResources() (requests resource.Quantity, limits resource.Quantity, err error)
MemoryResources returns the Memory request and limit values to be used by Gossip Router pod
type DiscoverySiteType ¶
type DiscoverySiteType string
Specifies the discovery mode for cross-site configuration +kubebuilder:validation:Enum=gossiprouter
const (
GossipRouterType DiscoverySiteType = "gossiprouter"
)
GossipRouterType is the only one supported but we may add other like submariner and/or skupper
type EncryptionSiteSpec ¶
type EncryptionSiteSpec struct { // +optional Protocol TLSProtocol `json:"protocol,omitempty"` TransportKeyStore CrossSiteKeyStore `json:"transportKeyStore"` RouterKeyStore CrossSiteKeyStore `json:"routerKeyStore"` // +optional TrustStore *CrossSiteTrustStore `json:"trustStore,omitempty"` }
EncryptionSiteSpec enables TLS for cross-site replication
func (*EncryptionSiteSpec) DeepCopy ¶
func (in *EncryptionSiteSpec) DeepCopy() *EncryptionSiteSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionSiteSpec.
func (*EncryptionSiteSpec) DeepCopyInto ¶
func (in *EncryptionSiteSpec) DeepCopyInto(out *EncryptionSiteSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EndpointEncryption ¶
type EndpointEncryption struct { // Disable or modify endpoint encryption. // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Configure Encryption",xDescriptors={"urn:alm:descriptor:com.tectonic.ui:select:Service","urn:alm:descriptor:com.tectonic.ui:select:Secret","urn:alm:descriptor:com.tectonic.ui:select:None"} Type CertificateSourceType `json:"type,omitempty"` // A service that provides TLS certificates // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Encryption Service",xDescriptors={"urn:alm:descriptor:com.tectonic.ui:text", "urn:alm:descriptor:com.tectonic.ui:fieldDependency:security.endpointEncryption.type:Service"} CertServiceName string `json:"certServiceName,omitempty"` // The secret that contains TLS certificates // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Encryption Secret",xDescriptors={"urn:alm:descriptor:io.kubernetes:Secret", "urn:alm:descriptor:com.tectonic.ui:fieldDependency:security.endpointEncryption.type:Secret"} CertSecretName string `json:"certSecretName,omitempty"` // +optional ClientCert ClientCertType `json:"clientCert,omitempty"` // +optional ClientCertSecretName string `json:"clientCertSecretName,omitempty"` }
EndpointEncryption configuration
func (*EndpointEncryption) DeepCopy ¶
func (in *EndpointEncryption) DeepCopy() *EndpointEncryption
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointEncryption.
func (*EndpointEncryption) DeepCopyInto ¶
func (in *EndpointEncryption) DeepCopyInto(out *EndpointEncryption)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ExposeSpec ¶
type ExposeSpec struct { // Type specifies different exposition methods for data grid Type ExposeType `json:"type"` // +optional NodePort int32 `json:"nodePort,omitempty"` // +optional Port int32 `json:"port,omitempty"` // The network hostname for your Infinispan cluster // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Route Hostname",xDescriptors={"urn:alm:descriptor:com.tectonic.ui:text", "urn:alm:descriptor:com.tectonic.ui:fieldDependency:expose.type:Route"} Host string `json:"host,omitempty"` // +optional Annotations map[string]string `json:"annotations,omitempty"` }
ExposeSpec describe how Infinispan will be exposed externally
func (*ExposeSpec) DeepCopy ¶
func (in *ExposeSpec) DeepCopy() *ExposeSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExposeSpec.
func (*ExposeSpec) DeepCopyInto ¶
func (in *ExposeSpec) DeepCopyInto(out *ExposeSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ExposeType ¶
type ExposeType string
ExposeType describe different exposition methods for Infinispan +kubebuilder:validation:Enum=NodePort;LoadBalancer;Route
type ExternalArtifactType ¶
type ExternalArtifactType string
ExternalArtifactType defines external artifact file type +kubebuilder:validation:Enum=file;zip;tgz
const ( ExternalArtifactTypeFile ExternalArtifactType = "file" ExternalArtifactTypeZip ExternalArtifactType = "zip" ExternalArtifactTypeTarGz ExternalArtifactType = "tgz" )
type ExternalDependencyType ¶
type ExternalDependencyType string
type GossipRouterHeartbeatSpec ¶
type GossipRouterHeartbeatSpec struct { // Enables the Gossip Router heartbeats // +optional Enabled *bool `json:"enabled,omitempty"` // Sends a heartbeat to the GossipRouter every interval milliseconds // +optional Interval *int64 `json:"interval,omitempty"` // Max time (millsecoonds) with no received message or heartbeat after which the connection to a GossipRouter is closed // +optional Timeout *int64 `json:"timeout,omitempty"` }
func (*GossipRouterHeartbeatSpec) DeepCopy ¶
func (in *GossipRouterHeartbeatSpec) DeepCopy() *GossipRouterHeartbeatSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GossipRouterHeartbeatSpec.
func (*GossipRouterHeartbeatSpec) DeepCopyInto ¶
func (in *GossipRouterHeartbeatSpec) DeepCopyInto(out *GossipRouterHeartbeatSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type HotRodRollingUpgradeStage ¶
type HotRodRollingUpgradeStage string
const ( HotRodRollingStageStart HotRodRollingUpgradeStage = "HotRodRollingStageStart" HotRodRollingStagePrepare HotRodRollingUpgradeStage = "HotRodRollingStagePrepare" HotRodRollingStageRedirect HotRodRollingUpgradeStage = "HotRodRollingStageRedirect" HotRodRollingStageSync HotRodRollingUpgradeStage = "HotRodRollingStageSync" HotRodRollingStageStatefulSetReplace HotRodRollingUpgradeStage = "HotRodRollingStageStatefulSetReplace" HotRodRollingStageCleanup HotRodRollingUpgradeStage = "HotRodRollingStageCleanup" )
type HotRodRollingUpgradeStatus ¶
type HotRodRollingUpgradeStatus struct { Stage HotRodRollingUpgradeStage `json:"stage,omitempty"` SourceStatefulSetName string `json:"SourceStatefulSetName,omitempty"` SourceVersion string `json:"SourceVersion,omitempty"` TargetStatefulSetName string `json:"TargetStatefulSetName,omitempty"` }
func (*HotRodRollingUpgradeStatus) DeepCopy ¶
func (in *HotRodRollingUpgradeStatus) DeepCopy() *HotRodRollingUpgradeStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HotRodRollingUpgradeStatus.
func (*HotRodRollingUpgradeStatus) DeepCopyInto ¶
func (in *HotRodRollingUpgradeStatus) DeepCopyInto(out *HotRodRollingUpgradeStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Infinispan ¶
type Infinispan struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec InfinispanSpec `json:"spec,omitempty"` Status InfinispanStatus `json:"status,omitempty"` }
Infinispan is the Schema for the infinispans API
func (*Infinispan) Affinity ¶
func (ispn *Infinispan) Affinity() *corev1.Affinity
func (*Infinispan) ApplyEndpointEncryptionSettings ¶
func (ispn *Infinispan) ApplyEndpointEncryptionSettings(servingCertsMode string)
ApplyEndpointEncryptionSettings compute the EndpointEncryption object
func (*Infinispan) ApplyMonitoringAnnotation ¶
func (ispn *Infinispan) ApplyMonitoringAnnotation()
func (*Infinispan) ApplyOperatorMeta ¶
func (i *Infinispan) ApplyOperatorMeta(defaultLabels, defaultAnnotations map[string]string)
func (*Infinispan) CrossSiteDiscoveryType ¶
func (ispn *Infinispan) CrossSiteDiscoveryType() DiscoverySiteType
func (*Infinispan) DeepCopy ¶
func (in *Infinispan) DeepCopy() *Infinispan
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Infinispan.
func (*Infinispan) DeepCopyInto ¶
func (in *Infinispan) DeepCopyInto(out *Infinispan)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Infinispan) DeepCopyObject ¶
func (in *Infinispan) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Infinispan) Default ¶
func (i *Infinispan) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*Infinispan) EnsureClusterStability ¶
func (ispn *Infinispan) EnsureClusterStability() error
func (*Infinispan) ExpectConditionStatus ¶
func (ispn *Infinispan) ExpectConditionStatus(expected map[ConditionType]metav1.ConditionStatus) error
func (*Infinispan) ExternalServiceLabels ¶
func (ispn *Infinispan) ExternalServiceLabels() map[string]string
ExternalServiceLabels returns all labels to be applied to the external service pods, including those defined by the user. It's values should never be used as a selector.
func (*Infinispan) ExternalServiceSelectorLabels ¶
func (ispn *Infinispan) ExternalServiceSelectorLabels() map[string]string
ExternalServiceSelectorLabels returns the minimum required labels to identify an external service. It does not contain any user defined labels. This should always be used for selectors so that updates to user labels don't break the controller logic.
func (*Infinispan) GenerateSecretName ¶
func (ispn *Infinispan) GenerateSecretName() string
func (*Infinispan) GetAdminSecretName ¶
func (ispn *Infinispan) GetAdminSecretName() string
GetAdminSecretName returns the admin secret name associated with a server
func (*Infinispan) GetAdminServiceName ¶
func (ispn *Infinispan) GetAdminServiceName() string
func (*Infinispan) GetAuthorizationRoles ¶
func (ispn *Infinispan) GetAuthorizationRoles() []AuthorizationRole
func (*Infinispan) GetCondition ¶
func (ispn *Infinispan) GetCondition(condition ConditionType) InfinispanCondition
GetCondition return the Status of the given condition or nil if condition is not present
func (*Infinispan) GetConfigListenerName ¶
func (ispn *Infinispan) GetConfigListenerName() string
func (*Infinispan) GetConfigName ¶
func (ispn *Infinispan) GetConfigName() string
GetConfigName returns the ConfigMap name for the cluster. It follows the StatefulSetName instead of the CRD name to support live migrations
func (*Infinispan) GetCredentialStoreSecretName ¶
func (ispn *Infinispan) GetCredentialStoreSecretName() string
func (*Infinispan) GetCrossSiteExposeType ¶
func (ispn *Infinispan) GetCrossSiteExposeType() CrossSiteExposeType
func (*Infinispan) GetEndpointScheme ¶
func (ispn *Infinispan) GetEndpointScheme() string
GetEndpointScheme returns the protocol scheme used by the Infinispan cluster
func (*Infinispan) GetExposeHost ¶
func (ispn *Infinispan) GetExposeHost() string
func (*Infinispan) GetExposeType ¶
func (ispn *Infinispan) GetExposeType() ExposeType
func (*Infinispan) GetGossipRouterDeploymentName ¶
func (ispn *Infinispan) GetGossipRouterDeploymentName() string
GetGossipRouterDeploymentName returns the Gossip Router deployment name
func (*Infinispan) GetInfinispanSecuritySecretName ¶
func (ispn *Infinispan) GetInfinispanSecuritySecretName() string
GetInfinispanSecuritySecretName returns the Secret containing the server certs and auth props
func (*Infinispan) GetJavaOptions ¶
func (ispn *Infinispan) GetJavaOptions() string
func (*Infinispan) GetKeystoreSecretName ¶
func (ispn *Infinispan) GetKeystoreSecretName() string
GetKeystoreSecretName ...
func (*Infinispan) GetLogCategoriesForConfig ¶
func (ispn *Infinispan) GetLogCategoriesForConfig() map[string]string
GetLogCategoriesForConfig return a map of log category for the Infinispan configuration
func (*Infinispan) GetLogPatternForConfig ¶
func (ispn *Infinispan) GetLogPatternForConfig() string
GetLogPatternForConfig returns the user configured log pattern or the DefaultLoggingPattern.
func (*Infinispan) GetOperatorUser ¶
func (ispn *Infinispan) GetOperatorUser() string
func (*Infinispan) GetPingServiceName ¶
func (ispn *Infinispan) GetPingServiceName() string
func (*Infinispan) GetRemoteSiteClusterName ¶
func (ispn *Infinispan) GetRemoteSiteClusterName(locationName string) string
func (*Infinispan) GetRemoteSiteLocations ¶
func (ispn *Infinispan) GetRemoteSiteLocations() (remoteLocations map[string]InfinispanSiteLocationSpec)
GetRemoteSiteLocations returns remote site locations
func (*Infinispan) GetRemoteSiteNamespace ¶
func (ispn *Infinispan) GetRemoteSiteNamespace(locationName string) string
func (*Infinispan) GetRemoteSiteRouteName ¶
func (ispn *Infinispan) GetRemoteSiteRouteName(locationName string) string
GetRemoteSiteRouteName return the remote Route name for cross-site replication
func (*Infinispan) GetRemoteSiteServiceFQN ¶
func (ispn *Infinispan) GetRemoteSiteServiceFQN(locationName string) string
func (*Infinispan) GetRemoteSiteServiceName ¶
func (ispn *Infinispan) GetRemoteSiteServiceName(locationName string) string
func (*Infinispan) GetSecretName ¶
func (ispn *Infinispan) GetSecretName() string
GetSecretName returns the secret name associated with a server
func (*Infinispan) GetServiceExternalName ¶
func (ispn *Infinispan) GetServiceExternalName() string
func (*Infinispan) GetServiceMonitorName ¶
func (ispn *Infinispan) GetServiceMonitorName() string
GetServiceMonitorName returns the ServiceMonitor name for the cluster
func (*Infinispan) GetServiceName ¶
func (ispn *Infinispan) GetServiceName() string
func (*Infinispan) GetSiteLocationsName ¶
func (ispn *Infinispan) GetSiteLocationsName() (locations []string)
GetSiteLocationsName returns all site locations (remote and local) name
func (*Infinispan) GetSiteRouteName ¶
func (ispn *Infinispan) GetSiteRouteName() string
GetSiteRouteName returns the local Route name for cross-site replication
func (*Infinispan) GetSiteRouterKeyStoreAlias ¶
func (ispn *Infinispan) GetSiteRouterKeyStoreAlias() string
GetSiteRouterKeyStoreAlias return the key alias in the keystore for the router TLS configuration
func (*Infinispan) GetSiteRouterKeyStoreFileName ¶
func (ispn *Infinispan) GetSiteRouterKeyStoreFileName() string
GetSiteRouterKeyStoreFileName returns the keystore filename for the router TLS configuration
func (*Infinispan) GetSiteRouterSecretName ¶
func (ispn *Infinispan) GetSiteRouterSecretName() string
GetSiteRouterSecretName returns the secret name for the router TLS keystore
func (*Infinispan) GetSiteServiceName ¶
func (ispn *Infinispan) GetSiteServiceName() string
func (*Infinispan) GetSiteTLSProtocol ¶
func (ispn *Infinispan) GetSiteTLSProtocol() string
GetSiteTLSProtocol returns the TLS protocol to be used to encrypt cross-site replication communication
func (*Infinispan) GetSiteTransportKeyStoreAlias ¶
func (ispn *Infinispan) GetSiteTransportKeyStoreAlias() string
GetSiteTransportKeyStoreAlias return the key alias in the keystore for the transport TLS configuration
func (*Infinispan) GetSiteTransportKeyStoreFileName ¶
func (ispn *Infinispan) GetSiteTransportKeyStoreFileName() string
GetSiteTransportKeyStoreFileName returns the keystore filename for the transport TLS configuration
func (*Infinispan) GetSiteTransportSecretName ¶
func (ispn *Infinispan) GetSiteTransportSecretName() string
GetSiteTransportSecretName returns the secret name for the transport TLS keystore
func (*Infinispan) GetSiteTrustStoreFileName ¶
func (ispn *Infinispan) GetSiteTrustStoreFileName() string
GetSiteTrustStoreFileName returns the truststore filename for the transport and router TLS configuration
func (*Infinispan) GetSiteTrustoreSecretName ¶
func (ispn *Infinispan) GetSiteTrustoreSecretName() string
GetSiteTrustoreSecretName returns the secret name with the truststore for the transport and router TLS keystore
func (*Infinispan) GetStatefulSetName ¶
func (ispn *Infinispan) GetStatefulSetName() string
GetStatefulSetName returns the name of the StatefulSet associated with the CRD. After one or more live migrations, the name can change
func (*Infinispan) GetTruststoreSecretName ¶
func (ispn *Infinispan) GetTruststoreSecretName() string
func (*Infinispan) GossipRouterAnnotations ¶
func (ispn *Infinispan) GossipRouterAnnotations() map[string]string
GossipRouterAnnotations returns all annotations to be applied to the GossipRouter pod. It's values
func (*Infinispan) GossipRouterPodLabels ¶
func (ispn *Infinispan) GossipRouterPodLabels() map[string]string
GossipRouterPodLabels returns all labels to be applied to the GossipRouter pod. It's values should never be used as a selector.
func (*Infinispan) GossipRouterPodSelectorLabels ¶
func (ispn *Infinispan) GossipRouterPodSelectorLabels() map[string]string
GossipRouterPodSelectorLabels returns the minimum required labels to identify a Gossip Router Pod. It does not contain any user defined labels. This should always be used for selectors so that updates to user labels don't break the controller logic.
func (*Infinispan) GracefulShutdownUpgrades ¶
func (ispn *Infinispan) GracefulShutdownUpgrades() bool
func (*Infinispan) HasCondition ¶
func (ispn *Infinispan) HasCondition(condition ConditionType) bool
HasCondition return true if a given condition exists
func (*Infinispan) HasDependenciesVolume ¶
func (ispn *Infinispan) HasDependenciesVolume() bool
HasDependenciesVolume true if custom dependencies are defined via PersistenceVolumeClaim
func (*Infinispan) HasExternalArtifacts ¶
func (ispn *Infinispan) HasExternalArtifacts() bool
HasExternalArtifacts true if external artifacts are defined
func (*Infinispan) HasSites ¶
func (ispn *Infinispan) HasSites() bool
func (*Infinispan) HotRodRollingUpgrades ¶
func (ispn *Infinispan) HotRodRollingUpgrades() bool
func (*Infinispan) ImageName ¶
func (ispn *Infinispan) ImageName() string
func (*Infinispan) ImageType ¶
func (ispn *Infinispan) ImageType() ImageType
func (*Infinispan) InitServiceContainer ¶
func (ispn *Infinispan) InitServiceContainer()
func (*Infinispan) IsAuthenticationEnabled ¶
func (ispn *Infinispan) IsAuthenticationEnabled() bool
func (*Infinispan) IsAuthorizationEnabled ¶
func (ispn *Infinispan) IsAuthorizationEnabled() bool
func (*Infinispan) IsCache ¶
func (ispn *Infinispan) IsCache() bool
func (*Infinispan) IsClientCertEnabled ¶
func (ispn *Infinispan) IsClientCertEnabled() bool
func (*Infinispan) IsConditionFalse ¶
func (ispn *Infinispan) IsConditionFalse(name ConditionType) bool
func (*Infinispan) IsConditionTrue ¶
func (ispn *Infinispan) IsConditionTrue(name ConditionType) bool
func (*Infinispan) IsConfigListenerEnabled ¶
func (ispn *Infinispan) IsConfigListenerEnabled() bool
func (*Infinispan) IsCredentialStoreSecretDefined ¶
func (ispn *Infinispan) IsCredentialStoreSecretDefined() bool
func (*Infinispan) IsDataGrid ¶
func (ispn *Infinispan) IsDataGrid() bool
func (*Infinispan) IsEncryptionCertFromService ¶
func (ispn *Infinispan) IsEncryptionCertFromService() bool
IsEncryptionCertFromService returns true if encryption certificates comes from a cluster service
func (*Infinispan) IsEncryptionCertSourceDefined ¶
func (ispn *Infinispan) IsEncryptionCertSourceDefined() bool
IsEncryptionCertSourceDefined returns true if encryption certificates source is defined
func (*Infinispan) IsEncryptionEnabled ¶
func (ispn *Infinispan) IsEncryptionEnabled() bool
func (*Infinispan) IsEphemeralStorage ¶
func (ispn *Infinispan) IsEphemeralStorage() bool
IsEphemeralStorage returns the value of ephemeralStorage if it is defined.
func (*Infinispan) IsGeneratedSecret ¶
func (ispn *Infinispan) IsGeneratedSecret() bool
IsGeneratedSecret verifies that the Secret should be generated by the controller
func (*Infinispan) IsGossipRouterEnabled ¶
func (ispn *Infinispan) IsGossipRouterEnabled() bool
func (*Infinispan) IsHotRodUpgrade ¶
func (ispn *Infinispan) IsHotRodUpgrade() bool
func (*Infinispan) IsJmxExposed ¶
func (ispn *Infinispan) IsJmxExposed() bool
func (*Infinispan) IsServiceMonitorEnabled ¶
func (ispn *Infinispan) IsServiceMonitorEnabled() bool
IsServiceMonitorEnabled validates that "infinispan.org/monitoring":true annotation defines or not
func (*Infinispan) IsSiteTLSEnabled ¶
func (ispn *Infinispan) IsSiteTLSEnabled() bool
IsSiteTLSEnabled returns true if the TLS is enabled for cross-site replication communicate
func (*Infinispan) IsUpgradeCondition ¶
func (ispn *Infinispan) IsUpgradeCondition() bool
func (*Infinispan) IsUpgradeNeeded ¶
func (ispn *Infinispan) IsUpgradeNeeded(logger logr.Logger) bool
func (*Infinispan) IsWellFormed ¶
func (ispn *Infinispan) IsWellFormed() bool
IsWellFormed return true if cluster is well formed
func (*Infinispan) LaunchGossipRouterEnabled ¶
func (ispn *Infinispan) LaunchGossipRouterEnabled() bool
func (*Infinispan) NotClusterFormed ¶
func (ispn *Infinispan) NotClusterFormed(pods, replicas int) bool
NotClusterFormed return true is cluster is not well formed
func (*Infinispan) PodAnnotations ¶
func (ispn *Infinispan) PodAnnotations() map[string]string
func (*Infinispan) PodLabels ¶
func (ispn *Infinispan) PodLabels() map[string]string
PodLabels returns all labels to be applied to Infinispan pods, including those defined by the user. It's values should never be used as a selector.
func (*Infinispan) PodSelectorLabels ¶
func (ispn *Infinispan) PodSelectorLabels() map[string]string
PodSelectorLabels returns the minimum required labels to identify an Infinispan Pod. It does not contain any user defined labels. This should always be used for selectors so that updates to user labels don't break the controller logic.
func (*Infinispan) PriorityClassName ¶
func (ispn *Infinispan) PriorityClassName() string
func (*Infinispan) RemoveCondition ¶
func (ispn *Infinispan) RemoveCondition(condition ConditionType) bool
RemoveCondition remove condition from Status
func (*Infinispan) ServiceAnnotations ¶
func (ispn *Infinispan) ServiceAnnotations() map[string]string
func (*Infinispan) ServiceLabels ¶
func (ispn *Infinispan) ServiceLabels(app string) map[string]string
func (*Infinispan) ServiceMonitorTargetLabels ¶
func (ispn *Infinispan) ServiceMonitorTargetLabels() []string
func (*Infinispan) ServiceSelectorLabels ¶
func (ispn *Infinispan) ServiceSelectorLabels() map[string]string
func (*Infinispan) SetCondition ¶
func (ispn *Infinispan) SetCondition(condition ConditionType, status metav1.ConditionStatus, message string) bool
SetCondition set condition to status
func (*Infinispan) SetConditions ¶
func (ispn *Infinispan) SetConditions(conds ...InfinispanCondition) bool
SetConditions set provided conditions to status
func (*Infinispan) SetupWebhookWithManager ¶
func (i *Infinispan) SetupWebhookWithManager(mgr ctrl.Manager) (err error)
func (*Infinispan) StorageClassName ¶
func (ispn *Infinispan) StorageClassName() string
StorageClassName returns a storage class name if it defined
func (*Infinispan) StorageSize ¶
func (ispn *Infinispan) StorageSize() string
StorageSize returns persistence storage size if it defined
func (*Infinispan) Tolerations ¶
func (ispn *Infinispan) Tolerations() []corev1.Toleration
func (*Infinispan) TopologySpreadConstraints ¶
func (ispn *Infinispan) TopologySpreadConstraints() []corev1.TopologySpreadConstraint
func (*Infinispan) UserConfigDefined ¶
func (ispn *Infinispan) UserConfigDefined() bool
func (*Infinispan) ValidateCreate ¶
func (i *Infinispan) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*Infinispan) ValidateDelete ¶
func (i *Infinispan) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*Infinispan) ValidateUpdate ¶
func (i *Infinispan) ValidateUpdate(oldRuntimeObj runtime.Object) error
ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
type InfinispanCloudEvents ¶
type InfinispanCloudEvents struct { // BootstrapServers is comma separated list of boostrap server:port addresses BootstrapServers string `json:"bootstrapServers"` // Acks configuration for the producer ack-value // +optional Acks string `json:"acks,omitempty"` // CacheEntriesTopic is the name of the topic on which events will be published // +optional CacheEntriesTopic string `json:"cacheEntriesTopic,omitempty"` }
InfinispanCloudEvents describes how Infinispan is connected with Cloud Event, see Kafka docs for more info
func (*InfinispanCloudEvents) DeepCopy ¶
func (in *InfinispanCloudEvents) DeepCopy() *InfinispanCloudEvents
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanCloudEvents.
func (*InfinispanCloudEvents) DeepCopyInto ¶
func (in *InfinispanCloudEvents) DeepCopyInto(out *InfinispanCloudEvents)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InfinispanCondition ¶
type InfinispanCondition struct { // Type is the type of the condition. Type ConditionType `json:"type"` // Status is the status of the condition. Status metav1.ConditionStatus `json:"status"` // Human-readable message indicating details about last transition. // +optional Message string `json:"message,omitempty"` }
InfinispanCondition define a condition of the cluster
func (*InfinispanCondition) DeepCopy ¶
func (in *InfinispanCondition) DeepCopy() *InfinispanCondition
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanCondition.
func (*InfinispanCondition) DeepCopyInto ¶
func (in *InfinispanCondition) DeepCopyInto(out *InfinispanCondition)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InfinispanContainerSpec ¶
type InfinispanContainerSpec struct { // +optional CliExtraJvmOpts string `json:"cliExtraJvmOpts,omitempty"` // +optional ExtraJvmOpts string `json:"extraJvmOpts,omitempty"` // +optional RouterExtraJvmOpts string `json:"routerExtraJvmOpts,omitempty"` // +optional Memory string `json:"memory,omitempty"` // +optional CPU string `json:"cpu,omitempty"` }
InfinispanContainerSpec specify resource requirements per container
func (*InfinispanContainerSpec) DeepCopy ¶
func (in *InfinispanContainerSpec) DeepCopy() *InfinispanContainerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanContainerSpec.
func (*InfinispanContainerSpec) DeepCopyInto ¶
func (in *InfinispanContainerSpec) DeepCopyInto(out *InfinispanContainerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*InfinispanContainerSpec) GetCpuResources ¶
func (spec *InfinispanContainerSpec) GetCpuResources() (requests resource.Quantity, limits resource.Quantity, err error)
GetCpuResources returns the CPU request and limit values to be used by pods
func (*InfinispanContainerSpec) GetMemoryResources ¶
func (spec *InfinispanContainerSpec) GetMemoryResources() (requests resource.Quantity, limits resource.Quantity, err error)
GetMemoryResources returns the Memory request and limit values to be used by pods
type InfinispanExternalArtifacts ¶
type InfinispanExternalArtifacts struct { // +optional // +kubebuilder:validation:Pattern=`^$|^(https?|ftp)://[-a-zA-Z0-9+&@#/%?=~_|!:,.;]*[-a-zA-Z0-9+&@#/%=~_|]` // URL of the file you want to download. Url string `json:"url"` // +optional // +kubebuilder:validation:Pattern=`^$|^([-_a-zA-Z0-9.]+):([-_a-zA-Z0-9.]+):([-_a-zA-Z0-9.]+)(?::([-_a-zA-Z0-9.]+))?$` // Coordinates of a maven artifact in the `groupId:artifactId:version` format, for example `org.postgresql:postgresql:42.3.1`. Maven string `json:"maven"` // +optional // Deprecated, no longer has any effect. Specifies the type of file you want to download. If not specified, the file type is automatically determined from the extension. Type ExternalArtifactType `json:"type,omitempty"` // +optional // +kubebuilder:validation:Pattern=`^(sha1|sha224|sha256|sha384|sha512|md5):[a-z0-9]+` // Checksum that you can use to verify downloaded files. Hash string `json:"hash,omitempty"` }
func (*InfinispanExternalArtifacts) DeepCopy ¶
func (in *InfinispanExternalArtifacts) DeepCopy() *InfinispanExternalArtifacts
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanExternalArtifacts.
func (*InfinispanExternalArtifacts) DeepCopyInto ¶
func (in *InfinispanExternalArtifacts) DeepCopyInto(out *InfinispanExternalArtifacts)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InfinispanExternalDependencies ¶
type InfinispanExternalDependencies struct { // The Persistent Volume Claim that holds custom libraries // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Persistent Volume Claim Name",xDescriptors="urn:alm:descriptor:io.kubernetes:PersistentVolumeClaim" VolumeClaimName string `json:"volumeClaimName,omitempty"` // +optional Artifacts []InfinispanExternalArtifacts `json:"artifacts,omitempty"` // +optional InitContainer InitDependenciesContainerSpec `json:"initContainer,omitempty"` }
InfinispanExternalDependencies describes all the external dependencies used by the Infinispan cluster: i.e. lib folder with custom jar, maven artifact, images ...
func (*InfinispanExternalDependencies) DeepCopy ¶
func (in *InfinispanExternalDependencies) DeepCopy() *InfinispanExternalDependencies
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanExternalDependencies.
func (*InfinispanExternalDependencies) DeepCopyInto ¶
func (in *InfinispanExternalDependencies) DeepCopyInto(out *InfinispanExternalDependencies)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InfinispanList ¶
type InfinispanList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Infinispan `json:"items"` }
InfinispanList contains a list of Infinispan
func (*InfinispanList) DeepCopy ¶
func (in *InfinispanList) DeepCopy() *InfinispanList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanList.
func (*InfinispanList) DeepCopyInto ¶
func (in *InfinispanList) DeepCopyInto(out *InfinispanList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*InfinispanList) DeepCopyObject ¶
func (in *InfinispanList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type InfinispanLoggingSpec ¶
type InfinispanLoggingSpec struct { // A custom pattern to be applied to the Log4j STDOUT output // +optional Pattern string `json:"pattern,omitempty"` Categories map[string]LoggingLevelType `json:"categories,omitempty"` }
func (*InfinispanLoggingSpec) DeepCopy ¶
func (in *InfinispanLoggingSpec) DeepCopy() *InfinispanLoggingSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanLoggingSpec.
func (*InfinispanLoggingSpec) DeepCopyInto ¶
func (in *InfinispanLoggingSpec) DeepCopyInto(out *InfinispanLoggingSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InfinispanSecurity ¶
type InfinispanSecurity struct { // +optional Authorization *Authorization `json:"authorization,omitempty"` // A secret that contains CredentialStore alias and password combinations // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="CredentialStore Secret",xDescriptors={"urn:alm:descriptor:io.kubernetes:Secret"} CredentialStoreSecretName string `json:"credentialStoreSecretName,omitempty"` // Enable or disable user authentication // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Toggle Authentication",xDescriptors="urn:alm:descriptor:com.tectonic.ui:booleanSwitch" EndpointAuthentication *bool `json:"endpointAuthentication,omitempty"` // The secret that contains user credentials. // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Authentication Secret",xDescriptors={"urn:alm:descriptor:io.kubernetes:Secret", "urn:alm:descriptor:com.tectonic.ui:fieldDependency:security.endpointAuthentication:true"} EndpointSecretName string `json:"endpointSecretName,omitempty"` // +optional EndpointEncryption *EndpointEncryption `json:"endpointEncryption,omitempty"` }
InfinispanSecurity info for the user application connection
func (*InfinispanSecurity) DeepCopy ¶
func (in *InfinispanSecurity) DeepCopy() *InfinispanSecurity
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanSecurity.
func (*InfinispanSecurity) DeepCopyInto ¶
func (in *InfinispanSecurity) DeepCopyInto(out *InfinispanSecurity)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InfinispanServiceContainerSpec ¶
type InfinispanServiceContainerSpec struct { // The amount of storage for the persistent volume claim. // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Storage Size",xDescriptors="urn:alm:descriptor:text" Storage *string `json:"storage,omitempty"` // Enable/disable container ephemeral storage // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Container Ephemeral Storage",xDescriptors="urn:alm:descriptor:com.tectonic.ui:booleanSwitch" EphemeralStorage bool `json:"ephemeralStorage,omitempty"` // The storage class object for persistent volume claims // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Storage Class Name",xDescriptors={"urn:alm:descriptor:io.kubernetes:StorageClass", "urn:alm:descriptor:com.tectonic.ui:fieldDependency:service.container.ephemeralStorage:false"} StorageClassName string `json:"storageClassName,omitempty"` // Periodic probe of container liveness. // Container will be restarted if the probe fails. // +optional LivenessProbe ContainerProbeSpec `json:"livenessProbe,omitempty"` // Periodic probe of container service readiness. // Container will be removed from service endpoints if the probe fails. // +optional ReadinessProbe ContainerProbeSpec `json:"readinessProbe,omitempty"` // StartupProbe indicates that the Pod has successfully initialized. // If specified, no other probes are executed until this completes successfully. // If this probe fails, the Pod will be restarted, just as if the livenessProbe failed. // This can be used to provide different probe parameters at the beginning of a Pod's lifecycle, // when it might take a long time to load data or warm a cache, than during steady-state operation. // +optional StartupProbe ContainerProbeSpec `json:"startupProbe,omitempty"` }
InfinispanServiceContainerSpec resource requirements specific for service
func (*InfinispanServiceContainerSpec) DeepCopy ¶
func (in *InfinispanServiceContainerSpec) DeepCopy() *InfinispanServiceContainerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanServiceContainerSpec.
func (*InfinispanServiceContainerSpec) DeepCopyInto ¶
func (in *InfinispanServiceContainerSpec) DeepCopyInto(out *InfinispanServiceContainerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InfinispanServiceSpec ¶
type InfinispanServiceSpec struct { // The service type // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Service Type",xDescriptors={"urn:alm:descriptor:com.tectonic.ui:select:Cache", "urn:alm:descriptor:com.tectonic.ui:select:DataGrid"} Type ServiceType `json:"type,omitempty"` // +optional Container *InfinispanServiceContainerSpec `json:"container,omitempty"` // +optional Sites *InfinispanSitesSpec `json:"sites,omitempty"` // Cache replication factor, or number of copies for each entry. // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Number of Owners",xDescriptors="urn:alm:descriptor:com.tectonic.ui:number" ReplicationFactor int32 `json:"replicationFactor,omitempty"` }
InfinispanServiceSpec specify configuration for specific service
func (*InfinispanServiceSpec) DeepCopy ¶
func (in *InfinispanServiceSpec) DeepCopy() *InfinispanServiceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanServiceSpec.
func (*InfinispanServiceSpec) DeepCopyInto ¶
func (in *InfinispanServiceSpec) DeepCopyInto(out *InfinispanServiceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InfinispanSiteLocationSpec ¶
type InfinispanSiteLocationSpec struct { Name string `json:"name"` // +optional Namespace string `json:"namespace,omitempty"` // +optional ClusterName string `json:"clusterName,omitempty"` // Deprecated and to be removed on subsequent release. Use .URL with infinispan+xsite schema instead. // +optional Host *string `json:"host,omitempty"` // Deprecated and to be removed on subsequent release. Use .URL with infinispan+xsite schema instead. // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Node Port",xDescriptors={"urn:alm:descriptor:com.tectonic.ui:number", "urn:alm:descriptor:com.tectonic.ui:fieldDependency:service.sites.local.expose.type:NodePort"} Port *int32 `json:"port,omitempty"` // +kubebuilder:validation:Pattern=`(^(kubernetes|minikube|openshift):\/\/(([a-z0-9]|[a-z0-9][a-z0-9\-]*[a-z0-9])\.)*([a-z0-9]|[a-z0-9][a-z0-9\-]*[a-z0-9])*(:[0-9]+)+$)|(^(infinispan\+xsite):\/\/(([a-z0-9]|[a-z0-9][a-z0-9\-]*[a-z0-9])\.)*([a-z0-9]|[a-z0-9][a-z0-9\-]*[a-z0-9])*(:[0-9]+)*$)` // +optional URL string `json:"url,omitempty"` // The access secret that allows backups to a remote site // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Backup Location Secret",xDescriptors="urn:alm:descriptor:io.kubernetes:Secret" SecretName string `json:"secretName,omitempty"` }
func (*InfinispanSiteLocationSpec) DeepCopy ¶
func (in *InfinispanSiteLocationSpec) DeepCopy() *InfinispanSiteLocationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanSiteLocationSpec.
func (*InfinispanSiteLocationSpec) DeepCopyInto ¶
func (in *InfinispanSiteLocationSpec) DeepCopyInto(out *InfinispanSiteLocationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InfinispanSitesLocalSpec ¶
type InfinispanSitesLocalSpec struct { Name string `json:"name"` Expose CrossSiteExposeSpec `json:"expose"` // +optional MaxRelayNodes int32 `json:"maxRelayNodes,omitempty"` // +optional Encryption *EncryptionSiteSpec `json:"encryption,omitempty"` // +optional Discovery *DiscoverySiteSpec `json:"discovery,omitempty"` }
InfinispanSitesLocalSpec enables cross-site replication
func (*InfinispanSitesLocalSpec) DeepCopy ¶
func (in *InfinispanSitesLocalSpec) DeepCopy() *InfinispanSitesLocalSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanSitesLocalSpec.
func (*InfinispanSitesLocalSpec) DeepCopyInto ¶
func (in *InfinispanSitesLocalSpec) DeepCopyInto(out *InfinispanSitesLocalSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InfinispanSitesSpec ¶
type InfinispanSitesSpec struct { Local InfinispanSitesLocalSpec `json:"local"` Locations []InfinispanSiteLocationSpec `json:"locations,omitempty"` }
func (*InfinispanSitesSpec) DeepCopy ¶
func (in *InfinispanSitesSpec) DeepCopy() *InfinispanSitesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanSitesSpec.
func (*InfinispanSitesSpec) DeepCopyInto ¶
func (in *InfinispanSitesSpec) DeepCopyInto(out *InfinispanSitesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InfinispanSpec ¶
type InfinispanSpec struct { // The number of nodes in the Infinispan cluster. // +operator-sdk:csv:customresourcedefinitions:type=spec,xDescriptors="urn:alm:descriptor:com.tectonic.ui:podCount" Replicas int32 `json:"replicas"` // The semantic version of the Infinispan cluster. // +optional // +kubebuilder:validation:Pattern=`^$|^(0|[1-9]\d*)\.(0|[1-9]\d*)\.(0|[1-9]\d*)(?:-((?:0|[1-9]\d*|\d*[a-zA-Z-][0-9a-zA-Z-]*)(?:\.(?:0|[1-9]\d*|\d*[a-zA-Z-][0-9a-zA-Z-]*))*))?(?:\+([0-9a-zA-Z-]+(?:\.[0-9a-zA-Z-]+)*))?$` Version string `json:"version"` // +optional Image *string `json:"image,omitempty"` // +optional Security InfinispanSecurity `json:"security,omitempty"` // +optional Container InfinispanContainerSpec `json:"container,omitempty"` // +optional Service InfinispanServiceSpec `json:"service,omitempty"` // +optional Logging *InfinispanLoggingSpec `json:"logging,omitempty"` // +optional Expose *ExposeSpec `json:"expose,omitempty"` // +optional Autoscale *Autoscale `json:"autoscale,omitempty"` // +optional // Deprecated. Use scheduling.affinity instead Affinity *corev1.Affinity `json:"affinity,omitempty"` // +optional // Deprecated. Has no effect starting with Infinispan 15.0.0 servers CloudEvents *InfinispanCloudEvents `json:"cloudEvents,omitempty"` // External dependencies needed by the Infinispan cluster // +optional Dependencies *InfinispanExternalDependencies `json:"dependencies,omitempty"` // +optional ConfigMapName string `json:"configMapName,omitempty"` // Strategy to use when doing upgrades Upgrades *InfinispanUpgradesSpec `json:"upgrades,omitempty"` // +optional ConfigListener *ConfigListenerSpec `json:"configListener,omitempty"` // +optional Jmx *JmxSpec `json:"jmx,omitempty"` // +optional Scheduling *SchedulingSpec `json:"scheduling,omitempty"` }
InfinispanSpec defines the desired state of Infinispan
func (*InfinispanSpec) DeepCopy ¶
func (in *InfinispanSpec) DeepCopy() *InfinispanSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanSpec.
func (*InfinispanSpec) DeepCopyInto ¶
func (in *InfinispanSpec) DeepCopyInto(out *InfinispanSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InfinispanStatus ¶
type InfinispanStatus struct { // +optional Conditions []InfinispanCondition `json:"conditions,omitempty"` // +optional StatefulSetName string `json:"statefulSetName,omitempty"` // +optional Security *InfinispanSecurity `json:"security,omitempty"` // +optional Replicas *int32 `json:"replicas,omitempty"` // +optional ReplicasWantedAtRestart int32 `json:"replicasWantedAtRestart,omitempty"` // The Pod's currently in the cluster // +optional // +operator-sdk:csv:customresourcedefinitions:type=status,displayName="Pod Status",xDescriptors="urn:alm:descriptor:com.tectonic.ui:podStatuses" PodStatus DeploymentStatus `json:"podStatus,omitempty"` // Infinispan Console URL // +optional // +operator-sdk:csv:customresourcedefinitions:type=status,displayName="Infinispan Console URL",xDescriptors="urn:alm:descriptor:org.w3:link" ConsoleUrl *string `json:"consoleUrl,omitempty"` // +optional HotRodRollingUpgradeStatus *HotRodRollingUpgradeStatus `json:"hotRodRollingUpgradeStatus,omitempty"` // The Operand status // +optional // +operator-sdk:csv:customresourcedefinitions:type=status,displayName="Operand Status" Operand OperandStatus `json:"operand,omitempty"` // The Operator status // +optional // +operator-sdk:csv:customresourcedefinitions:type=status,displayName="Operator Status" Operator Operator `json:"operator,omitempty"` // The Selector used to identify Infinispan cluster pods // +optional Selector string `json:"selector"` }
InfinispanStatus defines the observed state of Infinispan
func (*InfinispanStatus) DeepCopy ¶
func (in *InfinispanStatus) DeepCopy() *InfinispanStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanStatus.
func (*InfinispanStatus) DeepCopyInto ¶
func (in *InfinispanStatus) DeepCopyInto(out *InfinispanStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InfinispanUpgradesSpec ¶
type InfinispanUpgradesSpec struct {
Type UpgradeType `json:"type"`
}
InfinispanUpgradesSpec defines the Infinispan upgrade strategy
func (*InfinispanUpgradesSpec) DeepCopy ¶
func (in *InfinispanUpgradesSpec) DeepCopy() *InfinispanUpgradesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InfinispanUpgradesSpec.
func (*InfinispanUpgradesSpec) DeepCopyInto ¶
func (in *InfinispanUpgradesSpec) DeepCopyInto(out *InfinispanUpgradesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InitDependenciesContainerSpec ¶
type InitDependenciesContainerSpec struct { // +optional // Memory in limit:request format Memory string `json:"memory,omitempty"` // +optional // CPU in limit:request format CPU string `json:"cpu,omitempty"` }
InitDependenciesContainerSpec describes the configuration options for the dependency download init container
func (*InitDependenciesContainerSpec) CpuResources ¶
func (spec *InitDependenciesContainerSpec) CpuResources() (requests resource.Quantity, limits resource.Quantity, err error)
CpuResources returns the CPU request and limit values to be used by by External Dependencies Downloader Init container
func (*InitDependenciesContainerSpec) DeepCopy ¶
func (in *InitDependenciesContainerSpec) DeepCopy() *InitDependenciesContainerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InitDependenciesContainerSpec.
func (*InitDependenciesContainerSpec) DeepCopyInto ¶
func (in *InitDependenciesContainerSpec) DeepCopyInto(out *InitDependenciesContainerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*InitDependenciesContainerSpec) MemoryResources ¶
func (spec *InitDependenciesContainerSpec) MemoryResources() (requests resource.Quantity, limits resource.Quantity, err error)
MemoryResources returns the Memory request and limit values to be used by External Dependencies Downloader Init container
type JmxSpec ¶
type JmxSpec struct { // If true, a JMX endpoint is exposed on the admin service // +optional // +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Toggle Jmx",xDescriptors="urn:alm:descriptor:com.tectonic.ui:booleanSwitch" Enabled bool `json:"enabled,omitempty"` }
func (*JmxSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JmxSpec.
func (*JmxSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LoggingLevelType ¶
type LoggingLevelType string
LoggingLevelType describe the logging level for selected category +kubebuilder:validation:Enum=trace;debug;info;warn;error
const ( LoggingLevelTrace LoggingLevelType = "trace" LoggingLevelDebug LoggingLevelType = "debug" LoggingLevelInfo LoggingLevelType = "info" LoggingLevelWarn LoggingLevelType = "warn" LoggingLevelError LoggingLevelType = "error" )
type OperandPhase ¶
type OperandPhase string
const ( // OperandPhasePending indicates that the configured Operand is currently being provisioned and the cluster is not WellFormed OperandPhasePending OperandPhase = "Pending" // OperandPhaseRunning indicates that the Operand has been provisioned and is WellFormed OperandPhaseRunning OperandPhase = "Running" )
type OperandStatus ¶
type OperandStatus struct { // Whether the Operand installed/pending is using a custom image // +optional CustomImage bool `json:"customImage,omitempty"` // Whether the Operand has been deprecated and is subject for removal in a subsequent release // +optional Deprecated bool `json:"deprecated,omitempty"` // The Image being used by the Operand currently being reconciled // +optional Image string `json:"image,omitempty"` // The most recently observed Phase of the Operand deployment // +optional Phase OperandPhase `json:"phase,omitempty"` // The Operand version to be reconciled // +optional Version string `json:"version,omitempty"` }
func (*OperandStatus) DeepCopy ¶
func (in *OperandStatus) DeepCopy() *OperandStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OperandStatus.
func (*OperandStatus) DeepCopyInto ¶
func (in *OperandStatus) DeepCopyInto(out *OperandStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Operator ¶
type Operator struct { // The name of the pod reconciling this resource // +optional Pod string `json:"pod,omitempty"` }
func (*Operator) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Operator.
func (*Operator) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SchedulingSpec ¶
type SchedulingSpec struct { // +optional Affinity *corev1.Affinity `json:"affinity,omitempty"` // +optional PriorityClassName string `json:"PriorityClassName,omitempty"` // +optional Tolerations []corev1.Toleration `json:"tolerations,omitempty"` // +optional TopologySpreadConstraints []corev1.TopologySpreadConstraint `json:"topologySpreadConstraints,omitempty"` }
func (*SchedulingSpec) DeepCopy ¶
func (in *SchedulingSpec) DeepCopy() *SchedulingSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchedulingSpec.
func (*SchedulingSpec) DeepCopyInto ¶
func (in *SchedulingSpec) DeepCopyInto(out *SchedulingSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceType ¶
type ServiceType string
+kubebuilder:validation:Enum=DataGrid;Cache
const ( // Deploys Infinispan to act like a cache. This means: // Caches are only used for volatile data. // No support for data persistence. // Cache definitions can still be permanent, but PV size is not configurable. // A default cache is created by default, // Additional caches can be created, but only as copies of default cache. ServiceTypeCache ServiceType = "Cache" // Deploys Infinispan to act like a data grid. // More flexibility and more configuration options are available: // Cross-site replication, store cached data in persistence store...etc. ServiceTypeDataGrid ServiceType = "DataGrid" )
type TLSProtocol ¶
type TLSProtocol string
TLSProtocol specifies the TLS protocol +kubebuilder:validation:Enum=TLSv1.2;TLSv1.3
const ( TLSVersion12 TLSProtocol = "TLSv1.2" TLSVersion13 TLSProtocol = "TLSv1.3" )
Note: TLS v1.1 and older are not consider secure anymore
type UpgradeType ¶
type UpgradeType string
const ( // UpgradeTypeHotRodRolling Upgrade with no downtime and data copied over Hot Rod UpgradeTypeHotRodRolling UpgradeType = "HotRodRolling" // UpgradeTypeShutdown Upgrade requires downtime and data persisted in cache stores UpgradeTypeShutdown UpgradeType = "Shutdown" )