sampled

Jan 23, 2024

Changes in this version

+ func NewVisibilityManager(persistence persistence.VisibilityManager, p Params) persistence.VisibilityManager

+ type Config struct

+ VisibilityClosedMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter

+ VisibilityListMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter

+ VisibilityOpenMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter

+ type Params struct

+ Config *Config

+ Logger log.Logger

+ MetricClient metrics.Client

+ RateLimiterFactoryFunc RateLimiterFactoryFunc

+ TimeSource clock.TimeSource

+ type RateLimiterFactory interface

+ GetRateLimiter func(domain string) tokenbucket.PriorityTokenBucket

+ func NewDomainToBucketMap(timeSource clock.TimeSource, numOfPriority int, ...) RateLimiterFactory

+ type RateLimiterFactoryFunc func(timeSource clock.TimeSource, numOfPriority int, ...) RateLimiterFactory