middleware

Documentation

Overview

Package middleware provides reusable gRPC server interceptors for common production concerns such as authentication, structured logging, payload logging, and panic recovery.

The helper functions return interceptor slices so callers can compose them into their own preferred chain order.

Index

• func AddAuth(authFunc grpc_auth.AuthFunc) ([]grpc.UnaryServerInterceptor, []grpc.StreamServerInterceptor)
• func AddLogging(logger *zap.Logger) ([]grpc.UnaryServerInterceptor, []grpc.StreamServerInterceptor)
• func AddPayloadLogging(logger *zap.Logger) ([]grpc.UnaryServerInterceptor, []grpc.StreamServerInterceptor)
• func AddRecovery() ([]grpc.UnaryServerInterceptor, []grpc.StreamServerInterceptor)

Examples

• AddLogging
• AddPayloadLogging
• AddRecovery

Functions

func AddAuth

func AddAuth(
	authFunc grpc_auth.AuthFunc,
) ([]grpc.UnaryServerInterceptor, []grpc.StreamServerInterceptor)

AddAuth returns unary and stream interceptors that enforce gRPC auth middleware.

func AddLogging

func AddLogging(
	logger *zap.Logger,
) ([]grpc.UnaryServerInterceptor, []grpc.StreamServerInterceptor)

AddLogging returns unary and stream interceptors for structured gRPC logging.

Example

unary, stream := AddLogging(zap.NewNop())
_, _ = unary, stream

func AddPayloadLogging

func AddPayloadLogging(
	logger *zap.Logger,
) ([]grpc.UnaryServerInterceptor, []grpc.StreamServerInterceptor)

AddPayloadLogging returns interceptors that log request and response payloads in addition to standard gRPC call metadata.

Example

unary, stream := AddPayloadLogging(zap.NewNop())
_, _ = unary, stream

func AddRecovery

func AddRecovery() ([]grpc.UnaryServerInterceptor, []grpc.StreamServerInterceptor)

AddRecovery returns interceptors that convert panics in gRPC handlers into internal errors.

Example

unary, stream := AddRecovery()
_, _ = unary, stream