http/me.ahoo.wow.http.ops

Package-level declarations

Types

The paths of the operator's routes, under the reserved context wow.

class WebhookNotifier(uri: URI, format: WebhookNotifier.Format = Format.GENERIC, kinds: Set<ParkedNotice.Kind> = ParkedNotice.Kind.entries.toSet(), service: String? = null, headers: Map<String, String> = emptyMap(), timeout: Duration = DEFAULT_TIMEOUT, client: HttpClient = HttpClient.newBuilder().connectTimeout(timeout.toJavaDuration()).build()) : ParkedNotifier

Posts each ParkedNotice of kinds to the webhook at uri, as JSON, through the JDK's HTTP client within timeout: a response other than 2xx fails the notification, which the runtime logs.

Functions

parkedRoutes

@ExperimentalWowApi

@InternalWowApi

fun parkedRoutes(ops: ParkedOps, manifest: Manifest, authorizer: CommandAuthorizer? = null, callerResolver: CallerResolver = CallerResolver.ANONYMOUS, options: WowHttpOptions = WowHttpOptions()): RouterFunction<ServerResponse>

The operator's routes over a node's parked entries, under OpsPaths.PARKED:

subscriptionRoutes

@ExperimentalWowApi

@InternalWowApi

fun subscriptionRoutes(sampler: NodeSampler, manifest: Manifest, authorizer: ServiceRouteAuthorizer = ServiceRouteAuthorizer.ALLOW_ALL, callerResolver: CallerResolver = CallerResolver.ANONYMOUS, options: WowHttpOptions = WowHttpOptions()): RouterFunction<ServerResponse>

The operator's read of the node's subscriptions, GET /wow/ops/subscriptions (OpsPaths.SUBSCRIPTIONS), served with the parked routes (parkedRoutes) and read-only: the node's id (node); each subscription (subscriptions) by its key, <context>.<name> (me.ahoo.wow.runtime.subscription.SubscriptionId.key), its group, its source (log or topic), its parked entries as the node's sampler last counted them (up to its NodeSampler.maxParked; null when it has not), and its partitions, each with its position and, in one this node runs, runs, the head and lag the sample read, and whether it is paused or throttled; and the checkpoints its groups hold under names they no longer have (orphans: group, name, partitions, parked). ServiceNode.subscriptionsView says what each holds.