RediGo

A way to ensure fetching / editing real data from the database by storing objects temporarily in redis and persisting them with MongoDB

TLDR

• Uses MongoDB to persist data
• Uses Redis to store recently changed data for the amount of time you set
• Uses Redis locks to edit real time data.
• This will fix issues where data may not be the most recent when switching to difference instances quickly

How to use RediGo

Create RediGo instance

    new RediGo("core", mongoClient, redissonClient, gson);

Create a RediGo object

@Data
@RequiredArgsConstructor
public class AltEntry implements RediGoObject<String, AltEntry.AltProfileSnapshot> {

    private final String hashedIp;

    @RediGoValue(key = "relatedIds")
    private Set<UUID> relatedIds = new HashSet<>();

    public void addUuid(UUID uuid) {
        this.relatedIds.add(uuid);
    }

    @Override
    public String getKey() {
        return this.hashedIp;
    }

    @Override
    public AltProfileSnapshot getSnapshot() {
        return new AltProfileSnapshot(this.hashedIp, this.relatedIds);
    }

    @Data
    @RequiredArgsConstructor
    public static class AltProfileSnapshot implements Snapshot {
        private final String hashedIp;
        private final Set<UUID> relatedIds;
    }
}

Create a RediGo collection

   redigoInstance.createCollection("alts", String.class, AltEntry.class, 30, false, AltEntry::new);

Get a RediGo real time object from the collection

    public AltEntry.AltProfileSnapshot getAlts(String hashedIp) {
        return this.collection.getOrCreateRealValue(hashedIp);
    }

Update a RediGo real time object from the collection

    public AltEntry.AltProfileSnapshot addUuid(String hashedIp, UUID uuid) {
        return this.collection.updateRealValue(hashedIp, altEntry -> altEntry.addUuid(uuid));
    }

This is an example setup of RediGo

public class AltManager {

    private final RediGoCollection<AltEntry.AltProfileSnapshot, String, AltEntry> collection;

    public AltManager(Core instance) {
        this.collection = instance.getRediGo().createCollection("alts", String.class, AltEntry.class, 30, false, AltEntry::new);
    }

    public AltEntry.AltProfileSnapshot addUuid(String hashedIp, UUID uuid) {
        return this.collection.updateRealValue(hashedIp, altEntry -> altEntry.addUuid(uuid));
    }

    public AltEntry.AltProfileSnapshot getAlts(String hashedIp) {
        return this.collection.getOrCreateRealValue(hashedIp);
    }
}

@Data
@RequiredArgsConstructor
public class AltEntry implements RediGoObject<String, AltEntry.AltProfileSnapshot> {

    private final String hashedIp;

    @RediGoValue(key = "relatedIds")
    private Set<UUID> relatedIds = new HashSet<>();

    public void addUuid(UUID uuid) {
        this.relatedIds.add(uuid);
    }

    @Override
    public String getKey() {
        return this.hashedIp;
    }

    @Override
    public AltProfileSnapshot getSnapshot() {
        return new AltProfileSnapshot(this.hashedIp, this.relatedIds);
    }

    @Data
    @RequiredArgsConstructor
    public static class AltProfileSnapshot implements Snapshot {
        private final String hashedIp;
        private final Set<UUID> relatedIds;
    }
}

For more examples check out

• Core