grpcx

func WithAuthFunc ¶

func WithAuthFunc(authFunc grpc_auth.AuthFunc) Option

func WithGrpcOption ¶

func WithGrpcOption(option grpc.ServerOption) Option

func WithLogger ¶

func WithLogger(logger *zap.Logger) Option

func WithPrometheus ¶

func WithPrometheus(listen string) Option

func WithRegistry ¶

func WithRegistry(register registry.Registry, serviceName string, listen string) Option

func WithStreamServerInterceptor ¶

func WithStreamServerInterceptor(intercoptors ...grpc.StreamServerInterceptor) Option

func WithTracer ¶

func WithTracer(tracer opentracing.Tracer) Option

func WithUnaryServerInterceptor ¶

func WithUnaryServerInterceptor(intercoptors ...grpc.UnaryServerInterceptor) Option

func Micro ¶

func Micro(name string, opts ...Option) (*Server, error)

micro service stack support. if you use prometheus, the http server implement yourself example:

  httpServer := &http.Server{
		Handler: promhttp.HandlerFor(reg, promhttp.HandlerOpts{}),
		Addr: fmt.Sprintf("0.0.0.0:%d", 9092)
	 }

	go func() {
		if err := httpServer.ListenAndServe(); err != nil {
			log.Fatal("Unable to start a http server.")
		}
	}()

func NewServer ¶

func NewServer(name string, opts ...Option) *Server