dynamicconfig

package

Go to main page

Versions in this module

v1

v1.2.14-prerelease11

Oct 18, 2024

v1.2.14-prerelease10

Oct 16, 2024

v1.2.14-prerelease09

Oct 10, 2024

v1.2.14-prerelease08

Oct 8, 2024

v1.2.14-prerelease07

Oct 8, 2024

v1.2.14-prerelease06

Oct 7, 2024

v1.2.14-prerelease05

Oct 4, 2024

v1.2.14-prerelease04

Oct 2, 2024

v1.2.14-prerelease03

Sep 26, 2024

v1.2.14-prerelease02

Sep 25, 2024

v1.2.14-prerelease01

Sep 12, 2024

v1.2.13

Sep 4, 2024

Changes in this version

type BoolKey

+ const MatchingEnableTasklistGuardAgainstOwnershipShardLoss

type DurationKey

+ const LocalPollWaitTime

+ const LocalTaskWaitTime

v1.2.13-prerelease13

Sep 12, 2024

v1.2.13-prerelease12

Sep 6, 2024

v1.2.13-prerelease11

Sep 4, 2024

v1.2.13-prerelease10

Aug 29, 2024

v1.2.13-prerelease09

Aug 28, 2024

v1.2.13-prerelease08

Aug 27, 2024

v1.2.13-prerelease07

Aug 27, 2024

v1.2.13-prerelease06

Aug 26, 2024

v1.2.13-prerelease05

Aug 22, 2024

v1.2.13-prerelease04

Aug 16, 2024

v1.2.13-prerelease03

Aug 12, 2024

v1.2.13-prerelease02

Aug 9, 2024

v1.2.13-prerelease01

Aug 7, 2024

v1.2.12

Jul 26, 2024

Changes in this version

type Collection

+ func (c *Collection) GetStringPropertyFilteredByRatelimitKey(key StringKey) StringPropertyWithRatelimitKeyFilter

type DurationKey

+ const GlobalRatelimiterUpdateInterval

+ const HistoryGlobalRatelimiterDecayAfter

+ const HistoryGlobalRatelimiterGCAfter

type Filter

+ const RatelimitKey

type FilterOption

+ func RatelimitKeyFilter(key string) FilterOption

type FloatKey

+ const HistoryGlobalRatelimiterNewDataWeight

type StringKey

+ const FrontendGlobalRatelimiterMode

+ type StringPropertyWithRatelimitKeyFilter func(globalRatelimitKey string) string

v1.2.12-prerelease7

Jul 26, 2024

v1.2.12-prerelease6

Jul 25, 2024

v1.2.12-prerelease5

Jul 17, 2024

v1.2.12-prerelease4

Jul 17, 2024

v1.2.12-prerelease3

Jul 10, 2024

v1.2.12-prerelease2

Jun 28, 2024

v1.2.12-prerelease1

Jun 27, 2024

v1.2.11

Jun 21, 2024

Changes in this version

type BoolKey

+ const EnableContextHeaderInVisibility

+ const EnableStrongIdempotencySanityCheck

type IntKey

+ const FrontendFailoverHistoryMaxSize

v1.2.11-prerelease9

Jun 27, 2024

v1.2.11-prerelease8

Jun 27, 2024

v1.2.11-prerelease7

Jun 21, 2024

v1.2.11-prerelease6

Jun 21, 2024

v1.2.11-prerelease5

Jun 13, 2024

v1.2.11-prerelease4

Jun 12, 2024

v1.2.11-prerelease3

Jun 11, 2024

v1.2.11-prerelease2

Jun 3, 2024

v1.2.11-prerelease10

Jun 28, 2024

v1.2.11-prerelease1

May 30, 2024

v1.2.10

May 17, 2024

Changes in this version

type BoolKey

+ const EnableStrongIdempotency

+ const EnableVisibilityDoubleRead

v1.2.10-prerelease7

May 30, 2024

v1.2.10-prerelease6

May 17, 2024

v1.2.10-prerelease5

May 13, 2024

v1.2.10-prerelease4

May 1, 2024

v1.2.10-prerelease3

Apr 29, 2024

v1.2.10-prerelease2

Apr 25, 2024

v1.2.10-prerelease1

Apr 24, 2024

v1.2.9

Apr 12, 2024

Changes in this version

type BoolKey

+ const TestGetBoolPropertyFilteredByDomainIDAndWorkflowIDKey

+ const TestGetBoolPropertyFilteredByDomainKey

+ const WorkflowIDExternalRateLimitEnabled

+ const WorkflowIDInternalRateLimitEnabled

type DurationKey

+ const TestGetDurationPropertyFilteredByDomainIDKey

+ const TestGetDurationPropertyFilteredByShardID

+ const TestGetDurationPropertyFilteredByWorkflowTypeKey

type FloatKey

+ const TestGetFloat64PropertyFilteredByShardIDKey

type IntKey

+ const DeleteHistoryEventContextTimeout

+ const TestGetIntPropertyFilteredByShardIDKey

+ const TestGetIntPropertyFilteredByWorkflowTypeKey

v1.2.9-prerelease7

Apr 29, 2024

v1.2.9-prerelease6

Apr 25, 2024

v1.2.9-prerelease5

Apr 24, 2024

v1.2.9-prerelease4

Apr 12, 2024

v1.2.9-prerelease3

Apr 9, 2024

v1.2.9-prerelease2

Mar 27, 2024

v1.2.9-prerelease1

Mar 19, 2024

v1.2.8

Mar 1, 2024

Changes in this version

type BoolKey

+ const EnableAsyncWorkflowConsumption

+ const EnableRetryForChecksumFailure

+ const EnableTaskVal

+ const WorkflowIDCacheExternalEnabled

+ const WorkflowIDCacheInternalEnabled

type IntKey

+ const FrontendAsyncRPS

+ const FrontendGlobalDomainAsyncRPS

+ const FrontendMaxDomainAsyncRPSPerInstance

v1.2.8-prerelease9

Mar 19, 2024

v1.2.8-prerelease8

Mar 1, 2024

v1.2.8-prerelease7

Feb 26, 2024

v1.2.8-prerelease6

Feb 22, 2024

v1.2.8-prerelease5

Feb 15, 2024

v1.2.8-prerelease4

Feb 12, 2024

v1.2.8-prerelease3

Feb 8, 2024

v1.2.8-prerelease2

Feb 5, 2024

v1.2.8-prerelease1

Jan 30, 2024

v1.2.7

Jan 23, 2024

Changes in this version

type BoolKey

+ const EnableCrossClusterEngine

+ const EnableCrossClusterOperationsForDomain

+ const EnableTimerDebugLogByDomainID

+ const QueueProcessorEnableGracefulSyncShutdown

+ const ReplicationTaskFetcherEnableGracefulSyncShutdown

+ const WorkflowIDCacheEnabled

type IntKey

+ const WorkflowIDExternalRPS

+ const WorkflowIDInternalRPS

v1.2.7-prerelease7

Feb 8, 2024

v1.2.7-prerelease6

Feb 5, 2024

v1.2.7-prerelease5

Jan 30, 2024

v1.2.7-prerelease4

Jan 30, 2024

v1.2.7-prerelease3

Jan 23, 2024

v1.2.7-prerelease2

Dec 11, 2023

v1.2.7-prerelease1

Dec 8, 2023

v1.2.6

Dec 6, 2023

Changes in this version

type BoolKey

+ const EnableLogCustomerQueryParameter

v1.2.6-prerelease5

Dec 11, 2023

v1.2.6-prerelease4

Dec 8, 2023

v1.2.6-prerelease3

Dec 6, 2023

v1.2.6-prerelease2

Nov 15, 2023

v1.2.6-prerelease1

Nov 6, 2023

v1.2.5

Oct 19, 2023

Changes in this version

type BoolKey

+ const ConcreteExecutionsFixerInvariantCollectionHistory

+ const ConcreteExecutionsFixerInvariantCollectionMutableState

+ const ConcreteExecutionsFixerInvariantCollectionStale

+ const ConcreteExecutionsScannerInvariantCollectionStale

+ const EnableReadVisibilityFromPinot

v1.2.5-prerelease3

Oct 19, 2023

v1.2.5-prerelease2

Oct 18, 2023

v1.2.5-prerelease1

Oct 3, 2023

v1.2.4

Sep 27, 2023

v1.2.3

Sep 15, 2023

retracted

v1.2.2

Aug 30, 2023

v1.2.1

Aug 28, 2023

Changes in this version

+ func ToGetDynamicConfigFilterRequest(configName string, filters []FilterOption) *types.GetDynamicConfigRequest

type BoolKey

+ const EnableShardIDMetrics

+ const EnableTasklistIsolation

+ func (k BoolKey) Filters() []Filter

type DurationKey

+ const AsyncTaskDispatchTimeout

+ const IsolationGroupStateFetchTimeout

+ const IsolationGroupStateRefreshInterval

+ const IsolationGroupStateUpdateTimeout

+ func (k DurationKey) Filters() []Filter

type DynamicBool

+ Filters []Filter

type DynamicDuration

+ Filters []Filter

type DynamicFloat

+ Filters []Filter

type DynamicInt

+ Filters []Filter

type DynamicList

+ Filters []Filter

type DynamicMap

+ Filters []Filter

type DynamicString

+ Filters []Filter

type FloatKey

+ func (k FloatKey) Filters() []Filter

type IntKey

+ const IsolationGroupStateUpdateRetryAttempts

+ const LargeShardHistoryBlobMetricThreshold

+ const LargeShardHistoryEventMetricThreshold

+ const LargeShardHistorySizeMetricThreshold

+ func (k IntKey) Filters() []Filter

type Key

+ Filters func() []Filter

type ListKey

+ const AllIsolationGroups

+ const DefaultIsolationGroupConfigStoreManagerGlobalMapping

+ func (k ListKey) Filters() []Filter

type MapKey

+ func (k MapKey) Filters() []Filter

type StringKey

+ func (k StringKey) Filters() []Filter

v1.0.0

Mar 17, 2023

Changes in this version

+ const ConfigStoreClient

+ const FileBasedClient

+ const InMemoryClient

+ const NopClient

+ var ListKeys = map[ListKey]DynamicList

+ func GetAllKeys() map[string]Key

type BoolKey

+ const EnableQueryAttributeValidation

+ const UseNewInitialFailoverVersion

type Client

+ GetListValue func(name ListKey, filters map[Filter]interface{}) ([]interface{}, error)

type Collection

+ func (c *Collection) GetListProperty(key ListKey) ListPropertyFn

+ type DynamicList struct

+ DefaultValue []interface{}

+ Description string

+ KeyName string

type IntKey

+ const SampleLoggingRate

+ type ListKey int

+ const HeaderForwardingRules

+ const LastListKey

+ const TestGetListPropertyKey

+ const UnknownListKey

+ func (k ListKey) DefaultList() []interface{}

+ func (k ListKey) DefaultValue() interface{}

+ func (k ListKey) Description() string

+ func (k ListKey) String() string

+ type ListPropertyFn func(opts ...FilterOption) []interface

type MockClient

+ func (m *MockClient) GetListValue(name ListKey, filters map[Filter]interface{}) ([]interface{}, error)

type MockClientMockRecorder

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

type StringKey

+ const ESAnalyzerWorkflowTypeMetricDomains

+ const ESAnalyzerWorkflowVersionMetricDomains

v0

v0.25.0

Oct 12, 2022

Changes in this version

+ var BoolKeys = map[BoolKey]DynamicBool

+ var DurationKeys = map[DurationKey]DynamicDuration

+ var FloatKeys = map[FloatKey]DynamicFloat

+ var IntKeys = map[IntKey]DynamicInt

+ var MapKeys = map[MapKey]DynamicMap

+ var StringKeys = map[StringKey]DynamicString

+ func ValidateKeyValuePair(key Key, value interface{}) error

+ type BoolKey int

+ const ESAnalyzerEnableAvgDurationBasedChecks

+ const EnableCassandraAllConsistencyLevelDelete

+ const EnablePendingActivityValidation

+ const EnableRecordWorkflowExecutionUninitialized

+ const EnableSQLAsyncTransaction

+ const LastBoolKey

+ const Lockdown

+ const UnknownBoolKey

+ func (k BoolKey) DefaultBool() bool

+ func (k BoolKey) DefaultValue() interface{}

+ func (k BoolKey) Description() string

+ func (k BoolKey) String() string

+ type DurationKey int

+ const LastDurationKey

+ const UnknownDurationKey

+ func (k DurationKey) DefaultDuration() time.Duration

+ func (k DurationKey) DefaultValue() interface{}

+ func (k DurationKey) Description() string

+ func (k DurationKey) String() string

+ type DynamicBool struct

+ DefaultValue bool

+ Description string

+ KeyName string

+ type DynamicDuration struct

+ DefaultValue time.Duration

+ Description string

+ KeyName string

+ type DynamicFloat struct

+ DefaultValue float64

+ Description string

+ KeyName string

+ type DynamicInt struct

+ DefaultValue int

+ Description string

+ KeyName string

+ type DynamicMap struct

+ DefaultValue map[string]interface{}

+ Description string

+ KeyName string

+ type DynamicString struct

+ DefaultValue string

+ Description string

+ KeyName string

+ type FloatKey int

+ const LastFloatKey

+ const UnknownFloatKey

+ func (k FloatKey) DefaultFloat() float64

+ func (k FloatKey) DefaultValue() interface{}

+ func (k FloatKey) Description() string

+ func (k FloatKey) String() string

+ type IntKey int

+ const FrontendGlobalDomainVisibilityRPS

+ const FrontendMaxDomainVisibilityRPSPerInstance

+ const FrontendVisibilityRPS

+ const LastIntKey

+ const PendingActivitiesCountLimitError

+ const PendingActivitiesCountLimitWarn

+ const ReplicatorCacheCapacity

+ const UnknownIntKey

+ const WorkflowDeletionJitterRange

+ func (k IntKey) DefaultInt() int

+ func (k IntKey) DefaultValue() interface{}

+ func (k IntKey) Description() string

+ func (k IntKey) String() string

type Key

+ func GetKeyFromKeyName(keyName string) (Key, error)

+ func ListAllProductionKeys() []Key

+ DefaultValue func() interface{}

+ Description func() string

+ type MapKey int

+ const LastMapKey

+ const UnknownMapKey

+ func (k MapKey) DefaultMap() map[string]interface{}

+ func (k MapKey) DefaultValue() interface{}

+ func (k MapKey) Description() string

+ func (k MapKey) String() string

+ type StringKey int

+ const LastStringKey

+ const UnknownStringKey

+ func (k StringKey) DefaultString() string

+ func (k StringKey) DefaultValue() interface{}

+ func (k StringKey) Description() string

+ func (k StringKey) String() string

v0.24.0

May 24, 2022

Changes in this version

+ const UnlimitedRPS

+ func GetDurationPropertyFilteredByWorkflowType(value time.Duration) func(domainName string, workflowType string) time.Duration

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

+ func GetIntPropertyFilteredByShardID(value int) func(shardID int) int

+ func GetIntPropertyFilteredByWorkflowType(value int) func(domainName string, workflowType string) int

+ type BoolPropertyFnWithDomainIDAndWorkflowIDFilter func(domainID string, workflowID string) bool

type Collection

+ func (c *Collection) GetBoolPropertyFilteredByDomainIDAndWorkflowID(key Key, defaultValue bool) BoolPropertyFnWithDomainIDAndWorkflowIDFilter

+ func (c *Collection) GetDurationPropertyFilteredByWorkflowType(key Key, defaultValue time.Duration) DurationPropertyFnWithWorkflowTypeFilter

+ func (c *Collection) GetIntPropertyFilteredByWorkflowType(key Key, defaultValue int) IntPropertyFnWithWorkflowTypeFilter

+ type DurationPropertyFnWithWorkflowTypeFilter func(domainName string, workflowType string) time.Duration

type Filter

+ const WorkflowID

+ const WorkflowType

type FilterOption

+ func WorkflowIDFilter(workflowID string) FilterOption

+ func WorkflowTypeFilter(name string) FilterOption

type FloatPropertyFn

+ func (f FloatPropertyFn) AsFloat64(opts ...FilterOption) func() float64

type IntPropertyFn

+ func (f IntPropertyFn) AsFloat64(opts ...FilterOption) func() float64

type IntPropertyFnWithDomainFilter

+ func (f IntPropertyFnWithDomainFilter) AsFloat64(domain string) func() float64

+ type IntPropertyFnWithWorkflowTypeFilter func(domainName string, workflowType string) int

type Key

+ const ArchiveInlineHistoryGlobalRPS

+ const ArchiveInlineHistoryRPS

+ const ArchiveInlineVisibilityGlobalRPS

+ const ArchiveInlineVisibilityRPS

+ const CorruptWorkflowWatchdogPause

+ const CrossClusterFetcherAggregationInterval

+ const CrossClusterFetcherErrorBackoffInterval

+ const CrossClusterFetcherJitterCoefficient

+ const CrossClusterFetcherParallelism

+ const CrossClusterFetcherServiceBusyBackoffInterval

+ const CrossClusterSourceProcessorCompleteTaskFailureRetryCount

+ const CrossClusterSourceProcessorMaxPendingTaskSize

+ const CrossClusterSourceProcessorMaxPollInterval

+ const CrossClusterSourceProcessorMaxPollIntervalJitterCoefficient

+ const CrossClusterSourceProcessorMaxPollRPS

+ const CrossClusterSourceProcessorMaxRedispatchQueueSize

+ const CrossClusterSourceProcessorUpdateAckInterval

+ const CrossClusterSourceProcessorUpdateAckIntervalJitterCoefficient

+ const CrossClusterTargetProcessorJitterCoefficient

+ const CrossClusterTargetProcessorMaxPendingTasks

+ const CrossClusterTargetProcessorMaxRetryCount

+ const CrossClusterTargetProcessorServiceBusyBackoffInterval

+ const CrossClusterTargetProcessorTaskWaitInterval

+ const CrossClusterTaskFetchBatchSize

+ const DecisionRetryMaxAttempts

+ const ESAnalyzerBufferWaitTime

+ const ESAnalyzerLimitToDomains

+ const ESAnalyzerLimitToTypes

+ const ESAnalyzerMaxNumDomains

+ const ESAnalyzerMaxNumWorkflowTypes

+ const ESAnalyzerMinNumWorkflowsForAvg

+ const ESAnalyzerNumWorkflowsToRefresh

+ const ESAnalyzerPause

+ const ESAnalyzerTimeWindow

+ const ESAnalyzerWorkflowDurationWarnThresholds

+ const EnableCrossClusterOperations

+ const EnableESAnalyzer

+ const EnableHistoryCorruptionCheck

+ const EnableReplicationTaskGeneration

+ const EnableWatchDog

+ const FrontendGlobalDomainUserRPS

+ const FrontendGlobalDomainWorkerRPS

+ const FrontendMaxDomainUserRPSPerInstance

+ const FrontendMaxDomainWorkerRPSPerInstance

+ const FrontendUserRPS

+ const FrontendWorkerRPS

+ const MatchingActivityTaskSyncMatchWaitTime

+ const MatchingDomainUserRPS

+ const MatchingDomainWorkerRPS

+ const MatchingUserRPS

+ const MatchingWorkerRPS

+ const MaxActivityCountDispatchByDomain

+ const TimerProcessorFailoverMaxStartJitterInterval

+ const TransferProcessorFailoverMaxStartJitterInterval

v0.23.2

Dec 2, 2021

v0.23.1

Nov 18, 2021

Changes in this version

+ const DynamicConfigConfigStoreClient

+ const DynamicConfigFileBasedClient

+ const DynamicConfigInMemoryClient

+ const DynamicConfigNopClient

+ var KeyNames map[string]Key

+ var Keys = map[Key]string

+ var NotFoundError = &types.EntityNotExistsError

+ func GetBoolPropertyFnFilteredByDomainID(value bool) func(domainID string) bool

type Client

+ ListValue func(name Key) ([]*types.DynamicConfigEntry, error)

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

type Filter

+ const LastFilterTypeForTest

+ const UnknownFilter

+ func ParseFilter(filterName string) Filter

type Key

+ const CrossClusterProcessorCompleteTaskFailureRetryCount

+ const CrossClusterProcessorCompleteTaskInterval

+ const CrossClusterProcessorEnableValidator

+ const CrossClusterProcessorMaxPollInterval

+ const CrossClusterProcessorMaxPollIntervalJitterCoefficient

+ const CrossClusterProcessorMaxPollRPS

+ const CrossClusterProcessorMaxRedispatchQueueSize

+ const CrossClusterProcessorSplitQueueInterval

+ const CrossClusterProcessorSplitQueueIntervalJitterCoefficient

+ const CrossClusterProcessorUpdateAckInterval

+ const CrossClusterProcessorUpdateAckIntervalJitterCoefficient

+ const CrossClusterProcessorValidationInterval

+ const CrossClusterProcessorValidationIntervalJitterCoefficient

+ const CrossClusterTaskBatchSize

+ const CrossClusterTaskDeleteBatchSize

+ const CrossClusterTaskWorkerCount

+ const EnableServiceAuthorization

+ const EnableServiceAuthorizationLogOnly

+ const FrontendDecisionResultCountLimit

+ const FrontendEmitSignalNameMetricsTag

+ const GRPCMaxSizeInByte

+ const LastKeyForTest

+ const NormalDecisionScheduleToStartMaxAttempts

+ const NormalDecisionScheduleToStartTimeout

+ const ReplicatorTaskDeleteBatchSize

+ const ReplicatorUpperLatency

+ const ResurrectionCheckMinDelay

+ const TaskCriticalRetryCount

+ const TestGetBoolPropertyFilteredByDomainIDKey

+ const TestGetBoolPropertyFilteredByTaskListInfoKey

+ const TestGetBoolPropertyKey

+ const TestGetDurationPropertyFilteredByDomainKey

+ const TestGetDurationPropertyFilteredByTaskListInfoKey

+ const TestGetDurationPropertyKey

+ const TestGetFloat64PropertyKey

+ const TestGetIntPropertyFilteredByDomainKey

+ const TestGetIntPropertyFilteredByTaskListInfoKey

+ const TestGetIntPropertyKey

+ const TestGetMapPropertyKey

+ const TestGetPropertyKey

+ const TestGetStringPropertyKey

+ const TimerTaskDeleteBatchSize

+ const TransferTaskDeleteBatchSize

+ const UnknownKey

type MockClient

+ func (m *MockClient) ListValue(name Key) ([]*types.DynamicConfigEntry, error)

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

type MockClientMockRecorder

+ func (mr *MockClientMockRecorder) ListValue(name interface{}) *gomock.Call

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

v0.22.4

Nov 11, 2021

v0.22.3

Oct 14, 2021

Changes in this version

type Key

+ const AllowArchivingIncompleteHistory

v0.22.2

Oct 8, 2021

v0.22.1

Oct 8, 2021

v0.22.0

Aug 20, 2021

v0.21.3

Jun 17, 2021

v0.21.2

Jun 1, 2021

Changes in this version

type Key

+ const ActivityIDMaxLength

+ const ActivityTypeMaxLength

+ const DomainNameMaxLength

+ const IdentityMaxLength

+ const MarkerNameMaxLength

+ const RequestIDMaxLength

+ const SignalNameMaxLength

+ const TaskListNameMaxLength

+ const TimerIDMaxLength

+ const WorkflowIDMaxLength

+ const WorkflowTypeMaxLength

v0.21.0

May 6, 2021

Changes in this version

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

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

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

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

+ func GetDurationPropertyFnFilteredByTShardID(value time.Duration) func(shardID int) 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 GetIntPropertyFilteredByDomain(value int) func(domain string) int

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

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

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

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

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

+ type BoolPropertyFnWithDomainFilter func(domain string) bool

+ type BoolPropertyFnWithDomainIDFilter func(domainID string) bool

+ type BoolPropertyFnWithTaskListInfoFilters func(domain string, taskList string, taskType int) 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)

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

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

+ func NewInMemoryClient() Client

+ func NewNopClient() Client

+ type Collection struct

+ func NewCollection(client Client, logger log.Logger, filterOptions ...FilterOption) *Collection

+ func NewNopCollection() *Collection

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type DurationPropertyFnWithDomainFilter func(domain string) time.Duration

+ type DurationPropertyFnWithDomainIDFilter func(domainID string) time.Duration

+ type DurationPropertyFnWithShardIDFilter func(shardID int) time.Duration

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

+ type FileBasedClientConfig struct

+ Filepath string

+ PollInterval time.Duration

+ type Filter int

+ const ClusterName

+ const DomainID

+ const DomainName

+ const ShardID

+ const TaskListName

+ const TaskType

+ func (f Filter) String() string

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

+ func ClusterNameFilter(clusterName string) FilterOption

+ func DomainFilter(name string) FilterOption

+ func DomainIDFilter(domainID string) FilterOption

+ func ShardIDFilter(shardID int) FilterOption

+ func TaskListFilter(name string) FilterOption

+ func TaskTypeFilter(taskType int) FilterOption

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

+ type FloatPropertyFnWithShardIDFilter func(shardID int) float64

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

+ type IntPropertyFnWithDomainFilter func(domain string) int

+ type IntPropertyFnWithShardIDFilter func(shardID int) int

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

+ type Key int

+ const AcquireShardConcurrency

+ const AcquireShardInterval

+ const ActiveTaskRedispatchInterval

+ const ActivityMaxScheduleToStartTimeoutForRetry

+ const AdminErrorInjectionRate

+ const AdminOperationToken

+ const AdvancedVisibilityWritingMode

+ const ArchiveRequestRPS

+ const BlobSizeLimitError

+ const BlobSizeLimitWarn

+ const ConcreteExecutionFixerDomainAllow

+ const ConcreteExecutionFixerEnabled

+ const ConcreteExecutionsScannerActivityBatchSize

+ const ConcreteExecutionsScannerBlobstoreFlushThreshold

+ const ConcreteExecutionsScannerConcurrency

+ const ConcreteExecutionsScannerEnabled

+ const ConcreteExecutionsScannerInvariantCollectionHistory

+ const ConcreteExecutionsScannerInvariantCollectionMutableState

+ const ConcreteExecutionsScannerPersistencePageSize

+ const CurrentExecutionFixerDomainAllow

+ const CurrentExecutionFixerEnabled

+ const CurrentExecutionsScannerActivityBatchSize

+ const CurrentExecutionsScannerBlobstoreFlushThreshold

+ const CurrentExecutionsScannerConcurrency

+ const CurrentExecutionsScannerEnabled

+ const CurrentExecutionsScannerInvariantCollectionHistory

+ const CurrentExecutionsScannerInvariantCollectionMutableState

+ const CurrentExecutionsScannerPersistencePageSize

+ const DecisionHeartbeatTimeout

+ const DecisionRetryCriticalAttempts

+ const DefaultEventEncoding

+ const DisableListVisibilityByFilter

+ const DisallowQuery

+ const DomainFailoverRefreshInterval

+ const DomainFailoverRefreshTimerJitterCoefficient

+ const EmitShardDiffLog

+ const EnableActivityLocalDispatchByDomain

+ const EnableAdminProtection

+ const EnableArchivalCompression

+ const EnableAuthorization

+ const EnableBatcher

+ const EnableCleaningOrphanTaskInTasklistScavenger

+ const EnableClientVersionCheck

+ const EnableConsistentQuery

+ const EnableConsistentQueryByDomain

+ const EnableDebugMode

+ const EnableDomainNotActiveAutoForwarding

+ const EnableDropStuckTaskByDomainID

+ const EnableFailoverManager

+ const EnableGRPCOutbound

+ const EnableGlobalDomain

+ const EnableGracefulFailover

+ const EnableParentClosePolicy

+ const EnableParentClosePolicyWorker

+ const EnableReadFromClosedExecutionV2

+ const EnableReadFromHistoryArchival

+ const EnableReadFromVisibilityArchival

+ const EnableReadVisibilityFromES

+ const EnableStickyQuery

+ const EnableVisibilitySampling

+ const EnableWorkflowShadower

+ const EventsCacheGlobalEnable

+ const EventsCacheGlobalInitialCount

+ const EventsCacheGlobalMaxCount

+ const EventsCacheInitialCount

+ const EventsCacheMaxCount

+ const EventsCacheMaxSize

+ const EventsCacheTTL

+ const ExecutionMgrNumConns

+ const FrontendESIndexMaxResultWindow

+ const FrontendESVisibilityListMaxQPS

+ const FrontendErrorInjectionRate

+ const FrontendFailoverCoolDown

+ const FrontendGlobalDomainRPS

+ const FrontendHistoryMaxPageSize

+ const FrontendHistoryMgrNumConns

+ const FrontendMaxBadBinaries

+ const FrontendMaxDomainRPSPerInstance

+ const FrontendPersistenceGlobalMaxQPS

+ const FrontendPersistenceMaxQPS

+ const FrontendRPS

+ const FrontendShutdownDrainDuration

+ const FrontendThrottledLogRPS

+ const FrontendVisibilityListMaxQPS

+ const FrontendVisibilityMaxPageSize

+ const HistoryArchivalStatus

+ const HistoryCacheInitialSize

+ const HistoryCacheMaxSize

+ const HistoryCacheTTL

+ const HistoryCountLimitError

+ const HistoryCountLimitWarn

+ const HistoryEnableTaskInfoLogByDomainID

+ const HistoryErrorInjectionRate

+ const HistoryLongPollExpirationInterval

+ const HistoryMaxAutoResetPoints

+ const HistoryMgrNumConns

+ const HistoryPersistenceGlobalMaxQPS

+ const HistoryPersistenceMaxQPS

+ const HistoryRPS

+ const HistoryScannerEnabled

+ const HistoryShutdownDrainDuration

+ const HistorySizeLimitError

+ const HistorySizeLimitWarn

+ const HistoryThrottledLogRPS

+ const HistoryVisibilityClosedMaxQPS

+ const HistoryVisibilityOpenMaxQPS

+ const MatchingEnableSyncMatch

+ const MatchingEnableTaskInfoLogByDomainID

+ const MatchingErrorInjectionRate

+ const MatchingForwarderMaxChildrenPerNode

+ const MatchingForwarderMaxOutstandingPolls

+ const MatchingForwarderMaxOutstandingTasks

+ const MatchingForwarderMaxRatePerSecond

+ const MatchingGetTasksBatchSize

+ const MatchingIdleTasklistCheckInterval

+ const MatchingLongPollExpirationInterval

+ const MatchingMaxTaskBatchSize

+ const MatchingMaxTaskDeleteBatchSize

+ const MatchingMinTaskThrottlingBurstSize

+ const MatchingNumTasklistReadPartitions

+ const MatchingNumTasklistWritePartitions

+ const MatchingOutstandingTaskAppendsThreshold

+ const MatchingPersistenceGlobalMaxQPS

+ const MatchingPersistenceMaxQPS

+ const MatchingRPS

+ const MatchingShutdownDrainDuration

+ const MatchingThrottledLogRPS

+ const MatchingUpdateAckInterval

+ const MaxBufferedQueryCount

+ const MaxDecisionStartToCloseSeconds

+ const MaxIDLengthLimit

+ const MaxIDLengthWarnLimit

+ const MaxRawTaskListNameLimit

+ const MaxRetentionDays

+ const MaxTasklistIdleTime

+ const MaximumBufferedEventsBatch

+ const MaximumSignalsPerExecution

+ const MinRetentionDays

+ const MutableStateChecksumGenProbability

+ const MutableStateChecksumInvalidateBefore

+ const MutableStateChecksumVerifyProbability

+ const NotifyFailoverMarkerInterval

+ const NotifyFailoverMarkerTimerJitterCoefficient

+ const NumArchiveSystemWorkflows

+ const NumParentClosePolicySystemWorkflows

+ const ParentClosePolicyThreshold

+ const PersistenceErrorInjectionRate

+ const QueueProcessorEnableLoadQueueStates

+ const QueueProcessorEnablePendingTaskSplitByDomainID

+ const QueueProcessorEnablePersistQueueStates

+ const QueueProcessorEnableRandomSplitByDomainID

+ const QueueProcessorEnableSplit

+ const QueueProcessorEnableStuckTaskSplitByDomainID

+ const QueueProcessorPendingTaskSplitThreshold

+ const QueueProcessorPollBackoffInterval

+ const QueueProcessorPollBackoffIntervalJitterCoefficient

+ const QueueProcessorRandomSplitProbability

+ const QueueProcessorSplitLookAheadDurationByDomainID

+ const QueueProcessorSplitMaxLevel

+ const QueueProcessorStuckTaskSplitThreshold

+ const ReplicationEventsFromCurrentCluster

+ const ReplicationTaskFetcherAggregationInterval

+ const ReplicationTaskFetcherErrorRetryWait

+ const ReplicationTaskFetcherParallelism

+ const ReplicationTaskFetcherServiceBusyWait

+ const ReplicationTaskFetcherTimerJitterCoefficient

+ const ReplicationTaskGenerationQPS

+ const ReplicationTaskProcessorCleanupInterval

+ const ReplicationTaskProcessorCleanupJitterCoefficient

+ const ReplicationTaskProcessorErrorRetryMaxAttempts

+ const ReplicationTaskProcessorErrorRetryWait

+ const ReplicationTaskProcessorErrorSecondRetryExpiration

+ const ReplicationTaskProcessorErrorSecondRetryMaxWait

+ const ReplicationTaskProcessorErrorSecondRetryWait

+ const ReplicationTaskProcessorHostQPS

+ const ReplicationTaskProcessorNoTaskInitialWait

+ const ReplicationTaskProcessorReadHistoryBatchSize

+ const ReplicationTaskProcessorShardQPS

+ const ReplicationTaskProcessorStartWait

+ const ReplicationTaskProcessorStartWaitJitterCoefficient

+ const ReplicatorProcessorEnablePriorityTaskProcessor

+ const ReplicatorProcessorMaxPollInterval

+ const ReplicatorProcessorMaxPollIntervalJitterCoefficient

+ const ReplicatorProcessorMaxPollRPS

+ const ReplicatorProcessorMaxRedispatchQueueSize

+ const ReplicatorProcessorUpdateAckInterval

+ const ReplicatorProcessorUpdateAckIntervalJitterCoefficient

+ const ReplicatorReadTaskMaxRetryCount

+ const ReplicatorTaskBatchSize

+ const ReplicatorTaskMaxRetryCount

+ const ReplicatorTaskWorkerCount

+ const RequiredDomainDataKeys

+ const ScannerBatchSizeForTasklistHandler

+ const ScannerGetOrphanTasksPageSize

+ const ScannerMaxTasksProcessedPerTasklistJob

+ const ScannerPersistenceMaxQPS

+ const SearchAttributesNumberOfKeysLimit

+ const SearchAttributesSizeOfValueLimit

+ const SearchAttributesTotalSizeLimit

+ const SendRawWorkflowHistory

+ const ShardSyncMinInterval

+ const ShardUpdateMinInterval

+ const StandbyClusterDelay

+ const StandbyTaskMissingEventsDiscardDelay

+ const StandbyTaskMissingEventsResendDelay

+ const StandbyTaskReReplicationContextTimeout

+ const StandbyTaskRedispatchInterval

+ const StickyTTL

+ const TaskListScannerEnabled

+ const TaskProcessRPS

+ const TaskRedispatchIntervalJitterCoefficient

+ const TaskSchedulerDispatcherCount

+ const TaskSchedulerQueueSize

+ const TaskSchedulerRoundRobinWeights

+ const TaskSchedulerShardQueueSize

+ const TaskSchedulerShardWorkerCount

+ const TaskSchedulerType

+ const TaskSchedulerWorkerCount

+ const TimerProcessorArchivalTimeLimit

+ const TimerProcessorCompleteTimerFailureRetryCount

+ const TimerProcessorCompleteTimerInterval

+ const TimerProcessorFailoverMaxPollRPS

+ const TimerProcessorGetFailureRetryCount

+ const TimerProcessorHistoryArchivalSizeLimit

+ const TimerProcessorMaxPollInterval

+ const TimerProcessorMaxPollIntervalJitterCoefficient

+ const TimerProcessorMaxPollRPS

+ const TimerProcessorMaxRedispatchQueueSize

+ const TimerProcessorMaxTimeShift

+ const TimerProcessorSplitQueueInterval

+ const TimerProcessorSplitQueueIntervalJitterCoefficient

+ const TimerProcessorUpdateAckInterval

+ const TimerProcessorUpdateAckIntervalJitterCoefficient

+ const TimerTaskBatchSize

+ const TimerTaskMaxRetryCount

+ const TimerTaskWorkerCount

+ const TimersFixerDomainAllow

+ const TimersFixerEnabled

+ const TimersScannerActivityBatchSize

+ const TimersScannerBlobstoreFlushThreshold

+ const TimersScannerConcurrency

+ const TimersScannerEnabled

+ const TimersScannerPeriodEnd

+ const TimersScannerPeriodStart

+ const TimersScannerPersistencePageSize

+ const TransactionSizeLimit

+ const TransferProcessorCompleteTransferFailureRetryCount

+ const TransferProcessorCompleteTransferInterval

+ const TransferProcessorEnableValidator

+ const TransferProcessorFailoverMaxPollRPS

+ const TransferProcessorMaxPollInterval

+ const TransferProcessorMaxPollIntervalJitterCoefficient

+ const TransferProcessorMaxPollRPS

+ const TransferProcessorMaxRedispatchQueueSize

+ const TransferProcessorSplitQueueInterval

+ const TransferProcessorSplitQueueIntervalJitterCoefficient

+ const TransferProcessorUpdateAckInterval

+ const TransferProcessorUpdateAckIntervalJitterCoefficient

+ const TransferProcessorValidationInterval

+ const TransferProcessorVisibilityArchivalTimeLimit

+ const TransferTaskBatchSize

+ const TransferTaskMaxRetryCount

+ const TransferTaskWorkerCount

+ const ValidSearchAttributes

+ const VisibilityArchivalQueryMaxPageSize

+ const VisibilityArchivalQueryMaxQPS

+ const VisibilityArchivalQueryMaxRangeInDays

+ const VisibilityArchivalStatus

+ const WorkerArchivalsPerIteration

+ const WorkerArchiverConcurrency

+ const WorkerBlobIntegrityCheckProbability

+ const WorkerDeterministicConstructionCheckProbability

+ const WorkerESProcessorBulkActions

+ const WorkerESProcessorBulkSize

+ const WorkerESProcessorFlushInterval

+ const WorkerESProcessorNumOfWorkers

+ const WorkerIndexerConcurrency

+ const WorkerPersistenceGlobalMaxQPS

+ const WorkerPersistenceMaxQPS

+ const WorkerReplicationTaskMaxRetryDuration

+ const WorkerThrottledLogRPS

+ const WorkerTimeLimitPerArchivalIteration

+ func (k Key) String() string

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

+ 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

+ type PropertyFn func() interface

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

+ type StringPropertyFnWithDomainFilter func(domain string) string

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