Green-Sky/solanaceae_object_store
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add file2 experimentally to the backend interface

Browse Source
This commit is contained in:
Green Sky 2024-07-16 15:56:30 +02:00
parent bccf7680e6
commit d9a9fe7a74
No known key found for this signature in database
2 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/solanaceae/object_store/object_store.cpp
View File

@ -4,6 +4,8 @@
#include "./serializer_json.hpp"
#include <solanaceae/file/file2.hpp>
#include <nlohmann/json.hpp> // this sucks
#include <iostream>
@ -70,6 +72,10 @@ bool StorageBackendI::write(Object o, const ByteSpan data) {
return write(o, fn_cb);
}
std::unique_ptr<File2I> StorageBackendI::file2(Object o, FILE2_FLAGS flags) {
return nullptr;
}
ObjectStore2::ObjectStore2(void) {
// HACK: set them up independently
auto& sjc = _reg.ctx().emplace<SerializerJsonCallbacks<Object>>();

12
src/solanaceae/object_store/object_store.hpp
View File

@ -15,6 +15,7 @@ using ObjectHandle = entt::basic_handle<ObjectRegistry>;
// fwd
struct ObjectStore2;
struct File2I;
struct StorageBackendI {
// OR or OS ?
@ -35,6 +36,15 @@ struct StorageBackendI {
using read_from_storage_put_data_cb = void(const ByteSpan buffer);
virtual bool read(Object o, std::function<read_from_storage_put_data_cb>& data_cb) = 0;
// ========== File2 interop ==========
enum FILE2_FLAGS : uint32_t {
FILE2_READ = 1u << 0,
FILE2_WRITE = 1u << 1,
};
// TODO: stronger requirements
// the backend might decide to not support writing using file2, if it's eg. zstd compressed
// backends might only support a single file2 instance per object!
std::unique_ptr<File2I> file2(Object o, FILE2_FLAGS flags); // default does nothing
};
namespace ObjectStore::Events {
@ -71,7 +81,7 @@ struct ObjectStoreEventI {
using ObjectStoreEventProviderI = EventProviderI<ObjectStoreEventI>;
struct ObjectStore2 : public ObjectStoreEventProviderI {
static constexpr const char* version {"2"};
static constexpr const char* version {"3"};
ObjectRegistry _reg;