IUntillDbStorageApi: updates (#103)

https://dev.untill.com/projects/#!687090

Co-authored-by: sda <[email protected]>

src/main/java/com/untill/driver/untillapi/dbstorage/IUntillDbStorageApi.java

@@ -3,6 +3,8 @@
 import com.untill.driver.IDriverContext;
 import com.untill.driver.untillapi.IUntillApi;
 
+import java.util.List;
+
 /**
  * UntillAPI allows to write/read data bytes to/from DB by driver configuration GUID and key.
  *
@@ -49,6 +51,15 @@ public interface IUntillDbStorageApi extends IUntillApi {
 	 */
 	byte[] read(String configurationGuid, String key);
 
+	/**
+	 * Returns the list of the data entries, written by any of the driver instances in network (same driverId!)
+	 *
+	 * @param thisConfigurationGuid driver configuration GUID
+	 * @param key                   data key
+	 * @return list of {@link StorageItem storage items}
+	 */
+	List<StorageItem> readFromAllConfigs(String thisConfigurationGuid, String key);
+
 	/**
 	 * Write data bytes by driver configuration GUID and key
 	 *
@@ -57,4 +68,14 @@ public interface IUntillDbStorageApi extends IUntillApi {
 	 * @param data              data bytes
 	 */
 	void write(String configurationGuid, String key, byte[] data);
+
+	/**
+	 * Write data bytes by driver configuration GUID and key with expiry date
+	 *
+	 * @param configurationGuid driver configuration GUID
+	 * @param key               data key
+	 * @param data              data bytes
+	 * @param expiryDate        unix timestamp in milliseconds
+	 */
+	void write(String configurationGuid, String key, byte[] data, long expiryDate);
 }

src/main/java/com/untill/driver/untillapi/dbstorage/StorageItem.java

@@ -0,0 +1,28 @@
+package com.untill.driver.untillapi.dbstorage;
+
+public class StorageItem {
+	/**
+	 * Driver configuration GUID
+	 */
+	private String configurationGuid;
+	/**
+	 * Data bytes
+	 */
+	private byte[] data;
+
+	public String getConfigurationGuid() {
+		return configurationGuid;
+	}
+
+	public void setConfigurationGuid(String configurationGuid) {
+		this.configurationGuid = configurationGuid;
+	}
+
+	public byte[] getData() {
+		return data;
+	}
+
+	public void setData(byte[] data) {
+		this.data = data;
+	}
+}