-
Notifications
You must be signed in to change notification settings - Fork 699
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
chore: Bind Object Store bucket stream when getting object. #1568
chore: Bind Object Store bucket stream when getting object. #1568
Conversation
0648187
to
c88ede9
Compare
c88ede9
to
8dd5559
Compare
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.
That's a great change, thanks! LGTM, just one nit.
test/object_test.go
Outdated
Name: fmt.Sprintf("OBJ_%s", mirrorBucketName), | ||
Mirror: &nats.StreamSource{ | ||
Name: fmt.Sprintf("OBJ_%s", bucketName), | ||
//FilterSubject: fmt.Sprintf("$O.%s.>", bucketName), |
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 should be removed
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.
Thanks! Addressed https://github.com/nats-io/nats.go/compare/8dd55597a3e322af2f638690cd860c5dfb0b7b7a..dce3c368c223901e66420afa21850e87f5782594 and tests pass this time.
The change is needed to properly operate on mirrored object store buckets. By binding stream nats.go does not need to search for stream by subjects (which does not work for mirrors).
8dd5559
to
dce3c36
Compare
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!
The change is needed to properly operate on mirrored object store buckets. By binding stream nats.go does not need to search for stream by subjects (which does not work for mirrors).
The change is needed to properly operate on mirrored object store buckets. By binding stream nats.go does not need to search for stream by subjects (which does not work for mirrors).
The change is needed to properly operate on mirrored object store buckets. By binding stream nats.go does not need to search for stream by subjects (which does not work for mirrors).
Related issue: nats-io/nats-server#5106