Uses of Class
org.wikimedia.eventutilities.core.event.EventStream

Packages that use EventStream

Package	Description
org.wikimedia.eventutilities.core.event
org.wikimedia.eventutilities.monitoring

Uses of EventStream in org.wikimedia.eventutilities.core.event

Methods in org.wikimedia.eventutilities.core.event that return EventStream

Modifier and Type	Method and Description
EventStream	EventStreamFactory.createEventStream(String streamName) Returns a new EventStream for this streamName using eventSchemaLoader and eventStreamConfig.

Methods in org.wikimedia.eventutilities.core.event that return types with arguments of type EventStream

Modifier and Type	Method and Description
List<EventStream>	EventStreamFactory.createAllCachedEventStreams() Creates EventStreams for all streams in our EventStreamConfig's cache.
List<EventStream>	EventStreamFactory.createEventStreams(Collection<String> streamNames) Returns a List of new EventStreams using eventSchemaLoader and eventStreamConfig.
List<EventStream>	EventStreamFactory.createEventStreamsMatchingSettings(Collection<String> streamNames, Map<String,String> settingsFilters) Creates EventStreams for the list of specified streams with settings that match the provided settingsFilters.

Uses of EventStream in org.wikimedia.eventutilities.monitoring

Methods in org.wikimedia.eventutilities.monitoring with parameters of type EventStream

Modifier and Type	Method and Description
com.fasterxml.jackson.databind.node.ObjectNode	CanaryEventProducer.canaryEvent(EventStream es) Given an EventStream, gets its schema and uses the JSONSchema examples to make a canary event.
com.fasterxml.jackson.databind.node.ObjectNode	CanaryEventProducer.canaryEvent(EventStream es, org.joda.time.DateTime timestamp) Given an EventStream, gets its schema and uses the JSONSchema examples to make a canary event.

Method parameters in org.wikimedia.eventutilities.monitoring with type arguments of type EventStream

Modifier and Type	Method and Description
Map<URI,List<com.fasterxml.jackson.databind.node.ObjectNode>>	CanaryEventProducer.getCanaryEventsToPostForStreams(List<EventStream> eventStreams, org.joda.time.DateTime timestamp) 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.
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.