infinispan

Documentation

Index

• Constants
• func Add(mgr manager.Manager) error
• func AddVolumeChmodInitContainer(containerName, volumeName, mountPath string, spec *corev1.PodSpec)
• func AddVolumeForUserAuthentication(i *infinispanv1.Infinispan, spec *corev1.PodSpec) bool
• func AddVolumesForEncryption(i *infinispanv1.Infinispan, spec *corev1.PodSpec)
• func ConfigureServerEncryption(i *v1.Infinispan, c *config.InfinispanConfiguration, client client.Client) (*reconcile.Result, error)
• func HashByte(data []byte) string
• func HashMap(m map[string][]byte) string
• func LabelsResource(name, resourceType string) map[string]string
• func NewCluster(i *v1.Infinispan, kubernetes *kube.Kubernetes) (*ispn.Cluster, error)
• func NewHttpClient(i *v1.Infinispan, kubernetes *kube.Kubernetes) (client.HttpClient, error)
• func PodEnv(i *infinispanv1.Infinispan, systemEnv *[]corev1.EnvVar) []corev1.EnvVar
• func PodLabels(name string) map[string]string
• func PodLivenessProbe() *corev1.Probe
• func PodPorts() []corev1.ContainerPort
• func PodPortsWithXsite(i *infinispanv1.Infinispan) []corev1.ContainerPort
• func PodReadinessProbe() *corev1.Probe
• func PodResources(spec infinispanv1.InfinispanContainerSpec) (*corev1.ResourceRequirements, error)
• func PodStartupProbe() *corev1.Probe
• func ServiceLabels(name string) map[string]string
• type ReconcileInfinispan
  • func NewFakeReconciler(client client.Client, scheme *runtime.Scheme, fakeKubernetes *kube.Kubernetes, ...) ReconcileInfinispan
  • func (r *ReconcileInfinispan) GetClient() client.Client
  • func (r *ReconcileInfinispan) Reconcile(request reconcile.Request) (reconcile.Result, error)
• type SecondaryResourceType
• type UpdateFn

Constants

const (
	EncryptKeystoreName = "keystore.p12"
	EncryptKeystorePath = ServerRoot + "/conf/keystore"
)

const (
	ServerRoot                  = "/opt/infinispan/server"
	DataMountPath               = ServerRoot + "/data"
	DataMountVolume             = "data-volume"
	CustomLibrariesMountPath    = ServerRoot + "/lib/custom-libraries"
	CustomLibrariesVolumeName   = "custom-libraries"
	ConfigVolumeName            = "config-volume"
	EncryptKeystoreVolumeName   = "encrypt-volume"
	EncryptTruststoreVolumeName = "encrypt-trust-volume"
	IdentitiesVolumeName        = "identities-volume"
	AdminIdentitiesVolumeName   = "admin-identities-volume"
	ControllerName              = "controller_infinispan"

	EventReasonPrelimChecksFailed    = "PrelimChecksFailed"
	EventReasonLowPersistenceStorage = "LowPersistenceStorage"
	EventReasonEphemeralStorage      = "EphemeralStorageEnables"
	EventReasonParseValueProblem     = "ParseValueProblem"
	EventLoadBalancerUnsupported     = "LoadBalancerUnsupported"
)

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new Infinispan Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.

func AddVolumeChmodInitContainer

func AddVolumeChmodInitContainer(containerName, volumeName, mountPath string, spec *corev1.PodSpec)

Adding an init container that run chmod if needed

func AddVolumeForUserAuthentication

func AddVolumeForUserAuthentication(i *infinispanv1.Infinispan, spec *corev1.PodSpec) bool

Returns true if the volume has been added

func AddVolumesForEncryption

func AddVolumesForEncryption(i *infinispanv1.Infinispan, spec *corev1.PodSpec)

func ConfigureServerEncryption

func ConfigureServerEncryption(i *v1.Infinispan, c *config.InfinispanConfiguration, client client.Client) (*reconcile.Result, error)

func HashByte

func HashByte(data []byte) string

func HashMap

func HashMap(m map[string][]byte) string

func LabelsResource

func LabelsResource(name, resourceType string) map[string]string

LabelsResource returns the labels that must me applied to the resource

func NewCluster

func NewCluster(i *v1.Infinispan, kubernetes *kube.Kubernetes) (*ispn.Cluster, error)

func NewHttpClient

func NewHttpClient(i *v1.Infinispan, kubernetes *kube.Kubernetes) (client.HttpClient, error)

func PodEnv

func PodEnv(i *infinispanv1.Infinispan, systemEnv *[]corev1.EnvVar) []corev1.EnvVar

func PodLabels

func PodLabels(name string) map[string]string

func PodLivenessProbe

func PodLivenessProbe() *corev1.Probe

func PodPorts

func PodPorts() []corev1.ContainerPort

func PodPortsWithXsite

func PodPortsWithXsite(i *infinispanv1.Infinispan) []corev1.ContainerPort

func PodReadinessProbe

func PodReadinessProbe() *corev1.Probe

func PodResources

func PodResources(spec infinispanv1.InfinispanContainerSpec) (*corev1.ResourceRequirements, error)

func PodStartupProbe

func PodStartupProbe() *corev1.Probe

func ServiceLabels

func ServiceLabels(name string) map[string]string

Types

type ReconcileInfinispan

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

ReconcileInfinispan reconciles a Infinispan object

func NewFakeReconciler

func NewFakeReconciler(client client.Client, scheme *runtime.Scheme, fakeKubernetes *kube.Kubernetes, fakeCluster ispn.ClusterInterface) ReconcileInfinispan

NewFakeReconciler creates a new fake Reconciler for unit testing

func (*ReconcileInfinispan) GetClient

func (r *ReconcileInfinispan) GetClient() client.Client

GetClient returns Kubernetes client for unit testing

func (*ReconcileInfinispan) Reconcile

func (r *ReconcileInfinispan) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a Infinispan object and makes changes based on the state read and what is in the Infinispan.Spec Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.

type SecondaryResourceType

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

type UpdateFn

type UpdateFn func()

UpdateFn can contains logic required for Infinispan CR update. Mutations (Infinispan CR Spec and Status updates) are only possible in this function. All others updates outside this functions will be skipped.