util

Documentation

Index

• 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

Functions

func BandwidthMeasurementClient

func BandwidthMeasurementClient(conn net.Conn, bytesDownlink int, timeout time.Duration) (float32, float32, error)

func BandwidthMeasurementClientContext

func BandwidthMeasurementClientContext(ctx context.Context, conn net.Conn, bytesDownlink int, timeout time.Duration) (float32, float32, error)

func BandwidthMeasurementServer

func BandwidthMeasurementServer(conn net.Conn, bytesDownlink int, timeout time.Duration) error

func BandwidthMeasurementServerContext

func BandwidthMeasurementServerContext(ctx context.Context, conn net.Conn, bytesDownlink int, timeout time.Duration) error

func CopyFile

func CopyFile(src, dst string) error

func DeepCopyMap

func DeepCopyMap(value map[string]interface{}) map[string]interface{}

func DelayMeasurement

func DelayMeasurement(network, address string, timeout time.Duration) (time.Duration, error)

func DelayMeasurementContext

func DelayMeasurementContext(ctx context.Context, network, address string, timeout time.Duration) (time.Duration, error)

func DownloadJsonFile

func DownloadJsonFile(ctx context.Context, url, filename string) error

func Enqueue

func Enqueue(jobChan chan<- Job, job Job)

func Exists

func Exists(path string) bool

func Process

func Process(job Job, wg *sync.WaitGroup)

func ReadJSON

func ReadJSON(fileName string, value interface{}) error

func WorkPool

func WorkPool(workerNum int, jobChan chan Job, wg *sync.WaitGroup)

func Worker

func Worker(jobChan <-chan Job, wg *sync.WaitGroup)

func WriteJSON

func WriteJSON(path string, data interface{}) error

Types

type Job

type Job func()