15914484710

Committed 26 Jun 2025 11:22PM UTC coverage: 85.935% (-9.0%) from 94.907%

Build # 15914484710

Build Type

Pull #6

github

Committed by

web-flow

Commit Message

Merge bb7205798 into a590240c6

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

Run Details

183 of 247 new or added lines in 13 files covered. (74.09%)

2 existing lines in 2 files now uncovered.

501 of 583 relevant lines covered (85.93%)

4.9 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)';	5✔
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) {	5✔
9	use Feature::Compat::Try;	5✔
10	use Future::AsyncAwait;	5✔
11	use OpenTelemetry::X;	5✔
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 ) {	5✔
22	try {	5✔
23	my $result = $exporter->export(\@items);	5✔
24	$self->report_result( $result, scalar @items );	5✔
25	}
26	catch ($e) {
NEW 27	warn $e;	×
28	}
29
30	return;	5✔
31	}
32
33	method report_result ( $result, $count ) { $result }	5✔
34
35	async method shutdown ( $timeout = undef ) {	5✔
36	await $exporter->shutdown( $timeout );	5✔
37	}
38
39	async method force_flush ( $timeout = undef ) {	4✔
40	await $exporter->force_flush( $timeout );	4✔
41	}
42	}

jjatria / perl-opentelemetry-sdk / 15914484710

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