@Override
    public DistroData getDatumSnapshot() {
        List<ClientSyncData> datum = new LinkedList<>();
        for (String each : clientManager.allClientId()) {
            Client client = clientManager.getClient(each);
            if (null == client || !client.isEphemeral()) {
                continue;
            }
            datum.add(client.generateSyncData());
        }
        ClientSyncDatumSnapshot snapshot = new ClientSyncDatumSnapshot();
        snapshot.setClientSyncDataList(datum);
        byte[] data = ApplicationUtils.getBean(Serializer.class).serialize(snapshot);
        return new DistroData(new DistroKey(DataOperation.SNAPSHOT.name(), TYPE), data);
    }
@Test
    void testGetDatumSnapshot() {
        when(clientManager.allClientId()).thenReturn(Collections.singletonList(CLIENT_ID));
        DistroData actual = distroClientDataProcessor.getDatumSnapshot();
        assertEquals(DataOperation.SNAPSHOT.name(), actual.getDistroKey().getResourceKey());
        assertEquals(DistroClientDataProcessor.TYPE, actual.getDistroKey().getResourceType());
    }