akka.projection.grpc.internal.proto
EventProducerServiceClient
Companion object EventProducerServiceClient
trait EventProducerServiceClient extends EventProducerService with EventProducerServiceClientPowerApi with AkkaGrpcClient
- Annotations
- @AkkaGrpcGenerated()
- Source
- EventProducerServiceClient.scala
- Alphabetic
- By Inheritance
- EventProducerServiceClient
- AkkaGrpcClient
- EventProducerServiceClientPowerApi
- EventProducerService
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def close(): Future[Done]
- Definition Classes
- AkkaGrpcClient
- abstract def closed: Future[Done]
- Definition Classes
- AkkaGrpcClient
- abstract def eventTimestamp(in: EventTimestampRequest): Future[EventTimestampResponse]
Used in some edge cases by the offset store to retrieve the timestamp for a certain event.
Used in some edge cases by the offset store to retrieve the timestamp for a certain event.
- Definition Classes
- EventProducerService
- abstract def eventsBySlices(in: Source[StreamIn, NotUsed]): Source[StreamOut, NotUsed]
- Definition Classes
- EventProducerService
- abstract def loadEvent(in: LoadEventRequest): Future[LoadEventResponse]
Lazy loading of a specific event.
Lazy loading of a specific event.
- Definition Classes
- EventProducerService
Concrete Value Members
- def eventTimestamp(): SingleResponseRequestBuilder[EventTimestampRequest, EventTimestampResponse]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer eventTimestamp(akka.projection.grpc.internal.proto.EventTimestampRequest) if possible.
- Definition Classes
- EventProducerServiceClientPowerApi
- def eventsBySlices(): StreamResponseRequestBuilder[Source[StreamIn, NotUsed], StreamOut]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer eventsBySlices(akka.stream.scaladsl.Source[akka.projection.grpc.internal.proto.StreamIn, akka.NotUsed]) if possible.
- Definition Classes
- EventProducerServiceClientPowerApi
- def loadEvent(): SingleResponseRequestBuilder[LoadEventRequest, LoadEventResponse]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer loadEvent(akka.projection.grpc.internal.proto.LoadEventRequest) if possible.
- Definition Classes
- EventProducerServiceClientPowerApi