util

Documentation

Index

• func GetTCPAndUDPPort() (string, error)
• func GetTCPPort() (string, error)
• func HumanizeBytes(s float64) string
• func IsHttp4xxError(resp *http.Response) bool
• func NewFinishableReader(r io.Reader, finishCh <-chan struct{}) io.Reader
• func NewRateLimitReader(r io.Reader, bytePerSec int) io.Reader
• type FinishableReader
  • func (r *FinishableReader) Read(p []byte) (int, error)
• type PortPool
  • func NewPortPool() *PortPool
  • func (p *PortPool) GetAndReserve() (string, error)
  • func (p *PortPool) Release(port string)
• type RateLimitReader
  • func (r *RateLimitReader) Read(p []byte) (int, error)

Functions

func GetTCPAndUDPPort

func GetTCPAndUDPPort() (string, error)

func GetTCPPort

func GetTCPPort() (string, error)

func HumanizeBytes

func HumanizeBytes(s float64) string

(base: https://github.com/schollz/progressbar/blob/9c6973820b2153b15d2e6a08d8705ec981fda59f/progressbar.go#L784-L799)

func IsHttp4xxError

func IsHttp4xxError(resp *http.Response) bool

func NewFinishableReader

func NewFinishableReader(r io.Reader, finishCh <-chan struct{}) io.Reader

func NewRateLimitReader

func NewRateLimitReader(r io.Reader, bytePerSec int) io.Reader

Types

type FinishableReader

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

func (*FinishableReader) Read

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

type PortPool

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

func NewPortPool

func NewPortPool() *PortPool

func (*PortPool) GetAndReserve

func (p *PortPool) GetAndReserve() (string, error)

func (*PortPool) Release

func (p *PortPool) Release(port string)

type RateLimitReader

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

func (*RateLimitReader) Read

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