controllers

package

Go to main page

Versions in this module

v1

v1.0.16

Nov 22, 2023

Changes in this version

+ const IngressTypePostfix

+ const PodNameLabelKey

+ const RouteTypePostfix

+ const ServiceTypePostfix

+ func EqualCRStatus(s1, s2 *brokerv1beta1.ActiveMQArtemisStatus) bool

type ActiveMQArtemisAddressReconciler

+ func NewActiveMQArtemisAddressReconciler(client client.Client, scheme *runtime.Scheme, logger logr.Logger) *ActiveMQArtemisAddressReconciler

type ActiveMQArtemisReconciler

+ func NewActiveMQArtemisReconciler(client rtclient.Client, scheme *runtime.Scheme, logger logr.Logger) *ActiveMQArtemisReconciler

+ func (r *ActiveMQArtemisReconciler) UpdateCRStatus(desired *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) error

type ActiveMQArtemisReconcilerImpl

+ func NewActiveMQArtemisReconcilerImpl(customResource *brokerv1beta1.ActiveMQArtemis, logger logr.Logger) *ActiveMQArtemisReconcilerImpl

+ func (r *ActiveMQArtemisReconcilerImpl) MakeVolumeMounts(customResource *brokerv1beta1.ActiveMQArtemis, namer common.Namers) []corev1.VolumeMount

+ func (r *ActiveMQArtemisReconcilerImpl) MakeVolumes(customResource *brokerv1beta1.ActiveMQArtemis, namer common.Namers) []corev1.Volume

+ func (reconciler *ActiveMQArtemisReconcilerImpl) NewPersistentVolumeClaimArrayForCR(customResource *brokerv1beta1.ActiveMQArtemis, namer common.Namers, ...) *[]corev1.PersistentVolumeClaim

+ func (reconciler *ActiveMQArtemisReconcilerImpl) ServiceDefinitionForCR(serviceName types.NamespacedName, client rtclient.Client, nameSuffix string, ...) *corev1.Service

type ActiveMQArtemisScaledownReconciler

+ func NewActiveMQArtemisScaledownReconciler(client client.Client, scheme *runtime.Scheme, config *rest.Config, ...) *ActiveMQArtemisScaledownReconciler

type ActiveMQArtemisSecurityReconciler

+ func NewActiveMQArtemisSecurityReconciler(client client.Client, scheme *runtime.Scheme, ...) *ActiveMQArtemisSecurityReconciler

type AddressRetry

+ func NewAddressRetry(addr string, a []*mgmt.Artemis, logger logr.Logger) *AddressRetry

v1.0.15

Aug 25, 2023

v1.0.14

Jul 21, 2023

Changes in this version

+ func ProcessBrokerStatus(cr *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) (retry bool)

+ func ProcessStatus(cr *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...)

type ActiveMQArtemisSecurityConfigHandler

+ func (r *ActiveMQArtemisSecurityConfigHandler) GetCRName() string

v1.0.13

Jun 27, 2023

v1.0.12

Jun 16, 2023

v1.0.11

Mar 22, 2023

Changes in this version

+ const BrokerImageKey

+ const InitImageKey

+ func AssertSecretContainsOneOf(secret corev1.Secret, keys []string, contextMessage string) *metav1.Condition

+ func UpdateStatus(cr *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...)

v1.0.10

Feb 8, 2023

v1.0.9

Feb 7, 2023

Changes in this version

+ func AssertSyntaxOkOnLoginConfigData(SecretContentForLoginConfigKey []byte) *metav1.Condition

+ func MatchBytesAgainsLoginConfigRegexp(buffer []byte) bool

v1.0.8

Feb 6, 2023

Changes in this version

+ const BrokerPropertiesName

+ const DefaultDeploymentSize

+ const JaasConfigKey

+ const LoggingConfigKey

+ const OrdinalPrefix

+ const OrdinalPrefixSep

+ func AssertConfigMapContainsKey(configMap corev1.ConfigMap, key string) *metav1.Condition

+ func AssertInstanceCounts(instanceCounts map[string]int) *metav1.Condition

+ func AssertSecretContainsKey(secret corev1.Secret, key string) *metav1.Condition

+ func NewInSyncWithError(ordinal string) *inSyncApplyError

+ func NewStatusOutOfSyncError(err error) statusOutOfSyncError

+ func NewStatusOutOfSyncErrorWith(brokerPropertiesName, expected, current string) statusOutOfSyncError

+ func NewStatusOutOfSyncMissingKeyError(err error) statusOutOfSyncMissingKeyError

type ArtemisError

+ func AssertBrokersAvailable(cr *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) ArtemisError

+ func AssertJaasPropertiesStatus(cr *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) ArtemisError

v1.0.7

Nov 25, 2022

Changes in this version

+ const StatusOutOfSyncError

+ func NewJolokiaClientsNotFoundError(err error) jolokiaClientNotFoundError

+ func NewUnknownJolokiaError(err error) unknownJolokiaError

+ func UpdateBrokerPropertiesStatus(cr *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) ctrl.Result

+ type ArtemisError interface

+ Error func() string

+ Requeue func() bool

+ func AssertBrokerPropertiesStatus(cr *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) ArtemisError

v1.0.6

Oct 28, 2022

Changes in this version

+ const ImageNamePrefix

+ func AppendStatus(data map[string]string, shaOfMap string) map[string]string

+ func UpdateCRStatus(cr *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) error

v1.0.5

Sep 14, 2022

v1.0.4

Jul 11, 2022

Changes in this version

+ const AnnotationDrainerPodTemplate

+ const AnnotationStatefulSet

+ const TCPLivenessPort

+ var StopCh chan struct

+ func GetBrokerConfigHandler(brokerNamespacedName types.NamespacedName) (handler common.ActiveMQArtemisConfigHandler)

+ func GetDefaultLabels(cr *brokerv1beta1.ActiveMQArtemis) map[string]string

+ func GetPodStatus(cr *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) olm.DeploymentStatus

+ func GetQueueConfig(addressRes *brokerv1beta1.ActiveMQArtemisAddress) (string, bool, error)

+ func GetStatefulSetNameForPod(client client.Client, pod *types.NamespacedName) (string, int, map[string]string)

+ func HexShaHashOfMap(props []string) string

+ func MajorMinorMicro(productVersion string) (major, minor, micro string)

+ func MakeContainerPorts(cr *brokerv1beta1.ActiveMQArtemis) []corev1.ContainerPort

+ func MakeEnvVarArrayForCR(customResource *brokerv1beta1.ActiveMQArtemis, namer Namers) []corev1.EnvVar

+ func MakeVolumeMounts(customResource *brokerv1beta1.ActiveMQArtemis, namer Namers) []corev1.VolumeMount

+ func MakeVolumes(customResource *brokerv1beta1.ActiveMQArtemis, namer Namers) []corev1.Volume

+ func NewPersistentVolumeClaimArrayForCR(customResource *brokerv1beta1.ActiveMQArtemis, namer Namers, arrayLength int) *[]corev1.PersistentVolumeClaim

+ func ReleaseController(brokerCRName string)

+ func UpdatePodStatus(cr *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) error

+ type ActiveMQArtemisAddressReconciler struct

+ Scheme *runtime.Scheme

+ func (r *ActiveMQArtemisAddressReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

+ func (r *ActiveMQArtemisAddressReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type ActiveMQArtemisIReconciler interface

+ Process func(customResource *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) uint32

+ ProcessAcceptorsAndConnectors func(customResource *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) uint32

+ ProcessConsole func(customResource *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...)

+ ProcessCredentials func(customResource *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) uint32

+ ProcessDeploymentPlan func(customResource *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) uint32

+ ProcessResources func(customResource *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) uint8

+ ProcessStatefulSet func(customResource *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) (*appsv1.StatefulSet, bool)

+ type ActiveMQArtemisQueueConfiguration struct

+ Address *string

+ AutoCreateAddress *bool

+ AutoDelete *bool

+ AutoDeleteDelay *int64

+ AutoDeleteMessageCount *int64

+ ConfigurationManaged *bool

+ ConsumerPriority *int32

+ ConsumersBeforeDispatch *int32

+ DelayBeforeDispatch *int64

+ Durable *bool

+ Enabled *bool

+ Exclusive *bool

+ FilterString *string

+ GroupBuckets *int32

+ GroupFirstKey *string

+ GroupRebalance *bool

+ GroupRebalancePauseDispatch *bool

+ Id *int64

+ Internal *bool

+ LastValue *bool

+ LastValueKey *string

+ MaxConsumers *int32

+ Name *string

+ NonDestructive *bool

+ PurgeOnNoConsumers *bool

+ RingSize *int64

+ RoutingType *string

+ Temporary *bool

+ Transient *bool

+ User *string

+ type ActiveMQArtemisReconciler struct

+ Scheme *runtime.Scheme

+ func NewReconcileActiveMQArtemis(c client.Client, s *runtime.Scheme) ActiveMQArtemisReconciler

+ func (r *ActiveMQArtemisReconciler) AddBrokerConfigHandler(namespacedName types.NamespacedName, ...) error

+ func (r *ActiveMQArtemisReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

+ func (r *ActiveMQArtemisReconciler) RemoveBrokerConfigHandler(namespacedName types.NamespacedName)

+ func (r *ActiveMQArtemisReconciler) SetupWithManager(mgr ctrl.Manager) error

+ func (r *ActiveMQArtemisReconciler) UpdatePodForSecurity(securityHandlerNamespacedName types.NamespacedName, ...) error

+ type ActiveMQArtemisReconcilerImpl struct

+ func (reconciler *ActiveMQArtemisReconcilerImpl) CurrentDeployedResources(customResource *brokerv1beta1.ActiveMQArtemis, client rtclient.Client)

+ func (reconciler *ActiveMQArtemisReconcilerImpl) ExposureDefinitionForCR(namespacedName types.NamespacedName, labels map[string]string, ...) rtclient.Object

+ func (reconciler *ActiveMQArtemisReconcilerImpl) NewPodTemplateSpecForCR(customResource *brokerv1beta1.ActiveMQArtemis, namer Namers, ...) *corev1.PodTemplateSpec

+ func (reconciler *ActiveMQArtemisReconcilerImpl) NewStatefulSetForCR(customResource *brokerv1beta1.ActiveMQArtemis, namer Namers, ...) *appsv1.StatefulSet

+ func (reconciler *ActiveMQArtemisReconcilerImpl) Process(customResource *brokerv1beta1.ActiveMQArtemis, namer Namers, ...) bool

+ func (reconciler *ActiveMQArtemisReconcilerImpl) ProcessAcceptorsAndConnectors(customResource *brokerv1beta1.ActiveMQArtemis, namer Namers, ...)

+ func (reconciler *ActiveMQArtemisReconcilerImpl) ProcessConsole(customResource *brokerv1beta1.ActiveMQArtemis, namer Namers, ...)

+ func (reconciler *ActiveMQArtemisReconcilerImpl) ProcessCredentials(customResource *brokerv1beta1.ActiveMQArtemis, namer Namers, ...)

+ func (reconciler *ActiveMQArtemisReconcilerImpl) ProcessDeploymentPlan(customResource *brokerv1beta1.ActiveMQArtemis, namer Namers, ...)

+ func (reconciler *ActiveMQArtemisReconcilerImpl) ProcessResources(customResource *brokerv1beta1.ActiveMQArtemis, client rtclient.Client, ...) error

+ func (reconciler *ActiveMQArtemisReconcilerImpl) ProcessStatefulSet(customResource *brokerv1beta1.ActiveMQArtemis, namer Namers, ...) *appsv1.StatefulSet

+ type ActiveMQArtemisScaledownReconciler struct

+ Config *rest.Config

+ Scheme *runtime.Scheme

+ func (r *ActiveMQArtemisScaledownReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

+ func (r *ActiveMQArtemisScaledownReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type ActiveMQArtemisSecurityConfigHandler struct

+ NamespacedName types.NamespacedName

+ SecurityCR *brokerv1beta1.ActiveMQArtemisSecurity

+ func (r *ActiveMQArtemisSecurityConfigHandler) Config(initContainers []corev1.Container, outputDirRoot string, ...) (value []string)

+ func (r *ActiveMQArtemisSecurityConfigHandler) GetDefaultLabels() map[string]string

+ func (r *ActiveMQArtemisSecurityConfigHandler) IsApplicableFor(brokerNamespacedName types.NamespacedName) bool

+ type ActiveMQArtemisSecurityReconciler struct

+ BrokerReconciler *ActiveMQArtemisReconciler

+ Scheme *runtime.Scheme

+ func (r *ActiveMQArtemisSecurityReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

+ func (r *ActiveMQArtemisSecurityReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type AddressDeployment struct

+ AddressResource brokerv1beta1.ActiveMQArtemisAddress

+ SsTargetNameBuilders []SSInfoData

+ type AddressObserver struct

+ func NewAddressObserver(kubeclientset kubernetes.Interface, client client.Client, ...) *AddressObserver

+ func (c *AddressObserver) Run(C chan types.NamespacedName) error

+ type AddressRetry struct

+ type JkInfo struct

+ Artemis *mgmt.Artemis

+ IP string

+ type Namers struct

+ GLOBAL_DATA_PATH string

+ LabelBuilder selectors.LabelerData

+ PodsNameBuilder namer.NamerData

+ SecretsConsoleNameBuilder namer.NamerData

+ SecretsCredentialsNameBuilder namer.NamerData

+ SecretsNettyNameBuilder namer.NamerData

+ SsGlobalName string

+ SsNameBuilder namer.NamerData

+ SvcHeadlessNameBuilder namer.NamerData

+ SvcPingNameBuilder namer.NamerData

+ func MakeNamers(customResource *brokerv1beta1.ActiveMQArtemis) *Namers

+ type SSInfoData struct

+ Labels map[string]string

+ NameBuilder namer.NamerData

+ type StatefulSetInfo struct

+ Labels map[string]string

+ NamespacedName types.NamespacedName

+ func GetDeployedStatefuleSetNames(client client.Client, targetCrNames []types.NamespacedName) []StatefulSetInfo

+ type ValueInfo struct

+ AutoGen bool

+ Internal bool

+ Value string

v1.0.3

Jun 7, 2022

v1.0.2

May 9, 2022

v1.0.1

Apr 11, 2022

v1.0.0

Feb 15, 2022

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