Versions in this module Expand all Collapse all v1 v1.0.0 Aug 3, 2022 Changes in this version + func BandwidthMeasurementClient(conn net.Conn, bytesDownlink int, timeout time.Duration) (float32, float32, error) + func BandwidthMeasurementClientContext(ctx context.Context, conn net.Conn, bytesDownlink int, timeout time.Duration) (float32, float32, error) + func BandwidthMeasurementServer(conn net.Conn, bytesDownlink int, timeout time.Duration) error + func BandwidthMeasurementServerContext(ctx context.Context, conn net.Conn, bytesDownlink int, timeout time.Duration) error + func CopyFile(src, dst string) error + func DeepCopyMap(value map[string]interface{}) map[string]interface + func DelayMeasurement(network, address string, timeout time.Duration) (time.Duration, error) + func DelayMeasurementContext(ctx context.Context, network, address string, timeout time.Duration) (time.Duration, error) + func DownloadJsonFile(ctx context.Context, url, filename string) error + func Enqueue(jobChan chan<- Job, job Job) + func Exists(path string) bool + func Process(job Job, wg *sync.WaitGroup) + func ReadJSON(fileName string, value interface{}) error + func WorkPool(workerNum int, jobChan chan Job, wg *sync.WaitGroup) + func Worker(jobChan <-chan Job, wg *sync.WaitGroup) + func WriteJSON(path string, data interface{}) error + type Job func()
Go to main page