tcpGateway

Documentation

Index

• Variables
• func CreateHandle(onRequest func(conn rony.Conn, reqCtx *gateway.RequestCtx) []byte, ...) gateway.ProxyFactory
• type Config
• type Gateway
  • func MustNew(config Config) *Gateway
  • func New(config Config) (*Gateway, error)
  • func (g *Gateway) Addr() []string
  • func (g *Gateway) GetConn(connID uint64) rony.Conn
  • func (g *Gateway) Run()
  • func (g *Gateway) SetProxy(method, path string, factory gateway.ProxyFactory)
  • func (g *Gateway) Shutdown()
  • func (g *Gateway) Start()
  • func (g *Gateway) Support(p gateway.Protocol) bool
  • func (g *Gateway) TotalConnections() int
• type HttpProxy
  • func (hp *HttpProxy) Set(method, path string, f gateway.ProxyFactory)
• type UnsafeConn

Variables

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

Functions

func CreateHandle

func CreateHandle(
	onRequest func(conn rony.Conn, reqCtx *gateway.RequestCtx) []byte,
	onResponse func(data []byte) (*pools.ByteBuffer, map[string]string),
) gateway.ProxyFactory

Types

type Config

type Config struct {
	Concurrency   int
	ListenAddress string
	MaxBodySize   int
	MaxIdleTime   time.Duration
	Protocol      gateway.Protocol
	ExternalAddrs []string
}

Config holds all the configuration for Gateway

type Gateway

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

Gateway is one of the main components of the Rony framework. Basically Gateway is the component that connects edge.Server with the external world. Clients which are not part of our cluster MUST connect to our edge servers through Gateway. This is an implementation of gateway.Gateway interface with support for **Http** and **Websocket** connections.

func MustNew

func MustNew(config Config) *Gateway

func New

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

func (*Gateway) Addr

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

Addr return the address which gateway is listen on

func (*Gateway) GetConn

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) SetProxy

func (g *Gateway) SetProxy(method, path string, factory gateway.ProxyFactory)

SetProxy set http proxy handlers. This function MUST NOT used concurrent and MUST ONLY use it before calling Start or Run.

func (*Gateway) Shutdown

func (g *Gateway) Shutdown()

Shutdown closes the server by stopping services in sequence, in a way that all the flying request will be served before server shutdown.

func (*Gateway) Start

func (g *Gateway) Start()

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

func (*Gateway) Support

func (g *Gateway) Support(p gateway.Protocol) bool

func (*Gateway) TotalConnections

func (g *Gateway) TotalConnections() int

type HttpProxy

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

HttpProxy help to provide RESTFull wrappers around RPC handlers.

func (*HttpProxy) Set

func (hp *HttpProxy) Set(method, path string, f gateway.ProxyFactory)

type UnsafeConn

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