Documentation ¶
Index ¶
- func Logger(log *slog.Logger) logging.Logger
- func PanicRecoveryHandler(log *slog.Logger) func(p any) error
- func StreamParallelTasksLimiter(sem chan struct{}, log *slog.Logger) grpc.StreamServerInterceptor
- func StreamServerSinglefligt(m *sync.Mutex, log *slog.Logger) grpc.StreamServerInterceptor
- func UnaryParallelTasksLimiter(sem chan struct{}, log *slog.Logger) grpc.UnaryServerInterceptor
- func UnaryServerSinglefligt(m *sync.Mutex, log *slog.Logger) grpc.UnaryServerInterceptor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StreamParallelTasksLimiter ¶
func StreamParallelTasksLimiter(sem chan struct{}, log *slog.Logger) grpc.StreamServerInterceptor
func StreamServerSinglefligt ¶
func UnaryParallelTasksLimiter ¶
func UnaryParallelTasksLimiter(sem chan struct{}, log *slog.Logger) grpc.UnaryServerInterceptor
func UnaryServerSinglefligt ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.