RecordPubSubMessage records a Pub/Sub message direction: "sent" or "received" channel: channel name (may be hidden for cardinality reduction) sharded: true for sharded pub/sub (SPUBLISH/SSUBSCRIBE)
(ctx context.Context, cn *pool.Conn, direction, channel string, sharded bool)
| 78 | // channel: channel name (may be hidden for cardinality reduction) |
| 79 | // sharded: true for sharded pub/sub (SPUBLISH/SSUBSCRIBE) |
| 80 | RecordPubSubMessage(ctx context.Context, cn *pool.Conn, direction, channel string, sharded bool) |
| 81 | |
| 82 | // RecordStreamLag records the lag for stream consumer group processing |
| 83 | // lag: time difference between message creation and consumption |
no outgoing calls
no test coverage detected