Versions in this module Expand all Collapse all v0 v0.0.2 Mar 2, 2021 Changes in this version + const DefaultImageNamespace + const DefaultImageRegistry + const DefaultMongoDBAuthDatabase + const DefaultMongoDBPasswordSecretRef + const InfinispanIdentityFileName + const InfinispanInstanceName + const InfinispanKind + const InfinispanSecretPasswordKey + const InfinispanSecretUsernameKey + const KafkaInstanceName + const KafkaKind + const KeycloakInstanceName + const KeycloakKind + const KnativeEventingBrokerKind + const KogitoBuilderImage + const KogitoRuntimeJVM + const KogitoRuntimeNative + const LatestTag + const MongoDBAppSecretAuthDatabaseKey + const MongoDBAppSecretDatabaseKey + const MongoDBAppSecretPasswordKey + const MongoDBAppSecretUsernameKey + const MongoDBKind + const MongoDBOperatorName + const RuntimeServiceAccountName + const RuntimeTypeKey + const StrimziOperatorName + var InfinispanAPIVersion = ispn.SchemeGroupVersion.String() + var KafkaAPIVersion = v1beta1.SchemeGroupVersion.String() + var KeycloakAPIVersion = v1alpha1.SchemeGroupVersion.String() + var KnativeEventingAPIVersion = eventingv1.SchemeGroupVersion.String() + var MongoDBAPIVersion = mongodb.SchemeGroupVersion.String() + func GetKafkaDefaultResource(name, namespace string) *v1beta1.Kafka + func GetKogitoImageVersion() string + func IsKafkaResource(apiVersion, kind string) bool + func IsKnativeEventingResource(apiVersion, kind string) bool + type ConfigMapHandler interface + TakeConfigMapOwnership func(key types.NamespacedName, owner resource.KubernetesResource) (updated bool, err error) + func NewConfigMapHandler(context *operator.Context, recorder record.EventRecorder) ConfigMapHandler + type DeploymentHandler interface + FetchDeployment func(key types.NamespacedName) (*appsv1.Deployment, error) + FetchDeploymentList func(namespace string) (*appsv1.DeploymentList, error) + IsDeploymentAvailable func(key types.NamespacedName) (bool, error) + MustFetchDeployment func(key types.NamespacedName) (*appsv1.Deployment, error) + func NewDeploymentHandler(context *operator.Context) DeploymentHandler + type ImageHandler interface + CreateImageStreamIfNotExists func() (*imgv1.ImageStream, error) + ResolveImage func() (string, error) + ResolveImageNameTag func() string + ResolveImageStreamTriggerAnnotation func(containerName string) (key, value string) + func NewImageHandler(context *operator.Context, image *api.Image, ...) ImageHandler + type ImageStreamHandler interface + CreateImageStream func(name, namespace, imageName, tag string, ...) *imgv1.ImageStream + FetchImageStream func(key types.NamespacedName) (*imgv1.ImageStream, error) + MustFetchImageStream func(key types.NamespacedName) (*imgv1.ImageStream, error) + func NewImageStreamHandler(context *operator.Context) ImageStreamHandler + type InfinispanCredential struct + Password string + Username string + type InfinispanHandler interface + CreateInfinispanInstance func(key types.NamespacedName, owner metav1.Object) (*ispn.Infinispan, error) + FetchInfinispanInstance func(key types.NamespacedName) (*ispn.Infinispan, error) + FetchInfinispanInstanceURI func(key types.NamespacedName) (string, error) + GetInfinispanCredential func(infinispanInstance *ispn.Infinispan) (*InfinispanCredential, error) + IsInfinispanAvailable func() bool + func NewInfinispanHandler(context *operator.Context) InfinispanHandler + type InfinispanIdentity struct + Credentials []InfinispanCredential + type KafkaHandler interface + CreateKafkaInstance func(key types.NamespacedName, owner resource.KubernetesResource) (*v1beta1.Kafka, error) + CreateKafkaTopic func(topicName, kafkaName, kafkaNamespace string) (*v1beta1.KafkaTopic, error) + FetchKafkaInstance func(key types.NamespacedName) (*v1beta1.Kafka, error) + FetchKafkaTopic func(key types.NamespacedName) (*v1beta1.KafkaTopic, error) + IsStrimziAvailable func() bool + ResolveKafkaServerURI func(kafka *v1beta1.Kafka) (string, error) + func NewKafkaHandler(context *operator.Context) KafkaHandler + type KeycloakHandler interface + IsKeycloakAvailable func() bool + func NewKeycloakHandler(context *operator.Context) KeycloakHandler + type KnativeHandler interface + FetchBroker func(key types.NamespacedName) (*eventingv1.Broker, error) + IsKnativeEventingAvailable func() bool + func NewKnativeHandler(context *operator.Context) KnativeHandler + type MongoDBHandler interface + IsMongoDBAvailable func() bool + IsMongoDBOperatorAvailable func(namespace string) (bool, error) + func NewMongoDBHandler(context *operator.Context) MongoDBHandler + type RBACHandler interface + SetupRBAC func(namespace string) (err error) + func NewRBACHandler(context *operator.Context) RBACHandler + type RouteHandler interface + CreateRoute func(service *corev1.Service) (route *routev1.Route) + FetchRoute func(key types.NamespacedName) (*routev1.Route, error) + GetHostFromRoute func(routeKey types.NamespacedName) (string, error) + func NewRouteHandler(context *operator.Context) RouteHandler + type ServiceHandler interface + CreateService func(instance api.KogitoService, deployment *appsv1.Deployment) *corev1.Service + func NewServiceHandler(context *operator.Context) ServiceHandler
Go to main page