service

package
v1.26.0 Latest Latest
Warning

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

Go to latest
Published: Sep 25, 2024 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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 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 PersistenceLazyLoadedServiceResolver added in v1.23.0

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

func (PersistenceLazyLoadedServiceResolver) AvailableMemberCount added in v1.24.0

func (p PersistenceLazyLoadedServiceResolver) AvailableMemberCount() int

type PersistenceRateLimitingParams added in v1.17.2

type PersistenceRateLimitingParams struct {
	fx.Out

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

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
Package api is a generated GoMock package.
Package api is a generated GoMock package.
api/getdlqtasks
Package getdlqtasks contains the logic to implement the historyservice.HistoryServiceServer.GetDLQTasks API.
Package getdlqtasks contains the logic to implement the historyservice.HistoryServiceServer.GetDLQTasks 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.
hsm
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.
replication/eventhandler
Package eventhandler is a generated GoMock package.
Package eventhandler 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.
Package matching is a generated GoMock package.
Package matching is a generated GoMock package.
common
Package common is a generated GoMock package.
Package common is a generated GoMock package.
dlq
Package dlq contains the workflow for deleting and re-enqueueing DLQ tasks.
Package dlq contains the workflow for deleting and re-enqueueing DLQ tasks.
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