-
Notifications
You must be signed in to change notification settings - Fork 1.6k
[CLN]: split up log impls into separate files #3575
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
Conversation
Reviewer ChecklistPlease leverage this checklist to ensure your code review is thorough before approving Testing, Bugs, Errors, Logs, Documentation
System Compatibility
Quality
|
This stack of pull requests is managed by Graphite. Learn more about stacking. |
2379f89
to
e0312e9
Compare
e0312e9
to
4d42e16
Compare
4d42e16
to
bc54aac
Compare
impl Debug for InternalLogRecord { | ||
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { | ||
f.debug_struct("LogRecord") | ||
.field("collection_id", &self.collection_id) | ||
.field("log_offset", &self.log_offset) | ||
.field("log_ts", &self.log_ts) | ||
.field("record", &self.record) | ||
.finish() | ||
} | ||
} |
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 looks as good as Derive. Any reason for manual impl?
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.
I'm not sure, Derive seems fine. Leaving as-is in this PR to avoid code change & re-org in the same PR.
offset: i64, | ||
batch_size: i32, |
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.
Do these have to be signed?
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.
No, but they're also signed in the proto. Leaving as-is in this PR to avoid code change & re-org in the same PR.
pub(super) async fn update_collection_log_offset( | ||
&mut self, | ||
collection_id: CollectionUuid, | ||
new_offset: i64, |
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.
Does this have to be signed?
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.
See above comment.
bc54aac
to
e511313
Compare
Description of changes
No logic changes, just split up the single file that had both the in-memory and grpc log impls.
Test plan
How are these changes tested?
pytest
for python,yarn test
for js,cargo test
for rustDocumentation Changes
Are all docstrings for user-facing APIs updated if required? Do we need to make documentation changes in the docs repository?
n/a