wrapper

Documentation

Index

• type Conn
  • func NewWrapper(connType string, conn interface{}, buffSize int) Conn
• type ConnWrapper
  • func (w *ConnWrapper) Close() error
  • func (w *ConnWrapper) Read() ([]byte, error)
  • func (w *ConnWrapper) ReadJSON(obj interface{}) error
  • func (w *ConnWrapper) SetReadDeadline(t time.Time) error
  • func (w *ConnWrapper) Write(message []byte) error
  • func (w *ConnWrapper) WriteJSON(obj interface{}) error

Types

type Conn

type Conn interface {
	Read() ([]byte, error)
	Write(message []byte) error

	ReadJSON(obj interface{}) error
	WriteJSON(obj interface{}) error

	Close() error

	SetReadDeadline(t time.Time) error
}

Conn conn

func NewWrapper

func NewWrapper(connType string, conn interface{}, buffSize int) Conn

NewWrapper new wrapper

type ConnWrapper

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

ConnWrapper conn wrapper

func (*ConnWrapper) Close

func (w *ConnWrapper) Close() error

Close close

func (*ConnWrapper) Read

func (w *ConnWrapper) Read() ([]byte, error)

Read read

func (*ConnWrapper) ReadJSON

func (w *ConnWrapper) ReadJSON(obj interface{}) error

ReadJSON read json

func (*ConnWrapper) SetReadDeadline

func (w *ConnWrapper) SetReadDeadline(t time.Time) error

SetReadDeadline set read deadline

func (*ConnWrapper) Write

func (w *ConnWrapper) Write(message []byte) error

Write write

func (*ConnWrapper) WriteJSON

func (w *ConnWrapper) WriteJSON(obj interface{}) error

WriteJSON write json