import "github.com/congphan/gobatch/processor"

employees := []employee{
    {
        Age:  50,
        Name: "name A1",
        Job:  "JOB 1",
    },
    {
        Age:  60,
        Name: "name A1",
        Job:  "JOB 2",
    },
    {
        Age:  70,
        Name: "ABC XYZ",
        Job:  "JOB 3",
    },
}

// simulate function to store list of employee to database
storeEmployees := func(s []employee) {
    fmt.Println(s)
}

p, _ := processor.New(2) // separate employees to batch with maximum 2 employees in a batch if enough
err := p.Execute(context.Background(), employees, func(batch processor.Batch) {
    data := batch.Data().([]employee)
    idx := batch.Index()

    fmt.Println("batch index: ", idx)
    storeEmployees(data)
})