Index (Wikimedia Event Platform Utilities 1.4.3-SNAPSHOT API)

A B C D E F G H I J L M O P R S T V W

A

accept(ObjectNode) - Method in class org.wikimedia.eventutilities.core.event.EventNormalizationStep.Validation
acceptableStatusPredicateDefault(int) - Static method in class org.wikimedia.eventutilities.core.http.BasicHttpClient: Default HTTP status code predicate, if 2xx, success is true.
addLoader(String, Function<URI, byte[]>) - Method in class org.wikimedia.eventutilities.core.util.ResourceLoader.Builder: Adds a loader function for a URI scheme.
addRoute(String, String) - Method in class org.wikimedia.eventutilities.core.http.BasicHttpClient.Builder: Adds a custom route from sourceURL to targetURL's host, port and protocol.
addRoute(URL, URL) - Method in class org.wikimedia.eventutilities.core.http.BasicHttpClient.Builder: Add custom route using URLs instead of STrings.
apply(ObjectNode) - Method in class org.wikimedia.eventutilities.core.event.EventKeySelector
apply(Consumer<ObjectNode>) - Method in interface org.wikimedia.eventutilities.core.event.JsonEventGenerator.EventNormalizer
asString(JsonNode) - Method in class org.wikimedia.eventutilities.core.json.JsonLoader: Convenience method to reuse our ObjectMapper to serialize a JsonNode to a JSON String.
asURL(String) - Static method in class org.wikimedia.eventutilities.core.util.ResourceLoader: Helper function to convert a String url to a URL.
asURLs(Collection<String>) - Static method in class org.wikimedia.eventutilities.core.util.ResourceLoader: Helper function to convert a List of String urls to URLs.

B

BasicHttpClient - Class in org.wikimedia.eventutilities.core.http: Wrapper around a CloseableHttpClient that aides in getting byte[] content at a URI.
BasicHttpClient.Builder - Class in org.wikimedia.eventutilities.core.http: BasicHttpClient builder class.
BasicHttpResult - Class in org.wikimedia.eventutilities.core.http: Class representing an HTTP request result from HttpRequest This is not called 'response' as it also can represent a failed result caused by a local Exception rather than an HTTP response error status code.
body - Variable in class org.wikimedia.eventutilities.core.http.BasicHttpResult: THe HTTP response body, if there was one.
build() - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader.Builder: Retuns a new EventSchemaLoader.
build() - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig.Builder: Returns a new EventStreamConfig.
build() - Method in class org.wikimedia.eventutilities.core.event.EventStreamFactory.Builder: Returns a new EventStreamFactory.
build() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig.EventUtilitiesConfigBuilder
build() - Method in class org.wikimedia.eventutilities.core.event.JsonEventGenerator.Builder
build() - Method in class org.wikimedia.eventutilities.core.http.BasicHttpClient.Builder
build(ResourceLoader) - Static method in class org.wikimedia.eventutilities.core.json.JsonSchemaLoader: Creates a new JsonLoader using resourceLoader and uses that to create a new JsonSchemaLoader.
build() - Method in class org.wikimedia.eventutilities.core.util.ResourceLoader.Builder
builder() - Static method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader
Builder() - Constructor for class org.wikimedia.eventutilities.core.event.EventSchemaLoader.Builder
builder() - Static method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Returns an Builder instance.
Builder() - Constructor for class org.wikimedia.eventutilities.core.event.EventStreamConfig.Builder
builder() - Static method in class org.wikimedia.eventutilities.core.event.EventStreamFactory
Builder() - Constructor for class org.wikimedia.eventutilities.core.event.EventStreamFactory.Builder
builder() - Static method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig
builder() - Static method in class org.wikimedia.eventutilities.core.event.JsonEventGenerator
builder() - Static method in class org.wikimedia.eventutilities.core.http.BasicHttpClient
Builder() - Constructor for class org.wikimedia.eventutilities.core.http.BasicHttpClient.Builder
builder() - Static method in class org.wikimedia.eventutilities.core.util.ResourceLoader: Returns a ResourceLoader.Builder.
Builder() - Constructor for class org.wikimedia.eventutilities.core.util.ResourceLoader.Builder
buildEventLoggingCapsule() - Static method in class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader: Adapted from https://github.com/wikimedia/eventlogging/blob/master/eventlogging/capsule.py.

C

cachedStreamConfigs() - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Returns all cached stream configs.
cachedStreamNames() - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Returns all cached stream name keys.
cacheGet(URI) - Method in class org.wikimedia.eventutilities.core.json.JsonSchemaLoader: Proxy method to get a schema by schemaUri directly from the local cache.
cachePut(URI, JsonNode) - Method in class org.wikimedia.eventutilities.core.json.JsonSchemaLoader: Proxy method to put a schema by schemaUri directly in the local cache.
CANARY_DOMAIN - Static variable in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Will be used as the value of meta.domain when building canary events.
canaryEvent(String) - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Given a streamName, gets its schema and uses the JSONSchema examples to make a canary event.
canaryEvent(String, DateTime) - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer
canaryEvent(EventStream) - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Given an EventStream, gets its schema and uses the JSONSchema examples to make a canary event.
canaryEvent(EventStream, DateTime) - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Given an EventStream, gets its schema and uses the JSONSchema examples to make a canary event.
CanaryEventProducer - Class in org.wikimedia.eventutilities.monitoring: Uses an EventStreamFactory to create and POST Wikimedia canary events to Wikimedia event services.
CanaryEventProducer(EventSchemaLoader, EventStreamConfig, BasicHttpClient) - Constructor for class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Constructs a new instance of CanaryEventProducer with a new instance of EventStreamFactory from eventSchemaLoader and eventStreamConfig.
CanaryEventProducer(EventStreamFactory, BasicHttpClient) - Constructor for class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Constructs a new CanaryEventProducer using the provided EventStreamFactory.
canEqual(Object) - Method in class org.wikimedia.eventutilities.core.event.types.SchemaConversions.RowField
causedByException() - Method in class org.wikimedia.eventutilities.core.http.BasicHttpResult: Returns true if this result represents a failure due to a local IOException.
checkJsonSchemaIsObject(ObjectNode) - Static method in class org.wikimedia.eventutilities.core.event.types.JsonSchemaConverter: DRY helper function that asserts that the jsonSchema has "type": "object".
clock(SerializableClock) - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig.EventUtilitiesConfigBuilder: Clock used for various time based operations and timestamp creation.
close() - Method in class org.wikimedia.eventutilities.core.http.BasicHttpClient
collectAllCachedSettings(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Collects all settingName values of every cached stream config entry.
collectAllCachedSettingsAsString(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Collects all settingName values of every cached stream config entry as a String If the value is an array, its contents will be flattened.
collectSetting(String, String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Collects the settingName value for streamName.
collectSettingAsString(String, String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Collects the settingName value as a String for streamName.
collectSettingMatchingSettings(String, List<String>, Map<String, String>) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Collect all settingName values for the list of specified streams with settings that match the provided settingsFilters.
collectSettingMatchingSettingsAsString(String, List<String>, Map<String, String>) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Collect all settingName values as Strings for the list of specified streams with settings that match the provided settingsFilters.
collectSettings(List<String>, String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Collects all settingName values for each of the listed streamNames.
collectSettingsAsString(List<String>, String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Collects all settingName values as a String for each of the listed streamNames.
collectTopics(List<String>) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Get all topics settings for the list of specified streams.
collectTopicsMatchingSettings(List<String>, Map<String, String>) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Get all topics settings for the list of specified streams with settings that match the provided settingsFiilters.
convert(ObjectNode) - Method in class org.wikimedia.eventutilities.core.event.types.JsonSchemaConverter: Converts this JSONSchema using the provided SchemaConversions.
convert(ObjectNode, String) - Method in class org.wikimedia.eventutilities.core.event.types.JsonSchemaConverter: Iterates through jsonSchema and calls appropriate TypeConverter methods on each jsonSchema property type in order to convert it into type T.
convertArrayType(ObjectNode, String) - Method in class org.wikimedia.eventutilities.core.event.types.JsonSchemaConverter
convertMapType(ObjectNode, String) - Method in class org.wikimedia.eventutilities.core.event.types.JsonSchemaConverter
convertRowType(ObjectNode, String) - Method in class org.wikimedia.eventutilities.core.event.types.JsonSchemaConverter
convertValue(JsonNode, Class<T>) - Method in class org.wikimedia.eventutilities.core.json.JsonLoader: Convenience method to reuse our ObjectMapper to convert a JsonNode to a Java Class.
create(HttpResponse, IntPredicate) - Static method in class org.wikimedia.eventutilities.core.http.BasicHttpResult: Creates an BasicHttpResult from an httpcomponents HttpResponse and a lambda isSuccess that determines what http response status codes constitute a successful response.
createAllCachedEventStreams() - Method in class org.wikimedia.eventutilities.core.event.EventStreamFactory: Creates EventStreams for all streams in our EventStreamConfig's cache.
createEventloggingSchemaLoader(BasicHttpClient) - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig
createEventSchemaLoader(BasicHttpClient) - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig
createEventSchemaValidator(EventSchemaLoader) - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig
createEventStream(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamFactory: Returns a new EventStream for this streamName using eventSchemaLoader and eventStreamConfig.
createEventStreamConfig(EventStreamConfigLoader) - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig
createEventStreamEventGenerator(String, String) - Method in class org.wikimedia.eventutilities.core.event.JsonEventGenerator: Create a validating event generator.
createEventStreamFactory(EventSchemaLoader, EventStreamConfig) - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig
createEventStreams(Collection<String>) - Method in class org.wikimedia.eventutilities.core.event.EventStreamFactory: Returns a List of new EventStreams using eventSchemaLoader and eventStreamConfig.
createEventStreamsMatchingSettings(Collection<String>, Map<String, String>) - Method in class org.wikimedia.eventutilities.core.event.EventStreamFactory: Creates EventStreams for the list of specified streams with settings that match the provided settingsFilters.
createFromMessageKeyFields(JsonNode) - Static method in class org.wikimedia.eventutilities.core.event.EventKeySelector
createHttpClient() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig
createJsonEventGenerator(EventSchemaLoader, EventStreamConfig) - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig
createMediawikiEventStreamConfigLoader(BasicHttpClient) - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig
createNonValidatingEventStreamEventGenerator(String, String) - Method in class org.wikimedia.eventutilities.core.event.JsonEventGenerator: Create a non-validating event generator.

D

DATACENTERS - Static variable in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: List of data center names that will be used to look up event service urls.
DEFAULT - Static variable in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig: Default values and instances to aide working with Event Streams in Wikimedia Production.

E

elementsStream() - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Returns a Java Stream iterator over the stream config entries.
encapsulateEventLoggingSchema(JsonNode) - Method in class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader: Given an EventLogging schema in an ObjectNode, 'encapsulate' it in the eventLoggingCapsuleSchema the same way that EventLogging python would.
equals(Object) - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig
equals(Object) - Method in class org.wikimedia.eventutilities.core.event.types.SchemaConversions.RowField
EVENT_GENERATOR - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaDefaults: Deprecated.

Wikimedia JsonEventGenerator default instance.
EVENT_GENERATOR - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaExternalDefaults: Deprecated.

Wikimedia JsonEventGenerator default instance.
EVENT_SCHEMA_BASE_URIS - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaDefaults: Deprecated.

List of event schema base URIs used in WMF production.
EVENT_SCHEMA_BASE_URIS - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaExternalDefaults: Deprecated.

List of event schema base URIs used in WMF production.
EVENT_SCHEMA_LOADER - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaDefaults: Deprecated.

Wikimedia EventSchemaLoader default instance.
EVENT_SCHEMA_LOADER - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaExternalDefaults: Deprecated.

Wikimedia EventSchemaLoader default instance.
EVENT_SCHEMA_VALIDATOR - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaDefaults: Deprecated.

Wikimedia EventSchemaValidator default instance.
EVENT_SCHEMA_VALIDATOR - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaExternalDefaults: Deprecated.

Wikimedia EventSchemaValidator default instance.
EVENT_SERVICE_SETTING - Static variable in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Stream Config setting name for destination event service name.
EVENT_SERVICE_TO_URI_MAP - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaDefaults: Deprecated.

This default is suitable for using in WMF production networks, but may become outdated.
EVENT_SERVICE_TO_URI_MAP - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaExternalDefaults: Deprecated.

This default is suitable for using in WMF production networks, but may become outdated.
EVENT_STREAM_CONFIG - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaDefaults: Deprecated.

Wikimedia EventStreamConfig default instance.
EVENT_STREAM_CONFIG - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaExternalDefaults: Deprecated.

Wikimedia EventStreamConfig default instance.
EVENT_STREAM_CONFIG_ENDPOINT - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaDefaults: Deprecated.

In production, api-ro needs the Host header set to the MediaWiki API that should be accessed.
EVENT_STREAM_CONFIG_URI - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaDefaults: Deprecated.

MediaWiki EventStreamConfig API used in WMF production to use to fetch stream configs.
EVENT_STREAM_CONFIG_URI - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaExternalDefaults: Deprecated.

MediaWiki EventStreamConfig API used in WMF production to use to fetch stream configs.
EVENT_STREAM_FACTORY - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaDefaults: Deprecated.

Wikimedia EventStreamFactory default instance.
EVENT_STREAM_FACTORY - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaExternalDefaults: Deprecated.

Wikimedia EventStreamFactory default instance.
EVENT_TIME_FIELD - Static variable in class org.wikimedia.eventutilities.core.event.JsonEventGenerator
eventId(Supplier<UUID>) - Static method in interface org.wikimedia.eventutilities.core.event.EventNormalizationStep: Set the event if (meta.id) if not already set.
EventKeySelector - Class in org.wikimedia.eventutilities.core.event: Creates a key node by extracting aliased fields from a value node.
EventKeySelector(List<Map.Entry<String, String>>) - Constructor for class org.wikimedia.eventutilities.core.event.EventKeySelector
EVENTLOGGING_SCHEMA_BASE_URI - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaDefaults: Deprecated.

URI from which to get legacy EventLogging on wiki schemas.
EVENTLOGGING_SCHEMA_BASE_URI - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaExternalDefaults: Deprecated.

URI from which to get legacy EventLogging on wiki schemas.
EVENTLOGGING_SCHEMA_FIELD - Static variable in class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader: EventLogging schema names are in an event's `schema` field.
EVENTLOGGING_SCHEMA_LOADER - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaDefaults: Deprecated.

Wikimedia legacy EventLoggingSchemaLoader instance.
EVENTLOGGING_SCHEMA_LOADER - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaExternalDefaults: Deprecated.

Wikimedia legacy EventLoggingSchemaLoader instance.
eventLoggingCapsuleSchema - Variable in class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader: EventCapsule schema.
eventloggingSchemaBaseUri(String) - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig.EventUtilitiesConfigBuilder: URI from which to get legacy EventLogging on wiki schemas.
EventLoggingSchemaLoader - Class in org.wikimedia.eventutilities.core.event: Loads EventLogging schemas from schema names (and/or revisions) by extending EventSchemaLoader and adding Mediawiki extension EventLogging schema specific functionality.
EventLoggingSchemaLoader(JsonSchemaLoader) - Constructor for class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader: Returns an EventLoggingSchemaLoader that uses JsonSchemaLoader to load JSONSchemas.
eventLoggingSchemaUriFor(String) - Method in class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader: Builds an EventLogging Mediawiki API schema URI for the latest revision.
eventLoggingSchemaUriFor(String, Integer) - Method in class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader: Builds an EventLogging Mediawiki API schema URI for a specific schema revision.
EventNormalizationStep - Interface in org.wikimedia.eventutilities.core.event: Define the steps to "normalize" an event before sending it to kafka.
EventNormalizationStep.Validation - Class in org.wikimedia.eventutilities.core.event
eventSchemaBaseUris(List<String>) - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig.EventUtilitiesConfigBuilder
EventSchemaLoader - Class in org.wikimedia.eventutilities.core.event: Class to load and cache JSONSchema JsonNodes from relative schema URIs and event data.
EventSchemaLoader(JsonSchemaLoader, JsonPointer) - Constructor for class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Constructs a EventSchemaLoader that prefixes URIs with baseURI and extracts schema URIs from the schemaField in events.
eventSchemaLoader - Variable in class org.wikimedia.eventutilities.core.event.EventStream: EventSchemaLoader instance used when getting a schema for this stream.
eventSchemaLoader - Variable in class org.wikimedia.eventutilities.core.event.EventStreamFactory: EventSchemaLoader instance used when constructing EventStreams.
EventSchemaLoader.Builder - Class in org.wikimedia.eventutilities.core.event
EventSchemaValidator - Class in org.wikimedia.eventutilities.core.event: Utility class to validate events against their schema.
EventSchemaValidator(EventSchemaLoader) - Constructor for class org.wikimedia.eventutilities.core.event.EventSchemaValidator
eventServiceName() - Method in class org.wikimedia.eventutilities.core.event.EventStream: Gets this EventStream's destination_event_service name.
eventServiceToUriMap - Variable in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Maps event service name to a service URL.
eventServiceToUriMap(Map<String, URI>) - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig.EventUtilitiesConfigBuilder: Mapping of service to port, used to route HTTP traffic through SSL tunnels.
eventServiceUri() - Method in class org.wikimedia.eventutilities.core.event.EventStream: Returns the (discovery) URL to which events belonging to this EventStream should be POSTed.
eventServiceUri(String) - Method in class org.wikimedia.eventutilities.core.event.EventStream: Returns the datacenter specific event service URL to which events belonging to this EventStream should be POSTed.
eventsToArrayNode(List<ObjectNode>) - Static method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Given a List of ObjectNodes, returns an ArrayNode of those ObjectNodes.
EventStream - Class in org.wikimedia.eventutilities.core.event: Represents a single event stream.
EventStream(String, EventSchemaLoader, EventStreamConfig) - Constructor for class org.wikimedia.eventutilities.core.event.EventStream: Consider using EventStreamFactory.createEventStream instead.
eventStreamConfig - Variable in class org.wikimedia.eventutilities.core.event.EventStream: EventStreamConfig instance used to lookup stream config settings for this stream.
EventStreamConfig - Class in org.wikimedia.eventutilities.core.event: Class to fetch and work with stream configuration from the a URI.
EventStreamConfig(EventStreamConfigLoader, Map<String, URI>) - Constructor for class org.wikimedia.eventutilities.core.event.EventStreamConfig: EventStreamConfig constructor.
eventStreamConfig - Variable in class org.wikimedia.eventutilities.core.event.EventStreamFactory: EventStreamConfig instance used when constructing EventStreams and looking up stream configs.
eventStreamConfig(EventStreamConfig) - Method in class org.wikimedia.eventutilities.core.event.JsonEventGenerator.Builder
EventStreamConfig.Builder - Class in org.wikimedia.eventutilities.core.event: Builder, builder pattern to construct EventStreamConfig instances.
eventStreamConfigEndpoint(String) - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig.EventUtilitiesConfigBuilder: In production, the mediawiki internal api endpoint needs the Host header set to the MediaWiki API that should be accessed.
eventStreamConfigLoader - Variable in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Used to load stream config at instantiation and on demand.
EventStreamConfigLoader - Class in org.wikimedia.eventutilities.core.event: Abstract class to load event stream config.
EventStreamConfigLoader() - Constructor for class org.wikimedia.eventutilities.core.event.EventStreamConfigLoader
eventStreamConfigUri(String) - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig.EventUtilitiesConfigBuilder: MediaWiki EventStreamConfig API used in WMF production to use to fetch stream configs.
EventStreamFactory - Class in org.wikimedia.eventutilities.core.event: Class to aide in constructing EventStream instances and working with groups of event streams using EventStreamConfig and EventSchemaLoader.
EventStreamFactory(EventSchemaLoader, EventStreamConfig) - Constructor for class org.wikimedia.eventutilities.core.event.EventStreamFactory: Constructs a new instance of EventStreamFactory.
eventStreamFactory - Variable in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: EventStreamFactory instance used when constructing EventStreams.
EventStreamFactory.Builder - Class in org.wikimedia.eventutilities.core.event: Builder builder pattern to construct EventStreamFactory instance.
eventTime(Instant) - Static method in interface org.wikimedia.eventutilities.core.event.EventNormalizationStep: Set the event time (dt) if not already set.
EventUtilitiesConfig - Class in org.wikimedia.eventutilities.core.event: Configuration for Event Utilities.
EventUtilitiesConfig.EventUtilitiesConfigBuilder - Class in org.wikimedia.eventutilities.core.event
EventUtilitiesFactory - Class in org.wikimedia.eventutilities.core.event
EventUtilitiesFactory(EventUtilitiesConfig) - Constructor for class org.wikimedia.eventutilities.core.event.EventUtilitiesFactory
exampleEvent() - Method in class org.wikimedia.eventutilities.core.event.EventStream: Gets the schema for stream and returns the first element in its JSONSchema examples.
exampleEvent(String) - Method in class org.wikimedia.eventutilities.core.event.EventStream: Gets the schema for stream and returns the first element in its JSONSchema examples.
exception - Variable in class org.wikimedia.eventutilities.core.http.BasicHttpResult: If a local IOException was encountered, this will be set to it.
EXTERNAL_DEFAULT - Static variable in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig: Default values and instances to aide working with Event Streams in Wikimedia outside of production networks, e.g.
extractSchemaUri(JsonNode) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Extracts the value at schemaFieldPointer from the event as a URI.

F

fieldsStream() - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Returns a Java Stream iterator over the Map.Entry of stream name to stream config entries.
filterStreamConfigs(List<String>, Map<String, String>) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Filter stream configs for streamNames that match the settingsFilters.
from(List<String>, String) - Static method in class org.wikimedia.eventutilities.core.event.EventStreamFactory: Helper function to quickly instantiate EventStreamFactory.
from(List<String>, String, Map<String, String>) - Static method in class org.wikimedia.eventutilities.core.event.EventStreamFactory: Helper function to quickly instantiate EventStreamFactory.
from(List<String>, String, Map<String, String>, String) - Static method in class org.wikimedia.eventutilities.core.event.EventStreamFactory: Helper function to quickly instantiate EventStreamFactory.
frozenClock(Instant) - Static method in interface org.wikimedia.eventutilities.core.SerializableClock: A clock that is frozen in time.

G

generateEvent(Consumer<ObjectNode>, Instant) - Method in interface org.wikimedia.eventutilities.core.event.JsonEventGenerator.EventNormalizer
generateEvent(String, String, Consumer<ObjectNode>, Instant) - Method in class org.wikimedia.eventutilities.core.event.JsonEventGenerator: Generates an json event calling the supplier eventData.
generateEvent(String, String, Consumer<ObjectNode>, Instant, boolean) - Method in class org.wikimedia.eventutilities.core.event.JsonEventGenerator: Generates a json event calling the supplier eventData.
get(URI, IntPredicate) - Method in class org.wikimedia.eventutilities.core.http.BasicHttpClient: Performs a GET request at URI and returns a BasicHttpResult.
get(URI) - Method in class org.wikimedia.eventutilities.core.http.BasicHttpClient: Performs a GET request at URI and returns a BasicHttpResult accepting any 2xx status as a success.
getAllCachedTopics() - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Get all topics settings for all known streams.
getAllCanaryEventsToPost() - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Gets canary events to POST for all streams that EventStreamConfig knows about.
getAsBytes(URI) - Method in class org.wikimedia.eventutilities.core.http.BasicHttpClient: Performs a GET request and returns the response body as a byte[].
getBody() - Method in class org.wikimedia.eventutilities.core.http.BasicHttpResult: Returns a copy of the byte[] response body.
getBodyAsString() - Method in class org.wikimedia.eventutilities.core.http.BasicHttpResult
getCanaryEventsToPost(String) - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Gets canary events to POST for a single stream.
getCanaryEventsToPost(String, DateTime) - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Gets canary events to POST for a single stream.
getCanaryEventsToPost(List<String>) - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Gets canary events to POST for a List of stream names.
getCanaryEventsToPost(List<String>, DateTime) - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Gets canary events to POST for a List of stream names.
getCanaryEventsToPostForStreams(List<EventStream>, DateTime) - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Given a list of streams and a timestamp, this will return a map of datacenter specific event service URIs to a list of canary events that should be POSTed to that event service.
getClock() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig: Clock used for various time based operations and timestamp creation.
getContent() - Method in class org.wikimedia.eventutilities.core.http.JsonHttpEntity
getContentLength() - Method in class org.wikimedia.eventutilities.core.http.JsonHttpEntity
getContentType() - Method in class org.wikimedia.eventutilities.core.http.JsonHttpEntity
getDescription() - Method in class org.wikimedia.eventutilities.core.event.types.SchemaConversions.RowField
getEventJsonSchema(String) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Given a JSON event, get its schema URI, and load and return schema for the event as a JsonSchema (suited for validation).
getEventJsonSchema(JsonNode) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Given a JSON event, get its schema URI, and load and return schema for the event as a JsonSchema (suited for validation).
getEventLoggingSchema(String) - Method in class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader: Given an EventLogging schema name , this will get the latest schema revision from EVENTLOGGING_SCHEMA_BASE_URI and encapsulate it.
getEventLoggingSchema(String, Integer) - Method in class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader: Given an EventLogging event schema name and revision, this will get the schema from EVENTLOGGING_SCHEMA_BASE_URI and encapsulate it.
getEventloggingSchemaBaseUri() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig: URI from which to get legacy EventLogging on wiki schemas.
getEventloggingSchemaLoader() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesFactory
getEventSchema(JsonNode) - Method in class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader: Given an EventLogging event object, this extracts its schema name at /schema and uses it to get the latest EventLogging schema.
getEventSchema(String) - Method in class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader: Given an EventLogging json event string, this parses it to a JsonNode and then extracts its schema name at /schema and uses it to get the latest EventLogging schema.
getEventSchema(JsonNode) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Given an event object, this extracts its schema URI at schemaField (prefixed with baseURI) and returns the schema there.
getEventSchema(String) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Given a JSON event string, get its schema URI, and load and return schema for the event.
getEventSchemaBaseUris() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig
getEventSchemaLoader() - Method in class org.wikimedia.eventutilities.core.event.EventStreamFactory: Returns the EventSchemaLoader instance this EventStreamFactory is using.
getEventSchemaLoader() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesFactory
getEventSchemaUri(JsonNode) - Method in class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader: Returns the latest EventLogging schema URI for this event.
getEventSchemaValidator() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesFactory
getEventServiceName(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Gets the destination_event_service name for the specified stream.
getEventServiceToUriMap() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig: Mapping of service to port, used to route HTTP traffic through SSL tunnels.
getEventServiceUri(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Gets the default event service URI for this stream via the EVENT_SERVICE_SETTING.
getEventServiceUri(String, String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Gets a datacenter specific destination event service URI for this stream via the EVENT_SERVICE_SETTING + the datacenter name.
getEventServiceUriByServiceName(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Gets the event service POST URI of an event service.
getEventStreamConfig() - Method in class org.wikimedia.eventutilities.core.event.EventStreamFactory: Returns the EventStreamConfig instance this EventStreamFactory is using.
getEventStreamConfig() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesFactory
getEventStreamConfigEndpoint() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig: In production, the mediawiki internal api endpoint needs the Host header set to the MediaWiki API that should be accessed.
getEventStreamConfigUri() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig: MediaWiki EventStreamConfig API used in WMF production to use to fetch stream configs.
getEventStreamFactory() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesFactory
getEventStreamFactory() - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Returns the EventStreamFactory this CanaryEventProducer is using.
getException() - Method in class org.wikimedia.eventutilities.core.http.BasicHttpResult
getHttpClient() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesFactory
getJsonEventGenerator() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesFactory
getJsonLoader() - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader
getJsonLoader() - Method in class org.wikimedia.eventutilities.core.json.JsonSchemaLoader: Return the underlying JsonLoader.
getJsonMapper() - Method in class org.wikimedia.eventutilities.core.event.JsonEventGenerator
getJsonNode(ObjectNode, String, String) - Static method in class org.wikimedia.eventutilities.core.event.types.JsonSchemaConverter: DRY helper function to get a JsonNode out of an ObjectNode by key, throwing IllegalArgumentException if the key does not exist, or is set to "null".
getJsonSchema(JsonNode) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Given a json schema parsed as a JsonNode materialize JsonSchema suited for validation.
getJsonSchemaType(ObjectNode) - Static method in class org.wikimedia.eventutilities.core.event.types.JsonSchemaConverter: DRY helper function to extract the JSONSchema "type".
getLatestEventSchema(JsonNode) - Method in class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader
getLatestEventSchema(String) - Method in class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader
getLatestEventSchema(JsonNode) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Given an event object, this extracts its schema URI at schemaField (prefixed with baseURI) and resolves it to the latest schema URI and returns the schema there.
getLatestEventSchema(String) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Given a JSON event string, get its schema URI, and load and return latest schema for the event.
getLatestSchema(URI) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Get a 'latest' JsonSchema given a schema URI looking in all baseUris.
getLatestSchemaUri(URI) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Converts the given schemaUri to a 'latest' schema URI.
getLatestSchemaUri(JsonNode) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Extracts the event's schema URI and converts it to a latest schema URI.
getLatestVersionFileName() - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader
getMediawikiEventStreamConfigLoader() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesFactory
getMessage() - Method in class org.wikimedia.eventutilities.core.http.BasicHttpResult
getMessageKeyFields(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Get the Kafka message key fields for a given stream.
getName() - Method in class org.wikimedia.eventutilities.core.event.types.SchemaConversions.RowField
getObjectMapper() - Method in interface org.wikimedia.eventutilities.core.event.JsonEventGenerator.EventNormalizer: The object mapper this normalizer will use to generate json nodes.
getOrSetMeta(ObjectNode) - Static method in interface org.wikimedia.eventutilities.core.event.EventNormalizationStep
getPossibleResourceUris(URI) - Method in class org.wikimedia.eventutilities.core.util.ResourceLoader: If the uri is aboslute, or if no baseUris are set, the only possible uri is the provided one.
getResourceLoader() - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader
getResourceLoader() - Method in class org.wikimedia.eventutilities.core.json.JsonLoader: Returns the underlying ResourceLoader.
getSchema(URI) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Get a JsonSchema at schemaUri looking in all baseUris.
getSchemaTitle(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Get all topics settings for the a single stream.
getSetting(String) - Method in class org.wikimedia.eventutilities.core.event.EventStream: Gets a setting from stream config for this stream.
getSetting(String, String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Gets a stream config setting for a specific stream.
getSettingAsString(String, String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Gets the stream config setting for a specific stream as a string.
getStatus() - Method in class org.wikimedia.eventutilities.core.http.BasicHttpResult
getStreamConfig(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Returns the stream config entry for a specific stream.
getStreamConfigs(List<String>) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Gets the stream config entries for the desired stream names.
getSuccess() - Method in class org.wikimedia.eventutilities.core.http.BasicHttpResult
getTopics(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Get all topics settings for a single stream.
getType() - Method in class org.wikimedia.eventutilities.core.event.types.SchemaConversions.RowField
getUri() - Method in exception org.wikimedia.eventutilities.core.util.ResourceLoadingException

H

hashCode() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig
hashCode() - Method in class org.wikimedia.eventutilities.core.event.types.SchemaConversions.RowField
httpClientBuilder() - Method in class org.wikimedia.eventutilities.core.http.BasicHttpClient.Builder

I

ingestionTime(SerializableClock) - Static method in interface org.wikimedia.eventutilities.core.event.EventNormalizationStep: Set the ingestionTime (meta.dt) if not already set.
ingestionTimeClock(SerializableClock) - Method in class org.wikimedia.eventutilities.core.event.JsonEventGenerator.Builder
isCached(URI) - Method in class org.wikimedia.eventutilities.core.json.JsonSchemaLoader: Proxy method to see if the schemaUri is currently cached.
isNullable() - Method in class org.wikimedia.eventutilities.core.event.types.SchemaConversions.RowField
isRepeatable() - Method in class org.wikimedia.eventutilities.core.http.JsonHttpEntity
isStreaming() - Method in class org.wikimedia.eventutilities.core.http.JsonHttpEntity

J

JsonEventGenerator - Class in org.wikimedia.eventutilities.core.event: Helper class suited to assist java clients producing json events directly to kafka.
JsonEventGenerator.Builder - Class in org.wikimedia.eventutilities.core.event
JsonEventGenerator.EventNormalizer - Interface in org.wikimedia.eventutilities.core.event: A component that applies various normalization and verification steps to the events it receives.
JsonHttpEntity - Class in org.wikimedia.eventutilities.core.http
JsonHttpEntity(ObjectMapper, JsonNode) - Constructor for class org.wikimedia.eventutilities.core.http.JsonHttpEntity
JsonLoader - Class in org.wikimedia.eventutilities.core.json: Uses a ResourceLoader to load content at URIs and parse it into YAML or JSON.
JsonLoader(ResourceLoader) - Constructor for class org.wikimedia.eventutilities.core.json.JsonLoader
JsonLoadingException - Exception in org.wikimedia.eventutilities.core.json: Thrown when an error is encountered by JsonSchemaLoader while attempting to load a JSONSchema from a URI.
JsonLoadingException(String) - Constructor for exception org.wikimedia.eventutilities.core.json.JsonLoadingException
JsonLoadingException(String, Exception) - Constructor for exception org.wikimedia.eventutilities.core.json.JsonLoadingException
jsonMapper(ObjectMapper) - Method in class org.wikimedia.eventutilities.core.event.JsonEventGenerator.Builder
jsonNodesAsText(Collection<JsonNode>) - Static method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Converts a List of JsonNodes to a List of Strings using JsonNode::asText.
JsonSchemaConverter<T> - Class in org.wikimedia.eventutilities.core.event.types: JsonSchemaConverter iterates through the JSONSchema properties and uses the provided SchemaConversions implementation to convert from JSONSchema types.
JsonSchemaConverter(SchemaConversions<T>) - Constructor for class org.wikimedia.eventutilities.core.event.types.JsonSchemaConverter
JsonSchemaLoader - Class in org.wikimedia.eventutilities.core.json: Uses a JsonLoader to fetch JSON schemas from URIs and cache them.
JsonSchemaLoader(JsonLoader) - Constructor for class org.wikimedia.eventutilities.core.json.JsonSchemaLoader: Make a new JsonSchemaLoader using JsonLoader.

L

LATEST_FILE_NAME - Static variable in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: When looking up latest schema versions, this will be used instead of a semver string.
latestSchemaId() - Method in class org.wikimedia.eventutilities.core.event.EventStream: Gets the $id from the latest schema.
latestSchemaURI(String) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Builds the URI to the latest schema using this title.
latestSchemaVersion() - Method in class org.wikimedia.eventutilities.core.event.EventStream: Infers the latest schema version number from the schema's $id field.
load(URI) - Method in class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader: Given a URI to an EventLogging 'event' field (un-encapsulated) schema, this will get the 'event' field schema at that URI, and then encapsulate it.
load(URI) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Returns the content at schemaURI as a JsonNode JSONSchema.
load(List<String>) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfigLoader: Loads stream configs for the given stream names.
load(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfigLoader: Loads stream configs for the given stream name.
load() - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfigLoader: Loads stream configs for all streams.
load(List<String>) - Method in class org.wikimedia.eventutilities.core.event.MediawikiEventStreamConfigLoader: EventStreamConfigLoader load implementation.
load(List<String>) - Method in class org.wikimedia.eventutilities.core.event.StaticEventStreamConfigLoader
load(URI) - Method in class org.wikimedia.eventutilities.core.json.JsonLoader: Given a schemaURI, this will request the JSON or YAML content at that URI and parse it into a JsonNode.
load(URI) - Method in class org.wikimedia.eventutilities.core.json.JsonSchemaLoader: Given a schemaUri, this will request the JSON or YAML content at that URI and parse it into a JsonNode.
load(URI) - Method in class org.wikimedia.eventutilities.core.util.ResourceLoader: Loads the resource at uri, potentially prefixing relative URIs with baseUrls.
loadSchema(URI) - Method in class org.wikimedia.eventutilities.core.event.EventStream: Loads the schema at the relative schemaUri using our eventSchemaLoader.

M

makeCanaryEvent(String, ObjectNode, DateTime) - Static method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Creates a canary event from an example event for a stream.
makeCanaryEvent(String, ObjectNode) - Static method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer
makeMediawikiEventStreamConfigApiUri(String, List<String>) - Static method in class org.wikimedia.eventutilities.core.event.MediawikiEventStreamConfigLoader: Builds a Mediawiki EventStreamConfig extension API URI for the given streams.
MEDIAWIKI_API_HOST - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaDefaults: Deprecated.

Hostname to use when interacting with the MediaWiki action API.
MEDIAWIKI_API_HOST - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaExternalDefaults: Deprecated.

Hostname to use when interacting with the MediaWiki action API.
mediawikiApiEndpoint - Variable in class org.wikimedia.eventutilities.core.event.MediawikiEventStreamConfigLoader: Base Mediawiki API endpoint, e.g https://meta.wikimedia.org/w/api.php.
MediawikiEventStreamConfigLoader - Class in org.wikimedia.eventutilities.core.event: EventStreamConfigLoader implementation that loads stream config from a remote Mediawiki EventStreamConfig extension API endpoint.
MediawikiEventStreamConfigLoader(String, JsonLoader) - Constructor for class org.wikimedia.eventutilities.core.event.MediawikiEventStreamConfigLoader: Constructs a MediawikiEventStreamConfigLoader that loads from mediawikiApiEndpoint using jsonLoader.
message - Variable in class org.wikimedia.eventutilities.core.http.BasicHttpResult: The HTTP response message, or the Exception message if a local exception was encountered.
MESSAGE_KEY_FIELDS_SETTING - Static variable in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Stream config setting name for Kafka message partition keys.
messageKeyFields() - Method in class org.wikimedia.eventutilities.core.event.EventStream: Get the Kafka message key fields.
META_FIELD - Static variable in class org.wikimedia.eventutilities.core.event.JsonEventGenerator
META_ID_FIELD - Static variable in class org.wikimedia.eventutilities.core.event.JsonEventGenerator
META_INGESTION_TIME_FIELD - Static variable in class org.wikimedia.eventutilities.core.event.JsonEventGenerator
META_STREAM_FIELD - Static variable in class org.wikimedia.eventutilities.core.event.JsonEventGenerator
META_WIKIMEDIA_ORG - Static variable in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig

O

OBJECT_MAPPER - Static variable in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Used for serializing JsonNode events to Strings.
objectNodeCollectValues(ObjectNode, String) - Static method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Finds all values of fieldName of each element in objectNode.
org.wikimedia.eventutilities.core - package org.wikimedia.eventutilities.core
org.wikimedia.eventutilities.core.event - package org.wikimedia.eventutilities.core.event
org.wikimedia.eventutilities.core.event.types - package org.wikimedia.eventutilities.core.event.types
org.wikimedia.eventutilities.core.http - package org.wikimedia.eventutilities.core.http
org.wikimedia.eventutilities.core.json - package org.wikimedia.eventutilities.core.json
org.wikimedia.eventutilities.core.util - package org.wikimedia.eventutilities.core.util
org.wikimedia.eventutilities.monitoring - package org.wikimedia.eventutilities.monitoring

P

parse(String) - Method in class org.wikimedia.eventutilities.core.json.JsonLoader: Parses the JSON or YAML string into a JsonNode.
parse(String) - Method in class org.wikimedia.eventutilities.core.json.JsonSchemaLoader: Parses the JSON or YAML string into a JsonNode.
post(URI, byte[]) - Method in class org.wikimedia.eventutilities.core.http.BasicHttpClient: Performs a POST request to URI and returns a BasicHttpResult accepting any 2xx status as a success.
post(URI, byte[], ContentType, IntPredicate) - Method in class org.wikimedia.eventutilities.core.http.BasicHttpClient: Performs a POST request to URI and returns a BasicHttpResult.
post(URI, ObjectMapper, JsonNode, IntPredicate) - Method in class org.wikimedia.eventutilities.core.http.BasicHttpClient: Performs a POST request to URI and returns a BasicHttpResult.
post(URI, HttpEntity, IntPredicate) - Method in class org.wikimedia.eventutilities.core.http.BasicHttpClient: Performs a POST request to URI and returns a BasicHttpResult.
postAllCanaryEvents() - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: POSTs canary events for all known streams.
postCanaryEvents(String) - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Posts canary events for a single streamName.
postCanaryEvents(List<String>) - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Posts canary events for each named event stream.
postCanaryEventsForStreams(List<EventStream>) - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: 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.
postEvents(URI, List<ObjectNode>) - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: POSTs the given list of events to the eventServiceUri.
postEventsToUris(Map<URI, List<ObjectNode>>) - Method in class org.wikimedia.eventutilities.monitoring.CanaryEventProducer: Iterates over the Map of URI to events and posts events to the URI.

R

reset() - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Re-fetches the content for all stream configs and saves it in the local stream configs cache.
ResourceLoader - Class in org.wikimedia.eventutilities.core.util: Loads resource content at URIs.
ResourceLoader(Map<String, Function<URI, byte[]>>, Function<URI, byte[]>, List<URL>) - Constructor for class org.wikimedia.eventutilities.core.util.ResourceLoader
ResourceLoader.Builder - Class in org.wikimedia.eventutilities.core.util: Builder class for ResouceLoader.
ResourceLoadingException - Exception in org.wikimedia.eventutilities.core.util: Thrown when an error is encountered by ResourceLoader while attempting to load a resource URI.
ResourceLoadingException(URI, String) - Constructor for exception org.wikimedia.eventutilities.core.util.ResourceLoadingException
ResourceLoadingException(URI, String, Exception) - Constructor for exception org.wikimedia.eventutilities.core.util.ResourceLoadingException
RESPONSE_STREAMS_KEY - Static variable in class org.wikimedia.eventutilities.core.event.MediawikiEventStreamConfigLoader: Key into the EventStreamConfig API response in which stream configs are located.
RowField(String, T, boolean, String) - Constructor for class org.wikimedia.eventutilities.core.event.types.SchemaConversions.RowField

S

schema() - Method in class org.wikimedia.eventutilities.core.event.EventStream: Infers the latest relative schemaUri for the stream from its schema_title stream config setting and fetches and returns the schema at that URI using eventSchemaLoader.
schema(String) - Method in class org.wikimedia.eventutilities.core.event.EventStream: Get the version relative schemaUri for the stream from its schema_title stream config setting and fetches and returns the schema at that URI using eventSchemaLoader.
SCHEMA_FIELD - Static variable in class org.wikimedia.eventutilities.core.event.JsonEventGenerator
SCHEMA_TITLE_SETTING - Static variable in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Stream Config setting name for schema title.
SchemaConversions<T> - Interface in org.wikimedia.eventutilities.core.event.types: Interface for supported WMF Event Schema type conversions.
SchemaConversions.RowField<T> - Class in org.wikimedia.eventutilities.core.event.types: Data Transfer Object wrapper for a 'row field' type.
schemaFieldPointer - Variable in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Field in an event from which to extract the schema URI.
schemaLoader - Variable in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: JsonSchemaLoader used to load schemas from URIs.
schemaLoader(EventSchemaLoader) - Method in class org.wikimedia.eventutilities.core.event.JsonEventGenerator.Builder
schemaTitle() - Method in class org.wikimedia.eventutilities.core.event.EventStream: Gets the JSONSchema title configured for this EventStream.
schemaUri(String, String) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader: Builds the URI to the schema using this title and this version.
schemaUri(String) - Method in class org.wikimedia.eventutilities.core.event.EventStream: Builds schema URI for stream based on WMF conventions.
schemaUri() - Method in class org.wikimedia.eventutilities.core.event.EventStream: Builds a latest relative schema URI for stream based on WMF conventions.
schemaValidation(ObjectNode, String) - Static method in interface org.wikimedia.eventutilities.core.event.EventNormalizationStep: Validates the event against the provided schema (must be the last step to apply).
SerializableClock - Interface in org.wikimedia.eventutilities.core: A clock that is serializable.
serializeAsBytes(ObjectNode) - Method in class org.wikimedia.eventutilities.core.event.JsonEventGenerator: Helper method to serialize the event as bytes.
setBaseUrls(List<URL>) - Method in class org.wikimedia.eventutilities.core.util.ResourceLoader.Builder: Sets the baseUrls.
setDefaultLoader(Function<URI, byte[]>) - Method in class org.wikimedia.eventutilities.core.util.ResourceLoader.Builder: Sets the default loader.
setEventSchemaLoader(List<String>) - Method in class org.wikimedia.eventutilities.core.event.EventStreamFactory.Builder
setEventSchemaLoader(EventSchemaLoader) - Method in class org.wikimedia.eventutilities.core.event.EventStreamFactory.Builder
setEventServiceToUriMap(Map<String, URI>) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig.Builder
setEventServiceToUriMap(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig.Builder
setEventServiceToUriMap(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamFactory.Builder
setEventServiceToUriMap(Map<String, String>) - Method in class org.wikimedia.eventutilities.core.event.EventStreamFactory.Builder
setEventStreamConfig(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamFactory.Builder
setEventStreamConfig(EventStreamConfig) - Method in class org.wikimedia.eventutilities.core.event.EventStreamFactory.Builder
setEventStreamConfigLoader(EventStreamConfigLoader) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig.Builder
setEventStreamConfigLoader(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig.Builder
setHttpRoute(String, String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamFactory.Builder
setHttpRoutes(Map<String, String>) - Method in class org.wikimedia.eventutilities.core.event.EventStreamFactory.Builder
setJsonLoader(JsonLoader) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig.Builder
setJsonSchemaLoader(JsonSchemaLoader) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader.Builder: Sets the JsonSchemaLoader.
setSchemaField(String) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader.Builder: Sets the schema field from which a schema URI will be extracted from events.
StaticEventStreamConfigLoader - Class in org.wikimedia.eventutilities.core.event: Loads stream config once from a static URI.
StaticEventStreamConfigLoader(URI, JsonLoader) - Constructor for class org.wikimedia.eventutilities.core.event.StaticEventStreamConfigLoader: Constructs a StaticEventStreamConfigLoader that loads from streamConfigUri using jsonLoader.
staticStreamConfigs - Variable in class org.wikimedia.eventutilities.core.event.StaticEventStreamConfigLoader
status - Variable in class org.wikimedia.eventutilities.core.http.BasicHttpResult: The HTTP response status code, or -1 if a local exception was encountered.
streamAndSchema(String, String) - Static method in interface org.wikimedia.eventutilities.core.event.EventNormalizationStep: Forcibly set the stream (meta.stream) and the schema URI.
streamConfigsCache - Variable in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Cached stream configurations.
streamConfigUri - Variable in class org.wikimedia.eventutilities.core.event.StaticEventStreamConfigLoader
streamExists(String) - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Returns true if the stream is declared in stream config.
streamName - Variable in class org.wikimedia.eventutilities.core.event.EventStream
streamName() - Method in class org.wikimedia.eventutilities.core.event.EventStream: Gets the stream name of this EventStream instance.
success - Variable in class org.wikimedia.eventutilities.core.http.BasicHttpResult: If the HTTP request that caused this result was successful.

T

topics() - Method in class org.wikimedia.eventutilities.core.event.EventStream: Gets the list of Kafka topics that compose this stream.
TOPICS_SETTING - Static variable in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Stream config topics setting.
toRegex(Collection<String>) - Static method in class org.wikimedia.eventutilities.core.event.EventStreamConfig: Converts a list of strings to a regex that will match any of the strings.
toString() - Method in class org.wikimedia.eventutilities.core.event.EventLoggingSchemaLoader
toString() - Method in class org.wikimedia.eventutilities.core.event.EventSchemaLoader
toString() - Method in class org.wikimedia.eventutilities.core.event.EventStream
toString() - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfig
toString() - Method in class org.wikimedia.eventutilities.core.event.EventStreamConfigLoader
toString() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig.EventUtilitiesConfigBuilder
toString() - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig
toString() - Method in class org.wikimedia.eventutilities.core.event.MediawikiEventStreamConfigLoader
toString() - Method in class org.wikimedia.eventutilities.core.event.StaticEventStreamConfigLoader
toString() - Method in class org.wikimedia.eventutilities.core.event.types.SchemaConversions.RowField
toString() - Method in class org.wikimedia.eventutilities.core.http.BasicHttpResult
toString() - Method in class org.wikimedia.eventutilities.core.json.JsonLoader
toString() - Method in class org.wikimedia.eventutilities.core.util.ResourceLoader
typeArray(T, boolean) - Method in interface org.wikimedia.eventutilities.core.event.types.SchemaConversions: Returns type that represents Array.
typeBoolean() - Method in interface org.wikimedia.eventutilities.core.event.types.SchemaConversions: Returns type that represents boolean.
typeDecimal() - Method in interface org.wikimedia.eventutilities.core.event.types.SchemaConversions: Returns type that represents decimal.
typeInteger() - Method in interface org.wikimedia.eventutilities.core.event.types.SchemaConversions: Returns type that represents integer.
typeMap(T, T, boolean) - Method in interface org.wikimedia.eventutilities.core.event.types.SchemaConversions: Returns type that represents Map.
typeNull() - Method in interface org.wikimedia.eventutilities.core.event.types.SchemaConversions: Returns type that represents null.
typeRow(List<SchemaConversions.RowField<T>>) - Method in interface org.wikimedia.eventutilities.core.event.types.SchemaConversions: Returns type that represents a row AKA a struct AKA a JSON object.
typeString() - Method in interface org.wikimedia.eventutilities.core.event.types.SchemaConversions: Returns type that represents String.
typeTimestamp() - Method in interface org.wikimedia.eventutilities.core.event.types.SchemaConversions: Returns type that represents timestamps.

V

validate(String) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaValidator
validate(JsonNode) - Method in class org.wikimedia.eventutilities.core.event.EventSchemaValidator

W

WIKIMEDIA_HTTP_CLIENT - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaDefaults: Deprecated.

Http client with routes set to work on the internal wikimedia network.
WIKIMEDIA_HTTP_CLIENT - Static variable in class org.wikimedia.eventutilities.core.event.WikimediaExternalDefaults: Deprecated.

Http client with routes set to work on the internal wikimedia network.
WikimediaDefaults - Class in org.wikimedia.eventutilities.core.event: Deprecated.
use EventUtilitiesConfig instead
WikimediaExternalDefaults - Class in org.wikimedia.eventutilities.core.event: Deprecated.
use EventUtilitiesConfig instead
withClock(SerializableClock) - Method in class org.wikimedia.eventutilities.core.event.EventUtilitiesConfig: Clock used for various time based operations and timestamp creation.
withHttpClient(BasicHttpClient) - Method in class org.wikimedia.eventutilities.core.util.ResourceLoader.Builder: Adds loaders for http and https using BasicHttpClient.
withHttpClient() - Method in class org.wikimedia.eventutilities.core.util.ResourceLoader.Builder: Adds loaders for http and https using a default BasicHttpClient.
withUuidSupplier(Supplier<UUID>) - Method in class org.wikimedia.eventutilities.core.event.JsonEventGenerator.Builder
writeTo(OutputStream) - Method in class org.wikimedia.eventutilities.core.http.JsonHttpEntity

A B C D E F G H I J L M O P R S T V W