| 279 | // struct's pointer-scan region. |
| 280 | stallSince time.Time |
| 281 | |
| 282 | connID string |
| 283 | txName, rxName string |
| 284 | |
| 285 | rxSeq uint64 // next contiguous sequence expected |
| 286 | } |
| 287 | |
| 288 | // encodeQueueMessage prepends the big-endian sequence to raw and base64-encodes |
| 289 | // the result for transport in a single queue message. |
| 290 | func encodeQueueMessage(seq uint64, raw []byte) string { |
| 291 | msg := make([]byte, seqHeaderSize+len(raw)) |
| 292 | binary.BigEndian.PutUint64(msg[:seqHeaderSize], seq) |
| 293 | copy(msg[seqHeaderSize:], raw) |