common

Documentation

Index

• Constants
• func GetProgramDir() string
• func HumanFriendlyTraffic(bytes uint64) string
• func Must(err error)
• func Must2(_ interface{}, err error)
• func ReadByte(r io.Reader) (byte, error)
• func RegisterOptionHandler(h OptionHandler)
• type Address
  • func NewAddress(host string, port int, network string) *Address
  • func (a *Address) Network() string
  • func (a *Address) ResolveIP(preferV4 bool) (net.IP, error)
  • func (a *Address) String() string
• type AddressType
• type Error
  • func NewError(info string) *Error
  • func (e *Error) Base(err error) *Error
  • func (e *Error) Error() string
• type OptionHandler
  • func PopOptionHandler() (OptionHandler, error)
• type RewindConn
  • func NewRewindConn(conn net.Conn) *RewindConn
  • func (c *RewindConn) Read(p []byte) (int, error)
• type RewindReadWriteCloser
  • func NewRewindReadWriteCloser(rwc io.ReadWriteCloser) *RewindReadWriteCloser
  • func (rwc *RewindReadWriteCloser) Close() error
  • func (rwc *RewindReadWriteCloser) Write(p []byte) (int, error)
• type RewindReader
  • func NewRewindReader(r io.Reader) *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 Runnable

Constants

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

const (
	Version = "v0.0.2"
)

Functions

func GetProgramDir

func GetProgramDir() string

func HumanFriendlyTraffic

func HumanFriendlyTraffic(bytes uint64) string

func Must

func Must(err error)

func Must2

func Must2(_ interface{}, err error)

func ReadByte

func ReadByte(r io.Reader) (byte, error)

func RegisterOptionHandler

func RegisterOptionHandler(h OptionHandler)

Types

type Address

type Address struct {
	net.Addr

	DomainName  string
	IP          net.IP
	Port        int
	NetworkType string
	AddressType
}

func NewAddress

func NewAddress(host string, port int, network string) *Address

func (*Address) Network

func (a *Address) Network() string

func (*Address) ResolveIP

func (a *Address) ResolveIP(preferV4 bool) (net.IP, error)

func (*Address) String

func (a *Address) String() string

type AddressType

type AddressType byte

const (
	IPv4       AddressType = 1
	DomainName AddressType = 3
	IPv6       AddressType = 4
)

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 OptionHandler

type OptionHandler interface {
	Name() string
	Handle() error
	Priority() int
}

func PopOptionHandler

func PopOptionHandler() (OptionHandler, error)

type RewindConn

type RewindConn struct {
	R *RewindReader
	net.Conn
}

func NewRewindConn

func NewRewindConn(conn net.Conn) *RewindConn

func (*RewindConn) Read

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

type RewindReadWriteCloser

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

func NewRewindReadWriteCloser

func NewRewindReadWriteCloser(rwc io.ReadWriteCloser) *RewindReadWriteCloser

func (*RewindReadWriteCloser) Close

func (rwc *RewindReadWriteCloser) Close() error

func (*RewindReadWriteCloser) Write

func (rwc *RewindReadWriteCloser) Write(p []byte) (int, error)

type RewindReader

type RewindReader struct {
	io.Reader
	io.ByteReader
	// contains filtered or unexported fields
}

func NewRewindReader

func NewRewindReader(r io.Reader) *RewindReader

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 Runnable

type Runnable interface {
	Run() error
	Close() error
}