dummy

Documentation

Index

• type Config
• type Conn
  • func (c *Conn) ClientIP() string
  • func (c *Conn) ConnID() uint64
  • func (c *Conn) Get(key string) interface{}
  • func (c *Conn) Persistent() bool
  • func (c *Conn) Pop() *rony.MessageEnvelope
  • func (c *Conn) Push(m *rony.MessageEnvelope)
  • func (c *Conn) SendBinary(streamID int64, data []byte) error
  • func (c *Conn) Set(key string, val interface{})
  • func (c *Conn) SetPersistent(b bool)
• 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) gateway.Conn
  • func (g *Gateway) OpenConn(connID uint64, ...)
  • func (g *Gateway) Run()
  • func (g *Gateway) SendToConn(connID uint64, streamID int64, data []byte)
  • 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 (*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) Persistent

func (c *Conn) Persistent() bool

func (*Conn) Pop

func (c *Conn) Pop() *rony.MessageEnvelope

func (*Conn) Push

func (c *Conn) Push(m *rony.MessageEnvelope)

func (*Conn) SendBinary

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

func (*Conn) Set

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

func (*Conn) SetPersistent

func (c *Conn) SetPersistent(b bool)

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)

func (*Gateway) GetConn

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

func (*Gateway) OpenConn

func (g *Gateway) OpenConn(connID uint64, onReceiveMessage func(connID uint64, streamID int64, data []byte), kvs ...gateway.KeyValue)

func (*Gateway) Run

func (g *Gateway) Run()

func (*Gateway) SendToConn

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

func (*Gateway) Shutdown

func (g *Gateway) Shutdown()

func (*Gateway) Start

func (g *Gateway) Start()