[receiver/iis] Do not pass metrics details to pkg/winperfcounters (op…

…en-telemetry#9789)

This is refactoring of the iisreceiver to make it use pkg/winperfcounters just as a source of perf counter values and do not pass metric details back and forth.

`pkg/winperfcounters` uses user configuration structures from `windowsperfcounters` receiver as its API interface which seems unnecessary. This is one of the steps in bigger refactoring to make the pkg/winperfcounters interface concise and not dependent on user setting structures from windowsperfcounters receiver.

pkg/winperfcounters/watcher.go

@@ -46,6 +46,16 @@ type Watcher struct {
  MetricRep
 }
 
+// NewWatcher creates new PerfCounterWatcher by provided parts of its path.
+func NewWatcher(object, instance, counterName string) (PerfCounterWatcher, error) {
+ path := counterPath(object, instance, counterName)
+ counter, err := pdh.NewPerfCounter(path, true)
+ if err != nil {
+ return nil, fmt.Errorf("failed to create perf counter with path %v: %w", path, err)
+ }
+ return Watcher{Counter: counter}, nil
+}
+
 func (w Watcher) Path() string {
  return w.Counter.Path()
 }

receiver/iisreceiver/recorder.go

@@ -0,0 +1,114 @@
+// Copyright The OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http:https://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+//go:build windows
+// +build windows
+
+package iisreceiver // import "github.com/open-telemetry/opentelemetry-collector-contrib/receiver/iisreceiver"
+
+import (
+ "go.opentelemetry.io/collector/pdata/pcommon"
+
+ "github.com/open-telemetry/opentelemetry-collector-contrib/receiver/iisreceiver/internal/metadata"
+)
+
+type recordFunc = func(*metadata.MetricsBuilder, pcommon.Timestamp, float64)
+
+type perfCounterRecorderConf struct {
+ object string
+ instance string
+ recorders map[string]recordFunc
+}
+
+var perfCounterRecorders = []perfCounterRecorderConf{
+ {
+ object: "Web Service",
+ instance: "_Total",
+ recorders: map[string]recordFunc{
+ "Current Connections": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisConnectionActiveDataPoint(ts, int64(val))
+ },
+ "Total Bytes Received": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisNetworkIoDataPoint(ts, int64(val), metadata.AttributeDirectionReceived)
+ },
+ "Total Bytes Sent": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisNetworkIoDataPoint(ts, int64(val), metadata.AttributeDirectionSent)
+ },
+ "Total Connection Attempts (all instances)": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp,
+ val float64) {
+ mb.RecordIisConnectionAttemptCountDataPoint(ts, int64(val))
+ },
+ "Total Delete Requests": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisRequestCountDataPoint(ts, int64(val), metadata.AttributeRequestDelete)
+ },
+ "Total Get Requests": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisRequestCountDataPoint(ts, int64(val), metadata.AttributeRequestGet)
+ },
+ "Total Head Requests": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisRequestCountDataPoint(ts, int64(val), metadata.AttributeRequestHead)
+ },
+ "Total Options Requests": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisRequestCountDataPoint(ts, int64(val), metadata.AttributeRequestOptions)
+ },
+ "Total Post Requests": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisRequestCountDataPoint(ts, int64(val), metadata.AttributeRequestPost)
+ },
+ "Total Put Requests": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisRequestCountDataPoint(ts, int64(val), metadata.AttributeRequestPut)
+ },
+ "Total Trace Requests": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisRequestCountDataPoint(ts, int64(val), metadata.AttributeRequestTrace)
+ },
+ "Total Files Received": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisNetworkFileCountDataPoint(ts, int64(val), metadata.AttributeDirectionReceived)
+ },
+ "Total Files Sent": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisNetworkFileCountDataPoint(ts, int64(val), metadata.AttributeDirectionSent)
+ },
+ "Total Anonymous Users": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisConnectionAnonymousDataPoint(ts, int64(val))
+ },
+ "Total blocked bandwidth bytes.": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisNetworkBlockedDataPoint(ts, int64(val))
+ },
+ "Service Uptime": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisUptimeDataPoint(ts, int64(val))
+ },
+ },
+ },
+ {
+ object: "HTTP Service Request Queues",
+ instance: "*",
+ recorders: map[string]recordFunc{
+ "RejectedRequests": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisRequestRejectedDataPoint(ts, int64(val))
+ },
+ "CurrentQueueSize": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisRequestQueueCountDataPoint(ts, int64(val))
+ },
+ "MaxQueueItemAge": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisRequestQueueAgeMaxDataPoint(ts, int64(val))
+ },
+ },
+ },
+ {
+ object: "Process",
+ instance: "_Total",
+ recorders: map[string]recordFunc{
+ "Thread Count": func(mb *metadata.MetricsBuilder, ts pcommon.Timestamp, val float64) {
+ mb.RecordIisThreadActiveDataPoint(ts, int64(val))
+ },
+ },
+ },
+}