service

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 PersistenceLazyLoadedServiceResolver struct {
	*atomic.Value // value type is membership.ServiceResolver
}

type PersistenceRateLimitingParams struct {
	fx.Out

	PersistenceMaxQps                  persistenceClient.PersistenceMaxQps
	PersistenceNamespaceMaxQps         persistenceClient.PersistenceNamespaceMaxQps
	PersistencePerShardNamespaceMaxQPS persistenceClient.PersistencePerShardNamespaceMaxQPS
	OperatorRPSRatio                   persistenceClient.OperatorRPSRatio
	PersistenceBurstRatio              persistenceClient.PersistenceBurstRatio
	DynamicRateLimitingParams          persistenceClient.DynamicRateLimitingParams
}