CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore(inputs.rabbitmq): Remove useless comment (#14389)

This commit is contained in:
RWDai 2023-12-06 06:16:11 -06:00 committed by GitHub
parent 627aa04845
commit 8dda436e7e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
plugins/inputs/rabbitmq/rabbitmq.go
View File

@ -70,7 +70,6 @@ type RabbitMQ struct {
upstreamFilter filter.Filter upstreamFilter filter.Filter
} }
// OverviewResponse ...
type OverviewResponse struct { type OverviewResponse struct {
MessageStats *MessageStats `json:"message_stats"` MessageStats *MessageStats `json:"message_stats"`
ObjectTotals *ObjectTotals `json:"object_totals"` ObjectTotals *ObjectTotals `json:"object_totals"`
@ -78,17 +77,14 @@ type OverviewResponse struct {
Listeners []Listeners `json:"listeners"` Listeners []Listeners `json:"listeners"`
} }
// Listeners ...
type Listeners struct { type Listeners struct {
Protocol string `json:"protocol"` Protocol string `json:"protocol"`
} }
// Details ...
type Details struct { type Details struct {
Rate float64 `json:"rate"` Rate float64 `json:"rate"`
} }
// MessageStats ...
type MessageStats struct { type MessageStats struct {
Ack int64 Ack int64
AckDetails Details `json:"ack_details"` AckDetails Details `json:"ack_details"`
@ -108,7 +104,6 @@ type MessageStats struct {
ReturnUnroutableDetails Details `json:"return_unroutable_details"` ReturnUnroutableDetails Details `json:"return_unroutable_details"`
} }
// ObjectTotals ...
type ObjectTotals struct { type ObjectTotals struct {
Channels int64 Channels int64
Connections int64 Connections int64
@ -117,7 +112,6 @@ type ObjectTotals struct {
Queues int64 Queues int64
} }
// QueueTotals ...
type QueueTotals struct { type QueueTotals struct {
Messages int64 Messages int64
MessagesReady int64 `json:"messages_ready"` MessagesReady int64 `json:"messages_ready"`
@ -129,7 +123,6 @@ type QueueTotals struct {
MessagePersistent int64 `json:"message_bytes_persistent"` MessagePersistent int64 `json:"message_bytes_persistent"`
} }
// Queue ...
type Queue struct { type Queue struct {
QueueTotals // just to not repeat the same code QueueTotals // just to not repeat the same code
MessageStats `json:"message_stats"` MessageStats `json:"message_stats"`
@ -147,7 +140,6 @@ type Queue struct {
HeadMessageTimestamp *int64 `json:"head_message_timestamp"` HeadMessageTimestamp *int64 `json:"head_message_timestamp"`
} }
// Node ...
type Node struct { type Node struct {
Name string Name string
@ -194,7 +186,6 @@ type Exchange struct {
AutoDelete bool `json:"auto_delete"` AutoDelete bool `json:"auto_delete"`
} }
// FederationLinkChannelMessageStats ...
type FederationLinkChannelMessageStats struct { type FederationLinkChannelMessageStats struct {
Confirm int64 `json:"confirm"` Confirm int64 `json:"confirm"`
ConfirmDetails Details `json:"confirm_details"` ConfirmDetails Details `json:"confirm_details"`
@ -204,7 +195,6 @@ type FederationLinkChannelMessageStats struct {
ReturnUnroutableDetails Details `json:"return_unroutable_details"` ReturnUnroutableDetails Details `json:"return_unroutable_details"`
} }
// FederationLinkChannel ...
type FederationLinkChannel struct { type FederationLinkChannel struct {
AcksUncommitted int64 `json:"acks_uncommitted"` AcksUncommitted int64 `json:"acks_uncommitted"`
ConsumerCount int64 `json:"consumer_count"` ConsumerCount int64 `json:"consumer_count"`
@ -214,7 +204,6 @@ type FederationLinkChannel struct {
MessageStats FederationLinkChannelMessageStats `json:"message_stats"` MessageStats FederationLinkChannelMessageStats `json:"message_stats"`
} }
// FederationLink ...
type FederationLink struct { type FederationLink struct {
Type string `json:"type"` Type string `json:"type"`
Queue string `json:"queue"` Queue string `json:"queue"`
@ -230,7 +219,6 @@ type HealthCheck struct {
Status string `json:"status"` Status string `json:"status"`
} }
// MemoryResponse ...
type MemoryResponse struct { type MemoryResponse struct {
Memory *Memory `json:"memory"` Memory *Memory `json:"memory"`
} }
@ -265,7 +253,6 @@ type ErrorResponse struct {
Reason string `json:"reason"` Reason string `json:"reason"`
} }
// gatherFunc ...
type gatherFunc func(r *RabbitMQ, acc telegraf.Accumulator) type gatherFunc func(r *RabbitMQ, acc telegraf.Accumulator)
var gatherFunctions = map[string]gatherFunc{ var gatherFunctions = map[string]gatherFunc{
@ -319,7 +306,6 @@ func (r *RabbitMQ) Init() error {
return nil return nil
} }
// Gather ...
func (r *RabbitMQ) Gather(acc telegraf.Accumulator) error { func (r *RabbitMQ) Gather(acc telegraf.Accumulator) error {
var wg sync.WaitGroup var wg sync.WaitGroup
for name, f := range gatherFunctions { for name, f := range gatherFunctions {