wow-spring-boot-starter/me.ahoo.wow.spring.boot.starter

Package-level declarations

Types

class BusProperties(@DefaultValue(value = ["kafka"]) var type: BusType = BusType.KAFKA, var localFirst: LocalFirstProperties = LocalFirstProperties())

BusType

enum BusType : Enum<BusType>

ConditionalOnWowEnabled

@ConditionalOnProperty(value = ["wow.enabled"], matchIfMissing = true, havingValue = "true")

annotation class ConditionalOnWowEnabled

DispatchProperties

class DispatchProperties(var workers: Int = KeyedExecutor.DEFAULT_WORKERS, var maxInFlight: Int = KeyedExecutor.DEFAULT_MAX_IN_FLIGHT, var throughput: Int = KeyedExecutor.DEFAULT_THROUGHPUT, var spin: Duration = KeyedExecutor.DEFAULT_SPIN)

The runtime's KeyedExecutor (wow.dispatch.*): the worker threads every dispatcher shares, and how many unfinished messages one receiver (one per dispatcher and bounded context) holds before it stops requesting more from its transport.

LocalFirstProperties

class LocalFirstProperties(@DefaultValue(value = ["true"]) var enabled: Boolean = true, @DefaultValue(value = ["10000"]) var backlogHighWaterMark: Int = LocalFirstDistributedCopies.DEFAULT_BACKLOG_HIGH_WATER_MARK) : EnabledCapable

WowAutoConfiguration

@AutoConfiguration(before = [LifecycleAutoConfiguration::class])

@EnableConfigurationProperties(value = [WowProperties::class, LifecycleProperties::class])

class WowAutoConfiguration(wowProperties: WowProperties)

Wow AutoConfiguration .

WowProperties

@ConfigurationProperties(prefix = "wow")

class WowProperties(var enabled: Boolean = true, var contextName: String? = null, var shutdownTimeout: Duration = DEFAULT_SHUTDOWN_TIMEOUT, var shutdownQuietPeriod: Duration = DEFAULT_SHUTDOWN_QUIET_PERIOD, var dispatch: DispatchProperties = DispatchProperties()) : EnabledCapable

WowRuntimeComponentOrder

object WowRuntimeComponentOrder

Deterministic ordering for the built-in runtime components.

Properties

ENABLED_SUFFIX_KEY

const val ENABLED_SUFFIX_KEY: String

WOW_RUNTIME_BEAN_NAME

const val WOW_RUNTIME_BEAN_NAME: String

WOW_RUNTIME_LIFECYCLE_BEAN_NAME

const val WOW_RUNTIME_LIFECYCLE_BEAN_NAME: String