parallelxl

package main

import (
	"context"
	"fmt"
	"log"
	"time"

	"github.com/luids-io/api/xlist"
	"github.com/luids-io/xlist/pkg/xlistd"
	"github.com/luids-io/xlist/pkg/xlistd/components/mockxl"
	"github.com/luids-io/xlist/pkg/xlistd/components/parallelxl"
)

func main() {
	ip4 := []xlist.Resource{xlist.IPv4}
	t5ms := 5 * time.Millisecond

	cfg := parallelxl.Config{
		SkipErrors:    true,
		FirstResponse: true,
	}
	childs := []xlistd.List{
		&mockxl.List{Results: []bool{false}, ResourceList: ip4, Reason: "rbl1"},
		&mockxl.List{Results: []bool{true, false}, ResourceList: ip4, Reason: "rbl2"},
		&mockxl.List{Results: []bool{true}, Lazy: t5ms, ResourceList: ip4, Reason: "rbl3"},
		//rbl4 allways fails, but with skiperrors ignores this fail
		&mockxl.List{Fail: true, ResourceList: ip4},
	}

	//constructs parallel rbl
	rbl := parallelxl.New("test", childs, ip4, cfg)
	for i := 0; i < 4; i++ {
		resp, err := rbl.Check(context.Background(), "10.10.10.10", xlist.IPv4)
		if err != nil {
			log.Fatalln("this should not happen")
		}
		fmt.Printf("%v %v\n", resp.Result, resp.Reason)
	}

}

Output:

true rbl2
true rbl3
true rbl2
true rbl3