Splunkent client refactor

.chloggen/splunkent-client.yaml → .chloggen/splunkent-client-refactor.yaml

@@ -1,20 +1,27 @@
 # Use this changelog template to create an entry for release notes.
-# If your change doesn't affect end users, such as a test fix or a tooling change,
-# you should instead start your pull request title with [chore] or use the "Skip Changelog" label.
 
 # One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
 change_type: 'enhancement'
 
 # The name of the component, or a single word describing the area of concern, (e.g. filelogreceiver)
-component: splunkentreceiver
+component: splunkentreceiver 
 
 # A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
-note: "adding component logic to splunkenterprise receiver"
+note: Refactor Splunkenterprise Receiver component to better leverage existing otel SDK.
 
 # Mandatory: One or more tracking issues related to the change. You can use the PR number here if no issue exists.
-issues: [12667]
+issues: [27026]
 
 # (Optional) One or more lines of additional information to render under the primary note.
 # These lines will be padded with 2 spaces and then inserted directly into the document.
 # Use pipe (|) for multiline entries.
 subtext:
+
+# If your change doesn't affect end users or the exported elements of any package,
+# you should instead start your pull request title with [chore] or use the "Skip Changelog" label.
+# Optional: The change log or logs in which this entry should be included.
+# e.g. '[user]' or '[user, api]'
+# Include 'user' if the change is relevant to end users.
+# Include 'api' if there is a change to a library API.
+# Default: '[user]'
+change_logs: [user]

receiver/lokireceiver/go.mod

@@ -32,7 +32,7 @@ require (
 )
 
 require (
-	cloud.google.com/go/compute/metadata v0.2.4-0.20230617002413-005d2dfb6b68 // indirect
+    cloud.google.com/go/compute/metadata v0.2.4-0.20230617002413-005d2dfb6b68 // indirect
 	github.com/beorn7/perks v1.0.1 // indirect
 	github.com/cespare/xxhash/v2 v2.2.0 // indirect
 	github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect

receiver/opencensusreceiver/go.mod

@@ -30,7 +30,7 @@ require (
 )
 
 require (
-	cloud.google.com/go/compute/metadata v0.2.4-0.20230617002413-005d2dfb6b68 // indirect
+    cloud.google.com/go/compute/metadata v0.2.4-0.20230617002413-005d2dfb6b68 // indirect
 	contrib.go.opencensus.io/exporter/prometheus v0.4.2 // indirect
 	github.com/beorn7/perks v1.0.1 // indirect
 	github.com/cespare/xxhash/v2 v2.2.0 // indirect

receiver/splunkenterprisereceiver/README.md

@@ -1,5 +1,38 @@
 # Splunk Enterprise Receiver
----
 
-The Splunk Enterprise Receiver is a pull based tool which enables the ingestion of key performance metrics (KPI's) describing the operational status of a user's Splunk Enterprise deployment to be 
-added to their OpenTelemetry Pipeline.
+The Splunk Enterprise Receiver is a pull based tool which enables the ingestion of performance metrics describing the operational status of a user's Splunk Enterprise deployment to an appropriate observability tool.
+It is designed to leverage several different data sources to gather these metrics including the [introspection api endpoint](https://docs.splunk.com/Documentation/Splunk/9.1.1/RESTREF/RESTintrospect) and serializing
+results from ad-hoc searches. Because of this, care must be taken by users when enabling metrics as running searches can effect your Splunk Enterprise Deployment and introspection may fail to report for Splunk
+Cloud deployments. The primary purpose of this receiver is to empower those tasked with the maintenance and care of a Splunk Enterprise deployment to leverage opentelemetry and their observability toolset in their
+jobs.
+
+## Configuration
+
+The following settings are required, omitting them will either cause your receiver to fail to compile or result in 4/5xx return codes during scraping.
+
+* `basicauth` (from [basicauthextension](https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/extension/basicauthextension)): A configured stanza for the basicauthextension.
+* `auth` (no default): String name referencing your auth extension.
+* `endpoint` (no default): your Splunk Enterprise host's endpoint.
+
+The following settings are optional:
+
+* `collection_interval` (default: 10m): The time between scrape attempts.
+* `timeout` (default: 60s): The time the scrape function will wait for a response before returning empty.
+
+Example:
+
+```yaml
+extensions:
+    basicauth/client:
+        client_auth:
+            username: admin
+            password: securityFirst
+
+receivers:
+    splunkenterprise:
+        auth: basicauth/client
+        endpoint: "https://localhost:8089"
+        timeout: 45s
+```
+
+For a full list of settings exposed by this receiver please look [here](./config.go) with a detailed configuration [here](./testdata/config.yaml).

receiver/splunkenterprisereceiver/client.go

@@ -5,41 +5,31 @@ package splunkenterprisereceiver // import "github.com/open-telemetry/openteleme
 
 import (
 	"context"
-	"crypto/tls"
-	"encoding/base64"
 	"fmt"
 	"net/http"
 	"net/url"
 	"strings"
+
+	"go.opentelemetry.io/collector/component"
 )
 
 type splunkEntClient struct {
-	endpoint  *url.URL
-	client    *http.Client
-	basicAuth string
+	client   *http.Client
+	endpoint *url.URL
 }
 
-func newSplunkEntClient(cfg *Config) splunkEntClient {
-	// tls party
-	tr := &http.Transport{
-		TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
+func newSplunkEntClient(cfg *Config, h component.Host, s component.TelemetrySettings) (*splunkEntClient, error) {
+	client, err := cfg.HTTPClientSettings.ToClient(h, s)
+	if err != nil {
+		return nil, err
 	}
 
-	client := &http.Client{Transport: tr}
-
 	endpoint, _ := url.Parse(cfg.Endpoint)
 
-	// build and encode our auth string. Do this work once to avoid rebuilding the
-	// auth header every time we make a new request
-	authString := fmt.Sprintf("%s:%s", cfg.Username, cfg.Password)
-	auth64 := base64.StdEncoding.EncodeToString([]byte(authString))
-	basicAuth := fmt.Sprintf("Basic %s", auth64)
-
-	return splunkEntClient{
-		client:    client,
-		endpoint:  endpoint,
-		basicAuth: basicAuth,
-	}
+	return &splunkEntClient{
+		client:   client,
+		endpoint: endpoint,
+	}, nil
 }
 
 // For running ad hoc searches only
@@ -59,10 +49,6 @@ func (c *splunkEntClient) createRequest(ctx context.Context, sr *searchResponse)
 			return nil, err
 		}
 
-		// Required headers
-		req.Header.Add("Authorization", c.basicAuth)
-		req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
-
 		return req, nil
 	}
 	path := fmt.Sprintf("/services/search/jobs/%s/results", *sr.Jobid)
@@ -73,10 +59,6 @@ func (c *splunkEntClient) createRequest(ctx context.Context, sr *searchResponse)
 		return nil, err
 	}
 
-	// Required headers
-	req.Header.Add("Authorization", c.basicAuth)
-	req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
-
 	return req, nil
 }
 
@@ -88,10 +70,6 @@ func (c *splunkEntClient) createAPIRequest(ctx context.Context, apiEndpoint stri
 		return nil, err
 	}
 
-	// Required headers
-	req.Header.Add("Authorization", c.basicAuth)
-	req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
-
 	return req, nil
 }