(info *contract.NetworkStatusPayload)
| 400 | } |
| 401 | |
| 402 | func daemonNetworkStatusFields(info *contract.NetworkStatusPayload) ([]keyValue, []string, []string) { |
| 403 | listener := networkListener(info) |
| 404 | |
| 405 | return []keyValue{ |
| 406 | {Label: "Network", Value: stringOrDash(info.Status)}, |
| 407 | {Label: "Network Listener", Value: stringOrDash(listener)}, |
| 408 | {Label: "Network Local Peers", Value: strconv.Itoa(info.LocalPeers)}, |
| 409 | {Label: "Network Remote Peers", Value: strconv.Itoa(info.RemotePeers)}, |
| 410 | {Label: "Network Channels", Value: strconv.Itoa(info.Channels)}, |
| 411 | {Label: "Network Queued Messages", Value: strconv.Itoa(info.QueuedMessages)}, |
| 412 | {Label: "Network Delivery Workers", Value: strconv.Itoa(info.DeliveryWorkers)}, |
| 413 | {Label: "Network Messages Sent", Value: strconv.FormatInt(info.MessagesSent, 10)}, |
| 414 | {Label: "Network Messages Received", Value: strconv.FormatInt(info.MessagesReceived, 10)}, |
| 415 | {Label: "Network Messages Rejected", Value: strconv.FormatInt(info.MessagesRejected, 10)}, |
| 416 | {Label: "Network Messages Delivered", Value: strconv.FormatInt(info.MessagesDelivered, 10)}, |
| 417 | {Label: "Network Workflow Tagged", Value: strconv.FormatInt(info.WorkflowTaggedEvents, 10)}, |
| 418 | {Label: "Network Handoff Tagged", Value: strconv.FormatInt(info.HandoffTaggedEvents, 10)}, |
| 419 | {Label: "Network Last Disconnect", Value: stringOrDash(info.LastDisconnect)}, |
| 420 | }, []string{ |
| 421 | "network_status", |
| 422 | "network_listener", |
| 423 | "network_local_peers", |
| 424 | "network_remote_peers", |
| 425 | "network_channels", |
| 426 | "network_queued_messages", |
| 427 | "network_delivery_workers", |
| 428 | "network_messages_sent", |
| 429 | "network_messages_received", |
| 430 | "network_messages_rejected", |
| 431 | "network_messages_delivered", |
| 432 | "network_workflow_tagged_events", |
| 433 | "network_handoff_tagged_events", |
| 434 | "network_last_disconnect", |
| 435 | }, []string{ |
| 436 | info.Status, |
| 437 | listener, |
| 438 | strconv.Itoa(info.LocalPeers), |
| 439 | strconv.Itoa(info.RemotePeers), |
| 440 | strconv.Itoa(info.Channels), |
| 441 | strconv.Itoa(info.QueuedMessages), |
| 442 | strconv.Itoa(info.DeliveryWorkers), |
| 443 | strconv.FormatInt(info.MessagesSent, 10), |
| 444 | strconv.FormatInt(info.MessagesReceived, 10), |
| 445 | strconv.FormatInt(info.MessagesRejected, 10), |
| 446 | strconv.FormatInt(info.MessagesDelivered, 10), |
| 447 | strconv.FormatInt(info.WorkflowTaggedEvents, 10), |
| 448 | strconv.FormatInt(info.HandoffTaggedEvents, 10), |
| 449 | info.LastDisconnect, |
| 450 | } |
| 451 | } |
| 452 | |
| 453 | func daemonNetworkStatusFromInfo(cfg *aghconfig.Config, info *aghdaemon.NetworkInfo) *contract.NetworkStatusPayload { |
| 454 | if info != nil { |
no test coverage detected