client

Documentation

Index

• Variables
• type Client
  • func NewAddrClient(addr net.Addr) (*Client, error)
  • func NewClient(conn net.Conn) *Client
  • func NewLazyClient(conn net.Conn, Addr net.Addr) *Client
  • func NewTcpClient(address string) (*Client, error)
  • func (c *Client) FreshSocket() error
  • func (c *Client) Loop()
  • func (c *Client) Recv(id uint32, ret interface{}, option *RecvOption) exception.ExceptionInterface
  • func (c *Client) SendPacket(p *roc.Packet) (uint32, error)
  • func (c *Client) SendRequest(path string, r json.Marshaler) (uint32, error)
• type RecvOption
  • func NewDefaultRecvOption() *RecvOption
• type TCPAddr
  • func (l TCPAddr) Network() string
  • func (l TCPAddr) String() string

Variables

var SocketNil = errors.New("the socket is nil")

Types

type Client

type Client struct {
	Packer         roc.PackerInterface
	IdGenerator    roc.IdGeneratorInterface
	Serializer     serializer.SerializerInterface
	PushChan       chan string
	ChannelManager *roc.ChannelManager
	Socket         net.Conn
	Addr           net.Addr
}

func NewAddrClient

func NewAddrClient(addr net.Addr) (*Client, error)

func NewClient

func NewClient(conn net.Conn) *Client

func NewLazyClient

func NewLazyClient(conn net.Conn, Addr net.Addr) *Client

func NewTcpClient

func NewTcpClient(address string) (*Client, error)

func (*Client) FreshSocket

func (c *Client) FreshSocket() error

func (*Client) Loop

func (c *Client) Loop()

func (*Client) Recv

func (c *Client) Recv(id uint32, ret interface{}, option *RecvOption) exception.ExceptionInterface

func (*Client) SendPacket

func (c *Client) SendPacket(p *roc.Packet) (uint32, error)

func (*Client) SendRequest

func (c *Client) SendRequest(path string, r json.Marshaler) (uint32, error)

type RecvOption

type RecvOption struct {
	Timeout time.Duration
}

func NewDefaultRecvOption

func NewDefaultRecvOption() *RecvOption

type TCPAddr

type TCPAddr struct {
	Addr string
}

func (TCPAddr) Network

func (l TCPAddr) Network() string

func (TCPAddr) String

func (l TCPAddr) String() string