mirror of
https://github.com/tiennm99/tjahzi.git
synced 2026-10-14 20:17:49 +00:00
Re #77: Cleanup after debugging and bugfix (incorrect order of arguments).
This commit is contained in:
1 parent
8ee05e3875
commit
52e2381e09
4 files changed
+10
-8
No files matched your search
@@ -144,8 +144,8 @@ public class LokiAppenderBuilder<B extends LokiAppenderBuilder<B>> extends Abstr
|
||||
batchSize,
|
||||
TimeUnit.SECONDS.toMillis(batchWait),
|
||||
bufferSizeBytes,
|
||||
TimeUnit.SECONDS.toMillis(shutdownTimeoutSeconds),
|
||||
logShipperWakeupIntervalMillis,
|
||||
TimeUnit.SECONDS.toMillis(shutdownTimeoutSeconds),
|
||||
isUseOffHeapBuffer()
|
||||
);
|
||||
|
||||
|
||||
+8
-4
@@ -5,6 +5,7 @@ import com.codahale.metrics.MetricRegistry;
|
||||
import org.apache.logging.log4j.LogManager;
|
||||
import org.apache.logging.log4j.Logger;
|
||||
import org.apache.logging.log4j.core.LoggerContext;
|
||||
import org.awaitility.Durations;
|
||||
import org.junit.jupiter.api.Test;
|
||||
import pl.tkowalcz.tjahzi.stats.DropwizardMonitoringModule;
|
||||
|
||||
@@ -45,9 +46,12 @@ class LokiAppenderMonitoringTest {
|
||||
.get("appender.loki.httpConnectAttempts");
|
||||
assertThat(connectAttemptsCounter).isNotNull();
|
||||
|
||||
await().untilAsserted(() -> {
|
||||
assertThat(connectAttemptsCounter.getCount()).isEqualTo(1);
|
||||
}
|
||||
);
|
||||
await()
|
||||
.atMost(Durations.ONE_MINUTE)
|
||||
.pollInterval(Durations.ONE_SECOND)
|
||||
.untilAsserted(() -> {
|
||||
assertThat(connectAttemptsCounter.getCount()).isEqualTo(1);
|
||||
}
|
||||
);
|
||||
}
|
||||
}
|
||||
@@ -19,8 +19,6 @@
|
||||
<Pattern>[%t] %d{DEFAULT} %5p %c{1} - %m%n%exception{full}</Pattern>
|
||||
</PatternLayout>
|
||||
|
||||
<connectTimeoutMillis>100</connectTimeoutMillis>
|
||||
|
||||
<Header name="server" value="127.0.0.1"/>
|
||||
<Label name="server" value="127.0.0.1"/>
|
||||
</Loki>
|
||||
|
||||
@@ -80,8 +80,8 @@ public class LokiAppenderFactory {
|
||||
configurator.getBatchSize(),
|
||||
TimeUnit.SECONDS.toMillis(configurator.getBatchWait()),
|
||||
bufferSizeBytes,
|
||||
TimeUnit.SECONDS.toMillis(configurator.getShutdownTimeoutSeconds()),
|
||||
configurator.getLogShipperWakeupIntervalMillis(),
|
||||
TimeUnit.SECONDS.toMillis(configurator.getShutdownTimeoutSeconds()),
|
||||
configurator.isUseOffHeapBuffer()
|
||||
);
|
||||
}
|
||||
|
||||
Reference in new issue
Block a user