|
| 1 | +/* |
| 2 | + * Copyright The OpenTelemetry Authors |
| 3 | + * SPDX-License-Identifier: Apache-2.0 |
| 4 | + */ |
| 5 | + |
| 6 | +#if os(macOS) |
| 7 | + |
| 8 | +import Foundation |
| 9 | +import GRPC |
| 10 | +import NIO |
| 11 | +import NIOSSL |
| 12 | +import OpenTelemetryApi |
| 13 | +import OpenTelemetryProtocolExporter |
| 14 | +import OpenTelemetrySdk |
| 15 | +import ResourceExtension |
| 16 | +import SignPostIntegration |
| 17 | +import StdoutExporter |
| 18 | +import ZipkinExporter |
| 19 | + |
| 20 | +let sampleKey = "sampleKey" |
| 21 | +let sampleValue = "sampleValue" |
| 22 | + |
| 23 | +var resources = DefaultResources().get() |
| 24 | + |
| 25 | +let instrumentationScopeName = "OTLPHTTPExporter" |
| 26 | +let instrumentationScopeVersion = "semver:0.1.0" |
| 27 | + |
| 28 | +let otlpHttpTraceExporter = OtlpHttpTraceExporter() |
| 29 | +let stdoutExporter = StdoutExporter() |
| 30 | +let spanExporter = MultiSpanExporter(spanExporters: [otlpHttpTraceExporter, stdoutExporter]) |
| 31 | + |
| 32 | +let spanProcessor = SimpleSpanProcessor(spanExporter: spanExporter) |
| 33 | +OpenTelemetry.registerTracerProvider(tracerProvider: |
| 34 | + TracerProviderBuilder() |
| 35 | + .add(spanProcessor: spanProcessor) |
| 36 | + .build() |
| 37 | +) |
| 38 | + |
| 39 | +let tracer = OpenTelemetry.instance.tracerProvider.get(instrumentationName: instrumentationScopeName, instrumentationVersion: instrumentationScopeVersion) |
| 40 | + |
| 41 | +if #available(macOS 10.14, *), #available(iOS 12.0, *) { |
| 42 | + let tracerProviderSDK = OpenTelemetry.instance.tracerProvider as? TracerProviderSdk |
| 43 | + tracerProviderSDK?.addSpanProcessor(SignPostIntegration()) |
| 44 | +} |
| 45 | + |
| 46 | +func createSpans() { |
| 47 | + let parentSpan1 = tracer.spanBuilder(spanName: "Main").setSpanKind(spanKind: .client).startSpan() |
| 48 | + parentSpan1.setAttribute(key: sampleKey, value: sampleValue) |
| 49 | + OpenTelemetry.instance.contextProvider.setActiveSpan(parentSpan1) |
| 50 | + for _ in 1...3 { |
| 51 | + doWork() |
| 52 | + } |
| 53 | + Thread.sleep(forTimeInterval: 0.5) |
| 54 | + |
| 55 | + let parentSpan2 = tracer.spanBuilder(spanName: "Another").setSpanKind(spanKind: .client).setActive(true).startSpan() |
| 56 | + parentSpan2.setAttribute(key: sampleKey, value: sampleValue) |
| 57 | + // do more Work |
| 58 | + for _ in 1...3 { |
| 59 | + doWork() |
| 60 | + } |
| 61 | + Thread.sleep(forTimeInterval: 0.5) |
| 62 | + |
| 63 | + parentSpan2.end() |
| 64 | + parentSpan1.end() |
| 65 | +} |
| 66 | + |
| 67 | +func doWork() { |
| 68 | + let childSpan = tracer.spanBuilder(spanName: "doWork").setSpanKind(spanKind: .client).startSpan() |
| 69 | + childSpan.setAttribute(key: sampleKey, value: sampleValue) |
| 70 | + Thread.sleep(forTimeInterval: Double.random(in: 0 ..< 10) / 100) |
| 71 | + childSpan.end() |
| 72 | +} |
| 73 | + |
| 74 | +// Create a Parent span (Main) and do some Work (child Spans). Repeat for another Span. |
| 75 | +createSpans() |
| 76 | + |
| 77 | +// Metrics |
| 78 | +let otlpHttpMetricExporter = OtlpHttpMetricExporter() |
| 79 | +let processor = MetricProcessorSdk() |
| 80 | +let meterProvider = MeterProviderSdk(metricProcessor: processor, metricExporter: otlpHttpMetricExporter, metricPushInterval: 0.1) |
| 81 | + |
| 82 | +OpenTelemetry.registerMeterProvider(meterProvider: meterProvider) |
| 83 | + |
| 84 | + |
| 85 | +var meter = meterProvider.get(instrumentationName: "otlp_example_meter'") |
| 86 | +var exampleCounter = meter.createIntCounter(name: "otlp_example_counter") |
| 87 | +var exampleMeasure = meter.createIntMeasure(name: "otlp_example_measure") |
| 88 | +var exampleObserver = meter.createIntObserver(name: "otlp_example_observation") { observer in |
| 89 | + var taskInfo = mach_task_basic_info() |
| 90 | + var count = mach_msg_type_number_t(MemoryLayout<mach_task_basic_info>.size) / 4 |
| 91 | + let _: kern_return_t = withUnsafeMutablePointer(to: &taskInfo) { |
| 92 | + $0.withMemoryRebound(to: integer_t.self, capacity: 1) { |
| 93 | + task_info(mach_task_self_, task_flavor_t(MACH_TASK_BASIC_INFO), $0, &count) |
| 94 | + } |
| 95 | + } |
| 96 | + labels1 = ["dim1": "value1"] |
| 97 | + observer.observe(value: Int(taskInfo.resident_size), labels: labels1) |
| 98 | +} |
| 99 | + |
| 100 | +var labels1 = ["dim1": "value1"] |
| 101 | +for _ in 1...3000 { |
| 102 | + exampleCounter.add(value: 1, labelset: meter.getLabelSet(labels: labels1)) |
| 103 | + exampleMeasure.record(value: 100, labelset: meter.getLabelSet(labels: labels1)) |
| 104 | + exampleMeasure.record(value: 500, labelset: meter.getLabelSet(labels: labels1)) |
| 105 | + exampleMeasure.record(value: 5, labelset: meter.getLabelSet(labels: labels1)) |
| 106 | + exampleMeasure.record(value: 750, labelset: meter.getLabelSet(labels: labels1)) |
| 107 | + sleep(1) |
| 108 | +} |
| 109 | + |
| 110 | +#endif |
0 commit comments