constants

Documentation

Index

• Constants
• type PersistenceType
  • func (p PersistenceType) String() string

Constants

const (
	QuarkusHealthPathReady = "/q/health/ready"
	QuarkusHealthPathLive  = "/q/health/live"

	// Quarkus Health Check Probe configuration.
	// See: https://quarkus.io/guides/smallrye-health#running-the-health-check
	QuarkusHealthPathStarted = "/q/health/started"
)

const (
	QuarkusHTTP = "quarkus-http"

	ConfigMapWorkflowPropsVolumeName = "workflow-properties"

	JobServiceRequestEventsURL       = "mp.messaging.outgoing.kogito-job-service-job-request-events.url"
	JobServiceRequestEventsConnector = "mp.messaging.outgoing.kogito-job-service-job-request-events.connector"
	JobServiceStatusChangeEvents     = "kogito.jobs-service.http.job-status-change-events"
	JobServiceStatusChangeEventsURL  = "mp.messaging.outgoing.kogito-job-service-job-status-events-http.url"
	JobServiceURLProtocol            = "http"
	JobServiceDataSourceReactiveURL  = "quarkus.datasource.reactive.url"
	JobServiceJobEventsPath          = "/v2/jobs/events"

	KogitoProcessInstancesEventsURL             = "mp.messaging.outgoing.kogito-processinstances-events.url"
	KogitoProcessInstancesEventsEnabled         = "kogito.events.processinstances.enabled"
	KogitoProcessInstancesEventsPath            = "/processes"
	KogitoProcessDefinitionsEventsURL           = "mp.messaging.outgoing.kogito-processdefinitions-events.url"
	KogitoProcessDefinitionsEventsEnabled       = "kogito.events.processdefinitions.enabled"
	KogitoProcessDefinitionsEventsErrorsEnabled = "kogito.events.processdefinitions.errors.propagate"
	KogitoProcessDefinitionsEventsPath          = "/definitions"
	KogitoUserTasksEventsEnabled                = "kogito.events.usertasks.enabled"
	// KogitoDataIndexHealthCheckEnabled configures if a workflow must check for the data index availability as part
	// of its start health check.
	KogitoDataIndexHealthCheckEnabled = "kogito.data-index.health-enabled"
	// KogitoDataIndexURL configures the data index url, this value can be used internally by the workflow.
	KogitoDataIndexURL              = "kogito.data-index.url"
	KogitoDataIndexQuarkusDevUICors = "%dev.quarkus.dev-ui.cors.enabled"
	// KogitoJobServiceHealthCheckEnabled configures if a workflow must check for the job service availability as part
	// of its start health check.
	KogitoJobServiceHealthCheckEnabled = "kogito.jobs-service.health-enabled"
	// KogitoJobServiceURL configures the jobs service, this value can be used internally by the workflow.
	KogitoJobServiceURL                   = "kogito.jobs-service.url"
	KogitoServiceURLProperty              = "kogito.service.url"
	KogitoServiceURLProtocol              = "http"
	DataIndexKafkaSmallRyeHealthProperty  = `quarkus.smallrye-health.check."io.quarkus.kafka.client.health.KafkaHealthCheck".enabled`
	JobServiceKafkaSmallRyeHealthProperty = `quarkus.smallrye-health.check."org.kie.kogito.jobs.service.messaging.http.health.knative.KSinkInjectionHealthCheck".enabled`

	DataIndexServiceName  = "data-index-service"
	JobServiceName        = "jobs-service"
	ImageNamePrefix       = "docker.io/apache/incubator-kie-kogito"
	KogitoImageNamePrefix = "docker.io/apache/incubator-kie-kogito"
	DataIndexName         = "data-index"

	DefaultDatabaseName   string = "sonataflow"
	DefaultPostgreSQLPort int    = 5432
)

const (
	RequeueAfterFailure          = 3 * time.Minute
	RequeueAfterFollowDeployment = 5 * time.Second
	RequeueAfterIsRunning        = 1 * time.Minute
	// RecoverDeploymentErrorRetries how many times the operator should try to recover from a failure before giving up
	RecoverDeploymentErrorRetries = 3
	// RequeueRecoverDeploymentErrorInterval interval between recovering from failures
	RequeueRecoverDeploymentErrorInterval = RecoverDeploymentErrorInterval * time.Minute
	RecoverDeploymentErrorInterval        = 10

	DefaultHTTPWorkflowPortInt = 8080
)

const (
	MicroprofileServiceCatalogPropertyPrefix = "org.kie.kogito.addons.discovery."
	KogitoOutgoingEventsURL                  = "mp.messaging.outgoing.kogito_outgoing_stream.url"
	KogitoOutgoingEventsConnector            = "mp.messaging.outgoing.kogito_outgoing_stream.connector"
	KogitoIncomingEventsConnector            = "mp.messaging.incoming.kogito_incoming_stream.connector"
	KogitoIncomingEventsPath                 = "mp.messaging.incoming.kogito_incoming_stream.path"
	KnativeHealthEnabled                     = "org.kie.kogito.addons.knative.eventing.health-enabled"
	KnativeInjectedEnvVar                    = "${K_SINK}"
	KnativeEventingBrokerDefault             = "default"
)

Types

type PersistenceType

type PersistenceType string

const (
	PersistenceTypePostgreSQL PersistenceType = "postgresql"
	PersistenceTypeEphemeral  PersistenceType = "ephemeral"
)

func (PersistenceType) String

func (p PersistenceType) String() string