io

Documentation

Index

• type CloudHubIO
• type JSONIO
  • func (io *JSONIO) Close() error
  • func (io *JSONIO) ReadData(msg *model.Message) (int, error)
  • func (io *JSONIO) SetReadDeadline(time time.Time) error
  • func (io *JSONIO) SetWriteDeadline(time time.Time) error
  • func (io *JSONIO) WriteData(msg *model.Message) error

Types

type CloudHubIO

type CloudHubIO interface {
	SetReadDeadline(time.Time) error
	SetWriteDeadline(time.Time) error
	ReadData(*model.Message) (int, error)
	WriteData(*model.Message) error
	Close() error
}

CloudHubIO handle the IO operation from connection

type JSONIO

type JSONIO struct {
	Connection conn.Connection
}

JSONIO address the json data from connection

func (*JSONIO) Close

func (io *JSONIO) Close() error

Close close the IO operation

func (*JSONIO) ReadData

func (io *JSONIO) ReadData(msg *model.Message) (int, error)

ReadData read data from connection

func (*JSONIO) SetReadDeadline

func (io *JSONIO) SetReadDeadline(time time.Time) error

SetReadDeadline set read operation dead line

func (*JSONIO) SetWriteDeadline

func (io *JSONIO) SetWriteDeadline(time time.Time) error

SetWriteDeadline set write operation dead line

func (*JSONIO) WriteData

func (io *JSONIO) WriteData(msg *model.Message) error

WriteData write data to connection