Skip to content

Commit c2cdfeb

Browse files
added log to salts writer and used formatted logs for job dispatcher
1 parent 87861bb commit c2cdfeb

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

src/main/java/com/uid2/admin/job/JobDispatcher.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ public CompletableFuture<Boolean> executeNextJob() {
123123
success = true;
124124
long after = System.currentTimeMillis();
125125
long durationMs = after - before;
126-
LOGGER.info("Job successfully executed: {} in {}ms", currentJobId, durationMs);
126+
LOGGER.info("Job successfully executed: job_id={} duration_ms={}", currentJobId, durationMs);
127127
break;
128128
} catch (Throwable t) {
129129
if (retryCount < maxRetries) {

src/main/java/com/uid2/admin/store/writer/EncryptedSaltStoreWriter.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,8 @@ public class EncryptedSaltStoreWriter extends SaltStoreWriter implements StoreWr
2727
private StoreScope scope;
2828
private RotatingCloudEncryptionKeyProvider cloudEncryptionKeyProvider;
2929
private Integer siteId;
30-
3130
private static final Logger LOGGER = LoggerFactory.getLogger(EncryptedSaltStoreWriter.class);
31+
3232
public EncryptedSaltStoreWriter(JsonObject config, RotatingSaltProvider provider, FileManager fileManager,
3333
TaggableCloudStorage cloudStorage, VersionGenerator versionGenerator, StoreScope scope,
3434
RotatingCloudEncryptionKeyProvider cloudEncryptionKeyProvider, Integer siteId) {
@@ -80,6 +80,7 @@ protected void uploadSaltsSnapshot(RotatingSaltProvider.SaltSnapshot snapshot, S
8080
}
8181

8282
this.upload(newSaltsFile.toString(), location);
83+
LOGGER.info("File encryption completed for site_id={} key_id={} store={}", siteId, encryptionKey.getId(), "salts");
8384
}
8485

8586
@Override

0 commit comments

Comments
 (0)