grpc

Documentation

Index

• func MetricsUnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• func UnaryServerPanicInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
• type GRPCServer
  • func New(o *Options) *GRPCServer
  • func (gs *GRPCServer) CatchSignal(s os.Signal)
  • func (gs *GRPCServer) MustStart()
  • func (gs *GRPCServer) Register(fn interface{}, server interface{})
  • func (gs *GRPCServer) Start() error
  • func (gs *GRPCServer) Stop()
  • func (gs *GRPCServer) StopContext(ctx context.Context)
• type Options

Functions

func MetricsUnaryInterceptor

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

func UnaryServerPanicInterceptor

func UnaryServerPanicInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)

Types

type GRPCServer

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

func New

func New(o *Options) *GRPCServer

func (*GRPCServer) CatchSignal

func (gs *GRPCServer) CatchSignal(s os.Signal)

func (*GRPCServer) MustStart

func (gs *GRPCServer) MustStart()

func (*GRPCServer) Register

func (gs *GRPCServer) Register(fn interface{}, server interface{})

func (*GRPCServer) Start

func (gs *GRPCServer) Start() error

func (*GRPCServer) Stop

func (gs *GRPCServer) Stop()

func (*GRPCServer) StopContext

func (gs *GRPCServer) StopContext(ctx context.Context)

type Options

type Options struct {
	Address                      string
	UnaryInterceptors            []grpc.UnaryServerInterceptor
	SkipRegisterReflectionServer bool
}