Documentation ¶
Overview ¶
Package v1 contains API Schema definitions for the infinispan v1 API group +k8s:deepcopy-gen=package,register +groupName=infinispan.org
Package v1 contains API Schema definitions for the infinispan v1 API group +k8s:deepcopy-gen=package,register +groupName=infinispan.org
Index ¶
- Constants
- Variables
- func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition
- func Resource(resource string) schema.GroupResource
- type Authorization
- type AuthorizationRole
- type Autoscale
- type CertificateSourceType
- type ClientCertType
- type ConditionType
- type CrossSiteExposeSpec
- type CrossSiteExposeType
- type EndpointEncryption
- type ExposeSpec
- type ExposeType
- type ImageType
- type Infinispan
- func (ispn *Infinispan) AddLabelsForPods(uMap map[string]string)
- func (ispn *Infinispan) AddLabelsForServices(uMap map[string]string)
- func (ispn *Infinispan) AddOperatorLabelsForPods(uMap map[string]string)
- func (ispn *Infinispan) AddOperatorLabelsForServices(uMap map[string]string)
- func (ispn *Infinispan) ApplyDefaults()
- func (ispn *Infinispan) ApplyEndpointEncryptionSettings(servingCertsMode string, reqLogger logr.Logger)
- func (ispn *Infinispan) ApplyMonitoringAnnotation()
- func (ispn *Infinispan) ApplyOperatorLabels() error
- func (in *Infinispan) DeepCopy() *Infinispan
- func (in *Infinispan) DeepCopyInto(out *Infinispan)
- func (in *Infinispan) DeepCopyObject() runtime.Object
- func (ispn *Infinispan) EnsureClusterStability() error
- func (ispn *Infinispan) ExpectConditionStatus(expected map[ConditionType]metav1.ConditionStatus) error
- func (ispn *Infinispan) GetAdminSecretName() string
- func (ispn *Infinispan) GetAuthorizationRoles() []AuthorizationRole
- func (ispn *Infinispan) GetCondition(condition ConditionType) InfinispanCondition
- func (ispn *Infinispan) GetConfigName() string
- func (ispn *Infinispan) GetEndpointScheme() string
- func (ispn *Infinispan) GetExposeType() ExposeType
- func (ispn *Infinispan) GetJavaOptions() string
- func (ispn *Infinispan) GetKeystoreSecretName() string
- func (ispn *Infinispan) GetLogCategoriesForConfig() map[string]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) 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) GetSiteServiceName() string
- func (ispn *Infinispan) GetTruststoreSecretName() string
- func (ispn *Infinispan) HasCustomLibraries() bool
- func (ispn *Infinispan) HasSites() bool
- func (ispn *Infinispan) ImageName() string
- func (ispn *Infinispan) ImageType() ImageType
- func (ispn *Infinispan) IsAuthenticationEnabled() bool
- func (ispn *Infinispan) IsAuthorizationEnabled() bool
- func (ispn *Infinispan) IsCache() bool
- func (ispn *Infinispan) IsClientCertEnabled() bool
- func (ispn *Infinispan) IsConditionTrue(name ConditionType) 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) IsServiceMonitorEnabled() bool
- func (ispn *Infinispan) IsUpgradeCondition() bool
- func (ispn *Infinispan) IsUpgradeNeeded(logger logr.Logger) bool
- func (ispn *Infinispan) IsWellFormed() bool
- func (ispn *Infinispan) NotClusterFormed(pods, replicas int) bool
- func (ispn *Infinispan) PreliminaryChecks() (*reconcile.Result, error)
- func (ispn *Infinispan) RemoveCondition(condition ConditionType) bool
- func (ispn *Infinispan) SetCondition(condition ConditionType, status metav1.ConditionStatus, message string) bool
- func (ispn *Infinispan) SetConditions(conds []InfinispanCondition) bool
- func (ispn *Infinispan) StorageClassName() string
- func (ispn *Infinispan) StorageSize() string
- type InfinispanCloudEvents
- type InfinispanCondition
- type InfinispanContainerSpec
- type InfinispanExternalDependencies
- type InfinispanList
- type InfinispanLoggingSpec
- type InfinispanSecurity
- type InfinispanServiceContainerSpec
- type InfinispanServiceSpec
- type InfinispanSiteLocationSpec
- type InfinispanSitesLocalSpec
- type InfinispanSitesSpec
- type InfinispanSpec
- type InfinispanStatus
- type LoggingLevelType
- type ServiceType
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) )
const ( // PodTargetLabels labels propagated to pods PodTargetLabels string = "infinispan.org/podTargetLabels" // TargetLabels labels propagated to services/ingresses/routes TargetLabels string = "infinispan.org/targetLabels" // 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 containg operator label/value map for services/ingresses/routes OperatorTargetLabelsEnvVarName string = "INFINISPAN_OPERATOR_TARGET_LABELS" // OperatorPodTargetLabelsEnvVarName is the name of the envvar containg operator label/value map for pods OperatorPodTargetLabelsEnvVarName string = "INFINISPAN_OPERATOR_POD_TARGET_LABELS" MaxRouteObjectNameLength = 63 // ServiceMonitoringAnnotation defines if we need to create ServiceMonitor or not ServiceMonitoringAnnotation string = "infinispan.org/monitoring" SiteServiceNameTemplate = "%v-site" SiteServiceFQNTemplate = "%s.%s.svc.cluster.local" )
Variables ¶
var ( // SchemeGroupVersion is group version used to register these objects SchemeGroupVersion = schema.GroupVersion{Group: "infinispan.org", Version: "v1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion} // AddToScheme adds registered types AddToScheme = SchemeBuilder.AddToScheme )
Functions ¶
func GetOpenAPIDefinitions ¶
func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource
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" ConditionStopping ConditionType = "Stopping" ConditionUpgrade ConditionType = "Upgrade" ConditionWellFormed ConditionType = "WellFormed" ConditionCrossSiteViewFormed ConditionType = "CrossSiteViewFormed" )
type CrossSiteExposeSpec ¶
type CrossSiteExposeSpec struct { // Type specifies different exposition methods for data grid Type CrossSiteExposeType `json:"type"` // +optional NodePort int32 `json:"nodePort,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
type EndpointEncryption ¶
type EndpointEncryption struct { // +optional Type CertificateSourceType `json:"type,omitempty"` // +optional CertServiceName string `json:"certServiceName,omitempty"` // +optional 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 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 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 +k8s:openapi-gen=true +kubebuilder:subresource:status
func (*Infinispan) AddLabelsForPods ¶
func (ispn *Infinispan) AddLabelsForPods(uMap map[string]string)
AddLabelsForPods adds to the user maps the labels defined for pods in the infinispan CR. New values override old ones in map.
func (*Infinispan) AddLabelsForServices ¶
func (ispn *Infinispan) AddLabelsForServices(uMap map[string]string)
AddLabelsForServices adds to the user maps the labels defined for services and ingresses/routes in the infinispan CR. New values override old ones in map.
func (*Infinispan) AddOperatorLabelsForPods ¶
func (ispn *Infinispan) AddOperatorLabelsForPods(uMap map[string]string)
AddOperatorLabelsForPods adds to the user maps the labels defined for pods in the infinispan CR by the operator. New values override old ones in map.
func (*Infinispan) AddOperatorLabelsForServices ¶
func (ispn *Infinispan) AddOperatorLabelsForServices(uMap map[string]string)
AddOperatorLabelsForServices adds to the user maps the labels defined for services and ingresses/routes in the infinispan CR. New values override old ones in map.
func (*Infinispan) ApplyDefaults ¶
func (ispn *Infinispan) ApplyDefaults()
ApplyDefaults applies default values to the Infinispan instance
func (*Infinispan) ApplyEndpointEncryptionSettings ¶
func (ispn *Infinispan) ApplyEndpointEncryptionSettings(servingCertsMode string, reqLogger logr.Logger)
ApplyEndpointEncryptionSettings compute the EndpointEncryption object
func (*Infinispan) ApplyMonitoringAnnotation ¶
func (ispn *Infinispan) ApplyMonitoringAnnotation()
func (*Infinispan) ApplyOperatorLabels ¶
func (ispn *Infinispan) ApplyOperatorLabels() error
ApplyOperatorLabels applies 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
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) EnsureClusterStability ¶
func (ispn *Infinispan) EnsureClusterStability() error
func (*Infinispan) ExpectConditionStatus ¶
func (ispn *Infinispan) ExpectConditionStatus(expected map[ConditionType]metav1.ConditionStatus) error
func (*Infinispan) GetAdminSecretName ¶
func (ispn *Infinispan) GetAdminSecretName() string
GetAdminSecretName returns the admin secret name associated with a server
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) GetConfigName ¶
func (ispn *Infinispan) GetConfigName() string
GetConfigName returns the ConfigMap name for the cluster
func (*Infinispan) GetEndpointScheme ¶
func (ispn *Infinispan) GetEndpointScheme() string
GetEndpointScheme returns the protocol scheme used by the Infinispan cluster
func (*Infinispan) GetExposeType ¶
func (ispn *Infinispan) GetExposeType() ExposeType
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) 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) 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) GetSiteServiceName ¶
func (ispn *Infinispan) GetSiteServiceName() string
func (*Infinispan) GetTruststoreSecretName ¶
func (ispn *Infinispan) GetTruststoreSecretName() string
func (*Infinispan) HasCustomLibraries ¶
func (ispn *Infinispan) HasCustomLibraries() bool
HasCustomLibraries true if custom libraries are defined
func (*Infinispan) HasSites ¶
func (ispn *Infinispan) HasSites() bool
func (*Infinispan) ImageName ¶
func (ispn *Infinispan) ImageName() string
func (*Infinispan) ImageType ¶
func (ispn *Infinispan) ImageType() ImageType
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) IsConditionTrue ¶
func (ispn *Infinispan) IsConditionTrue(name ConditionType) 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
func (*Infinispan) IsGeneratedSecret ¶
func (ispn *Infinispan) IsGeneratedSecret() bool
IsGeneratedSecret verifies that the Secret should be generated by the controller
func (*Infinispan) IsServiceMonitorEnabled ¶
func (ispn *Infinispan) IsServiceMonitorEnabled() bool
IsServiceMonitorEnabled validates that "infinispan.org/monitoring":true annotation defines or not
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) NotClusterFormed ¶
func (ispn *Infinispan) NotClusterFormed(pods, replicas int) bool
NotClusterFormed return true is cluster is not well formed
func (*Infinispan) PreliminaryChecks ¶
func (ispn *Infinispan) PreliminaryChecks() (*reconcile.Result, error)
PreliminaryChecks performs all the possible initial checks
func (*Infinispan) RemoveCondition ¶
func (ispn *Infinispan) RemoveCondition(condition ConditionType) bool
RemoveCondition remove condition from Status
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) 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
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 ExtraJvmOpts string `json:"extraJvmOpts,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 ¶
type InfinispanExternalDependencies ¶
type InfinispanExternalDependencies struct { // Name of the persistent volume claim with custom libraries // +optional VolumeClaimName string `json:"volumeClaimName,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 {
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"` // +optional EndpointAuthentication *bool `json:"endpointAuthentication,omitempty"` // +optional 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 { // +optional Storage *string `json:"storage,omitempty"` // +optional EphemeralStorage bool `json:"ephemeralStorage,omitempty"` // +optional StorageClassName string `json:"storageClassName,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 { Type ServiceType `json:"type,omitempty"` // +optional Container *InfinispanServiceContainerSpec `json:"container,omitempty"` // +optional Sites *InfinispanSitesSpec `json:"sites,omitempty"` // +optional 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 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"` // +optional 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"` }
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 { Replicas int32 `json:"replicas"` // +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 Affinity *corev1.Affinity `json:"affinity,omitempty"` // +optional CloudEvents *InfinispanCloudEvents `json:"cloudEvents,omitempty"` // External dependencies needed by the Infinispan cluster // +optional Dependencies *InfinispanExternalDependencies `json:"dependencies,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 ReplicasWantedAtRestart int32 `json:"replicasWantedAtRestart,omitempty"` // +optional PodStatus olm.DeploymentStatus `json:"podStatus,omitempty"` // +optional ConsoleUrl *string `json:"consoleUrl,omitempty"` }
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 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 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" )