mirror of
https://github.com/tiennm99/tjahzi.git
synced 2026-10-15 12:15:11 +00:00
Corrected the typo in the Thorgal character name.
This commit is contained in:
1 parent
7c6898c72b
commit
20188f9b45
16 files changed
+42
-42
No files matched your search
+1
-1
@@ -4,7 +4,7 @@
|
||||
|
||||
<parent>
|
||||
<groupId>pl.tkowalcz</groupId>
|
||||
<artifactId>thjazi</artifactId>
|
||||
<artifactId>tjahzi</artifactId>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
</parent>
|
||||
|
||||
|
||||
+4
-4
@@ -1,4 +1,4 @@
|
||||
package pl.tkowalcz.thjazi;
|
||||
package pl.tkowalcz.tjahzi;
|
||||
|
||||
import com.google.protobuf.Timestamp;
|
||||
import io.netty.buffer.ByteBuf;
|
||||
@@ -10,8 +10,8 @@ import org.agrona.MutableDirectBuffer;
|
||||
import org.agrona.concurrent.Agent;
|
||||
import org.agrona.concurrent.MessageHandler;
|
||||
import org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer;
|
||||
import pl.tkowalcz.thjazi.http.NettyHttpClient;
|
||||
import pl.tkowalcz.thjazi.http.TextBuilders;
|
||||
import pl.tkowalcz.tjahzi.http.NettyHttpClient;
|
||||
import pl.tkowalcz.tjahzi.http.TextBuilders;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.util.HashMap;
|
||||
@@ -57,7 +57,7 @@ public class LogBufferAgent implements Agent, MessageHandler {
|
||||
|
||||
@Override
|
||||
public void onMessage(int msgTypeId, MutableDirectBuffer buffer, int index, int length) {
|
||||
if (msgTypeId == ThjaziLogger.LOG_MESSAGE_TYPE_ID) {
|
||||
if (msgTypeId == TjahziLogger.LOG_MESSAGE_TYPE_ID) {
|
||||
processMessage(buffer, index);
|
||||
} else {
|
||||
// Ignore
|
||||
+3
-3
@@ -1,4 +1,4 @@
|
||||
package pl.tkowalcz.thjazi;
|
||||
package pl.tkowalcz.tjahzi;
|
||||
|
||||
import org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer;
|
||||
|
||||
@@ -10,7 +10,7 @@ public class LoggingSystem {
|
||||
this.logBuffer = logBuffer;
|
||||
}
|
||||
|
||||
public ThjaziLogger createLogger() {
|
||||
return new ThjaziLogger(logBuffer);
|
||||
public TjahziLogger createLogger() {
|
||||
return new TjahziLogger(logBuffer);
|
||||
}
|
||||
}
|
||||
+3
-3
@@ -1,15 +1,15 @@
|
||||
package pl.tkowalcz.thjazi;
|
||||
package pl.tkowalcz.tjahzi;
|
||||
|
||||
import org.agrona.concurrent.AgentRunner;
|
||||
import org.agrona.concurrent.SleepingMillisIdleStrategy;
|
||||
import org.agrona.concurrent.UnsafeBuffer;
|
||||
import org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer;
|
||||
import org.agrona.concurrent.ringbuffer.RingBufferDescriptor;
|
||||
import pl.tkowalcz.thjazi.http.NettyHttpClient;
|
||||
import pl.tkowalcz.tjahzi.http.NettyHttpClient;
|
||||
|
||||
import java.nio.ByteBuffer;
|
||||
|
||||
public class ThjaziInitializer {
|
||||
public class TjahziInitializer {
|
||||
|
||||
public LoggingSystem createLoggingSystem(
|
||||
NettyHttpClient httpClient,
|
||||
+4
-4
@@ -1,21 +1,21 @@
|
||||
package pl.tkowalcz.thjazi;
|
||||
package pl.tkowalcz.tjahzi;
|
||||
|
||||
import org.agrona.concurrent.AtomicBuffer;
|
||||
import org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
public class ThjaziLogger {
|
||||
public class TjahziLogger {
|
||||
|
||||
public static final int LOG_MESSAGE_TYPE_ID = 5;
|
||||
|
||||
private final ManyToOneRingBuffer logBuffer;
|
||||
|
||||
public ThjaziLogger(ManyToOneRingBuffer logBuffer) {
|
||||
public TjahziLogger(ManyToOneRingBuffer logBuffer) {
|
||||
this.logBuffer = logBuffer;
|
||||
}
|
||||
|
||||
public ThjaziLogger log(long timestamp,
|
||||
public TjahziLogger log(long timestamp,
|
||||
Map<String, String> labels,
|
||||
String line) {
|
||||
int requiredSize = calculateRequiredSizeAscii(labels, line);
|
||||
+1
-1
@@ -1,4 +1,4 @@
|
||||
package pl.tkowalcz.thjazi.http;
|
||||
package pl.tkowalcz.tjahzi.http;
|
||||
|
||||
public class ClientConfiguration {
|
||||
|
||||
+1
-1
@@ -1,4 +1,4 @@
|
||||
package pl.tkowalcz.thjazi.http;
|
||||
package pl.tkowalcz.tjahzi.http;
|
||||
|
||||
public class ClientConfigurationBuilder {
|
||||
|
||||
+1
-1
@@ -1,4 +1,4 @@
|
||||
package pl.tkowalcz.thjazi.http;
|
||||
package pl.tkowalcz.tjahzi.http;
|
||||
|
||||
public class HttpClientFactory {
|
||||
|
||||
+1
-1
@@ -1,4 +1,4 @@
|
||||
package pl.tkowalcz.thjazi.http;
|
||||
package pl.tkowalcz.tjahzi.http;
|
||||
|
||||
import io.netty.channel.ChannelInitializer;
|
||||
import io.netty.channel.ChannelPipeline;
|
||||
+3
-3
@@ -1,4 +1,4 @@
|
||||
package pl.tkowalcz.thjazi.http;
|
||||
package pl.tkowalcz.tjahzi.http;
|
||||
|
||||
import io.netty.bootstrap.Bootstrap;
|
||||
import io.netty.buffer.ByteBuf;
|
||||
@@ -27,8 +27,8 @@ public class NettyHttpClient implements AutoCloseable {
|
||||
host = clientConfiguration.getHost();
|
||||
logEndpoint = clientConfiguration.getLogEndpoint();
|
||||
|
||||
ThreadGroup threadGroup = new ThreadGroup("Thjazi Loki client");
|
||||
ThreadFactory threadFactory = r -> new Thread(threadGroup, r, "thjazi-worker");
|
||||
ThreadGroup threadGroup = new ThreadGroup("Tjahzi Loki client");
|
||||
ThreadFactory threadFactory = r -> new Thread(threadGroup, r, "tjahzi-worker");
|
||||
group = new NioEventLoopGroup(1, threadFactory);
|
||||
|
||||
Bootstrap bootstrap = new Bootstrap();
|
||||
+1
-1
@@ -1,4 +1,4 @@
|
||||
package pl.tkowalcz.thjazi.http;
|
||||
package pl.tkowalcz.tjahzi.http;
|
||||
|
||||
import io.netty.util.concurrent.FastThreadLocal;
|
||||
import javolution.text.TextBuilder;
|
||||
@@ -1,4 +1,4 @@
|
||||
package pl.tkowalcz.thjazi;
|
||||
package pl.tkowalcz.tjahzi;
|
||||
|
||||
import io.restassured.RestAssured;
|
||||
import io.restassured.http.ContentType;
|
||||
@@ -12,9 +12,9 @@ import org.testcontainers.containers.output.OutputFrame;
|
||||
import org.testcontainers.containers.wait.strategy.Wait;
|
||||
import org.testcontainers.junit.jupiter.Container;
|
||||
import org.testcontainers.junit.jupiter.Testcontainers;
|
||||
import pl.tkowalcz.thjazi.http.ClientConfiguration;
|
||||
import pl.tkowalcz.thjazi.http.HttpClientFactory;
|
||||
import pl.tkowalcz.thjazi.http.NettyHttpClient;
|
||||
import pl.tkowalcz.tjahzi.http.ClientConfiguration;
|
||||
import pl.tkowalcz.tjahzi.http.HttpClientFactory;
|
||||
import pl.tkowalcz.tjahzi.http.NettyHttpClient;
|
||||
|
||||
import java.util.Map;
|
||||
import java.util.function.Consumer;
|
||||
@@ -56,7 +56,7 @@ class LoggingSystemSanityCheckTest {
|
||||
NettyHttpClient httpClient = HttpClientFactory.defaultFactory()
|
||||
.getHttpClient(clientConfiguration);
|
||||
|
||||
ThjaziInitializer initializer = new ThjaziInitializer();
|
||||
TjahziInitializer initializer = new TjahziInitializer();
|
||||
LoggingSystem loggingSystem = initializer.createLoggingSystem(
|
||||
httpClient,
|
||||
1024 * 1024,
|
||||
@@ -65,7 +65,7 @@ class LoggingSystemSanityCheckTest {
|
||||
|
||||
long timestamp = System.currentTimeMillis();
|
||||
|
||||
ThjaziLogger logger = loggingSystem.createLogger();
|
||||
TjahziLogger logger = loggingSystem.createLogger();
|
||||
logger.log(
|
||||
timestamp,
|
||||
Map.of("version", "0.43", "server", "127.0.0.1"),
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
package pl.tkowalcz.thjazi;
|
||||
package pl.tkowalcz.tjahzi;
|
||||
|
||||
import io.restassured.RestAssured;
|
||||
import io.restassured.http.ContentType;
|
||||
@@ -14,9 +14,9 @@ import org.testcontainers.containers.output.OutputFrame;
|
||||
import org.testcontainers.containers.wait.strategy.Wait;
|
||||
import org.testcontainers.junit.jupiter.Container;
|
||||
import org.testcontainers.junit.jupiter.Testcontainers;
|
||||
import pl.tkowalcz.thjazi.http.ClientConfiguration;
|
||||
import pl.tkowalcz.thjazi.http.HttpClientFactory;
|
||||
import pl.tkowalcz.thjazi.http.NettyHttpClient;
|
||||
import pl.tkowalcz.tjahzi.http.ClientConfiguration;
|
||||
import pl.tkowalcz.tjahzi.http.HttpClientFactory;
|
||||
import pl.tkowalcz.tjahzi.http.NettyHttpClient;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
@@ -59,7 +59,7 @@ class LoggingSystemTest {
|
||||
NettyHttpClient httpClient = HttpClientFactory.defaultFactory()
|
||||
.getHttpClient(clientConfiguration);
|
||||
|
||||
ThjaziInitializer initializer = new ThjaziInitializer();
|
||||
TjahziInitializer initializer = new TjahziInitializer();
|
||||
LoggingSystem loggingSystem = initializer.createLoggingSystem(
|
||||
httpClient,
|
||||
1024 * 1024,
|
||||
@@ -68,7 +68,7 @@ class LoggingSystemTest {
|
||||
|
||||
long timestamp = System.currentTimeMillis();
|
||||
|
||||
ThjaziLogger logger = loggingSystem.createLogger();
|
||||
TjahziLogger logger = loggingSystem.createLogger();
|
||||
for (int i = 0; i < 1000; i++) {
|
||||
logger.log(
|
||||
timestamp + i,
|
||||
|
||||
@@ -4,7 +4,7 @@
|
||||
|
||||
<parent>
|
||||
<groupId>pl.tkowalcz</groupId>
|
||||
<artifactId>thjazi</artifactId>
|
||||
<artifactId>tjahzi</artifactId>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
</parent>
|
||||
|
||||
|
||||
@@ -4,7 +4,7 @@
|
||||
|
||||
<parent>
|
||||
<groupId>pl.tkowalcz</groupId>
|
||||
<artifactId>thjazi</artifactId>
|
||||
<artifactId>tjahzi</artifactId>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
</parent>
|
||||
|
||||
|
||||
@@ -3,10 +3,10 @@
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
<groupId>pl.tkowalcz</groupId>
|
||||
<artifactId>thjazi</artifactId>
|
||||
<artifactId>tjahzi</artifactId>
|
||||
<packaging>pom</packaging>
|
||||
|
||||
<description>Thjazi is a low overhead logging client for Loki</description>
|
||||
<description>Tjahzi is a low overhead logging client for Loki</description>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
|
||||
<modules>
|
||||
@@ -16,14 +16,14 @@
|
||||
</modules>
|
||||
|
||||
<scm>
|
||||
<developerConnection>scm:git:git@github.com:tkowalcz/thjazi.git</developerConnection>
|
||||
<url>https://github.com/tkowalcz/thjazi</url>
|
||||
<developerConnection>scm:git:git@github.com:tkowalcz/tjahzi.git</developerConnection>
|
||||
<url>https://github.com/tkowalcz/tjahzi</url>
|
||||
</scm>
|
||||
|
||||
<licenses>
|
||||
<license>
|
||||
<name>MIT License</name>
|
||||
<url>https://github.com/tkowalcz/thjazi/blob/master/LICENSE</url>
|
||||
<url>https://github.com/tkowalcz/tjahzi/blob/master/LICENSE</url>
|
||||
<distribution>repo</distribution>
|
||||
<comments>A short and simple permissive license</comments>
|
||||
</license>
|
||||
|
||||
Reference in new issue
Block a user