connect

Documentation

Index

• type Conn
• type Messenger
  • func (m *Messenger) Ask(request []byte, response []byte) (int, error)
  • func (m *Messenger) AskAtLeast(request []byte, response []byte, min int) (int, error)
  • func (m *Messenger) Read(response []byte) (int, error)
  • func (m *Messenger) ReadAtLeast(response []byte, min int) (int, error)
• type NetConn
  • func (c *NetConn) SetReadTimeout(t time.Duration) error

Types

type Conn

type Conn interface {
	io.ReadWriteCloser
	SetReadTimeout(t time.Duration) error
}

type Messenger

type Messenger struct {
	Conn

	Timeout time.Duration
	// contains filtered or unexported fields
}

func (*Messenger) Ask

func (m *Messenger) Ask(request []byte, response []byte) (int, error)

func (*Messenger) AskAtLeast

func (m *Messenger) AskAtLeast(request []byte, response []byte, min int) (int, error)

func (*Messenger) Read

func (m *Messenger) Read(response []byte) (int, error)

func (*Messenger) ReadAtLeast

func (m *Messenger) ReadAtLeast(response []byte, min int) (int, error)

type NetConn

type NetConn struct {
	net.Conn
}

func (*NetConn) SetReadTimeout

func (c *NetConn) SetReadTimeout(t time.Duration) error