Package | Description |
---|---|
org.wikimedia.eventutilities.core.http | |
org.wikimedia.eventutilities.monitoring |
Modifier and Type | Method and Description |
---|---|
static BasicHttpResult |
BasicHttpResult.create(org.apache.http.HttpResponse response,
IntPredicate isSuccess)
Creates an BasicHttpResult from an httpcomponents HttpResponse and a lambda
isSuccess that determines what http response status codes constitute a successful
response.
|
BasicHttpResult |
BasicHttpClient.get(URI uri)
Performs a GET request at URI and returns a BasicHttpResult accepting any 2xx status as a success.
|
BasicHttpResult |
BasicHttpClient.get(URI uri,
IntPredicate acceptableStatus)
Performs a GET request at URI and returns a BasicHttpResult.
|
BasicHttpResult |
BasicHttpClient.post(URI endpoint,
byte[] data)
Performs a POST request to URI and returns a BasicHttpResult accepting any 2xx status as a success.
|
BasicHttpResult |
BasicHttpClient.post(URI endpoint,
byte[] postBody,
org.apache.http.entity.ContentType contentType,
IntPredicate acceptableStatus)
Performs a POST request to URI and returns a BasicHttpResult.
|
BasicHttpResult |
BasicHttpClient.post(URI endpoint,
org.apache.http.HttpEntity postBody,
IntPredicate acceptableStatus)
Performs a POST request to URI and returns a BasicHttpResult.
|
BasicHttpResult |
BasicHttpClient.post(URI endpoint,
com.fasterxml.jackson.databind.ObjectMapper mapper,
com.fasterxml.jackson.databind.JsonNode node,
IntPredicate acceptableStatus)
Performs a POST request to URI and returns a BasicHttpResult.
|
Modifier and Type | Method and Description |
---|---|
BasicHttpResult |
CanaryEventProducer.postEvents(URI eventServiceUri,
List<com.fasterxml.jackson.databind.node.ObjectNode> events)
POSTs the given list of
events to the eventServiceUri.
|
Modifier and Type | Method and Description |
---|---|
Map<URI,BasicHttpResult> |
CanaryEventProducer.postAllCanaryEvents()
POSTs canary events for all known streams.
|
Map<URI,BasicHttpResult> |
CanaryEventProducer.postCanaryEvents(List<String> streamNames)
Posts canary events for each named event stream.
|
Map<URI,BasicHttpResult> |
CanaryEventProducer.postCanaryEvents(String streamName)
Posts canary events for a single streamName.
|
Map<URI,BasicHttpResult> |
CanaryEventProducer.postCanaryEventsForStreams(List<EventStream> eventStreams)
Gets canary events for each eventStream, POSTs them to the appropriate
event service url(s), and collects the results of each POST
into a Map of event service url to result ObjectNode.
|
Map<URI,BasicHttpResult> |
CanaryEventProducer.postEventsToUris(Map<URI,List<com.fasterxml.jackson.databind.node.ObjectNode>> uriToEvents)
Iterates over the Map of URI to events and posts events to the URI.
|
Copyright © 2025. All rights reserved.