feat(inputs.opensearch_query): Add opensearch_query input plugin

go.sum

@@ -450,7 +450,6 @@ github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.2.3/go.mod h1:7gc
 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.3.2/go.mod h1:72HRZDLMtmVQiLG2tLfQcaWLCssELvGl+Zf2WVxMmR8=
 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.5.0/go.mod h1:Mq6AEc+oEjCUlBuLiK5YwW4shSOAKCQ3tXN0sQeYoBA=
 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.7/go.mod h1:HvVdEh/x4jsPBsjNvDy+MH3CDCPy4gTZEzFe2r4uJY8=
-github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.15/go.mod h1:ZVJ7ejRl4+tkWMuCwjXoy0jd8fF5u3RCyWjSVjUIvQE=
 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.17/go.mod h1:4nYOrY41Lrbk2170/BGkcJKBhws9Pfn8MG3aGqjjeFI=
 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.19/go.mod h1:02CP6iuYP+IVnBX5HULVdSAku/85eHB2Y9EsFhrkEwU=
 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.21 h1:5C6XgTViSb0bunmU57b3CT+MhxULqHH2721FVA+/kDM=

plugins/inputs/opensearch_query/opensearch_query.go

@@ -26,8 +26,8 @@ var sampleConfig string
 // OpensearchQuery struct
 type OpensearchQuery struct {
 	URLs                []string        `toml:"urls"`
-	Username            string          `toml:"username"`
-	Password            string          `toml:"password"`
+	Username            config.Secret   `toml:"username"`
+	Password            config.Secret   `toml:"password"`
 	EnableSniffer       bool            `toml:"enable_sniffer"`
 	Timeout             config.Duration `toml:"timeout"`
 	HealthCheckInterval config.Duration `toml:"health_check_interval"`
@@ -119,10 +119,21 @@ func (o *OpensearchQuery) initAggregation(agg osAggregation, i int) (err error)
 }
 
 func (o *OpensearchQuery) newClient() error {
+	username, err := o.Username.Get()
+	if err != nil {
+		return fmt.Errorf("getting username failed: %v", err)
+	}
+	defer config.ReleaseSecret(username)
+	password, err := o.Password.Get()
+	if err != nil {
+		return fmt.Errorf("getting password failed: %v", err)
+	}
+	defer config.ReleaseSecret(password)
+
 	clientConfig := opensearch.Config{
 		Addresses: o.URLs,
-		Username:  o.Username,
-		Password:  o.Password,
+		Username:  string(username),
+		Password:  string(password),
 	}
 
 	if o.InsecureSkipVerify {
@@ -202,7 +213,7 @@ func (o *OpensearchQuery) runAggregationQuery(ctx context.Context, aggregation o
 	aq.Query = boolQuery
 	req, err := json.Marshal(aq)
 	if err != nil {
-		return nil, fmt.Errorf("failed to marshal request: %s", err)
+		return nil, fmt.Errorf("failed to marshal request: %w", err)
 	}
 
 	searchRequest := &opensearchapi.SearchRequest{