NetworkStatusPayloadFromStatus converts the runtime network status snapshot into the shared payload.
(status *network.Status)
| 302 | |
| 303 | // NetworkStatusPayloadFromStatus converts the runtime network status snapshot into the shared payload. |
| 304 | func NetworkStatusPayloadFromStatus(status *network.Status) *contract.NetworkStatusPayload { |
| 305 | if status == nil { |
| 306 | return nil |
| 307 | } |
| 308 | |
| 309 | kindMetrics := make([]contract.NetworkKindMetricPayload, 0, len(status.KindMetrics)) |
| 310 | for _, metric := range status.KindMetrics { |
| 311 | kindMetrics = append(kindMetrics, contract.NetworkKindMetricPayload{ |
| 312 | Kind: string(metric.Kind), |
| 313 | Sent: metric.Sent, |
| 314 | Received: metric.Received, |
| 315 | Rejected: metric.Rejected, |
| 316 | Delivered: metric.Delivered, |
| 317 | }) |
| 318 | } |
| 319 | |
| 320 | return &contract.NetworkStatusPayload{ |
| 321 | Enabled: status.Enabled, |
| 322 | Status: strings.TrimSpace(status.Status), |
| 323 | ListenerHost: strings.TrimSpace(status.ListenerHost), |
| 324 | ListenerPort: status.ListenerPort, |
| 325 | LocalPeers: status.LocalPeers, |
| 326 | RemotePeers: status.RemotePeers, |
| 327 | Channels: status.Channels, |
| 328 | QueuedMessages: status.QueuedMessages, |
| 329 | QueuedSessions: status.QueuedSessions, |
| 330 | DeliveryWorkers: status.DeliveryWorkers, |
| 331 | MessagesSent: status.MessagesSent, |
| 332 | MessagesReceived: status.MessagesReceived, |
| 333 | MessagesRejected: status.MessagesRejected, |
| 334 | MessagesDelivered: status.MessagesDelivered, |
| 335 | WorkflowTaggedEvents: status.WorkflowTaggedEvents, |
| 336 | HandoffTaggedEvents: status.HandoffTaggedEvents, |
| 337 | OpenThreads: status.OpenThreads, |
| 338 | OpenDirectRooms: status.OpenDirectRooms, |
| 339 | OpenWorkItems: status.OpenWorkItems, |
| 340 | ConversationMessages: status.ConversationMessages, |
| 341 | WorkTransitions: status.WorkTransitions, |
| 342 | DirectResolves: status.DirectResolves, |
| 343 | LastDisconnect: strings.TrimSpace(status.LastDisconnect), |
| 344 | KindMetrics: kindMetrics, |
| 345 | } |
| 346 | } |
| 347 | |
| 348 | // NetworkSendRequestFromPayload validates and converts one shared send payload into the runtime request. |
| 349 | func NetworkSendRequestFromPayload(req contract.NetworkSendRequest) (network.SendRequest, error) { |