service

Documentation

Index

• func GrpcServerOptionsProvider(logger log.Logger, rpcFactory common.RPCFactory, ...) []grpc.ServerOption
• func PersistenceMaxQpsFn(maxQps dynamicconfig.IntPropertyFn, globalMaxQps dynamicconfig.IntPropertyFn) persistenceClient.PersistenceMaxQps
• type PersistenceRateLimitingParams
  • func NewPersistenceRateLimitingParams(maxQps dynamicconfig.IntPropertyFn, globalMaxQps dynamicconfig.IntPropertyFn, ...) PersistenceRateLimitingParams

Functions

func GrpcServerOptionsProvider

func GrpcServerOptionsProvider(
	logger log.Logger,
	rpcFactory common.RPCFactory,
	retryableInterceptor *interceptor.RetryableInterceptor,
	telemetryInterceptor *interceptor.TelemetryInterceptor,
	rateLimitInterceptor *interceptor.RateLimitInterceptor,
	tracingInterceptor telemetry.ServerTraceInterceptor,
) []grpc.ServerOption

func PersistenceMaxQpsFn

func PersistenceMaxQpsFn(
	maxQps dynamicconfig.IntPropertyFn,
	globalMaxQps dynamicconfig.IntPropertyFn,
) persistenceClient.PersistenceMaxQps

Types

type PersistenceRateLimitingParams

type PersistenceRateLimitingParams struct {
	fx.Out

	PersistenceMaxQps                  persistenceClient.PersistenceMaxQps
	PersistenceNamespaceMaxQps         persistenceClient.PersistenceNamespaceMaxQps
	PersistencePerShardNamespaceMaxQPS persistenceClient.PersistencePerShardNamespaceMaxQPS
	EnablePriorityRateLimiting         persistenceClient.EnablePriorityRateLimiting
	DynamicRateLimitingParams          persistenceClient.DynamicRateLimitingParams
}

func NewPersistenceRateLimitingParams

func NewPersistenceRateLimitingParams(
	maxQps dynamicconfig.IntPropertyFn,
	globalMaxQps dynamicconfig.IntPropertyFn,
	namespaceMaxQps dynamicconfig.IntPropertyFnWithNamespaceFilter,
	perShardNamespaceMaxQps dynamicconfig.IntPropertyFnWithNamespaceFilter,
	enablePriorityRateLimiting dynamicconfig.BoolPropertyFn,
	dynamicRateLimitingParams dynamicconfig.MapPropertyFn,
) PersistenceRateLimitingParams