dynamicconfig

Apr 16, 2021

Changes in this version

type Key

+ const MaxRetentionDays

Jan 22, 2021

Changes in this version

type Key

+ const AdminErrorInjectionRate

+ const EnableDebugMode

+ const FrontendErrorInjectionRate

+ const HistoryEnableTaskInfoLogByDomainID

+ const HistoryErrorInjectionRate

+ const MatchingEnableTaskInfoLogByDomainID

+ const MatchingErrorInjectionRate

+ const TimersFixerDomainAllow

+ const TimersFixerEnabled

+ const TimersScannerActivityBatchSize

+ const TimersScannerBlobstoreFlushThreshold

+ const TimersScannerConcurrency

+ const TimersScannerEnabled

+ const TimersScannerPeriodEnd

+ const TimersScannerPeriodStart

+ const TimersScannerPersistencePageSize

+ const TransferProcessorEnableValidator

+ const TransferProcessorValidationInterval

Jan 13, 2021

Changes in this version

type Key

+ const ActivityMaxScheduleToStartTimeoutForRetry

+ const ConcreteExecutionFixerDomainAllow

+ const ConcreteExecutionFixerEnabled

+ const CurrentExecutionFixerDomainAllow

+ const CurrentExecutionFixerEnabled

+ const PersistenceErrorInjectionRate

Jan 21, 2021

Changes in this version

type Key

+ const DecisionRetryCriticalAttempts

+ const DecisionRetryMaxAttempts

+ const EnableForceScheduleNewDecision

Dec 4, 2020

Changes in this version

type Client

+ func NewInMemoryClient() Client

type Key

+ const EnableActivityLocalDispatchByDomain

+ const FrontendFailoverCoolDown

+ const MaxRawTaskListNameLimit

+ const ReplicationTaskProcessorErrorSecondRetryExpiration

+ const ReplicationTaskProcessorErrorSecondRetryMaxWait

+ const ReplicationTaskProcessorErrorSecondRetryWait

Oct 8, 2020

Changes in this version

type Filter

+ const ClusterName

type FilterOption

+ func ClusterNameFilter(clusterName string) FilterOption

type Key

+ const EnableFailoverManager

+ const MaxIDLengthWarnLimit

+ const QueueProcessorEnableLoadQueueStates

+ const QueueProcessorEnablePendingTaskSplitByDomainID

+ const QueueProcessorEnablePersistQueueStates

+ const QueueProcessorEnableStuckTaskSplitByDomainID

+ const StandbyTaskReReplicationContextTimeout

+ const WorkerEnableReplication

Sep 14, 2020

Changes in this version

type Collection

+ func (c *Collection) GetBoolPropertyFilteredByDomain(key Key, defaultValue bool) BoolPropertyFnWithDomainFilter

+ func (c *Collection) GetBoolPropertyFilteredByDomainID(key Key, defaultValue bool) BoolPropertyFnWithDomainIDFilter

+ func (c *Collection) GetStringPropertyFilteredByDomain(key Key, defaultValue string) StringPropertyFnWithDomainFilter

type Key

+ const ActiveTaskRedispatchInterval

+ const ConcreteExecutionsScannerActivityBatchSize

+ const ConcreteExecutionsScannerBlobstoreFlushThreshold

+ const ConcreteExecutionsScannerConcurrency

+ const ConcreteExecutionsScannerEnabled

+ const ConcreteExecutionsScannerInvariantCollectionHistory

+ const ConcreteExecutionsScannerInvariantCollectionMutableState

+ const ConcreteExecutionsScannerPersistencePageSize

+ const CurrentExecutionsScannerActivityBatchSize

+ const CurrentExecutionsScannerBlobstoreFlushThreshold

+ const CurrentExecutionsScannerConcurrency

+ const CurrentExecutionsScannerEnabled

+ const CurrentExecutionsScannerInvariantCollectionHistory

+ const CurrentExecutionsScannerInvariantCollectionMutableState

+ const CurrentExecutionsScannerPersistencePageSize

+ const DomainFailoverRefreshInterval

+ const DomainFailoverRefreshTimerJitterCoefficient

+ const EnableGracefulFailover

+ const EventsCacheGlobalInitialCount

+ const EventsCacheGlobalMaxCount

+ const EventsCacheInitialCount

+ const EventsCacheMaxCount

+ const NotifyFailoverMarkerInterval

+ const NotifyFailoverMarkerTimerJitterCoefficient

+ const QueueProcessorEnablePendingTaskSplit

+ const QueueProcessorEnableRandomSplitByDomainID

+ const QueueProcessorEnableSplit

+ const QueueProcessorEnableStuckTaskSplit

+ const QueueProcessorPendingTaskSplitThreshold

+ const QueueProcessorPollBackoffInterval

+ const QueueProcessorPollBackoffIntervalJitterCoefficient

+ const QueueProcessorRandomSplitProbability

+ const QueueProcessorSplitLookAheadDurationByDomainID

+ const QueueProcessorSplitMaxLevel

+ const QueueProcessorStuckTaskSplitThreshold

+ const ReplicationTaskFetcherServiceBusyWait

+ const ReplicationTaskGenerationQPS

+ const ReplicationTaskProcessorHostQPS

+ const ReplicationTaskProcessorReadHistoryBatchSize

+ const ReplicationTaskProcessorShardQPS

+ const ReplicationTaskProcessorStartWait

+ const ReplicationTaskProcessorStartWaitJitterCoefficient

+ const StandbyTaskRedispatchInterval

+ const TaskRedispatchIntervalJitterCoefficient

+ const TimerProcessorEnableMultiCurosrProcessor

+ const TimerProcessorSplitQueueInterval

+ const TimerProcessorSplitQueueIntervalJitterCoefficient

+ const TransferProcessorEnableMultiCurosrProcessor

+ const TransferProcessorSplitQueueInterval

+ const TransferProcessorSplitQueueIntervalJitterCoefficient

+ const WorkerEnableKafkaReplication

Jul 7, 2020

Changes in this version

+ func GetDurationPropertyFnFilteredByTShardID(value time.Duration) func(shardID int) time.Duration

type Key

+ const EventsCacheGlobalEnable

+ const EventsCacheGlobalInitialSize

+ const EventsCacheGlobalMaxSize

+ const ExecutionsScannerActivityBatchSize

+ const ExecutionsScannerBlobstoreFlushThreshold

+ const ExecutionsScannerConcurrency

+ const ExecutionsScannerInvariantCollectionHistory

+ const ExecutionsScannerInvariantCollectionMutableState

+ const ExecutionsScannerPersistencePageSize

+ const ReplicatorProcessorEnablePriorityTaskProcessor

+ const ReplicatorProcessorMaxRedispatchQueueSize

+ const ReplicatorProcessorRedispatchInterval

+ const ReplicatorProcessorRedispatchIntervalJitterCoefficient

+ const ReplicatorReadTaskMaxRetryCount

+ const TaskSchedulerDispatcherCount

+ const TaskSchedulerQueueSize

+ const TaskSchedulerRoundRobinWeights

+ const TaskSchedulerShardQueueSize

+ const TaskSchedulerShardWorkerCount

+ const TaskSchedulerType

+ const TaskSchedulerWorkerCount

+ const TimerProcessorEnablePriorityTaskProcessor

+ const TimerProcessorMaxRedispatchQueueSize

+ const TimerProcessorRedispatchInterval

+ const TimerProcessorRedispatchIntervalJitterCoefficient

+ const TransferProcessorEnablePriorityTaskProcessor

+ const TransferProcessorMaxRedispatchQueueSize

+ const TransferProcessorRedispatchInterval

+ const TransferProcessorRedispatchIntervalJitterCoefficient

May 26, 2020

Changes in this version

+ type BoolPropertyFnWithDomainIDFilter func(id string) bool

type Collection

+ func (c *Collection) GetBoolPropertyFnWithDomainIDFilter(key Key, defaultValue bool) BoolPropertyFnWithDomainIDFilter

+ func (c *Collection) GetDurationPropertyFilteredByDomainID(key Key, defaultValue time.Duration) DurationPropertyFnWithDomainIDFilter

+ func (c *Collection) GetDurationPropertyFilteredByShardID(key Key, defaultValue time.Duration) DurationPropertyFnWithShardIDFilter

+ func (c *Collection) GetFloat64PropertyFilteredByShardID(key Key, defaultValue float64) FloatPropertyFnWithShardIDFilter

+ func (c *Collection) GetIntPropertyFilteredByShardID(key Key, defaultValue int) IntPropertyFnWithShardIDFilter

+ type DurationPropertyFnWithDomainIDFilter func(domainID string) time.Duration

+ type DurationPropertyFnWithShardIDFilter func(shardID int) time.Duration

type Filter

+ const ShardID

type FilterOption

+ func ShardIDFilter(shardID int) FilterOption

+ type FloatPropertyFnWithShardIDFilter func(shardID int) float64

+ type IntPropertyFnWithShardIDFilter func(shardID int) int

type Key

+ const EnableAuthorization

+ const EnableDropStuckTaskByDomainID

+ const EnablePriorityTaskProcessor

+ const ExecutionsScannerEnabled

+ const FrontendEnableCleanupReplicationTask

+ const FrontendEnableRPCReplication

+ const FrontendGlobalDomainRPS

+ const FrontendMaxDomainRPSPerInstance

+ const FrontendPersistenceGlobalMaxQPS

+ const FrontendShutdownDrainDuration

+ const HistoryEnableCleanupReplicationTask

+ const HistoryEnableKafkaReplication

+ const HistoryEnableRPCReplication

+ const HistoryPersistenceGlobalMaxQPS

+ const HistoryScannerEnabled

+ const HistoryShutdownDrainDuration

+ const MatchingPersistenceGlobalMaxQPS

+ const MatchingShutdownDrainDuration

+ const MutableStateChecksumGenProbability

+ const MutableStateChecksumInvalidateBefore

+ const MutableStateChecksumVerifyProbability

+ const ReplicationEventsFromCurrentCluster

+ const SendRawWorkflowHistory

+ const SkipReapplicationByDomainId

+ const TaskListScannerEnabled

+ const TaskProcessRPS

+ const WorkerEnableRPCReplication

+ const WorkerPersistenceGlobalMaxQPS

+ const WorkerReReplicationContextTimeout

Feb 15, 2020

Changes in this version

type Collection

+ func (c *Collection) GetIntPropertyFilteredByDomainID(key Key, defaultValue int) IntPropertyFnWithDomainIDFilter

type Filter

+ const DomainID

type FilterOption

+ func DomainIDFilter(id string) FilterOption

+ type IntPropertyFnWithDomainIDFilter func(domainID string) int

type Key

+ const AcquireShardConcurrency

+ const EnableConsistentQuery

+ const EnableConsistentQueryByDomain

+ const MaxBufferedQueryCount

+ const ReplicationTaskFetcherAggregationInterval

+ const ReplicationTaskFetcherErrorRetryWait

+ const ReplicationTaskFetcherParallelism

+ const ReplicationTaskFetcherTimerJitterCoefficient

+ const ReplicationTaskProcessorCleanupInterval

+ const ReplicationTaskProcessorCleanupJitterCoefficient

+ const ReplicationTaskProcessorErrorRetryMaxAttempts

+ const ReplicationTaskProcessorErrorRetryWait

+ const ReplicationTaskProcessorNoTaskInitialWait

+ const ShardSyncTimerJitterCoefficient

+ const VisibilityArchivalQueryMaxPageSize

+ const VisibilityArchivalQueryMaxQPS

+ const VisibilityArchivalQueryMaxRangeInDays

+ const WorkerReplicationTaskContextDuration

+ type MockClient struct

+ func NewMockClient(ctrl *gomock.Controller) *MockClient

+ func (m *MockClient) EXPECT() *MockClientMockRecorder

+ func (m *MockClient) GetBoolValue(name Key, filters map[Filter]interface{}, defaultValue bool) (bool, error)

+ func (m *MockClient) GetDurationValue(name Key, filters map[Filter]interface{}, defaultValue time.Duration) (time.Duration, error)

+ func (m *MockClient) GetFloatValue(name Key, filters map[Filter]interface{}, defaultValue float64) (float64, error)

+ func (m *MockClient) GetIntValue(name Key, filters map[Filter]interface{}, defaultValue int) (int, error)

+ func (m *MockClient) GetMapValue(name Key, filters map[Filter]interface{}, defaultValue map[string]interface{}) (map[string]interface{}, error)

+ func (m *MockClient) GetStringValue(name Key, filters map[Filter]interface{}, defaultValue string) (string, error)

+ func (m *MockClient) GetValue(name Key, defaultValue interface{}) (interface{}, error)

+ func (m *MockClient) GetValueWithFilters(name Key, filters map[Filter]interface{}, defaultValue interface{}) (interface{}, error)

+ func (m *MockClient) UpdateValue(name Key, value interface{}) error

+ type MockClientMockRecorder struct

+ func (mr *MockClientMockRecorder) GetBoolValue(name, filters, defaultValue interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) GetDurationValue(name, filters, defaultValue interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) GetFloatValue(name, filters, defaultValue interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) GetIntValue(name, filters, defaultValue interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) GetMapValue(name, filters, defaultValue interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) GetStringValue(name, filters, defaultValue interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) GetValue(name, defaultValue interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) GetValueWithFilters(name, filters, defaultValue interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) UpdateValue(name, value interface{}) *gomock.Call

Nov 27, 2019

Changes in this version

type Key

+ const EnableStickyQuery

Nov 21, 2019

Changes in this version

type Key

+ const DisallowQuery

+ const EnablePollForMutableState

Oct 18, 2019

Changes in this version

type Key

+ const StandbyTaskMissingEventsDiscardDelay

+ const StandbyTaskMissingEventsResendDelay

Oct 7, 2019

Changes in this version

type Key

+ const EnableNDC

+ const EnableParentClosePolicy

+ const EnableParentClosePolicyWorker

+ const NumParentClosePolicySystemWorkflows

+ const ParentClosePolicyThreshold

+ const TimerProcessorArchivalTimeLimit

Sep 17, 2019

Changes in this version

+ func GetDurationPropertyFnFilteredByDomain(value time.Duration) func(domain string) time.Duration

type Key

+ const AdvancedVisibilityWritingMode

+ const TransferProcessorVisibilityArchivalTimeLimit

+ const UseTerminateAsDefaultParentClosePolicy

Aug 12, 2019

Changes in this version

type Key

+ const DecisionHeartbeatTimeout

Jul 30, 2019

Changes in this version

type Key

+ const EnableReadFromHistoryArchival

+ const EnableReadFromVisibilityArchival

+ const FrontendDomainRPS

+ const HistoryArchivalStatus

+ const MatchingForwarderMaxChildrenPerNode

+ const MatchingForwarderMaxOutstandingPolls

+ const MatchingForwarderMaxOutstandingTasks

+ const MatchingForwarderMaxRatePerSecond

+ const MatchingNumTasklistReadPartitions

+ const MatchingNumTasklistWritePartitions

+ const StickyTTL

+ const TimerProcessorHistoryArchivalSizeLimit

+ const TimerProcessorHistoryArchivalTimeLimit

+ const VisibilityArchivalStatus

Jul 24, 2019

Changes in this version

type Client

+ UpdateValue func(name Key, value interface{}) error

type Key

+ const EnableBatcher

+ const MaxDecisionStartToCloseSeconds

+ const MinRetentionDays

Jun 17, 2019

Changes in this version

+ func GetMapPropertyFn(value map[string]interface{}) func(opts ...FilterOption) map[string]interface

type Collection

+ func (c *Collection) GetMapProperty(key Key, defaultValue map[string]interface{}) MapPropertyFn

type Key

+ const ArchiveRequestRPS

+ const SearchAttributesNumberOfKeysLimit

+ const SearchAttributesSizeOfValueLimit

+ const SearchAttributesTotalSizeLimit

+ const TransactionSizeLimit

+ const ValidSearchAttributes

+ const WorkerBlobIntegrityCheckProbability

+ const WorkerTimeLimitPerArchivalIteration

+ type MapPropertyFn func(opts ...FilterOption) map[string]interface

May 14, 2019

Changes in this version

type Client

+ func NewFileBasedClient(config *FileBasedClientConfig, logger log.Logger, doneCh chan struct{}) (Client, error)

+ type FileBasedClientConfig struct

+ Filepath string

+ PollInterval time.Duration

type Key

+ const FrontendMaxBadBinaries

+ const HistoryMaxAutoResetPoints

+ const WorkerReplicationTaskMaxRetryCount

+ const WorkerReplicationTaskMaxRetryDuration

May 8, 2019

Changes in this version

type Key

+ const EnableClientVersionCheck

+ const EnableDomainNotActiveAutoForwarding

+ const EnableReadFromArchival

+ const FrontendESIndexMaxResultWindow

+ const FrontendThrottledLogRPS

+ const HistoryThrottledLogRPS

+ const MatchingMaxTaskDeleteBatchSize

+ const MatchingThrottledLogRPS

+ const ScannerPersistenceMaxQPS

+ const WorkerArchivalsPerIteration

+ const WorkerArchiverConcurrency

+ const WorkerDeterministicConstructionCheckProbability

+ const WorkerReplicatorMessageConcurrency

+ const WorkerReplicatorMetaTaskConcurrency

+ const WorkerReplicatorTaskConcurrency

+ const WorkerThrottledLogRPS

Mar 8, 2019

Changes in this version

+ func GetStringPropertyFn(value string) func(opts ...FilterOption) string

type Key

+ const ArchivalStatus

+ const EmitShardDiffLog

+ const NumArchiveSystemWorkflows

Feb 19, 2019

Changes in this version

type Key

+ const EnableArchivalCompression

+ const EnableReadFromClosedExecutionV2

+ const FrontendESVisibilityListMaxQPS

+ const WorkerHistoryPageSize

+ const WorkerTargetArchivalBlobSize

Feb 12, 2019

Changes in this version

type Key

+ const EnableReadVisibilityFromES

+ const EventsCacheInitialSize

+ const EventsCacheMaxSize

+ const EventsCacheTTL

+ const WorkerESProcessorBulkActions

+ const WorkerESProcessorBulkSize

+ const WorkerESProcessorFlushInterval

+ const WorkerESProcessorNumOfWorkers

+ const WorkerIndexerConcurrency

Jan 18, 2019

Changes in this version

type Key

+ const WorkerReplicatorActivityBufferRetryCount

+ const WorkerReplicatorHistoryBufferRetryCount

Jan 7, 2019

Changes in this version

+ const DefaultEnableVisibilityToKafka

+ func GetBoolPropertyFnFilteredByDomain(value bool) func(domain string) bool

+ type BoolPropertyFnWithDomainFilter func(domain string) bool

type Collection

+ func (c *Collection) GetBoolPropertyFnWithDomainFilter(key Key, defaultValue bool) BoolPropertyFnWithDomainFilter

type Key

+ const BlobSizeLimitError

+ const BlobSizeLimitWarn

+ const DisableListVisibilityByFilter

+ const EnableArchival

+ const EnableEventsV2

+ const EnableHistoryRereplication

+ const EnableVisibilityToKafka

+ const FrontendVisibilityListMaxQPS

+ const HistoryCountLimitError

+ const HistoryCountLimitWarn

+ const HistorySizeLimitError

+ const HistorySizeLimitWarn

+ const MaxIDLengthLimit

+ const MaximumSignalsPerExecution

+ const NumSystemWorkflows

+ const WorkerReplicationTaskMaxRetry

+ const WorkerReplicatorBufferRetryCount

+ const WorkerReplicatorConcurrency

Oct 19, 2018

Changes in this version

+ func GetIntPropertyFilteredByDomain(value int) func(domain string) int

type Collection

+ func (c *Collection) GetStringProperty(key Key, defaultValue string) StringPropertyFn

+ func (c *Collection) GetStringPropertyFnWithDomainFilter(key Key, defaultValue string) StringPropertyFnWithDomainFilter

type Key

+ const AdminOperationToken

+ const DefaultEventEncoding

+ const EnableAdminProtection

+ const EnableNewKafkaClient

+ const EnableSyncActivityHeartbeat

+ const EnableVisibilitySampling

+ const HistoryRPS

+ const HistoryVisibilityClosedMaxQPS

+ const HistoryVisibilityOpenMaxQPS

+ const TimerProcessorMaxTimeShift

+ type StringPropertyFn func(opts ...FilterOption) string

+ type StringPropertyFnWithDomainFilter func(domain string) string

Jul 26, 2018

Changes in this version

type Key

+ const ReplicatorProcessorUpdateAckIntervalJitterCoefficient

+ const TimerProcessorUpdateAckIntervalJitterCoefficient

+ const TransferProcessorUpdateAckIntervalJitterCoefficient

Jul 24, 2018

Changes in this version

+ func GetBoolPropertyFn(value bool) func(opts ...FilterOption) bool

+ func GetDurationPropertyFn(value time.Duration) func(opts ...FilterOption) time.Duration

+ func GetDurationPropertyFnFilteredByTaskListInfo(value time.Duration) func(domain string, taskList string, taskType int) time.Duration

+ func GetFloatPropertyFn(value float64) func(opts ...FilterOption) float64

+ func GetIntPropertyFilteredByTaskListInfo(value int) func(domain string, taskList string, taskType int) int

+ func GetIntPropertyFn(value int) func(opts ...FilterOption) int

+ type BoolPropertyFnWithTaskListInfoFilters func(domain string, taskList string, taskType int) bool

type Collection

+ func (c *Collection) GetBoolPropertyFilteredByTaskListInfo(key Key, defaultValue bool) BoolPropertyFnWithTaskListInfoFilters

+ func (c *Collection) GetDurationPropertyFilteredByDomain(key Key, defaultValue time.Duration) DurationPropertyFnWithDomainFilter

+ func (c *Collection) GetDurationPropertyFilteredByTaskListInfo(key Key, defaultValue time.Duration) DurationPropertyFnWithTaskListInfoFilters

+ func (c *Collection) GetIntPropertyFilteredByDomain(key Key, defaultValue int) IntPropertyFnWithDomainFilter

+ func (c *Collection) GetIntPropertyFilteredByTaskListInfo(key Key, defaultValue int) IntPropertyFnWithTaskListInfoFilters

+ type DurationPropertyFnWithDomainFilter func(domain string) time.Duration

+ type DurationPropertyFnWithTaskListInfoFilters func(domain string, taskList string, taskType int) time.Duration

type Filter

+ const TaskType

type FilterOption

+ func TaskTypeFilter(taskType int) FilterOption

+ type IntPropertyFnWithDomainFilter func(domain string) int

+ type IntPropertyFnWithTaskListInfoFilters func(domain string, taskList string, taskType int) int

type Key

+ const AcquireShardInterval

+ const EnableGlobalDomain

+ const ExecutionMgrNumConns

+ const FrontendHistoryMaxPageSize

+ const FrontendHistoryMgrNumConns

+ const FrontendPersistenceMaxQPS

+ const FrontendRPS

+ const FrontendVisibilityMaxPageSize

+ const HistoryCacheInitialSize

+ const HistoryCacheMaxSize

+ const HistoryCacheTTL

+ const HistoryMgrNumConns

+ const HistoryPersistenceMaxQPS

+ const MatchingGetTasksBatchSize

+ const MatchingOutstandingTaskAppendsThreshold

+ const MatchingPersistenceMaxQPS

+ const MatchingRPS

+ const MaxDecisionStartToCloseTimeout

+ const MaxTasklistIdleTime

+ const MaximumBufferedEventsBatch

+ const ReplicatorProcessorMaxPollInterval

+ const ReplicatorProcessorMaxPollIntervalJitterCoefficient

+ const ReplicatorProcessorMaxPollRPS

+ const ReplicatorProcessorStartDelay

+ const ReplicatorProcessorUpdateAckInterval

+ const ReplicatorProcessorUpdateShardTaskCount

+ const ReplicatorTaskBatchSize

+ const ReplicatorTaskMaxRetryCount

+ const ReplicatorTaskWorkerCount

+ const ShardSyncMinInterval

+ const ShardUpdateMinInterval

+ const StandbyClusterDelay

+ const TimerProcessorCompleteTimerFailureRetryCount

+ const TimerProcessorCompleteTimerInterval

+ const TimerProcessorFailoverMaxPollRPS

+ const TimerProcessorFailoverStartDelay

+ const TimerProcessorGetFailureRetryCount

+ const TimerProcessorMaxPollInterval

+ const TimerProcessorMaxPollIntervalJitterCoefficient

+ const TimerProcessorMaxPollRPS

+ const TimerProcessorStartDelay

+ const TimerProcessorUpdateAckInterval

+ const TimerProcessorUpdateShardTaskCount

+ const TimerTaskBatchSize

+ const TimerTaskMaxRetryCount

+ const TimerTaskWorkerCount

+ const TransferProcessorCompleteTransferFailureRetryCount

+ const TransferProcessorCompleteTransferInterval

+ const TransferProcessorFailoverMaxPollRPS

+ const TransferProcessorFailoverStartDelay

+ const TransferProcessorMaxPollInterval

+ const TransferProcessorMaxPollIntervalJitterCoefficient

+ const TransferProcessorMaxPollRPS

+ const TransferProcessorStartDelay

+ const TransferProcessorUpdateAckInterval

+ const TransferProcessorUpdateShardTaskCount

+ const TransferTaskBatchSize

+ const TransferTaskMaxRetryCount

+ const TransferTaskWorkerCount

+ const WorkerPersistenceMaxQPS

Mar 12, 2018

Changes in this version

+ type BoolPropertyFn func(opts ...FilterOption) bool

+ type Client interface

+ GetBoolValue func(name Key, filters map[Filter]interface{}, defaultValue bool) (bool, error)

+ GetDurationValue func(name Key, filters map[Filter]interface{}, defaultValue time.Duration) (time.Duration, error)

+ GetFloatValue func(name Key, filters map[Filter]interface{}, defaultValue float64) (float64, error)

+ GetIntValue func(name Key, filters map[Filter]interface{}, defaultValue int) (int, error)

+ GetMapValue func(name Key, filters map[Filter]interface{}, defaultValue map[string]interface{}) (map[string]interface{}, error)

+ GetStringValue func(name Key, filters map[Filter]interface{}, defaultValue string) (string, error)

+ GetValue func(name Key, defaultValue interface{}) (interface{}, error)

+ GetValueWithFilters func(name Key, filters map[Filter]interface{}, defaultValue interface{}) (interface{}, error)

+ func NewNopClient() Client

+ type Collection struct

+ func NewCollection(client Client, logger bark.Logger) *Collection

+ func NewNopCollection() *Collection

+ func (c *Collection) GetBoolProperty(key Key, defaultValue bool) BoolPropertyFn

+ func (c *Collection) GetDurationProperty(key Key, defaultValue time.Duration) DurationPropertyFn

+ func (c *Collection) GetFloat64Property(key Key, defaultValue float64) FloatPropertyFn

+ func (c *Collection) GetIntProperty(key Key, defaultValue int) IntPropertyFn

+ func (c *Collection) GetProperty(key Key, defaultValue interface{}) PropertyFn

+ type DurationPropertyFn func(opts ...FilterOption) time.Duration

+ type Filter int

+ const DomainName

+ const TaskListName

+ func (f Filter) String() string

+ type FilterOption func(filterMap map[Filter]interface{})

+ func DomainFilter(name string) FilterOption

+ func TaskListFilter(name string) FilterOption

+ type FloatPropertyFn func(opts ...FilterOption) float64

+ type IntPropertyFn func(opts ...FilterOption) int

+ type Key int

+ const HistoryLongPollExpirationInterval

+ const MatchingEnableSyncMatch

+ const MatchingIdleTasklistCheckInterval

+ const MatchingLongPollExpirationInterval

+ const MatchingMaxTaskBatchSize

+ const MatchingMinTaskThrottlingBurstSize

+ const MatchingUpdateAckInterval

+ func (k Key) String() string

+ type PropertyFn func() interface