-
Notifications
You must be signed in to change notification settings - Fork 7
/
examples_test.go
47 lines (42 loc) · 1.13 KB
/
examples_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
package pgq_test
import (
"context"
"database/sql"
"log/slog"
"os"
"time"
"go.dataddo.com/pgq"
"go.opentelemetry.io/otel/metric/noop"
)
var db *sql.DB
func ExampleNewConsumer() {
slogger := slog.New(slog.NewTextHandler(os.Stdout, &slog.HandlerOptions{Level: slog.LevelDebug}))
c, err := pgq.NewConsumer(db, "queue_name", &Handler{},
pgq.WithLockDuration(10*time.Minute),
pgq.WithPollingInterval(500*time.Millisecond),
pgq.WithAckTimeout(5*time.Second),
pgq.WithMessageProcessingReserveDuration(5*time.Second),
pgq.WithMaxParallelMessages(42),
pgq.WithMetrics(noop.Meter{}),
pgq.WithHistoryLimit(24*time.Hour),
pgq.WithLogger(slogger),
pgq.WithInvalidMessageCallback(func(ctx context.Context, msg pgq.InvalidMessage, err error) {
// message Payload and/or Metadata are not JSON object.
// The message will be discarded.
slogger.Warn("invalid message",
"error", err,
"msg.id", msg.ID,
)
}),
)
_, _ = c, err
}
func ExampleNewPublisher() {
hostname, _ := os.Hostname()
p := pgq.NewPublisher(db,
pgq.WithMetaInjectors(
pgq.StaticMetaInjector(pgq.Metadata{"publisher-id": hostname}),
),
)
_ = p
}