transport

Documentation

Index

• Variables
• func Register(params RegisterParams)
• type Config
• type RegisterParams
• type Server
  • func NewServer(params RegisterParams) *Server
  • func (s *Server) Start() error
  • func (s *Server) Stop(ctx context.Context)

Variables

var (
	// GRPCModule for fx.
	GRPCModule = fx.Options(
		fx.Provide(grpc.NewServer),
		fx.Provide(grpc.UnaryServerInterceptor),
		fx.Provide(grpc.StreamServerInterceptor),
		fx.Provide(gprometheus.NewServerMetrics),
		fx.Provide(gprometheus.NewClientMetrics),
		fx.Provide(gopentracing.NewTracer),
	)

	// HTTPModule for fx.
	HTTPModule = fx.Options(
		fx.Provide(http.NewServer),
		fx.Provide(hprometheus.NewServerMetrics),
		fx.Provide(hprometheus.NewClientMetrics),
		fx.Provide(hopentracing.NewTracer),
	)

	// NSQModule for fx.
	NSQModule = fx.Options(
		fx.Provide(nprometheus.NewProducerMetrics),
		fx.Provide(nprometheus.NewConsumerMetrics),
		fx.Provide(nopentracing.NewTracer),
		fx.Provide(marshaller.NewMsgPack),
	)

	// Module for fx.
	Module = fx.Options(
		GRPCModule,
		HTTPModule,
		NSQModule,
		fx.Invoke(Register),
	)
)

Functions

func Register

func Register(params RegisterParams)

Register all the transports.

Types

type Config

type Config struct {
	Port string      `yaml:"port"`
	GRPC grpc.Config `yaml:"grpc"`
	HTTP http.Config `yaml:"http"`
	NSQ  nsq.Config  `yaml:"nsq"`
}

Config for transport.

type RegisterParams

type RegisterParams struct {
	fx.In

	Lifecycle  fx.Lifecycle
	Shutdowner fx.Shutdowner
	Config     *Config
	HTTP       *http.Server
	GRPC       *grpc.Server
}

RegisterParams for transport.

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server handles all the transports.

func NewServer

func NewServer(params RegisterParams) *Server

NewServer for transport.

func (*Server) Start

func (s *Server) Start() error

Start all the servers.

func (*Server) Stop

func (s *Server) Stop(ctx context.Context)

Stop all the servers.