grpc

Documentation

Index

• Variables
• func AsService(f any) any
• func InterceptorLogger(l *zap.Logger) logging.Logger
• type ServerParams
• type ServerResult
  • func NewServer(p ServerParams) (ServerResult, error)
• type Service

Variables

var (
	ErrInternalServer = status.Error(codes.Internal, "errors.general.internal_error")
)

var ServerModule = fx.Module("grpcserver",
	fx.Provide(
		NewServer,
	),
	fx.Decorate(wrapLogger),
)

Functions

func AsService

func AsService(f any) any

AsService annotates the given constructor to state that it provides a GRPC service to the "grpcservices" group.

func InterceptorLogger

func InterceptorLogger(l *zap.Logger) logging.Logger

InterceptorLogger adapts zap logger to interceptor logger. This code is simple enough to be copied and not imported.

Types

type ServerParams

type ServerParams struct {
	fx.In

	LC fx.Lifecycle

	Logger   *zap.Logger
	Config   *config.Config
	DB       *sql.DB
	TP       *tracesdk.TracerProvider
	Services []Service `group:"grpcservices"`
	TokenMgr *auth.TokenMgr
	UserInfo userinfo.UserInfoRetriever
	Perms    perms.Permissions
}

type ServerResult

type ServerResult struct {
	fx.Out

	Server *grpc.Server
}

func NewServer

func NewServer(p ServerParams) (ServerResult, error)

type Service

type Service interface {
	RegisterServer(srv *grpc.Server)
}