oio.event.filters package

Submodules

oio.event.filters.account_update module

class oio.event.filters.account_update.AccountUpdateFilter(app, conf, **kwargs)[source]

Bases: oio.event.filters.base.Filter

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

init()[source]
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(*args, **kwargs)[source]

Bases: oio.event.filters.base.Filter

Filter that deletes chunks on content deletion events

process(env, cb)[source]
oio.event.filters.content_cleaner.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

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

oio.event.filters.volume_index module

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

Bases: oio.event.filters.base.Filter

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

Module contents