Comments (11)
So, this has turned out to be a bit of a yak shave. There's a lot of things to solve. My progress is here:
https://github.com/jroper/cloudstate/tree/eventing
I haven't even started on projection support, just getting things ready. Here's what I've implemented:
- Modified it so the event source isn't a
Source
, it takes aFlow
and is responsible for running it. - Made acknowledgements so they execute after the handler has returned (previously, they were executed in parallel to the handler handling the event, meaning event processing was at most once). This is why the
Source
takes aFlow
, the output of theFlow
is the acknowledgement message references. - Made the Google Pubsub support use the streaming call properly - we send one subscription call, send the messages in the pull response through the handler, and then route the acknowledgements back into the input of the call (a circular graph), rather than making separate gRPC calls for it.
- Added a RestartSource so that when there's a network/io failure/application error etc, the stream restarts.
- Implemented support for more than just serialized Anys on the wire. We now support JSON, plain text, plain bytes, and protobufs (not wrapped in Any). We use Cloudevents metadata to pass type information.
- Added support for Cloudevents. This metadata is not yet sent to/from the user functions, but it will be.
I'm now pretty close to actually implementing the projection support.
from cloudstate.
Current status video by @jroper - https://youtu.be/lan5Awqy-xI
from cloudstate.
@viktorklang, can we sync on that to avoid having different APIs? Unless this is something that needs to be completely different because of its nature.
But in any case, ultimately, it would be better if the underlying used API (not the one exposed to the client) is based on what we plan to build for general projections in Akka/Play/Lagom.
from cloudstate.
@renatocaval This Issue is not about creating a new API, it's more to establish the flow to what they will create their projections from/using. Initially we're likely to either use the Akka Persistence projections or create an ingress for Pipelines.
from cloudstate.
I got it. Thanks for the explanation.
from cloudstate.
from cloudstate.
Nice @jroper !
from cloudstate.
Hi ... Any new progress on this? I was wondering if it's possible to consume Kafka events and react to them using CloudState.
from cloudstate.
@omidb Reacting to Kafka events seems more like a Eventing-related question. You can implement support for Kafka and plug that into the Eventing Support (currently on Google Cloud PubSub support is built in).
from cloudstate.
@viktorklang Would you please point me to the docs for Eventing Support?
from cloudstate.
@omidb It has not been officially released yet, but you can see it here:
And how it can be used here: https://github.com/cloudstateio/cloudstate/blob/master/protocols/example/shoppingcart/shoppingcart.proto#L47
from cloudstate.
Related Issues (20)
- TCK: order of state action updates for addItem by the value entity ShoppingCart HOT 4
- Empty streamed responses are not actually connected HOT 2
- Dead letter logs on CRDT entity passivation HOT 1
- Failure: multiple grpc services in the same package HOT 1
- Projections for value entities
- HTTP API default mappings HOT 1
- Docker build error for Dockerfile.js-shopping-cart HOT 3
- Documentation on How to get started is not complete
- How / when are new versions of cloudstate-proxy-dev-mode published HOT 5
- Upgrade to akka-persistence-spanner 1.0.0-RC5 HOT 16
- Add local cache images layer for docker images on build HOT 5
- [proto] having gRPC service names PascalCase'd and others. HOT 1
- Usability issue with CRUD entity naming HOT 9
- Native-image Cassandra smoke test is flaky HOT 2
- nil pointer exception in spanner_store.go
- K8s Resource limits not applied to user functions HOT 2
- Additional conditions not managed properly when reconciling StatefulService
- NPM module postinstall fails on Windows
- A proposal to find and agree on a common protocol to discover services HOT 5
- The wrong site HOT 1
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
π Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. πππ
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google β€οΈ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from cloudstate.