oio.event.filters package

Submodules

oio.event.filters.account_update module

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

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()[source]
process(env, cb)[source]
oio.event.filters.account_update.filter_factory(global_conf, **local_conf)[source]

oio.event.filters.base module

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

Bases: object

init()[source]
process(env, cb)[source]

oio.event.filters.bury module

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

Bases: oio.event.filters.base.Filter

Bury all events

process(env, cb)[source]
oio.event.filters.bury.filter_factory(global_conf, **local_conf)[source]

oio.event.filters.content_cleaner module

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

Bases: oio.event.filters.base.Filter

Filter that deletes chunks on content deletion events

init()[source]
process(env, cb)[source]
oio.event.filters.content_cleaner.filter_factory(global_conf, **local_conf)[source]

oio.event.filters.dump module

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

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, cb)[source]
oio.event.filters.dump.filter_factory(global_conf, **local_conf)[source]

oio.event.filters.logger module

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

Bases: oio.event.filters.base.Filter

Log all events with ‘info’ level

process(env, cb)[source]
oio.event.filters.logger.filter_factory(global_conf, **local_conf)[source]

oio.event.filters.noop module

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

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)[source]

oio.event.filters.notify module

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

Bases: oio.event.filters.base.Filter

init()[source]
process(env, cb)[source]
should_notify(event)[source]
oio.event.filters.notify.filter_factory(global_conf, **local_conf)[source]

oio.event.filters.volume_index module

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

Bases: oio.event.filters.base.Filter

process(env, cb)[source]
oio.event.filters.volume_index.filter_factory(global_conf, **local_conf)[source]

oio.event.filters.webhook module

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

Bases: oio.event.filters.base.Filter

init()[source]
process(env, cb)[source]
oio.event.filters.webhook.extract_data_from_event(env)[source]
oio.event.filters.webhook.filter_factory(global_conf, **local_conf)[source]

Module contents