-
Notifications
You must be signed in to change notification settings - Fork 18
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
CASSANDRA-18221: Add AccordConfig to track accord specific configs #39
base: trunk
Are you sure you want to change the base?
Conversation
final List<Instance> instances = new CopyOnWriteArrayList<>(); | ||
|
||
public SimpleProgressLog(Node node) | ||
public SimpleProgressLog(Node node, AccordConfig config) |
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.
should Node
expose config? That way you don't need to pass all over?
@@ -29,6 +29,7 @@ | |||
|
|||
import javax.annotation.Nullable; | |||
|
|||
import accord.utils.AccordConfig; |
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 feel we should have accord.config
package, this is likely to expand over time
@@ -822,7 +825,7 @@ void ensureScheduled() | |||
return; | |||
|
|||
isScheduled = true; | |||
node.scheduler().once(() -> commandStore.execute(PreLoadContext.empty(), ignore -> run()).begin(commandStore.agent()), 200L, TimeUnit.MILLISECONDS); | |||
node.scheduler().once(() -> commandStore.execute(PreLoadContext.empty(), ignore -> run()).begin(commandStore.agent()), config.progress_log_scheduler_delay_in_ms, TimeUnit.MILLISECONDS); |
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.
we are trying to move away from _in_ms
postfix... this may call out that we should likely move some of the config classes to accord?
public AccordConfig(long progress_log_scheduler_delay_in_ms) { | ||
this.progress_log_scheduler_delay_in_ms = progress_log_scheduler_delay_in_ms; | ||
} |
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 constructor isn't something we can maintain, as we add more and more configs this will become an issue
6a9482b
to
4a8566a
Compare
c3a1d8f
to
efc6a38
Compare
289d5ea
to
064735b
Compare
2edc7fb
to
a271897
Compare
50d6ef9
to
bd0761c
Compare
183d5d0
to
cd7f495
Compare
patch by Kamalesh Palanisamy;