dummyGateway

Documentation

Index

• type Config
• type Conn
  • func NewConn(id uint64) *Conn
  • func (c *Conn) Body() []byte
  • func (c *Conn) ClientIP() string
  • func (c *Conn) ConnID() uint64
  • func (c *Conn) Get(key string) interface{}
  • func (c *Conn) Method() string
  • func (c *Conn) MultiPart() (*multipart.Form, error)
  • func (c *Conn) Path() string
  • func (c *Conn) Persistent() bool
  • func (c *Conn) ReadHeader(key string) string
  • func (c *Conn) Redirect(statusCode int, newHostPort string)
  • func (c *Conn) Set(key string, val interface{})
  • func (c *Conn) SetPersistent(b bool) *Conn
  • func (c *Conn) WithHandler(...) *Conn
  • func (c *Conn) WriteBinary(streamID int64, data []byte) error
  • func (c *Conn) WriteHeader(key, value string)
  • func (c *Conn) WriteStatus(status int)
• type Gateway
  • func New(config Config) (*Gateway, error)
  • func (g *Gateway) Addr() []string
  • func (g *Gateway) CloseConn(connID uint64)
  • func (g *Gateway) GetConn(connID uint64) rony.Conn
  • func (g *Gateway) OpenConn(connID uint64, persistent bool, ...)
  • func (g *Gateway) Protocol() rony.GatewayProtocol
  • func (g *Gateway) REST(connID uint64, method, path string, body []byte, kvs ...*rony.KeyValue) (respBody []byte, respHdr map[string]string)
  • func (g *Gateway) RPC(connID uint64, streamID int64, data []byte) error
  • func (g *Gateway) Run()
  • func (g *Gateway) Shutdown()
  • func (g *Gateway) Start()

Types

type Config

type Config struct {
	Exposer func(gw *Gateway)
}

type Conn

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

func NewConn

func NewConn(id uint64) *Conn

func (*Conn) Body

func (c *Conn) Body() []byte

func (*Conn) ClientIP

func (c *Conn) ClientIP() string

func (*Conn) ConnID

func (c *Conn) ConnID() uint64

func (*Conn) Get

func (c *Conn) Get(key string) interface{}

func (*Conn) Method

func (c *Conn) Method() string

func (*Conn) MultiPart

func (c *Conn) MultiPart() (*multipart.Form, error)

func (*Conn) Path

func (c *Conn) Path() string

func (*Conn) Persistent

func (c *Conn) Persistent() bool

func (*Conn) ReadHeader

func (c *Conn) ReadHeader(key string) string

func (*Conn) Redirect

func (c *Conn) Redirect(statusCode int, newHostPort string)

func (*Conn) Set

func (c *Conn) Set(key string, val interface{})

func (*Conn) SetPersistent

func (c *Conn) SetPersistent(b bool) *Conn

func (*Conn) WithHandler

func (c *Conn) WithHandler(onMessage func(connID uint64, streamID int64, data []byte, hdr map[string]string)) *Conn

func (*Conn) WriteBinary

func (c *Conn) WriteBinary(streamID int64, data []byte) error

func (*Conn) WriteHeader

func (c *Conn) WriteHeader(key, value string)

func (*Conn) WriteStatus

func (c *Conn) WriteStatus(status int)

type Gateway

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

func New

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

func (*Gateway) Addr

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

func (*Gateway) CloseConn

func (g *Gateway) CloseConn(connID uint64)

CloseConn closed the connection

func (*Gateway) GetConn

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

func (*Gateway) OpenConn

func (g *Gateway) OpenConn(
	connID uint64, persistent bool,
	onReceiveMessage func(connID uint64, streamID int64, data []byte),
	hdr ...*rony.KeyValue,
)

OpenConn opens a persistent connection to the gateway. For short lived use RPC or REST methods.

func (*Gateway) Protocol

func (g *Gateway) Protocol() rony.GatewayProtocol

func (*Gateway) REST

func (g *Gateway) REST(
	connID uint64, method, path string,
	body []byte,
	kvs ...*rony.KeyValue,
) (respBody []byte, respHdr map[string]string)

REST emulates a Http REST request.

func (*Gateway) RPC

func (g *Gateway) RPC(connID uint64, streamID int64, data []byte) error

RPC emulates sending an RPC command to the connection. It opens a non-persistent connection if connID does not exists

func (*Gateway) Run

func (g *Gateway) Run()

func (*Gateway) Shutdown

func (g *Gateway) Shutdown()

func (*Gateway) Start

func (g *Gateway) Start()