grpc

Documentation

Index

• Constants
• Variables
• func InterceptorLogger(logger *zap.Logger) logging.Logger
• func NewServer() (*grpc.Server, error)
• type HealthCheck
  • func (h *HealthCheck) Check(_ context.Context, _ *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)
  • func (h *HealthCheck) Watch(_ *healthpb.HealthCheckRequest, _ healthgrpc.Health_WatchServer) error

Constants

const (
	FieldLength = 2
)

Variables

var Module = fx.Options(
	fx.Provide(
		func() (*grpc.Server, error) {
			return NewServer()
		},
	),
	fx.Invoke(
		func(lc fx.Lifecycle, grpcServer *grpc.Server) error {
			lc.Append(
				fx.Hook{
					OnStart: func(context.Context) error {
						listener, err := net.Listen("tcp", fmt.Sprintf(":%s", environment.GetGRPCPort()))
						if err != nil {
							return fmt.Errorf("failed to listen: %w", err)
						}
						server := &HealthCheck{}
						healthpb.RegisterHealthServer(grpcServer, server)
						go func() {
							if err := grpcServer.Serve(listener); err != nil {
								panic(err)
							}
						}()
						return nil
					},
					OnStop: func(context.Context) error {
						grpcServer.GracefulStop()
						return nil
					},
				},
			)
			return nil
		},
	),
)

Functions

func InterceptorLogger

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

func NewServer

func NewServer() (*grpc.Server, error)

Types

type HealthCheck

type HealthCheck struct {
	healthgrpc.UnimplementedHealthServer
}

func (*HealthCheck) Check

func (h *HealthCheck) Check(_ context.Context, _ *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)

func (*HealthCheck) Watch

func (h *HealthCheck) Watch(_ *healthpb.HealthCheckRequest, _ healthgrpc.Health_WatchServer) error