Package buildbot :: Package status :: Module persistent_queue :: Class PersistentQueue

Class PersistentQueue

object --+
         |
        PersistentQueue

Keeps a list of abstract items and serializes it to the disk.

It has 2 layers of queue, normally an in-memory queue and an on-disk queue. When the number of items in the primary queue gets too large, the new items are automatically saved to the secondary queue. The older items are kept in the primary queue.

Instance Methods

__init__(self, primaryQueue=None, secondaryQueue=None, path=None)
x.__init__(...) initializes x; see help(type(x)) for signature

source code

pushItem(self, item)

source code

insertBackChunk(self, chunk)

source code

popChunk(self, nbItems=None)

source code

save(self)

source code

items(self)

source code

nbItems(self)

source code

maxItems(self)

source code

__providedBy__(...)
Object Specification Descriptor

source code

__provides__(...)
Special descriptor for class __provides__

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Class Variables
	__implemented__ = `<implementedBy buildbot.status.persistent_qu...`

Properties
Inherited from `object`: `__class__`

Method Details

init(self, primaryQueue=None, secondaryQueue=None, path=None)
(Constructor)

source code

x.__init__(...) initializes x; see help(type(x)) for signature

Overrides: object.__init__

provides(...)

Special descriptor for class __provides__

The descriptor caches the implementedBy info, so that
we can get declarations for objects without instance-specific
interfaces a bit quicker.

For example:

  >>> from zope.interface import Interface
  >>> class IFooFactory(Interface):
  ...     pass
  >>> class IFoo(Interface):
  ...     pass
  >>> class C(object):
  ...     implements(IFoo)
  ...     classProvides(IFooFactory)
  >>> [i.getName() for i in C.__provides__]
  ['IFooFactory']

  >>> [i.getName() for i in C().__provides__]
  ['IFoo']

Class Variable Details

implemented

Value:

<implementedBy buildbot.status.persistent_queue.PersistentQueue>

Class PersistentQueue

__init__(self, primaryQueue=None, secondaryQueue=None, path=None) (Constructor)

__provides__(...)

__implemented__

init(self, primaryQueue=None, secondaryQueue=None, path=None)
(Constructor)

provides(...)

implemented