X-Git-Url: http://git.vrable.net/?a=blobdiff_plain;f=python%2Fcumulus%2Fstore%2F__init__.py;h=0899d70b04c9a03e1b0e1e32bc2166eca4ae4e88;hb=c343597dac79f9edc63d95d881625a317fadb1d9;hp=84ca119238b9f6ee0d7e1b87830a51c4caf4211f;hpb=a44f5f73e7b43ff152f8b515a74bb9e0b1b48cc6;p=cumulus.git diff --git a/python/cumulus/store/__init__.py b/python/cumulus/store/__init__.py index 84ca119..0899d70 100644 --- a/python/cumulus/store/__init__.py +++ b/python/cumulus/store/__init__.py @@ -1,9 +1,27 @@ +# Cumulus: Efficient Filesystem Backup to the Cloud +# Copyright (C) 2008-2010 The Cumulus Developers +# See the AUTHORS file for a list of contributors. +# +# 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 2 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, write to the Free Software Foundation, Inc., +# 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. + import exceptions, re, urlparse type_patterns = { 'checksums': re.compile(r"^snapshot-(.*)\.(\w+)sums$"), 'segments': re.compile(r"^([0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12})(\.\S+)?$"), - 'snapshots': re.compile(r"^snapshot-(.*)\.lbs$") + 'snapshots': re.compile(r"^snapshot-(.*)\.(cumulus|lbs)$") } class NotFoundError(exceptions.KeyError): @@ -37,19 +55,19 @@ class Store (object): except ImportError: raise NotImplementedError, "Scheme %s not implemented" % scheme - def list(self, type): + def list(self, path): raise NotImplementedError - def get(self, type, name): + def get(self, path): raise NotImplementedError - def put(self, type, name, fp): + def put(self, path, fp): raise NotImplementedError - def delete(self, type, name): + def delete(self, path): raise NotImplementedError - def stat(self, type, name): + def stat(self, path): raise NotImplementedError def scan(self): @@ -61,11 +79,14 @@ class Store (object): pass def close(self): - """Tier down the connection explicitly if needed + """Tear down the connection explicitly if needed + + Currently needed for sftp to be able to end the program.""" - Currently needed for sftp to be able to end the program.""" + pass - pass + def __del__(self): + self.close() def open(url): return Store(url)