Index

_

_propagate_kwargs (connector.connector.ConnectorEnvironment attribute)

A

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)

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)

C

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.job.Job attribute) ChannelJob (class in connector.jobrunner.channels) ChannelManager (class in connector.jobrunner.channels) ChannelNotFound ChannelQueue (class in connector.jobrunner.channels) children (connector.unit.mapper.Mapper attribute) close() (connector.jobrunner.runner.Database method) (connector.session.ConnectorSession method) close_databases() (connector.jobrunner.runner.ConnectorRunner method) cmp_no_eta() (connector.jobrunner.channels.ChannelJob method) commit() (connector.session.ConnectorSession method) 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.session (module) connector.unit.backend_adapter (module) connector.unit.mapper (module) connector.unit.synchronizer (module) 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.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_created (connector.queue.job.Job attribute) date_done (connector.queue.job.Job attribute) date_enqueued (connector.queue.job.Job attribute) date_started (connector.queue.job.Job 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) description (connector.queue.job.Job attribute), [1] direct (connector.unit.mapper.Mapper attribute)

E

enqueue() (connector.queue.job.OpenERPJobStorage method) enqueue_resolve_args() (connector.queue.job.OpenERPJobStorage method) env (connector.connector.ConnectorEnvironment attribute) (connector.connector.ConnectorUnit attribute) (connector.session.ConnectorSession attribute) eta (connector.queue.job.Job attribute), [1]

Event (class in connector.event) exc_info (connector.queue.job.Job 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)

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] func_name (connector.queue.job.Job attribute) func_string (connector.queue.job.Job attribute), [1]

G

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_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) get_wakeup_time() (connector.jobrunner.channels.Channel method) (connector.jobrunner.channels.ChannelManager method) (connector.jobrunner.channels.ChannelQueue method)

H

has_capacity() (connector.jobrunner.channels.Channel method)

has_consumer_for() (connector.event.Event method)

I

identity_exact() (in module connector.queue.job) identity_key (connector.queue.job.Job attribute) IDMissingInBackend Importer (class in connector.unit.synchronizer) ImportMapChild (class in connector.unit.mapper)

ImportMapper (class in connector.unit.mapper) initialize_databases() (connector.jobrunner.runner.ConnectorRunner method) 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_record_with_same_identity_key() (connector.queue.job.OpenERPJobStorage method) JobError 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) 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.queue.job.Job attribute)

N

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) OpenERPJobStorage (class in connector.queue.job) options (connector.unit.mapper.Mapper attribute)

P

parent (connector.backend.Backend attribute) (connector.unit.mapper.MapRecord attribute) parse_simple_config() (connector.jobrunner.channels.ChannelManager class method) perform() (connector.queue.job.Job method) pg_try_advisory_lock() (in module connector.connector) 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) PriorityQueue (class in connector.jobrunner.channels) process_notifications() (connector.jobrunner.runner.ConnectorRunner method)

R

read() (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) result (connector.queue.job.Job attribute) retry (connector.queue.job.Job attribute) RetryableJobError rollback() (connector.session.ConnectorSession method) run() (connector.jobrunner.runner.ConnectorRunner method) (connector.unit.synchronizer.Synchronizer method) run_jobs() (connector.jobrunner.runner.ConnectorRunner method)

S

SafeSet (class in connector.jobrunner.channels) search() (connector.unit.backend_adapter.CRUDAdapter method) search_read() (connector.unit.backend_adapter.CRUDAdapter method) select_jobs() (connector.jobrunner.runner.Database method) sequential (connector.jobrunner.channels.Channel attribute) 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_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_item() (connector.unit.mapper.MapChild method) source (connector.unit.mapper.MapRecord attribute) split_strip() (connector.jobrunner.channels.ChannelManager static method) state (connector.queue.job.Job attribute) stop() (connector.jobrunner.runner.ConnectorRunner method) store() (connector.queue.job.JobStorage method) (connector.queue.job.OpenERPJobStorage method) subscribe() (connector.event.Event method) 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) 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) uuid (connector.queue.job.Job attribute), [1]

V

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

version (connector.backend.Backend attribute)

W

wait_notification() (connector.jobrunner.runner.ConnectorRunner method)

whitelist_unpickle_global() (in module connector.queue.job) write() (connector.unit.backend_adapter.CRUDAdapter method)