object EventProducer
The event producer implementation that can be included a gRPC route in an Akka HTTP server.
- Source
- EventProducer.scala
- Alphabetic
- By Inheritance
- EventProducer
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final class EventProducerSource extends AnyRef
- final class Transformation extends AnyRef
Transformation of events to the external (public) representation.
Transformation of events to the external (public) representation. Events can be excluded by mapping them to
None
.
Value Members
- def grpcServiceHandler(sources: Set[EventProducerSource], interceptor: Option[EventProducerInterceptor])(implicit system: ActorSystem[_]): PartialFunction[HttpRequest, Future[HttpResponse]]
The gRPC route that can be included in an Akka HTTP server.
The gRPC route that can be included in an Akka HTTP server.
- sources
All sources that should be available from this event producer
- interceptor
An optional request interceptor applied to each request to the service
- def grpcServiceHandler(sources: Set[EventProducerSource])(implicit system: ActorSystem[_]): PartialFunction[HttpRequest, Future[HttpResponse]]
The gRPC route that can be included in an Akka HTTP server.
The gRPC route that can be included in an Akka HTTP server.
- sources
All sources that should be available from this event producer
- def grpcServiceHandler(source: EventProducerSource)(implicit system: ActorSystem[_]): PartialFunction[HttpRequest, Future[HttpResponse]]
The gRPC route that can be included in an Akka HTTP server.
- object EventProducerSource
- object Transformation