Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { PersistenceMaxQPS dynamicconfig.IntPropertyFn PersistenceGlobalMaxQPS dynamicconfig.IntPropertyFn EnableSyncMatch dynamicconfig.BoolPropertyFnWithTaskListInfoFilters UserRPS dynamicconfig.IntPropertyFn WorkerRPS dynamicconfig.IntPropertyFn DomainUserRPS dynamicconfig.IntPropertyFnWithDomainFilter DomainWorkerRPS dynamicconfig.IntPropertyFnWithDomainFilter ShutdownDrainDuration dynamicconfig.DurationPropertyFn // taskListManager configuration RangeSize int64 GetTasksBatchSize dynamicconfig.IntPropertyFnWithTaskListInfoFilters UpdateAckInterval dynamicconfig.DurationPropertyFnWithTaskListInfoFilters IdleTasklistCheckInterval dynamicconfig.DurationPropertyFnWithTaskListInfoFilters MaxTasklistIdleTime dynamicconfig.DurationPropertyFnWithTaskListInfoFilters NumTasklistWritePartitions dynamicconfig.IntPropertyFnWithTaskListInfoFilters NumTasklistReadPartitions dynamicconfig.IntPropertyFnWithTaskListInfoFilters ForwarderMaxOutstandingPolls dynamicconfig.IntPropertyFnWithTaskListInfoFilters ForwarderMaxOutstandingTasks dynamicconfig.IntPropertyFnWithTaskListInfoFilters ForwarderMaxRatePerSecond dynamicconfig.IntPropertyFnWithTaskListInfoFilters ForwarderMaxChildrenPerNode dynamicconfig.IntPropertyFnWithTaskListInfoFilters AsyncTaskDispatchTimeout dynamicconfig.DurationPropertyFnWithTaskListInfoFilters LocalPollWaitTime dynamicconfig.DurationPropertyFnWithTaskListInfoFilters LocalTaskWaitTime dynamicconfig.DurationPropertyFnWithTaskListInfoFilters // Time to hold a poll request before returning an empty response if there are no tasks LongPollExpirationInterval dynamicconfig.DurationPropertyFnWithTaskListInfoFilters MinTaskThrottlingBurstSize dynamicconfig.IntPropertyFnWithTaskListInfoFilters MaxTaskDeleteBatchSize dynamicconfig.IntPropertyFnWithTaskListInfoFilters // taskWriter configuration OutstandingTaskAppendsThreshold dynamicconfig.IntPropertyFnWithTaskListInfoFilters MaxTaskBatchSize dynamicconfig.IntPropertyFnWithTaskListInfoFilters ThrottledLogRPS dynamicconfig.IntPropertyFn // debugging configuration EnableDebugMode bool // note that this value is initialized once on service start EnableTaskInfoLogByDomainID dynamicconfig.BoolPropertyFnWithDomainIDFilter ActivityTaskSyncMatchWaitTime dynamicconfig.DurationPropertyFnWithDomainFilter // isolation configuration EnableTasklistIsolation dynamicconfig.BoolPropertyFnWithDomainFilter AllIsolationGroups []string // hostname info HostName string // rate limiter configuration TaskDispatchRPS float64 TaskDispatchRPSTTL time.Duration // task gc configuration MaxTimeBetweenTaskDeletes time.Duration EnableTasklistOwnershipGuard dynamicconfig.BoolPropertyFn }
Config represents configuration for cadence-matching service
func NewConfig ¶
func NewConfig(dc *dynamicconfig.Collection, hostName string) *Config
NewConfig returns new service config with default values
type ForwarderConfig ¶
type TaskListConfig ¶
type TaskListConfig struct { ForwarderConfig EnableSyncMatch func() bool // Time to hold a poll request before returning an empty response if there are no tasks LongPollExpirationInterval func() time.Duration RangeSize int64 ActivityTaskSyncMatchWaitTime dynamicconfig.DurationPropertyFnWithDomainFilter GetTasksBatchSize func() int UpdateAckInterval func() time.Duration IdleTasklistCheckInterval func() time.Duration MaxTasklistIdleTime func() time.Duration MinTaskThrottlingBurstSize func() int MaxTaskDeleteBatchSize func() int AsyncTaskDispatchTimeout func() time.Duration LocalPollWaitTime func() time.Duration LocalTaskWaitTime func() time.Duration // taskWriter configuration OutstandingTaskAppendsThreshold func() int MaxTaskBatchSize func() int NumWritePartitions func() int NumReadPartitions func() int // isolation configuration EnableTasklistIsolation func() bool AllIsolationGroups []string // hostname HostName string // rate limiter configuration TaskDispatchRPS float64 TaskDispatchRPSTTL time.Duration // task gc configuration MaxTimeBetweenTaskDeletes time.Duration }
Click to show internal directories.
Click to hide internal directories.