Package | Description |
---|---|
org.wikimedia.eventutilities.core.event | |
org.wikimedia.eventutilities.monitoring |
Modifier and Type | Field and Description |
---|---|
static EventStreamFactory |
WikimediaDefaults.EVENT_STREAM_FACTORY
Deprecated.
Wikimedia EventStreamFactory default instance.
|
static EventStreamFactory |
WikimediaExternalDefaults.EVENT_STREAM_FACTORY
Deprecated.
Wikimedia EventStreamFactory default instance.
|
Modifier and Type | Method and Description |
---|---|
EventStreamFactory |
EventStreamFactory.Builder.build()
Returns a new EventStreamFactory.
|
EventStreamFactory |
EventUtilitiesConfig.createEventStreamFactory(EventSchemaLoader eventSchemaLoader,
EventStreamConfig eventStreamConfig) |
static EventStreamFactory |
EventStreamFactory.from(List<String> eventSchemaBaseUris,
String eventStreamConfigUri)
Helper function to quickly instantiate EventStreamFactory.
|
static EventStreamFactory |
EventStreamFactory.from(List<String> eventSchemaBaseUris,
String eventStreamConfigUri,
Map<String,String> httpRoutes)
Helper function to quickly instantiate EventStreamFactory.
|
static EventStreamFactory |
EventStreamFactory.from(List<String> eventSchemaBaseUris,
String eventStreamConfigUri,
Map<String,String> httpRoutes,
String eventServiceToUriMapUrl)
Helper function to quickly instantiate EventStreamFactory.
|
EventStreamFactory |
EventUtilitiesFactory.getEventStreamFactory() |
Modifier and Type | Field and Description |
---|---|
protected EventStreamFactory |
CanaryEventProducer.eventStreamFactory
EventStreamFactory instance used when constructing EventStreams.
|
Modifier and Type | Method and Description |
---|---|
EventStreamFactory |
CanaryEventProducer.getEventStreamFactory()
Returns the EventStreamFactory this CanaryEventProducer is using.
|
Constructor and Description |
---|
CanaryEventProducer(EventStreamFactory eventStreamFactory,
BasicHttpClient client)
Constructs a new CanaryEventProducer using the provided EventStreamFactory.
|
Copyright © 2025. All rights reserved.