transport

package
v1.76.15 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 16, 2022 License: Unlicense Imports: 15 Imported by: 9

Documentation

Index

Constants

This section is empty.

Variables

Functions

func Register added in v1.70.0

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 added in v1.70.0

type RegisterParams struct {
	fx.In

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

RegisterParams for transport.

type Server added in v1.70.1

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

Server handles all the transports.

func NewServer added in v1.70.1

func NewServer(params RegisterParams) *Server

NewServer for transport.

func (*Server) Start added in v1.70.1

func (s *Server) Start() error

Start all the servers.

func (*Server) Stop added in v1.70.1

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

Stop all the servers.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL