-
Notifications
You must be signed in to change notification settings - Fork 27
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
feat(*): Notifies on manifest deployment #79
feat(*): Notifies on manifest deployment #79
Conversation
0b19d4d
to
bd15001
Compare
bd15001
to
593a575
Compare
src/mirror/mod.rs
Outdated
description: Some(format!("Durable wadm mirror consumer for {lattice_id}")), | ||
ack_policy: async_nats::jetstream::consumer::AckPolicy::Explicit, | ||
// These should be real quick to ack | ||
ack_wait: std::time::Duration::from_secs(1), |
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.
Since this is a mirror, it's always a local NATS message right? I'd only ask to make this configurable if this message will traverse over a real network boundary
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.
It will likely cross a network boundary. I'll bump this to 2s, but because this is temporary I don't really see a need to make it configurable
Please note that this is a bit big because I had to have a stream that combined internal wadm events with wasmbus ones. However, I did realize that we only care about streams for their configuration and delivery guarantees, and not for their storage capabilities. Because of this, we don't actually have to have the users configure the streams beforehand. So while this adds one more stream to manage combining the two topics (until nats 2.10 comes out and we move to it), the user no longer has to configure any of them. Closes wasmCloud#49 Signed-off-by: Taylor Thomas <taylor@cosmonic.com>
593a575
to
b6aa026
Compare
Please note that this is a bit big because I had to have a stream that combined internal wadm events with wasmbus ones. However, I did realize that we only care about streams for their configuration and delivery guarantees, and not for their storage capabilities. Because of this, we don't actually have to have the users configure the streams beforehand. So while this adds one more stream to manage combining the two topics (until nats 2.10 comes out and we move to it), the user no longer has to configure any of them.
Closes #49