5 #ifndef CVMFS_UPLOAD_GATEWAY_H_
6 #define CVMFS_UPLOAD_GATEWAY_H_
31 : session_token_file(session_token_file),
53 virtual bool FinalizeSession(
bool commit,
const std::string& old_root_hash,
54 const std::string& new_root_hash,
59 virtual std::string
name()
const;
61 virtual bool Peek(
const std::string& path);
63 virtual bool Mkdir(
const std::string &path);
70 virtual void DoUpload(
const std::string& remote_path,
83 virtual void DoRemoveAsync(
const std::string& file_to_delete);
89 virtual bool ReadKey(
const std::string& key_file, std::string* key_id,
104 #endif // CVMFS_UPLOAD_GATEWAY_H_
static bool WillHandle(const SpoolerDefinition &spooler_definition)
virtual int64_t DoGetObjectSize(const std::string &file_name)
virtual std::string name() const
virtual bool Peek(const std::string &path)
virtual bool PlaceBootstrappingShortcut(const shash::Any &object)
const SpoolerDefinition & spooler_definition() const
const CallbackTN * commit_callback
Config(const std::string &session_token_file, const std::string &key_file, const std::string &api_url)
virtual void StreamedUpload(UploadStreamHandle *handle, UploadBuffer buffer, const CallbackTN *callback)
virtual bool FinalizeSession(bool commit, const std::string &old_root_hash, const std::string &new_root_hash, const RepositoryTag &tag)
SessionContext * session_context_
virtual unsigned int GetNumberOfErrors() const
virtual ~GatewayUploader()
virtual void FinalizeStreamedUpload(UploadStreamHandle *handle, const shash::Any &content_hash)
GatewayStreamHandle(const CallbackTN *commit_callback, ObjectPack::BucketHandle bkt)
static bool ParseSpoolerDefinition(const SpoolerDefinition &spooler_definition, Config *config)
virtual void WaitForUpload() const
AbstractUploader::CallbackTN CallbackTN
virtual void DoRemoveAsync(const std::string &file_to_delete)
virtual void DoUpload(const std::string &remote_path, IngestionSource *source, const CallbackTN *callback)
virtual bool Mkdir(const std::string &path)
ObjectPack::BucketHandle bucket
virtual bool ReadKey(const std::string &key_file, std::string *key_id, std::string *secret)
virtual void ReadSessionTokenFile(const std::string &token_file_name, std::string *token)
GatewayUploader(const SpoolerDefinition &spooler_definition)
virtual UploadStreamHandle * InitStreamedUpload(const CallbackTN *callback)
virtual bool Initialize()
std::string session_token_file