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