/************************************************************************ * EOS - the CERN Disk Storage System * * Copyright (C) 2018 CERN/Switzerland * * * * This program is free software: you can redistribute it and/or modify * * it under the terms of the GNU General Public License as published by * * the Free Software Foundation, either version 3 of the License, or * * (at your option) any later version. * * * * This program is distributed in the hope that it will be useful, * * but WITHOUT ANY WARRANTY; without even the implied warranty of * * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * * GNU General Public License for more details. * * * * You should have received a copy of the GNU General Public License * * along with this program. If not, see .* ************************************************************************/ //------------------------------------------------------------------------------ //! @author Georgios Bitzes //! @brief Single class which builds redis requests towards the backend. //------------------------------------------------------------------------------ #pragma once #include "namespace/Namespace.hh" #include "namespace/interface/IContainerMD.hh" #include "namespace/interface/IFileMD.hh" #include "namespace/interface/Identifiers.hh" #include #include EOSNSNAMESPACE_BEGIN class IContainerMD; class IFileMD; using RedisRequest = std::vector; class RequestBuilder { public: //---------------------------------------------------------------------------- //! Write container protobuf metadata. //---------------------------------------------------------------------------- static RedisRequest writeContainerProto(IContainerMD* obj); //---------------------------------------------------------------------------- //! Write container protobuf metadata - low level API. //---------------------------------------------------------------------------- static RedisRequest writeContainerProto(ContainerIdentifier id, const std::string& hint, const std::string& blob); //---------------------------------------------------------------------------- //! Write file protobuf metadata. //---------------------------------------------------------------------------- static RedisRequest writeFileProto(IFileMD* obj); //---------------------------------------------------------------------------- //! Write file protobuf metadata - low level API. //---------------------------------------------------------------------------- static RedisRequest writeFileProto(FileIdentifier id, const std::string& hint, const std::string& blob); //---------------------------------------------------------------------------- //! Read container protobuf metadata. //---------------------------------------------------------------------------- static RedisRequest readContainerProto(ContainerIdentifier id); //---------------------------------------------------------------------------- //! Read file protobuf metadata. //---------------------------------------------------------------------------- static RedisRequest readFileProto(FileIdentifier id); //---------------------------------------------------------------------------- //! Delete container protobuf metadata. //---------------------------------------------------------------------------- static RedisRequest deleteContainerProto(ContainerIdentifier id); //---------------------------------------------------------------------------- //! Delete file protobuf metadata. //---------------------------------------------------------------------------- static RedisRequest deleteFileProto(FileIdentifier id); //---------------------------------------------------------------------------- //! Calculate number of containers. //---------------------------------------------------------------------------- static RedisRequest getNumberOfContainers(); //---------------------------------------------------------------------------- //! Calculate number of files. //---------------------------------------------------------------------------- static RedisRequest getNumberOfFiles(); //---------------------------------------------------------------------------- //! Generate a cache-invalidation notification for a particular fid //---------------------------------------------------------------------------- static RedisRequest notifyCacheInvalidationFid(FileIdentifier id); //---------------------------------------------------------------------------- //! Generate a cache-invalidation notification for a particular cid //---------------------------------------------------------------------------- static RedisRequest notifyCacheInvalidationCid(ContainerIdentifier id); //---------------------------------------------------------------------------- //! Get key for files contained within a filesystem. //---------------------------------------------------------------------------- static std::string keyFilesystemFiles(IFileMD::location_t location); //---------------------------------------------------------------------------- //! Get key for unlinked files contained within a filesystem. //! (files pending deletion) //---------------------------------------------------------------------------- static std::string keyFilesystemUnlinked(IFileMD::location_t location); }; EOSNSNAMESPACE_END