tcpGateway

package
v0.2.10 Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2021 License: BSD-3-Clause Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrUnsupportedProtocol  = errors.New("gateway protocol is not supported")
	ErrWriteToClosedConn    = errors.New("write to closed conn")
	ErrUnexpectedSocketRead = errors.New("unexpected socket read")
	ErrOpCloseReceived      = errors.New("close operation received")
)

Functions

This section is empty.

Types

type Config 

type Config struct {
	Concurrency   int
	ListenAddress string
	MaxBodySize   int
	MaxIdleTime   time.Duration
	Protocol      gateway.Protocol
	ExternalAddrs []string
	// contains filtered or unexported fields
}

Config

type Gateway 

type Gateway struct {
	gateway.ConnectHandler
	gateway.MessageHandler
	gateway.CloseHandler
	// contains filtered or unexported fields
}

Gateway

func MustNew 

func MustNew(config Config) *Gateway

func New 

func New(config Config) (*Gateway, error)

New

func (*Gateway) Addr 

func (g *Gateway) Addr() []string

Addr return the address which gateway is listen on

func (*Gateway) GetConn added in v0.0.6 

func (g *Gateway) GetConn(connID uint64) rony.Conn

GetConn returns the connection identified by connID

func (*Gateway) Run 

func (g *Gateway) Run()

Run is blocking and runs the server endless loop until a non-temporary error happens

func (*Gateway) Shutdown 

func (g *Gateway) Shutdown()

Shutdown

func (*Gateway) Start 

func (g *Gateway) Start()

Start is non-blocking and call the Run function in background

func (*Gateway) TotalConnections added in v0.0.49 

func (g *Gateway) TotalConnections() int

type UnsafeConn added in v0.0.46 

type UnsafeConn interface {
	net.Conn
	UnsafeConn() net.Conn
}

Source Files

View all Source files

Directories

Path Synopsis
Package wsutil provides utilities for working with WebSocket protocol.
 Package wsutil provides utilities for working with WebSocket protocol.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.