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"
	Post                             = "POST"
	DefaultHTTPProtocol              = "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"
	JobServiceRequestEventsMethod                   = "mp.messaging.outgoing.kogito-job-service-job-request-events.method"
	JobServiceStatusChangeEvents                    = "kogito.jobs-service.http.job-status-change-events"
	JobServiceStatusChangeEventsURL                 = "mp.messaging.outgoing.kogito-job-service-job-status-events-http.url"
	JobServiceStatusChangeEventsConnector           = "mp.messaging.outgoing.kogito-job-service-job-status-events-http.connector"
	JobServiceStatusChangeEventsMethod              = "mp.messaging.outgoing.kogito-job-service-job-status-events-http.method"
	JobServiceURLProtocol                           = "http"
	JobServiceDataSourceReactiveURL                 = "quarkus.datasource.reactive.url"
	JobServiceJobEventsPath                         = "/v2/jobs/events"
	JobServiceLeaderCheckExpirationInSeconds        = "kogito.jobs-service.management.leader-check.expiration-in-seconds"
	DefaultJobServiceLeaderCheckExpirationInSeconds = "60"

	KogitoProcessInstancesEventsConnector = "mp.messaging.outgoing.kogito-processinstances-events.connector"
	KogitoProcessInstancesEventsMethod    = "mp.messaging.outgoing.kogito-processinstances-events.method"
	KogitoProcessInstancesEventsURL       = "mp.messaging.outgoing.kogito-processinstances-events.url"
	KogitoProcessInstancesEventsEnabled   = "kogito.events.processinstances.enabled"
	KogitoProcessInstancesEventsPath      = "/processes"
	// KogitoProcessInstancesMultiEventsPath Same value as KogitoProcessInstancesEventsPath intentionally
	KogitoProcessInstancesMultiEventsPath       = "/processes"
	KogitoProcessDefinitionsEventsConnector     = "mp.messaging.outgoing.kogito-processdefinitions-events.connector"
	KogitoProcessDefinitionsEventsMethod        = "mp.messaging.outgoing.kogito-processdefinitions-events.method"
	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"
	KogitoJobsPath                              = "/jobs"
	// 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"

	// 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`
	JobServiceLeaderLivenessSmallRyeHealthProperty = `quarkus.smallrye-health.check."org.kie.kogito.jobs.service.management.JobServiceLeaderLivenessHealthCheck".enabled`
	DataIndexKafkaHealthCheck                      = `quarkus.smallrye-health.check."io.quarkus.kafka.client.health.KafkaHealthCheck".enabled`
	JobServiceKSinkInjectionHealthCheck            = `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"
	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}"
	TriggerFinalizer                         = "trigger-deletion"
	QuarkusDevUICorsEnabled                  = "quarkus.dev-ui.cors.enabled"
	QuarkusHttpCors                          = "quarkus.http.cors"
	QuarkusHttpCorsOrigins                   = "quarkus.http.cors.origins"
	KogitoEventsGrouping                     = "kogito.events.grouping"
	KogitoEventsGroupingBinary               = "kogito.events.grouping.binary"
	KogitoEventsGroupingCompress             = "kogito.events.grouping.compress"
)

Types

type PersistenceType

type PersistenceType string

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

func (PersistenceType) String

func (p PersistenceType) String() string