network

Documentation

Index

• func ManagedConnectionCaller(handler interface{}, params ...interface{})
• type BufferedConnectionEvents
• type ManagedConnection
  • func NewManagedConnection(conn net.Conn) *ManagedConnection
  • func (mc *ManagedConnection) Close() error
  • func (mc *ManagedConnection) LocalAddr() net.Addr
  • func (mc *ManagedConnection) Read(receiveBuffer []byte) (n int, err error)
  • func (mc *ManagedConnection) RemoteAddr() net.Addr
  • func (mc *ManagedConnection) SetDeadline(t time.Time) error
  • func (mc *ManagedConnection) SetReadDeadline(t time.Time) error
  • func (mc *ManagedConnection) SetReadTimeout(d time.Duration) error
  • func (mc *ManagedConnection) SetTimeout(d time.Duration) error
  • func (mc *ManagedConnection) SetWriteDeadline(t time.Time) error
  • func (mc *ManagedConnection) SetWriteTimeout(d time.Duration) error
  • func (mc *ManagedConnection) Write(data []byte) (n int, err error)

Functions

func ManagedConnectionCaller

func ManagedConnectionCaller(handler interface{}, params ...interface{})

Types

type BufferedConnectionEvents

type BufferedConnectionEvents struct {
	ReceiveData *events.Event
	Close       *events.Event
	Error       *events.Event
}

type ManagedConnection

type ManagedConnection struct {
	Conn   net.Conn
	Events BufferedConnectionEvents

	BytesRead    int
	BytesWritten int
	// contains filtered or unexported fields
}

func NewManagedConnection

func NewManagedConnection(conn net.Conn) *ManagedConnection

func (*ManagedConnection) Close

func (mc *ManagedConnection) Close() error

func (*ManagedConnection) LocalAddr

func (mc *ManagedConnection) LocalAddr() net.Addr

func (*ManagedConnection) Read

func (mc *ManagedConnection) Read(receiveBuffer []byte) (n int, err error)

func (*ManagedConnection) RemoteAddr

func (mc *ManagedConnection) RemoteAddr() net.Addr

func (*ManagedConnection) SetDeadline

func (mc *ManagedConnection) SetDeadline(t time.Time) error

func (*ManagedConnection) SetReadDeadline

func (mc *ManagedConnection) SetReadDeadline(t time.Time) error

func (*ManagedConnection) SetReadTimeout

func (mc *ManagedConnection) SetReadTimeout(d time.Duration) error

func (*ManagedConnection) SetTimeout

func (mc *ManagedConnection) SetTimeout(d time.Duration) error

func (*ManagedConnection) SetWriteDeadline

func (mc *ManagedConnection) SetWriteDeadline(t time.Time) error

func (*ManagedConnection) SetWriteTimeout

func (mc *ManagedConnection) SetWriteTimeout(d time.Duration) error

func (*ManagedConnection) Write

func (mc *ManagedConnection) Write(data []byte) (n int, err error)