rw

Documentation

Index

• Constants
• type Closer
• type HttpWriter
  • func NewHttpReaderWriter(w http.ResponseWriter, r io.ReadCloser) *HttpWriter
  • func (c *HttpWriter) Close() error
  • func (*HttpWriter) Name() string
  • func (c *HttpWriter) Write(buf []byte) (n int, err error)
• type ReaderCloser
• type ReaderWriterCloser
• type TcpReaderWriter
  • func NewTcpReaderWriter(conn net.Conn) *TcpReaderWriter
  • func (c *TcpReaderWriter) Close() error
  • func (*TcpReaderWriter) Name() string
  • func (c *TcpReaderWriter) Read(buf []byte) (n int, err error)
  • func (c *TcpReaderWriter) Write(buf []byte) (n int, err error)
• type UdpReaderWriter
  • func NewUdpReaderWriter(addr *net.UDPAddr, conn *net.UDPConn) *UdpReaderWriter
  • func (c *UdpReaderWriter) Close() error
  • func (w *UdpReaderWriter) Handle()
  • func (*UdpReaderWriter) Name() string
  • func (c *UdpReaderWriter) Read(buf []byte) (n int, err error)
  • func (c *UdpReaderWriter) Write(buf []byte) (n int, err error)
• type WriterCloser
• type WsReaderWriter
  • func NewWsReaderWriter(conn *websocket.Conn) *WsReaderWriter
  • func (c *WsReaderWriter) Close() error
  • func (*WsReaderWriter) Name() string
  • func (c *WsReaderWriter) Read(buf []byte) (n int, err error)
  • func (c *WsReaderWriter) Write(buf []byte) (n int, err error)

Constants

const (
	ProtocolTCP  = "tcp"
	ProtocolUDP  = "udp"
	ProtocolWS   = "ws"
	ProtocolHttp = "http"
)

Types

type Closer

type Closer interface {
	Close() error
}

type HttpWriter

type HttpWriter struct {
	io.ReadCloser
	// contains filtered or unexported fields
}

func NewHttpReaderWriter

func NewHttpReaderWriter(w http.ResponseWriter, r io.ReadCloser) *HttpWriter

func (*HttpWriter) Close

func (c *HttpWriter) Close() error

func (*HttpWriter) Name

func (*HttpWriter) Name() string

func (*HttpWriter) Write

func (c *HttpWriter) Write(buf []byte) (n int, err error)

type ReaderCloser

type ReaderCloser interface {
	Closer
	Read([]byte) (int, error)
}

type ReaderWriterCloser

type ReaderWriterCloser interface {
	Closer
	Read([]byte) (int, error)
	Write([]byte) (int, error)
	Name() string
}

type TcpReaderWriter

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

func NewTcpReaderWriter

func NewTcpReaderWriter(conn net.Conn) *TcpReaderWriter

func (*TcpReaderWriter) Close

func (c *TcpReaderWriter) Close() error

func (*TcpReaderWriter) Name

func (*TcpReaderWriter) Name() string

func (*TcpReaderWriter) Read

func (c *TcpReaderWriter) Read(buf []byte) (n int, err error)

func (*TcpReaderWriter) Write

func (c *TcpReaderWriter) Write(buf []byte) (n int, err error)

type UdpReaderWriter

type UdpReaderWriter struct {
	sync.Mutex

	BufferChan chan []byte

	Closed bool
	// contains filtered or unexported fields
}

func NewUdpReaderWriter

func NewUdpReaderWriter(addr *net.UDPAddr, conn *net.UDPConn) *UdpReaderWriter

func (*UdpReaderWriter) Close

func (c *UdpReaderWriter) Close() error

func (*UdpReaderWriter) Handle

func (w *UdpReaderWriter) Handle()

func (*UdpReaderWriter) Name

func (*UdpReaderWriter) Name() string

func (*UdpReaderWriter) Read

func (c *UdpReaderWriter) Read(buf []byte) (n int, err error)

func (*UdpReaderWriter) Write

func (c *UdpReaderWriter) Write(buf []byte) (n int, err error)

type WriterCloser

type WriterCloser interface {
	Closer
	Write([]byte) (int, error)
}

type WsReaderWriter

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

func NewWsReaderWriter

func NewWsReaderWriter(conn *websocket.Conn) *WsReaderWriter

func (*WsReaderWriter) Close

func (c *WsReaderWriter) Close() error

func (*WsReaderWriter) Name

func (*WsReaderWriter) Name() string

func (*WsReaderWriter) Read

func (c *WsReaderWriter) Read(buf []byte) (n int, err error)

func (*WsReaderWriter) Write

func (c *WsReaderWriter) Write(buf []byte) (n int, err error)