Index

_

_propagate_kwargs (connector.connector.ConnectorEnvironment attribute)

A

active (connector.queue.model.QueueJob attribute) add() (connector.jobrunner.channels.ChannelQueue method) (connector.jobrunner.channels.PriorityQueue method) advisory_lock_or_retry() (connector.connector.ConnectorUnit method)

args (connector.queue.job.Job attribute) assign_jobs() (connector.queue.model.QueueWorker method) assign_then_enqueue() (connector.queue.model.QueueWorker method) autovacuum() (connector.queue.model.QueueJob method) available_db_names() (connector.queue.worker.WorkerWatcher static method)

B

Backend (class in connector.backend) backend (connector.connector.ConnectorEnvironment attribute) backend_adapter (connector.unit.synchronizer.Synchronizer attribute) backend_record (connector.connector.ConnectorEnvironment attribute) backend_to_m2o() (in module connector.unit.mapper) BackendAdapter (class in connector.unit.backend_adapter)

bind() (connector.connector.Binder method) Binder (class in connector.connector) binder (connector.unit.synchronizer.Synchronizer attribute) binder_for() (connector.connector.ConnectorUnit method) browse() (connector.session.ConnectorSession method) button_done() (connector.queue.model.QueueJob method)

C

cancel() (connector.queue.job.Job method) canceled (connector.queue.job.Job attribute) change_context() (connector.session.ConnectorSession method) change_user() (connector.session.ConnectorSession method) changed_by (connector.unit.mapper.MappingDefinition attribute) changed_by() (in module connector.unit.mapper) Channel (class in connector.jobrunner.channels), [1] channel (connector.queue.model.JobFunction attribute) (connector.queue.model.QueueJob attribute) channel_id (connector.queue.model.JobFunction attribute) ChannelJob (class in connector.jobrunner.channels) ChannelManager (class in connector.jobrunner.channels) ChannelNotFound ChannelQueue (class in connector.jobrunner.channels) check_alive() (connector.queue.worker.WorkerWatcher method) children (connector.unit.mapper.Mapper attribute) close() (connector.jobrunner.runner.Database method) (connector.session.ConnectorSession method) close_databases() (connector.jobrunner.runner.ConnectorRunner method) commit() (connector.session.ConnectorSession method) company_id (connector.queue.model.QueueJob attribute) complete_name (connector.queue.model.JobChannel attribute) configure() (connector.jobrunner.channels.Channel method) connector.backend (module) connector.backend_model (module) connector.connector (module)

connector.event (module) connector.exception (module) connector.jobrunner.channels (module) connector.jobrunner.runner (module), [1] connector.queue.job (module) connector.queue.model (module) connector.queue.queue (module) connector.queue.worker (module) connector.session (module) connector.unit.backend_adapter (module) connector.unit.mapper (module) connector.unit.synchronizer (module) ConnectorBackend (class in connector.backend_model) ConnectorEnvironment (class in connector.connector) ConnectorException ConnectorRunner (class in connector.jobrunner.runner) ConnectorSession (class in connector.session) ConnectorSessionHandler (class in connector.session) ConnectorUnit (class in connector.connector) context (connector.session.ConnectorSession attribute), [1] (connector.session.ConnectorSessionHandler attribute) convert() (in module connector.unit.mapper) cr (connector.session.ConnectorSession attribute), [1] create() (connector.session.ConnectorSession method) (connector.unit.backend_adapter.CRUDAdapter method) create_environment() (connector.connector.ConnectorEnvironment class method) CRUDAdapter (class in connector.unit.backend_adapter)

D

Database (class in connector.jobrunner.runner) date_alive (connector.queue.model.QueueWorker attribute) date_created (connector.queue.job.Job attribute) (connector.queue.model.QueueJob attribute) date_done (connector.queue.job.Job attribute) (connector.queue.model.QueueJob attribute) date_enqueued (connector.queue.job.Job attribute) (connector.queue.model.QueueJob attribute) date_start (connector.queue.model.QueueWorker attribute) date_started (connector.queue.job.Job attribute) (connector.queue.model.QueueJob attribute)

db_name (connector.session.ConnectorSessionHandler attribute) db_record() (connector.queue.job.OpenERPJobStorage method) db_record_from_uuid() (connector.queue.job.OpenERPJobStorage method) delete() (connector.unit.backend_adapter.CRUDAdapter method) Deleter (class in connector.unit.synchronizer) DeleteSynchronizer (in module connector.unit.synchronizer) dequeue() (connector.queue.queue.JobsQueue method) description (connector.queue.job.Job attribute), [1] direct (connector.unit.mapper.Mapper attribute)

E

enqueue() (connector.queue.job.OpenERPJobStorage method) (connector.queue.queue.JobsQueue method) enqueue_job_uuid() (connector.queue.worker.Worker method) enqueue_jobs() (connector.queue.model.QueueWorker method) enqueue_resolve_args() (connector.queue.job.OpenERPJobStorage method) env (connector.connector.ConnectorEnvironment attribute) (connector.connector.ConnectorUnit attribute) (connector.session.ConnectorSession attribute) environment (connector.connector.ConnectorUnit attribute) eta (connector.queue.job.Job attribute), [1] (connector.queue.model.QueueJob attribute)

Event (class in connector.event) exc_info (connector.queue.job.Job attribute) (connector.queue.model.QueueJob attribute) exists() (connector.queue.job.JobStorage method) (connector.queue.job.OpenERPJobStorage method) Exporter (class in connector.unit.synchronizer) ExportMapChild (class in connector.unit.mapper) ExportMapper (class in connector.unit.mapper) ExportSynchronizer (in module connector.unit.synchronizer) ExternalBinding (class in connector.backend_model)

F

FailedJobError finalize() (connector.unit.mapper.Mapper method) fire() (connector.event.Event method) follow_m2o_relations() (in module connector.unit.mapper) for_model_names (connector.connector.MetaConnectorUnit attribute) format_items() (connector.unit.mapper.ImportMapChild method) (connector.unit.mapper.MapChild method)

from_env() (connector.session.ConnectorSession class method) fullname (connector.jobrunner.channels.Channel attribute) func (connector.queue.job.Job attribute), [1] (connector.queue.model.QueueJob attribute) func_name (connector.queue.job.Job attribute) (connector.queue.model.QueueJob attribute) func_string (connector.queue.job.Job attribute), [1] (connector.queue.model.QueueJob attribute)

G

get_backend() (connector.backend_model.ConnectorBackend method) get_binder_for_model() (connector.connector.ConnectorUnit method) get_channel_by_name() (connector.jobrunner.channels.ChannelManager method) get_channel_from_config() (connector.jobrunner.channels.ChannelManager method) get_class() (connector.backend.Backend method) get_connector_unit() (connector.connector.ConnectorEnvironment method) get_connector_unit_for_model() (connector.connector.ConnectorUnit method)

get_db_names() (connector.jobrunner.runner.ConnectorRunner method) get_item_values() (connector.unit.mapper.MapChild method) get_items() (connector.unit.mapper.MapChild method) get_jobs_to_run() (connector.jobrunner.channels.Channel method) (connector.jobrunner.channels.ChannelManager method) get_openerp_module() (in module connector.connector) get_subchannel_by_name() (connector.jobrunner.channels.Channel method)

H

has_consumer_for() (connector.event.Event method)

I

IDMissingInBackend Importer (class in connector.unit.synchronizer) ImportMapChild (class in connector.unit.mapper) ImportMapper (class in connector.unit.mapper) ImportSynchronizer (in module connector.unit.synchronizer)

initialize_databases() (connector.jobrunner.runner.ConnectorRunner method) install_in_connector() (in module connector.connector) InvalidDataError is_module_installed() (connector.session.ConnectorSession method) (in module connector.connector)

J

Job (class in connector.queue.job) job() (in module connector.queue.job) job_function_id (connector.queue.model.QueueJob attribute) job_function_ids (connector.queue.model.JobChannel attribute) job_ids (connector.queue.model.QueueWorker attribute) (connector.queue.model.RequeueJob attribute)

job_storage_class (connector.queue.worker.Worker attribute) JobChannel (class in connector.queue.model) JobError JobFunction (class in connector.queue.model) JobsQueue (class in connector.queue.queue) JobStorage (class in connector.queue.job)

K

kwargs (connector.queue.job.Job attribute)

L

load() (connector.queue.job.JobStorage method) (connector.queue.job.OpenERPJobStorage method)

localcontext (connector.connector.ConnectorUnit attribute)

M

m2o_to_backend() (in module connector.unit.mapper) ManyIDSInBackend map_methods (connector.unit.mapper.Mapper attribute) map_record() (connector.unit.mapper.Mapper method) MapChild (class in connector.unit.mapper) MapOptions (class in connector.unit.mapper) Mapper (class in connector.unit.mapper) mapper (connector.unit.synchronizer.Synchronizer attribute) mapping() (in module connector.unit.mapper) MappingDefinition (class in connector.unit.mapper) MappingError MapRecord (class in connector.unit.mapper)

match() (connector.backend.Backend method) (connector.connector.ConnectorUnit class method) max_retries (connector.queue.job.Job attribute) (connector.queue.model.QueueJob attribute) MetaConnectorUnit (class in connector.connector) MetaMapper (class in connector.unit.mapper) model (connector.connector.ConnectorEnvironment attribute) (connector.connector.ConnectorUnit attribute) model_name (connector.connector.ConnectorEnvironment attribute) (connector.connector.MetaConnectorUnit attribute) (connector.queue.job.Job attribute) (connector.queue.model.QueueJob attribute)

N

name (connector.backend_model.ConnectorBackend attribute) (connector.queue.model.JobChannel attribute) (connector.queue.model.JobFunction attribute) (connector.queue.model.QueueJob attribute) name_get() (connector.queue.model.JobChannel method) NetworkRetryableError

NoConnectorUnitError NoExternalId none() (in module connector.unit.mapper) NoSuchJobError NothingToDoJob notify() (connector.jobrunner.channels.ChannelManager method) NotReadableJobError

O

on_record_create (in module connector.event) on_record_unlink (in module connector.event) on_record_write (in module connector.event) only_create (connector.unit.mapper.MappingDefinition attribute)

only_create() (in module connector.unit.mapper) open_related_action() (connector.queue.model.QueueJob method) OpenERPJobStorage (class in connector.queue.job) options (connector.unit.mapper.Mapper attribute)

P

parent (connector.backend.Backend attribute) (connector.unit.mapper.MapRecord attribute) parent_id (connector.queue.model.JobChannel attribute) parent_required() (connector.queue.model.JobChannel method) parse_simple_config() (connector.jobrunner.channels.ChannelManager class method) perform() (connector.queue.job.Job method) pg_try_advisory_lock() (in module connector.connector) pid (connector.queue.model.QueueWorker attribute)

pool (connector.connector.ConnectorEnvironment attribute) (connector.session.ConnectorSession attribute), [1] pop() (connector.jobrunner.channels.ChannelQueue method) (connector.jobrunner.channels.PriorityQueue method) postpone() (connector.queue.job.Job method) priority (connector.queue.job.Job attribute) (connector.queue.model.QueueJob attribute) PriorityQueue (class in connector.jobrunner.channels) process_notifications() (connector.jobrunner.runner.ConnectorRunner method)

Q

queue_class (connector.queue.worker.Worker attribute)

QueueJob (class in connector.queue.model) QueueWorker (class in connector.queue.model)

R

read() (connector.session.ConnectorSession method) (connector.unit.backend_adapter.CRUDAdapter method) register_class() (connector.backend.Backend method) related_action() (connector.queue.job.Job method) (in module connector.queue.job) remove() (connector.jobrunner.channels.Channel method) (connector.jobrunner.channels.ChannelQueue method) (connector.jobrunner.channels.PriorityQueue method) (connector.jobrunner.channels.SafeSet method) remove_db() (connector.jobrunner.channels.ChannelManager method) remove_job() (connector.jobrunner.channels.ChannelManager method) requeue() (connector.queue.model.QueueJob method) (connector.queue.model.RequeueJob method)

RequeueJob (class in connector.queue.model) result (connector.queue.job.Job attribute) (connector.queue.model.QueueJob attribute) retry (connector.queue.job.Job attribute) (connector.queue.model.QueueJob attribute) RetryableJobError rollback() (connector.session.ConnectorSession method) run() (connector.jobrunner.runner.ConnectorRunner method) (connector.queue.worker.Worker method) (connector.queue.worker.WorkerWatcher method) (connector.unit.synchronizer.Synchronizer method) run_job() (connector.queue.worker.Worker method) run_jobs() (connector.jobrunner.runner.ConnectorRunner method)

S

SafeSet (class in connector.jobrunner.channels) search() (connector.session.ConnectorSession method) (connector.unit.backend_adapter.CRUDAdapter method) search_read() (connector.unit.backend_adapter.CRUDAdapter method) select_jobs() (connector.jobrunner.runner.Database method) service (connector.backend.Backend attribute), [1] session (connector.connector.ConnectorEnvironment attribute) session() (connector.session.ConnectorSessionHandler method) set_done() (connector.jobrunner.channels.Channel method) (connector.queue.job.Job method) set_enqueued() (connector.queue.job.Job method) set_failed() (connector.jobrunner.channels.Channel method) (connector.queue.job.Job method) set_job_enqueued() (connector.jobrunner.runner.Database method) set_lang() (connector.connector.ConnectorEnvironment method) set_pending() (connector.jobrunner.channels.Channel method) (connector.queue.job.Job method)

set_running() (connector.jobrunner.channels.Channel method) set_started() (connector.queue.job.Job method) simple_configure() (connector.jobrunner.channels.ChannelManager method) skip_add_item() (connector.unit.mapper.MapChild method) skip_item() (connector.unit.mapper.MapChild method) source (connector.unit.mapper.MapRecord attribute) split_strip() (connector.jobrunner.channels.ChannelManager static method) start_service() (in module connector.queue.worker) state (connector.queue.job.Job attribute) (connector.queue.model.QueueJob attribute) stop() (connector.jobrunner.runner.ConnectorRunner method) store() (connector.queue.job.JobStorage method) (connector.queue.job.OpenERPJobStorage method) subscribe() (connector.event.Event method) sync_date (connector.backend_model.ExternalBinding attribute) Synchronizer (class in connector.unit.synchronizer)

T

to_backend() (connector.connector.Binder method)

to_openerp() (connector.connector.Binder method)

U

uid (connector.session.ConnectorSession attribute), [1] (connector.session.ConnectorSessionHandler attribute) unit_for() (connector.connector.ConnectorUnit method) unlink() (connector.queue.model.JobChannel method) (connector.session.ConnectorSession method) unsubscribe() (connector.event.Event method) unwrap_binding() (connector.connector.Binder method)

unwrap_model() (connector.connector.Binder method) update() (connector.unit.mapper.MapRecord method) user_id (connector.queue.job.Job attribute) (connector.queue.model.QueueJob attribute) uuid (connector.queue.job.Job attribute), [1] (connector.queue.model.QueueJob attribute) (connector.queue.model.QueueWorker attribute)

V

values() (connector.unit.mapper.MapRecord method)

version (connector.backend.Backend attribute) (connector.backend_model.ConnectorBackend attribute)

W

wait_notification() (connector.jobrunner.runner.ConnectorRunner method) whitelist_unpickle_global() (in module connector.queue.job) Worker (class in connector.queue.worker) worker_for_db() (connector.queue.worker.WorkerWatcher method) worker_id (connector.queue.model.QueueJob attribute) worker_lost() (connector.queue.worker.WorkerWatcher method)

worker_timeout (connector.queue.model.QueueWorker attribute) worker_uuid (connector.queue.job.Job attribute) WorkerWatcher (class in connector.queue.worker) write() (connector.queue.model.JobChannel method) (connector.queue.model.QueueJob method) (connector.session.ConnectorSession method) (connector.unit.backend_adapter.CRUDAdapter method)