common

Nov 22, 2023

Changes in this version

+ const BrokerImageKey

+ const DefaultDeploymentSize

+ const ImageNamePrefix

+ const InitImageKey

+ func DetectOpenshift() (bool, error)

+ func DetermineCompactVersionToUse(customResource *brokerv1beta1.ActiveMQArtemis) (string, error)

+ func DetermineImageToUse(customResource *brokerv1beta1.ActiveMQArtemis, imageTypeKey string) string

+ func GetDeployedResources(instance *brokerv1beta1.ActiveMQArtemis, client rtclient.Client) (map[reflect.Type][]rtclient.Object, error)

+ func GetDeploymentSize(cr *brokerv1beta1.ActiveMQArtemis) int32

+ func GetSingleStatefulSetStatus(ss *appsv1.StatefulSet, cr *brokerv1beta1.ActiveMQArtemis) olm.DeploymentStatus

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

+ func ResolveBrokerVersionFromCR(cr *brokerv1beta1.ActiveMQArtemis) (string, error)

+ func ResolveImage(customResource *brokerv1beta1.ActiveMQArtemis, key string) string

+ func ValidateBrokerVersion(customResource *brokerv1beta1.ActiveMQArtemis) *metav1.Condition

+ 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

Jul 21, 2023

Changes in this version

type ActiveMQArtemisConfigHandler

+ GetCRName func() string

+ type BufferWriter struct

+ Buffer *bytes.Buffer

+ func (w BufferWriter) Write(p []byte) (int, error)

Jun 16, 2023

Changes in this version

+ var ClusterDomain *string

+ func GetClusterDomain() string

Mar 22, 2023

Changes in this version

+ const ConfigAppliedConditionOutOfSyncMessage

+ const DeployedConditionZeroSizeMessage

+ const ImageDependentPairMessage

Feb 7, 2023

Changes in this version

+ const JaasConfigSyntaxMatchRegExDefault

+ func GetJaasConfigSyntaxMatchRegEx() string

Feb 6, 2023

Changes in this version

+ const ImageVersionConflictMessage

+ const PDBNonNilSelectorMessage

+ const ValidConditionFailedExtraMountReason

+ const ValidConditionFailedReservedLabelReason

+ const ValidConditionImageVersionConflictReason

+ const ValidConditionPDBNonNilSelectorReason

+ func Int32ToPtr(v int32) *int32

+ func ResolveBrokerVersion(existingVersions map[string]*semver.Version, expected *semver.Version) *semver.Version

+ type BrokerVersion struct

+ Version *semver.Version

+ func NewBrokerVersion(ver *semver.Version) *BrokerVersion

+ func (bver *BrokerVersion) IsMatch(ver *semver.Version) bool

+ func (bver *BrokerVersion) MajorOnly() bool

+ func (bver *BrokerVersion) MinorOnly() bool

Nov 25, 2022

Changes in this version

+ const ValidConditionFailedReason

+ const ValidConditionMissingResourcesReason

+ const ValidConditionSuccessReason

+ const ValidConditionType

Oct 28, 2022

Changes in this version

+ const NotReadyConditionMessage

+ const NotReadyConditionReason

+ const ReadyConditionReason

+ const ReadyConditionType

+ func IsConditionPresentAndEqual(conditions []metav1.Condition, condition metav1.Condition) bool

+ func SetReadyCondition(conditions *[]metav1.Condition)

Jul 11, 2022

Changes in this version

+ const DEFAULT_RESYNC_PERIOD

+ const OpenShiftAPIServerKind

+ const RouteKind

+ func CompareRequiredResources(res1 *corev1.ResourceRequirements, res2 *corev1.ResourceRequirements) bool

+ func FromJson(jsonStr *string, obj interface{}) error

+ func GetManager() manager.Manager

+ func GetReconcileResyncPeriod() time.Duration

+ func NewTrue() *bool

+ func ResolveWatchNamespaceForManager(oprNamespace string, watchNamespace string) (bool, []string)

+ func ResourceExists(dc discovery.DiscoveryInterface, apiGroupVersion, kind string) (bool, error)

+ func SetManager(mgr manager.Manager)

+ func ToJson(obj interface{}) (string, error)

+ type ActiveMQArtemisConfigHandler interface

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

+ IsApplicableFor func(brokerNamespacedName types.NamespacedName) bool

+ type AutoDetector struct

+ func NewAutoDetect(mgr manager.Manager) (*AutoDetector, error)

+ func (b *AutoDetector) DetectOpenshift() error

+ type StateManager struct

+ func GetStateManager() *StateManager

+ func (sm *StateManager) Clear()

+ func (sm *StateManager) GetState(key string) interface{}

+ func (sm *StateManager) SetState(key string, value interface{})