Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GrpcServerOptionsProvider ¶
func GrpcServerOptionsProvider( params GrpcServerOptionsParams, ) []grpc.ServerOption
func PersistenceMaxQpsFn ¶
func PersistenceMaxQpsFn( maxQps dynamicconfig.IntPropertyFn, globalMaxQps dynamicconfig.IntPropertyFn, ) persistenceClient.PersistenceMaxQps
Types ¶
type GrpcServerOptionsParams ¶ added in v1.22.0
type GrpcServerOptionsParams struct {
fx.In
Logger log.Logger
RpcFactory common.RPCFactory
RetryableInterceptor *interceptor.RetryableInterceptor
TelemetryInterceptor *interceptor.TelemetryInterceptor
RateLimitInterceptor *interceptor.RateLimitInterceptor
TracingInterceptor telemetry.ServerTraceInterceptor
AdditionalInterceptors []grpc.UnaryServerInterceptor `optional:"true"`
}
type PersistenceRateLimitingParams ¶ added in v1.17.2
type PersistenceRateLimitingParams struct {
fx.Out
PersistenceMaxQps persistenceClient.PersistenceMaxQps
PersistenceNamespaceMaxQps persistenceClient.PersistenceNamespaceMaxQps
PersistencePerShardNamespaceMaxQPS persistenceClient.PersistencePerShardNamespaceMaxQPS
EnablePriorityRateLimiting persistenceClient.EnablePriorityRateLimiting
OperatorRPSRatio persistenceClient.OperatorRPSRatio
DynamicRateLimitingParams persistenceClient.DynamicRateLimitingParams
}
func NewPersistenceRateLimitingParams ¶ added in v1.17.2
func NewPersistenceRateLimitingParams( maxQps dynamicconfig.IntPropertyFn, globalMaxQps dynamicconfig.IntPropertyFn, namespaceMaxQps dynamicconfig.IntPropertyFnWithNamespaceFilter, perShardNamespaceMaxQps dynamicconfig.IntPropertyFnWithNamespaceFilter, enablePriorityRateLimiting dynamicconfig.BoolPropertyFn, operatorRPSRatio dynamicconfig.FloatPropertyFn, dynamicRateLimitingParams dynamicconfig.MapPropertyFn, ) PersistenceRateLimitingParams
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package frontend is a generated GoMock package.
|
Package frontend is a generated GoMock package. |
|
Package history is a generated GoMock package.
|
Package history is a generated GoMock package. |
|
archival
Package archival is a generated GoMock package.
|
Package archival is a generated GoMock package. |
|
deletemanager
Package deletemanager is a generated GoMock package.
|
Package deletemanager is a generated GoMock package. |
|
events
Package events is a generated GoMock package.
|
Package events is a generated GoMock package. |
|
ndc
Package ndc is a generated GoMock package.
|
Package ndc is a generated GoMock package. |
|
queues
Package queues is a generated GoMock package.
|
Package queues is a generated GoMock package. |
|
replication
Package replication is a generated GoMock package.
|
Package replication is a generated GoMock package. |
|
shard
Package shard is a generated GoMock package.
|
Package shard is a generated GoMock package. |
|
tasks
Package tasks is a generated GoMock package.
|
Package tasks is a generated GoMock package. |
|
workflow
Package workflow is a generated GoMock package.
|
Package workflow is a generated GoMock package. |
|
workflow/cache
Package cache is a generated GoMock package.
|
Package cache is a generated GoMock package. |
|
archiver
Package archiver is a generated GoMock package.
|
Package archiver is a generated GoMock package. |
|
common
Package common is a generated GoMock package.
|
Package common is a generated GoMock package. |
|
parentclosepolicy
Package parentclosepolicy is a generated GoMock package.
|
Package parentclosepolicy is a generated GoMock package. |
Click to show internal directories.
Click to hide internal directories.