grpcmiddleware

Documentation

Overview

Package grpcmiddleware provides a way to add functions that will be called for each gRPC, before that RPC executes.

Index

• type Middleware
  • func (m *Middleware) AddStreamMiddleware(middleware StreamMiddleware)
  • func (m *Middleware) AddUnaryMiddleware(middleware UnaryMiddleware)
  • func (m *Middleware) StreamIntercept(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
  • func (m *Middleware) UnaryIntercept(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• type StreamMiddleware
• type UnaryMiddleware

Types

type Middleware

type Middleware struct {
	// contains filtered or unexported fields
}

func (*Middleware) AddStreamMiddleware

func (m *Middleware) AddStreamMiddleware(middleware StreamMiddleware)

func (*Middleware) AddUnaryMiddleware

func (m *Middleware) AddUnaryMiddleware(middleware UnaryMiddleware)

func (*Middleware) StreamIntercept

func (m *Middleware) StreamIntercept(srv interface{},
	ss grpc.ServerStream,
	info *grpc.StreamServerInfo,
	handler grpc.StreamHandler) error

StreamInterceptor method can be provided to gRPC server options as a grpc.StreamInterceptor

opts := []grpc.ServerOption{}
opts = append(opts, grpc.StreamInterceptor(middleware.StreamIntercept))
s := grpc.NewServer(opts...)

func (*Middleware) UnaryIntercept

func (m *Middleware) UnaryIntercept(
	ctx context.Context,
	req interface{},
	info *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler,
) (interface{}, error)

UnaryIntercept method can be provided to gRPC server options as a grpc.UnaryInterceptor

opts := []grpc.ServerOption{}
opts = append(opts, grpc.UnaryInterceptor(middleware.UnaryIntercept))
s := grpc.NewServer(opts...)

type StreamMiddleware

type StreamMiddleware func(srv interface{},
	ss grpc.ServerStream,
	info *grpc.StreamServerInfo) error

type UnaryMiddleware

type UnaryMiddleware func(
	ctx context.Context,
	req interface{},
	info *grpc.UnaryServerInfo) (interface{}, error)