grpc

package
v0.0.0-...-1427ac7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 30, 2020 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

Functions

func ServeGRPC

func ServeGRPC(params ServeGrpcParams)

func StreamLogAndCaptureErrors

func StreamLogAndCaptureErrors(log *zap.Logger, debug bool) grpc.StreamServerInterceptor

func UnaryLogAndCaptureErrors

func UnaryLogAndCaptureErrors(log *zap.Logger, debug bool) grpc.UnaryServerInterceptor

Types

type GRPCRecovery

type GRPCRecovery interface {
	Handle(p interface{}) (err error)
}

func NewGRPCRecovery

func NewGRPCRecovery() GRPCRecovery

type ListenerResult

type ListenerResult struct {
	fx.Out
	Listener net.Listener `name:"grpc-listener"`
}

func NewListener

func NewListener(grpcConfig config.GRPCConfig) (ListenerResult, error)

type ServeGrpcParams

type ServeGrpcParams struct {
	fx.In

	Lc       fx.Lifecycle
	Listener net.Listener `name:"grpc-listener"`
	Server   *grpc.Server `name:"server-grpc"`
	Monitor  monitoring.Monitor
	Logger   *zap.Logger
}

type ServerParams

type ServerParams struct {
	fx.In
	Logger   *zap.Logger
	Recovery GRPCRecovery
	Debug    config.DebugConfig
}

type ServerResult

type ServerResult struct {
	fx.Out
	Server *grpc.Server `name:"server-grpc"`
}

func NewServer

func NewServer(params ServerParams) ServerResult

Directories

Path Synopsis
v1
schedulerService/mocks
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
JackTT - Gopher 🇻🇳