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
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]