service

Documentation

Index

• Variables
• func GrpcServerOptionsProvider(params GrpcServerOptionsParams) []grpc.ServerOption
• type GrpcServerOptionsParams
• type PersistenceLazyLoadedServiceResolver
  • func (p PersistenceLazyLoadedServiceResolver) AvailableMemberCount() int
• type PersistenceRateLimitingParams
  • func NewPersistenceRateLimitingParams(maxQps dynamicconfig.IntPropertyFn, globalMaxQps dynamicconfig.IntPropertyFn, ...) PersistenceRateLimitingParams

Variables

var PersistenceLazyLoadedServiceResolverModule = fx.Options(
	fx.Provide(func() PersistenceLazyLoadedServiceResolver {
		return PersistenceLazyLoadedServiceResolver{
			Value: &atomic.Value{},
		}
	}),
	fx.Invoke(initPersistenceLazyLoadedServiceResolver),
)

Functions

func GrpcServerOptionsProvider

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

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 PersistenceLazyLoadedServiceResolver

type PersistenceLazyLoadedServiceResolver struct {
	*atomic.Value // value type is membership.ServiceResolver
}

func (PersistenceLazyLoadedServiceResolver) AvailableMemberCount

func (p PersistenceLazyLoadedServiceResolver) AvailableMemberCount() int

type PersistenceRateLimitingParams

type PersistenceRateLimitingParams struct {
	fx.Out

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

func NewPersistenceRateLimitingParams

func NewPersistenceRateLimitingParams(
	maxQps dynamicconfig.IntPropertyFn,
	globalMaxQps dynamicconfig.IntPropertyFn,
	namespaceMaxQps dynamicconfig.IntPropertyFnWithNamespaceFilter,
	globalNamespaceMaxQps dynamicconfig.IntPropertyFnWithNamespaceFilter,
	perShardNamespaceMaxQps dynamicconfig.IntPropertyFnWithNamespaceFilter,
	operatorRPSRatio dynamicconfig.FloatPropertyFn,
	burstRatio dynamicconfig.FloatPropertyFn,
	dynamicRateLimitingParams dynamicconfig.TypedPropertyFn[dynamicconfig.DynamicRateLimitingParams],
	lazyLoadedServiceResolver PersistenceLazyLoadedServiceResolver,
	logger log.Logger,
) PersistenceRateLimitingParams