std

Documentation

Index

• Constants
• func Copy(dst io.Writer, src io.Reader) (written int64, err error)
• func Pipe(alice, bob io.ReadWriteCloser, closeWait int) (errA, errB 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 MultiPort
  • func ParseMultiPort(addr string) (*MultiPort, error)
• type QPPPort
  • func NewQPPPort(underlying io.ReadWriteCloser, pad *qpp.QuantumPermutationPad, seed []byte) *QPPPort
  • func (r *QPPPort) Close() error
  • func (r *QPPPort) Read(p []byte) (n int, err error)
  • func (r *QPPPort) Write(p []byte) (n int, err error)

Constants

const (
	EXIT_WAIT = 5 // max seconds to wait before exit
)

Functions

func Copy

func Copy(dst io.Writer, src io.Reader) (written int64, err error)

Memory optimized io.Copy function specified for this library

func Pipe

func Pipe(alice, bob io.ReadWriteCloser, closeWait int) (errA, errB error)

Pipe create a general bidirectional pipe between two streams

func SnmpLogger

func SnmpLogger(path string, interval int)

Types

type CompStream

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

CompStream is a net.Conn wrapper that compresses data using snappy

func NewCompStream

func NewCompStream(conn net.Conn) *CompStream

NewCompStream creates a new stream that compresses data using snappy

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 MultiPort

type MultiPort struct {
	Host    string
	MinPort uint64
	MaxPort uint64
}

func ParseMultiPort

func ParseMultiPort(addr string) (*MultiPort, error)

Parse mulitport listener or dialer

type QPPPort

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

QPPPort implements io.ReadWriteCloser interface for Quantum Permutation Pads

func NewQPPPort

func NewQPPPort(underlying io.ReadWriteCloser, pad *qpp.QuantumPermutationPad, seed []byte) *QPPPort

func (*QPPPort) Close

func (r *QPPPort) Close() error

func (*QPPPort) Read

func (r *QPPPort) Read(p []byte) (n int, err error)

func (*QPPPort) Write

func (r *QPPPort) Write(p []byte) (n int, err error)