diff --git a/core/pom.xml b/core/pom.xml index f1f7344..cb02064 100644 --- a/core/pom.xml +++ b/core/pom.xml @@ -1,4 +1,5 @@ - 4.0.0 @@ -17,7 +18,7 @@ org.agrona agrona - 1.12.0 + 1.22.0 io.netty @@ -34,77 +35,9 @@ - - pl.tkowalcz.tjahzi - loki-protobuf - 0.9.33-SNAPSHOT - test - - - io.rest-assured - rest-assured - 4.3.1 - test - - - org.awaitility - awaitility - 4.0.3 - test - - - org.assertj - assertj-core - 3.15.0 - test - - - - com.github.tomakehurst - wiremock-jre8 - 2.27.2 - test - - org.apache.logging.log4j log4j-slf4j-impl - 2.13.3 - test - - - com.googlecode.catch-exception - catch-exception - 1.2.0 - test - - - - - org.junit.jupiter - junit-jupiter-api - - - org.junit.jupiter - junit-jupiter-params - - - org.junit.jupiter - junit-jupiter-engine - - - org.testcontainers - testcontainers - - - org.testcontainers - junit-jupiter - - - - org.xerial.snappy - snappy-java - 1.1.8.4 test diff --git a/core/src/test/java/pl/tkowalcz/tjahzi/LogBufferAgentTest.java b/core/src/test/java/pl/tkowalcz/tjahzi/LogBufferAgentTest.java index f1f9df2..004b339 100644 --- a/core/src/test/java/pl/tkowalcz/tjahzi/LogBufferAgentTest.java +++ b/core/src/test/java/pl/tkowalcz/tjahzi/LogBufferAgentTest.java @@ -16,7 +16,10 @@ import java.util.Map; import static org.assertj.core.api.Assertions.assertThat; import static org.mockito.Matchers.any; -import static org.mockito.Mockito.*; +import static org.mockito.Mockito.mock; +import static org.mockito.Mockito.times; +import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.verifyZeroInteractions; class LogBufferAgentTest { @@ -28,9 +31,7 @@ class LogBufferAgentTest { void setUp() { logBuffer = new ManyToOneRingBuffer( new UnsafeBuffer( - ByteBuffer.wrap( - new byte[1024 * 1024 + RingBufferDescriptor.TRAILER_LENGTH] - ) + ByteBuffer.allocateDirect(1024 * 1024 + RingBufferDescriptor.TRAILER_LENGTH) ) ); @@ -72,14 +73,14 @@ class LogBufferAgentTest { LabelSerializerCreator.from(Map.of()), ByteBuffer.wrap(( "Cupcake ipsum dolor sit amet cake wafer. " + - "Soufflé jelly beans biscuit topping. " + - "Danish bonbon gummies powder caramels. " + - "Danish jelly beans sweet roll topping jelly beans oat cake toffee. " + - "Chocolate cake sesame snaps brownie biscuit cheesecake. " + - "Ice cream dessert sweet donut marshmallow. " + - "Muffin bear claw cookie jelly-o sugar plum jelly beans apple pie fruitcake cookie. " + - "Tootsie roll carrot cake pastry jujubes jelly beans chupa chups. " + - "Soufflé cake muffin liquorice tart soufflé pie sesame snaps." + "Soufflé jelly beans biscuit topping. " + + "Danish bonbon gummies powder caramels. " + + "Danish jelly beans sweet roll topping jelly beans oat cake toffee. " + + "Chocolate cake sesame snaps brownie biscuit cheesecake. " + + "Ice cream dessert sweet donut marshmallow. " + + "Muffin bear claw cookie jelly-o sugar plum jelly beans apple pie fruitcake cookie. " + + "Tootsie roll carrot cake pastry jujubes jelly beans chupa chups. " + + "Soufflé cake muffin liquorice tart soufflé pie sesame snaps." ).getBytes()) ); } @@ -176,9 +177,7 @@ class LogBufferAgentTest { ManyToOneRingBuffer logBuffer = new ManyToOneRingBuffer( new UnsafeBuffer( - ByteBuffer.wrap( - new byte[1024 + RingBufferDescriptor.TRAILER_LENGTH] - ) + ByteBuffer.allocateDirect(1024 + RingBufferDescriptor.TRAILER_LENGTH) ) ); @@ -234,9 +233,7 @@ class LogBufferAgentTest { // Given ManyToOneRingBuffer logBuffer = new ManyToOneRingBuffer( new UnsafeBuffer( - ByteBuffer.wrap( - new byte[64 * 1024 + RingBufferDescriptor.TRAILER_LENGTH] - ) + ByteBuffer.allocateDirect(64 * 1024 + RingBufferDescriptor.TRAILER_LENGTH) ) ); diff --git a/core/src/test/java/pl/tkowalcz/tjahzi/LogBufferSerializerDeserializerTest.java b/core/src/test/java/pl/tkowalcz/tjahzi/LogBufferSerializerDeserializerTest.java index 9c70431..b428e64 100644 --- a/core/src/test/java/pl/tkowalcz/tjahzi/LogBufferSerializerDeserializerTest.java +++ b/core/src/test/java/pl/tkowalcz/tjahzi/LogBufferSerializerDeserializerTest.java @@ -1,6 +1,5 @@ package pl.tkowalcz.tjahzi; -import com.google.common.collect.Streams; import com.google.protobuf.InvalidProtocolBufferException; import com.google.protobuf.Timestamp; import io.netty.buffer.ByteBuf; @@ -34,12 +33,12 @@ class LogBufferSerializerDeserializerTest { "WARN", "[Mando] You have something I want.", 38 // log line - + 21 // log level - + 45 // labels string sizes - + 6 * 4 // labels string length indicators - + 8 // timestamp millis - + 8 // timestamp nanos - + 4 // labels count + + 21 // log level + + 45 // labels string sizes + + 6 * 4 // labels string length indicators + + 8 // timestamp millis + + 8 // timestamp nanos + + 4 // labels count ), Arguments.of( "Message with empty labels", @@ -48,10 +47,10 @@ class LogBufferSerializerDeserializerTest { "WARN", "[Mando] You have something I want.", 38 // log line - + 21 // log level - + 8 // timestamp millis - + 8 // timestamp nanos - + 4 // labels count + + 21 // log level + + 8 // timestamp millis + + 8 // timestamp nanos + + 4 // labels count ), Arguments.of( "Message with null log level", @@ -63,11 +62,11 @@ class LogBufferSerializerDeserializerTest { null, "[Mando] You have something I want.", 38 // log line - + 45 // labels string sizes - + 6 * 4 // labels string length indicators - + 8 // timestamp millis - + 8 // timestamp nanos - + 4 // labels count + + 45 // labels string sizes + + 6 * 4 // labels string length indicators + + 8 // timestamp millis + + 8 // timestamp nanos + + 4 // labels count ) ); } @@ -133,10 +132,7 @@ class LogBufferSerializerDeserializerTest { Stream incomingLabelsStream = toPropertyStream(labels); assertThat(stream.getLabels()).isEqualToIgnoringWhitespace( - Streams.concat( - incomingLabelsStream, - logLevelStream - ) + Stream.concat(incomingLabelsStream, logLevelStream) .collect(joining(",", "{", "}")) ); } diff --git a/core/src/test/java/pl/tkowalcz/tjahzi/LogBufferTranscoderTest.java b/core/src/test/java/pl/tkowalcz/tjahzi/LogBufferTranscoderTest.java index ff19f90..1925c9c 100644 --- a/core/src/test/java/pl/tkowalcz/tjahzi/LogBufferTranscoderTest.java +++ b/core/src/test/java/pl/tkowalcz/tjahzi/LogBufferTranscoderTest.java @@ -1,6 +1,5 @@ package pl.tkowalcz.tjahzi; -import com.google.common.collect.Streams; import com.google.protobuf.InvalidProtocolBufferException; import com.google.protobuf.Timestamp; import io.netty.buffer.ByteBuf; @@ -16,6 +15,7 @@ import org.junit.jupiter.params.provider.MethodSource; import java.nio.ByteBuffer; import java.util.LinkedHashMap; import java.util.Map; +import java.util.function.Function; import java.util.stream.Stream; import static java.util.stream.Collectors.joining; @@ -91,11 +91,12 @@ class LogBufferTranscoderTest { Stream staticLabelsStream = toPropertyStream(staticLabels); assertThat(stream.getLabels()).isEqualToIgnoringWhitespace( - Streams.concat( - incomingLabelsStream, - logLevelStream, - staticLabelsStream - ) + Stream.of( + incomingLabelsStream, + logLevelStream, + staticLabelsStream + ) + .flatMap(Function.identity()) .collect(joining(",", "{", "}")) ); } diff --git a/log4j2-appender/pom.xml b/log4j2-appender/pom.xml index 9921996..f526ed9 100644 --- a/log4j2-appender/pom.xml +++ b/log4j2-appender/pom.xml @@ -17,7 +17,7 @@ pl.tkowalcz.tjahzi core - 0.9.33-SNAPSHOT + ${project.version} @@ -37,70 +37,6 @@ org.apache.logging.log4j log4j-slf4j-impl - 2.17.0 - test - - - org.mockito - mockito-core - 3.9.0 - test - - - - com.google.code.java-allocation-instrumenter - java-allocation-instrumenter - 3.3.0 - test - - - io.rest-assured - rest-assured - 4.3.1 - test - - - org.awaitility - awaitility - 4.0.3 - test - - - org.assertj - assertj-core - 3.15.0 - test - - - - - org.junit.jupiter - junit-jupiter-api - - - org.junit.jupiter - junit-jupiter-params - - - org.junit.jupiter - junit-jupiter-engine - - - org.testcontainers - testcontainers - - - org.testcontainers - junit-jupiter - - - org.testcontainers - nginx - - - com.alibaba - dns-cache-manipulator - 1.8.1 test diff --git a/logback-appender-nodep/pom.xml b/logback-appender-nodep/pom.xml index 14f87ab..24f62eb 100644 --- a/logback-appender-nodep/pom.xml +++ b/logback-appender-nodep/pom.xml @@ -22,7 +22,7 @@ pl.tkowalcz.tjahzi logback-appender - 0.9.33-SNAPSHOT + ${project.version} diff --git a/logback-appender/pom.xml b/logback-appender/pom.xml index 37f7aaa..0cbacb1 100644 --- a/logback-appender/pom.xml +++ b/logback-appender/pom.xml @@ -1,4 +1,5 @@ - 4.0.0 @@ -12,13 +13,12 @@ logback-appender logback-appender jar - 0.9.33-SNAPSHOT pl.tkowalcz.tjahzi core - 0.9.33-SNAPSHOT + ${project.version} @@ -41,7 +41,6 @@ tests test - ch.qos.logback logback-core @@ -49,62 +48,6 @@ tests test - - - com.google.code.java-allocation-instrumenter - java-allocation-instrumenter - 3.3.0 - test - - - io.rest-assured - rest-assured - 4.3.1 - test - - - org.awaitility - awaitility - 4.0.3 - test - - - org.assertj - assertj-core - 3.15.0 - test - - - - - org.testcontainers - testcontainers - - - org.testcontainers - junit-jupiter - - - org.testcontainers - nginx - - - - org.junit.jupiter - junit-jupiter-api - - - org.junit.jupiter - junit-jupiter-params - - - org.junit.jupiter - junit-jupiter-engine - - - org.junit.vintage - junit-vintage-engine - @@ -123,8 +66,12 @@ - com.google.code.java-allocation-instrumenter - java-allocation-instrumenter + + com.google.code.java-allocation-instrumenter + + + java-allocation-instrumenter + 3.3.0 diff --git a/pom.xml b/pom.xml index be78ee8..d88fcde 100644 --- a/pom.xml +++ b/pom.xml @@ -1,4 +1,5 @@ - 4.0.0 @@ -9,12 +10,13 @@ 0.9.33-SNAPSHOT Tjahzi - Tjahzi is a low overhead logging client for Loki + Tjahzi is a low overhead logging client for Loki + https://github.com/tkowalcz/tjahzi core - loki-protobuf + log4j2-appender log4j2-appender-nodep @@ -24,7 +26,9 @@ - scm:git:git@github.com:tkowalcz/tjahzi.git + + scm:git:git@github.com:tkowalcz/tjahzi.git + https://github.com/tkowalcz/tjahzi tjahzi-0.7 @@ -32,18 +36,24 @@ ossrh - https://oss.sonatype.org/content/repositories/snapshots + + https://oss.sonatype.org/content/repositories/snapshots + ossrh - https://oss.sonatype.org/service/local/staging/deploy/maven2/ + + https://oss.sonatype.org/service/local/staging/deploy/maven2/ + MIT License - https://github.com/tkowalcz/tjahzi/blob/master/LICENSE + + https://github.com/tkowalcz/tjahzi/blob/master/LICENSE + repo A short and simple permissive license @@ -57,7 +67,8 @@ - UTF-8 + UTF-8 + 8 8 @@ -72,50 +83,141 @@ - org.junit.jupiter - junit-jupiter-api - 5.11.4 - test - - - org.junit.jupiter - junit-jupiter-params - 5.11.4 - test - - - org.junit.jupiter - junit-jupiter-engine - 5.11.4 - test - - - org.junit.vintage - junit-vintage-engine - 5.11.4 - test - - - org.testcontainers - testcontainers - 1.20.4 - test - - - org.testcontainers - nginx - 1.20.4 - test - - - org.testcontainers - junit-jupiter - 1.20.4 + org.apache.logging.log4j + log4j-slf4j-impl + 2.13.3 test + + + + pl.tkowalcz.tjahzi + loki-protobuf + ${project.version} + test + + + + + io.rest-assured + rest-assured + 5.5.0 + test + + + org.awaitility + awaitility + 4.2.2 + test + + + org.assertj + assertj-core + 3.27.3 + test + + + + org.wiremock + wiremock + 3.11.0 + test + + + + com.googlecode.catch-exception + catch-exception + 1.2.0 + test + + + + org.xerial.snappy + snappy-java + 1.1.10.7 + test + + + org.junit.jupiter + junit-jupiter-api + 5.11.4 + test + + + org.junit.jupiter + junit-jupiter-params + 5.11.4 + test + + + org.junit.jupiter + junit-jupiter-engine + 5.11.4 + test + + + org.junit.vintage + junit-vintage-engine + 5.11.4 + test + + + org.testcontainers + testcontainers + 1.20.4 + test + + + org.testcontainers + nginx + 1.20.4 + test + + + org.testcontainers + junit-jupiter + 1.20.4 + test + + + + org.mockito + mockito-core + 3.9.0 + test + + + com.google.code.java-allocation-instrumenter + + java-allocation-instrumenter + 3.3.0 + test + + + com.alibaba + dns-cache-manipulator + 1.8.3 + test + + + + ch.qos.logback + logback-core + 1.3.15 + tests + test + + + ch.qos.logback + logback-classic + 1.3.15 + tests + test + + @@ -127,7 +229,7 @@ org.apache.maven.plugins maven-surefire-plugin - 2.22.2 + 3.5.2 org.apache.maven.plugins @@ -157,15 +259,12 @@ - - org.apache.maven.plugins - maven-surefire-plugin - maven-compiler-plugin ${maven.compiler.target} - ${maven.compiler.testTarget} + ${maven.compiler.testTarget} + @@ -187,8 +286,10 @@ false - com.google.protobuf.* - ${java.home}/bin/javadoc + com.google.protobuf.* + + ${java.home}/bin/javadoc + @@ -240,5 +341,30 @@ ${env.GPG_PASSPHRASE} + + + java16+ + + [16,) + + + + + + org.apache.maven.plugins + maven-surefire-plugin + + 3.5.2 + + + --add-opens java.base/java.net=ALL-UNNAMED + --add-opens java.base/sun.net=ALL-UNNAMED + + + + + + +