Documentation ¶
Overview ¶
Package dynamicconfig is a generated GoMock package.
Package dynamicconfig is a generated GoMock package.
Index ¶
- Constants
- func GetBoolPropertyFn(value bool) func(opts ...FilterOption) bool
- func GetBoolPropertyFnFilteredByNamespace(value bool) func(namespace string) bool
- func GetDurationPropertyFn(value time.Duration) func(opts ...FilterOption) time.Duration
- func GetDurationPropertyFnFilteredByNamespace(value time.Duration) func(namespace string) time.Duration
- func GetDurationPropertyFnFilteredByTaskQueueInfo(value time.Duration) ...
- func GetFloatPropertyFn(value float64) func(opts ...FilterOption) float64
- func GetIntPropertyFilteredByNamespace(value int) func(namespace string) int
- func GetIntPropertyFilteredByTaskQueueInfo(value int) func(namespace string, taskQueue string, taskType enumspb.TaskQueueType) int
- func GetIntPropertyFn(value int) func(opts ...FilterOption) int
- func GetMapPropertyFn(value map[string]interface{}) func(opts ...FilterOption) map[string]interface{}
- func GetMapPropertyFnWithNamespaceFilter(value map[string]interface{}) func(namespace string) map[string]interface{}
- func GetStringPropertyFn(value string) func(opts ...FilterOption) string
- func NewFileBasedClient(config *FileBasedClientConfig, logger log.Logger, doneCh <-chan interface{}) (*fileBasedClient, error)
- func NewFileBasedClientWithReader(reader fileReader, config *FileBasedClientConfig, logger log.Logger, ...) (*fileBasedClient, error)
- func NewNoopClient() *noopClient
- type BoolPropertyFn
- type BoolPropertyFnWithNamespaceFilter
- type BoolPropertyFnWithNamespaceIDFilter
- type BoolPropertyFnWithTaskQueueInfoFilters
- type Client
- type Collection
- func (c *Collection) GetBoolProperty(key Key, defaultValue bool) BoolPropertyFn
- func (c *Collection) GetBoolPropertyFilteredByTaskQueueInfo(key Key, defaultValue bool) BoolPropertyFnWithTaskQueueInfoFilters
- func (c *Collection) GetBoolPropertyFnWithNamespaceFilter(key Key, defaultValue bool) BoolPropertyFnWithNamespaceFilter
- func (c *Collection) GetBoolPropertyFnWithNamespaceIDFilter(key Key, defaultValue bool) BoolPropertyFnWithNamespaceIDFilter
- func (c *Collection) GetDurationProperty(key Key, defaultValue time.Duration) DurationPropertyFn
- func (c *Collection) GetDurationPropertyFilteredByNamespace(key Key, defaultValue time.Duration) DurationPropertyFnWithNamespaceFilter
- func (c *Collection) GetDurationPropertyFilteredByNamespaceID(key Key, defaultValue time.Duration) DurationPropertyFnWithNamespaceIDFilter
- func (c *Collection) GetDurationPropertyFilteredByShardID(key Key, defaultValue time.Duration) DurationPropertyFnWithShardIDFilter
- func (c *Collection) GetDurationPropertyFilteredByTaskQueueInfo(key Key, defaultValue time.Duration) DurationPropertyFnWithTaskQueueInfoFilters
- func (c *Collection) GetFloat64Property(key Key, defaultValue float64) FloatPropertyFn
- func (c *Collection) GetFloat64PropertyFilteredByShardID(key Key, defaultValue float64) FloatPropertyFnWithShardIDFilter
- func (c *Collection) GetFloatPropertyFilteredByNamespace(key Key, defaultValue float64) FloatPropertyFnWithNamespaceFilter
- func (c *Collection) GetFloatPropertyFilteredByTaskQueueInfo(key Key, defaultValue float64) FloatPropertyFnWithTaskQueueInfoFilters
- func (c *Collection) GetIntProperty(key Key, defaultValue int) IntPropertyFn
- func (c *Collection) GetIntPropertyFilteredByNamespace(key Key, defaultValue int) IntPropertyFnWithNamespaceFilter
- func (c *Collection) GetIntPropertyFilteredByShardID(key Key, defaultValue int) IntPropertyFnWithShardIDFilter
- func (c *Collection) GetIntPropertyFilteredByTaskQueueInfo(key Key, defaultValue int) IntPropertyFnWithTaskQueueInfoFilters
- func (c *Collection) GetMapProperty(key Key, defaultValue map[string]interface{}) MapPropertyFn
- func (c *Collection) GetMapPropertyFnWithNamespaceFilter(key Key, defaultValue map[string]interface{}) MapPropertyFnWithNamespaceFilter
- func (c *Collection) GetProperty(key Key, defaultValue interface{}) PropertyFn
- func (c *Collection) GetStringProperty(key Key, defaultValue string) StringPropertyFn
- func (c *Collection) GetStringPropertyFnWithNamespaceFilter(key Key, defaultValue string) StringPropertyFnWithNamespaceFilter
- type DurationPropertyFn
- type DurationPropertyFnWithNamespaceFilter
- type DurationPropertyFnWithNamespaceIDFilter
- type DurationPropertyFnWithShardIDFilter
- type DurationPropertyFnWithTaskQueueInfoFilters
- type FileBasedClientConfig
- type Filter
- type FilterOption
- type FloatPropertyFn
- type FloatPropertyFnWithNamespaceFilter
- type FloatPropertyFnWithShardIDFilter
- type FloatPropertyFnWithTaskQueueInfoFilters
- type IntPropertyFn
- type IntPropertyFnWithNamespaceFilter
- type IntPropertyFnWithShardIDFilter
- type IntPropertyFnWithTaskQueueInfoFilters
- type Key
- type MapPropertyFn
- type MapPropertyFnWithNamespaceFilter
- type 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{}, ...) (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)
- type MockClientMockRecorder
- 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
- type MockfileReader
- type MockfileReaderMockRecorder
- type MutableEphemeralClient
- func (c *MutableEphemeralClient) Add(k Key, v interface{}, mcs ...MutationConstraint)
- func (bc MutableEphemeralClient) GetBoolValue(name Key, filters []map[Filter]interface{}, defaultValue bool) (bool, error)
- func (bc MutableEphemeralClient) GetDurationValue(name Key, filters []map[Filter]interface{}, defaultValue time.Duration) (time.Duration, error)
- func (bc MutableEphemeralClient) GetFloatValue(name Key, filters []map[Filter]interface{}, defaultValue float64) (float64, error)
- func (bc MutableEphemeralClient) GetIntValue(name Key, filters []map[Filter]interface{}, defaultValue int) (int, error)
- func (bc MutableEphemeralClient) GetMapValue(name Key, filters []map[Filter]interface{}, ...) (map[string]interface{}, error)
- func (bc MutableEphemeralClient) GetStringValue(name Key, filters []map[Filter]interface{}, defaultValue string) (string, error)
- func (bc MutableEphemeralClient) GetValue(name Key, defaultValue interface{}) (interface{}, error)
- func (bc MutableEphemeralClient) GetValueWithFilters(name Key, filters []map[Filter]interface{}, defaultValue interface{}) (interface{}, error)
- func (c *MutableEphemeralClient) MAdd(kvs map[Key]interface{}, mcs ...MutationConstraint)
- func (c *MutableEphemeralClient) MSet(kvs map[Key]interface{}, mcs ...MutationConstraint)
- func (c *MutableEphemeralClient) Set(k Key, v interface{}, mcs ...MutationConstraint)
- func (c *MutableEphemeralClient) Update(mutations ...Mutation)
- type Mutation
- type MutationConstraint
- type PropertyFn
- type StringPropertyFn
- type StringPropertyFnWithNamespaceFilter
Constants ¶
const ( // AdminMatchingNamespaceToPartitionDispatchRate is the max qps of any task queue partition for a given namespace AdminMatchingNamespaceToPartitionDispatchRate = "admin.matchingNamespaceToPartitionDispatchRate" // AdminMatchingNamespaceTaskqueueToPartitionDispatchRate is the max qps of a task queue partition for a given namespace & task queue AdminMatchingNamespaceTaskqueueToPartitionDispatchRate = "admin.matchingNamespaceTaskqueueToPartitionDispatchRate" // StandardVisibilityPersistenceMaxReadQPS is the max QPC system host can query standard visibility DB (SQL or Cassandra) for read. StandardVisibilityPersistenceMaxReadQPS = "system.standardVisibilityPersistenceMaxReadQPS" // StandardVisibilityPersistenceMaxWriteQPS is the max QPC system host can query standard visibility DB (SQL or Cassandra) for write. StandardVisibilityPersistenceMaxWriteQPS = "system.standardVisibilityPersistenceMaxWriteQPS" // AdvancedVisibilityPersistenceMaxReadQPS is the max QPC system host can query advanced visibility DB (Elasticsearch) for read. AdvancedVisibilityPersistenceMaxReadQPS = "system.advancedVisibilityPersistenceMaxReadQPS" // AdvancedVisibilityPersistenceMaxWriteQPS is the max QPC system host can query advanced visibility DB (Elasticsearch) for write. AdvancedVisibilityPersistenceMaxWriteQPS = "system.advancedVisibilityPersistenceMaxWriteQPS" // AdvancedVisibilityWritingMode is key for how to write to advanced visibility AdvancedVisibilityWritingMode = "system.advancedVisibilityWritingMode" // EnableWriteToSecondaryAdvancedVisibility is the config to enable write to secondary visibility for Elasticsearch EnableWriteToSecondaryAdvancedVisibility = "system.enableWriteToSecondaryAdvancedVisibility" // EnableReadVisibilityFromES is key for enable read from Elasticsearch EnableReadVisibilityFromES = "system.enableReadVisibilityFromES" // EnableReadFromSecondaryAdvancedVisibility is the config to enable read from secondary Elasticsearch EnableReadFromSecondaryAdvancedVisibility = "system.enableReadFromSecondaryAdvancedVisibility" // HistoryArchivalState is key for the state of history archival HistoryArchivalState = "system.historyArchivalState" // EnableReadFromHistoryArchival is key for enabling reading history from archival store EnableReadFromHistoryArchival = "system.enableReadFromHistoryArchival" // VisibilityArchivalState is key for the state of visibility archival VisibilityArchivalState = "system.visibilityArchivalState" // EnableReadFromVisibilityArchival is key for enabling reading visibility from archival store EnableReadFromVisibilityArchival = "system.enableReadFromVisibilityArchival" // EnableNamespaceNotActiveAutoForwarding whether enabling DC auto forwarding to active cluster // for signal / start / signal with start API if namespace is not active EnableNamespaceNotActiveAutoForwarding = "system.enableNamespaceNotActiveAutoForwarding" // TransactionSizeLimit is the largest allowed transaction size to persistence TransactionSizeLimit = "system.transactionSizeLimit" // DisallowQuery is the key to disallow query for a namespace DisallowQuery = "system.disallowQuery" // EnableAuthorization is the key to enable authorization for a namespace EnableAuthorization = "system.enableAuthorization" // EnableCrossNamespaceCommands is the key to enable commands for external namespaces EnableCrossNamespaceCommands = "system.enableCrossNamespaceCommands" // ClusterMetadataRefreshInterval is config to manage cluster metadata table refresh interval ClusterMetadataRefreshInterval = "system.clusterMetadataRefreshInterval" // ForceSearchAttributesCacheRefreshOnRead forces refreshing search attributes cache on a read operation, so we always // get the latest data from DB. This effectively bypasses cache value and is used to facilitate testing of changes in // search attributes. This should not be turned on in production. ForceSearchAttributesCacheRefreshOnRead = "system.forceSearchAttributesCacheRefreshOnRead" EnableRingpopTLS = "system.enableRingpopTLS" // EnableParentClosePolicyWorker decides whether or not enable system workers for processing parent close policy task EnableParentClosePolicyWorker = "system.enableParentClosePolicyWorker" // EnableStickyQuery indicates if sticky query should be enabled per namespace EnableStickyQuery = "system.enableStickyQuery" // EnableActivityLocalDispatch indicates if acitivty local dispatch is enabled per namespace EnableActivityLocalDispatch = "system.enableActivityLocalDispatch" // NamespaceCacheRefreshInterval is the key for namespace cache refresh interval dynamic config NamespaceCacheRefreshInterval = "system.namespaceCacheRefreshInterval" // BlobSizeLimitError is the per event blob size limit BlobSizeLimitError = "limit.blobSize.error" // BlobSizeLimitWarn is the per event blob size limit for warning BlobSizeLimitWarn = "limit.blobSize.warn" // MemoSizeLimitError is the per event memo size limit MemoSizeLimitError = "limit.memoSize.error" // MemoSizeLimitWarn is the per event memo size limit for warning MemoSizeLimitWarn = "limit.memoSize.warn" // HistorySizeLimitError is the per workflow execution history size limit HistorySizeLimitError = "limit.historySize.error" // HistorySizeLimitWarn is the per workflow execution history size limit for warning HistorySizeLimitWarn = "limit.historySize.warn" // HistoryCountLimitError is the per workflow execution history event count limit HistoryCountLimitError = "limit.historyCount.error" // HistoryCountLimitWarn is the per workflow execution history event count limit for warning HistoryCountLimitWarn = "limit.historyCount.warn" // MaxIDLengthLimit is the length limit for various IDs, including: Namespace, TaskQueue, WorkflowID, ActivityID, TimerID, // WorkflowType, ActivityType, SignalName, MarkerName, ErrorReason/FailureReason/CancelCause, Identity, RequestID MaxIDLengthLimit = "limit.maxIDLength" // FrontendPersistenceMaxQPS is the max qps frontend host can query DB FrontendPersistenceMaxQPS = "frontend.persistenceMaxQPS" // FrontendPersistenceGlobalMaxQPS is the max qps frontend cluster can query DB FrontendPersistenceGlobalMaxQPS = "frontend.persistenceGlobalMaxQPS" // FrontendVisibilityMaxPageSize is default max size for ListWorkflowExecutions in one page FrontendVisibilityMaxPageSize = "frontend.visibilityMaxPageSize" // FrontendESIndexMaxResultWindow is ElasticSearch index setting max_result_window FrontendESIndexMaxResultWindow = "frontend.esIndexMaxResultWindow" // FrontendHistoryMaxPageSize is default max size for GetWorkflowExecutionHistory in one page FrontendHistoryMaxPageSize = "frontend.historyMaxPageSize" // FrontendRPS is workflow rate limit per second FrontendRPS = "frontend.rps" // FrontendMaxNamespaceRPSPerInstance is workflow namespace rate limit per second FrontendMaxNamespaceRPSPerInstance = "frontend.namespaceRPS" // FrontendMaxNamespaceBurstPerInstance is workflow namespace burst limit FrontendMaxNamespaceBurstPerInstance = "frontend.namespaceBurst" // FrontendMaxNamespaceCountPerInstance is workflow namespace count limit per second FrontendMaxNamespaceCountPerInstance = "frontend.namespaceCount" // FrontendMaxNamespaceVisibilityRPSPerInstance is namespace rate limit per second for visibility APIs. // This config is EXPERIMENTAL and may be changed or removed in a later release. FrontendMaxNamespaceVisibilityRPSPerInstance = "frontend.namespaceRPS.visibility" // FrontendMaxNamespaceVisibilityBurstPerInstance is namespace burst limit for visibility APIs. // This config is EXPERIMENTAL and may be changed or removed in a later release. FrontendMaxNamespaceVisibilityBurstPerInstance = "frontend.namespaceBurst.visibility" // FrontendGlobalNamespaceRPS is workflow namespace rate limit per second for the whole cluster FrontendGlobalNamespaceRPS = "frontend.globalNamespacerps" // FrontendThrottledLogRPS is the rate limit on number of log messages emitted per second for throttled logger FrontendThrottledLogRPS = "frontend.throttledLogRPS" // FrontendShutdownDrainDuration is the duration of traffic drain during shutdown FrontendShutdownDrainDuration = "frontend.shutdownDrainDuration" // EnableClientVersionCheck enables client version check for frontend EnableClientVersionCheck = "frontend.enableClientVersionCheck" // FrontendMaxBadBinaries is the max number of bad binaries in namespace config FrontendMaxBadBinaries = "frontend.maxBadBinaries" // SendRawWorkflowHistory is whether to enable raw history retrieving SendRawWorkflowHistory = "frontend.sendRawWorkflowHistory" // SearchAttributesNumberOfKeysLimit is the limit of number of keys SearchAttributesNumberOfKeysLimit = "frontend.searchAttributesNumberOfKeysLimit" // SearchAttributesSizeOfValueLimit is the size limit of each value SearchAttributesSizeOfValueLimit = "frontend.searchAttributesSizeOfValueLimit" // SearchAttributesTotalSizeLimit is the size limit of the whole map SearchAttributesTotalSizeLimit = "frontend.searchAttributesTotalSizeLimit" // VisibilityArchivalQueryMaxPageSize is the maximum page size for a visibility archival query VisibilityArchivalQueryMaxPageSize = "frontend.visibilityArchivalQueryMaxPageSize" // VisibilityArchivalQueryMaxRangeInDays is the maximum number of days for a visibility archival query VisibilityArchivalQueryMaxRangeInDays = "frontend.visibilityArchivalQueryMaxRangeInDays" // VisibilityArchivalQueryMaxQPS is the timeout for a visibility archival query VisibilityArchivalQueryMaxQPS = "frontend.visibilityArchivalQueryMaxQPS" // EnableServerVersionCheck is a flag that controls whether or not periodic version checking is enabled EnableServerVersionCheck = "frontend.enableServerVersionCheck" // EnableTokenNamespaceEnforcement enables enforcement that namespace in completion token matches namespace of the request EnableTokenNamespaceEnforcement = "frontend.enableTokenNamespaceEnforcement" // DisableListVisibilityByFilter is config to disable list open/close workflow using filter DisableListVisibilityByFilter = "frontend.disableListVisibilityByFilter" // KeepAliveMinTime is the minimum amount of time a client should wait before sending a keepalive ping. KeepAliveMinTime = "frontend.keepAliveMinTime" // KeepAlivePermitWithoutStream If true, server allows keepalive pings even when there are no active // streams(RPCs). If false, and client sends ping when there are no active // streams, server will send GOAWAY and close the connection. KeepAlivePermitWithoutStream = "frontend.keepAlivePermitWithoutStream" // KeepAliveMaxConnectionIdle is a duration for the amount of time after which an // idle connection would be closed by sending a GoAway. Idleness duration is // defined since the most recent time the number of outstanding RPCs became // zero or the connection establishment. KeepAliveMaxConnectionIdle = "frontend.keepAliveMaxConnectionIdle" // KeepAliveMaxConnectionAge is a duration for the maximum amount of time a // connection may exist before it will be closed by sending a GoAway. A // random jitter of +/-10% will be added to MaxConnectionAge to spread out // connection storms. KeepAliveMaxConnectionAge = "frontend.keepAliveMaxConnectionAge" // KeepAliveMaxConnectionAgeGrace is an additive period after MaxConnectionAge after // which the connection will be forcibly closed. KeepAliveMaxConnectionAgeGrace = "frontend.keepAliveMaxConnectionAgeGrace" // KeepAliveTime After a duration of this time if the server doesn't see any activity it // pings the client to see if the transport is still alive. // If set below 1s, a minimum value of 1s will be used instead. KeepAliveTime = "frontend.keepAliveTime" // KeepAliveTimeout After having pinged for keepalive check, the server waits for a duration // of Timeout and if no activity is seen even after that the connection is closed. KeepAliveTimeout = "frontend.keepAliveTimeout" // FrontendEnableSchedules enables schedule-related RPCs in the frontend FrontendEnableSchedules = "frontend.enableSchedules" // DeleteNamespaceDeleteActivityRPS is RPS per every parallel delete executions activity. // Total RPS is equal to DeleteNamespaceDeleteActivityRPS * DeleteNamespaceConcurrentDeleteExecutionsActivities. DeleteNamespaceDeleteActivityRPS = "frontend.deleteNamespaceDeleteActivityRPS" // DeleteNamespaceConcurrentDeleteExecutionsActivities is a number of concurrent delete executions activities. // Must be not greater than 256 and number of worker cores in the cluster. DeleteNamespaceConcurrentDeleteExecutionsActivities = "frontend.deleteNamespaceConcurrentDeleteExecutionsActivities" // MatchingRPS is request rate per second for each matching host MatchingRPS = "matching.rps" // MatchingPersistenceMaxQPS is the max qps matching host can query DB MatchingPersistenceMaxQPS = "matching.persistenceMaxQPS" // MatchingPersistenceGlobalMaxQPS is the max qps matching cluster can query DB MatchingPersistenceGlobalMaxQPS = "matching.persistenceGlobalMaxQPS" // MatchingMinTaskThrottlingBurstSize is the minimum burst size for task queue throttling MatchingMinTaskThrottlingBurstSize = "matching.minTaskThrottlingBurstSize" // MatchingGetTasksBatchSize is the maximum batch size to fetch from the task buffer MatchingGetTasksBatchSize = "matching.getTasksBatchSize" // MatchingLongPollExpirationInterval is the long poll expiration interval in the matching service MatchingLongPollExpirationInterval = "matching.longPollExpirationInterval" // MatchingSyncMatchWaitDuration is to wait time for sync match MatchingSyncMatchWaitDuration = "matching.syncMatchWaitDuration" // MatchingUpdateAckInterval is the interval for update ack MatchingUpdateAckInterval = "matching.updateAckInterval" // MatchingIdleTaskqueueCheckInterval is the IdleTaskqueueCheckInterval MatchingIdleTaskqueueCheckInterval = "matching.idleTaskqueueCheckInterval" // MaxTaskqueueIdleTime is the max time taskqueue being idle MaxTaskqueueIdleTime = "matching.maxTaskqueueIdleTime" // MatchingOutstandingTaskAppendsThreshold is the threshold for outstanding task appends MatchingOutstandingTaskAppendsThreshold = "matching.outstandingTaskAppendsThreshold" // MatchingMaxTaskBatchSize is max batch size for task writer MatchingMaxTaskBatchSize = "matching.maxTaskBatchSize" // MatchingMaxTaskDeleteBatchSize is the max batch size for range deletion of tasks MatchingMaxTaskDeleteBatchSize = "matching.maxTaskDeleteBatchSize" // MatchingThrottledLogRPS is the rate limit on number of log messages emitted per second for throttled logger MatchingThrottledLogRPS = "matching.throttledLogRPS" // MatchingNumTaskqueueWritePartitions is the number of write partitions for a task queue MatchingNumTaskqueueWritePartitions = "matching.numTaskqueueWritePartitions" // MatchingNumTaskqueueReadPartitions is the number of read partitions for a task queue MatchingNumTaskqueueReadPartitions = "matching.numTaskqueueReadPartitions" // MatchingForwarderMaxOutstandingPolls is the max number of inflight polls from the forwarder MatchingForwarderMaxOutstandingPolls = "matching.forwarderMaxOutstandingPolls" // MatchingForwarderMaxOutstandingTasks is the max number of inflight addTask/queryTask from the forwarder MatchingForwarderMaxOutstandingTasks = "matching.forwarderMaxOutstandingTasks" // MatchingForwarderMaxRatePerSecond is the max rate at which add/query can be forwarded MatchingForwarderMaxRatePerSecond = "matching.forwarderMaxRatePerSecond" // MatchingForwarderMaxChildrenPerNode is the max number of children per node in the task queue partition tree MatchingForwarderMaxChildrenPerNode = "matching.forwarderMaxChildrenPerNode" // MatchingShutdownDrainDuration is the duration of traffic drain during shutdown MatchingShutdownDrainDuration = "matching.shutdownDrainDuration" // HistoryRPS is request rate per second for each history host HistoryRPS = "history.rps" // HistoryPersistenceMaxQPS is the max qps history host can query DB HistoryPersistenceMaxQPS = "history.persistenceMaxQPS" // HistoryPersistenceGlobalMaxQPS is the max qps history cluster can query DB HistoryPersistenceGlobalMaxQPS = "history.persistenceGlobalMaxQPS" // HistoryLongPollExpirationInterval is the long poll expiration interval in the history service HistoryLongPollExpirationInterval = "history.longPollExpirationInterval" // HistoryCacheInitialSize is initial size of history cache HistoryCacheInitialSize = "history.cacheInitialSize" // HistoryCacheMaxSize is max size of history cache HistoryCacheMaxSize = "history.cacheMaxSize" // HistoryCacheTTL is TTL of history cache HistoryCacheTTL = "history.cacheTTL" // HistoryShutdownDrainDuration is the duration of traffic drain during shutdown HistoryShutdownDrainDuration = "history.shutdownDrainDuration" // EventsCacheInitialSize is initial size of events cache EventsCacheInitialSize = "history.eventsCacheInitialSize" // EventsCacheMaxSize is max size of events cache EventsCacheMaxSize = "history.eventsCacheMaxSize" // EventsCacheTTL is TTL of events cache EventsCacheTTL = "history.eventsCacheTTL" // AcquireShardInterval is interval that timer used to acquire shard AcquireShardInterval = "history.acquireShardInterval" // AcquireShardConcurrency is number of goroutines that can be used to acquire shards in the shard controller. AcquireShardConcurrency = "history.acquireShardConcurrency" // StandbyClusterDelay is the artificial delay added to standby cluster's view of active cluster's time StandbyClusterDelay = "history.standbyClusterDelay" // StandbyTaskMissingEventsResendDelay is the amount of time standby cluster's will wait (if events are missing) // before calling remote for missing events StandbyTaskMissingEventsResendDelay = "history.standbyTaskMissingEventsResendDelay" // StandbyTaskMissingEventsDiscardDelay is the amount of time standby cluster's will wait (if events are missing) // before discarding the task StandbyTaskMissingEventsDiscardDelay = "history.standbyTaskMissingEventsDiscardDelay" // TimerTaskHighPriorityRPS is the per namespace rps limit for processing timer tasks as high priority TimerTaskHighPriorityRPS = "history.timerTaskHighPriorityRPS" // TimerTaskBatchSize is batch size for timer processor to process tasks TimerTaskBatchSize = "history.timerTaskBatchSize" // TimerTaskWorkerCount is number of task workers for timer processor TimerTaskWorkerCount = "history.timerTaskWorkerCount" // TimerTaskMaxRetryCount is max retry count for timer processor TimerTaskMaxRetryCount = "history.timerTaskMaxRetryCount" // TimerProcessorEnableSingleCursor indicates if only one timer processor should be started for both active and standby tasks // NOTE: this is an experimental flag for guarantee task execution and will be deprecated after multicursor solution is ready TimerProcessorEnableSingleCursor = "history.timerProcessorEnableSingleCursor" // TimerProcessorEnablePriorityTaskScheduler indicates whether host level priority task scheduler should be used for timer processor TimerProcessorEnablePriorityTaskScheduler = "history.timerProcessorEnablePriorityTaskScheduler" // TimerProcessorSchedulerWorkerCount is the number of workers in the host level task scheduler for timer processor TimerProcessorSchedulerWorkerCount = "history.timerProcessorSchedulerWorkerCount" // TimerProcessorSchedulerQueueSize is the task channel size in the host level task scheduler for timer processor TimerProcessorSchedulerQueueSize = "history.timerProcessorSchedulerQueueSize" // TimerProcessorSchedulerRoundRobinWeights is the priority round robin weights for timer task scheduler TimerProcessorSchedulerRoundRobinWeights = "history.timerProcessorSchedulerRoundRobinWeights" // TimerProcessorCompleteTimerFailureRetryCount is retry count for timer processor complete timer operation TimerProcessorCompleteTimerFailureRetryCount = "history.timerProcessorCompleteTimerFailureRetryCount" // TimerProcessorUpdateAckInterval is update interval for timer processor TimerProcessorUpdateAckInterval = "history.timerProcessorUpdateAckInterval" // TimerProcessorUpdateAckIntervalJitterCoefficient is the update interval jitter coefficient TimerProcessorUpdateAckIntervalJitterCoefficient = "history.timerProcessorUpdateAckIntervalJitterCoefficient" // TimerProcessorCompleteTimerInterval is complete timer interval for timer processor TimerProcessorCompleteTimerInterval = "history.timerProcessorCompleteTimerInterval" // TimerProcessorFailoverMaxPollRPS is max poll rate per second for timer processor TimerProcessorFailoverMaxPollRPS = "history.timerProcessorFailoverMaxPollRPS" // TimerProcessorMaxPollRPS is max poll rate per second for timer processor TimerProcessorMaxPollRPS = "history.timerProcessorMaxPollRPS" // TimerProcessorMaxPollHostRPS is max poll rate per second for all timer processor on a host TimerProcessorMaxPollHostRPS = "history.timerProcessorMaxPollHostRPS" // TimerProcessorMaxPollInterval is max poll interval for timer processor TimerProcessorMaxPollInterval = "history.timerProcessorMaxPollInterval" // TimerProcessorMaxPollIntervalJitterCoefficient is the max poll interval jitter coefficient TimerProcessorMaxPollIntervalJitterCoefficient = "history.timerProcessorMaxPollIntervalJitterCoefficient" // TimerProcessorRescheduleInterval is the redispatch interval for timer processor TimerProcessorRescheduleInterval = "history.timerProcessorRescheduleInterval" // TimerProcessorRescheduleIntervalJitterCoefficient is the redispatch interval jitter coefficient TimerProcessorRescheduleIntervalJitterCoefficient = "history.timerProcessorRescheduleIntervalJitterCoefficient" // TimerProcessorMaxReschedulerSize is the threshold of the number of tasks in the redispatch queue for timer processor TimerProcessorMaxReschedulerSize = "history.timerProcessorMaxReschedulerSize" // TimerProcessorPollBackoffInterval is the poll backoff interval if task redispatcher's size exceeds limit for timer processor TimerProcessorPollBackoffInterval = "history.timerProcessorPollBackoffInterval" // TimerProcessorMaxTimeShift is the max shift timer processor can have TimerProcessorMaxTimeShift = "history.timerProcessorMaxTimeShift" // TimerProcessorHistoryArchivalSizeLimit is the max history size for inline archival TimerProcessorHistoryArchivalSizeLimit = "history.timerProcessorHistoryArchivalSizeLimit" // TimerProcessorArchivalTimeLimit is the upper time limit for inline history archival TimerProcessorArchivalTimeLimit = "history.timerProcessorArchivalTimeLimit" // TransferTaskHighPriorityRPS is the per namespace rps limit for processing timer tasks as high priority TransferTaskHighPriorityRPS = "history.transferTaskHighPriorityRPS" // TransferTaskBatchSize is batch size for transferQueueProcessor TransferTaskBatchSize = "history.transferTaskBatchSize" // TransferProcessorFailoverMaxPollRPS is max poll rate per second for transferQueueProcessor TransferProcessorFailoverMaxPollRPS = "history.transferProcessorFailoverMaxPollRPS" // TransferProcessorMaxPollRPS is max poll rate per second for transferQueueProcessor TransferProcessorMaxPollRPS = "history.transferProcessorMaxPollRPS" // TransferProcessorMaxPollHostRPS is max poll rate per second for all transferQueueProcessor on a host TransferProcessorMaxPollHostRPS = "history.transferProcessorMaxPollHostRPS" // TransferTaskWorkerCount is number of worker for transferQueueProcessor TransferTaskWorkerCount = "history.transferTaskWorkerCount" // TransferTaskMaxRetryCount is max times of retry for transferQueueProcessor TransferTaskMaxRetryCount = "history.transferTaskMaxRetryCount" // TransferProcessorEnableSingleCursor indicates if only one transfer processor should be started for both active and standby tasks // NOTE: this is an experimental flag for guarantee task execution and will be deprecated after multicursor solution is ready TransferProcessorEnableSingleCursor = "history.transferProcessorEnableSingleCursor" // TransferProcessorEnablePriorityTaskScheduler indicates whether host level priority task scheduler should be used for transferQueueProcessor TransferProcessorEnablePriorityTaskScheduler = "history.transferProcessorEnablePriorityTaskScheduler" // TransferProcessorSchedulerWorkerCount is the number of workers in the host level task scheduler for transferQueueProcessor TransferProcessorSchedulerWorkerCount = "history.transferProcessorSchedulerWorkerCount" // TransferProcessorSchedulerQueueSize is the task channel size in the host level task scheduler for transferQueueProcessor TransferProcessorSchedulerQueueSize = "history.transferProcessorSchedulerQueueSize" // TransferProcessorSchedulerRoundRobinWeights is the priority round robin weights for transfer task scheduler TransferProcessorSchedulerRoundRobinWeights = "history.transferProcessorSchedulerRoundRobinWeights" // TransferProcessorCompleteTransferFailureRetryCount is times of retry for failure TransferProcessorCompleteTransferFailureRetryCount = "history.transferProcessorCompleteTransferFailureRetryCount" // TransferProcessorUpdateShardTaskCount is update shard count for transferQueueProcessor TransferProcessorUpdateShardTaskCount = "history.transferProcessorUpdateShardTaskCount" // TransferProcessorMaxPollInterval max poll interval for transferQueueProcessor TransferProcessorMaxPollInterval = "history.transferProcessorMaxPollInterval" // TransferProcessorMaxPollIntervalJitterCoefficient is the max poll interval jitter coefficient TransferProcessorMaxPollIntervalJitterCoefficient = "history.transferProcessorMaxPollIntervalJitterCoefficient" // TransferProcessorUpdateAckInterval is update interval for transferQueueProcessor TransferProcessorUpdateAckInterval = "history.transferProcessorUpdateAckInterval" // TransferProcessorUpdateAckIntervalJitterCoefficient is the update interval jitter coefficient TransferProcessorUpdateAckIntervalJitterCoefficient = "history.transferProcessorUpdateAckIntervalJitterCoefficient" // TransferProcessorCompleteTransferInterval is complete timer interval for transferQueueProcessor TransferProcessorCompleteTransferInterval = "history.transferProcessorCompleteTransferInterval" // TransferProcessorRescheduleInterval is the redispatch interval for transferQueueProcessor TransferProcessorRescheduleInterval = "history.transferProcessorRescheduleInterval" // TransferProcessorRescheduleIntervalJitterCoefficient is the redispatch interval jitter coefficient TransferProcessorRescheduleIntervalJitterCoefficient = "history.transferProcessorRescheduleIntervalJitterCoefficient" // TransferProcessorMaxReschedulerSize is the threshold of the number of tasks in the redispatch queue for transferQueueProcessor TransferProcessorMaxReschedulerSize = "history.transferProcessorMaxReschedulerSize" // TransferProcessorPollBackoffInterval is the poll backoff interval if task redispatcher's size exceeds limit for transferQueueProcessor TransferProcessorPollBackoffInterval = "history.transferProcessorPollBackoffInterval" // TransferProcessorVisibilityArchivalTimeLimit is the upper time limit for archiving visibility records TransferProcessorVisibilityArchivalTimeLimit = "history.transferProcessorVisibilityArchivalTimeLimit" // VisibilityTaskHighPriorityRPS is the per namespace rps limit for processing timer tasks as high priority VisibilityTaskHighPriorityRPS = "history.visibilityTaskHighPriorityRPS" // VisibilityTaskBatchSize is batch size for visibilityQueueProcessor VisibilityTaskBatchSize = "history.visibilityTaskBatchSize" // VisibilityProcessorFailoverMaxPollRPS is max poll rate per second for visibilityQueueProcessor VisibilityProcessorFailoverMaxPollRPS = "history.visibilityProcessorFailoverMaxPollRPS" // VisibilityProcessorMaxPollRPS is max poll rate per second for visibilityQueueProcessor VisibilityProcessorMaxPollRPS = "history.visibilityProcessorMaxPollRPS" // VisibilityProcessorMaxPollHostRPS is max poll rate per second for all visibilityQueueProcessor on a host VisibilityProcessorMaxPollHostRPS = "history.visibilityProcessorMaxPollHostRPS" // VisibilityTaskWorkerCount is number of worker for visibilityQueueProcessor VisibilityTaskWorkerCount = "history.visibilityTaskWorkerCount" // VisibilityTaskMaxRetryCount is max times of retry for visibilityQueueProcessor VisibilityTaskMaxRetryCount = "history.visibilityTaskMaxRetryCount" // VisibilityProcessorEnablePriorityTaskScheduler indicates whether host level priority task scheduler should be used for visibilityQueueProcessor VisibilityProcessorEnablePriorityTaskScheduler = "history.visibilityProcessorEnablePriorityTaskScheduler" // VisibilityProcessorSchedulerWorkerCount is the number of workers in the host level task scheduler for visibilityQueueProcessor VisibilityProcessorSchedulerWorkerCount = "history.visibilityProcessorSchedulerWorkerCount" // VisibilityProcessorSchedulerQueueSize is the task channel size in the host level task scheduler for visibilityQueueProcessor VisibilityProcessorSchedulerQueueSize = "history.visibilityProcessorSchedulerQueueSize" // VisibilityProcessorSchedulerRoundRobinWeights is the priority round robin weights for visibility task scheduler VisibilityProcessorSchedulerRoundRobinWeights = "history.visibilityProcessorSchedulerRoundRobinWeights" // VisibilityProcessorCompleteTaskFailureRetryCount is times of retry for failure VisibilityProcessorCompleteTaskFailureRetryCount = "history.visibilityProcessorCompleteTaskFailureRetryCount" // VisibilityProcessorMaxPollInterval max poll interval for visibilityQueueProcessor VisibilityProcessorMaxPollInterval = "history.visibilityProcessorMaxPollInterval" // VisibilityProcessorMaxPollIntervalJitterCoefficient is the max poll interval jitter coefficient VisibilityProcessorMaxPollIntervalJitterCoefficient = "history.visibilityProcessorMaxPollIntervalJitterCoefficient" // VisibilityProcessorUpdateAckInterval is update interval for visibilityQueueProcessor VisibilityProcessorUpdateAckInterval = "history.visibilityProcessorUpdateAckInterval" // VisibilityProcessorUpdateAckIntervalJitterCoefficient is the update interval jitter coefficient VisibilityProcessorUpdateAckIntervalJitterCoefficient = "history.visibilityProcessorUpdateAckIntervalJitterCoefficient" // VisibilityProcessorCompleteTaskInterval is complete timer interval for visibilityQueueProcessor VisibilityProcessorCompleteTaskInterval = "history.visibilityProcessorCompleteTaskInterval" // VisibilityProcessorRescheduleInterval is the redispatch interval for visibilityQueueProcessor VisibilityProcessorRescheduleInterval = "history.visibilityProcessorRescheduleInterval" // VisibilityProcessorRescheduleIntervalJitterCoefficient is the redispatch interval jitter coefficient VisibilityProcessorRescheduleIntervalJitterCoefficient = "history.visibilityProcessorRescheduleIntervalJitterCoefficient" // VisibilityProcessorMaxReschedulerSize is the threshold of the number of tasks in the redispatch queue for visibilityQueueProcessor VisibilityProcessorMaxReschedulerSize = "history.visibilityProcessorMaxReschedulerSize" // VisibilityProcessorPollBackoffInterval is the poll backoff interval if task redispatcher's size exceeds limit for visibilityQueueProcessor VisibilityProcessorPollBackoffInterval = "history.visibilityProcessorPollBackoffInterval" // VisibilityProcessorVisibilityArchivalTimeLimit is the upper time limit for archiving visibility records VisibilityProcessorVisibilityArchivalTimeLimit = "history.visibilityProcessorVisibilityArchivalTimeLimit" // ReplicatorTaskBatchSize is batch size for ReplicatorProcessor ReplicatorTaskBatchSize = "history.replicatorTaskBatchSize" // ReplicatorTaskWorkerCount is number of worker for ReplicatorProcessor ReplicatorTaskWorkerCount = "history.replicatorTaskWorkerCount" // ReplicatorTaskMaxRetryCount is max times of retry for ReplicatorProcessor ReplicatorTaskMaxRetryCount = "history.replicatorTaskMaxRetryCount" // ReplicatorProcessorMaxPollRPS is max poll rate per second for ReplicatorProcessor ReplicatorProcessorMaxPollRPS = "history.replicatorProcessorMaxPollRPS" // ReplicatorProcessorMaxPollInterval is max poll interval for ReplicatorProcessor ReplicatorProcessorMaxPollInterval = "history.replicatorProcessorMaxPollInterval" // ReplicatorProcessorMaxPollIntervalJitterCoefficient is the max poll interval jitter coefficient ReplicatorProcessorMaxPollIntervalJitterCoefficient = "history.replicatorProcessorMaxPollIntervalJitterCoefficient" // ReplicatorProcessorUpdateAckInterval is update interval for ReplicatorProcessor ReplicatorProcessorUpdateAckInterval = "history.replicatorProcessorUpdateAckInterval" // ReplicatorProcessorUpdateAckIntervalJitterCoefficient is the update interval jitter coefficient ReplicatorProcessorUpdateAckIntervalJitterCoefficient = "history.replicatorProcessorUpdateAckIntervalJitterCoefficient" // ReplicatorProcessorRescheduleInterval is the redispatch interval for ReplicatorProcessor ReplicatorProcessorRescheduleInterval = "history.replicatorProcessorRescheduleInterval" // ReplicatorProcessorRescheduleIntervalJitterCoefficient is the redispatch interval jitter coefficient ReplicatorProcessorRescheduleIntervalJitterCoefficient = "history.replicatorProcessorRescheduleIntervalJitterCoefficient" // ReplicatorProcessorMaxReschedulerSize is the threshold of the number of tasks in the redispatch queue for ReplicatorProcessor ReplicatorProcessorMaxReschedulerSize = "history.replicatorProcessorMaxReschedulerSize" // ReplicatorProcessorEnablePriorityTaskProcessor indicates whether priority task processor should be used for ReplicatorProcessor ReplicatorProcessorEnablePriorityTaskProcessor = "history.replicatorProcessorEnablePriorityTaskProcessor" // MaximumBufferedEventsBatch is max number of buffer event in mutable state MaximumBufferedEventsBatch = "history.maximumBufferedEventsBatch" // MaximumSignalsPerExecution is max number of signals supported by single execution MaximumSignalsPerExecution = "history.maximumSignalsPerExecution" // ShardUpdateMinInterval is the minimal time interval which the shard info can be updated ShardUpdateMinInterval = "history.shardUpdateMinInterval" // ShardSyncMinInterval is the minimal time interval which the shard info should be sync to remote ShardSyncMinInterval = "history.shardSyncMinInterval" // EmitShardDiffLog whether emit the shard diff log EmitShardDiffLog = "history.emitShardDiffLog" // DefaultEventEncoding is the encoding type for history events DefaultEventEncoding = "history.defaultEventEncoding" // NumArchiveSystemWorkflows is key for number of archive system workflows running in total NumArchiveSystemWorkflows = "history.numArchiveSystemWorkflows" // ArchiveRequestRPS is the rate limit on the number of archive request per second ArchiveRequestRPS = "history.archiveRequestRPS" // DefaultActivityRetryPolicy represents the out-of-box retry policy for activities where // the user has not specified an explicit RetryPolicy DefaultActivityRetryPolicy = "history.defaultActivityRetryPolicy" // DefaultWorkflowRetryPolicy represents the out-of-box retry policy for unset fields // where the user has set an explicit RetryPolicy, but not specified all the fields DefaultWorkflowRetryPolicy = "history.defaultWorkflowRetryPolicy" // HistoryMaxAutoResetPoints is the key for max number of auto reset points stored in mutableState HistoryMaxAutoResetPoints = "history.historyMaxAutoResetPoints" // EnableParentClosePolicy whether to ParentClosePolicy EnableParentClosePolicy = "history.enableParentClosePolicy" // ParentClosePolicyThreshold decides that parent close policy will be processed by sys workers(if enabled) if // the number of children greater than or equal to this threshold ParentClosePolicyThreshold = "history.parentClosePolicyThreshold" // NumParentClosePolicySystemWorkflows is key for number of parentClosePolicy system workflows running in total NumParentClosePolicySystemWorkflows = "history.numParentClosePolicySystemWorkflows" // HistoryThrottledLogRPS is the rate limit on number of log messages emitted per second for throttled logger HistoryThrottledLogRPS = "history.throttledLogRPS" // StickyTTL is to expire a sticky taskqueue if no update more than this duration StickyTTL = "history.stickyTTL" // WorkflowTaskHeartbeatTimeout for workflow task heartbeat WorkflowTaskHeartbeatTimeout = "history.workflowTaskHeartbeatTimeout" // WorkflowTaskCriticalAttempts is the number of attempts for a workflow task that's regarded as critical WorkflowTaskCriticalAttempts = "history.workflowTaskCriticalAttempt" // WorkflowTaskRetryMaxInterval is the maximum interval added to a workflow task's startToClose timeout for slowing down retry WorkflowTaskRetryMaxInterval = "history.workflowTaskRetryMaxInterval" // DefaultWorkflowTaskTimeout for a workflow task DefaultWorkflowTaskTimeout = "history.defaultWorkflowTaskTimeout" // SkipReapplicationByNamespaceID is whether skipping a event re-application for a namespace SkipReapplicationByNamespaceID = "history.SkipReapplicationByNamespaceID" // StandbyTaskReReplicationContextTimeout is the context timeout for standby task re-replication StandbyTaskReReplicationContextTimeout = "history.standbyTaskReReplicationContextTimeout" // MaxBufferedQueryCount indicates max buffer query count MaxBufferedQueryCount = "history.MaxBufferedQueryCount" // MutableStateChecksumGenProbability is the probability [0-100] that checksum will be generated for mutable state MutableStateChecksumGenProbability = "history.mutableStateChecksumGenProbability" // MutableStateChecksumVerifyProbability is the probability [0-100] that checksum will be verified for mutable state MutableStateChecksumVerifyProbability = "history.mutableStateChecksumVerifyProbability" // MutableStateChecksumInvalidateBefore is the epoch timestamp before which all checksums are to be discarded MutableStateChecksumInvalidateBefore = "history.mutableStateChecksumInvalidateBefore" // ReplicationTaskFetcherParallelism determines how many go routines we spin up for fetching tasks ReplicationTaskFetcherParallelism = "history.ReplicationTaskFetcherParallelism" // ReplicationTaskFetcherAggregationInterval determines how frequently the fetch requests are sent ReplicationTaskFetcherAggregationInterval = "history.ReplicationTaskFetcherAggregationInterval" // ReplicationTaskFetcherTimerJitterCoefficient is the jitter for fetcher timer ReplicationTaskFetcherTimerJitterCoefficient = "history.ReplicationTaskFetcherTimerJitterCoefficient" // ReplicationTaskFetcherErrorRetryWait is the wait time when fetcher encounters error ReplicationTaskFetcherErrorRetryWait = "history.ReplicationTaskFetcherErrorRetryWait" // ReplicationTaskProcessorErrorRetryWait is the initial retry wait when we see errors in applying replication tasks ReplicationTaskProcessorErrorRetryWait = "history.ReplicationTaskProcessorErrorRetryWait" // ReplicationTaskProcessorErrorRetryBackoffCoefficient is the retry wait backoff time coefficient ReplicationTaskProcessorErrorRetryBackoffCoefficient = "history.ReplicationTaskProcessorErrorRetryBackoffCoefficient" // ReplicationTaskProcessorErrorRetryMaxInterval is the retry wait backoff max duration ReplicationTaskProcessorErrorRetryMaxInterval = "history.ReplicationTaskProcessorErrorRetryMaxInterval" // ReplicationTaskProcessorErrorRetryMaxAttempts is the max retry attempts for applying replication tasks ReplicationTaskProcessorErrorRetryMaxAttempts = "history.ReplicationTaskProcessorErrorRetryMaxAttempts" // ReplicationTaskProcessorErrorRetryExpiration is the max retry duration for applying replication tasks ReplicationTaskProcessorErrorRetryExpiration = "history.ReplicationTaskProcessorErrorRetryExpiration" // ReplicationTaskProcessorNoTaskInitialWait is the wait time when not ask is returned ReplicationTaskProcessorNoTaskInitialWait = "history.ReplicationTaskProcessorNoTaskInitialWait" // ReplicationTaskProcessorCleanupInterval determines how frequently the cleanup replication queue ReplicationTaskProcessorCleanupInterval = "history.ReplicationTaskProcessorCleanupInterval" // ReplicationTaskProcessorCleanupJitterCoefficient is the jitter for cleanup timer ReplicationTaskProcessorCleanupJitterCoefficient = "history.ReplicationTaskProcessorCleanupJitterCoefficient" // ReplicationTaskProcessorStartWait is the wait time before each task processing batch ReplicationTaskProcessorStartWait = "history.ReplicationTaskProcessorStartWait" // ReplicationTaskProcessorHostQPS is the qps of task processing rate limiter on host level ReplicationTaskProcessorHostQPS = "history.ReplicationTaskProcessorHostQPS" // ReplicationTaskProcessorShardQPS is the qps of task processing rate limiter on shard level ReplicationTaskProcessorShardQPS = "history.ReplicationTaskProcessorShardQPS" // WorkerPersistenceMaxQPS is the max qps worker host can query DB WorkerPersistenceMaxQPS = "worker.persistenceMaxQPS" // WorkerPersistenceGlobalMaxQPS is the max qps worker cluster can query DB WorkerPersistenceGlobalMaxQPS = "worker.persistenceGlobalMaxQPS" // WorkerIndexerConcurrency is the max concurrent messages to be processed at any given time WorkerIndexerConcurrency = "worker.indexerConcurrency" // WorkerESProcessorNumOfWorkers is num of workers for esProcessor WorkerESProcessorNumOfWorkers = "worker.ESProcessorNumOfWorkers" // WorkerESProcessorBulkActions is max number of requests in bulk for esProcessor WorkerESProcessorBulkActions = "worker.ESProcessorBulkActions" // WorkerESProcessorBulkSize is max total size of bulk in bytes for esProcessor WorkerESProcessorBulkSize = "worker.ESProcessorBulkSize" // WorkerESProcessorFlushInterval is flush interval for esProcessor WorkerESProcessorFlushInterval = "worker.ESProcessorFlushInterval" // WorkerESProcessorAckTimeout is the timeout that store will wait to get ack signal from ES processor. // Should be at least WorkerESProcessorFlushInterval+<time to process request>. WorkerESProcessorAckTimeout = "worker.ESProcessorAckTimeout" // WorkerArchiverMaxConcurrentActivityExecutionSize indicates worker archiver max concurrent activity execution size WorkerArchiverMaxConcurrentActivityExecutionSize = "worker.ArchiverMaxConcurrentActivityExecutionSize" // WorkerArchiverMaxConcurrentWorkflowTaskExecutionSize indicates worker archiver max concurrent workflow execution size WorkerArchiverMaxConcurrentWorkflowTaskExecutionSize = "worker.ArchiverMaxConcurrentWorkflowTaskExecutionSize" // WorkerArchiverMaxConcurrentActivityTaskPollers indicates worker archiver max concurrent activity pollers WorkerArchiverMaxConcurrentActivityTaskPollers = "worker.ArchiverMaxConcurrentActivityTaskPollers" // WorkerArchiverMaxConcurrentWorkflowTaskPollers indicates worker archiver max concurrent workflow pollers WorkerArchiverMaxConcurrentWorkflowTaskPollers = "worker.ArchiverMaxConcurrentWorkflowTaskPollers" // WorkerArchiverConcurrency controls the number of coroutines handling archival work per archival workflow WorkerArchiverConcurrency = "worker.ArchiverConcurrency" // WorkerArchivalsPerIteration controls the number of archivals handled in each iteration of archival workflow WorkerArchivalsPerIteration = "worker.ArchivalsPerIteration" // WorkerTimeLimitPerArchivalIteration controls the time limit of each iteration of archival workflow WorkerTimeLimitPerArchivalIteration = "worker.TimeLimitPerArchivalIteration" // WorkerThrottledLogRPS is the rate limit on number of log messages emitted per second for throttled logger WorkerThrottledLogRPS = "worker.throttledLogRPS" // WorkerScannerMaxConcurrentActivityExecutionSize indicates worker scanner max concurrent activity execution size WorkerScannerMaxConcurrentActivityExecutionSize = "worker.ScannerMaxConcurrentActivityExecutionSize" // WorkerScannerMaxConcurrentWorkflowTaskExecutionSize indicates worker scanner max concurrent workflow execution size WorkerScannerMaxConcurrentWorkflowTaskExecutionSize = "worker.ScannerMaxConcurrentWorkflowTaskExecutionSize" // WorkerScannerMaxConcurrentActivityTaskPollers indicates worker scanner max concurrent activity pollers WorkerScannerMaxConcurrentActivityTaskPollers = "worker.ScannerMaxConcurrentActivityTaskPollers" // WorkerScannerMaxConcurrentWorkflowTaskPollers indicates worker scanner max concurrent workflow pollers WorkerScannerMaxConcurrentWorkflowTaskPollers = "worker.ScannerMaxConcurrentWorkflowTaskPollers" // ScannerPersistenceMaxQPS is the maximum rate of persistence calls from worker.Scanner ScannerPersistenceMaxQPS = "worker.scannerPersistenceMaxQPS" // TaskQueueScannerEnabled indicates if task queue scanner should be started as part of worker.Scanner TaskQueueScannerEnabled = "worker.taskQueueScannerEnabled" // HistoryScannerEnabled indicates if history scanner should be started as part of worker.Scanner HistoryScannerEnabled = "worker.historyScannerEnabled" // ExecutionsScannerEnabled indicates if executions scanner should be started as part of worker.Scanner ExecutionsScannerEnabled = "worker.executionsScannerEnabled" // WorkerBatcherMaxConcurrentActivityExecutionSize indicates worker batcher max concurrent activity execution size WorkerBatcherMaxConcurrentActivityExecutionSize = "worker.BatcherMaxConcurrentActivityExecutionSize" // WorkerBatcherMaxConcurrentWorkflowTaskExecutionSize indicates worker batcher max concurrent workflow execution size WorkerBatcherMaxConcurrentWorkflowTaskExecutionSize = "worker.BatcherMaxConcurrentWorkflowTaskExecutionSize" // WorkerBatcherMaxConcurrentActivityTaskPollers indicates worker batcher max concurrent activity pollers WorkerBatcherMaxConcurrentActivityTaskPollers = "worker.BatcherMaxConcurrentActivityTaskPollers" // WorkerBatcherMaxConcurrentWorkflowTaskPollers indicates worker batcher max concurrent workflow pollers WorkerBatcherMaxConcurrentWorkflowTaskPollers = "worker.BatcherMaxConcurrentWorkflowTaskPollers" // EnableBatcher decides whether start batcher in our worker EnableBatcher = "worker.enableBatcher" // WorkerParentCloseMaxConcurrentActivityExecutionSize indicates worker parent close worker max concurrent activity execution size WorkerParentCloseMaxConcurrentActivityExecutionSize = "worker.ParentCloseMaxConcurrentActivityExecutionSize" // WorkerParentCloseMaxConcurrentWorkflowTaskExecutionSize indicates worker parent close worker max concurrent workflow execution size WorkerParentCloseMaxConcurrentWorkflowTaskExecutionSize = "worker.ParentCloseMaxConcurrentWorkflowTaskExecutionSize" // WorkerParentCloseMaxConcurrentActivityTaskPollers indicates worker parent close worker max concurrent activity pollers WorkerParentCloseMaxConcurrentActivityTaskPollers = "worker.ParentCloseMaxConcurrentActivityTaskPollers" // WorkerParentCloseMaxConcurrentWorkflowTaskPollers indicates worker parent close worker max concurrent workflow pollers WorkerParentCloseMaxConcurrentWorkflowTaskPollers = "worker.ParentCloseMaxConcurrentWorkflowTaskPollers" // WorkerEnableScheduler controls whether to start the worker for scheduled workflows WorkerEnableScheduler = "worker.enableScheduler" // WorkerSchedulerNumWorkers controls number of scheduler workers to run per namespace WorkerSchedulerNumWorkers = "worker.schedulerNumWorkers" )
const DefaultNumTaskQueuePartitions = 4
Variables ¶
This section is empty.
Functions ¶
func GetBoolPropertyFn ¶
func GetBoolPropertyFn(value bool) func(opts ...FilterOption) bool
GetBoolPropertyFn returns value as BoolPropertyFn
func GetBoolPropertyFnFilteredByNamespace ¶
GetBoolPropertyFnFilteredByNamespace returns value as BoolPropertyFnWithNamespaceFilters
func GetDurationPropertyFn ¶
func GetDurationPropertyFn(value time.Duration) func(opts ...FilterOption) time.Duration
GetDurationPropertyFn returns value as DurationPropertyFn
func GetDurationPropertyFnFilteredByNamespace ¶
func GetDurationPropertyFnFilteredByNamespace(value time.Duration) func(namespace string) time.Duration
GetDurationPropertyFnFilteredByNamespace returns value as DurationPropertyFnFilteredByNamespace
func GetDurationPropertyFnFilteredByTaskQueueInfo ¶
func GetDurationPropertyFnFilteredByTaskQueueInfo(value time.Duration) func(namespace string, taskQueue string, taskType enumspb.TaskQueueType) time.Duration
GetDurationPropertyFnFilteredByTaskQueueInfo returns value as DurationPropertyFnWithTaskQueueInfoFilters
func GetFloatPropertyFn ¶
func GetFloatPropertyFn(value float64) func(opts ...FilterOption) float64
GetFloatPropertyFn returns value as FloatPropertyFn
func GetIntPropertyFilteredByNamespace ¶
GetIntPropertyFilteredByNamespace returns values as IntPropertyFnWithNamespaceFilters
func GetIntPropertyFilteredByTaskQueueInfo ¶
func GetIntPropertyFilteredByTaskQueueInfo(value int) func(namespace string, taskQueue string, taskType enumspb.TaskQueueType) int
GetIntPropertyFilteredByTaskQueueInfo returns value as IntPropertyFnWithTaskQueueInfoFilters
func GetIntPropertyFn ¶
func GetIntPropertyFn(value int) func(opts ...FilterOption) int
GetIntPropertyFn returns value as IntPropertyFn
func GetMapPropertyFn ¶
func GetMapPropertyFn(value map[string]interface{}) func(opts ...FilterOption) map[string]interface{}
GetMapPropertyFn returns value as MapPropertyFn
func GetMapPropertyFnWithNamespaceFilter ¶
func GetMapPropertyFnWithNamespaceFilter(value map[string]interface{}) func(namespace string) map[string]interface{}
GetMapPropertyFnWithNamespaceFilter returns value as MapPropertyFn
func GetStringPropertyFn ¶
func GetStringPropertyFn(value string) func(opts ...FilterOption) string
GetStringPropertyFn returns value as StringPropertyFn
func NewFileBasedClient ¶
func NewFileBasedClient(config *FileBasedClientConfig, logger log.Logger, doneCh <-chan interface{}) (*fileBasedClient, error)
NewFileBasedClient creates a file based client.
func NewFileBasedClientWithReader ¶ added in v1.16.0
func NewFileBasedClientWithReader(reader fileReader, config *FileBasedClientConfig, logger log.Logger, doneCh <-chan interface{}) (*fileBasedClient, error)
Types ¶
type BoolPropertyFn ¶
type BoolPropertyFn func(opts ...FilterOption) bool
BoolPropertyFn is a wrapper to get bool property from dynamic config
type BoolPropertyFnWithNamespaceFilter ¶
BoolPropertyFnWithNamespaceFilter is a wrapper to get bool property from dynamic config
type BoolPropertyFnWithNamespaceIDFilter ¶
BoolPropertyFnWithNamespaceIDFilter is a wrapper to get bool property from dynamic config
type BoolPropertyFnWithTaskQueueInfoFilters ¶
type BoolPropertyFnWithTaskQueueInfoFilters func(namespace string, taskQueue string, taskType enumspb.TaskQueueType) bool
BoolPropertyFnWithTaskQueueInfoFilters is a wrapper to get bool property from dynamic config with three filters: namespace, taskQueue, taskType
type Client ¶
type Client interface { GetValue(name Key, defaultValue interface{}) (interface{}, error) GetValueWithFilters(name Key, filters []map[Filter]interface{}, defaultValue interface{}) (interface{}, error) GetIntValue(name Key, filters []map[Filter]interface{}, defaultValue int) (int, error) GetFloatValue(name Key, filters []map[Filter]interface{}, defaultValue float64) (float64, error) GetBoolValue(name Key, filters []map[Filter]interface{}, defaultValue bool) (bool, error) GetStringValue(name Key, filters []map[Filter]interface{}, defaultValue string) (string, error) GetMapValue( name Key, filters []map[Filter]interface{}, defaultValue map[string]interface{}, ) (map[string]interface{}, error) GetDurationValue( name Key, filters []map[Filter]interface{}, defaultValue time.Duration, ) (time.Duration, error) }
Client allows fetching values from a dynamic configuration system NOTE: This does not have async options right now. In the interest of keeping it minimal, we can add when requirement arises. Filters should be ordered from most to least specific. An empty filter is automatically added to the end of each filters slice, so callers don't need to add it.
type Collection ¶
type Collection struct {
// contains filtered or unexported fields
}
Collection wraps dynamic config client with a closure so that across the code, the config values can be directly accessed by calling the function without propagating the client everywhere in code
func NewCollection ¶
func NewCollection(client Client, logger log.Logger) *Collection
NewCollection creates a new collection
func NewNoopCollection ¶
func NewNoopCollection() *Collection
NewNoopCollection creates a new nop collection
func (*Collection) GetBoolProperty ¶
func (c *Collection) GetBoolProperty(key Key, defaultValue bool) BoolPropertyFn
GetBoolProperty gets property and asserts that it's an bool
func (*Collection) GetBoolPropertyFilteredByTaskQueueInfo ¶
func (c *Collection) GetBoolPropertyFilteredByTaskQueueInfo(key Key, defaultValue bool) BoolPropertyFnWithTaskQueueInfoFilters
GetBoolPropertyFilteredByTaskQueueInfo gets property with taskQueueInfo as filters and asserts that it's an bool
func (*Collection) GetBoolPropertyFnWithNamespaceFilter ¶
func (c *Collection) GetBoolPropertyFnWithNamespaceFilter(key Key, defaultValue bool) BoolPropertyFnWithNamespaceFilter
GetBoolPropertyFnWithNamespaceFilter gets property with namespace filter and asserts that its namespace
func (*Collection) GetBoolPropertyFnWithNamespaceIDFilter ¶
func (c *Collection) GetBoolPropertyFnWithNamespaceIDFilter(key Key, defaultValue bool) BoolPropertyFnWithNamespaceIDFilter
GetBoolPropertyFnWithNamespaceIDFilter gets property with namespaceID filter and asserts that it's a bool
func (*Collection) GetDurationProperty ¶
func (c *Collection) GetDurationProperty(key Key, defaultValue time.Duration) DurationPropertyFn
GetDurationProperty gets property and asserts that it's a duration
func (*Collection) GetDurationPropertyFilteredByNamespace ¶
func (c *Collection) GetDurationPropertyFilteredByNamespace(key Key, defaultValue time.Duration) DurationPropertyFnWithNamespaceFilter
GetDurationPropertyFilteredByNamespace gets property with namespace filter and asserts that it's a duration
func (*Collection) GetDurationPropertyFilteredByNamespaceID ¶
func (c *Collection) GetDurationPropertyFilteredByNamespaceID(key Key, defaultValue time.Duration) DurationPropertyFnWithNamespaceIDFilter
GetDurationPropertyFilteredByNamespaceID gets property with namespaceID filter and asserts that it's a duration
func (*Collection) GetDurationPropertyFilteredByShardID ¶
func (c *Collection) GetDurationPropertyFilteredByShardID(key Key, defaultValue time.Duration) DurationPropertyFnWithShardIDFilter
GetDurationPropertyFilteredByShardID gets property with shardID id as filter and asserts that it's a duration
func (*Collection) GetDurationPropertyFilteredByTaskQueueInfo ¶
func (c *Collection) GetDurationPropertyFilteredByTaskQueueInfo(key Key, defaultValue time.Duration) DurationPropertyFnWithTaskQueueInfoFilters
GetDurationPropertyFilteredByTaskQueueInfo gets property with taskQueueInfo as filters and asserts that it's a duration
func (*Collection) GetFloat64Property ¶
func (c *Collection) GetFloat64Property(key Key, defaultValue float64) FloatPropertyFn
GetFloat64Property gets property and asserts that it's a float64
func (*Collection) GetFloat64PropertyFilteredByShardID ¶
func (c *Collection) GetFloat64PropertyFilteredByShardID(key Key, defaultValue float64) FloatPropertyFnWithShardIDFilter
GetFloat64PropertyFilteredByShardID gets property with shardID filter and asserts that it's a float64
func (*Collection) GetFloatPropertyFilteredByNamespace ¶
func (c *Collection) GetFloatPropertyFilteredByNamespace(key Key, defaultValue float64) FloatPropertyFnWithNamespaceFilter
GetFloatPropertyFilteredByNamespace gets property with namespace filter and asserts that it's a float
func (*Collection) GetFloatPropertyFilteredByTaskQueueInfo ¶
func (c *Collection) GetFloatPropertyFilteredByTaskQueueInfo(key Key, defaultValue float64) FloatPropertyFnWithTaskQueueInfoFilters
GetFloatPropertyFilteredByTaskQueueInfo gets property with taskQueueInfo as filters and asserts that it's an integer
func (*Collection) GetIntProperty ¶
func (c *Collection) GetIntProperty(key Key, defaultValue int) IntPropertyFn
GetIntProperty gets property and asserts that it's an integer
func (*Collection) GetIntPropertyFilteredByNamespace ¶
func (c *Collection) GetIntPropertyFilteredByNamespace(key Key, defaultValue int) IntPropertyFnWithNamespaceFilter
GetIntPropertyFilteredByNamespace gets property with namespace filter and asserts that it's an integer
func (*Collection) GetIntPropertyFilteredByShardID ¶
func (c *Collection) GetIntPropertyFilteredByShardID(key Key, defaultValue int) IntPropertyFnWithShardIDFilter
GetIntPropertyFilteredByShardID gets property with shardID as filter and asserts that it's an integer
func (*Collection) GetIntPropertyFilteredByTaskQueueInfo ¶
func (c *Collection) GetIntPropertyFilteredByTaskQueueInfo(key Key, defaultValue int) IntPropertyFnWithTaskQueueInfoFilters
GetIntPropertyFilteredByTaskQueueInfo gets property with taskQueueInfo as filters and asserts that it's an integer
func (*Collection) GetMapProperty ¶
func (c *Collection) GetMapProperty(key Key, defaultValue map[string]interface{}) MapPropertyFn
GetMapProperty gets property and asserts that it's a map
func (*Collection) GetMapPropertyFnWithNamespaceFilter ¶
func (c *Collection) GetMapPropertyFnWithNamespaceFilter(key Key, defaultValue map[string]interface{}) MapPropertyFnWithNamespaceFilter
GetMapPropertyFnWithNamespaceFilter gets property and asserts that it's a map
func (*Collection) GetProperty ¶
func (c *Collection) GetProperty(key Key, defaultValue interface{}) PropertyFn
GetProperty gets a interface property and returns defaultValue if property is not found
func (*Collection) GetStringProperty ¶
func (c *Collection) GetStringProperty(key Key, defaultValue string) StringPropertyFn
GetStringProperty gets property and asserts that it's an string
func (*Collection) GetStringPropertyFnWithNamespaceFilter ¶
func (c *Collection) GetStringPropertyFnWithNamespaceFilter(key Key, defaultValue string) StringPropertyFnWithNamespaceFilter
GetStringPropertyFnWithNamespaceFilter gets property with namespace filter and asserts that its namespace
type DurationPropertyFn ¶
type DurationPropertyFn func(opts ...FilterOption) time.Duration
DurationPropertyFn is a wrapper to get duration property from dynamic config
type DurationPropertyFnWithNamespaceFilter ¶
DurationPropertyFnWithNamespaceFilter is a wrapper to get duration property from dynamic config with namespace as filter
type DurationPropertyFnWithNamespaceIDFilter ¶
DurationPropertyFnWithNamespaceIDFilter is a wrapper to get duration property from dynamic config with namespaceID as filter
type DurationPropertyFnWithShardIDFilter ¶
DurationPropertyFnWithShardIDFilter is a wrapper to get duration property from dynamic config with shardID as filter
type DurationPropertyFnWithTaskQueueInfoFilters ¶
type DurationPropertyFnWithTaskQueueInfoFilters func(namespace string, taskQueue string, taskType enumspb.TaskQueueType) time.Duration
DurationPropertyFnWithTaskQueueInfoFilters is a wrapper to get duration property from dynamic config with three filters: namespace, taskQueue, taskType
type FileBasedClientConfig ¶
type FileBasedClientConfig struct { Filepath string `yaml:"filepath"` PollInterval time.Duration `yaml:"pollInterval"` }
FileBasedClientConfig is the config for the file based dynamic config client. It specifies where the config file is stored and how often the config should be updated by checking the config file again.
type Filter ¶
type Filter int
Filter represents a filter on the dynamic config key
const ( // Namespace is the namespace name Namespace Filter // NamespaceID is the namespace Id NamespaceID // TaskQueueName is the taskqueue name TaskQueueName // TaskType is the task type (0:Workflow, 1:Activity) TaskType // ShardID is the shard id ShardID )
type FilterOption ¶
type FilterOption func(filterMap map[Filter]interface{})
FilterOption is used to provide filters for dynamic config keys
func NamespaceFilter ¶
func NamespaceFilter(name string) FilterOption
NamespaceFilter filters by namespace name
func NamespaceIDFilter ¶
func NamespaceIDFilter(namespaceID string) FilterOption
NamespaceIDFilter filters by namespace id
func ShardIDFilter ¶
func ShardIDFilter(shardID int32) FilterOption
ShardIDFilter filters by shard id
func TaskQueueFilter ¶
func TaskQueueFilter(name string) FilterOption
TaskQueueFilter filters by task queue name
func TaskTypeFilter ¶
func TaskTypeFilter(taskType enumspb.TaskQueueType) FilterOption
TaskTypeFilter filters by task type
type FloatPropertyFn ¶
type FloatPropertyFn func(opts ...FilterOption) float64
FloatPropertyFn is a wrapper to get float property from dynamic config
type FloatPropertyFnWithNamespaceFilter ¶
FloatPropertyFnWithNamespaceFilter is a wrapper to get float property from dynamic config with namespace as filter
type FloatPropertyFnWithShardIDFilter ¶
FloatPropertyFnWithShardIDFilter is a wrapper to get float property from dynamic config with shardID as filter
type FloatPropertyFnWithTaskQueueInfoFilters ¶
type FloatPropertyFnWithTaskQueueInfoFilters func(namespace string, taskQueue string, taskType enumspb.TaskQueueType) float64
FloatPropertyFnWithTaskQueueInfoFilters is a wrapper to get float property from dynamic config with three filters: namespace, taskQueue, taskType
type IntPropertyFn ¶
type IntPropertyFn func(opts ...FilterOption) int
IntPropertyFn is a wrapper to get int property from dynamic config
type IntPropertyFnWithNamespaceFilter ¶
IntPropertyFnWithNamespaceFilter is a wrapper to get int property from dynamic config with namespace as filter
type IntPropertyFnWithShardIDFilter ¶
IntPropertyFnWithShardIDFilter is a wrapper to get int property from dynamic config with shardID as filter
type IntPropertyFnWithTaskQueueInfoFilters ¶
type IntPropertyFnWithTaskQueueInfoFilters func(namespace string, taskQueue string, taskType enumspb.TaskQueueType) int
IntPropertyFnWithTaskQueueInfoFilters is a wrapper to get int property from dynamic config with three filters: namespace, taskQueue, taskType
type MapPropertyFn ¶
type MapPropertyFn func(opts ...FilterOption) map[string]interface{}
MapPropertyFn is a wrapper to get map property from dynamic config
type MapPropertyFnWithNamespaceFilter ¶
MapPropertyFnWithNamespaceFilter is a wrapper to get map property from dynamic config
type MockClient ¶
type MockClient struct {
// contains filtered or unexported fields
}
MockClient is a mock of Client interface.
func NewMockClient ¶
func NewMockClient(ctrl *gomock.Controller) *MockClient
NewMockClient creates a new mock instance.
func (*MockClient) EXPECT ¶
func (m *MockClient) EXPECT() *MockClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClient) GetBoolValue ¶
func (m *MockClient) GetBoolValue(name Key, filters []map[Filter]interface{}, defaultValue bool) (bool, error)
GetBoolValue mocks base method.
func (*MockClient) GetDurationValue ¶
func (m *MockClient) GetDurationValue(name Key, filters []map[Filter]interface{}, defaultValue time.Duration) (time.Duration, error)
GetDurationValue mocks base method.
func (*MockClient) GetFloatValue ¶
func (m *MockClient) GetFloatValue(name Key, filters []map[Filter]interface{}, defaultValue float64) (float64, error)
GetFloatValue mocks base method.
func (*MockClient) GetIntValue ¶
func (m *MockClient) GetIntValue(name Key, filters []map[Filter]interface{}, defaultValue int) (int, error)
GetIntValue mocks base method.
func (*MockClient) GetMapValue ¶
func (m *MockClient) GetMapValue(name Key, filters []map[Filter]interface{}, defaultValue map[string]interface{}) (map[string]interface{}, error)
GetMapValue mocks base method.
func (*MockClient) GetStringValue ¶
func (m *MockClient) GetStringValue(name Key, filters []map[Filter]interface{}, defaultValue string) (string, error)
GetStringValue mocks base method.
func (*MockClient) GetValue ¶
func (m *MockClient) GetValue(name Key, defaultValue interface{}) (interface{}, error)
GetValue mocks base method.
func (*MockClient) GetValueWithFilters ¶
func (m *MockClient) GetValueWithFilters(name Key, filters []map[Filter]interface{}, defaultValue interface{}) (interface{}, error)
GetValueWithFilters mocks base method.
type MockClientMockRecorder ¶
type MockClientMockRecorder struct {
// contains filtered or unexported fields
}
MockClientMockRecorder is the mock recorder for MockClient.
func (*MockClientMockRecorder) GetBoolValue ¶
func (mr *MockClientMockRecorder) GetBoolValue(name, filters, defaultValue interface{}) *gomock.Call
GetBoolValue indicates an expected call of GetBoolValue.
func (*MockClientMockRecorder) GetDurationValue ¶
func (mr *MockClientMockRecorder) GetDurationValue(name, filters, defaultValue interface{}) *gomock.Call
GetDurationValue indicates an expected call of GetDurationValue.
func (*MockClientMockRecorder) GetFloatValue ¶
func (mr *MockClientMockRecorder) GetFloatValue(name, filters, defaultValue interface{}) *gomock.Call
GetFloatValue indicates an expected call of GetFloatValue.
func (*MockClientMockRecorder) GetIntValue ¶
func (mr *MockClientMockRecorder) GetIntValue(name, filters, defaultValue interface{}) *gomock.Call
GetIntValue indicates an expected call of GetIntValue.
func (*MockClientMockRecorder) GetMapValue ¶
func (mr *MockClientMockRecorder) GetMapValue(name, filters, defaultValue interface{}) *gomock.Call
GetMapValue indicates an expected call of GetMapValue.
func (*MockClientMockRecorder) GetStringValue ¶
func (mr *MockClientMockRecorder) GetStringValue(name, filters, defaultValue interface{}) *gomock.Call
GetStringValue indicates an expected call of GetStringValue.
func (*MockClientMockRecorder) GetValue ¶
func (mr *MockClientMockRecorder) GetValue(name, defaultValue interface{}) *gomock.Call
GetValue indicates an expected call of GetValue.
func (*MockClientMockRecorder) GetValueWithFilters ¶
func (mr *MockClientMockRecorder) GetValueWithFilters(name, filters, defaultValue interface{}) *gomock.Call
GetValueWithFilters indicates an expected call of GetValueWithFilters.
type MockfileReader ¶ added in v1.16.0
type MockfileReader struct {
// contains filtered or unexported fields
}
MockfileReader is a mock of fileReader interface.
func NewMockfileReader ¶ added in v1.16.0
func NewMockfileReader(ctrl *gomock.Controller) *MockfileReader
NewMockfileReader creates a new mock instance.
func (*MockfileReader) EXPECT ¶ added in v1.16.0
func (m *MockfileReader) EXPECT() *MockfileReaderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockfileReaderMockRecorder ¶ added in v1.16.0
type MockfileReaderMockRecorder struct {
// contains filtered or unexported fields
}
MockfileReaderMockRecorder is the mock recorder for MockfileReader.
func (*MockfileReaderMockRecorder) ReadFile ¶ added in v1.16.0
func (mr *MockfileReaderMockRecorder) ReadFile(src interface{}) *gomock.Call
ReadFile indicates an expected call of ReadFile.
func (*MockfileReaderMockRecorder) Stat ¶ added in v1.16.0
func (mr *MockfileReaderMockRecorder) Stat(src interface{}) *gomock.Call
Stat indicates an expected call of Stat.
type MutableEphemeralClient ¶ added in v1.12.0
type MutableEphemeralClient struct {
// contains filtered or unexported fields
}
MutableEphemeralClient is a dynamicconfig.Client implementation that is safely mutable in the presence of an unbounded number of reads and writes. Writers block other writers but not readers. Readers don't block anything. Mutations are batched to the Update function. Data written to objects of this type is not made durable.
func NewMutableEphemeralClient ¶ added in v1.12.0
func NewMutableEphemeralClient(mutations ...Mutation) *MutableEphemeralClient
NewMutableEphemeralClient constructs a new MutableEphemeralClient with an empty internal store.
func (*MutableEphemeralClient) Add ¶ added in v1.12.0
func (c *MutableEphemeralClient) Add( k Key, v interface{}, mcs ...MutationConstraint, )
Set adds a value to the set of configured values for a given key.
func (MutableEphemeralClient) GetBoolValue ¶ added in v1.12.0
func (MutableEphemeralClient) GetDurationValue ¶ added in v1.12.0
func (MutableEphemeralClient) GetFloatValue ¶ added in v1.12.0
func (MutableEphemeralClient) GetIntValue ¶ added in v1.12.0
func (MutableEphemeralClient) GetMapValue ¶ added in v1.12.0
func (MutableEphemeralClient) GetStringValue ¶ added in v1.12.0
func (MutableEphemeralClient) GetValueWithFilters ¶ added in v1.12.0
func (*MutableEphemeralClient) MAdd ¶ added in v1.12.0
func (c *MutableEphemeralClient) MAdd( kvs map[Key]interface{}, mcs ...MutationConstraint, )
MSet appends to multiple keys atomically. The supplied MutationConstraints are applied to each of the resulting configuration values.
func (*MutableEphemeralClient) MSet ¶ added in v1.12.0
func (c *MutableEphemeralClient) MSet( kvs map[Key]interface{}, mcs ...MutationConstraint, )
MSet assigns to multiple keys atomically. The supplied MutationConstraints are applied to each of the resulting configuration values.
func (*MutableEphemeralClient) Set ¶ added in v1.12.0
func (c *MutableEphemeralClient) Set( k Key, v interface{}, mcs ...MutationConstraint, )
Set assigns a single configuration value, overwriting any existing values.
func (*MutableEphemeralClient) Update ¶ added in v1.12.0
func (c *MutableEphemeralClient) Update(mutations ...Mutation)
Updated applies the provided Mutations to this MutableEphemeralClients underlying non-durable value store.
type Mutation ¶ added in v1.12.0
type Mutation func(configValueMap)
Mutation expresses a modification to a MutableEphemeralClient's internal value store. Mutation functions are applied with MutableEphemeralClient.Update.
func Add ¶ added in v1.12.0
func Add(k Key, v interface{}, constrainers ...MutationConstraint) Mutation
Add appends the supplied value and optional constraints to those already present under the indicated key. If there are no values present for the key this is equivalent to Set.
func Set ¶ added in v1.12.0
func Set(k Key, v interface{}, constrainers ...MutationConstraint) Mutation
Set assigns the supplied value along with optional constraints to the indicated key. Any other additional value (possibly with other constraints) is overwritten.
type MutationConstraint ¶ added in v1.12.0
type MutationConstraint func(map[string]interface{})
MutationConstraint expresses a configuration constraint (namespace, queue name, or queue type) that is an optional part of a Mutation.
func ForNamespace ¶ added in v1.12.0
func ForNamespace(ns string) MutationConstraint
ForNamespaces builds an exact-match namespace MutationConstraint.
func ForTaskQueueName ¶ added in v1.12.0
func ForTaskQueueName(n string) MutationConstraint
ForTaskQueueName builds an exact-match task queue name MutationConstraint.
func ForTaskType ¶ added in v1.12.0
func ForTaskType(t int) MutationConstraint
ForTaskType builds an exact-match task type MutationConstraint.
type PropertyFn ¶
type PropertyFn func() interface{}
PropertyFn is a wrapper to get property from dynamic config
type StringPropertyFn ¶
type StringPropertyFn func(opts ...FilterOption) string
StringPropertyFn is a wrapper to get string property from dynamic config
type StringPropertyFnWithNamespaceFilter ¶
StringPropertyFnWithNamespaceFilter is a wrapper to get string property from dynamic config