This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-projection.git
from 14bcba1 fix: move latch.countDown() after buffer.append() in
concatHandler to fix race condition (#464)
add 1f31e05 add pekko-projection-grpc module (#457)
No new revisions were added by this update.
Summary of changes:
.github/workflows/checks.yml | 2 +-
build.sbt | 16 +-
.../pekko/projection/grpc/event_producer.proto | 109 ++++++
grpc/src/main/resources/reference.conf | 36 ++
.../grpc/consumer/GrpcQuerySettings.scala | 108 ++++++
.../grpc/consumer/GrpcReadJournalProvider.scala | 34 ++
.../grpc/consumer/javadsl/GrpcReadJournal.scala | 126 +++++++
.../grpc/consumer/scaladsl/GrpcReadJournal.scala | 388 +++++++++++++++++++++
.../grpc/internal/EventProducerServiceImpl.scala | 293 ++++++++++++++++
.../grpc/internal/ProtoAnySerialization.scala | 378 ++++++++++++++++++++
.../grpc/producer/EventProducerSettings.scala | 45 +++
.../grpc/producer/javadsl/EventProducer.scala | 103 ++++++
.../javadsl/EventProducerInterceptor.scala | 35 ++
.../producer/javadsl/EventProducerSource.scala | 36 ++
.../grpc/producer/javadsl/Transformation.scala | 69 ++++
.../grpc/producer/scaladsl/EventProducer.scala | 172 +++++++++
.../grpc/producer/javadsl/ProducerCompileTest.java | 60 ++++
.../example/shoppingcart/shoppingcart_api.proto | 23 ++
.../pekko/projection/grpc/internal/test.proto | 11 +
grpc/src/test/resources/application.conf | 30 ++
grpc/src/test/resources/logback-test.xml | 42 +++
.../grpc/consumer/GrpcQuerySettingsSpec.scala | 37 ++
.../grpc/internal/EventProducerServiceSpec.scala | 300 ++++++++++++++++
.../grpc/internal/ProtoAnySerializationSpec.scala | 78 +++++
.../pekko/projection/grpc/internal/TestData.scala | 42 +++
project/Dependencies.scala | 18 +-
project/plugins.sbt | 2 +
27 files changed, 2589 insertions(+), 4 deletions(-)
create mode 100644
grpc/src/main/protobuf/org/apache/pekko/projection/grpc/event_producer.proto
create mode 100644 grpc/src/main/resources/reference.conf
create mode 100644
grpc/src/main/scala/org/apache/pekko/projection/grpc/consumer/GrpcQuerySettings.scala
create mode 100644
grpc/src/main/scala/org/apache/pekko/projection/grpc/consumer/GrpcReadJournalProvider.scala
create mode 100644
grpc/src/main/scala/org/apache/pekko/projection/grpc/consumer/javadsl/GrpcReadJournal.scala
create mode 100644
grpc/src/main/scala/org/apache/pekko/projection/grpc/consumer/scaladsl/GrpcReadJournal.scala
create mode 100644
grpc/src/main/scala/org/apache/pekko/projection/grpc/internal/EventProducerServiceImpl.scala
create mode 100644
grpc/src/main/scala/org/apache/pekko/projection/grpc/internal/ProtoAnySerialization.scala
create mode 100644
grpc/src/main/scala/org/apache/pekko/projection/grpc/producer/EventProducerSettings.scala
create mode 100644
grpc/src/main/scala/org/apache/pekko/projection/grpc/producer/javadsl/EventProducer.scala
create mode 100644
grpc/src/main/scala/org/apache/pekko/projection/grpc/producer/javadsl/EventProducerInterceptor.scala
create mode 100644
grpc/src/main/scala/org/apache/pekko/projection/grpc/producer/javadsl/EventProducerSource.scala
create mode 100644
grpc/src/main/scala/org/apache/pekko/projection/grpc/producer/javadsl/Transformation.scala
create mode 100644
grpc/src/main/scala/org/apache/pekko/projection/grpc/producer/scaladsl/EventProducer.scala
create mode 100644
grpc/src/test/java/org/apache/pekko/projection/grpc/producer/javadsl/ProducerCompileTest.java
create mode 100644
grpc/src/test/protobuf/com/example/shoppingcart/shoppingcart_api.proto
create mode 100644
grpc/src/test/protobuf/org/apache/pekko/projection/grpc/internal/test.proto
create mode 100644 grpc/src/test/resources/application.conf
create mode 100644 grpc/src/test/resources/logback-test.xml
create mode 100644
grpc/src/test/scala/org/apache/pekko/projection/grpc/consumer/GrpcQuerySettingsSpec.scala
create mode 100644
grpc/src/test/scala/org/apache/pekko/projection/grpc/internal/EventProducerServiceSpec.scala
create mode 100644
grpc/src/test/scala/org/apache/pekko/projection/grpc/internal/ProtoAnySerializationSpec.scala
create mode 100644
grpc/src/test/scala/org/apache/pekko/projection/grpc/internal/TestData.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
