middleware

Documentation

Index

• Variables
• func KeepAliveServerParams() keepalive.ServerParameters
• func KeepaliveEnforcementPolicy() keepalive.EnforcementPolicy
• type ClientInterceptor
  • func (cl *ClientInterceptor) UnaryClientInterceptor(ctx context.Context, method string, req interface{}, reply interface{}, ...) error
• type ServerInterceptor
  • func (si *ServerInterceptor) UnaryServerInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

Variables

var (
	Log *zap.Logger
)

Functions

func KeepAliveServerParams

func KeepAliveServerParams() keepalive.ServerParameters

func KeepaliveEnforcementPolicy

func KeepaliveEnforcementPolicy() keepalive.EnforcementPolicy

Types

type ClientInterceptor

type ClientInterceptor struct {
	Unary  grpc.UnaryClientInterceptor
	Stream grpc.StreamClientInterceptor
}

func (*ClientInterceptor) UnaryClientInterceptor

func (cl *ClientInterceptor) UnaryClientInterceptor(
	ctx context.Context,
	method string,
	req interface{},
	reply interface{},
	cc *grpc.ClientConn,
	invoker grpc.UnaryInvoker,
	opts ...grpc.CallOption,
) error

type ServerInterceptor

type ServerInterceptor struct {
	Unary  grpc.UnaryServerInterceptor
	Stream grpc.StreamServerInterceptor
}

func (*ServerInterceptor) UnaryServerInterceptor

func (si *ServerInterceptor) UnaryServerInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

UnaryServerInterceptor is a middleware for gRPC server requests.