[#11992] Add ServiceId creation and deletion api

commons-buffer/src/test/java/com/navercorp/pinpoint/common/util/BytesUtilsTest.java

@@ -23,9 +23,14 @@
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
 
+import java.io.IOException;
 import java.nio.ByteBuffer;
 import java.nio.charset.StandardCharsets;
 import java.util.Arrays;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Properties;
+import java.util.UUID;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.fail;
@@ -513,4 +518,46 @@ public void testShortToUnsignedShort() {
         assertEquals(32768, BytesUtils.shortToUnsignedShort(maxOver));
         assertEquals(65535, BytesUtils.shortToUnsignedShort((short) -1));
     }
+
+    @Test
+    public void UUIDConversionTest() {
+        UUID uuid = UUID.randomUUID();
+        System.out.println("input: " + uuid);
+
+        byte[] bytes = BytesUtils.toBytes(uuid);
+        System.out.println("bytes: " + Arrays.toString(bytes));
+        System.out.println("bytes toString: " + BytesUtils.toString(bytes));
+
+        UUID convertedUUID = BytesUtils.toUUID(bytes);
+        System.out.println("result: " + convertedUUID);
+
+        org.assertj.core.api.Assertions.assertThat(uuid).isEqualTo(convertedUUID);
+    }
+
+    @Test
+    public void testMapConversion() throws IOException {
+        Map<String, String> tags = new HashMap<>();
+        tags.put("key2", "value2");
+        tags.put("key1", "value1");
+
+        System.out.println("----input----");
+        System.out.println("map: " + tags);
+
+        Properties properties = new Properties();
+        properties.putAll(tags);
+        System.out.println("java properties: " + properties);
+        System.out.print("properties.store(): ");
+        properties.store(System.out, null);
+
+
+        System.out.println("----output----");
+        byte[] bytes = BytesUtils.toBytes(tags);
+        System.out.println("bytes: " + Arrays.toString(bytes));
+        System.out.println("bytes toString: " + BytesUtils.toString(bytes));
+
+        Map<String, String> convertedTags = BytesUtils.toMap(bytes);
+        System.out.println("map: " + convertedTags);
+
+        org.assertj.core.api.Assertions.assertThat(tags).isEqualTo(convertedTags);
+    }
 }

commons-hbase/src/main/java/com/navercorp/pinpoint/common/hbase/HbaseColumnFamily.java

@@ -88,6 +88,21 @@ private ApplicationIndex(HbaseTable hBaseTable, byte[] columnFamilyName) {
         }
     }
 
+    public static final ServiceId SERVICE_ID = new ServiceId(HbaseTable.SERVICE_ID, Bytes.toBytes("I"));
+    public static class ServiceId extends HbaseColumnFamily {
+        private ServiceId(HbaseTable hBaseTable, byte[] columnFamilyName) {
+            super(hBaseTable, columnFamilyName);
+        }
+    }
+
+    public static final ServiceInfo SERVICE_NAME = new ServiceInfo(HbaseTable.SERVICE_INFO, Bytes.toBytes("N"));
+    public static final ServiceInfo SERVICE_INFO = new ServiceInfo(HbaseTable.SERVICE_INFO, Bytes.toBytes("I"));
+    public static class ServiceInfo extends HbaseColumnFamily {
+        private ServiceInfo(HbaseTable hBaseTable, byte[] columnFamilyName) {
+            super(hBaseTable, columnFamilyName);
+        }
+    }
+
     public static final ApplicationStatStatistics APPLICATION_STAT_STATISTICS = new ApplicationStatStatistics(HbaseTable.APPLICATION_STAT_AGGRE, Bytes.toBytes("S"));
     public static class ApplicationStatStatistics extends HbaseColumnFamily {
         public int TIMESPAN_MS = 5 * 60 * 1000;

commons-hbase/src/main/java/com/navercorp/pinpoint/common/hbase/HbaseTable.java

@@ -28,6 +28,8 @@ public enum HbaseTable {
     AGENT_STAT_VER2("AgentStatV2"),
     AGENT_URI_STAT("AgentUriStat"),
     API_METADATA("ApiMetaData"),
+    SERVICE_INFO("ServiceInfo"),
+    SERVICE_ID("ServiceId"),
     APPLICATION_INDEX("ApplicationIndex"),
     APPLICATION_STAT_AGGRE("ApplicationStatAggre"),
     APPLICATION_TRACE_INDEX("ApplicationTraceIndex"),

commons-server/src/main/java/com/navercorp/pinpoint/common/server/bo/id/ServiceInfo.java

@@ -0,0 +1,53 @@
+package com.navercorp.pinpoint.common.server.bo.id;
+
+import jakarta.annotation.Nullable;
+
+import java.util.Collections;
+import java.util.Map;
+import java.util.Objects;
+import java.util.UUID;
+
+public class ServiceInfo {
+
+    public static final UUID DEFAULT_SERVICE_ID = new UUID(0, 0);
+    public static final ServiceInfo DEFAULT = new ServiceInfo(DEFAULT_SERVICE_ID, "DEFAULT", Collections.emptyMap());
+
+    private final UUID serviceId;
+    private final String serviceName;
+
+    private final Map<String, String> tags;
+
+    public ServiceInfo(UUID serviceId, String serviceName,
+                       @Nullable Map<String, String> tags) {
+        this.serviceId = Objects.requireNonNull(serviceId, "serviceId");
+        this.serviceName = Objects.requireNonNull(serviceName, "serviceName");
+        this.tags = tags;
+    }
+
+    public UUID getServiceId() {
+        return serviceId;
+    }
+
+    public String getServiceName() {
+        return serviceName;
+    }
+
+    public Map<String, String> getTags() {
+        return tags;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+
+        ServiceInfo that = (ServiceInfo) o;
+
+        return serviceId.equals(that.serviceId);
+    }
+
+    @Override
+    public int hashCode() {
+        return serviceId.hashCode();
+    }
+}

commons-server/src/main/java/com/navercorp/pinpoint/common/server/dao/hbase/mapper/id/ServiceIdMapper.java

@@ -0,0 +1,27 @@
+package com.navercorp.pinpoint.common.server.dao.hbase.mapper.id;
+
+import com.navercorp.pinpoint.common.hbase.HbaseColumnFamily;
+import com.navercorp.pinpoint.common.hbase.RowMapper;
+import com.navercorp.pinpoint.common.util.BytesUtils;
+import org.apache.hadoop.hbase.client.Result;
+import org.springframework.stereotype.Component;
+
+import java.util.UUID;
+
+@Component
+public class ServiceIdMapper implements RowMapper<UUID> {
+
+    private static final HbaseColumnFamily.ServiceId DESCRIPTOR = HbaseColumnFamily.SERVICE_ID;
+
+    @Override
+    public UUID mapRow(Result result, int rowNum) throws Exception {
+        if (result.isEmpty()) {
+            return null;
+        }
+        byte[] family = DESCRIPTOR.getName();
+        byte[] qualifier = DESCRIPTOR.getName();
+
+        byte[] serializedServiceId = result.getValue(family, qualifier);
+        return BytesUtils.toUUID(serializedServiceId);
+    }
+}

commons-server/src/main/java/com/navercorp/pinpoint/common/server/dao/hbase/mapper/id/ServiceIdNameMapper.java

@@ -0,0 +1,19 @@
+package com.navercorp.pinpoint.common.server.dao.hbase.mapper.id;
+
+import com.navercorp.pinpoint.common.hbase.RowMapper;
+import com.navercorp.pinpoint.common.util.BytesUtils;
+import org.apache.hadoop.hbase.client.Result;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ServiceIdNameMapper implements RowMapper<String> {
+
+    @Override
+    public String mapRow(Result result, int rowNum) throws Exception {
+        if (result.isEmpty()) {
+            return null;
+        }
+        byte[] rowKey = result.getRow();
+        return BytesUtils.toString(rowKey);
+    }
+}

commons-server/src/main/java/com/navercorp/pinpoint/common/server/dao/hbase/mapper/id/ServiceInfoMapper.java

@@ -0,0 +1,36 @@
+package com.navercorp.pinpoint.common.server.dao.hbase.mapper.id;
+
+import com.navercorp.pinpoint.common.hbase.HbaseColumnFamily;
+import com.navercorp.pinpoint.common.hbase.RowMapper;
+import com.navercorp.pinpoint.common.server.bo.id.ServiceInfo;
+import com.navercorp.pinpoint.common.util.BytesUtils;
+import org.apache.hadoop.hbase.client.Result;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+import java.util.UUID;
+
+@Component
+public class ServiceInfoMapper implements RowMapper<ServiceInfo> {
+
+    private static final HbaseColumnFamily.ServiceInfo NAME = HbaseColumnFamily.SERVICE_NAME;
+    private static final HbaseColumnFamily.ServiceInfo INFO = HbaseColumnFamily.SERVICE_INFO;
+
+    public ServiceInfo mapRow(Result result, int rowNum) throws Exception {
+        if (result.isEmpty()) {
+            return null;
+        }
+        byte[] rowKey = result.getRow();
+        UUID serviceId = BytesUtils.toUUID(rowKey);
+
+        byte[] serviceNameBytes = result.getValue(NAME.getName(), NAME.getName());
+        String serviceName = BytesUtils.toString(serviceNameBytes);
+
+        Map<String, String> tags = null;
+        byte[] tagsBytes = result.getValue(INFO.getName(), INFO.getName());
+        if (tagsBytes != null) {
+            tags = BytesUtils.toMap(tagsBytes);
+        }
+        return new ServiceInfo(serviceId, serviceName, tags);
+    }
+}

commons-server/src/main/java/com/navercorp/pinpoint/common/server/dao/hbase/mapper/id/ServiceInfoNameMapper.java

@@ -0,0 +1,25 @@
+package com.navercorp.pinpoint.common.server.dao.hbase.mapper.id;
+
+import com.navercorp.pinpoint.common.hbase.HbaseColumnFamily;
+import com.navercorp.pinpoint.common.hbase.RowMapper;
+import com.navercorp.pinpoint.common.util.BytesUtils;
+import org.apache.hadoop.hbase.client.Result;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ServiceInfoNameMapper implements RowMapper<String> {
+
+    private static final HbaseColumnFamily.ServiceInfo DESCRIPTOR = HbaseColumnFamily.SERVICE_NAME;
+
+    @Override
+    public String mapRow(Result result, int rowNum) throws Exception {
+        if (result.isEmpty()) {
+            return null;
+        }
+        byte[] family = DESCRIPTOR.getName();
+        byte[] qualifier = DESCRIPTOR.getName();
+
+        byte[] serializedServiceName = result.getValue(family, qualifier);
+        return BytesUtils.toString(serializedServiceName);
+    }
+}