backedtcp

Documentation

Index

• type Socket
  • func NewSocket(getWire func() (net.Conn, error)) *Socket
  • func (sock *Socket) Close() (err error)
  • func (sock *Socket) LocalAddr() net.Addr
  • func (sock *Socket) Read(p []byte) (n int, err error)
  • func (sock *Socket) RemoteAddr() net.Addr
  • func (sock *Socket) Reset() (err error)
  • func (sock *Socket) SetDeadline(t time.Time) error
  • func (sock *Socket) SetReadDeadline(t time.Time) error
  • func (sock *Socket) SetWriteDeadline(t time.Time) error
  • func (sock *Socket) Write(p []byte) (n int, err error)

Types

type Socket

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

Socket represents a single BackedTCP connection

func NewSocket

func NewSocket(getWire func() (net.Conn, error)) *Socket

NewSocket constructs a new BackedTCP connection.

func (*Socket) Close

func (sock *Socket) Close() (err error)

Close closes the socket.

func (*Socket) LocalAddr

func (sock *Socket) LocalAddr() net.Addr

func (*Socket) Read

func (sock *Socket) Read(p []byte) (n int, err error)

func (*Socket) RemoteAddr

func (sock *Socket) RemoteAddr() net.Addr

func (*Socket) Reset

func (sock *Socket) Reset() (err error)

Reset forces the socket to discard its underlying connection and reconnect.

func (*Socket) SetDeadline

func (sock *Socket) SetDeadline(t time.Time) error

func (*Socket) SetReadDeadline

func (sock *Socket) SetReadDeadline(t time.Time) error

func (*Socket) SetWriteDeadline

func (sock *Socket) SetWriteDeadline(t time.Time) error

func (*Socket) Write

func (sock *Socket) Write(p []byte) (n int, err error)