common

Documentation

Index

• Constants
• func HumanFriendlyTraffic(bytes uint64) string
• func Must(err error)
• func Must2(_ interface{}, err error)
• func PickPort(network string, host string) int
• type Error
  • func NewError(info string) *Error
  • func (e *Error) Base(err error) *Error
  • func (e *Error) Error() string
• type RewindConn
  • func NewRewindConn(conn net.Conn) *RewindConn
  • func (c *RewindConn) Read(p []byte) (int, error)
• type RewindReader
  • func (r *RewindReader) Discard(n int) (int, error)
  • func (r *RewindReader) Read(p []byte) (int, error)
  • func (r *RewindReader) ReadByte() (byte, error)
  • func (r *RewindReader) Rewind()
  • func (r *RewindReader) SetBufferSize(size int)
  • func (r *RewindReader) StopBuffering()
• type StickyWriter
  • func (w *StickyWriter) Write(p []byte) (int, error)

Constants

const (
	KiB = 1024
	MiB = KiB * 1024
	GiB = MiB * 1024
)

Functions

func HumanFriendlyTraffic

func HumanFriendlyTraffic(bytes uint64) string

func Must

func Must(err error)

func Must2

func Must2(_ interface{}, err error)

func PickPort

func PickPort(network string, host string) int

Types

type Error

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

func NewError

func NewError(info string) *Error

func (*Error) Base

func (e *Error) Base(err error) *Error

func (*Error) Error

func (e *Error) Error() string

type RewindConn

type RewindConn struct {
	net.Conn
	*RewindReader
}

func NewRewindConn

func NewRewindConn(conn net.Conn) *RewindConn

func (*RewindConn) Read

func (c *RewindConn) Read(p []byte) (int, error)

type RewindReader

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

func (*RewindReader) Discard

func (r *RewindReader) Discard(n int) (int, error)

func (*RewindReader) Read

func (r *RewindReader) Read(p []byte) (int, error)

func (*RewindReader) ReadByte

func (r *RewindReader) ReadByte() (byte, error)

func (*RewindReader) Rewind

func (r *RewindReader) Rewind()

func (*RewindReader) SetBufferSize

func (r *RewindReader) SetBufferSize(size int)

func (*RewindReader) StopBuffering

func (r *RewindReader) StopBuffering()

type StickyWriter

type StickyWriter struct {
	MaxBuffered int
	// contains filtered or unexported fields
}

func (*StickyWriter) Write

func (w *StickyWriter) Write(p []byte) (int, error)