-
Notifications
You must be signed in to change notification settings - Fork 53
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
KV mirror #391
Conversation
@@ -83,6 +109,9 @@ export class StreamAPIImpl extends BaseApiClient implements StreamAPI { | |||
validateStreamName(name); | |||
const old = await this.info(name); | |||
const update = Object.assign(old.config, cfg); | |||
update.mirror = convertStreamSourceDomain(update.mirror); |
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.
Not sure updating a stream and changing the mirror/source actually works (in that I don't think the server supports that), so maybe the reason why it is only on "AddStream" in the go client?
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 should be a noop regardless - because it has to have "domain" set which won't be, so it is ignored. I just wanted to trap it for uniformity in case it updates later.
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
… to, to prevent a lookup of a stream by subject. [FEAT] added support for KVs to be accessed from a mirror
@kozlovic I added the additional changes required by the client to support history, watch, keys. |
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
No description provided.