Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion example_batch_insert_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,8 @@ func Example_batchInsert() {
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 100},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down
3 changes: 2 additions & 1 deletion example_complete_job_within_tx_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,8 @@ func Example_completeJobWithinTx() {
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 100},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down
3 changes: 2 additions & 1 deletion example_cron_job_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,8 @@ func Example_cronJob() {
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 100},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down
3 changes: 2 additions & 1 deletion example_custom_insert_opts_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,8 @@ func Example_customInsertOpts() {
river.QueueDefault: {MaxWorkers: 100},
"high_priority": {MaxWorkers: 100},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down
3 changes: 2 additions & 1 deletion example_error_handler_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,8 @@ func Example_errorHandler() {
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 10},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down
3 changes: 2 additions & 1 deletion example_graceful_shutdown_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,8 @@ func Example_gracefulShutdown() {
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 100},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down
3 changes: 2 additions & 1 deletion example_insert_and_work_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,8 @@ func Example_insertAndWork() {
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 100},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down
3 changes: 2 additions & 1 deletion example_job_cancel_from_client_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,8 @@ func Example_jobCancelFromClient() {
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 10},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down
3 changes: 2 additions & 1 deletion example_job_cancel_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,8 @@ func Example_jobCancel() { //nolint:dupl
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 10},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down
3 changes: 2 additions & 1 deletion example_job_snooze_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,8 @@ func Example_jobSnooze() { //nolint:dupl
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 10},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down
3 changes: 2 additions & 1 deletion example_periodic_job_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,8 @@ func Example_periodicJob() {
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 100},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down
3 changes: 2 additions & 1 deletion example_queue_pause_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,8 @@ func Example_queuePause() {
unreliableQueue: {MaxWorkers: 10},
reliableQueue: {MaxWorkers: 10},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down
3 changes: 2 additions & 1 deletion example_scheduled_job_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,8 @@ func Example_scheduledJob() {
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 100},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down
3 changes: 2 additions & 1 deletion example_subscription_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,8 @@ func Example_subscription() {
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 100},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down
3 changes: 2 additions & 1 deletion example_unique_job_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,8 @@ func Example_uniqueJob() {
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 100},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down
3 changes: 2 additions & 1 deletion example_work_func_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,8 @@ func Example_workFunc() {
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: 100},
},
Workers: workers,
TestOnly: true, // suitable only for use in tests; remove for live environments
Workers: workers,
})
if err != nil {
panic(err)
Expand Down