Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@

@ThreadSafe
@SuppressWarnings("FutureReturnValueIgnored")
public class KafkaSpanExporter implements SpanExporter {
public final class KafkaSpanExporter implements SpanExporter {
private static final Logger logger = LoggerFactory.getLogger(KafkaSpanExporter.class);
private final String topicName;
private final Producer<String, Collection<SpanData>> producer;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.common.serialization.Serializer;

public class KafkaSpanExporterBuilder {
public final class KafkaSpanExporterBuilder {
private static final long DEFAULT_TIMEOUT_IN_SECONDS = 5L;
private String topicName;
private Producer<String, Collection<SpanData>> producer;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@
import org.apache.kafka.common.errors.SerializationException;
import org.apache.kafka.common.serialization.Deserializer;

public class SpanDataDeserializer implements Deserializer<ExportTraceServiceRequest> {
public final class SpanDataDeserializer implements Deserializer<ExportTraceServiceRequest> {
@SuppressWarnings("NullAway")
@Override
public ExportTraceServiceRequest deserialize(String topic, byte[] data) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
import org.apache.kafka.common.errors.SerializationException;
import org.apache.kafka.common.serialization.Serializer;

public class SpanDataSerializer implements Serializer<Collection<SpanData>> {
public final class SpanDataSerializer implements Serializer<Collection<SpanData>> {
@Override
public byte[] serialize(String topic, Collection<SpanData> data) {
if (Objects.isNull(data)) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
import javax.annotation.Nullable;

/** Builder utility class for creating instances of {@link MicrometerMeterProvider}. */
public class MicrometerMeterProviderBuilder {
public final class MicrometerMeterProviderBuilder {
private final Supplier<MeterRegistry> meterRegistrySupplier;
@Nullable private CallbackRegistrar callbackRegistrar;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
/**
* A {@link ContextStorageProvider} that returns a {@link ContextStorage} which is completely no-op.
*/
public class NoopContextStorageProvider implements ContextStorageProvider {
public final class NoopContextStorageProvider implements ContextStorageProvider {

/** Returns a no-op context storage. */
@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@
* <p>The above will succeed both with the {@linkplain OpenTelemetry#noop() default implementation}
* and this one, but with this implementation there will be no overhead at all.
*/
public class NoopOpenTelemetry implements OpenTelemetry {
public final class NoopOpenTelemetry implements OpenTelemetry {

private static final OpenTelemetry INSTANCE = new NoopOpenTelemetry();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,10 +11,10 @@
import io.opentelemetry.sdk.logs.data.LogRecordData;
import java.util.function.Predicate;

public class FilteringLogRecordProcessor implements LogRecordProcessor {
public final class FilteringLogRecordProcessor implements LogRecordProcessor {

public final LogRecordProcessor delegate;
public final Predicate<LogRecordData> predicate;
private final LogRecordProcessor delegate;
private final Predicate<LogRecordData> predicate;
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

it seems reasonable to me to expect that people would not be relying on these being available


public FilteringLogRecordProcessor(
LogRecordProcessor delegate, Predicate<LogRecordData> predicate) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@

@SuppressWarnings("rawtypes")
@AutoService(ComponentProvider.class)
public class AppServerResourceDetector implements ComponentProvider<Resource> {
public final class AppServerResourceDetector implements ComponentProvider<Resource> {

@Override
public Class<Resource> getType() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
import io.opentelemetry.sdk.autoconfigure.spi.traces.ConfigurableSamplerProvider;
import io.opentelemetry.sdk.trace.samplers.Sampler;

public class LinksParentAlwaysOnSamplerProvider implements ConfigurableSamplerProvider {
public final class LinksParentAlwaysOnSamplerProvider implements ConfigurableSamplerProvider {
@Override
public Sampler createSampler(ConfigProperties config) {
return LinksBasedSampler.create(Sampler.parentBased(Sampler.alwaysOn()));
Expand Down
Loading