service

Documentation

Index

• func GrpcServerOptionsProvider(params GrpcServerOptionsParams) []grpc.ServerOption
• func PersistenceMaxQpsFn(maxQps dynamicconfig.IntPropertyFn, globalMaxQps dynamicconfig.IntPropertyFn) persistenceClient.PersistenceMaxQps
• type GrpcServerOptionsParams
• type PersistenceRateLimitingParams
  • func NewPersistenceRateLimitingParams(maxQps dynamicconfig.IntPropertyFn, globalMaxQps dynamicconfig.IntPropertyFn, ...) PersistenceRateLimitingParams

Functions

func GrpcServerOptionsProvider

func GrpcServerOptionsProvider(
	params GrpcServerOptionsParams,
) []grpc.ServerOption

func PersistenceMaxQpsFn

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

Types

type GrpcServerOptionsParams

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

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

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