Documentation
¶
Overview ¶
Package v1beta1 contains API Schema definitions for the broker v1beta1 API group +kubebuilder:object:generate=true +groupName=broker.amq.io
Index ¶
- Constants
- Variables
- type AcceptorType
- type ActiveMQArtemis
- func (in *ActiveMQArtemis) DeepCopy() *ActiveMQArtemis
- func (in *ActiveMQArtemis) DeepCopyInto(out *ActiveMQArtemis)
- func (in *ActiveMQArtemis) DeepCopyObject() runtime.Object
- func (r *ActiveMQArtemis) Default()
- func (r *ActiveMQArtemis) Hub()
- func (r *ActiveMQArtemis) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *ActiveMQArtemis) ValidateCreate() error
- func (r *ActiveMQArtemis) ValidateDelete() error
- func (r *ActiveMQArtemis) ValidateUpdate(old runtime.Object) error
- type ActiveMQArtemisAddress
- func (in *ActiveMQArtemisAddress) DeepCopy() *ActiveMQArtemisAddress
- func (in *ActiveMQArtemisAddress) DeepCopyInto(out *ActiveMQArtemisAddress)
- func (in *ActiveMQArtemisAddress) DeepCopyObject() runtime.Object
- func (r *ActiveMQArtemisAddress) Default()
- func (r *ActiveMQArtemisAddress) Hub()
- func (r *ActiveMQArtemisAddress) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *ActiveMQArtemisAddress) ValidateCreate() error
- func (r *ActiveMQArtemisAddress) ValidateDelete() error
- func (r *ActiveMQArtemisAddress) ValidateUpdate(old runtime.Object) error
- type ActiveMQArtemisAddressList
- type ActiveMQArtemisAddressSpec
- type ActiveMQArtemisAddressStatus
- type ActiveMQArtemisList
- type ActiveMQArtemisScaledown
- type ActiveMQArtemisScaledownList
- type ActiveMQArtemisScaledownSpec
- type ActiveMQArtemisScaledownStatus
- type ActiveMQArtemisSecurity
- func (in *ActiveMQArtemisSecurity) DeepCopy() *ActiveMQArtemisSecurity
- func (in *ActiveMQArtemisSecurity) DeepCopyInto(out *ActiveMQArtemisSecurity)
- func (in *ActiveMQArtemisSecurity) DeepCopyObject() runtime.Object
- func (r *ActiveMQArtemisSecurity) Default()
- func (r *ActiveMQArtemisSecurity) Hub()
- func (r *ActiveMQArtemisSecurity) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *ActiveMQArtemisSecurity) ValidateCreate() error
- func (r *ActiveMQArtemisSecurity) ValidateDelete() error
- func (r *ActiveMQArtemisSecurity) ValidateUpdate(old runtime.Object) error
- type ActiveMQArtemisSecurityList
- type ActiveMQArtemisSecuritySpec
- type ActiveMQArtemisSecurityStatus
- type ActiveMQArtemisSpec
- type ActiveMQArtemisStatus
- type ActiveMQArtemisUpgrades
- type AddressSettingType
- type AddressSettingsType
- type AllowedListEntryType
- type AuthorisationConfigType
- type BrokerDomainType
- type BrokerSecuritySettingType
- type ConnectorConfigType
- type ConnectorType
- type ConsoleType
- type DefaultAccessType
- type DeploymentPlanType
- type ExtraMountsType
- type GuestLoginModuleType
- type KeyValueType
- type KeycloakLoginModuleType
- type KeycloakModuleConfigurationType
- type LoginModuleReferenceType
- type LoginModulesType
- type ManagementSecuritySettingsType
- type PermissionType
- type PodSecurityType
- type PropertiesLoginModuleType
- type QueueConfigurationType
- type RoleAccessType
- type SecurityDomainsType
- type SecuritySettingsType
- type StorageType
- type UserType
Constants ¶
const ( DeployedConditionType = "Deployed" DeployedConditionReadyReason = "AllPodsReady" DeployedConditionNotReadyReason = "PodsNotReady" DeployedConditionZeroSizeReason = "ZeroSizeDeployment" DeployedConditionZeroSizeMessage = "Pods not scheduled. Deployment size is 0" ValidConditionType = "Valid" ValidConditionSuccessReason = "ValidationSucceeded" ValidConditionFailedReservedLabelReason = "ReservedLabelReference" )
Variables ¶
var ( // GroupVersion is group version used to register these objects GroupVersion = schema.GroupVersion{Group: "broker.amq.io", Version: "v1beta1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion} // AddToScheme adds the types in this group-version to the given scheme. AddToScheme = SchemeBuilder.AddToScheme )
Functions ¶
This section is empty.
Types ¶
type AcceptorType ¶
type AcceptorType struct {
Name string `json:"name"`
// Port number
Port int32 `json:"port,omitempty"`
// The protocols to enable for this acceptor
Protocols string `json:"protocols,omitempty"`
// Whether or not to enable SSL on this port
SSLEnabled bool `json:"sslEnabled,omitempty"`
// Name of the secret to use for ssl information
SSLSecret string `json:"sslSecret,omitempty"`
// Comma separated list of cipher suites used for SSL communication.
EnabledCipherSuites string `json:"enabledCipherSuites,omitempty"`
// Comma separated list of protocols used for SSL communication.
EnabledProtocols string `json:"enabledProtocols,omitempty"`
// Tells a client connecting to this acceptor that 2-way SSL is required. This property takes precedence over wantClientAuth.
NeedClientAuth bool `json:"needClientAuth,omitempty"`
// Tells a client connecting to this acceptor that 2-way SSL is requested but not required. Overridden by needClientAuth.
WantClientAuth bool `json:"wantClientAuth,omitempty"`
// The CN of the connecting client's SSL certificate will be compared to its hostname to verify they match. This is useful only for 2-way SSL.
VerifyHost bool `json:"verifyHost,omitempty"`
// Used to change the SSL Provider between JDK and OPENSSL. The default is JDK.
SSLProvider string `json:"sslProvider,omitempty"`
// A regular expression used to match the server_name extension on incoming SSL connections. If the name doesn't match then the connection to the acceptor will be rejected.
SNIHost string `json:"sniHost,omitempty"`
// Whether or not to expose this acceptor
Expose bool `json:"expose,omitempty"`
// To indicate which kind of routing type to use.
AnycastPrefix string `json:"anycastPrefix,omitempty"`
// To indicate which kind of routing type to use
MulticastPrefix string `json:"multicastPrefix,omitempty"`
// Max number of connections allowed to make
ConnectionsAllowed int `json:"connectionsAllowed,omitempty"`
// AMQP Minimum Large Message Size
AMQPMinLargeMessageSize int `json:"amqpMinLargeMessageSize,omitempty"`
// For openwire protocol if advisory topics are enabled, default false
SupportAdvisory *bool `json:"supportAdvisory,omitempty"`
// If prevents advisory addresses/queues to be registered to management service, default false
SuppressInternalManagementObjects *bool `json:"suppressInternalManagementObjects,omitempty"`
// Whether to let the acceptor to bind to all interfaces (0.0.0.0)
BindToAllInterfaces *bool `json:"bindToAllInterfaces,omitempty"`
// Provider used for the keystore; "SUN", "SunJCE", etc. Default is null
KeyStoreProvider string `json:"keyStoreProvider,omitempty"`
// Type of truststore being used; "JKS", "JCEKS", "PKCS12", etc. Default in broker is "JKS"
TrustStoreType string `json:"trustStoreType,omitempty"`
// Provider used for the truststore; "SUN", "SunJCE", etc. Default in broker is null
TrustStoreProvider string `json:"trustStoreProvider,omitempty"`
}
func (*AcceptorType) DeepCopy ¶
func (in *AcceptorType) DeepCopy() *AcceptorType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AcceptorType.
func (*AcceptorType) DeepCopyInto ¶
func (in *AcceptorType) DeepCopyInto(out *AcceptorType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ActiveMQArtemis ¶
type ActiveMQArtemis struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec ActiveMQArtemisSpec `json:"spec,omitempty"`
Status ActiveMQArtemisStatus `json:"status,omitempty"`
}
ActiveMQArtemis is the Schema for the activemqartemises API
func (*ActiveMQArtemis) DeepCopy ¶
func (in *ActiveMQArtemis) DeepCopy() *ActiveMQArtemis
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemis.
func (*ActiveMQArtemis) DeepCopyInto ¶
func (in *ActiveMQArtemis) DeepCopyInto(out *ActiveMQArtemis)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ActiveMQArtemis) DeepCopyObject ¶
func (in *ActiveMQArtemis) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ActiveMQArtemis) Default ¶
func (r *ActiveMQArtemis) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*ActiveMQArtemis) Hub ¶
func (r *ActiveMQArtemis) Hub()
func (*ActiveMQArtemis) SetupWebhookWithManager ¶
func (r *ActiveMQArtemis) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*ActiveMQArtemis) ValidateCreate ¶
func (r *ActiveMQArtemis) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*ActiveMQArtemis) ValidateDelete ¶
func (r *ActiveMQArtemis) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*ActiveMQArtemis) ValidateUpdate ¶
func (r *ActiveMQArtemis) ValidateUpdate(old runtime.Object) error
ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
type ActiveMQArtemisAddress ¶
type ActiveMQArtemisAddress struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec ActiveMQArtemisAddressSpec `json:"spec,omitempty"`
Status ActiveMQArtemisAddressStatus `json:"status,omitempty"`
}
ActiveMQArtemisAddress is the Schema for the activemqartemisaddresses API
func (*ActiveMQArtemisAddress) DeepCopy ¶
func (in *ActiveMQArtemisAddress) DeepCopy() *ActiveMQArtemisAddress
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisAddress.
func (*ActiveMQArtemisAddress) DeepCopyInto ¶
func (in *ActiveMQArtemisAddress) DeepCopyInto(out *ActiveMQArtemisAddress)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ActiveMQArtemisAddress) DeepCopyObject ¶
func (in *ActiveMQArtemisAddress) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ActiveMQArtemisAddress) Default ¶
func (r *ActiveMQArtemisAddress) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*ActiveMQArtemisAddress) Hub ¶
func (r *ActiveMQArtemisAddress) Hub()
func (*ActiveMQArtemisAddress) SetupWebhookWithManager ¶
func (r *ActiveMQArtemisAddress) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*ActiveMQArtemisAddress) ValidateCreate ¶
func (r *ActiveMQArtemisAddress) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*ActiveMQArtemisAddress) ValidateDelete ¶
func (r *ActiveMQArtemisAddress) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*ActiveMQArtemisAddress) ValidateUpdate ¶
func (r *ActiveMQArtemisAddress) ValidateUpdate(old runtime.Object) error
ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
type ActiveMQArtemisAddressList ¶
type ActiveMQArtemisAddressList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []ActiveMQArtemisAddress `json:"items"`
}
ActiveMQArtemisAddressList contains a list of ActiveMQArtemisAddress
func (*ActiveMQArtemisAddressList) DeepCopy ¶
func (in *ActiveMQArtemisAddressList) DeepCopy() *ActiveMQArtemisAddressList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisAddressList.
func (*ActiveMQArtemisAddressList) DeepCopyInto ¶
func (in *ActiveMQArtemisAddressList) DeepCopyInto(out *ActiveMQArtemisAddressList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ActiveMQArtemisAddressList) DeepCopyObject ¶
func (in *ActiveMQArtemisAddressList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ActiveMQArtemisAddressSpec ¶
type ActiveMQArtemisAddressSpec struct {
// Address Name
AddressName string `json:"addressName,omitempty"`
// Queue Name
QueueName *string `json:"queueName,omitempty"`
// The Routing Type
RoutingType *string `json:"routingType,omitempty"`
// Whether or not delete the queue from broker when CR is undeployed(default false)
RemoveFromBrokerOnDelete bool `json:"removeFromBrokerOnDelete,omitempty"`
// User name for creating the queue or address
User *string `json:"user,omitempty"`
// The user's password
Password *string `json:"password,omitempty"`
QueueConfiguration *QueueConfigurationType `json:"queueConfiguration,omitempty"`
// Apply to the broker crs in the current namespace. A value of * or empty string means applying to all broker crs. Default apply to all broker crs
ApplyToCrNames []string `json:"applyToCrNames,omitempty"`
}
ActiveMQArtemisAddressSpec defines the desired state of ActiveMQArtemisAddress
func (*ActiveMQArtemisAddressSpec) DeepCopy ¶
func (in *ActiveMQArtemisAddressSpec) DeepCopy() *ActiveMQArtemisAddressSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisAddressSpec.
func (*ActiveMQArtemisAddressSpec) DeepCopyInto ¶
func (in *ActiveMQArtemisAddressSpec) DeepCopyInto(out *ActiveMQArtemisAddressSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ActiveMQArtemisAddressStatus ¶
type ActiveMQArtemisAddressStatus struct {
}
ActiveMQArtemisAddressStatus defines the observed state of ActiveMQArtemisAddress
func (*ActiveMQArtemisAddressStatus) DeepCopy ¶
func (in *ActiveMQArtemisAddressStatus) DeepCopy() *ActiveMQArtemisAddressStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisAddressStatus.
func (*ActiveMQArtemisAddressStatus) DeepCopyInto ¶
func (in *ActiveMQArtemisAddressStatus) DeepCopyInto(out *ActiveMQArtemisAddressStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ActiveMQArtemisList ¶
type ActiveMQArtemisList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []ActiveMQArtemis `json:"items"`
}
ActiveMQArtemisList contains a list of ActiveMQArtemis
func (*ActiveMQArtemisList) DeepCopy ¶
func (in *ActiveMQArtemisList) DeepCopy() *ActiveMQArtemisList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisList.
func (*ActiveMQArtemisList) DeepCopyInto ¶
func (in *ActiveMQArtemisList) DeepCopyInto(out *ActiveMQArtemisList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ActiveMQArtemisList) DeepCopyObject ¶
func (in *ActiveMQArtemisList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ActiveMQArtemisScaledown ¶
type ActiveMQArtemisScaledown struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec ActiveMQArtemisScaledownSpec `json:"spec,omitempty"`
Status ActiveMQArtemisScaledownStatus `json:"status,omitempty"`
}
ActiveMQArtemisScaledown is the Schema for the activemqartemisscaledowns API
func (*ActiveMQArtemisScaledown) DeepCopy ¶
func (in *ActiveMQArtemisScaledown) DeepCopy() *ActiveMQArtemisScaledown
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisScaledown.
func (*ActiveMQArtemisScaledown) DeepCopyInto ¶
func (in *ActiveMQArtemisScaledown) DeepCopyInto(out *ActiveMQArtemisScaledown)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ActiveMQArtemisScaledown) DeepCopyObject ¶
func (in *ActiveMQArtemisScaledown) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ActiveMQArtemisScaledownList ¶
type ActiveMQArtemisScaledownList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []ActiveMQArtemisScaledown `json:"items"`
}
ActiveMQArtemisScaledownList contains a list of ActiveMQArtemisScaledown
func (*ActiveMQArtemisScaledownList) DeepCopy ¶
func (in *ActiveMQArtemisScaledownList) DeepCopy() *ActiveMQArtemisScaledownList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisScaledownList.
func (*ActiveMQArtemisScaledownList) DeepCopyInto ¶
func (in *ActiveMQArtemisScaledownList) DeepCopyInto(out *ActiveMQArtemisScaledownList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ActiveMQArtemisScaledownList) DeepCopyObject ¶
func (in *ActiveMQArtemisScaledownList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ActiveMQArtemisScaledownSpec ¶
type ActiveMQArtemisScaledownSpec struct {
// Triggered by main ActiveMQArtemis CRD messageMigration entry
LocalOnly bool `json:"localOnly"`
Resources corev1.ResourceRequirements `json:"resources,omitempty"`
}
ActiveMQArtemisScaledownSpec defines the desired state of ActiveMQArtemisScaledown
func (*ActiveMQArtemisScaledownSpec) DeepCopy ¶
func (in *ActiveMQArtemisScaledownSpec) DeepCopy() *ActiveMQArtemisScaledownSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisScaledownSpec.
func (*ActiveMQArtemisScaledownSpec) DeepCopyInto ¶
func (in *ActiveMQArtemisScaledownSpec) DeepCopyInto(out *ActiveMQArtemisScaledownSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ActiveMQArtemisScaledownStatus ¶
type ActiveMQArtemisScaledownStatus struct {
}
ActiveMQArtemisScaledownStatus defines the observed state of ActiveMQArtemisScaledown
func (*ActiveMQArtemisScaledownStatus) DeepCopy ¶
func (in *ActiveMQArtemisScaledownStatus) DeepCopy() *ActiveMQArtemisScaledownStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisScaledownStatus.
func (*ActiveMQArtemisScaledownStatus) DeepCopyInto ¶
func (in *ActiveMQArtemisScaledownStatus) DeepCopyInto(out *ActiveMQArtemisScaledownStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ActiveMQArtemisSecurity ¶
type ActiveMQArtemisSecurity struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec ActiveMQArtemisSecuritySpec `json:"spec,omitempty"`
Status ActiveMQArtemisSecurityStatus `json:"status,omitempty"`
}
ActiveMQArtemisSecurity is the Schema for the activemqartemissecurities API
func (*ActiveMQArtemisSecurity) DeepCopy ¶
func (in *ActiveMQArtemisSecurity) DeepCopy() *ActiveMQArtemisSecurity
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisSecurity.
func (*ActiveMQArtemisSecurity) DeepCopyInto ¶
func (in *ActiveMQArtemisSecurity) DeepCopyInto(out *ActiveMQArtemisSecurity)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ActiveMQArtemisSecurity) DeepCopyObject ¶
func (in *ActiveMQArtemisSecurity) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ActiveMQArtemisSecurity) Default ¶
func (r *ActiveMQArtemisSecurity) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*ActiveMQArtemisSecurity) Hub ¶
func (r *ActiveMQArtemisSecurity) Hub()
func (*ActiveMQArtemisSecurity) SetupWebhookWithManager ¶
func (r *ActiveMQArtemisSecurity) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*ActiveMQArtemisSecurity) ValidateCreate ¶
func (r *ActiveMQArtemisSecurity) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*ActiveMQArtemisSecurity) ValidateDelete ¶
func (r *ActiveMQArtemisSecurity) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*ActiveMQArtemisSecurity) ValidateUpdate ¶
func (r *ActiveMQArtemisSecurity) ValidateUpdate(old runtime.Object) error
ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
type ActiveMQArtemisSecurityList ¶
type ActiveMQArtemisSecurityList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []ActiveMQArtemisSecurity `json:"items"`
}
ActiveMQArtemisSecurityList contains a list of ActiveMQArtemisSecurity
func (*ActiveMQArtemisSecurityList) DeepCopy ¶
func (in *ActiveMQArtemisSecurityList) DeepCopy() *ActiveMQArtemisSecurityList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisSecurityList.
func (*ActiveMQArtemisSecurityList) DeepCopyInto ¶
func (in *ActiveMQArtemisSecurityList) DeepCopyInto(out *ActiveMQArtemisSecurityList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ActiveMQArtemisSecurityList) DeepCopyObject ¶
func (in *ActiveMQArtemisSecurityList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ActiveMQArtemisSecuritySpec ¶
type ActiveMQArtemisSecuritySpec struct {
LoginModules LoginModulesType `json:"loginModules,omitempty"`
SecurityDomains SecurityDomainsType `json:"securityDomains,omitempty"`
SecuritySettings SecuritySettingsType `json:"securitySettings,omitempty"`
// Apply this security config to the broker crs in the current namespace. A value of * or empty string means applying to all broker crs. Default apply to all broker crs
ApplyToCrNames []string `json:"applyToCrNames,omitempty"`
}
ActiveMQArtemisSecuritySpec defines the desired state of ActiveMQArtemisSecurity
func (*ActiveMQArtemisSecuritySpec) DeepCopy ¶
func (in *ActiveMQArtemisSecuritySpec) DeepCopy() *ActiveMQArtemisSecuritySpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisSecuritySpec.
func (*ActiveMQArtemisSecuritySpec) DeepCopyInto ¶
func (in *ActiveMQArtemisSecuritySpec) DeepCopyInto(out *ActiveMQArtemisSecuritySpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ActiveMQArtemisSecurityStatus ¶
type ActiveMQArtemisSecurityStatus struct {
}
ActiveMQArtemisSecurityStatus defines the observed state of ActiveMQArtemisSecurity
func (*ActiveMQArtemisSecurityStatus) DeepCopy ¶
func (in *ActiveMQArtemisSecurityStatus) DeepCopy() *ActiveMQArtemisSecurityStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisSecurityStatus.
func (*ActiveMQArtemisSecurityStatus) DeepCopyInto ¶
func (in *ActiveMQArtemisSecurityStatus) DeepCopyInto(out *ActiveMQArtemisSecurityStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ActiveMQArtemisSpec ¶
type ActiveMQArtemisSpec struct {
// User name for standard broker user. It is required for connecting to the broker and the web console. If left empty, it will be generated.
AdminUser string `json:"adminUser,omitempty"`
// Password for standard broker user. It is required for connecting to the broker and the web console. If left empty, it will be generated.
AdminPassword string `json:"adminPassword,omitempty"`
//
DeploymentPlan DeploymentPlanType `json:"deploymentPlan,omitempty"`
// Acceptor configuration
Acceptors []AcceptorType `json:"acceptors,omitempty"`
Connectors []ConnectorType `json:"connectors,omitempty"`
Console ConsoleType `json:"console,omitempty"`
// The version of the broker deployment.
Version string `json:"version,omitempty"`
Upgrades ActiveMQArtemisUpgrades `json:"upgrades,omitempty"`
AddressSettings AddressSettingsType `json:"addressSettings,omitempty"`
// Optional list of key=value properties that are applied to the broker configuration bean.
BrokerProperties []string `json:"brokerProperties,omitempty"`
// Optional list of environment variables to apply to the container(s), not exclusive
Env []corev1.EnvVar `json:"env,omitempty"`
}
ActiveMQArtemisSpec defines the desired state of ActiveMQArtemis
func (*ActiveMQArtemisSpec) DeepCopy ¶
func (in *ActiveMQArtemisSpec) DeepCopy() *ActiveMQArtemisSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisSpec.
func (*ActiveMQArtemisSpec) DeepCopyInto ¶
func (in *ActiveMQArtemisSpec) DeepCopyInto(out *ActiveMQArtemisSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ActiveMQArtemisStatus ¶
type ActiveMQArtemisStatus struct {
// Current state of the resource
// Conditions represent the latest available observations of an object's state
// +optional
// +patchMergeKey=type
// +patchStrategy=merge
Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,2,rep,name=conditions"`
// Pod Status
PodStatus olm.DeploymentStatus `json:"podStatus"`
}
ActiveMQArtemisStatus defines the observed state of ActiveMQArtemis
func (*ActiveMQArtemisStatus) DeepCopy ¶
func (in *ActiveMQArtemisStatus) DeepCopy() *ActiveMQArtemisStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisStatus.
func (*ActiveMQArtemisStatus) DeepCopyInto ¶
func (in *ActiveMQArtemisStatus) DeepCopyInto(out *ActiveMQArtemisStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ActiveMQArtemisUpgrades ¶
type ActiveMQArtemisUpgrades struct {
// Set to true to enable automatic micro version product upgrades, disabled by default.
Enabled bool `json:"enabled"`
// Set to true to enable automatic micro version product upgrades, disabled by default. Requires spec.upgrades.enabled true.
Minor bool `json:"minor"`
}
ActiveMQArtemis App product upgrade flags, this is deprecated in v1beta1, specifying the Version is sufficient
func (*ActiveMQArtemisUpgrades) DeepCopy ¶
func (in *ActiveMQArtemisUpgrades) DeepCopy() *ActiveMQArtemisUpgrades
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ActiveMQArtemisUpgrades.
func (*ActiveMQArtemisUpgrades) DeepCopyInto ¶
func (in *ActiveMQArtemisUpgrades) DeepCopyInto(out *ActiveMQArtemisUpgrades)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AddressSettingType ¶
type AddressSettingType struct {
// the address to send dead messages to
DeadLetterAddress *string `json:"deadLetterAddress,omitempty"`
// whether or not to automatically create the dead-letter-address and/or a corresponding queue on that address when a message found to be undeliverable
AutoCreateDeadLetterResources *bool `json:"autoCreateDeadLetterResources,omitempty"`
// the prefix to use for auto-created dead letter queues
DeadLetterQueuePrefix *string `json:"deadLetterQueuePrefix,omitempty"`
// the suffix to use for auto-created dead letter queues
DeadLetterQueueSuffix *string `json:"deadLetterQueueSuffix,omitempty"`
// the address to send expired messages to
ExpiryAddress *string `json:"expiryAddress,omitempty"`
// whether or not to automatically create the expiry-address and/or a corresponding queue on that address when a message is sent to a matching queue
AutoCreateExpiryResources *bool `json:"autoCreateExpiryResources,omitempty"`
// the prefix to use for auto-created expiry queues
ExpiryQueuePrefix *string `json:"expiryQueuePrefix,omitempty"`
// the suffix to use for auto-created expiry queues
ExpiryQueueSuffix *string `json:"expiryQueueSuffix,omitempty"`
// Overrides the expiration time for messages using the default value for expiration time. "-1" disables this setting.
ExpiryDelay *int32 `json:"expiryDelay,omitempty"`
// Overrides the expiration time for messages using a lower value. "-1" disables this setting.
MinExpiryDelay *int32 `json:"minExpiryDelay,omitempty"`
// Overrides the expiration time for messages using a higher value. "-1" disables this setting.
MaxExpiryDelay *int32 `json:"maxExpiryDelay,omitempty"`
// the time (in ms) to wait before redelivering a cancelled message.
RedeliveryDelay *int32 `json:"redeliveryDelay,omitempty"`
// Maximum value for the redelivery-delay
MaxRedeliveryDelay *int32 `json:"maxRedeliveryDelay,omitempty"`
// how many times to attempt to deliver a message before sending to dead letter address
MaxDeliveryAttempts *int32 `json:"maxDeliveryAttempts,omitempty"`
// the maximum size in bytes for an address. -1 means no limits. This is used in PAGING, BLOCK and FAIL policies. Supports byte notation like K, Mb, GB, etc.
MaxSizeBytes *string `json:"maxSizeBytes,omitempty"`
// used with the address full BLOCK policy, the maximum size in bytes an address can reach before messages start getting rejected. Works in combination with max-size-bytes for AMQP protocol only. Default = -1 (no limit).
MaxSizeBytesRejectThreshold *int32 `json:"maxSizeBytesRejectThreshold,omitempty"`
// The page size in bytes to use for an address. Supports byte notation like K, Mb, GB, etc.
PageSizeBytes *string `json:"pageSizeBytes,omitempty"`
// Number of paging files to cache in memory to avoid IO during paging navigation
PageMaxCacheSize *int32 `json:"pageMaxCacheSize,omitempty"`
// what happens when an address where maxSizeBytes is specified becomes full
AddressFullPolicy *string `json:"addressFullPolicy,omitempty"`
// how many days to keep message counter history for this address
MessageCounterHistoryDayLimit *int32 `json:"messageCounterHistoryDayLimit,omitempty"`
// This is deprecated please use default-last-value-queue instead.
LastValueQueue *bool `json:"lastValueQueue,omitempty"`
// whether to treat the queues under the address as a last value queues by default
DefaultLastValueQueue *bool `json:"defaultLastValueQueue,omitempty"`
// the property to use as the key for a last value queue by default
DefaultLastValueKey *string `json:"defaultLastValueKey,omitempty"`
// whether the queue should be non-destructive by default
DefaultNonDestructive *bool `json:"defaultNonDestructive,omitempty"`
// whether to treat the queues under the address as exclusive queues by default
DefaultExclusiveQueue *bool `json:"defaultExclusiveQueue,omitempty"`
// whether to rebalance groups when a consumer is added
DefaultGroupRebalance *bool `json:"defaultGroupRebalance,omitempty"`
// whether to pause dispatch when rebalancing groups
DefaultGroupRebalancePauseDispatch *bool `json:"defaultGroupRebalancePauseDispatch,omitempty"`
// number of buckets to use for grouping, -1 (default) is unlimited and uses the raw group, 0 disables message groups.
DefaultGroupBuckets *int32 `json:"defaultGroupBuckets,omitempty"`
// key used to mark a message is first in a group for a consumer
DefaultGroupFirstKey *string `json:"defaultGroupFirstKey,omitempty"`
// the default number of consumers needed before dispatch can start for queues under the address.
DefaultConsumersBeforeDispatch *int32 `json:"defaultConsumersBeforeDispatch,omitempty"`
// the default delay (in milliseconds) to wait before dispatching if number of consumers before dispatch is not met for queues under the address.
DefaultDelayBeforeDispatch *int32 `json:"defaultDelayBeforeDispatch,omitempty"`
// how long (in ms) to wait after the last consumer is closed on a queue before redistributing messages.
RedistributionDelay *int32 `json:"redistributionDelay,omitempty"`
// if there are no queues matching this address, whether to forward message to DLA (if it exists for this address)
SendToDlaOnNoRoute *bool `json:"sendToDlaOnNoRoute,omitempty"`
// The minimum rate of message consumption allowed before a consumer is considered "slow." Measured in messages-per-second.
SlowConsumerThreshold *int32 `json:"slowConsumerThreshold,omitempty"`
// what happens when a slow consumer is identified
SlowConsumerPolicy *string `json:"slowConsumerPolicy,omitempty"`
// How often to check for slow consumers on a particular queue. Measured in seconds.
SlowConsumerCheckPeriod *int32 `json:"slowConsumerCheckPeriod,omitempty"`
// DEPRECATED. whether or not to automatically create JMS queues when a producer sends or a consumer connects to a queue
AutoCreateJmsQueues *bool `json:"autoCreateJmsQueues,omitempty"`
// DEPRECATED. whether or not to delete auto-created JMS queues when the queue has 0 consumers and 0 messages
AutoDeleteJmsQueues *bool `json:"autoDeleteJmsQueues,omitempty"`
// DEPRECATED. whether or not to automatically create JMS topics when a producer sends or a consumer subscribes to a topic
AutoCreateJmsTopics *bool `json:"autoCreateJmsTopics,omitempty"`
// DEPRECATED. whether or not to delete auto-created JMS topics when the last subscription is closed
AutoDeleteJmsTopics *bool `json:"autoDeleteJmsTopics,omitempty"`
// whether or not to automatically create a queue when a client sends a message to or attempts to consume a message from a queue
AutoCreateQueues *bool `json:"autoCreateQueues,omitempty"`
// whether or not to delete auto-created queues when the queue has 0 consumers and 0 messages
AutoDeleteQueues *bool `json:"autoDeleteQueues,omitempty"`
// whether or not to delete created queues when the queue has 0 consumers and 0 messages
AutoDeleteCreatedQueues *bool `json:"autoDeleteCreatedQueues,omitempty"`
// how long to wait (in milliseconds) before deleting auto-created queues after the queue has 0 consumers.
AutoDeleteQueuesDelay *int32 `json:"autoDeleteQueuesDelay,omitempty"`
// the message count the queue must be at or below before it can be evaluated to be auto deleted, 0 waits until empty queue (default) and -1 disables this check.
AutoDeleteQueuesMessageCount *int32 `json:"autoDeleteQueuesMessageCount,omitempty"`
//What to do when a queue is no longer in broker.xml. OFF = will do nothing queues will remain, FORCE = delete queues even if messages remaining.
ConfigDeleteQueues *string `json:"configDeleteQueues,omitempty"`
// whether or not to automatically create addresses when a client sends a message to or attempts to consume a message from a queue mapped to an address that doesnt exist
AutoCreateAddresses *bool `json:"autoCreateAddresses,omitempty"`
// whether or not to delete auto-created addresses when it no longer has any queues
AutoDeleteAddresses *bool `json:"autoDeleteAddresses,omitempty"`
// how long to wait (in milliseconds) before deleting auto-created addresses after they no longer have any queues
AutoDeleteAddressesDelay *int32 `json:"autoDeleteAddressesDelay,omitempty"`
// What to do when an address is no longer in broker.xml. OFF = will do nothing addresses will remain, FORCE = delete address and its queues even if messages remaining.
ConfigDeleteAddresses *string `json:"configDeleteAddresses,omitempty"`
// how many message a management resource can browse
ManagementBrowsePageSize *int32 `json:"managementBrowsePageSize,omitempty"`
// purge the contents of the queue once there are no consumers
DefaultPurgeOnNoConsumers *bool `json:"defaultPurgeOnNoConsumers,omitempty"`
// the maximum number of consumers allowed on this queue at any one time
DefaultMaxConsumers *int32 `json:"defaultMaxConsumers,omitempty"`
// the routing-type used on auto-created queues
DefaultQueueRoutingType *string `json:"defaultQueueRoutingType,omitempty"`
// the routing-type used on auto-created addresses
DefaultAddressRoutingType *string `json:"defaultAddressRoutingType,omitempty"`
// the default window size for a consumer
DefaultConsumerWindowSize *int32 `json:"defaultConsumerWindowSize,omitempty"`
// the default ring-size value for any matching queue which doesnt have ring-size explicitly defined
DefaultRingSize *int32 `json:"defaultRingSize,omitempty"`
// the number of messages to preserve for future queues created on the matching address
RetroactiveMessageCount *int32 `json:"retroactiveMessageCount,omitempty"`
// whether or not to enable metrics for metrics plugins on the matching address
EnableMetrics *bool `json:"enableMetrics,omitempty"`
// pattern for matching settings against addresses; can use wildards
Match string `json:"match,omitempty"`
// max size of the message returned from management API, default 256
ManagementMessageAttributeSizeLimit *int32 `json:"managementMessageAttributeSizeLimit,omitempty"`
// Unit used in specifying slow consumer threshold, default is MESSAGE_PER_SECOND
SlowConsumerThresholdMeasurementUnit *string `json:"slowConsumerThresholdMeasurementUnit,omitempty"`
// Whether or not set the timestamp of arrival on messages. default false
EnableIngressTimestamp *bool `json:"enableIngressTimestamp,omitempty"`
// What to do when a divert is no longer in broker.xml. OFF = will do nothing and divert will remain(default), FORCE = delete divert.
ConfigDeleteDiverts *string `json:"configDeleteDiverts,omitempty"`
// the maximum number of messages allowed on the address (default -1). This is used in PAGING, BLOCK and FAIL policies. It does not support notations and it is a simple number of messages allowed.
MaxSizeMessages *int64 `json:"maxSizeMessages,omitempty"`
}
func (*AddressSettingType) DeepCopy ¶
func (in *AddressSettingType) DeepCopy() *AddressSettingType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AddressSettingType.
func (*AddressSettingType) DeepCopyInto ¶
func (in *AddressSettingType) DeepCopyInto(out *AddressSettingType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AddressSettingsType ¶
type AddressSettingsType struct {
// How to merge the address settings to broker configuration
ApplyRule *string `json:"applyRule,omitempty"`
AddressSetting []AddressSettingType `json:"addressSetting,omitempty"`
}
func (*AddressSettingsType) DeepCopy ¶
func (in *AddressSettingsType) DeepCopy() *AddressSettingsType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AddressSettingsType.
func (*AddressSettingsType) DeepCopyInto ¶
func (in *AddressSettingsType) DeepCopyInto(out *AddressSettingsType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AllowedListEntryType ¶
type AllowedListEntryType struct {
// The domain of allowedList
Domain *string `json:"domain,omitempty"`
// The key of allowedList
Key *string `json:"key,omitempty"`
}
func (*AllowedListEntryType) DeepCopy ¶
func (in *AllowedListEntryType) DeepCopy() *AllowedListEntryType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AllowedListEntryType.
func (*AllowedListEntryType) DeepCopyInto ¶
func (in *AllowedListEntryType) DeepCopyInto(out *AllowedListEntryType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AuthorisationConfigType ¶
type AuthorisationConfigType struct {
AllowedList []AllowedListEntryType `json:"allowedList,omitempty"`
DefaultAccess []DefaultAccessType `json:"defaultAccess,omitempty"`
RoleAccess []RoleAccessType `json:"roleAccess,omitempty"`
}
func (*AuthorisationConfigType) DeepCopy ¶
func (in *AuthorisationConfigType) DeepCopy() *AuthorisationConfigType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AuthorisationConfigType.
func (*AuthorisationConfigType) DeepCopyInto ¶
func (in *AuthorisationConfigType) DeepCopyInto(out *AuthorisationConfigType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerDomainType ¶
type BrokerDomainType struct {
// Name for the broker/console domain
Name *string `json:"name,omitempty"`
LoginModules []LoginModuleReferenceType `json:"loginModules,omitempty"`
}
func (*BrokerDomainType) DeepCopy ¶
func (in *BrokerDomainType) DeepCopy() *BrokerDomainType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerDomainType.
func (*BrokerDomainType) DeepCopyInto ¶
func (in *BrokerDomainType) DeepCopyInto(out *BrokerDomainType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerSecuritySettingType ¶
type BrokerSecuritySettingType struct {
// The address match pattern of a security setting
Match string `json:"match,omitempty"`
Permissions []PermissionType `json:"permissions,omitempty"`
}
func (*BrokerSecuritySettingType) DeepCopy ¶
func (in *BrokerSecuritySettingType) DeepCopy() *BrokerSecuritySettingType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerSecuritySettingType.
func (*BrokerSecuritySettingType) DeepCopyInto ¶
func (in *BrokerSecuritySettingType) DeepCopyInto(out *BrokerSecuritySettingType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConnectorConfigType ¶
type ConnectorConfigType struct {
// The connector host for connecting to management
Host *string `json:"host,omitempty"`
// The connector port for connecting to management
Port *int32 `json:"port,omitempty"`
// The RMI registry port for management
RmiRegistryPort *int32 `json:"rmiRegistryPort,omitempty"`
// The JMX realm of management
JmxRealm *string `json:"jmxRealm,omitempty"`
// The JMX object name of management
ObjectName *string `json:"objectName,omitempty"`
// The management authentication type
AuthenticatorType *string `json:"authenticatorType,omitempty"`
// Whether management connection is secured
Secured *bool `json:"secured,omitempty"`
// The keystore provider for management connector
KeyStoreProvider *string `json:"keyStoreProvider,omitempty"`
// The keystore path for management connector
KeyStorePath *string `json:"keyStorePath,omitempty"`
// The keystore password for management connector
KeyStorePassword *string `json:"keyStorePassword,omitempty"`
// The truststore provider for management connector
TrustStoreProvider *string `json:"trustStoreProvider,omitempty"`
// The truststore path for management connector
TrustStorePath *string `json:"trustStorePath,omitempty"`
// The truststore password for management connector
TrustStorePassword *string `json:"trustStorePassword,omitempty"`
// The password codec for management connector
PasswordCodec *string `json:"passwordCodec,omitempty"`
}
func (*ConnectorConfigType) DeepCopy ¶
func (in *ConnectorConfigType) DeepCopy() *ConnectorConfigType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectorConfigType.
func (*ConnectorConfigType) DeepCopyInto ¶
func (in *ConnectorConfigType) DeepCopyInto(out *ConnectorConfigType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConnectorType ¶
type ConnectorType struct {
// The name of the connector
Name string `json:"name"`
// The type either tcp or vm
Type string `json:"type,omitempty"`
// Hostname or IP to connect to
Host string `json:"host"`
// Port number
Port int32 `json:"port"`
// Whether or not to enable SSL on this port
SSLEnabled bool `json:"sslEnabled,omitempty"`
// Name of the secret to use for ssl information
SSLSecret string `json:"sslSecret,omitempty"`
// Comma separated list of cipher suites used for SSL communication.
EnabledCipherSuites string `json:"enabledCipherSuites,omitempty"`
// Comma separated list of protocols used for SSL communication.
EnabledProtocols string `json:"enabledProtocols,omitempty"`
// Tells a client connecting to this connector that 2-way SSL is required. This property takes precedence over wantClientAuth.
NeedClientAuth bool `json:"needClientAuth,omitempty"`
// Tells a client connecting to this connector that 2-way SSL is requested but not required. Overridden by needClientAuth.
WantClientAuth bool `json:"wantClientAuth,omitempty"`
// The CN of the connecting client's SSL certificate will be compared to its hostname to verify they match. This is useful only for 2-way SSL.
VerifyHost bool `json:"verifyHost,omitempty"`
// Used to change the SSL Provider between JDK and OPENSSL. The default is JDK.
SSLProvider string `json:"sslProvider,omitempty"`
// A regular expression used to match the server_name extension on incoming SSL connections. If the name doesn't match then the connection to the acceptor will be rejected.
SNIHost string `json:"sniHost,omitempty"`
// Whether or not to expose this connector
Expose bool `json:"expose,omitempty"`
// Provider used for the keystore; "SUN", "SunJCE", etc. Default is null
KeyStoreProvider string `json:"keyStoreProvider,omitempty"`
// Type of truststore being used; "JKS", "JCEKS", "PKCS12", etc. Default in broker is "JKS"
TrustStoreType string `json:"trustStoreType,omitempty"`
// Provider used for the truststore; "SUN", "SunJCE", etc. Default in broker is null
TrustStoreProvider string `json:"trustStoreProvider,omitempty"`
}
func (*ConnectorType) DeepCopy ¶
func (in *ConnectorType) DeepCopy() *ConnectorType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectorType.
func (*ConnectorType) DeepCopyInto ¶
func (in *ConnectorType) DeepCopyInto(out *ConnectorType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConsoleType ¶
type ConsoleType struct {
// Whether or not to expose this port
Expose bool `json:"expose,omitempty"`
// Whether or not to enable SSL on this port
SSLEnabled bool `json:"sslEnabled,omitempty"`
// Name of the secret to use for ssl information
SSLSecret string `json:"sslSecret,omitempty"`
// If the embedded server requires client authentication
UseClientAuth bool `json:"useClientAuth,omitempty"`
}
func (*ConsoleType) DeepCopy ¶
func (in *ConsoleType) DeepCopy() *ConsoleType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConsoleType.
func (*ConsoleType) DeepCopyInto ¶
func (in *ConsoleType) DeepCopyInto(out *ConsoleType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DefaultAccessType ¶
type DefaultAccessType struct {
// The method of defaultAccess/roleAccess List
Method *string `json:"method,omitempty"`
// The roles of defaultAccess/roleAccess List
Roles []string `json:"roles,omitempty"`
}
func (*DefaultAccessType) DeepCopy ¶
func (in *DefaultAccessType) DeepCopy() *DefaultAccessType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DefaultAccessType.
func (*DefaultAccessType) DeepCopyInto ¶
func (in *DefaultAccessType) DeepCopyInto(out *DefaultAccessType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeploymentPlanType ¶
type DeploymentPlanType struct {
//The image used for the broker deployment
Image string `json:"image,omitempty"`
// The init container image used to configure broker
InitImage string `json:"initImage,omitempty"`
// The number of broker pods to deploy
Size int32 `json:"size,omitempty"`
// If true require user password login credentials for broker protocol ports
RequireLogin bool `json:"requireLogin,omitempty"`
// If true use persistent volume via persistent volume claim for journal storage
PersistenceEnabled bool `json:"persistenceEnabled,omitempty"`
// If aio use ASYNCIO, if nio use NIO for journal IO
JournalType string `json:"journalType,omitempty"`
//If true migrate messages on scaledown
MessageMigration *bool `json:"messageMigration,omitempty"`
Resources corev1.ResourceRequirements `json:"resources,omitempty"`
Storage StorageType `json:"storage,omitempty"`
// If true enable the Jolokia JVM Agent
JolokiaAgentEnabled bool `json:"jolokiaAgentEnabled,omitempty"`
// If true enable the management role based access control
ManagementRBACEnabled bool `json:"managementRBACEnabled,omitempty"`
ExtraMounts ExtraMountsType `json:"extraMounts,omitempty"`
// Whether broker is clustered
Clustered *bool `json:"clustered,omitempty"`
PodSecurity PodSecurityType `json:"podSecurity,omitempty"`
LivenessProbe *corev1.Probe `json:"livenessProbe,omitempty"`
ReadinessProbe *corev1.Probe `json:"readinessProbe,omitempty"`
// Whether or not to install the artemis metrics plugin
EnableMetricsPlugin *bool `json:"enableMetricsPlugin,omitempty"`
Tolerations []corev1.Toleration `json:"tolerations,omitempty"`
// Assign labels to a broker pod, the keys `ActiveMQArtemis` and `application` are not allowed
Labels map[string]string `json:"labels,omitempty"`
//custom node selector
NodeSelector map[string]string `json:"nodeSelector,omitempty"`
//custom Affinity
Affinity corev1.Affinity `json:"affinity,omitempty"`
PodSecurityContext *corev1.PodSecurityContext `json:"podSecurityContext,omitempty"`
}
func (*DeploymentPlanType) DeepCopy ¶
func (in *DeploymentPlanType) DeepCopy() *DeploymentPlanType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeploymentPlanType.
func (*DeploymentPlanType) DeepCopyInto ¶
func (in *DeploymentPlanType) DeepCopyInto(out *DeploymentPlanType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ExtraMountsType ¶
type ExtraMountsType struct {
// Name of ConfigMap
ConfigMaps []string `json:"configMaps,omitempty"`
// Name of Secret
Secrets []string `json:"secrets,omitempty"`
}
func (*ExtraMountsType) DeepCopy ¶
func (in *ExtraMountsType) DeepCopy() *ExtraMountsType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExtraMountsType.
func (*ExtraMountsType) DeepCopyInto ¶
func (in *ExtraMountsType) DeepCopyInto(out *ExtraMountsType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type GuestLoginModuleType ¶
type GuestLoginModuleType struct {
// Name for GuestLoginModule
Name string `json:"name,omitempty"`
// The guest user name
GuestUser *string `json:"guestUser,omitempty"`
// The guest user role
GuestRole *string `json:"guestRole,omitempty"`
}
func (*GuestLoginModuleType) DeepCopy ¶
func (in *GuestLoginModuleType) DeepCopy() *GuestLoginModuleType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GuestLoginModuleType.
func (*GuestLoginModuleType) DeepCopyInto ¶
func (in *GuestLoginModuleType) DeepCopyInto(out *GuestLoginModuleType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KeyValueType ¶
type KeyValueType struct {
// The credentials key
Key string `json:"key,omitempty"`
// The credentials value
Value *string `json:"value,omitempty"`
}
func (*KeyValueType) DeepCopy ¶
func (in *KeyValueType) DeepCopy() *KeyValueType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KeyValueType.
func (*KeyValueType) DeepCopyInto ¶
func (in *KeyValueType) DeepCopyInto(out *KeyValueType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KeycloakLoginModuleType ¶
type KeycloakLoginModuleType struct {
// Name for KeycloakLoginModule
Name string `json:"name,omitempty"`
// Type of KeycloakLoginModule directAccess or bearerToken
ModuleType *string `json:"moduleType,omitempty"`
Configuration KeycloakModuleConfigurationType `json:"configuration,omitempty"`
}
func (*KeycloakLoginModuleType) DeepCopy ¶
func (in *KeycloakLoginModuleType) DeepCopy() *KeycloakLoginModuleType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KeycloakLoginModuleType.
func (*KeycloakLoginModuleType) DeepCopyInto ¶
func (in *KeycloakLoginModuleType) DeepCopyInto(out *KeycloakLoginModuleType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KeycloakModuleConfigurationType ¶
type KeycloakModuleConfigurationType struct {
// Realm for KeycloakLoginModule
Realm *string `json:"realm,omitempty"`
// Public key for the realm
RealmPublicKey *string `json:"realmPublicKey,omitempty"`
// URL of the keycloak authentication server
AuthServerUrl *string `json:"authServerUrl,omitempty"`
// How SSL is required
SslRequired *string `json:"sslRequired,omitempty"`
// Resource Name
Resource *string `json:"resource,omitempty"`
// If it is public client
PublicClient *bool `json:"publicClient,omitempty"`
Credentials []KeyValueType `json:"credentials,omitempty"`
// If to use resource role mappings
UseResourceRoleMappings *bool `json:"useResourceRoleMappings,omitempty"`
// If to enable CORS
EnableCors *bool `json:"enableCors,omitempty"`
// CORS max age
CorsMaxAge *int64 `json:"corsMaxAge,omitempty"`
// CORS allowed methods
CorsAllowedMethods *string `json:"corsAllowedMethods,omitempty"`
// CORS allowed headers
CorsAllowedHeaders *string `json:"corsAllowedHeaders,omitempty"`
// CORS exposed headers
CorsExposedHeaders *string `json:"corsExposedHeaders,omitempty"`
// If to expose access token
ExposeToken *bool `json:"exposeToken,omitempty"`
// If only verify bearer token
BearerOnly *bool `json:"bearerOnly,omitempty"`
// If auto-detect bearer token only
AutoDetectBearerOnly *bool `json:"autoDetectBearerOnly,omitempty"`
// Size of the connection pool
ConnectionPoolSize *int64 `json:"connectionPoolSize,omitempty"`
// If to allow any host name
AllowAnyHostName *bool `json:"allowAnyHostName,omitempty"`
// If to disable trust manager
DisableTrustManager *bool `json:"disableTrustManager,omitempty"`
// Path of a trust store
TrustStore *string `json:"trustStore,omitempty"`
// Truststore password
TrustStorePassword *string `json:"trustStorePassword,omitempty"`
// Path of a client keystore
ClientKeyStore *string `json:"clientKeyStore,omitempty"`
// Client keystore password
ClientKeyStorePassword *string `json:"clientKeyStorePassword,omitempty"`
// Client key password
ClientKeyPassword *string `json:"clientKeyPassword,omitempty"`
// If always refresh token
AlwaysRefreshToken *bool `json:"alwaysRefreshToken,omitempty"`
// If register node at startup
RegisterNodeAtStartup *bool `json:"registerNodeAtStartup,omitempty"`
// Period for re-registering node
RegisterNodePeriod *int64 `json:"registerNodePeriod,omitempty"`
// Type of token store. session or cookie
TokenStore *string `json:"tokenStore,omitempty"`
// Cookie path for a cookie store
TokenCookiePath *string `json:"tokenCookiePath,omitempty"`
// OpenID Connect ID Token attribute to populate the UserPrincipal name with
PrincipalAttribute *string `json:"principalAttribute,omitempty"`
// The proxy URL
ProxyUrl *string `json:"proxyUrl,omitempty"`
// If not to change session id on a successful login
TurnOffChangeSessionIdOnLogin *bool `json:"turnOffChangeSessionIdOnLogin,omitempty"`
// Minimum time to refresh an active access token
TokenMinimumTimeToLive *int64 `json:"tokenMinimumTimeToLive,omitempty"`
// Minimum interval between two requests to Keycloak to retrieve new public keys
MinTimeBetweenJwksRequests *int64 `json:"minTimeBetweenJwksRequests,omitempty"`
// Maximum interval between two requests to Keycloak to retrieve new public keys
PublicKeyCacheTtl *int64 `json:"publicKeyCacheTtl,omitempty"`
// Whether to turn off processing of the access_token query parameter for bearer token processing
IgnoreOauthQueryParameter *bool `json:"ignoreOauthQueryParameter,omitempty"`
// Verify whether the token contains this client name (resource) as an audience
VerifyTokenAudience *bool `json:"verifyTokenAudience,omitempty"`
// Whether to support basic authentication
EnableBasicAuth *bool `json:"enableBasicAuth,omitempty"`
// The confidential port used by the Keycloak server for secure connections over SSL/TLS
ConfidentialPort *int32 `json:"confidentialPort,omitempty"`
// The regular expression to which the Redirect URI is to be matched
// value is the replacement String
RedirectRewriteRules []KeyValueType `json:"redirectRewriteRules,omitempty"`
// The OAuth2 scope parameter for DirectAccessGrantsLoginModule
Scope *string `json:"scope,omitempty"`
}
func (*KeycloakModuleConfigurationType) DeepCopy ¶
func (in *KeycloakModuleConfigurationType) DeepCopy() *KeycloakModuleConfigurationType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KeycloakModuleConfigurationType.
func (*KeycloakModuleConfigurationType) DeepCopyInto ¶
func (in *KeycloakModuleConfigurationType) DeepCopyInto(out *KeycloakModuleConfigurationType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LoginModuleReferenceType ¶
type LoginModuleReferenceType struct {
// Name for login modules for broker/console domain
Name *string `json:"name,omitempty"`
// Flag of login modules for broker/console domain
Flag *string `json:"flag,omitempty"`
// Debug option of login modules for broker/console domain
Debug *bool `json:"debug,omitempty"`
// Reload option of login modules for broker/console domain
Reload *bool `json:"reload,omitempty"`
}
func (*LoginModuleReferenceType) DeepCopy ¶
func (in *LoginModuleReferenceType) DeepCopy() *LoginModuleReferenceType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoginModuleReferenceType.
func (*LoginModuleReferenceType) DeepCopyInto ¶
func (in *LoginModuleReferenceType) DeepCopyInto(out *LoginModuleReferenceType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LoginModulesType ¶
type LoginModulesType struct {
PropertiesLoginModules []PropertiesLoginModuleType `json:"propertiesLoginModules,omitempty"`
GuestLoginModules []GuestLoginModuleType `json:"guestLoginModules,omitempty"`
KeycloakLoginModules []KeycloakLoginModuleType `json:"keycloakLoginModules,omitempty"`
}
func (*LoginModulesType) DeepCopy ¶
func (in *LoginModulesType) DeepCopy() *LoginModulesType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoginModulesType.
func (*LoginModulesType) DeepCopyInto ¶
func (in *LoginModulesType) DeepCopyInto(out *LoginModulesType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ManagementSecuritySettingsType ¶
type ManagementSecuritySettingsType struct {
// The roles allowed to login hawtio
HawtioRoles []string `json:"hawtioRoles,omitempty"`
Connector ConnectorConfigType `json:"connector,omitempty"`
Authorisation AuthorisationConfigType `json:"authorisation,omitempty"`
}
func (*ManagementSecuritySettingsType) DeepCopy ¶
func (in *ManagementSecuritySettingsType) DeepCopy() *ManagementSecuritySettingsType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagementSecuritySettingsType.
func (*ManagementSecuritySettingsType) DeepCopyInto ¶
func (in *ManagementSecuritySettingsType) DeepCopyInto(out *ManagementSecuritySettingsType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PermissionType ¶
type PermissionType struct {
// The operation type of a security setting
OperationType string `json:"operationType"`
// The roles of a security setting
Roles []string `json:"roles,omitempty"`
}
func (*PermissionType) DeepCopy ¶
func (in *PermissionType) DeepCopy() *PermissionType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PermissionType.
func (*PermissionType) DeepCopyInto ¶
func (in *PermissionType) DeepCopyInto(out *PermissionType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PodSecurityType ¶
type PodSecurityType struct {
// ServiceAccount Name of the pod
ServiceAccountName *string `json:"serviceAccountName,omitempty"`
// runAsUser as defined in PodSecurityContext for the pod
RunAsUser *int64 `json:"runAsUser,omitempty"`
}
func (*PodSecurityType) DeepCopy ¶
func (in *PodSecurityType) DeepCopy() *PodSecurityType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodSecurityType.
func (*PodSecurityType) DeepCopyInto ¶
func (in *PodSecurityType) DeepCopyInto(out *PodSecurityType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PropertiesLoginModuleType ¶
type PropertiesLoginModuleType struct {
// Name for PropertiesLoginModule
Name string `json:"name,omitempty"`
Users []UserType `json:"users,omitempty"`
}
func (*PropertiesLoginModuleType) DeepCopy ¶
func (in *PropertiesLoginModuleType) DeepCopy() *PropertiesLoginModuleType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PropertiesLoginModuleType.
func (*PropertiesLoginModuleType) DeepCopyInto ¶
func (in *PropertiesLoginModuleType) DeepCopyInto(out *PropertiesLoginModuleType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type QueueConfigurationType ¶
type QueueConfigurationType struct {
// If ignore if the target queue already exists
IgnoreIfExists *bool `json:"ignoreIfExists,omitempty"`
// The routing type of the queue
RoutingType *string `json:"routingType,omitempty"`
// The filter string for the queue
FilterString *string `json:"filterString,omitempty"`
// If the queue is durable or not
Durable *bool `json:"durable,omitempty"`
// The user associated with the queue
User *string `json:"user,omitempty"`
// Max number of consumers allowed on this queue
MaxConsumers *int32 `json:"maxConsumers,omitempty"`
// If the queue is exclusive
Exclusive *bool `json:"exclusive,omitempty"`
// If rebalance the message group
GroupRebalance *bool `json:"groupRebalance,omitempty"`
// If pause message dispatch when rebalancing groups
GroupRebalancePauseDispatch *bool `json:"groupRebalancePauseDispatch,omitempty"`
// Number of messaging group buckets
GroupBuckets *int32 `json:"groupBuckets,omitempty"`
// Header set on the first group message
GroupFirstKey *string `json:"groupFirstKey,omitempty"`
// If it is a last value queue
LastValue *bool `json:"lastValue,omitempty"`
// The property used for last value queue to identify last values
LastValueKey *string `json:"lastValueKey,omitempty"`
// If force non-destructive consumers on the queue
NonDestructive *bool `json:"nonDestructive,omitempty"`
// Whether to delete all messages when no consumers connected to the queue
PurgeOnNoConsumers *bool `json:"purgeOnNoConsumers,omitempty"`
// If the queue is enabled
Enabled *bool `json:"enabled,omitempty"`
// Number of consumers required before dispatching messages
ConsumersBeforeDispatch *int32 `json:"consumersBeforeDispatch,omitempty"`
// Milliseconds to wait for `consumers-before-dispatch` to be met before dispatching messages anyway
DelayBeforeDispatch *int64 `json:"delayBeforeDispatch,omitempty"`
// Consumer Priority
ConsumerPriority *int32 `json:"consumerPriority,omitempty"`
// Auto-delete the queue
AutoDelete *bool `json:"autoDelete,omitempty"`
// Delay (Milliseconds) before auto-delete the queue
AutoDeleteDelay *int64 `json:"autoDeleteDelay,omitempty"`
// Message count of the queue to allow auto delete
AutoDeleteMessageCount *int64 `json:"autoDeleteMessageCount,omitempty"`
// The size the queue should maintain according to ring semantics
RingSize *int64 `json:"ringSize,omitempty"`
// If the queue is configuration managed
ConfigurationManaged *bool `json:"configurationManaged,omitempty"`
// If the queue is temporary
Temporary *bool `json:"temporary,omitempty"`
// Whether auto create address
AutoCreateAddress *bool `json:"autoCreateAddress,omitempty"`
}
func (*QueueConfigurationType) DeepCopy ¶
func (in *QueueConfigurationType) DeepCopy() *QueueConfigurationType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueConfigurationType.
func (*QueueConfigurationType) DeepCopyInto ¶
func (in *QueueConfigurationType) DeepCopyInto(out *QueueConfigurationType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RoleAccessType ¶
type RoleAccessType struct {
// The domain of roleAccess List
Domain *string `json:"domain,omitempty"`
// The key of roleAccess List
Key *string `json:"key,omitempty"`
AccessList []DefaultAccessType `json:"accessList,omitempty"`
}
func (*RoleAccessType) DeepCopy ¶
func (in *RoleAccessType) DeepCopy() *RoleAccessType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RoleAccessType.
func (*RoleAccessType) DeepCopyInto ¶
func (in *RoleAccessType) DeepCopyInto(out *RoleAccessType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SecurityDomainsType ¶
type SecurityDomainsType struct {
BrokerDomain BrokerDomainType `json:"brokerDomain,omitempty"`
ConsoleDomain BrokerDomainType `json:"consoleDomain,omitempty"`
}
func (*SecurityDomainsType) DeepCopy ¶
func (in *SecurityDomainsType) DeepCopy() *SecurityDomainsType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecurityDomainsType.
func (*SecurityDomainsType) DeepCopyInto ¶
func (in *SecurityDomainsType) DeepCopyInto(out *SecurityDomainsType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SecuritySettingsType ¶
type SecuritySettingsType struct {
Broker []BrokerSecuritySettingType `json:"broker,omitempty"`
Management ManagementSecuritySettingsType `json:"management,omitempty"`
}
func (*SecuritySettingsType) DeepCopy ¶
func (in *SecuritySettingsType) DeepCopy() *SecuritySettingsType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecuritySettingsType.
func (*SecuritySettingsType) DeepCopyInto ¶
func (in *SecuritySettingsType) DeepCopyInto(out *SecuritySettingsType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StorageType ¶
type StorageType struct {
Size string `json:"size,omitempty"`
// The storageClassName to be used in PVC
StorageClassName string `json:"storageClassName,omitempty"`
}
func (*StorageType) DeepCopy ¶
func (in *StorageType) DeepCopy() *StorageType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageType.
func (*StorageType) DeepCopyInto ¶
func (in *StorageType) DeepCopyInto(out *StorageType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type UserType ¶
type UserType struct {
// User name to be defined in properties login module
Name string `json:"name,omitempty"`
// Password to be defined in properties login module
Password *string `json:"password,omitempty"`
// Roles to be defined in properties login module
Roles []string `json:"roles,omitempty"`
}
func (*UserType) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UserType.
func (*UserType) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.