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

NodeSamplerAutoConfiguration

@AutoConfiguration(after = [WowAutoConfiguration::class], before = [HealthAutoConfiguration::class, ObservabilityAutoConfiguration::class])

class NodeSamplerAutoConfiguration

The node's one sampler (NodeSampler), every wow.node.sample-interval, its parked entries counted up to wow.node.max-parked: the node's health, its gauges and the operator's read of its subscriptions all read its samples, so the ledgers and the logs' heads are read once per interval, whoever reports them.

Constructors

constructor()

Functions

wowNodeSampler

@Bean(initMethod = "start", destroyMethod = "close")

@ConditionalOnBean(value = [ServiceNode::class])

@ConditionalOnMissingBean

@InternalWowApi

fun wowNodeSampler(node: ServiceNode, properties: WowProperties): NodeSampler

wowSubscriptionsRouterFunction

@Bean

@ConditionalOnBean(value = [ServiceNode::class])

@ConditionalOnProperty(prefix = "wow.http.ops", name = ["enabled"], havingValue = "true")

@InternalWowApi

fun wowSubscriptionsRouterFunction(manifest: Manifest, sampler: NodeSampler, callers: CallerResolver, options: WowHttpOptions, routeAuthorizers: ObjectProvider<ServiceRouteAuthorizer>): RouterFunction<ServerResponse>

The operator's read of the node's subscriptions, when wow.http.ops.enabled, beside the parked routes: authenticated by the application's CallerResolver, read by a caller that reaches every tenant, and authorized by its ServiceRouteAuthorizers as the route ops.subscriptions of the context wow.