service

package
v1.22.3-rc2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 28, 2023 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GrpcServerOptionsProvider

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

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

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.
api
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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL