Repository navigation
RiverClient Init. Syntax Err #508
Description
I followd the documentation and wrote a sample code.
riverClient, err := river.NewClient(riverpgxv5.New(dbPool), &river.Config{
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 100},
},
Workers: workers,
})
but this is showing syntax err.
and i had to change to below with passing a type.
riverClient, err := river.NewClient[pgx.Tx](riverpgxv5.New(dbPool), &river.Config{
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 100},
},
})
Is there any version issue here ?
Activity
ciokan commentedon Aug 6, 2024
Same with the
AddWorkercode. I had to change the official example fromriver.AddWorker(workers, &SortWorker{})toriver.AddWorker[SortArgs](workers, &SortWorker{})