-
Notifications
You must be signed in to change notification settings - Fork 0
Add basic filtered replication and write pause #40
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
ShooterIT
left a comment
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.
excellent work!
| /* Add main channel client to the list of slaves */ | ||
| client *main_ch_client = task->main_channel_client; | ||
| main_ch_client->flags |= CLIENT_SLAVE; | ||
| main_ch_client->flags |= (CLIENT_SLAVE | CLIENT_REPL_MIGRATION_DEST); |
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.
for your approach, maybe we don't mark this client as slave, so can revert my several changes, let me try it 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.
yes, I initially did it that way. Either approach is possible but not sure which one is better. In one sense, this is a slave and makes sense to mark as SLAVE. Though, it causes some problems when you don't want to forward from replication backlog directly and had to mitigate this way.
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.
OK, i see, we can decide later
Add basic filtered replication and write pause Changes: Initial implementation for filtered repl stream delivery to destination node Initial write pause Fixes for crashes & code refactor TODO: Write pause time limit Tests
Add basic filtered replication and write pause Changes: Initial implementation for filtered repl stream delivery to destination node Initial write pause Fixes for crashes & code refactor TODO: Write pause time limit Tests
Changes:
TODO: