Allow for maps instead of interfaces for worker functions about goworker HOT 3 CLOSED

func(queue string, args ...interface{}) error{
    files, ok := args[0].(map[string]string)
    if !ok {
      // error
    }
    productFile := os.Open(files["product_file"])
    // more things done here
    return nil
}

func newMapFunc(f func(queue string, args map[string]interface{}) error) (func(queue string, args ...interface{}) error) {
    return func(queue string, args ...interface{}) error {
        if len(args) != 1 {
            // return some error
        }
        mapArgs, ok := args[0].(map[string]interface{})
        if !ok {
            // return some error
        }
        return f(mapArgs)
    }
}

// ...

func someWorker(queue string, args map[string]interface) error{
    path, ok := args["product_file"].(string)
    if !ok {
        // return some error
    }
    productFile := os.Open(path)
    // more things done here
    return nil
}

// ...

goworker.Register("MyClass", newMapFunc(someWorker))
goworker.Register("MyOtherClass", newMapFunc(someOtherWorker))