(entry store.NetworkChannelEntry)
| 91 | } |
| 92 | |
| 93 | func nativeNetworkChannelPayload(entry store.NetworkChannelEntry) map[string]any { |
| 94 | return map[string]any{ |
| 95 | "channel": strings.TrimSpace(entry.Channel), |
| 96 | "workspace_id": strings.TrimSpace(entry.WorkspaceID), |
| 97 | "purpose": strings.TrimSpace(entry.Purpose), |
| 98 | "fanout_policy": store.NormalizeNetworkFanoutPolicy(entry.FanoutPolicy), |
| 99 | "coordinator_peer_id": strings.TrimSpace(entry.CoordinatorPeerID), |
| 100 | } |
| 101 | } |
| 102 | |
| 103 | func (n *daemonNativeTools) networkChannelUpdate( |
| 104 | ctx context.Context, |
no test coverage detected