(envelope Envelope, err error)
| 1344 | } |
| 1345 | |
| 1346 | func (r *Router) warnChannelPolicyFallback(envelope Envelope, err error) { |
| 1347 | if r == nil || r.logger == nil || err == nil { |
| 1348 | return |
| 1349 | } |
| 1350 | r.logger.Warn( |
| 1351 | "network.router.channel_policy_lookup_failed", |
| 1352 | "error", err, |
| 1353 | "workspace_id", envelope.WorkspaceID, |
| 1354 | "channel", envelope.Channel, |
| 1355 | "thread_id", normalizeOptionalIdentifier(envelope.ThreadID), |
| 1356 | "fallback_policy", store.NetworkFanoutPolicyCapabilityMatch, |
| 1357 | ) |
| 1358 | } |
| 1359 | |
| 1360 | type selectedThreadPeers struct { |
| 1361 | peers []LocalPeer |
no test coverage detected