Documentation
¶
Index ¶
- Variables
- func ServeGRPC(params ServeGrpcParams)
- func StreamLogAndCaptureErrors(log *zap.Logger, debug bool) grpc.StreamServerInterceptor
- func UnaryLogAndCaptureErrors(log *zap.Logger, debug bool) grpc.UnaryServerInterceptor
- type GRPCRecovery
- type ListenerResult
- type ServeGrpcParams
- type ServerParams
- type ServerResult
Constants ¶
This section is empty.
Variables ¶
View Source
var Module = fx.Options( v1.Module, fx.Provide( NewGRPCRecovery, NewListener, NewServer, ), )
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 ¶
func NewListener ¶
func NewListener(grpcConfig config.GRPCConfig) (ListenerResult, error)
type ServeGrpcParams ¶
type ServerParams ¶
type ServerParams struct { fx.In Logger *zap.Logger Recovery GRPCRecovery Debug config.DebugConfig }
type ServerResult ¶
func NewServer ¶
func NewServer(params ServerParams) ServerResult
Directories
¶
Path | Synopsis |
---|---|
schedulerService/mocks
Package mocks is a generated GoMock package.
|
Package mocks is a generated GoMock package. |
Click to show internal directories.
Click to hide internal directories.