[chore] apply fieldalignment to collectdreceiver

Author: atoulme

receiver/collectdreceiver/collectd.go

@@ -17,25 +17,25 @@ import (
 )
 
 type collectDRecord struct {
-	Dsnames        []*string      `json:"dsnames"`
-	Dstypes        []*string      `json:"dstypes"`
+	Time           *float64       `json:"time"`
 	Host           *string        `json:"host"`
 	Interval       *float64       `json:"interval"`
 	Plugin         *string        `json:"plugin"`
 	PluginInstance *string        `json:"plugin_instance"`
-	Time           *float64       `json:"time"`
 	TypeS          *string        `json:"type"`
 	TypeInstance   *string        `json:"type_instance"`
-	Values         []*json.Number `json:"values"`
 	Message        *string        `json:"message"`
 	Meta           map[string]any `json:"meta"`
 	Severity       *string        `json:"severity"`
+	Dstypes        []*string      `json:"dstypes"`
+	Dsnames        []*string      `json:"dsnames"`
+	Values         []*json.Number `json:"values"`
 }
 
 type createMetricInfo struct {
-	Name   string
 	DsType *string
 	Val    *json.Number
+	Name   string
 }
 
 func (cdr *collectDRecord) isEvent() bool {

receiver/collectdreceiver/config.go

@@ -13,10 +13,10 @@ import (
 
 // Config defines configuration for Collectd receiver.
 type Config struct {
-	confighttp.ServerConfig `mapstructure:",squash"` // squash ensures fields are correctly decoded in embedded struct
-	Timeout                 time.Duration            `mapstructure:"timeout"`
-	Encoding                string                   `mapstructure:"encoding"`
-	AttributesPrefix        string                   `mapstructure:"attributes_prefix"`
+	Encoding                string `mapstructure:"encoding"`
+	AttributesPrefix        string `mapstructure:"attributes_prefix"`
+	confighttp.ServerConfig `mapstructure:",squash"`
+	Timeout                 time.Duration `mapstructure:"timeout"`
 }
 
 func (c *Config) Validate() error {

receiver/collectdreceiver/config_test.go

@@ -22,9 +22,9 @@ func TestLoadConfig(t *testing.T) {
 	t.Parallel()
 
 	tests := []struct {
-		id       component.ID
 		expected component.Config
 		wantErr  error
+		id       component.ID
 	}{
 		{
 			id:       component.NewIDWithName(metadata.Type, ""),

receiver/collectdreceiver/receiver.go

@@ -26,13 +26,13 @@ var _ receiver.Metrics = (*collectdReceiver)(nil)
 
 // collectdReceiver implements the receiver.Metrics for CollectD protocol.
 type collectdReceiver struct {
+	nextConsumer       consumer.Metrics
 	logger             *zap.Logger
 	server             *http.Server
-	defaultAttrsPrefix string
-	nextConsumer       consumer.Metrics
 	obsrecv            *receiverhelper.ObsReport
-	createSettings     receiver.Settings
 	config             *Config
+	createSettings     receiver.Settings
+	defaultAttrsPrefix string
 }
 
 // newCollectdReceiver creates the CollectD receiver with the given parameters.

receiver/collectdreceiver/receiver_test.go

@@ -25,22 +25,22 @@ import (
 )
 
 type wantedBody struct {
+	Attributes map[string]string
 	Name       string
 	Time       float64
-	Attributes map[string]string
 	Value      float64
 }
 
 func TestNewReceiver(t *testing.T) {
 	type args struct {
+		nextConsumer consumer.Metrics
 		config       *Config
 		attrsPrefix  string
-		nextConsumer consumer.Metrics
 	}
 	tests := []struct {
-		name    string
 		args    args
 		wantErr error
+		name    string
 	}{
 		{
 			name: "happy path",
@@ -71,8 +71,8 @@ func TestCollectDServer(t *testing.T) {
 		HTTPMethod   string
 		QueryParams  string
 		RequestBody  string
-		ResponseCode int
 		WantData     []pmetric.Metrics
+		ResponseCode int
 	}
 
 	config := &Config{