|
|
@@ -29,6 +29,7 @@ const (
|
|
|
defaultBasePath = ""
|
|
|
defaultWorkerPoolSize = 5
|
|
|
defaultPollingFrequency = 60
|
|
|
+ defaultForceRefreshInterval = 30
|
|
|
defaultBatchSize = 100
|
|
|
defaultPollingScheduler = "round_robin"
|
|
|
defaultSchedulerEntryFrequencyMinInterval = 5
|
|
|
@@ -122,6 +123,7 @@ type Options struct {
|
|
|
cleanupArchiveBatchSize int
|
|
|
cleanupRemoveSessionsDays int
|
|
|
pollingFrequency int
|
|
|
+ forceRefreshInterval int
|
|
|
batchSize int
|
|
|
pollingScheduler string
|
|
|
schedulerEntryFrequencyMinInterval int
|
|
|
@@ -200,6 +202,7 @@ func NewOptions() *Options {
|
|
|
cleanupArchiveBatchSize: defaultCleanupArchiveBatchSize,
|
|
|
cleanupRemoveSessionsDays: defaultCleanupRemoveSessionsDays,
|
|
|
pollingFrequency: defaultPollingFrequency,
|
|
|
+ forceRefreshInterval: defaultForceRefreshInterval,
|
|
|
batchSize: defaultBatchSize,
|
|
|
pollingScheduler: defaultPollingScheduler,
|
|
|
schedulerEntryFrequencyMinInterval: defaultSchedulerEntryFrequencyMinInterval,
|
|
|
@@ -378,6 +381,11 @@ func (o *Options) PollingFrequency() int {
|
|
|
return o.pollingFrequency
|
|
|
}
|
|
|
|
|
|
+// ForceRefreshInterval returns the force refresh interval
|
|
|
+func (o *Options) ForceRefreshInterval() int {
|
|
|
+ return o.forceRefreshInterval
|
|
|
+}
|
|
|
+
|
|
|
// BatchSize returns the number of feeds to send for background processing.
|
|
|
func (o *Options) BatchSize() int {
|
|
|
return o.batchSize
|
|
|
@@ -663,6 +671,7 @@ func (o *Options) SortedOptions(redactSecret bool) []*Option {
|
|
|
"OAUTH2_USER_CREATION": o.oauth2UserCreationAllowed,
|
|
|
"POCKET_CONSUMER_KEY": redactSecretValue(o.pocketConsumerKey, redactSecret),
|
|
|
"POLLING_FREQUENCY": o.pollingFrequency,
|
|
|
+ "FORCE_REFRESH_INTERVAL": o.forceRefreshInterval,
|
|
|
"POLLING_PARSING_ERROR_LIMIT": o.pollingParsingErrorLimit,
|
|
|
"POLLING_SCHEDULER": o.pollingScheduler,
|
|
|
"PROXY_HTTP_CLIENT_TIMEOUT": o.proxyHTTPClientTimeout,
|