undo change

Author: aphralG

internal/collector/nginxplusreceiver/scraper.go

@@ -34,7 +34,7 @@ const (
 	peerStateUnhealthy = "unhealthy"
 )
 
-type NginxPlusScraper struct {
+type nginxPlusScraper struct {
 	previousServerZoneResponses   map[string]ResponseStatuses
 	previousLocationZoneResponses map[string]ResponseStatuses
 	plusClient                    *plusapi.NginxClient
@@ -57,7 +57,7 @@ type ResponseStatuses struct {
 func newNginxPlusScraper(
 	settings receiver.Settings,
 	cfg *Config,
-) (*NginxPlusScraper, error) {
+) (*nginxPlusScraper, error) {
 	endpoint := strings.TrimPrefix(cfg.APIDetails.URL, "unix:")
 	logger := settings.Logger
 	logger.Info("Creating NGINX Plus scraper")
@@ -79,7 +79,7 @@ func newNginxPlusScraper(
 		return nil, err
 	}
 
-	return &NginxPlusScraper{
+	return &nginxPlusScraper{
 		plusClient: plusClient,
 		settings:   settings,
 		cfg:        cfg,
@@ -89,7 +89,7 @@ func newNginxPlusScraper(
 	}, nil
 }
 
-func (nps *NginxPlusScraper) createPreviousLocationZoneResponses(stats *plusapi.Stats) {
+func (nps *nginxPlusScraper) createPreviousLocationZoneResponses(stats *plusapi.Stats) {
 	previousLocationZoneResponses := make(map[string]ResponseStatuses)
 	for lzName, lz := range stats.LocationZones {
 		respStatus := ResponseStatuses{
@@ -106,7 +106,7 @@ func (nps *NginxPlusScraper) createPreviousLocationZoneResponses(stats *plusapi.
 	nps.previousLocationZoneResponses = previousLocationZoneResponses
 }
 
-func (nps *NginxPlusScraper) createPreviousServerZoneResponses(stats *plusapi.Stats) {
+func (nps *nginxPlusScraper) createPreviousServerZoneResponses(stats *plusapi.Stats) {
 	previousServerZoneResponses := make(map[string]ResponseStatuses)
 	for szName, sz := range stats.ServerZones {
 		respStatus := ResponseStatuses{
@@ -123,7 +123,7 @@ func (nps *NginxPlusScraper) createPreviousServerZoneResponses(stats *plusapi.St
 	nps.previousServerZoneResponses = previousServerZoneResponses
 }
 
-func (nps *NginxPlusScraper) scrape(ctx context.Context) (pmetric.Metrics, error) {
+func (nps *nginxPlusScraper) scrape(ctx context.Context) (pmetric.Metrics, error) {
 	// nps.init.Do is ran only once, it is only ran the first time scrape is called to set the previous responses
 	// metric value
 	nps.init.Do(func() {
@@ -151,7 +151,7 @@ func (nps *NginxPlusScraper) scrape(ctx context.Context) (pmetric.Metrics, error
 	return nps.mb.Emit(metadata.WithResource(nps.rb.Emit())), nil
 }
 
-func (nps *NginxPlusScraper) recordMetrics(stats *plusapi.Stats) {
+func (nps *nginxPlusScraper) recordMetrics(stats *plusapi.Stats) {
 	now := pcommon.NewTimestampFromTime(time.Now())
 
 	// NGINX config reloads
@@ -193,7 +193,7 @@ func (nps *NginxPlusScraper) recordMetrics(stats *plusapi.Stats) {
 	nps.recordStreamMetrics(stats, now)
 }
 
-func (nps *NginxPlusScraper) recordStreamMetrics(stats *plusapi.Stats, now pcommon.Timestamp) {
+func (nps *nginxPlusScraper) recordStreamMetrics(stats *plusapi.Stats, now pcommon.Timestamp) {
 	for name, streamServerZone := range stats.StreamServerZones {
 		nps.mb.RecordNginxStreamIoDataPoint(
 			now,
@@ -437,7 +437,7 @@ func (nps *NginxPlusScraper) recordStreamMetrics(stats *plusapi.Stats, now pcomm
 	}
 }
 
-func (nps *NginxPlusScraper) recordSSLMetrics(now pcommon.Timestamp, stats *plusapi.Stats) {
+func (nps *nginxPlusScraper) recordSSLMetrics(now pcommon.Timestamp, stats *plusapi.Stats) {
 	nps.mb.RecordNginxSslHandshakesDataPoint(
 		now,
 		int64(stats.SSL.HandshakesFailed),
@@ -503,7 +503,7 @@ func (nps *NginxPlusScraper) recordSSLMetrics(now pcommon.Timestamp, stats *plus
 	)
 }
 
-func (nps *NginxPlusScraper) recordSlabPageMetrics(stats *plusapi.Stats, now pcommon.Timestamp) {
+func (nps *nginxPlusScraper) recordSlabPageMetrics(stats *plusapi.Stats, now pcommon.Timestamp) {
 	for name, slab := range stats.Slabs {
 		nps.mb.RecordNginxSlabPageFreeDataPoint(now, int64(slab.Pages.Free), name)
 		nps.mb.RecordNginxSlabPageUsageDataPoint(now, int64(slab.Pages.Used), name)
@@ -534,7 +534,7 @@ func (nps *NginxPlusScraper) recordSlabPageMetrics(stats *plusapi.Stats, now pco
 	}
 }
 
-func (nps *NginxPlusScraper) recordHTTPUpstreamPeerMetrics(stats *plusapi.Stats, now pcommon.Timestamp) {
+func (nps *nginxPlusScraper) recordHTTPUpstreamPeerMetrics(stats *plusapi.Stats, now pcommon.Timestamp) {
 	for name, upstream := range stats.Upstreams {
 		nps.mb.RecordNginxHTTPUpstreamKeepaliveCountDataPoint(now, int64(upstream.Keepalive), upstream.Zone, name)
 
@@ -803,7 +803,7 @@ func (nps *NginxPlusScraper) recordHTTPUpstreamPeerMetrics(stats *plusapi.Stats,
 	}
 }
 
-func (nps *NginxPlusScraper) recordServerZoneMetrics(stats *plusapi.Stats, now pcommon.Timestamp) {
+func (nps *nginxPlusScraper) recordServerZoneMetrics(stats *plusapi.Stats, now pcommon.Timestamp) {
 	for szName, sz := range stats.ServerZones {
 		nps.mb.RecordNginxHTTPRequestIoDataPoint(
 			now,
@@ -838,7 +838,7 @@ func (nps *NginxPlusScraper) recordServerZoneMetrics(stats *plusapi.Stats, now p
 
 // Duplicate of recordLocationZoneHTTPMetrics but same function can not be used due to plusapi.ServerZone
 // nolint: dupl
-func (nps *NginxPlusScraper) recordServerZoneHTTPMetrics(sz plusapi.ServerZone, szName string, now pcommon.Timestamp) {
+func (nps *nginxPlusScraper) recordServerZoneHTTPMetrics(sz plusapi.ServerZone, szName string, now pcommon.Timestamp) {
 	nps.mb.RecordNginxHTTPResponseStatusDataPoint(now, int64(sz.Responses.Responses1xx),
 		metadata.AttributeNginxStatusRange1xx,
 		szName,
@@ -908,7 +908,7 @@ func (nps *NginxPlusScraper) recordServerZoneHTTPMetrics(sz plusapi.ServerZone,
 	nps.previousServerZoneResponses[szName] = respStatus
 }
 
-func (nps *NginxPlusScraper) recordLocationZoneMetrics(stats *plusapi.Stats, now pcommon.Timestamp) {
+func (nps *nginxPlusScraper) recordLocationZoneMetrics(stats *plusapi.Stats, now pcommon.Timestamp) {
 	for lzName, lz := range stats.LocationZones {
 		nps.mb.RecordNginxHTTPRequestIoDataPoint(
 			now,
@@ -943,7 +943,7 @@ func (nps *NginxPlusScraper) recordLocationZoneMetrics(stats *plusapi.Stats, now
 
 // Duplicate of recordServerZoneHTTPMetrics but same function can not be used due to plusapi.LocationZone
 // nolint: dupl
-func (nps *NginxPlusScraper) recordLocationZoneHTTPMetrics(lz plusapi.LocationZone,
+func (nps *nginxPlusScraper) recordLocationZoneHTTPMetrics(lz plusapi.LocationZone,
 	lzName string, now pcommon.Timestamp,
 ) {
 	nps.mb.RecordNginxHTTPResponseStatusDataPoint(now, int64(lz.Responses.Responses1xx),
@@ -1015,7 +1015,7 @@ func (nps *NginxPlusScraper) recordLocationZoneHTTPMetrics(lz plusapi.LocationZo
 	nps.previousLocationZoneResponses[lzName] = respStatus
 }
 
-func (nps *NginxPlusScraper) recordHTTPLimitMetrics(stats *plusapi.Stats, now pcommon.Timestamp) {
+func (nps *nginxPlusScraper) recordHTTPLimitMetrics(stats *plusapi.Stats, now pcommon.Timestamp) {
 	for name, limitConnection := range stats.HTTPLimitConnections {
 		nps.mb.RecordNginxHTTPLimitConnRequestsDataPoint(
 			now,
@@ -1071,7 +1071,7 @@ func (nps *NginxPlusScraper) recordHTTPLimitMetrics(stats *plusapi.Stats, now pc
 	}
 }
 
-func (nps *NginxPlusScraper) recordCacheMetrics(stats *plusapi.Stats, now pcommon.Timestamp) {
+func (nps *nginxPlusScraper) recordCacheMetrics(stats *plusapi.Stats, now pcommon.Timestamp) {
 	for name, cache := range stats.Caches {
 		nps.mb.RecordNginxCacheBytesReadDataPoint(
 			now,
@@ -1174,7 +1174,7 @@ func socketClient(socketPath string) *http.Client {
 	}
 }
 
-func (nps *NginxPlusScraper) Shutdown(ctx context.Context) error {
+func (nps *nginxPlusScraper) Shutdown(ctx context.Context) error {
 	return nil
 }