-
Notifications
You must be signed in to change notification settings - Fork 36
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
doc: grpc sample restaurant order replication #963
Conversation
samples/grpc/local-drone-control-scala/src/main/protobuf/common/coordinates.proto
Show resolved
Hide resolved
implicit val timeout: Timeout = settings.askTimeout | ||
|
||
// initial consumer topic filter for location id | ||
// FIXME no docs of setting up initial consumer filter, am I missing some API? |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
looking good
samples/grpc/local-drone-control-scala/src/main/protobuf/common/coordinates.proto
Show resolved
Hide resolved
samples/grpc/local-drone-control-scala/src/main/scala/local/drones/DeliveriesQueue.scala
Outdated
Show resolved
Hide resolved
"delivery-events", | ||
// location id already is in the format of a topic filter expression | ||
Vector( | ||
ConsumerFilter.ExcludeRegexEntityIds(Set(".*")), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this can use the new excludeAll, and include filter in GrpcReadJournal constructor
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yep, but not until we made a milestone with those
samples/grpc/local-drone-control-scala/src/main/scala/local/drones/DeliveriesQueue.scala
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Central cloud accepts setting up restaurants and their locations, then registering deliveries per restaurant, the delivery orders are then replicated to the right local drone control where a drone can get assigned the closest by order on request.