(value int)
| 53 | } |
| 54 | |
| 55 | func SetRetentionSeconds(value int) { |
| 56 | normalized := int64(value) |
| 57 | if normalized <= 0 { |
| 58 | normalized = defaultRetentionSeconds |
| 59 | } else if normalized > maxRetentionSeconds { |
| 60 | normalized = maxRetentionSeconds |
| 61 | } |
| 62 | retentionSeconds.Store(normalized) |
| 63 | } |
| 64 | |
| 65 | func Enqueue(payload []byte) { |
| 66 | if !Enabled() { |
no outgoing calls
no test coverage detected