15837458681

Committed 23 Jun 2025 11:37PM UTC coverage: 84.575% (-10.3%) from 94.907%

Build # 15837458681

Build Type

Pull #6

github

Committed by

web-flow

Commit Message

Merge 3001e4bc9 into a590240c6

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

Run Details

168 of 241 new or added lines in 13 files covered. (69.71%)

8 existing lines in 1 file now uncovered.

488 of 577 relevant lines covered (84.58%)

4.46 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)';	2✔
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) {	1✔
9	use Feature::Compat::Try;	2✔
10	use Future::AsyncAwait;	2✔
11	use OpenTelemetry::X;	2✔
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 ) {	1✔
22	try {	1✔
23	my $result = $exporter->export(\@items);	1✔
24	$self->report_result( $result, scalar @items );	1✔
25	}
26	catch ($e) {
NEW 27	warn $e;	×
28	}
29
30	return;	1✔
31	}
32
33	method report_result ( $result, $count ) { $result }	1✔
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 / 15837458681

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