grpcserver

Documentation

Index

• Variables
• func GetInstance() *grpc.Server
• func GrpcSignCheckFunc(ctx context.Context) (context.Context, error)
• func NewService(sign string, backends ...Backend) *grpc.Server
• type Backend

Variables

var DefaultCtxTagsOptions = []grpc_ctxtags.Option{
	grpc_ctxtags.WithFieldExtractor(grpc_ctxtags.TagBasedRequestFieldExtractor("log_fields")),
}

var DefaultRecoveryOptions = []grpc_recovery.Option{
	grpc_recovery.WithRecoveryHandler(func(p interface{}) (err error) {
		return status.Errorf(codes.Unknown, "panic triggered: %v", p)
	}),
}

var DefaultServerOptions = []grpc.ServerOption{
	grpc.ChainStreamInterceptor(
		grpc_recovery.StreamServerInterceptor(DefaultRecoveryOptions...),
		grpc_ctxtags.StreamServerInterceptor(DefaultCtxTagsOptions...),
		grpc_prometheus.StreamServerInterceptor,
		otelgrpc.StreamServerInterceptor(),
		grpc_auth.StreamServerInterceptor(GrpcSignCheckFunc),
	),
	grpc.ChainUnaryInterceptor(
		grpc_recovery.UnaryServerInterceptor(DefaultRecoveryOptions...),
		grpc_ctxtags.UnaryServerInterceptor(DefaultCtxTagsOptions...),
		grpc_prometheus.UnaryServerInterceptor,
		otelgrpc.UnaryServerInterceptor(),
		grpc_auth.UnaryServerInterceptor(GrpcSignCheckFunc),
	),
}

var SignKey = ""

Functions

func GetInstance

func GetInstance() *grpc.Server

func GrpcSignCheckFunc

func GrpcSignCheckFunc(ctx context.Context) (context.Context, error)

func NewService

func NewService(sign string, backends ...Backend) *grpc.Server

NewService initializes a new grpc service

Types

type Backend

type Backend interface {
	RegisterGRPC(*grpc.Server)
}

Backend abstracts a registerable GRPC