transport

Documentation

Index

• Variables
• func Register(params RegisterParams)
• type Config
• type RegisterParams
• type Server
  • func NewServers(http *http.Server, grpc *grpc.Server, debug *debug.Server) []Server

Variables

var (
	// GRPCModule for fx.
	GRPCModule = fx.Options(
		fx.Provide(grpc.NewServer),
		fx.Provide(gtracer.NewTracer),
	)

	// HTTPModule for fx.
	HTTPModule = fx.Options(
		fx.Provide(http.NewServer),
		fx.Provide(htracer.NewTracer),
	)

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

Functions

func Register

func Register(params RegisterParams)

Register all the transports.

Types

type Config

type Config struct {
	GRPC *grpc.Config `yaml:"grpc,omitempty" json:"grpc,omitempty" toml:"grpc,omitempty"`
	HTTP *http.Config `yaml:"http,omitempty" json:"http,omitempty" toml:"http,omitempty"`
}

Config for transport.

type RegisterParams

type RegisterParams struct {
	fx.In

	Lifecycle fx.Lifecycle
	Servers   []Server
}

RegisterParams for transport.

type Server

type Server interface {
	Start()
	Stop(ctx context.Context)
}

Server for transport.

func NewServers

func NewServers(http *http.Server, grpc *grpc.Server, debug *debug.Server) []Server

NewServers for transport.