capistrant commented on code in PR #12624:
URL: https://github.com/apache/druid/pull/12624#discussion_r894632346
##########
server/src/test/java/org/apache/druid/server/coordinator/TestDruidCoordinatorConfig.java:
##########
@@ -252,4 +223,333 @@ public boolean getCoordinatorKillIgnoreDurationToRetain()
{
return coordinatorKillIgnoreDurationToRetain;
}
+
+ @Override
+ public String getLoadQueuePeonType()
+ {
+ return loadQueuePeonType;
+ }
+
+ @Override
+ public Duration getHttpLoadQueuePeonRepeatDelay()
+ {
+ return httpLoadQueuePeonRepeatDelay;
+ }
+
+ @Override
+ public int getNumCuratorCallBackThreads()
+ {
+ return curatorLoadQueuePeonNumCallbackThreads;
+ }
+
+ @Override
+ public Duration getHttpLoadQueuePeonHostTimeout()
+ {
+ return httpLoadQueuePeonHostTimeout;
+ }
+
+ @Override
+ public int getHttpLoadQueuePeonBatchSize()
+ {
+ return httpLoadQueuePeonBatchSize;
+ }
+
+ public static class Builder
+ {
+ private static final Duration DEFAULT_COORDINATOR_START_DELAY = new
Duration("PT300s");
+ private static final Duration DEFAULT_COORDINATOR_PERIOD = new
Duration("PT60s");
+ private static final Duration DEFAULT_COORDINATOR_INDEXING_PERIOD = new
Duration("PT1800s");
+ private static final Duration DEFAULT_METADATA_STORE_MANAGEMENT_PERIOD =
new Duration("PT3600s");
+ private static final Duration DEFAULT_COORDINATOR_KILL_PERIOD = new
Duration("PT86400s");
+ private static final Duration DEFAULT_COORDINATOR_KILL_DURATION_TO_RETAION
= new Duration("PT7776000s");
+ private static final boolean
DEFAULT_COORDINATOR_KILL_IGNORE_DURATION_TO_RETAIN = false;
+ private static final int DEFAULT_COORDINATOR_KILL_MAX_SEGMENTS = 100;
+ private static final Duration DEFAULT_COORDINATOR_SUPERVISOR_KILL_PERIOD =
new Duration("PT86400s");
+ private static final Duration
DEFAULT_COORDINATOR_SUPERVISOR_KILL_DURATION_TO_RETAIN = new
Duration("PT7776000s");
+ private static final Duration DEFAULT_COORDINATOR_COMPACTION_KILL_PERIOD =
new Duration("PT86400s");
+ private static final Duration DEFAULT_COORDINATOR_RULE_KILL_PERIOD = new
Duration("PT86400s");
+ private static final Duration
DEFAULT_COORDINATOR_RULE_KILL_DURATION_TO_RETAIN = new Duration("PT7776000s");
+ private static final Duration DEFAULT_COORDINATOR_DATASOURCE_KILL_PERIOD =
new Duration("PT86400s");
+ private static final Duration
DEFAULT_COORDINATOR_DATASOURCE_KILL_DURATION_TO_RETAIN = new
Duration("PT7776000s");
+ private static final Duration DEFAULT_LOAD_TIMEOUT_DELAY = new Duration(15
* 60 * 1000);
+ private static final Duration DEFAULT_LOAD_QUEUE_PEON_REPEAT_DELAY =
Duration.millis(50);
+ private static final String DEFAULT_LOAD_QUEUE_PEON_TYPE = "curator";
+ private static final int
DEFAULT_CURATOR_LOAD_QUEUE_PEON_NUM_CALLBACK_THREADS = 2;
+ private static final Duration DEFAULT_HTTP_LOAD_QUEUE_PEON_REPEAT_DELAY =
Duration.millis(60000);
+ private static final Duration DEFAULT_HTTP_LOAD_QUEUE_PEON_HOST_TIMEOUT =
Duration.millis(300000);
+ private static final int DEFAULT_HTTP_LOAD_QUEUE_PEON_BATCH_SIZE = 1;
+ private static final boolean DEFAULT_COMPACTION_SKIP_LOCKED_INTERVALS =
true;
+ private static final Duration DEFAULT_COORDINATOR_AUDIT_KILL_PERIOD = new
Duration("PT86400s");
+ private static final Duration
DEFAULT_COORDINATOR_AUTIT_KILL_DURATION_TO_RETAIN = new Duration("PT7776000s");
+
+
+ private Duration coordinatorStartDelay;
+ private Duration coordinatorPeriod;
+ private Duration coordinatorIndexingPeriod;
+ private Duration metadataStoreManagementPeriod;
+ private Duration coordinatorKillPeriod;
+ private Duration coordinatorKillDurationToRetain;
+ private Boolean coordinatorKillIgnoreDurationToRetain;
+ private Integer coordinatorKillMaxSegments;
+ private Duration coordinatorSupervisorKillPeriod;
+ private Duration coordinatorSupervisorKillDurationToRetain;
+ private Duration coordinatorCompactionKillPeriod;
+ private Duration coordinatorRuleKillPeriod;
+ private Duration coordinatorRuleKillDurationToRetain;
+ private Duration coordinatorDatasourceKillPeriod;
+ private Duration coordinatorDatasourceKillDurationToRetain;
+ private Duration loadTimeoutDelay;
+ private Duration loadQueuePeonRepeatDelay;
+ private String loadQueuePeonType;
+ private Duration httpLoadQueuePeonRepeatDelay;
+ private Integer curatorLoadQueuePeonNumCallbackThreads;
+ private Duration httpLoadQueuePeonHostTimeout;
+ private Integer httpLoadQueuePeonBatchSize;
+ private Boolean compactionSkippedLockedIntervals;
+ private Duration coordinatorAuditKillPeriod;
+ private Duration coordinatorAuditKillDurationToRetain;
+
+ public Builder()
+ {
+ }
+
+ public Builder(
Review Comment:
ya, that is unused. I removed. If needed in the future it can be easily
created with code gen
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
