| 652 | } |
| 653 | |
| 654 | func (t *TCPTransport) registerMetrics(registerer prometheus.Registerer) { |
| 655 | const subsystem = "memberlist_tcp_transport" |
| 656 | |
| 657 | t.incomingStreams = promauto.With(registerer).NewCounter(prometheus.CounterOpts{ |
| 658 | Namespace: t.cfg.MetricsNamespace, |
| 659 | Subsystem: subsystem, |
| 660 | Name: "incoming_streams_total", |
| 661 | Help: "Number of incoming memberlist streams", |
| 662 | }) |
| 663 | |
| 664 | t.outgoingStreams = promauto.With(registerer).NewCounter(prometheus.CounterOpts{ |
| 665 | Namespace: t.cfg.MetricsNamespace, |
| 666 | Subsystem: subsystem, |
| 667 | Name: "outgoing_streams_total", |
| 668 | Help: "Number of outgoing streams", |
| 669 | }) |
| 670 | |
| 671 | t.outgoingStreamErrors = promauto.With(registerer).NewCounter(prometheus.CounterOpts{ |
| 672 | Namespace: t.cfg.MetricsNamespace, |
| 673 | Subsystem: subsystem, |
| 674 | Name: "outgoing_stream_errors_total", |
| 675 | Help: "Number of errors when opening memberlist stream to another node", |
| 676 | }) |
| 677 | |
| 678 | t.receivedPackets = promauto.With(registerer).NewCounter(prometheus.CounterOpts{ |
| 679 | Namespace: t.cfg.MetricsNamespace, |
| 680 | Subsystem: subsystem, |
| 681 | Name: "packets_received_total", |
| 682 | Help: "Number of received memberlist packets", |
| 683 | }) |
| 684 | |
| 685 | t.receivedPacketsBytes = promauto.With(registerer).NewCounter(prometheus.CounterOpts{ |
| 686 | Namespace: t.cfg.MetricsNamespace, |
| 687 | Subsystem: subsystem, |
| 688 | Name: "packets_received_bytes_total", |
| 689 | Help: "Total bytes received as packets. This metric only tracks broadcast packets, and does not include full state syncs or pings.", |
| 690 | }) |
| 691 | |
| 692 | t.receivedPacketsErrors = promauto.With(registerer).NewCounter(prometheus.CounterOpts{ |
| 693 | Namespace: t.cfg.MetricsNamespace, |
| 694 | Subsystem: subsystem, |
| 695 | Name: "packets_received_errors_total", |
| 696 | Help: "Number of errors when receiving memberlist packets", |
| 697 | }) |
| 698 | |
| 699 | t.droppedPackets = promauto.With(registerer).NewCounter(prometheus.CounterOpts{ |
| 700 | Namespace: t.cfg.MetricsNamespace, |
| 701 | Subsystem: subsystem, |
| 702 | Name: "packets_dropped_total", |
| 703 | Help: "Number of dropped memberlist packets. These packets were not sent due to timeout waiting for a writer.", |
| 704 | }) |
| 705 | |
| 706 | t.sentPackets = promauto.With(registerer).NewCounter(prometheus.CounterOpts{ |
| 707 | Namespace: t.cfg.MetricsNamespace, |
| 708 | Subsystem: subsystem, |
| 709 | Name: "packets_sent_total", |
| 710 | Help: "Number of memberlist packets sent", |
| 711 | }) |