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 ?
I followd the documentation and wrote a sample code.
but this is showing syntax err.
and i had to change to below with passing a type.
Is there any version issue here ?