gateway

type CloseHandler func(c Conn)

type Conn interface {
	ConnID() uint64
	ClientIP() string
	Push(m *rony.MessageEnvelope)
	Pop() *rony.MessageEnvelope
	SendBinary(streamID int64, data []byte) error
	Persistent() bool
	Get(key string) interface{}
	Set(key string, val interface{})
}

type ConnectHandler func(c Conn)

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

type KeyValue struct {
	Key   string
	Value string
}

type MessageHandler func(c Conn, streamID int64, data []byte, kvs ...KeyValue)

type Protocol string