gateway

type CloseHandler ¶

type CloseHandler = func(c rony.Conn)

type ConnectHandler ¶

type ConnectHandler = func(c rony.Conn, kvs ...*rony.KeyValue)

type Gateway ¶

type Gateway interface {
	Start()
	Run()
	Shutdown()
	GetConn(connID uint64) rony.Conn
	Addr() []string
}

Gateway defines the gateway interface where clients could connect and communicate with the edge server

type MessageHandler ¶

type MessageHandler = func(c rony.Conn, streamID int64, data []byte, bypass bool)

type Protocol ¶

type Protocol int32

const (
	Undefined Protocol = 0
	Dummy     Protocol = 1 << iota
	Http
	Websocket
	Quic
	Grpc
	TCP = Http | Websocket // Http & Websocket
)

func (p Protocol) String() string

type ProxyFactory ¶ added in v0.6.40

type ProxyFactory interface {
	Get() ProxyHandle
	Release(h ProxyHandle)
}

type ProxyHandle ¶ added in v0.6.1

type ProxyHandle interface {
	OnRequest(conn rony.Conn, ctx *RequestCtx) []byte
	OnResponse(data []byte) (*pools.ByteBuffer, map[string]string)
}

type RequestCtx ¶ added in v0.5.23

type RequestCtx = fasthttp.RequestCtx