config

Documentation

Index

• type Config
  • func NewConfig(dc *dynamicconfig.Collection, hostName string) *Config
• type ForwarderConfig
• type TaskListConfig

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

	// 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
}

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 ForwarderConfig struct {
	ForwarderMaxOutstandingPolls func() int
	ForwarderMaxOutstandingTasks func() int
	ForwarderMaxRatePerSecond    func() int
	ForwarderMaxChildrenPerNode  func() int
}

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
	// 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
}