generic

Documentation

Index

• func CopyBuffer(dst io.Writer, src io.Reader, buf []byte) (written int64, err error)
• func SnmpLogger(path string, interval int)
• type CompStream
  • func NewCompStream(conn net.Conn) *CompStream
  • func (c *CompStream) Close() error
  • func (c *CompStream) LocalAddr() net.Addr
  • func (c *CompStream) Read(p []byte) (n int, err error)
  • func (c *CompStream) RemoteAddr() net.Addr
  • func (c *CompStream) SetDeadline(t time.Time) error
  • func (c *CompStream) SetReadDeadline(t time.Time) error
  • func (c *CompStream) SetWriteDeadline(t time.Time) error
  • func (c *CompStream) Write(p []byte) (n int, err error)
• type Mux
• type Stream

Functions

func CopyBuffer

func CopyBuffer(dst io.Writer, src io.Reader, buf []byte) (written int64, err error)

io.CopyBuffer has extra tests for interface like io.ReaderFrom and io.WriterTo which is not efficient in memory management from tests

func SnmpLogger

func SnmpLogger(path string, interval int)

Types

type CompStream

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

func NewCompStream

func NewCompStream(conn net.Conn) *CompStream

func (*CompStream) Close

func (c *CompStream) Close() error

func (*CompStream) LocalAddr

func (c *CompStream) LocalAddr() net.Addr

func (*CompStream) Read

func (c *CompStream) Read(p []byte) (n int, err error)

func (*CompStream) RemoteAddr

func (c *CompStream) RemoteAddr() net.Addr

func (*CompStream) SetDeadline

func (c *CompStream) SetDeadline(t time.Time) error

func (*CompStream) SetReadDeadline

func (c *CompStream) SetReadDeadline(t time.Time) error

func (*CompStream) SetWriteDeadline

func (c *CompStream) SetWriteDeadline(t time.Time) error

func (*CompStream) Write

func (c *CompStream) Write(p []byte) (n int, err error)

type Mux

type Mux interface {
	Open() (io.ReadWriteCloser, error)
	Accept() (io.ReadWriteCloser, error)
	IsClosed() bool
	NumStreams() int
	RemoteAddr() net.Addr
	Close() error
}

type Stream

type Stream interface {
	io.ReadWriteCloser
	ID() uint32
	RemoteAddr() net.Addr
}