oio.event.filters package

Submodules

oio.event.filters.account_update module

class oio.event.filters.account_update.AccountUpdateFilter(app, conf, logger=None)

Bases: oio.event.filters.base.Filter

Fill in the account service with information coming from meta2 services (number of objects in a container, etc.) and meta1 services (a container has been created or removed).

init()

process(env, beanstalkd, cb)

oio.event.filters.account_update.filter_factory(global_conf, **local_conf)

oio.event.filters.base module

class oio.event.filters.base.Filter(app, conf, logger=None)

Bases: object

init()

process(env, beanstalkd, cb)

oio.event.filters.bury module

class oio.event.filters.bury.BuryFilter(app, conf, logger=None)

Bases: oio.event.filters.base.Filter

Bury all events

process(env, beanstalkd, cb)

oio.event.filters.bury.filter_factory(global_conf, **local_conf)

oio.event.filters.content_cleaner module

class oio.event.filters.content_cleaner.ContentReaperFilter(app, conf, logger=None)

Bases: oio.event.filters.base.Filter

Filter that deletes chunks on content deletion events

init()

process(env, beanstalkd, cb)

oio.event.filters.content_cleaner.filter_factory(global_conf, **local_conf)

oio.event.filters.dump module

class oio.event.filters.dump.DumpFilter(app, conf, **kwargs)

Bases: oio.event.filters.base.Filter

Dump events to files in /tmp directory. Each event will be named after its job ID (example: /tmp/event_3). This filter is only intended to help debugging.

process(env, beanstalkd, cb)

oio.event.filters.dump.filter_factory(global_conf, **local_conf)

oio.event.filters.logger module

class oio.event.filters.logger.LoggerFilter(app, conf, logger=None)

Bases: oio.event.filters.base.Filter

Log all events with ‘info’ level

process(env, beanstalkd, cb)

oio.event.filters.logger.filter_factory(global_conf, **local_conf)

oio.event.filters.noop module

class oio.event.filters.noop.NoopFilter(app, conf, logger=None)

Bases: oio.event.filters.base.Filter

Does nothing with the input event.

Useful if you just want to drop the events.

oio.event.filters.noop.filter_factory(global_conf, **local_conf)

oio.event.filters.notify module

class oio.event.filters.notify.NotifyFilter(app, conf, logger=None)

Bases: oio.event.filters.base.Filter

init()

process(env, beanstalkd, cb)

should_notify(event)

oio.event.filters.notify.filter_factory(global_conf, **local_conf)

oio.event.filters.replicate module

class oio.event.filters.replicate.ReplicateFilter(app, conf, logger=None)

Bases: oio.event.filters.notify.NotifyFilter

This filter will check, with the help of the account service, if the container or object linked in the event is supposed to be replicated, before forwarding the event to the replication queue.

ALLOWED_EVENT_TYPES = ('storage.container.deleted', 'storage.container.new', 'storage.container.state', 'storage.container.update', 'storage.content.append', 'storage.content.broken', 'storage.content.deleted', 'storage.content.new', 'storage.content.perfectible', 'storage.content.rebuilt', 'storage.content.update')

init()

should_notify(event)

oio.event.filters.replicate.filter_factory(global_conf, **local_conf)

oio.event.filters.volume_index module

class oio.event.filters.volume_index.VolumeIndexFilter(*args, **kwargs)

Bases: oio.event.filters.base.Filter

process(env, beanstalkd, cb)

oio.event.filters.volume_index.filter_factory(global_conf, **local_conf)

oio.event.filters.webhook module

class oio.event.filters.webhook.WebhookFilter(app, conf, logger=None)

Bases: oio.event.filters.base.Filter

init()

process(env, beanstalkd, cb)

oio.event.filters.webhook.extract_data_from_event(env)

oio.event.filters.webhook.filter_factory(global_conf, **local_conf)

oio.event.filters.xcute module

class oio.event.filters.xcute.XcuteFilter(app, conf, logger=None)

Bases: oio.event.filters.base.Filter

DEFAULT_RETRY_DELAY_TO_REPLY = 60

init()

process(env, beanstalkd, cb)

oio.event.filters.xcute.filter_factory(global_conf, **local_conf)

Module contents