class InMemoryCachedDistributedMetaStorageBridge {

    public void iterate(
        String globalKeyPrefix,
        BiConsumer<String, ? super Serializable> cb
    ) throws IgniteCheckedException {
        for (Map.Entry<String, byte[]> entry : cache.tailMap(globalKeyPrefix).entrySet()) {
            if (!entry.getKey().startsWith(globalKeyPrefix))
                break;

            cb.accept(entry.getKey(), unmarshal(marshaller, entry.getValue()));
        }
    }

    public  InMemoryCachedDistributedMetaStorageBridge(JdkMarshaller marshaller);

}