15943487025

Committed 28 Jun 2025 11:05AM UTC coverage: 95.122% (+0.2%) from 94.907%

Build # 15943487025

Build Type

Pull #6

github

Committed by

web-flow

Commit Message

Merge 603a95520 into a590240c6

Pull Request Pull Request #6: WIP: Add support for logs

Run Details

221 of 241 new or added lines in 13 files covered. (91.7%)

2 existing lines in 2 files now uncovered.

546 of 574 relevant lines covered (95.12%)

5.48 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

93.75

/lib/OpenTelemetry/Processor/Simple.pm

use Object::Pad ':experimental(init_expr)';
# ABSTRACT: A basic OpenTelemetry span processor

package OpenTelemetry::Processor::Simple;

our $VERSION = '0.028';

class OpenTelemetry::Processor::Simple :does(OpenTelemetry::Processor) {
    use Feature::Compat::Try;
    use Future::AsyncAwait;
    use OpenTelemetry::X;

    field $exporter :param;

    ADJUST {
        die OpenTelemetry::X->create(
            Invalid => "Exporter must implement the OpenTelemetry::Exporter interface: " . ( ref $exporter || $exporter )
        ) unless $exporter && $exporter->DOES('OpenTelemetry::Exporter');
    }

    method process ( @items ) {
        try {
            my $result = $exporter->export(\@items);
            $self->report_result( $result, scalar @items );
        }
        catch ($e) {
            warn $e;
        }

        return;
    }

    method report_result ( $result, $count ) { $result }

    async method shutdown ( $timeout = undef ) {
        await $exporter->shutdown( $timeout );
    }

    async method force_flush ( $timeout = undef ) {
        await $exporter->force_flush( $timeout );
    }
}

1	use Object::Pad ':experimental(init_expr)';	4✔
2	# ABSTRACT: A basic OpenTelemetry span processor
3
4	package OpenTelemetry::Processor::Simple;
5
6	our $VERSION = '0.028';
7
8	class OpenTelemetry::Processor::Simple :does(OpenTelemetry::Processor) {	3✔
9	use Feature::Compat::Try;	4✔
10	use Future::AsyncAwait;	4✔
11	use OpenTelemetry::X;	4✔
12
13	field $exporter :param;
14
15	ADJUST {
16	die OpenTelemetry::X->create(
17	Invalid => "Exporter must implement the OpenTelemetry::Exporter interface: " . ( ref $exporter \|\| $exporter )
18	) unless $exporter && $exporter->DOES('OpenTelemetry::Exporter');
19	}
20
21	method process ( @items ) {	2✔
22	try {	2✔
23	my $result = $exporter->export(\@items);	2✔
24	$self->report_result( $result, scalar @items );	2✔
25	}
26	catch ($e) {
NEW 27	warn $e;	×
28	}
29
30	return;	2✔
31	}
32
33	method report_result ( $result, $count ) { $result }	2✔
34
35	async method shutdown ( $timeout = undef ) {	2✔
36	await $exporter->shutdown( $timeout );	2✔
37	}
38
39	async method force_flush ( $timeout = undef ) {	2✔
40	await $exporter->force_flush( $timeout );	2✔
41	}
42	}

jjatria / perl-opentelemetry-sdk / 15943487025

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous