Infinispan Operator 2.2 corresponds to Infinispan 13.0.
1. Infinispan Operator
Infinispan Operator provides operational intelligence and reduces management complexity for deploying Infinispan on Kubernetes and Red Hat OpenShift.
1.1. Infinispan Operator deployments
When you install Infinispan Operator, it extends the Kubernetes API with Custom Resource Definitions (CRDs) for deploying and managing Infinispan clusters on Red Hat OpenShift.
To interact with Infinispan Operator, Kubernetes users apply Custom Resources (CRs) through the Kubernetes Dashboard or kubectl
client.
Infinispan Operator listens for Infinispan
CRs and automatically provisions native resources, such as StatefulSets and Secrets, that your Infinispan deployment requires.
Infinispan Operator also configures Infinispan services according to the specifications in Infinispan
CRs, including the number of pods for the cluster and backup locations for cross-site replication.
1.2. Cluster management
A single Infinispan Operator installation can manage multiple Infinispan clusters in separate namespaces. Each time a user applies CRs to modify the deployment, Infinispan Operator applies the changes globally to all Infinispan clusters.
1.3. Resource reconciliation
Infinispan Operator reconciles custom resources such as the Cache
CR with resources on your Infinispan cluster.
Bidirectional reconciliation synchronizes your CRs with changes that you make to Infinispan resources through the Infinispan Console, command line interface (CLI), or other client application and vice versa. For example if you create a cache through the Infinispan Console then Infinispan Operator adds a declarative Kubernetes representation.
To perform reconciliation Infinispan Operator creates a listener
pod for each Infinispan cluster that detects modifications for Infinispan
resources.
-
When you create a cache through the Infinispan Console, CLI, or other client application, Infinispan Operator creates a corresponding
Cache
CR with a unique name that conforms to the Kubernetes naming policy. -
Declarative Kubernetes representations of Infinispan resources that Infinispan Operator creates with the
listener
pod are linked toInfinispan
CRs.
DeletingInfinispan
CRs removes any associated resource declarations.
2. Installing the native Infinispan CLI as a client plugin
Infinispan provides a command line interface (CLI) compiled to a native executable that you can install as a plugin for kubectl
clients.
You can then use your kubectl
client to:
-
Create Infinispan Operator subscriptions and remove Infinispan Operator installations.
-
Set up Infinispan clusters and configure services.
-
Work with Infinispan resources via remote shells.
2.1. Installing the native Infinispan CLI plugin
Install the native Infinispan Command Line Interface (CLI) as a plugin for kubectl
clients.
-
Have a
kubectl
oroc
client. -
Download the native Infinispan CLI distribution from infinispan-quarkus releases.
-
Extract the
.zip
archive for the native Infinispan CLI distribution. -
Copy the native executable, or create a hard link, to a file named "kubectl-infinispan", for example:
cp infinispan-cli kubectl-infinispan
-
Add
kubectl-infinispan
to yourPATH
. -
Verify that the CLI is installed.
kubectl plugin list The following compatible plugins are available: /path/to/kubectl-infinispan
-
Use the
infinispan --help
command to view available commands.kubectl infinispan --help
2.2. kubectl-infinispan command reference
This topic provides some details about the kubectl-infinispan
plugin for clients.
Use the For example, |
Command |
Description |
|
Creates Infinispan Operator subscriptions and installs into the global namespace by default. |
|
Creates Infinispan clusters. |
|
Displays running Infinispan clusters. |
|
Starts an interactive remote shell session on a Infinispan cluster. |
|
Removes Infinispan clusters. |
|
Removes Infinispan Operator installations and all managed resources. |
3. Installing Infinispan Operator
Install Infinispan Operator into a Kubernetes namespace to create and manage Infinispan clusters.
3.1. Installing Infinispan Operator on Red Hat OpenShift
Create subscriptions to Infinispan Operator on OpenShift so you can install different Infinispan versions and receive automatic updates.
Automatic updates apply to Infinispan Operator first and then for each Infinispan node. Infinispan Operator updates clusters one node at a time, gracefully shutting down each node and then bringing it back online with the updated version before going on to the next node.
-
Access to OperatorHub running on OpenShift. Some OpenShift environments, such as OpenShift Container Platform, can require administrator credentials.
-
Ensure the Operator Lifecycle Manager (OLM) is installed.
-
Have an OpenShift project for Infinispan Operator if you plan to install it into a specific namespace.
-
Log in to the Kubernetes Dashboard.
-
Navigate to OperatorHub.
-
Find and select Infinispan Operator.
-
Select Install and continue to Create Operator Subscription.
-
Specify options for your subscription.
- Installation Mode
-
You can install Infinispan Operator into a Specific namespace or All namespaces.
- Update Channel
-
Subscribe to updates for Infinispan Operator versions.
- Approval Strategies
-
When new Infinispan versions become available, you can install updates manually or let Infinispan Operator install them automatically.
-
Select Subscribe to install Infinispan Operator.
-
Navigate to Installed Operators to verify the Infinispan Operator installation.
3.2. Installing Infinispan Operator with the native CLI plugin
Install Infinispan Operator with the native Infinispan CLI plugin, kubectl-infinispan
.
-
Have
kubectl-infinispan
on yourPATH
. -
Ensure the Operator Lifecycle Manager (OLM) is installed.
-
Run the
oc infinispan install
command to create Infinispan Operator subscriptions, for example:kubectl infinispan install --channel=2.2 --source=redhat-operators --source-namespace=openshift-marketplace
-
Verify the installation.
kubectl get pods -n openshift-operators | grep infinispan-operator NAME READY STATUS infinispan-operator-<id> 1/1 Running
Use |
3.3. Installing Infinispan Operator from OperatorHub.io
Use the command line to install Infinispan Operator from OperatorHub.io.
-
OKD 3.11 or later.
-
Kubernetes 1.11 or later.
-
Ensure the Operator Lifecycle Manager (OLM) is installed.
-
Have administrator access on the Kubernetes cluster.
-
Have a
kubectl
oroc
client.
-
Navigate to the Infinispan Operator entry on OperatorHub.io.
-
Follow the instructions to install Infinispan Operator into your Kubernetes cluster.
3.4. Building and installing Infinispan Operator manually
Manually build and install Infinispan Operator from the GitHub repository.
-
Follow the appropriate instructions in the Infinispan Operator README.
4. Creating Infinispan clusters
Create Infinispan clusters running on Kubernetes with the Infinispan
CR or with the native Infinispan CLI plugin for kubectl
clients.
4.1. Infinispan custom resource (CR)
Infinispan Operator adds a new Custom Resource (CR) of type Infinispan
that lets you handle Infinispan clusters as complex units on Kubernetes.
Infinispan Operator listens for Infinispan
Custom Resources (CR) that you use to instantiate and configure Infinispan clusters and manage Kubernetes resources, such as StatefulSets and Services.
Infinispan
CRapiVersion: infinispan.org/v1
kind: Infinispan
metadata:
name: infinispan
spec:
replicas: 2
service:
type: DataGrid
Field | Description |
---|---|
|
Declares the version of the |
|
Declares the |
|
Specifies a name for your Infinispan cluster. |
|
Specifies the number of pods in your Infinispan cluster. |
|
Specifies the type of Infinispan service to create. |
4.2. Creating Infinispan clusters
Create Infinispan clusters with the native CLI plugin, kubectl-infinispan
.
-
Install Infinispan Operator.
-
Have
kubectl-infinispan
on yourPATH
.
-
Run the
infinispan create cluster
command.For example, create a Infinispan cluster with two pods as follows:
kubectl infinispan create cluster --replicas=3 -Pservice.type=DataGrid infinispan
-
Watch Infinispan Operator create the Infinispan pods.
kubectl get pods -w
After you create a Infinispan cluster, use the kubectl
to apply changes to Infinispan
CR and configure your Infinispan service.
You can also delete Infinispan clusters with kubectl-infinispan
and re-create them as required.
kubectl infinispan delete cluster infinispan
4.3. Verifying Infinispan cluster views
Confirm that Infinispan pods have successfully formed clusters.
-
Create at least one Infinispan cluster.
-
Retrieve the
Infinispan
CR for Infinispan Operator.kubectl get infinispan -o yaml
The response indicates that Infinispan pods have received clustered views, as in the following example:
conditions: - message: 'View: [infinispan-0, infinispan-1]' status: "True" type: wellFormed
Do the following for automated scripts:
|
Retrieving cluster view from logs
You can also get the cluster view from Infinispan logs as follows:
kubectl logs infinispan-0 | grep ISPN000094
INFO [org.infinispan.CLUSTER] (MSC service thread 1-2) \
ISPN000094: Received new cluster view for channel infinispan: \
[infinispan-0|0] (1) [infinispan-0]
INFO [org.infinispan.CLUSTER] (jgroups-3,infinispan-0) \
ISPN000094: Received new cluster view for channel infinispan: \
[infinispan-0|1] (2) [infinispan-0, infinispan-1]
4.4. Modifying Infinispan clusters
Configure Infinispan clusters by providing Infinispan Operator with a custom Infinispan
CR.
-
Install Infinispan Operator.
-
Create at least one Infinispan cluster.
-
Have an
oc
or akubectl
client.
-
Create a YAML file that defines your
Infinispan
CR.For example, create a
my_infinispan.yaml
file that changes the number of Infinispan pods to two:cat > cr_minimal.yaml<<EOF apiVersion: infinispan.org/v1 kind: Infinispan metadata: name: infinispan spec: replicas: 2 service: type: DataGrid EOF
-
Apply your
Infinispan
CR.kubectl apply -f my_infinispan.yaml
-
Watch Infinispan Operator scale the Infinispan pods.
kubectl get pods -w
4.5. Stopping and starting Infinispan clusters
Stop and start Infinispan pods in a graceful, ordered fashion to correctly preserve cluster state.
Clusters of Data Grid Service pods must restart with the same number of pods that existed before shutdown. This allows Infinispan to restore the distribution of data across the cluster. After Infinispan Operator fully restarts the cluster you can safely add and remove pods.
-
Change the
spec.replicas
field to0
to stop the Infinispan cluster.spec: replicas: 0
-
Ensure you have the correct number of pods before you restart the cluster.
kubectl get infinispan infinispan -o=jsonpath='{.status.replicasWantedAtRestart}'
-
Change the
spec.replicas
field to the same number of pods to restart the Infinispan cluster.spec: replicas: 6
5. Configuring Infinispan clusters
Apply custom Infinispan configuration to clusters that Infinispan Operator manages.
5.1. Applying custom configuration to Infinispan clusters
Add Infinispan configuration to a ConfigMap
and make it available to Infinispan Operator.
Infinispan Operator can then apply the custom configuration to your Infinispan cluster.
Infinispan Operator applies default configuration on top of your custom configuration to ensure it can continue to manage your Infinispan clusters. Be careful when applying custom configuration outside the |
Use the Infinispan Helm chart to deploy clusters of fully configurable Infinispan Server instances on OpenShift. |
-
Have valid Infinispan configuration in XML, YAML, or JSON format.
-
Add Infinispan configuration to a
infinispan-config.[xml|yaml|json]
key in thedata
field of yourConfigMap
.XMLapiVersion: v1 kind: ConfigMap metadata: name: cluster-config namespace: ispn-namespace data: infinispan-config.xml: > <infinispan> <!-- Custom configuration goes here. --> </infinispan>
YAMLapiVersion: v1 kind: ConfigMap metadata: name: cluster-config namespace: ispn-namespace data: infinispan-config.yaml: > infinispan: # Custom configuration goes here.
JSONapiVersion: v1 kind: ConfigMap metadata: name: cluster-config namespace: ispn-namespace data: infinispan-config.json: > { "infinispan": { } }
-
Create the
ConfigMap
from your YAML file.kubectl apply -f cluster-config.yaml
-
Specify the name of the
ConfigMap
with thespec.configMapName
field in yourInfinispan
CR and then apply the changes.spec: configMapName: "cluster-config"
If your cluster is already running Infinispan Operator restarts it to apply the configuration.
Each time you modify the Infinispan configuration in the ConfigMap
, Infinispan Operator detects the updates and restarts the cluster to apply the changes.
5.2. Custom Infinispan configuration
You can add Infinispan configuration to a ConfigMap
in XML, YAML, or JSON format.
Cache template
<infinispan>
<cache-container>
<distributed-cache-configuration name="base-template">
<expiration lifespan="5000"/>
</distributed-cache-configuration>
<distributed-cache-configuration name="extended-template"
configuration="base-template">
<encoding media-type="application/x-protostream"/>
<expiration lifespan="10000"
max-idle="1000"/>
</distributed-cache-configuration>
</cache-container>
</infinispan>
infinispan:
cacheContainer:
caches:
base-template:
distributedCacheConfiguration:
expiration:
lifespan: "5000"
extended-template:
distributedCacheConfiguration:
configuration: "base-template"
encoding:
mediaType: "application/x-protostream"
expiration:
lifespan: "10000"
maxIdle: "1000"
{
"infinispan" : {
"cache-container" : {
"caches" : {
"base-template" : {
"distributed-cache-configuration" : {
"expiration" : {
"lifespan" : "5000"
}
}
},
"extended-template" : {
"distributed-cache-configuration" : {
"configuration" : "base-template",
"encoding": {
"media-type": "application/x-protostream"
},
"expiration" : {
"lifespan" : "10000",
"max-idle" : "1000"
}
}
}
}
}
}
}
Multiple caches
<infinispan
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:infinispan:config:13.0 https://infinispan.org/schemas/infinispan-config-13.0.xsd
urn:infinispan:server:13.0 https://infinispan.org/schemas/infinispan-server-13.0.xsd"
xmlns="urn:infinispan:config:13.0"
xmlns:server="urn:infinispan:server:13.0">
<cache-container name="default"
statistics="true">
<distributed-cache name="mycacheone"
mode="ASYNC"
statistics="true">
<encoding media-type="application/x-protostream"/>
<expiration lifespan="300000"/>
<memory max-size="400MB"
when-full="REMOVE"/>
</distributed-cache>
<distributed-cache name="mycachetwo"
mode="SYNC"
statistics="true">
<encoding media-type="application/x-protostream"/>
<expiration lifespan="300000"/>
<memory max-size="400MB"
when-full="REMOVE"/>
</distributed-cache>
</cache-container>
</infinispan>
infinispan:
cacheContainer:
name: "default"
statistics: "true"
caches:
mycacheone:
distributedCache:
mode: "ASYNC"
statistics: "true"
encoding:
mediaType: "application/x-protostream"
expiration:
lifespan: "300000"
memory:
maxSize: "400MB"
whenFull: "REMOVE"
mycachetwo:
distributedCache:
mode: "SYNC"
statistics: "true"
encoding:
mediaType: "application/x-protostream"
expiration:
lifespan: "300000"
memory:
maxSize: "400MB"
whenFull: "REMOVE"
{
"infinispan" : {
"cache-container" : {
"name" : "default",
"statistics" : "true",
"caches" : {
"mycacheone" : {
"distributed-cache" : {
"mode": "ASYNC",
"statistics": "true",
"encoding": {
"media-type": "application/x-protostream"
},
"expiration" : {
"lifespan" : "300000"
},
"memory": {
"max-size": "400MB",
"when-full": "REMOVE"
}
}
},
"mycachetwo" : {
"distributed-cache" : {
"mode": "SYNC",
"statistics": "true",
"encoding": {
"media-type": "application/x-protostream"
},
"expiration" : {
"lifespan" : "300000"
},
"memory": {
"max-size": "400MB",
"when-full": "REMOVE"
}
}
}
}
}
}
}
Logging configuration
You can also include Apache Log4j configuration in XML format as part of your ConfigMap
.
Use the |
apiVersion: v1
kind: ConfigMap
metadata:
name: logging-config
namespace: ispn-namespace
data:
infinispan-config.xml: >
<infinispan>
<!-- Add custom Infinispan configuration if required. -->
<!-- You can provide either Infinispan configuration, logging configuration, or both. -->
</infinispan>
log4j.xml: >
<?xml version="1.0" encoding="UTF-8"?>
<Configuration name="ServerConfig" monitorInterval="60" shutdownHook="disable">
<Appenders>
<!-- Colored output on the console -->
<Console name="STDOUT">
<PatternLayout pattern="%d{HH:mm:ss,SSS} %-5p (%t) [%c] %m%throwable%n"/>
</Console>
</Appenders>
<Loggers>
<Root level="INFO">
<AppenderRef ref="STDOUT" level="TRACE"/>
</Root>
<Logger name="org.infinispan" level="TRACE"/>
</Loggers>
</Configuration>
6. Upgrading Infinispan clusters
Infinispan Operator handles Infinispan cluster upgrades when new versions become available.
Infinispan Operator requires the Operator Lifecycle Manager to perform cluster upgrades. |
6.1. Infinispan cluster upgrades
The spec.upgrades.type
field controls how Infinispan Operator upgrades your Infinispan cluster when new versions become available.
There are two types of cluster upgrade:
Shutdown
-
Upgrades Infinispan clusters with service downtime. This is the default upgrade type.
HotRodRolling
-
Upgrades Infinispan clusters without service downtime.
Shutdown upgrades
To perform a shutdown upgrade, Infinispan Operator does the following:
-
Gracefully shuts down the existing cluster.
-
Removes the existing cluster.
-
Creates a new cluster with the target version.
Hot Rod rolling upgrades
To perform a Hot Rod rolling upgrade, Infinispan Operator does the following:
-
Creates a new Infinispan cluster with the target version that runs alongside your existing cluster.
-
Creates a remote cache store to transfer data from the existing cluster to the new cluster.
-
Redirects all clients to the new cluster.
-
Removes the existing cluster when all data and client connections are transferred to the new cluster.
You should not perform Hot Rod rolling upgrades with caches that enable passivation with persistent cache stores. In the event that the upgrade does not complete successfully, passivation can result in data loss when Infinispan Operator rolls back the target cluster. If your cache configuration enables passivation you should perform a shutdown upgrade. |
6.2. Upgrading Infinispan clusters with downtime
Upgrading Infinispan clusters with downtime results in service disruption but does not require any additional capacity.
-
If required, configure a persistent cache store to preserve your data during the upgrade.
At the start of the upgrade process Infinispan Operator shuts down your existing cluster. This results in data loss if you do not configure a persistent cache store.
-
Ensure that
Shutdown
is set as the value for thespec.upgrades.type
field, which is the default.spec: upgrades: type: Shutdown
-
Apply your changes, if necessary.
When it detects a new Infinispan version, Infinispan Operator automatically upgrades your cluster or prompts you to manually approve the upgrade before proceeding.
6.3. Performing Hot Rod rolling upgrades for Infinispan clusters
Performing Hot Rod rolling upgrades lets you move to a new Infinispan version without service disruption. However, this upgrade type requires additional capacity and temporarily results in two Infinispan clusters with different versions running concurrently.
-
Specify
HotRodRolling
as the value for thespec.upgrades.type
field.spec: upgrades: type: HotRodRolling
-
Apply your changes.
When it detects a new Infinispan version, Infinispan Operator automatically upgrades your cluster or prompts you to manually approve the upgrade before proceeding.
7. Setting up Infinispan services
Use Infinispan Operator to create clusters of either Cache Service or Data Grid Service pods.
7.1. Service types
Services are stateful applications, based on the Infinispan Server image, that provide flexible and robust in-memory data storage.
When you create Infinispan clusters you specify either DataGrid
or Cache
as the service type with the spec.service.type
field.
DataGrid
service type-
Deploy Infinispan clusters with full configuration and capabilities.
Cache
service type-
Deploy Infinispan clusters with minimal configuration.
The Infinispan team recommends the DataGrid
service type for clusters because it lets you:
-
Back up data across global clusters with cross-site replication.
-
Create caches with any valid configuration.
-
Add file-based cache stores to save data in a persistent volume.
-
Query values across caches using the Infinispan Query API.
-
Use advanced Infinispan features and capabilities.
The The |
7.2. Creating Data Grid Service pods
To use custom cache definitions along with Infinispan capabilities such as cross-site replication, create clusters of Data Grid Service pods.
-
Create an
Infinispan
CR that setsspec.service.type: DataGrid
and configures any other Data Grid Service resources.apiVersion: infinispan.org/v1 kind: Infinispan metadata: name: infinispan spec: replicas: 2 service: type: DataGrid
You cannot change the
spec.service.type
field after you create pods. To change the service type, you must delete the existing pods and create new ones. -
Apply your
Infinispan
CR to create the cluster.
7.2.1. Data Grid Service CR
This topic describes the Infinispan
CR for Data Grid Service pods.
apiVersion: infinispan.org/v1
kind: Infinispan
metadata:
name: infinispan
annotations:
infinispan.org/monitoring: 'true'
spec:
replicas: 6
upgrades:
type: Shutdown
service:
type: DataGrid
container:
storage: 2Gi
# The ephemeralStorage and storageClassName fields are mutually exclusive.
ephemeralStorage: false
storageClassName: my-storage-class
sites:
local:
name: azure
expose:
type: LoadBalancer
locations:
- name: azure
url: openshift://api.azure.host:6443
secretName: azure-token
- name: aws
clusterName: infinispan
namespace: ispn-namespace
url: openshift://api.aws.host:6443
secretName: aws-token
security:
endpointSecretName: endpoint-identities
endpointEncryption:
type: Secret
certSecretName: tls-secret
container:
extraJvmOpts: "-XX:NativeMemoryTracking=summary"
cpu: "2000m:1000m"
memory: "2Gi:1Gi"
logging:
categories:
org.infinispan: debug
org.jgroups: debug
org.jgroups.protocols.TCP: error
org.jgroups.protocols.relay.RELAY2: error
expose:
type: LoadBalancer
configMapName: "my-cluster-config"
configListener:
enabled: true
affinity:
podAntiAffinity:
preferredDuringSchedulingIgnoredDuringExecution:
- weight: 100
podAffinityTerm:
labelSelector:
matchLabels:
app: infinispan-pod
clusterName: infinispan
infinispan_cr: infinispan
topologyKey: "kubernetes.io/hostname"
Field | Description |
---|---|
|
Names your Infinispan cluster. |
|
Automatically creates a |
|
Specifies the number of pods in your cluster. |
|
Controls how Infinispan Operator upgrades your Infinispan cluster when new versions become available. |
|
Configures the type Infinispan service. A value of |
|
Configures the storage resources for Data Grid Service pods. |
|
Configures cross-site replication. |
|
Specifies an authentication secret that contains Infinispan user credentials. |
|
Specifies TLS certificates and keystores to encrypt client connections. |
|
Specifies JVM, CPU, and memory resources for Infinispan pods. |
|
Configures Infinispan logging categories. |
|
Controls how Infinispan endpoints are exposed on the network. |
|
Specifies a |
|
Creates a The |
|
Configures anti-affinity strategies that guarantee Infinispan availability. |
7.3. Allocating storage resources
You can allocate storage for Data Grid Service pods but not Cache Service pods.
By default, Infinispan Operator allocates 1Gi
for the persistent volume claim.
However you should adjust the amount of storage available to Data Grid Service pods so that Infinispan can preserve cluster state during shutdown.
If available container storage is less than the amount of available memory, data loss can occur. |
-
Allocate storage resources with the
spec.service.container.storage
field. -
Configure either the
ephemeralStorage
field or thestorageClassName
field as required.These fields are mutually exclusive. Add only one of them to your
Infinispan
CR. -
Apply the changes.
spec:
service:
type: DataGrid
container:
storage: 2Gi
ephemeralStorage: true
StorageClass
objectspec:
service:
type: DataGrid
container:
storage: 2Gi
storageClassName: my-storage-class
Field | Description |
---|---|
|
Specifies the amount of storage for Data Grid Service pods. |
|
Defines whether storage is ephemeral or permanent. Set the value to |
|
Specifies the name of a |
7.3.1. Persistent volume claims
Infinispan Operator creates a persistent volume claim (PVC) and mounts container storage at:
/opt/infinispan/server/data
When you create caches, Infinispan permanently stores their configuration so your caches are available after cluster restarts. This applies to both Cache Service and Data Grid Service pods.
Data is always volatile in clusters of Cache Service pods. When you shutdown the cluster, you permanently lose the data.
Use a file-based cache store, by adding the <file-store/>
element to your Infinispan cache configuration, if you want Data Grid Service pods to persist data during cluster shutdown.
7.4. Allocating CPU and memory
Allocate CPU and memory resources to Infinispan pods with the Infinispan
CR.
Infinispan Operator requests 1Gi of memory from the Kubernetes scheduler when creating Infinispan pods. CPU requests are unbounded by default. |
-
Allocate the number of CPU units with the
spec.container.cpu
field. -
Allocate the amount of memory, in bytes, with the
spec.container.memory
field.The
cpu
andmemory
fields have values in the format of<limit>:<requests>
. For example,cpu: "2000m:1000m"
limits pods to a maximum of2000m
of CPU and requests1000m
of CPU for each pod at startup. Specifying a single value sets both the limit and request. -
Apply your
Infinispan
CR.If your cluster is running, Infinispan Operator restarts the Infinispan pods so changes take effect.
spec:
container:
cpu: "2000m:1000m"
memory: "2Gi:1Gi"
7.5. Setting JVM options
Pass additional JVM options to Infinispan pods at startup.
-
Configure JVM options with the
spec.container
filed in yourInfinispan
CR. -
Apply your
Infinispan
CR.If your cluster is running, Infinispan Operator restarts the Infinispan pods so changes take effect.
spec:
container:
extraJvmOpts: "-<option>=<value>"
routerExtraJvmOpts: "-<option>=<value>"
cliExtraJvmOpts: "-<option>=<value>"
Field | Description |
---|---|
|
Specifies additional JVM options for the Infinispan Server. |
|
Specifies additional JVM options for the Gossip router. |
|
Specifies additional JVM options for the Infinispan CLI. |
7.6. Adjusting log levels
Change levels for different Infinispan logging categories when you need to debug issues. You can also adjust log levels to reduce the number of messages for certain categories to minimize the use of container resources.
-
Configure Infinispan logging with the
spec.logging.categories
field in yourInfinispan
CR.spec: logging: categories: org.infinispan: debug org.jgroups: debug
-
Apply the changes.
-
Retrieve logs from Infinispan pods as required.
kubectl logs -f $POD_NAME
7.6.1. Logging reference
Find information about log categories and levels.
Root category | Description | Default level |
---|---|---|
|
Infinispan messages |
|
|
Cluster transport messages |
|
Log level | Description |
---|---|
|
Provides detailed information about running state of applications. This is the most verbose log level. |
|
Indicates the progress of individual requests or activities. |
|
Indicates overall progress of applications, including lifecycle events. |
|
Indicates circumstances that can lead to error or degrade performance. |
|
Indicates error conditions that might prevent operations or activities from being successful but do not prevent applications from running. |
Infinispan Operator does not log GC messages by default.
You can direct GC messages to stdout
with the following JVM options:
extraJvmOpts: "-Xlog:gc*:stdout:time,level,tags"
7.7. Specifying Infinispan Server images
Specify which Infinispan Server image Infinispan Operator should use to create pods with the spec.image
field.
spec:
image: quay.io/infinispan/server:latest
7.8. Creating Cache Service pods
Create Infinispan clusters with Cache Service pods for a volatile, low-latency data store with minimal configuration.
Cache Service pods provide volatile storage only, which means you lose all data when you modify your |
-
Create an
Infinispan
CR that setsspec.service.type: Cache
and configures any other Cache Service resources.apiVersion: infinispan.org/v1 kind: Infinispan metadata: name: infinispan spec: replicas: 2 service: type: Cache
-
Apply your
Infinispan
CR to create the cluster.
7.8.1. Cache Service CR
This topic describes the Infinispan
CR for Cache Service pods.
apiVersion: infinispan.org/v1
kind: Infinispan
metadata:
name: infinispan
annotations:
infinispan.org/monitoring: 'true'
spec:
replicas: 2
upgrades:
type: Shutdown
service:
type: Cache
replicationFactor: 2
autoscale:
maxMemUsagePercent: 70
maxReplicas: 5
minMemUsagePercent: 30
minReplicas: 2
security:
endpointSecretName: endpoint-identities
endpointEncryption:
type: Secret
certSecretName: tls-secret
container:
extraJvmOpts: "-XX:NativeMemoryTracking=summary"
cpu: "2000m:1000m"
memory: "2Gi:1Gi"
logging:
categories:
org.infinispan: trace
org.jgroups: trace
expose:
type: LoadBalancer
affinity:
podAntiAffinity:
preferredDuringSchedulingIgnoredDuringExecution:
- weight: 100
podAffinityTerm:
labelSelector:
matchLabels:
app: infinispan-pod
clusterName: infinispan
infinispan_cr: infinispan
topologyKey: "kubernetes.io/hostname"
Field | Description |
---|---|
|
Names your Infinispan cluster. |
|
Automatically creates a |
|
Specifies the number of pods in your cluster. If you enable autoscaling capabilities, this field specifies the initial number of pods. |
|
Controls how Infinispan Operator upgrades your Infinispan cluster when new versions become available. |
|
Configures the type Infinispan service. A value of |
|
Sets the number of copies for each entry across the cluster. The default for Cache Service pods is two, which replicates each cache entry to avoid data loss. |
|
Enables and configures automatic scaling. |
|
Specifies an authentication secret that contains Infinispan user credentials. |
|
Specifies TLS certificates and keystores to encrypt client connections. |
|
Specifies JVM, CPU, and memory resources for Infinispan pods. |
|
Configures Infinispan logging categories. |
|
Controls how Infinispan endpoints are exposed on the network. |
|
Configures anti-affinity strategies that guarantee Infinispan availability. |
7.9. Automatic scaling
Infinispan Operator can monitor the default cache on Cache Service pods to automatically scale clusters up or down, by creating or deleting pods based on memory usage.
Automatic scaling is available for clusters of Cache Service pods only. Infinispan Operator does not perform automatic scaling for clusters of Data Grid Service pods. |
When you enable automatic scaling, you define memory usage thresholds that let Infinispan Operator determine when it needs to create or delete pods. Infinispan Operator monitors statistics for the default cache and, when memory usage reaches the configured thresholds, scales your clusters up or down.
This threshold sets an upper boundary for the amount of memory that pods in your cluster can use before scaling up or performing eviction. When Infinispan Operator detects that any node reaches the maximum amount of memory that you configure, it creates a new node if possible. If Infinispan Operator cannot create a new node then it performs eviction when memory usage reaches 100 percent.
This threshold sets a lower boundary for memory usage across your Infinispan cluster. When Infinispan Operator detects that memory usage falls below the minimum, it shuts down pods.
Autoscaling capabilities work with the default cache only.
If you plan to add other caches to your cluster, you should not include the autoscale
field in your Infinispan
CR.
In this case you should use eviction to control the size of the data container on each node.
7.9.1. Configuring automatic scaling
If you create clusters with Cache Service pods, you can configure Infinispan Operator to automatically scale clusters.
-
Add the
spec.autoscale
resource to yourInfinispan
CR to enable automatic scaling.Set a value of
true
for theautoscale.disabled
field to disable automatic scaling. -
Configure thresholds for automatic scaling with the following fields:
Field Description spec.autoscale.maxMemUsagePercent
Specifies a maximum threshold, as a percentage, for memory usage on each node.
spec.autoscale.maxReplicas
Specifies the maximum number of Cache Service pods for the cluster.
spec.autoscale.minMemUsagePercent
Specifies a minimum threshold, as a percentage, for cluster memory usage.
spec.autoscale.minReplicas
Specifies the minimum number of Cache Service pods for the cluster.
For example, add the following to your
Infinispan
CR:spec: service: type: Cache autoscale: disabled: false maxMemUsagePercent: 70 maxReplicas: 5 minMemUsagePercent: 30 minReplicas: 2
-
Apply the changes.
7.10. Adding labels and annotations to Infinispan resources
Attach key/value labels and annotations to pods and services that Infinispan Operator creates and manages. Labels help you identify relationships between objects to better organize and monitor Infinispan resources. Annotations are arbitrary non-identifying metadata for client applications or deployment and management tooling.
-
Open your
Infinispan
CR for editing. -
Attach labels and annotations to Infinispan resources in the
metadata.annotations
section.-
Define values for annotations directly in the
metadata.annotations
section. -
Define values for labels with the
metadata.labels
field.
-
-
Apply your
Infinispan
CR.
apiVersion: infinispan.org/v1
kind: Infinispan
metadata:
annotations:
infinispan.org/targetAnnotations: service-annotation1, service-annotation2
infinispan.org/podTargetAnnotations: pod-annotation1, pod-annotation2
service-annotation1: value
service-annotation2: value
pod-annotation1: value
pod-annotation2: value
apiVersion: infinispan.org/v1
kind: Infinispan
metadata:
annotations:
infinispan.org/targetLabels: service-label1, service-label2
infinispan.org/podTargetLabels: pod-label1, pod-label2
labels:
service-label1: value
service-label2: value
pod-label1: value
pod-label2: value
# The operator does not attach these labels to resources.
my-label: my-value
environment: development
7.11. Adding labels and annotations with environment variables
Set environment variables for Infinispan Operator to add labels and annotations that automatically propagate to all Infinispan pods and services.
Add labels and annotations to your Infinispan Operator subscription with the spec.config.env
field in one of the following ways:
-
Use the
kubectl edit subscription
command.kubectl edit subscription infinispan -n openshift-operators
-
Use the Red Hat OpenShift Console.
-
Navigate to Operators > Installed Operators > Subscription.
-
Select Edit Subscription from the Actions menu.
-
spec:
config:
env:
- name: INFINISPAN_OPERATOR_TARGET_LABELS
value: |
{"service-label1":"value",
service-label1":"value"}
- name: INFINISPAN_OPERATOR_POD_TARGET_LABELS
value: |
{"pod-label1":"value",
"pod-label2":"value"}
- name: INFINISPAN_OPERATOR_TARGET_ANNOTATIONS
value: |
{"service-annotation1":"value",
"service-annotation2":"value"}
- name: INFINISPAN_OPERATOR_POD_TARGET_ANNOTATIONS
value: |
{"pod-annotation1":"value",
"pod-annotation2":"value"}
8. Configuring authentication
Application users need credentials to access Infinispan clusters. You can use default, generated credentials or add your own.
8.1. Default credentials
Infinispan Operator generates base64-encoded credentials for the following users:
User | Secret name | Description |
---|---|---|
|
|
Credentials for the default application user. |
|
|
Credentials that Infinispan Operator uses to interact with Infinispan resources. |
8.2. Retrieving credentials
Get credentials from authentication secrets to access Infinispan clusters.
-
Retrieve credentials from authentication secrets.
kubectl get secret infinispan-generated-secret
Base64-decode credentials.
kubectl get secret infinispan-generated-secret -o jsonpath="{.data.identities\.yaml}" | base64 --decode
8.3. Adding custom user credentials
Configure access to Infinispan cluster endpoints with custom credentials.
Modifying |
-
Create an
identities.yaml
file with the credentials that you want to add.credentials: - username: myfirstusername password: changeme-one - username: mysecondusername password: changeme-two
-
Create an authentication secret from
identities.yaml
.kubectl create secret generic --from-file=identities.yaml connect-secret
-
Specify the authentication secret with
spec.security.endpointSecretName
in yourInfinispan
CR and then apply the changes.spec: security: endpointSecretName: connect-secret
8.4. Changing the operator password
You can change the password for the operator
user if you do not want to use the automatically generated password.
-
Update the
password
key in theinfinispan-generated-operator-secret
secret as follows:kubectl patch secret infinispan-generated-operator-secret -p='{"stringData":{"password": "supersecretoperatorpassword"}}'
You should update only the
password
key in thegenerated-operator-secret
secret. When you update the password, Infinispan Operator automatically refreshes other keys in that secret.
8.5. Disabling user authentication
Allow users to access Infinispan clusters and manipulate data without providing credentials.
Do not disable authentication if endpoints are accessible from outside the Kubernetes cluster via |
-
Set
false
as the value for thespec.security.endpointAuthentication
field in yourInfinispan
CR.spec: security: endpointAuthentication: false
-
Apply the changes.
9. Configuring client certificate authentication
Add client trust stores to your project and configure Infinispan to allow connections only from clients that present valid certificates. This increases security of your deployment by ensuring that clients are trusted by a public certificate authority (CA).
9.1. Client certificate authentication
Client certificate authentication restricts in-bound connections based on the certificates that clients present.
You can configure Infinispan to use trust stores with either of the following strategies:
To validate client certificates, Infinispan requires a trust store that contains any part of the certificate chain for the signing authority, typically the root CA certificate. Any client that presents a certificate signed by the CA can connect to Infinispan.
If you use the Validate
strategy for verifying client certificates, you must also configure clients to provide valid Infinispan credentials if you enable authentication.
Requires a trust store that contains all public client certificates in addition to the root CA certificate. Only clients that present a signed certificate can connect to Infinispan.
If you use the Authenticate
strategy for verifying client certificates, you must ensure that certificates contain valid Infinispan credentials as part of the distinguished name (DN).
9.2. Enabling client certificate authentication
To enable client certificate authentication, you configure Infinispan to use trust stores with either the Validate
or Authenticate
strategy.
-
Set either
Validate
orAuthenticate
as the value for thespec.security.endpointEncryption.clientCert
field in yourInfinispan
CR.The default value is
None
. -
Specify the secret that contains the client trust store with the
spec.security.endpointEncryption.clientCertSecretName
field.By default Infinispan Operator expects a trust store secret named
<cluster-name>-client-cert-secret
.The secret must be unique to each
Infinispan
CR instance in the Kubernetes cluster. When you delete theInfinispan
CR, Kubernetes also automatically deletes the associated secret.spec: security: endpointEncryption: type: Secret certSecretName: tls-secret clientCert: Validate clientCertSecretName: infinispan-client-cert-secret
-
Apply the changes.
Provide Infinispan Operator with a trust store that contains all client certificates. Alternatively you can provide certificates in PEM format and let Infinispan generate a client trust store.
9.3. Providing client truststores
If you have a trust store that contains the required certificates you can make it available to Infinispan Operator.
Infinispan supports trust stores in PKCS12
format only.
-
Specify the name of the secret that contains the client trust store as the value of the
metadata.name
field.The name must match the value of the
spec.security.endpointEncryption.clientCertSecretName
field. -
Provide the password for the trust store with the
stringData.truststore-password
field. -
Specify the trust store with the
data.truststore.p12
field.apiVersion: v1 kind: Secret metadata: name: infinispan-client-cert-secret type: Opaque stringData: truststore-password: changme data: truststore.p12: "<base64_encoded_PKCS12_trust_store>"
-
Apply the changes.
9.4. Providing client certificates
Infinispan Operator can generate a trust store from certificates in PEM format.
-
Specify the name of the secret that contains the client trust store as the value of the
metadata.name
field.The name must match the value of the
spec.security.endpointEncryption.clientCertSecretName
field. -
Specify the signing certificate, or CA certificate bundle, as the value of the
data.trust.ca
field. -
If you use the
Authenticate
strategy to verify client identities, add the certificate for each client that can connect to Infinispan endpoints with thedata.trust.cert.<name>
field.Infinispan Operator uses the
<name>
value as the alias for the certificate when it generates the trust store. -
Optionally provide a password for the trust store with the
stringData.truststore-password
field.If you do not provide one, Infinispan Operator sets "password" as the trust store password.
apiVersion: v1 kind: Secret metadata: name: infinispan-client-cert-secret type: Opaque stringData: truststore-password: changme data: trust.ca: "<base64_encoded_CA_certificate>" trust.cert.client1: "<base64_encoded_client_certificate>" trust.cert.client2: "<base64_encoded_client_certificate>"
-
Apply the changes.
10. Configuring encryption
Encrypt connections between clients and Infinispan pods with Red Hat OpenShift service certificates or custom TLS certificates.
10.1. Encryption with Red Hat OpenShift service certificates
Infinispan Operator automatically generates TLS certificates that are signed by the Red Hat OpenShift service CA. Infinispan Operator then stores the certificates and keys in a secret so you can retrieve them and use with remote clients.
If the Red Hat OpenShift service CA is available, Infinispan Operator adds the following spec.security.endpointEncryption
configuration to the Infinispan
CR:
spec:
security:
endpointEncryption:
type: Service
certServiceName: service.beta.openshift.io
certSecretName: infinispan-cert-secret
Field | Description |
---|---|
|
Specifies the service that provides TLS certificates. |
|
Specifies a secret with a service certificate and key in PEM format. Defaults to |
Service certificates use the internal DNS name of the Infinispan cluster as the common name (CN), for example:
For this reason, service certificates can be fully trusted only inside OpenShift. If you want to encrypt connections with clients running outside OpenShift, you should use custom TLS certificates. Service certificates are valid for one year and are automatically replaced before they expire. |
10.2. Retrieving TLS certificates
Get TLS certificates from encryption secrets to create client trust stores.
-
Retrieve
tls.crt
from encryption secrets as follows:kubectl get secret infinispan-cert-secret -o jsonpath='{.data.tls\.crt}' | base64 --decode > tls.crt
10.3. Disabling encryption
You can disable encryption so clients do not need TLS certificates to establish connections with Infinispan.
Do not disable encryption if endpoints are accessible from outside the Kubernetes cluster via |
-
Set
None
as the value for thespec.security.endpointEncryption.type
field in yourInfinispan
CR.spec: security: endpointEncryption: type: None
-
Apply the changes.
10.4. Using custom TLS certificates
Use custom PKCS12 keystore or TLS certificate/key pairs to encrypt connections between clients and Infinispan clusters.
-
Create either a keystore or certificate secret.
The secret must be unique to each
Infinispan
CR instance in the Kubernetes cluster. When you delete theInfinispan
CR, Kubernetes also automatically deletes the associated secret.
-
Add the encryption secret to your OpenShift namespace, for example:
kubectl apply -f tls_secret.yaml
-
Specify the encryption secret with the
spec.security.endpointEncryption.certSecretName
field in yourInfinispan
CR.spec: security: endpointEncryption: type: Secret certSecretName: tls-secret
-
Apply the changes.
10.4.1. Custom encryption secrets
Custom encryption secrets that add keystores or certificate/key pairs to secure Infinispan connections must contain specific fields.
apiVersion: v1
kind: Secret
metadata:
name: tls-secret
type: Opaque
stringData:
alias: server
password: changeme
data:
keystore.p12: "MIIKDgIBAzCCCdQGCSqGSIb3DQEHA..."
Field | Description |
---|---|
|
Specifies an alias for the keystore. |
|
Specifies the keystore password. |
|
Adds a base64-encoded keystore. |
apiVersion: v1
kind: Secret
metadata:
name: tls-secret
type: Opaque
data:
tls.key: "LS0tLS1CRUdJTiBQUk ..."
tls.crt: "LS0tLS1CRUdJTiBDRVl ..."
Field | Description |
---|---|
|
Adds a base64-encoded TLS key. |
|
Adds a base64-encoded TLS certificate. |
11. Configuring user roles and permissions
Secure access to Infinispan services by configuring role-based access control (RBAC) for users. This requires you to assign roles to users so that they have permission to access caches and Infinispan resources.
11.1. Enabling security authorization
By default authorization is disabled to ensure backwards compatibility with Infinispan
CR instances.
Complete the following procedure to enable authorization and use role-based access control (RBAC) for Infinispan users.
-
Set
true
as the value for thespec.security.authorization.enabled
field in yourInfinispan
CR.spec: security: authorization: enabled: true
-
Apply the changes.
11.2. User roles and permissions
Infinispan Operator provides a set of default roles that are associated with different permissions.
Role | Permissions | Description |
---|---|---|
|
ALL |
Superuser with all permissions including control of the Cache Manager lifecycle. |
|
ALL_READ, ALL_WRITE, LISTEN, EXEC, MONITOR, CREATE |
Can create and delete Infinispan resources in addition to |
|
ALL_READ, ALL_WRITE, LISTEN, EXEC, MONITOR |
Has read and write access to Infinispan resources in addition to |
|
ALL_READ, MONITOR |
Has read access to Infinispan resources in addition to |
|
MONITOR |
Can view statistics for Infinispan clusters. |
Infinispan Operator credentials
Infinispan Operator generates credentials that it uses to authenticate with Infinispan clusters to perform internal operations.
By default Infinispan Operator credentials are automatically assigned the admin
role when you enable security authorization.
-
How security authorization works (Infinispan Security Guide).
11.3. Assigning roles and permissions to users
Assign users with roles that control whether users are authorized to access Infinispan cluster resources. Roles can have different permission levels, from read-only to unrestricted access.
Users gain authorization implicitly.
For example, "admin" gets |
-
Create an
identities.yaml
file that assigns roles to users.credentials: - username: admin password: changeme - username: my-user-1 password: changeme roles: - admin - username: my-user-2 password: changeme roles: - monitor
-
Create an authentication secret from
identities.yaml
.If necessary, delete the existing secret first.
kubectl delete secret connect-secret --ignore-not-found kubectl create secret generic --from-file=identities.yaml connect-secret
-
Specify the authentication secret with
spec.security.endpointSecretName
in yourInfinispan
CR and then apply the changes.spec: security: endpointSecretName: connect-secret
11.4. Adding custom roles and permissions
You can define custom roles with different combinations of permissions.
-
Open your
Infinispan
CR for editing. -
Specify custom roles and their associated permissions with the
spec.security.authorization.roles
field.spec: security: authorization: enabled: true roles: - name: my-role-1 permissions: - ALL - name: my-role-2 permissions: - READ - WRITE
-
Apply the changes.
12. Configuring network access to Infinispan
Expose Infinispan clusters so you can access Infinispan Console, the Infinispan command line interface (CLI), REST API, and Hot Rod endpoint.
12.1. Getting the service for internal connections
By default, Infinispan Operator creates a service that provides access to Infinispan clusters from clients running on Kubernetes.
This internal service has the same name as your Infinispan cluster, for example:
metadata:
name: infinispan
-
Check that the internal service is available as follows:
kubectl get services
12.2. Exposing Infinispan through a LoadBalancer service
Use a LoadBalancer
service to make Infinispan clusters available to clients running outside Kubernetes.
To access Infinispan with unencrypted Hot Rod client connections you must use
a |
-
Include
spec.expose
in yourInfinispan
CR. -
Specify
LoadBalancer
as the service type with thespec.expose.type
field. -
Optionally specify the network port where the service is exposed with the
spec.expose.port
field.spec: expose: type: LoadBalancer port: 65535
-
Apply the changes.
-
Verify that the
-external
service is available.kubectl get services | grep external
12.3. Exposing Infinispan through a NodePort service
Use a NodePort
service to expose Infinispan clusters on the network.
-
Include
spec.expose
in yourInfinispan
CR. -
Specify
NodePort
as the service type with thespec.expose.type
field. -
Configure the port where Infinispan is exposed with the
spec.expose.nodePort
field.spec: expose: type: NodePort nodePort: 30000
-
Apply the changes.
-
Verify that the
-external
service is available.kubectl get services | grep external
12.4. Exposing Infinispan through a Route
Use a Kubernetes Ingress or an OpenShift Route
with passthrough encryption to make Infinispan clusters available on the network.
-
Include
spec.expose
in yourInfinispan
CR. -
Specify
Route
as the service type with thespec.expose.type
field. -
Optionally add a hostname with the
spec.expose.host
field.spec: expose: type: Route host: www.example.org
-
Apply the changes.
-
Verify that the route is available.
kubectl get ingress
Route
portsWhen you create a Route
, it exposes a port on the network that accepts client connections and redirects traffic to Infinispan services that listen on port 11222
.
The port where the Route
is available depends on whether you use encryption or not.
Port | Description |
---|---|
|
Encryption is disabled. |
|
Encryption is enabled. |
12.5. Network services
Reference information for network services that Infinispan Operator creates and manages.
Service | Port | Protocol | Description |
---|---|---|---|
|
|
TCP |
Access to Infinispan endpoints within the Kubernetes cluster or from an OpenShift |
|
|
TCP |
Cluster discovery for Infinispan pods. |
|
|
TCP |
Access to Infinispan endpoints from a |
|
|
TCP |
JGroups RELAY2 channel for cross-site communication. |
13. Setting up cross-site replication
Ensure availability with Infinispan Operator by configuring geographically distributed clusters as a unified service.
You can configure clusters to perform cross-site replication with:
-
Connections that Infinispan Operator manages.
-
Connections that you configure and manage.
You can use both managed and manual connections for Infinispan clusters in the same |
13.1. Cross-site replication expose types
You can use a NodePort
service, a LoadBalancer
service, or an OpenShift Route
to handle network traffic for backup operations between Infinispan clusters.
Before you start setting up cross-site replication you should determine what expose type is available for your Red Hat OpenShift cluster.
In some cases you may require an administrator to provision services before you can configure an expose type.
NodePort
A NodePort
is a service that accepts network traffic at a static port, in the 30000
to 32767
range, on an IP address that is available externally to the OpenShift cluster.
To use a NodePort
as the expose type for cross-site replication, an administrator must provision external IP addresses for each OpenShift node.
In most cases, an administrator must also configure DNS routing for those external IP addresses.
LoadBalancer
A LoadBalancer
is a service that directs network traffic to the correct node in the OpenShift cluster.
Whether you can use a LoadBalancer
as the expose type for cross-site replication depends on the host platform.
AWS supports network load balancers (NLB) while some other cloud platforms do not.
To use a LoadBalancer
service, an administrator must first create an ingress controller backed by an NLB.
Route
An OpenShift Route
allows Infinispan clusters to connect with each other through a public secure URL.
Infinispan uses TLS with the SNI header to send backup requests between clusters through an OpenShift Route
.
To do this you must add a keystore with TLS certificates so that Infinispan can encrypt network traffic for cross-site replication.
When you specify Route
as the expose type for cross-site replication, Infinispan Operator creates a route with TLS passthrough encryption for each Infinispan cluster that it manages.
You can specify a hostname for the Route
but you cannot specify a Route
that you have already created.
Likewise it is not possible to use an ingress instead of a route because Kubernetes does not support TLS+SNI.
13.2. Managed cross-site replication
Infinispan Operator can discover Infinispan clusters running in different data centers to form global clusters.
When you configure managed cross-site connections, Infinispan Operator creates router pods in each Infinispan cluster.
Infinispan pods use the <cluster_name>-site
service to connect to these router pods and send backup requests.
Router pods maintain a record of all pod IP addresses and parse RELAY message headers to forward backup requests to the correct Infinispan cluster. If a router pod crashes then all Infinispan pods start using any other available router pod until Kubernetes restores it.
To manage cross-site connections, Infinispan Operator uses the Kubernetes API. Each OpenShift cluster must have network access to the remote Kubernetes API and a service account token for each backup cluster. |
Infinispan clusters do not start running until Infinispan Operator discovers all backup locations that you configure. |
13.2.1. Creating service account tokens for managed cross-site connections
Generate service account tokens on OpenShift clusters that allow Infinispan Operator to automatically discover Infinispan clusters and manage cross-site connections.
This procedure is specific to OpenShift clusters. If you are using another Kubernetes distribution, you should create site access secrets instead.
-
Ensure all OpenShift clusters have access to the Kubernetes API.
Infinispan Operator uses this API to manage cross-site connections.Infinispan Operator does not modify remote Infinispan clusters. The service account tokens provide read only access through the Kubernetes API.
-
Log in to an OpenShift cluster.
-
Create a service account.
For example, create a service account at LON:
oc create sa lon serviceaccount/lon created
-
Add the view role to the service account with the following command:
oc policy add-role-to-user view system:serviceaccount:<namespace>:lon
-
If you use a
NodePort
service to expose Infinispan clusters on the network, you must also add thecluster-reader
role to the service account:oc adm policy add-cluster-role-to-user cluster-reader -z <service-account-name> -n <namespace>
-
Repeat the preceding steps on your other OpenShift clusters.
-
Exchange service account tokens on each OpenShift cluster.
13.2.2. Exchanging service account tokens
After you create service account tokens on your OpenShift clusters, you add them to secrets on each backup location. For example, at LON you add the service account token for NYC. At NYC you add the service account token for LON.
-
Get tokens from each service account.
Use the following command or get the token from the Kubernetes Dashboard:
oc sa get-token lon eyJhbGciOiJSUzI1NiIsImtpZCI6IiJ9...
-
Log in to an OpenShift cluster.
-
Add the service account token for a backup location with the following command:
oc create secret generic <token-name> --from-literal=token=<token>
For example, log in to the OpenShift cluster at NYC and create a
lon-token
secret as follows:oc create secret generic lon-token --from-literal=token=eyJhbGciOiJSUzI1NiIsImtpZCI6IiJ9...
-
Repeat the preceding steps on your other OpenShift clusters.
13.2.3. Setting up Kubernetes for managed cross-site connections
Apply cluster roles and create site access secrets on Kubernetes to use cross-site replication capabilities.
-
Install
role.yaml
androle_binding.yaml
if you install Infinispan Operator manually.During OLM installation, Infinispan Operator sets up cluster roles required for cross-site replication.
kubectl apply -f config/rbac/role.yaml kubectl apply -f config/rbac/role_binding.yaml
-
If you run Infinispan Operator in any Kubernetes deployment (Minikube, Kind, and so on), you should create secrets that contain the files that allow Kubernetes clusters to authenticate with each other.
Do one of the following:
-
Retrieve service account tokens from each site and then add them to secrets on each backup location, for example:
kubectl create serviceaccount site-a -n ns-site-a kubectl create clusterrole xsite-cluster-role --verb=get,list,watch --resource=nodes,services kubectl create clusterrolebinding xsite-cluster-role-binding --clusterrole=xsite-cluster-role --serviceaccount=ns-site-a:site-a TOKENNAME=kubectl get serviceaccount/site-a -o jsonpath='{.secrets[0].name}' -n ns-site-a TOKEN=kubectl get secret $TOKENNAME -o jsonpath='{.data.token}' -n ns-site-a | base64 --decode kubectl create secret generic site-a-secret -n ns-site-a --from-literal=token=$TOKEN
-
Create secrets on each site that contain
ca.crt
,client.crt
, andclient.key
from your Kubernetes installation.For example, for Minikube do the following on LON:
kubectl create secret generic site-a-secret \ --from-file=certificate-authority=/opt/minikube/.minikube/ca.crt \ --from-file=client-certificate=/opt/minikube/.minikube/client.crt \ --from-file=client-key=/opt/minikube/.minikube/client.key
-
13.2.4. Configuring managed cross-site connections
Configure Infinispan Operator to establish cross-site views with Infinispan clusters.
-
Determine a suitable expose type for cross-site replication.
If you use an OpenShiftRoute
you must add a keystore with TLS certificates and secure cross-site connections. -
Create and exchange Red Hat OpenShift service account tokens for each Infinispan cluster.
Or, if you are using Kubernetes, apply cluster roles and create site access secrets.
-
Create an
Infinispan
CR for each Infinispan cluster. -
Specify the name of the local site with
spec.service.sites.local.name
. -
Configure the expose type for cross-site replication.
-
Set the value of the
spec.service.sites.local.expose.type
field to one of the following:-
NodePort
-
LoadBalancer
-
Route
-
-
Optionally specify a port or custom hostname with the following fields:
-
spec.service.sites.local.expose.nodePort
if you use aNodePort
service. -
spec.service.sites.local.expose.port
if you use aLoadBalancer
service. -
spec.service.sites.local.expose.routeHostName
if you use an OpenShiftRoute
.
-
-
-
Specify the number of pods that can send RELAY messages with the
service.sites.local.maxRelayNodes
field.Configure all pods in your cluster to send
RELAY
messages for better performance. If all pods send backup requests directly, then no pods need to forward backup requests. -
Provide the name, URL, and secret for each Infinispan cluster that acts as a backup location with
spec.service.sites.locations
. -
If Infinispan cluster names or namespaces at the remote site do not match the local site, specify those values with the
clusterName
andnamespace
fields.The following are example
Infinispan
CR definitions for LON and NYC:-
LON
apiVersion: infinispan.org/v1 kind: Infinispan metadata: name: infinispan spec: replicas: 3 service: type: DataGrid sites: local: name: LON expose: type: LoadBalancer port: 65535 maxRelayNodes: 1 locations: - name: NYC clusterName: <nyc_cluster_name> namespace: <nyc_cluster_namespace> url: openshift://api.rhdg-nyc.openshift-aws.myhost.com:6443 secretName: nyc-token logging: categories: org.jgroups.protocols.TCP: error org.jgroups.protocols.relay.RELAY2: error
-
NYC
apiVersion: infinispan.org/v1 kind: Infinispan metadata: name: nyc-cluster spec: replicas: 2 service: type: DataGrid sites: local: name: NYC expose: type: LoadBalancer port: 65535 maxRelayNodes: 1 locations: - name: LON clusterName: infinispan namespace: ispn-namespace url: openshift://api.rhdg-lon.openshift-aws.myhost.com:6443 secretName: lon-token logging: categories: org.jgroups.protocols.TCP: error org.jgroups.protocols.relay.RELAY2: error
Be sure to adjust logging categories in your
Infinispan
CR to decrease log levels for JGroups TCP and RELAY2 protocols. This prevents a large number of log files from uses container storage.spec: logging: categories: org.jgroups.protocols.TCP: error org.jgroups.protocols.relay.RELAY2: error
-
-
Configure your
Infinispan
CRs with any other Data Grid Service resources and then apply the changes. -
Verify that Infinispan clusters form a cross-site view.
-
Retrieve the
Infinispan
CR.kubectl get infinispan -o yaml
-
Check for the
type: CrossSiteViewFormed
condition.
-
If your clusters have formed a cross-site view, you can start adding backup locations to caches.
13.3. Manually configuring cross-site connections
You can specify static network connection details to perform cross-site replication with Infinispan clusters running outside Kubernetes. Manual cross-site connections are necessary in any scenario where access to the Kubernetes API is not available outside the Kubernetes cluster where Infinispan runs.
-
Determine a suitable expose type for cross-site replication.
If you use an OpenShiftRoute
you must add a keystore with TLS certificates and secure cross-site connections. -
Ensure you have the correct host names and ports for each Infinispan cluster and each
<cluster-name>-site
service.Manually connecting Infinispan clusters to form cross-site views requires predictable network locations for Infinispan services, which means you need to know the network locations before they are created.
-
Create an
Infinispan
CR for each Infinispan cluster. -
Specify the name of the local site with
spec.service.sites.local.name
. -
Configure the expose type for cross-site replication.
-
Set the value of the
spec.service.sites.local.expose.type
field to one of the following:-
NodePort
-
LoadBalancer
-
Route
-
-
Optionally specify a port or custom hostname with the following fields:
-
spec.service.sites.local.expose.nodePort
if you use aNodePort
service. -
spec.service.sites.local.expose.port
if you use aLoadBalancer
service. -
spec.service.sites.local.expose.routeHostName
if you use an OpenShiftRoute
.
-
-
-
Provide the name and static URL for each Infinispan cluster that acts as a backup location with
spec.service.sites.locations
, for example:-
LON
apiVersion: infinispan.org/v1 kind: Infinispan metadata: name: infinispan spec: replicas: 3 service: type: DataGrid sites: local: name: LON expose: type: LoadBalancer port: 65535 maxRelayNodes: 1 locations: - name: NYC url: infinispan+xsite://infinispan-nyc.myhost.com:7900 logging: categories: org.jgroups.protocols.TCP: error org.jgroups.protocols.relay.RELAY2: error
-
NYC
apiVersion: infinispan.org/v1 kind: Infinispan metadata: name: infinispan spec: replicas: 2 service: type: DataGrid sites: local: name: NYC expose: type: LoadBalancer port: 65535 maxRelayNodes: 1 locations: - name: LON url: infinispan+xsite://infinispan-lon.myhost.com logging: categories: org.jgroups.protocols.TCP: error org.jgroups.protocols.relay.RELAY2: error
Be sure to adjust logging categories in your
Infinispan
CR to decrease log levels for JGroups TCP and RELAY2 protocols. This prevents a large number of log files from uses container storage.spec: logging: categories: org.jgroups.protocols.TCP: error org.jgroups.protocols.relay.RELAY2: error
-
-
Configure your
Infinispan
CRs with any other Data Grid Service resources and then apply the changes. -
Verify that Infinispan clusters form a cross-site view.
-
Retrieve the
Infinispan
CR.kubectl get infinispan -o yaml
-
Check for the
type: CrossSiteViewFormed
condition.
-
If your clusters have formed a cross-site view, you can start adding backup locations to caches.
13.4. Resources for configuring cross-site replication
The following tables provides fields and descriptions for cross-site resources.
Field | Description |
---|---|
|
Infinispan supports cross-site replication with Data Grid Service clusters only. |
Field | Description |
---|---|
|
Names the local site where a Infinispan cluster runs. |
|
Specifies the network service for cross-site replication. Infinispan clusters use this service to communicate and perform backup operations. You can set the value to |
|
Specifies a static port within the default range of |
|
Specifies the network port for the service if you expose Infinispan through a |
|
Specifies a custom hostname if you expose Infinispan through an OpenShift |
|
Specifies the maximum number of pods that can send RELAY messages for cross-site replication. The default value is |
Field | Description |
---|---|
|
Provides connection information for all backup locations. |
|
Specifies a backup location that matches |
|
Specifies the URL of the Kubernetes API for managed connections or a static URL for manual connections. Use Use Note that the Use the |
|
Specifies the secret that contains the service account token for the backup site. If you set up cross-site on Kubernetes this field specifies the access secret for a site which can be any appropriate authentication object. |
|
Specifies the cluster name at the backup location if it is different to the cluster name at the local site. |
|
Specifies the namespace of the Infinispan cluster at the backup location if it does not match the namespace at the local site. |
Managed cross-site connections
spec:
service:
type: DataGrid
sites:
local:
name: LON
expose:
type: LoadBalancer
maxRelayNodes: 1
locations:
- name: NYC
clusterName: <nyc_cluster_name>
namespace: <nyc_cluster_namespace>
url: openshift://api.site-b.devcluster.openshift.com:6443
secretName: nyc-token
Manual cross-site connections
spec:
service:
type: DataGrid
sites:
local:
name: LON
expose:
type: LoadBalancer
port: 65535
maxRelayNodes: 1
locations:
- name: NYC
url: infinispan+xsite://infinispan-nyc.myhost.com:7900
13.5. Securing cross-site connections
Add keystores and trust stores so that Infinispan clusters can secure cross-site replication traffic.
You must add a keystore to use an OpenShift Route
as the expose type for cross-site replication.
Securing cross-site connections is optional if you use a NodePort
or LoadBalancer
as the expose type.
-
Have a PKCS12 keystore that Infinispan can use to encrypt and decrypt RELAY messages.
You must provide a keystore for relay pods and router pods to secure cross-site connections.
The keystore can be the same for relay pods and router pods or you can provide separate keystores for each.
You can also use the same keystore for each Infinispan cluster or a unique keystore for each cluster. -
Optionally have a trust store that contains part of the certificate chain or root CA certificate that verifies public certificates for Infinispan relay pods and router pods.
By default, Infinispan uses the Java trust store to verify public certificates.
-
Create cross-site encryption secrets.
-
Create keystore secrets.
-
Create trust store secrets if you do not want to use the default Java trust store.
-
-
Modify the
Infinispan
CR for each Infinispan cluster to specify the secret name for theencryption.transportKeyStore.secretName
andencryption.routerKeyStore.secretName
fields. -
Configure any other fields to encrypt RELAY messages as required and then apply the changes.
apiVersion: infinispan.org/v1 kind: Infinispan metadata: name: infinispan spec: replicas: 2 expose: type: LoadBalancer service: type: DataGrid sites: local: name: SiteA # ... encryption: protocol: TLSv1.3 transportKeyStore: secretName: transport-tls-secret alias: transport filename: keystore.p12 routerKeyStore: secretName: router-tls-secret alias: router filename: keystore.p12 trustStore: secretName: truststore-tls-secret filename: truststore.p12 locations: # ...
13.5.1. Resources for configuring cross-site encryption
The following tables provides fields and descriptions for encrypting cross-site connections.
Field | Description |
---|---|
|
Specifies the TLS protocol to use for cross-site connections. The default value is |
|
Configures a keystore secret for relay pods. |
|
Configures a keystore secret for router pods. |
|
Configures an optional trust store secret for relay pods and router pods. |
Field | Description |
---|---|
|
Specifies the secret that contains a keystore that relay pods can use to encrypt and decrypt RELAY messages. This field is required. |
|
Optionally specifies the alias of the certificate in the keystore.
The default value is |
|
Optionally specifies the filename of the keystore.
The default value is |
Field | Description |
---|---|
|
Specifies the secret that contains a keystore that router pods can use to encrypt and decrypt RELAY messages. This field is required. |
|
Optionally specifies the alias of the certificate in the keystore.
The default value is |
|
Optionally specifies the filename of the keystore.
The default value is |
Field | Description |
---|---|
|
Optionally specifies the secret that contains a trust store to verify public certificates for relay pods and router pods.
The default value is |
|
Optionally specifies the filename of the trust store.
The default value is |
13.5.2. Cross-site encryption secrets
Cross-site replication encryption secrets add keystores and optional trust stores for securing cross-site connections.
apiVersion: v1
kind: Secret
metadata:
name: tls-secret
type: Opaque
stringData:
password: changeme
type: pkcs12
data:
<file-name>: "MIIKDgIBAzCCCdQGCSqGSIb3DQEHA..."
Field | Description |
---|---|
|
Specifies the password for the keystore or trust store. |
|
Optionally specifies the keystore or trust store type. The default value is |
|
Adds a base64-encoded keystore or trust store. |
13.6. Configuring sites in the same Kubernetes cluster
For evaluation and demonstration purposes, you can configure Infinispan to back up between pods in the same Kubernetes cluster.
Using |
-
Create an
Infinispan
CR for each Infinispan cluster. -
Specify the name of the local site with
spec.service.sites.local.name
. -
Set
ClusterIP
as the value of thespec.service.sites.local.expose.type
field. -
Provide the name of the Infinispan cluster that acts as a backup location with
spec.service.sites.locations.clusterName
. -
If both Infinispan clusters have the same name, specify the namespace of the backup location with
spec.service.sites.locations.namespace
.apiVersion: infinispan.org/v1 kind: Infinispan metadata: name: example-clustera spec: replicas: 1 expose: type: LoadBalancer service: type: DataGrid sites: local: name: SiteA expose: type: ClusterIP maxRelayNodes: 1 locations: - name: SiteB clusterName: example-clusterb namespace: cluster-namespace
-
Configure your
Infinispan
CRs with any other Data Grid Service resources and then apply the changes. -
Verify that Infinispan clusters form a cross-site view.
-
Retrieve the
Infinispan
CR.kubectl get infinispan -o yaml
-
Check for the
type: CrossSiteViewFormed
condition.
-
14. Monitoring Infinispan services
Infinispan exposes metrics that can be used by Prometheus and Grafana for monitoring and visualizing the cluster state.
This documentation explains how to set up monitoring on OpenShift Container Platform. If you’re working with community Prometheus deployments, you might find these instructions useful as a general guide. However you should refer to the Prometheus documentation for installation and usage instructions. See the Prometheus Operator documentation. |
14.1. Creating a Prometheus service monitor
Infinispan Operator automatically creates a Prometheus ServiceMonitor
that scrapes metrics from your Infinispan cluster.
Enable monitoring for user-defined projects on OpenShift Container Platform.
When the Operator detects an Infinispan
CR with the monitoring annotation set to true
, which is the default, Infinispan Operator does the following:
-
Creates a
ServiceMonitor
named<cluster_name>-monitor
. -
Adds the
infinispan.org/monitoring: 'true'
annotation to yourInfinispan
CR metadata, if the value is not already explicitly set:apiVersion: infinispan.org/v1 kind: Infinispan metadata: name: infinispan annotations: infinispan.org/monitoring: 'true'
To authenticate with Infinispan, Prometheus uses the |
You can check that Prometheus is scraping Infinispan metrics as follows:
-
In the Kubernetes Dashboard, select the </> Developer perspective and then select Monitoring.
-
Open the Dashboard tab for the namespace where your Infinispan cluster runs.
-
Open the Metrics tab and confirm that you can query Infinispan metrics such as:
vendor_cache_manager_default_cluster_size
14.1.1. Disabling the Prometheus service monitor
You can disable the ServiceMonitor
if you do not want Prometheus to scrape metrics for your Infinispan cluster.
-
Set
'false'
as the value for theinfinispan.org/monitoring
annotation in yourInfinispan
CR.apiVersion: infinispan.org/v1 kind: Infinispan metadata: name: infinispan annotations: infinispan.org/monitoring: 'false'
-
Apply the changes.
14.2. Creating Grafana data sources
Create a GrafanaDatasource
CR so you can visualize Infinispan metrics in Grafana dashboards.
-
Have an
oc
client. -
Have
cluster-admin
access to OpenShift Container Platform. -
Enable monitoring for user-defined projects on OpenShift Container Platform.
-
Install the Grafana Operator from the alpha channel and create a
Grafana
CR.
-
Create a
ServiceAccount
that lets Grafana read Infinispan metrics from Prometheus.apiVersion: v1 kind: ServiceAccount metadata: name: infinispan-monitoring
-
Apply the
ServiceAccount
.oc apply -f service-account.yaml
-
Grant
cluster-monitoring-view
permissions to theServiceAccount
.oc adm policy add-cluster-role-to-user cluster-monitoring-view -z infinispan-monitoring
-
-
Create a Grafana data source.
-
Retrieve the token for the
ServiceAccount
.oc serviceaccounts get-token infinispan-monitoring
-
Define a
GrafanaDataSource
that includes the token in thespec.datasources.secureJsonData.httpHeaderValue1
field, as in the following example:apiVersion: integreatly.org/v1alpha1 kind: GrafanaDataSource metadata: name: grafanadatasource spec: name: datasource.yaml datasources: - access: proxy editable: true isDefault: true jsonData: httpHeaderName1: Authorization timeInterval: 5s tlsSkipVerify: true name: Prometheus secureJsonData: httpHeaderValue1: >- Bearer eyJhbGciOiJSUzI1NiIsImtpZCI6Imc4O... type: prometheus url: 'https://thanos-querier.openshift-monitoring.svc.cluster.local:9091'
-
-
Apply the
GrafanaDataSource
.oc apply -f grafana-datasource.yaml
Enable Grafana dashboards with the Infinispan Operator configuration properties.
14.3. Configuring Infinispan dashboards
Infinispan Operator provides global configuration properties that let you configure Grafana dashboards for Infinispan clusters.
You can modify global configuration properties while Infinispan Operator is running. |
-
Infinispan Operator must watch the namespace where the Grafana Operator is running.
-
Create a
ConfigMap
namedinfinispan-operator-config
in the Infinispan Operator namespace.apiVersion: v1 kind: ConfigMap metadata: name: infinispan-operator-config data: grafana.dashboard.namespace: infinispan grafana.dashboard.name: infinispan grafana.dashboard.monitoring.key: middleware
-
Specify the namespace of your Infinispan cluster with the
data.grafana.dashboard.namespace
property.Deleting the value for this property removes the dashboard. Changing the value moves the dashboard to that namespace.
-
Specify a name for the dashboard with the
data.grafana.dashboard.name
property. -
If necessary, specify a monitoring key with the
data.grafana.dashboard.monitoring.key
property. -
Create
infinispan-operator-config
or update the configuration.oc apply -f infinispan-operator-config.yaml
-
Open the Grafana UI, which is available at:
oc get routes grafana-route -o jsonpath=https://"{.spec.host}"
15. Guaranteeing availability with anti-affinity
Kubernetes includes anti-affinity capabilities that protect workloads from single points of failure.
15.1. Anti-affinity strategies
Each Infinispan node in a cluster runs in a pod that runs on an Kubernetes node in a cluster. Each Red Hat OpenShift node runs on a physical host system. Anti-affinity works by distributing Infinispan nodes across Kubernetes nodes, ensuring that your Infinispan clusters remain available even if hardware failures occur.
Infinispan Operator offers two anti-affinity strategies:
kubernetes.io/hostname
-
Infinispan replica pods are scheduled on different Kubernetes nodes.
topology.kubernetes.io/zone
-
Infinispan replica pods are scheduled across multiple zones.
Fault tolerance
Anti-affinity strategies guarantee cluster availability in different ways.
The equations in the following section apply only if the number of Kubernetes nodes or zones is greater than the number of Infinispan nodes. |
Provides tolerance of x
node failures for the following types of cache:
-
Replicated:
x = spec.replicas - 1
-
Distributed:
x = num_owners - 1
Provides tolerance of x
zone failures when x
zones exist for the following types of cache:
-
Replicated:
x = spec.replicas - 1
-
Distributed:
x = num_owners - 1
|
15.2. Configuring anti-affinity
Specify where Kubernetes schedules pods for your Infinispan clusters to ensure availability.
-
Add the
spec.affinity
block to yourInfinispan
CR. -
Configure anti-affinity strategies as necessary.
-
Apply your
Infinispan
CR.
15.2.1. Anti-affinity strategy configurations
Configure anti-affinity strategies in your Infinispan
CR to control where Kubernetes schedules Infinispan replica pods.
Topology keys | Description |
---|---|
|
Schedules Infinispan replica pods across multiple zones. |
|
Schedules Infinispan replica pods on different Kubernetes nodes. |
Schedule pods on different Kubernetes nodes
The following is the anti-affinity strategy that Infinispan Operator uses if you do not configure the spec.affinity
field in your Infinispan
CR:
spec:
affinity:
podAntiAffinity:
preferredDuringSchedulingIgnoredDuringExecution:
- weight: 100
podAffinityTerm:
labelSelector:
matchLabels:
app: infinispan-pod
clusterName: <cluster_name>
infinispan_cr: <cluster_name>
topologyKey: "kubernetes.io/hostname"
Requiring different nodes
In the following example, Kubernetes does not schedule Infinispan pods if different nodes are not available:
spec:
affinity:
podAntiAffinity:
requiredDuringSchedulingIgnoredDuringExecution:
- labelSelector:
matchLabels:
app: infinispan-pod
clusterName: <cluster_name>
infinispan_cr: <cluster_name>
topologyKey: "topology.kubernetes.io/hostname"
To ensure that you can schedule Infinispan replica pods on different Kubernetes nodes, the number of Kubernetes nodes available must be greater than the value of |
Schedule pods across multiple Kubernetes zones
The following example prefers multiple zones when scheduling pods but schedules Infinispan replica pods on different Kubernetes nodes if it is not possible to schedule across zones:
spec:
affinity:
podAntiAffinity:
preferredDuringSchedulingIgnoredDuringExecution:
- weight: 100
podAffinityTerm:
labelSelector:
matchLabels:
app: infinispan-pod
clusterName: <cluster_name>
infinispan_cr: <cluster_name>
topologyKey: "topology.kubernetes.io/zone"
- weight: 90
podAffinityTerm:
labelSelector:
matchLabels:
app: infinispan-pod
clusterName: <cluster_name>
infinispan_cr: <cluster_name>
topologyKey: "kubernetes.io/hostname"
Requiring multiple zones
The following example uses the zone strategy only when scheduling Infinispan replica pods:
spec:
affinity:
podAntiAffinity:
requiredDuringSchedulingIgnoredDuringExecution:
- labelSelector:
matchLabels:
app: infinispan-pod
clusterName: <cluster_name>
infinispan_cr: <cluster_name>
topologyKey: "topology.kubernetes.io/zone"
16. Creating caches with Infinispan Operator
Use Cache
CRs to add cache configuration with Infinispan Operator and control how Infinispan stores your data.
16.1. Infinispan caches
Cache configuration defines the characteristics and features of the data store and must be valid with the Infinispan schema. Infinispan recommends creating standalone files in XML or JSON format that define your cache configuration. You should separate Infinispan configuration from application code for easier validation and to avoid the situation where you need to maintain XML snippets in Java or some other client language.
To create caches with Infinispan clusters running on Kubernetes, you should:
-
Use
Cache
CR as the mechanism for creating caches through the Kubernetes front end. -
Use
Batch
CR to create multiple caches at a time from standalone configuration files. -
Access Infinispan Console and create caches in XML or JSON format.
You can use Hot Rod or HTTP clients but Infinispan recommends Cache
CR or Batch
CR unless your specific use case requires programmatic remote cache creation.
Cache CRs
-
Cache
CRs apply to Data Grid Service pods only. -
Each
Cache
CR corresponds to a single cache on the Infinispan cluster.
16.2. Creating caches with the Cache CR
Complete the following steps to create caches on Data Grid Service clusters using valid configuration in XML or YAML format.
-
Create a
Cache
CR with a unique value in themetadata.name
field. -
Specify the target Infinispan cluster with the
spec.clusterName
field. -
Name your cache with the
spec.name
field.The
name
attribute in the cache configuration does not take effect. If you do not specify a name with thespec.name
field then the cache uses the value of themetadata.name
field. -
Add a cache configuration with the
spec.template
field. -
Apply the
Cache
CR, for example:kubectl apply -f mycache.yaml cache.infinispan.org/mycachedefinition created
Cache CR examples
apiVersion: infinispan.org/v2alpha1
kind: Cache
metadata:
name: mycachedefinition
spec:
clusterName: infinispan
name: myXMLcache
template: <distributed-cache mode="SYNC" statistics="true"><encoding media-type="application/x-protostream"/><persistence><file-store/></persistence></distributed-cache>
apiVersion: infinispan.org/v2alpha1
kind: Cache
metadata:
name: mycachedefinition
spec:
clusterName: infinispan
name: myYAMLcache
template: |-
distributedCache:
mode: "SYNC"
owners: "2"
statistics: "true"
encoding:
mediaType: "application/x-protostream"
persistence:
fileStore: ~
16.3. Adding persistent cache stores
You can add persistent cache stores to Data Grid Service pods to save data to the persistent volume.
Infinispan creates a Single File cache store, .dat
file, in the /opt/infinispan/server/data
directory.
-
Add the
<file-store/>
element to thepersistence
configuration in your Infinispan cache, as in the following example:<distributed-cache name="persistent-cache" mode="SYNC"> <encoding media-type="application/x-protostream"/> <persistence> <file-store/> </persistence> </distributed-cache>
16.4. Adding caches to Cache Service pods
Cache Service pods include a default cache configuration with recommended settings. This default cache lets you start using Infinispan without the need to create caches.
Because the default cache provides recommended settings, you should create caches only as copies of the default. If you want multiple custom caches you should create Data Grid Service pods instead of Cache Service pods. |
-
Access the Infinispan Console and provide a copy of the default configuration in XML or JSON format.
-
Use the Infinispan CLI to create a copy from the default cache as follows:
[//containers/default]> create cache --template=default mycache
16.4.1. Default cache configuration
This topic describes default cache configuration for Cache Service pods.
<distributed-cache name="default"
mode="SYNC"
owners="2">
<memory storage="OFF_HEAP"
max-size="<maximum_size_in_bytes>"
when-full="REMOVE" />
<partition-handling when-split="ALLOW_READ_WRITES"
merge-policy="REMOVE_ALL"/>
</distributed-cache>
Default caches:
-
Use synchronous distribution to store data across the cluster.
-
Create two replicas of each entry on the cluster.
-
Store cache entries as bytes in native memory (off-heap).
-
Define the maximum size for the data container in bytes. Infinispan Operator calculates the maximum size when it creates pods.
-
Evict cache entries to control the size of the data container. You can enable automatic scaling so that Infinispan Operator adds pods when memory usage increases instead of removing entries.
-
Use a conflict resolution strategy that allows read and write operations for cache entries, even if segment owners are in different partitions.
-
Specify a merge policy that removes entries from the cache when Infinispan detects conflicts.
17. Running batch operations
Infinispan Operator provides a Batch
CR that lets you create Infinispan resources in bulk.
Batch
CR uses the Infinispan command line interface (CLI) in batch mode to carry out sequences of operations.
Modifying a |
17.1. Running inline batch operations
Include your batch operations directly in a Batch
CR if they do not require separate configuration artifacts.
-
Create a
Batch
CR.-
Specify the name of the Infinispan cluster where you want the batch operations to run as the value of the
spec.cluster
field. -
Add each CLI command to run on a line in the
spec.config
field.apiVersion: infinispan.org/v2alpha1 kind: Batch metadata: name: mybatch spec: cluster: infinispan config: | create cache --template=org.infinispan.DIST_SYNC mycache put --cache=mycache hello world put --cache=mycache hola mundo
-
-
Apply your
Batch
CR.kubectl apply -f mybatch.yaml
-
Check the
status.Phase
field in theBatch
CR to verify the operations completed successfully.
17.2. Creating ConfigMaps for batch operations
Create a ConfigMap
so that additional files, such as Infinispan cache configuration, are available for batch operations.
For demonstration purposes, you should add some configuration artifacts to your host filesystem before you start the procedure:
-
Create a
/tmp/mybatch
directory where you can add some files.mkdir -p /tmp/mybatch
-
Create a Infinispan cache configuration.
cat > /tmp/mybatch/mycache.xml<<EOF <distributed-cache name="mycache" mode="SYNC"> <encoding media-type="application/x-protostream"/> <memory max-count="1000000" when-full="REMOVE"/> </distributed-cache> EOF
-
Create a
batch
file that contains all commands you want to run.For example, the following
batch
file creates a cache named "mycache" and adds two entries to it:create cache mycache --file=/etc/batch/mycache.xml put --cache=mycache hello world put --cache=mycache hola mundo
The
ConfigMap
is mounted in Infinispan pods at/etc/batch
. You must prepend all--file=
directives in your batch operations with that path. -
Ensure all configuration artifacts that your batch operations require are in the same directory as the
batch
file.ls /tmp/mybatch batch mycache.xml
-
Create a
ConfigMap
from the directory.kubectl create configmap mybatch-config-map --from-file=/tmp/mybatch
17.3. Running batch operations with ConfigMaps
Run batch operations that include configuration artifacts.
-
Create a
ConfigMap
that contains any files your batch operations require.
-
Create a
Batch
CR that specifies the name of a Infinispan cluster as the value of thespec.cluster
field. -
Set the name of the
ConfigMap
that contains yourbatch
file and configuration artifacts with thespec.configMap
field.cat > mybatch.yaml<<EOF apiVersion: infinispan.org/v2alpha1 kind: Batch metadata: name: mybatch spec: cluster: infinispan configMap: mybatch-config-map EOF
-
Apply your
Batch
CR.kubectl apply -f mybatch.yaml
-
Check the
status.Phase
field in theBatch
CR to verify the operations completed successfully.
17.4. Batch status messages
Verify and troubleshoot batch operations with the status.Phase
field in the Batch
CR.
Phase | Description |
---|---|
|
All batch operations have completed successfully. |
|
Batch operations are queued and resources are initializing. |
|
Batch operations are ready to start. |
|
Batch operations are in progress. |
|
One or more batch operations were not successful. |
Batch operations are not atomic. If a command in a batch script fails, it does not affect the other operations or cause them to rollback.
If your batch operations have any server or syntax errors, you can view log messages in the |
17.5. Example batch operations
Use these example batch operations as starting points for creating and modifying Infinispan resources with the Batch
CR.
You can pass configuration files to Infinispan Operator only via a The |
17.5.1. Caches
-
Create multiple caches from configuration files.
echo "creating caches..."
create cache sessions --file=/etc/batch/infinispan-prod-sessions.xml
create cache tokens --file=/etc/batch/infinispan-prod-tokens.xml
create cache people --file=/etc/batch/infinispan-prod-people.xml
create cache books --file=/etc/batch/infinispan-prod-books.xml
create cache authors --file=/etc/batch/infinispan-prod-authors.xml
echo "list caches in the cluster"
ls caches
-
Create a template from a file and then create caches from the template.
echo "creating caches..."
create cache mytemplate --file=/etc/batch/mycache.xml
create cache sessions --template=mytemplate
create cache tokens --template=mytemplate
echo "list caches in the cluster"
ls caches
17.5.2. Counters
Use the Batch
CR to create multiple counters that can increment and decrement to record the count of objects.
You can use counters to generate identifiers, act as rate limiters, or track the number of times a resource is accessed.
echo "creating counters..."
create counter --concurrency-level=1 --initial-value=5 --storage=PERSISTENT --type=weak mycounter1
create counter --initial-value=3 --storage=PERSISTENT --type=strong mycounter2
create counter --initial-value=13 --storage=PERSISTENT --type=strong --upper-bound=10 mycounter3
echo "list counters in the cluster"
ls counters
17.5.3. Protobuf schema
Register Protobuf schema to query values in caches.
Protobuf schema (.proto
files) provide metadata about custom entities and controls field indexing.
echo "creating schema..."
schema --upload=person.proto person.proto
schema --upload=book.proto book.proto
schema --upload=author.proto book.proto
echo "list Protobuf schema"
ls schemas
17.5.4. Tasks
Upload tasks that implement org.infinispan.tasks.ServerTask
or scripts that are compatible with the javax.script
scripting API.
echo "creating tasks..."
task upload --file=/etc/batch/myfirstscript.js myfirstscript
task upload --file=/etc/batch/mysecondscript.js mysecondscript
task upload --file=/etc/batch/mythirdscript.js mythirdscript
echo "list tasks"
ls tasks
18. Backing up and restoring Infinispan clusters
Infinispan Operator lets you back up and restore Infinispan cluster state for disaster recovery and to migrate Infinispan resources between clusters.
18.1. Backup and Restore CRs
Backup
and Restore
CRs save in-memory data at runtime so you can easily recreate Infinispan clusters.
Applying a Backup
or Restore
CR creates a new pod that joins the Infinispan cluster as a zero-capacity member, which means it does not require cluster rebalancing or state transfer to join.
For backup operations, the pod iterates over cache entries and other resources and creates an archive, a .zip
file, in the /opt/infinispan/backups
directory on the persistent volume (PV).
Performing backups does not significantly impact performance because the other pods in the Infinispan cluster only need to respond to the backup pod as it iterates over cache entries. |
For restore operations, the pod retrieves Infinispan resources from the archive on the PV and applies them to the Infinispan cluster.
When either the backup or restore operation completes, the pod leaves the cluster and is terminated.
Infinispan Operator does not reconcile Backup
and Restore
CRs which mean that backup and restore operations are "one-time" events.
Modifying an existing Backup
or Restore
CR instance does not perform an operation or have any effect.
If you want to update .spec
fields, you must create a new instance of the Backup
or Restore
CR.
18.2. Backing up Infinispan clusters
Create a backup file that stores Infinispan cluster state to a persistent volume.
-
Create an
Infinispan
CR withspec.service.type: DataGrid
. -
Ensure there are no active client connections to the Infinispan cluster.
Infinispan backups do not provide snapshot isolation and data modifications are not written to the archive after the cache is backed up.
To archive the exact state of the cluster, you should always disconnect any clients before you back it up.
-
Name the
Backup
CR with themetadata.name
field. -
Specify the Infinispan cluster to backup with the
spec.cluster
field. -
Configure the persistent volume claim (PVC) that adds the backup archive to the persistent volume (PV) with the
spec.volume.storage
andspec.volume.storage.storageClassName
fields.apiVersion: infinispan.org/v2alpha1 kind: Backup metadata: name: my-backup spec: cluster: source-cluster volume: storage: 1Gi storageClassName: my-storage-class
-
Optionally include
spec.resources
fields to specify which Infinispan resources you want to back up.If you do not include any
spec.resources
fields, theBackup
CR creates an archive that contains all Infinispan resources. If you do specifyspec.resources
fields, theBackup
CR creates an archive that contains those resources only.spec: ... resources: templates: - distributed-sync-prod - distributed-sync-dev caches: - cache-one - cache-two counters: - counter-name protoSchemas: - authors.proto - books.proto tasks: - wordStream.js
You can also use the
*
wildcard character as in the following example:spec: ... resources: caches: - "*" protoSchemas: - "*"
-
Apply your
Backup
CR.kubectl apply -f my-backup.yaml
-
Check that the
status.phase
field has a status ofSucceeded
in theBackup
CR and that Infinispan logs have the following message:ISPN005044: Backup file created 'my-backup.zip'
-
Run the following command to check that the backup is successfully created:
kubectl describe Backup my-backup -n namespace
18.3. Restoring Infinispan clusters
Restore Infinispan cluster state from a backup archive.
-
Create a
Backup
CR on a source cluster. -
Create a target Infinispan cluster of Data Grid Service pods.
If you restore an existing cache, the operation overwrites the data in the cache but not the cache configuration.
For example, you back up a distributed cache named
mycache
on the source cluster. You then restoremycache
on a target cluster where it already exists as a replicated cache. In this case, the data from the source cluster is restored andmycache
continues to have a replicated configuration on the target cluster. -
Ensure there are no active client connections to the target Infinispan cluster you want to restore.
Cache entries that you restore from a backup can overwrite more recent cache entries.
For example, a client performs acache.put(k=2)
operation and you then restore a backup that containsk=1
.
-
Name the
Restore
CR with themetadata.name
field. -
Specify a
Backup
CR to use with thespec.backup
field. -
Specify the Infinispan cluster to restore with the
spec.cluster
field.apiVersion: infinispan.org/v2alpha1 kind: Restore metadata: name: my-restore spec: backup: my-backup cluster: target-cluster
-
Optionally add the
spec.resources
field to restore specific resources only.spec: ... resources: templates: - distributed-sync-prod - distributed-sync-dev caches: - cache-one - cache-two counters: - counter-name protoSchemas: - authors.proto - books.proto tasks: - wordStream.js
-
Apply your
Restore
CR.kubectl apply -f my-restore.yaml
-
Check that the
status.phase
field has a status ofSucceeded
in theRestore
CR and that Infinispan logs have the following message:ISPN005045: Restore 'my-backup' complete
You should then open the Infinispan Console or establish a CLI connection to verify data and Infinispan resources are restored as expected.
18.4. Backup and restore status
Backup
and Restore
CRs include a status.phase
field that provides the status for each phase of the operation.
Status | Description |
---|---|
|
The system has accepted the request and the controller is preparing the underlying resources to create the pod. |
|
The controller has prepared all underlying resources successfully. |
|
The pod is created and the operation is in progress on the Infinispan cluster. |
|
The operation has completed successfully on the Infinispan cluster and the pod is terminated. |
|
The operation did not successfully complete and the pod is terminated. |
|
The controller cannot obtain the status of the pod or determine the state of the operation. This condition typically indicates a temporary communication error with the pod. |
18.4.1. Handling failed backup and restore operations
If the status.phase
field of the Backup
or Restore
CR is Failed
, you should examine pod logs to determine the root cause before you attempt the operation again.
-
Examine the logs for the pod that performed the failed operation.
Pods are terminated but remain available until you delete the
Backup
orRestore
CR.kubectl logs <backup|restore_pod_name>
-
Resolve any error conditions or other causes of failure as indicated by the pod logs.
-
Create a new instance of the
Backup
orRestore
CR and attempt the operation again.
19. Deploying custom code to Infinispan
Add custom code, such as scripts and event listeners, to your Infinispan clusters.
Before you can deploy custom code to Infinispan clusters, you need to make it available. To do this you can copy artifacts from a persistent volume (PV), download artifacts from an HTTP or FTP server, or use both methods.
19.1. Copying code artifacts to Infinispan clusters
Adding your artifacts to a persistent volume (PV) and then copy them to Infinispan pods.
This procedure explains how to use a temporary pod that mounts a persistent volume claim (PVC) that:
-
Lets you add code artifacts to the PV (perform a write operation).
-
Allows Infinispan pods to load code artifacts from the PV (perform a read operation).
To perform these read and write operations, you need certain PV access modes. However, support for different PVC access modes is platform dependent.
It is beyond the scope of this document to provide instructions for creating PVCs with different platforms.
For simplicity, the following procedure shows a PVC with the ReadWriteMany
access mode.
In some cases only the ReadOnlyMany
or ReadWriteOnce
access modes are available.
You can use a combination of those access modes by reclaiming and reusing PVCs with the same spec.volumeName
.
Using |
-
Change to the namespace for your Infinispan cluster.
kubectl config set-context --current --namespace=ispn-namespace
-
Create a PVC for your custom code artifacts, for example:
apiVersion: v1 kind: PersistentVolumeClaim metadata: name: datagrid-libs spec: accessModes: - ReadWriteMany resources: requests: storage: 100Mi
-
Apply your PVC.
kubectl apply -f datagrid-libs.yaml
-
Create a pod that mounts the PVC, for example:
apiVersion: v1 kind: Pod metadata: name: datagrid-libs-pod spec: securityContext: fsGroup: 2000 volumes: - name: lib-pv-storage persistentVolumeClaim: claimName: datagrid-libs containers: - name: lib-pv-container image: quay.io/infinispan/server:13.0 volumeMounts: - mountPath: /tmp/libs name: lib-pv-storage
-
Add the pod to the Infinispan namespace and wait for it to be ready.
kubectl apply -f datagrid-libs-pod.yaml kubectl wait --for=condition=ready --timeout=2m pod/datagrid-libs-pod
-
Copy your code artifacts to the pod so that they are loaded into the PVC.
For example to copy code artifacts from a local
libs
directory, do the following:kubectl cp --no-preserve=true libs datagrid-libs-pod:/tmp/
-
Delete the pod.
kubectl delete pod datagrid-libs-pod
Specify the persistent volume with
spec.dependencies.volumeClaimName
in yourInfinispan
CR and then apply the changes.apiVersion: infinispan.org/v1 kind: Infinispan metadata: name: infinispan spec: replicas: 2 dependencies: volumeClaimName: datagrid-libs service: type: DataGrid
If you update your custom code on the persistent volume, you must restart the Infinispan cluster so it can load the changes. |
19.2. Downloading code artifacts
Add your artifacts to an HTTP or FTP server so that Infinispan Operator downloads them to the /opt/infinispan/server/lib
directory on each Infinispan node.
When downloading files, Infinispan Operator can automatically detect the file type.
Infinispan Operator also extracts archived files, such as zip
or tgz
, to the filesystem after the download completes.
Each time Infinispan Operator creates a Infinispan node it downloads the artifacts to the node. The download also occurs when Infinispan Operator recreates pods after terminating them. |
-
Host your code artifacts on an HTTP or FTP server.
-
Add the
spec.dependencies.artifacts
field to yourInfinispan
CR.-
Specify the location of the file to download via
HTTP
orFTP
as the value of thespec.dependencies.artifacts.url
field. -
Optionally specify a checksum to verify the integrity of the download with the
spec.dependencies.artifacts.hash
field.The
hash
field requires a value is in the format of<algorithm>:<checksum>
where<algorithm>
issha1|sha224|sha256|sha384|sha512|md5
. -
Set the file type, if necessary, with the
spec.dependencies.artifacts.type
field.You should explicitly set the file type if it is not included in the URL or if the file type is actually different to the extension in the URL.
If you set
type: file
, Infinispan Operator downloads the file as-is without extracting it to the filesystem.apiVersion: infinispan.org/v1 kind: Infinispan metadata: name: infinispan spec: replicas: 2 dependencies: artifacts: - url: http://example.com:8080/path hash: sha256:596408848b56b5a23096baa110cd8b633c9a9aef2edd6b38943ade5b4edcd686 type: zip service: type: DataGrid
-
-
Apply the changes.
20. Sending cloud events from Infinispan clusters
Configure Infinispan as a Knative source by sending CloudEvents
to Apache Kafka topics.
20.1. Cloud events
You can send CloudEvents
from Infinispan clusters when entries in caches are created, updated, removed, or expired.
Infinispan sends structured events to Kafka in JSON format, as in the following example:
{
"specversion": "1.0",
"source": "/infinispan/<cluster_name>/<cache_name>",
"type": "org.infinispan.entry.created",
"time": "<timestamp>",
"subject": "<key-name>",
"id": "key-name:CommandInvocation:node-name:0",
"data": {
"property": "value"
}
}
Field | Description |
---|---|
|
Prefixes events for Infinispan cache entries with |
|
Entry value. |
|
Entry key, converted to string. |
|
Generated identifier for the event. |
20.2. Enabling cloud events
Configure Infinispan to send CloudEvents
.
-
Set up an Kafka cluster that listens for Infinispan topics.
-
Add
spec.cloudEvents
to yourInfinispan
CR.-
Configure the number of acknowledgements with the
spec.cloudEvents.acks
field. Values are "0", "1", or "all". -
List Kafka servers to which Infinispan sends events with the
spec.cloudEvents.bootstrapServers
field. -
Specify the Kafka topic for Infinispan events with the
spec.cloudEvents.cacheEntriesTopic
field.spec: cloudEvents: acks: "1" bootstrapServers: my-cluster-kafka-bootstrap_1.<namespace_1>.svc:9092,my-cluster-kafka-bootstrap_2.<namespace_2>.svc:9092 cacheEntriesTopic: target-topic
-
-
Apply your changes.
21. Establishing remote client connections
Connect to Infinispan clusters from the Infinispan Console, Command Line Interface (CLI), and remote clients.
21.1. Client connection details
Client connections to Infinispan require the following information:
-
Hostname
-
Port
-
Authentication credentials, if required
-
TLS certificate, if you use encryption
The hostname you use depends on whether clients are running on the same Kubernetes cluster as Infinispan.
Client applications running on the same Kubernetes cluster use the internal service name for the Infinispan cluster.
metadata:
name: infinispan
Client applications running on a different Kubernetes, or outside Kubernetes, use a hostname that depends on how Infinispan is exposed on the network.
A LoadBalancer
service uses the URL for the load balancer.
A NodePort
service uses the node hostname.
An Red Hat OpenShift Route
uses either a custom hostname that you define or a hostname that the system generates.
Client connections on Kubernetes and a through LoadBalancer
service use port 11222
.
NodePort
services use a port in the range of 30000
to 60000
.
Routes use either port 80
(unencrypted) or 443
(encrypted).
21.2. Connecting to Infinispan clusters with remote shells
Start a remote shell session to Infinispan clusters and use the command line interface (CLI) to work with Infinispan resources and perform administrative operations.
-
Have
kubectl-infinispan
on yourPATH
. -
Have valid Infinispan credentials.
-
Run the
infinispan shell
command to connect to your Infinispan cluster.kubectl infinispan shell <cluster_name>
If you have access to authentication secrets and there is only one Infinispan user the
kubectl-infinispan
plugin automatically detects your credentials and authenticates to Infinispan. If your deployment has multiple Infinispan credentials, specify a user with the--username
argument and enter the corresponding password when prompted. -
Perform CLI operations as required.
Press the tab key or use the
--help
argument to view available options and help text. -
Use the
quit
command to end the remote shell session.
21.3. Accessing Infinispan Console
Access the console to create caches, perform adminstrative operations, and monitor your Infinispan clusters.
-
Expose Infinispan on the network so you can access the console through a browser.
For example, configure aLoadBalancer
service or create aRoute
.
-
Access the console from any browser at
$HOSTNAME:$PORT
.Replace
$HOSTNAME:$PORT
with the network location where Infinispan is available.
21.4. Hot Rod clients
Hot Rod is a binary TCP protocol that Infinispan provides for high-performance data transfer capabilities with remote clients.
The Hot Rod protocol includes a mechanism that provides clients with an up-to-date view of the cache topology. Client intelligence improves performance by reducing the number of network hops for read and write operations.
Clients running in the same Kubernetes cluster can access internal IP addresses for Infinispan pods so you can use any client intelligence.
HASH_DISTRIBUTION_AWARE
is the default intelligence mechanism and enables clients to route requests to primary owners, which provides the best performance for Hot Rod clients.
BASIC
intelligenceHot Rod clients must use BASIC
intelligence in the following situations:
-
Connecting to Infinispan through a
LoadBalancer
,NodePort
, or OpenShiftRoute
. -
Failing over to a different Kubernetes cluster when using cross-site replication.
Kubernetes cluster administrators can define network policies that restrict traffic to Infinispan.
In some cases network isolation policies can require you to use BASIC
intelligence even when clients are running in the same Kubernetes cluster but a different namespace.
21.4.1. Hot Rod client configuration API
You can programmatically configure Hot Rod client connections with the ConfigurationBuilder
interface.
Replace
|
On Kubernetes
import org.infinispan.client.hotrod.configuration.ConfigurationBuilder;
import org.infinispan.client.hotrod.configuration.SaslQop;
import org.infinispan.client.hotrod.impl.ConfigurationProperties;
...
ConfigurationBuilder builder = new ConfigurationBuilder();
builder.addServer()
.host("$HOSTNAME")
.port(ConfigurationProperties.DEFAULT_HOTROD_PORT)
.security().authentication()
.username("username")
.password("changeme")
.realm("default")
.saslQop(SaslQop.AUTH)
.saslMechanism("SCRAM-SHA-512")
.ssl()
.sniHostName("$SERVICE_HOSTNAME")
.trustStoreFileName("/var/run/secrets/kubernetes.io/serviceaccount/service-ca.crt")
.trustStoreType("pem");
# Connection
infinispan.client.hotrod.server_list=$HOSTNAME:$PORT
# Authentication
infinispan.client.hotrod.use_auth=true
infinispan.client.hotrod.auth_username=developer
infinispan.client.hotrod.auth_password=$PASSWORD
infinispan.client.hotrod.auth_server_name=$CLUSTER_NAME
infinispan.client.hotrod.sasl_properties.javax.security.sasl.qop=auth
infinispan.client.hotrod.sasl_mechanism=SCRAM-SHA-512
# Encryption
infinispan.client.hotrod.sni_host_name=$SERVICE_HOSTNAME
infinispan.client.hotrod.trust_store_file_name=/var/run/secrets/kubernetes.io/serviceaccount/service-ca.crt
infinispan.client.hotrod.trust_store_type=pem
Outside Kubernetes
import org.infinispan.client.hotrod.configuration.ClientIntelligence;
import org.infinispan.client.hotrod.configuration.ConfigurationBuilder;
import org.infinispan.client.hotrod.configuration.SaslQop;
...
ConfigurationBuilder builder = new ConfigurationBuilder();
builder.addServer()
.host("$HOSTNAME")
.port("$PORT")
.security().authentication()
.username("username")
.password("changeme")
.realm("default")
.saslQop(SaslQop.AUTH)
.saslMechanism("SCRAM-SHA-512")
.ssl()
.sniHostName("$SERVICE_HOSTNAME")
//Create a client trust store with tls.crt from your project.
.trustStoreFileName("/path/to/truststore.pkcs12")
.trustStorePassword("trust_store_password")
.trustStoreType("PCKS12");
builder.clientIntelligence(ClientIntelligence.BASIC);
# Connection
infinispan.client.hotrod.server_list=$HOSTNAME:$PORT
# Client intelligence
infinispan.client.hotrod.client_intelligence=BASIC
# Authentication
infinispan.client.hotrod.use_auth=true
infinispan.client.hotrod.auth_username=developer
infinispan.client.hotrod.auth_password=$PASSWORD
infinispan.client.hotrod.auth_server_name=$CLUSTER_NAME
infinispan.client.hotrod.sasl_properties.javax.security.sasl.qop=auth
infinispan.client.hotrod.sasl_mechanism=SCRAM-SHA-512
# Encryption
infinispan.client.hotrod.sni_host_name=$SERVICE_HOSTNAME
# Create a client trust store with tls.crt from your project.
infinispan.client.hotrod.trust_store_file_name=/path/to/truststore.pkcs12
infinispan.client.hotrod.trust_store_password=trust_store_password
infinispan.client.hotrod.trust_store_type=PCKS12
21.4.2. Configuring Hot Rod clients for certificate authentication
If you enable client certificate authentication, clients must present valid certificates when negotiating connections with Infinispan.
If you use the Validate
strategy, you must configure clients with a keystore so they can present signed certificates.
You must also configure clients with Infinispan credentials and any suitable authentication mechanism.
If you use the Authenticate
strategy, you must configure clients with a keystore that contains signed certificates and valid Infinispan credentials as part of the distinguished name (DN).
Hot Rod clients must also use the EXTERNAL
authentication mechanism.
If you enable security authorization, you should assign the Common Name (CN) from the client certificate a role with the appropriate permissions. |
The following example shows a Hot Rod client configuration for client certificate authentication with the Authenticate
strategy:
import org.infinispan.client.hotrod.configuration.ConfigurationBuilder;
...
ConfigurationBuilder builder = new ConfigurationBuilder();
builder.security()
.authentication()
.saslMechanism("EXTERNAL")
.ssl()
.keyStoreFileName("/path/to/keystore")
.keyStorePassword("keystorepassword".toCharArray())
.keyStoreType("PCKS12");
21.4.3. Creating caches from Hot Rod clients
You can remotely create caches on Infinispan clusters running on Kubernetes with Hot Rod clients.
However, Infinispan recommends that you create caches using Infinispan Console, the CLI, or with Cache
CRs instead of with Hot Rod clients.
Programmatically creating caches
The following example shows how to add cache configurations to the ConfigurationBuilder
and then create them with the RemoteCacheManager
:
import org.infinispan.client.hotrod.DefaultTemplate;
import org.infinispan.client.hotrod.RemoteCache;
import org.infinispan.client.hotrod.RemoteCacheManager;
...
builder.remoteCache("my-cache")
.templateName(DefaultTemplate.DIST_SYNC);
builder.remoteCache("another-cache")
.configuration("<infinispan><cache-container><distributed-cache name=\"another-cache\"><encoding media-type=\"application/x-protostream\"/></distributed-cache></cache-container></infinispan>");
try (RemoteCacheManager cacheManager = new RemoteCacheManager(builder.build())) {
// Get a remote cache that does not exist.
// Rather than return null, create the cache from a template.
RemoteCache<String, String> cache = cacheManager.getCache("my-cache");
// Store a value.
cache.put("hello", "world");
// Retrieve the value and print it.
System.out.printf("key = %s\n", cache.get("hello"));
This example shows how to create a cache named CacheWithXMLConfiguration using the XMLStringConfiguration()
method to pass the cache configuration as XML:
import org.infinispan.client.hotrod.RemoteCacheManager;
import org.infinispan.commons.configuration.XMLStringConfiguration;
...
private void createCacheWithXMLConfiguration() {
String cacheName = "CacheWithXMLConfiguration";
String xml = String.format("<distributed-cache name=\"%s\">" +
"<encoding media-type=\"application/x-protostream\"/>" +
"<locking isolation=\"READ_COMMITTED\"/>" +
"<transaction mode=\"NON_XA\"/>" +
"<expiration lifespan=\"60000\" interval=\"20000\"/>" +
"</distributed-cache>"
, cacheName);
manager.administration().getOrCreateCache(cacheName, new XMLStringConfiguration(xml));
System.out.println("Cache with configuration exists or is created.");
}
Using Hot Rod client properties
When you invoke cacheManager.getCache()
calls for named caches that do not exist, Infinispan creates them from the Hot Rod client properties instead of returning null.
Add cache configuration to hotrod-client.properties
as in the following example:
# Add cache configuration
infinispan.client.hotrod.cache.my-cache.template_name=org.infinispan.DIST_SYNC
infinispan.client.hotrod.cache.another-cache.configuration=<infinispan><cache-container><distributed-cache name=\"another-cache\"/></cache-container></infinispan>
infinispan.client.hotrod.cache.my-other-cache.configuration_uri=file:/path/to/configuration.xml
21.5. Accessing the REST API
Infinispan provides a RESTful interface that you can interact with using HTTP clients.
-
Expose Infinispan on the network so you can access the REST API.
For example, configure aLoadBalancer
service or create aRoute
.
-
Access the REST API with any HTTP client at
$HOSTNAME:$PORT/rest/v2
.Replace
$HOSTNAME:$PORT
with the network location where Infinispan listens for client connections.