transport

Documentation

Index

• Variables
• func IsEnabled(cfg *Config) bool
• func Register(lc fx.Lifecycle, servers []Server)
• type Config
• type Server
  • func NewServers(http *http.Server, grpc *grpc.Server, debug *debug.Server) []Server

Variables

var Module = fx.Options(
	grpc.Module,
	http.Module,
	events.Module,
	meta.Module,
	limiter.Module,
	fx.Provide(NewServers),
	fx.Invoke(Register),
)

Module for fx.

Functions

func IsEnabled

func IsEnabled(cfg *Config) bool

IsEnabled for transport.

func Register

func Register(lc fx.Lifecycle, servers []Server)

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 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.