dynamicconfig

package

Go to main page

Versions in this module

v0

v0.8.6

Aug 27, 2019

v0.8.5

Aug 27, 2019

v0.8.4

Aug 26, 2019

v0.8.3

Aug 14, 2019

v0.8.2

Aug 13, 2019

v0.8.1

Aug 12, 2019

v0.8.0

Aug 12, 2019

Changes in this version

type Key

+ const DecisionHeartbeatTimeout

v0.7.3

Aug 8, 2019

v0.7.2

Aug 8, 2019

v0.7.1

Aug 6, 2019

v0.7.0

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

v0.6.1

Jul 26, 2019

v0.6.0

Jul 24, 2019

Changes in this version

type Client

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

type Key

+ const EnableBatcher

+ const MaxDecisionStartToCloseSeconds

+ const MinRetentionDays

v0.5.9

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

v0.5.8

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

v0.5.7

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

v0.5.5

Mar 12, 2019

v0.5.4

Mar 8, 2019

Changes in this version

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

type Key

+ const ArchivalStatus

+ const EmitShardDiffLog

+ const NumArchiveSystemWorkflows

v0.5.3

Feb 19, 2019

Changes in this version

type Key

+ const EnableArchivalCompression

+ const EnableReadFromClosedExecutionV2

+ const FrontendESVisibilityListMaxQPS

+ const WorkerHistoryPageSize

+ const WorkerTargetArchivalBlobSize

v0.5.2

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

v0.5.1

Jan 18, 2019

Changes in this version

type Key

+ const WorkerReplicatorActivityBufferRetryCount

+ const WorkerReplicatorHistoryBufferRetryCount

v0.5.0

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

v0.4.0

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

v0.3.15

Jul 26, 2018

Changes in this version

type Key

+ const ReplicatorProcessorUpdateAckIntervalJitterCoefficient

+ const TimerProcessorUpdateAckIntervalJitterCoefficient

+ const TransferProcessorUpdateAckIntervalJitterCoefficient

v0.3.14

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

v0.3.13

Jun 9, 2018

v0.3.12

May 26, 2018

v0.3.11

Apr 16, 2018

v0.3.10

Apr 10, 2018

v0.3.9

Mar 14, 2018

v0.3.8

Mar 13, 2018

v0.3.7

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL