Skip to content

Commit 0047a96

Browse files
committed
chore: switch to SPDX license headers
1 parent 1cd4374 commit 0047a96

589 files changed

Lines changed: 126155 additions & 132551 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

_template/version.py

Lines changed: 4 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,4 @@
1-
# Copyright The OpenTelemetry Authors
2-
#
3-
# Licensed under the Apache License, Version 2.0 (the "License");
4-
# you may not use this file except in compliance with the License.
5-
# You may obtain a copy of the License at
6-
#
7-
# http://www.apache.org/licenses/LICENSE-2.0
8-
#
9-
# Unless required by applicable law or agreed to in writing, software
10-
# distributed under the License is distributed on an "AS IS" BASIS,
11-
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12-
# See the License for the specific language governing permissions and
13-
# limitations under the License.
14-
15-
__version__ = "0.63b0.dev"
1+
# Copyright The OpenTelemetry Authors
2+
# SPDX-License-Identifier: Apache-2.0
3+
4+
__version__ = "0.63b0.dev"
Lines changed: 4 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,4 @@
1-
# Copyright The OpenTelemetry Authors
2-
#
3-
# Licensed under the Apache License, Version 2.0 (the "License");
4-
# you may not use this file except in compliance with the License.
5-
# You may obtain a copy of the License at
6-
#
7-
# http://www.apache.org/licenses/LICENSE-2.0
8-
#
9-
# Unless required by applicable law or agreed to in writing, software
10-
# distributed under the License is distributed on an "AS IS" BASIS,
11-
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12-
# See the License for the specific language governing permissions and
13-
# limitations under the License.
14-
15-
__version__ = "0.63b0.dev"
1+
# Copyright The OpenTelemetry Authors
2+
# SPDX-License-Identifier: Apache-2.0
3+
4+
__version__ = "0.63b0.dev"
Lines changed: 103 additions & 114 deletions
Original file line numberDiff line numberDiff line change
@@ -1,114 +1,103 @@
1-
# Copyright The OpenTelemetry Authors
2-
#
3-
# Licensed under the Apache License, Version 2.0 (the "License");
4-
# you may not use this file except in compliance with the License.
5-
# You may obtain a copy of the License at
6-
#
7-
# http://www.apache.org/licenses/LICENSE-2.0
8-
#
9-
# Unless required by applicable law or agreed to in writing, software
10-
# distributed under the License is distributed on an "AS IS" BASIS,
11-
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12-
# See the License for the specific language governing permissions and
13-
# limitations under the License.
14-
15-
import logging
16-
import random
17-
import sys
18-
import time
19-
from logging import INFO
20-
21-
import psutil
22-
23-
from opentelemetry import metrics
24-
from opentelemetry.exporter.prometheus_remote_write import (
25-
PrometheusRemoteWriteMetricsExporter,
26-
)
27-
from opentelemetry.metrics import Observation
28-
from opentelemetry.sdk.metrics import MeterProvider
29-
from opentelemetry.sdk.metrics.export import PeriodicExportingMetricReader
30-
31-
logging.basicConfig(stream=sys.stdout, level=logging.INFO)
32-
logger = logging.getLogger(__name__)
33-
34-
35-
testing_labels = {"environment": "testing"}
36-
37-
exporter = PrometheusRemoteWriteMetricsExporter(
38-
endpoint="http://cortex:9009/api/prom/push",
39-
headers={"X-Scope-Org-ID": "5"},
40-
)
41-
reader = PeriodicExportingMetricReader(exporter, 1000)
42-
provider = MeterProvider(metric_readers=[reader])
43-
metrics.set_meter_provider(provider)
44-
meter = metrics.get_meter(__name__)
45-
46-
47-
# Callback to gather cpu usage
48-
def get_cpu_usage_callback(observer):
49-
for number, percent in enumerate(psutil.cpu_percent(percpu=True)):
50-
labels = {"cpu_number": str(number)}
51-
yield Observation(percent, labels)
52-
53-
54-
# Callback to gather RAM usage
55-
def get_ram_usage_callback(observer):
56-
ram_percent = psutil.virtual_memory().percent
57-
yield Observation(ram_percent, {})
58-
59-
60-
requests_counter = meter.create_counter(
61-
name="requests",
62-
description="number of requests",
63-
unit="1",
64-
)
65-
66-
request_min_max = meter.create_counter(
67-
name="requests_min_max",
68-
description="min max sum count of requests",
69-
unit="1",
70-
)
71-
72-
request_last_value = meter.create_counter(
73-
name="requests_last_value",
74-
description="last value number of requests",
75-
unit="1",
76-
)
77-
78-
requests_active = meter.create_up_down_counter(
79-
name="requests_active",
80-
description="number of active requests",
81-
unit="1",
82-
)
83-
84-
meter.create_observable_counter(
85-
callbacks=[get_ram_usage_callback],
86-
name="ram_usage",
87-
description="ram usage",
88-
unit="1",
89-
)
90-
91-
meter.create_observable_up_down_counter(
92-
callbacks=[get_cpu_usage_callback],
93-
name="cpu_percent",
94-
description="per-cpu usage",
95-
unit="1",
96-
)
97-
98-
request_latency = meter.create_histogram("request_latency")
99-
100-
# Load generator
101-
num = random.randint(0, 1000)
102-
while True:
103-
# counters
104-
requests_counter.add(num % 131 + 200, testing_labels)
105-
request_min_max.add(num % 181 + 200, testing_labels)
106-
request_last_value.add(num % 101 + 200, testing_labels)
107-
108-
# updown counter
109-
requests_active.add(num % 7231 + 200, testing_labels)
110-
111-
request_latency.record(num % 92, testing_labels)
112-
logger.log(level=INFO, msg="completed metrics collection cycle")
113-
time.sleep(1)
114-
num += 9791
1+
# Copyright The OpenTelemetry Authors
2+
# SPDX-License-Identifier: Apache-2.0
3+
4+
import logging
5+
import random
6+
import sys
7+
import time
8+
from logging import INFO
9+
10+
import psutil
11+
12+
from opentelemetry import metrics
13+
from opentelemetry.exporter.prometheus_remote_write import (
14+
PrometheusRemoteWriteMetricsExporter,
15+
)
16+
from opentelemetry.metrics import Observation
17+
from opentelemetry.sdk.metrics import MeterProvider
18+
from opentelemetry.sdk.metrics.export import PeriodicExportingMetricReader
19+
20+
logging.basicConfig(stream=sys.stdout, level=logging.INFO)
21+
logger = logging.getLogger(__name__)
22+
23+
24+
testing_labels = {"environment": "testing"}
25+
26+
exporter = PrometheusRemoteWriteMetricsExporter(
27+
endpoint="http://cortex:9009/api/prom/push",
28+
headers={"X-Scope-Org-ID": "5"},
29+
)
30+
reader = PeriodicExportingMetricReader(exporter, 1000)
31+
provider = MeterProvider(metric_readers=[reader])
32+
metrics.set_meter_provider(provider)
33+
meter = metrics.get_meter(__name__)
34+
35+
36+
# Callback to gather cpu usage
37+
def get_cpu_usage_callback(observer):
38+
for number, percent in enumerate(psutil.cpu_percent(percpu=True)):
39+
labels = {"cpu_number": str(number)}
40+
yield Observation(percent, labels)
41+
42+
43+
# Callback to gather RAM usage
44+
def get_ram_usage_callback(observer):
45+
ram_percent = psutil.virtual_memory().percent
46+
yield Observation(ram_percent, {})
47+
48+
49+
requests_counter = meter.create_counter(
50+
name="requests",
51+
description="number of requests",
52+
unit="1",
53+
)
54+
55+
request_min_max = meter.create_counter(
56+
name="requests_min_max",
57+
description="min max sum count of requests",
58+
unit="1",
59+
)
60+
61+
request_last_value = meter.create_counter(
62+
name="requests_last_value",
63+
description="last value number of requests",
64+
unit="1",
65+
)
66+
67+
requests_active = meter.create_up_down_counter(
68+
name="requests_active",
69+
description="number of active requests",
70+
unit="1",
71+
)
72+
73+
meter.create_observable_counter(
74+
callbacks=[get_ram_usage_callback],
75+
name="ram_usage",
76+
description="ram usage",
77+
unit="1",
78+
)
79+
80+
meter.create_observable_up_down_counter(
81+
callbacks=[get_cpu_usage_callback],
82+
name="cpu_percent",
83+
description="per-cpu usage",
84+
unit="1",
85+
)
86+
87+
request_latency = meter.create_histogram("request_latency")
88+
89+
# Load generator
90+
num = random.randint(0, 1000)
91+
while True:
92+
# counters
93+
requests_counter.add(num % 131 + 200, testing_labels)
94+
request_min_max.add(num % 181 + 200, testing_labels)
95+
request_last_value.add(num % 101 + 200, testing_labels)
96+
97+
# updown counter
98+
requests_active.add(num % 7231 + 200, testing_labels)
99+
100+
request_latency.record(num % 92, testing_labels)
101+
logger.log(level=INFO, msg="completed metrics collection cycle")
102+
time.sleep(1)
103+
num += 9791

0 commit comments

Comments
 (0)