Index

A

abandon_stale_jobs() (media_nommer.feederd.job_cache.JobCache class method) AWS_ACCESS_KEY_ID (in module media_nommer.conf.settings)

AWS_SECRET_ACCESS_KEY (in module media_nommer.conf.settings)

B

BaseNommer (class in media_nommer.ec2nommerd.nommers.base_nommer)

C

CACHE (media_nommer.feederd.job_cache.JobCache attribute) CONFIG_S3_BUCKET (in module media_nommer.conf.settings)

contemplate_termination() (media_nommer.ec2nommerd.node_state.NodeStateManager class method)

D

download_file() (media_nommer.core.storage_backends.s3.S3Backend class method) download_settings() (in module media_nommer.conf.utils)

download_source_file() (media_nommer.ec2nommerd.nommers.base_nommer.BaseNommer method)

E

EC2_AMI_ID (in module media_nommer.conf.settings) EC2_INSTANCE_TYPE (in module media_nommer.conf.settings) EC2_KEY_NAME (in module media_nommer.conf.settings)

EC2_SECURITY_GROUPS (in module media_nommer.conf.settings) EC2InstanceManager (class in media_nommer.feederd.ec2_instance_manager) EncodingJob (class in media_nommer.core.job_state_backend)

F

FEEDERD_ABANDON_INACTIVE_JOBS_THRESH (in module media_nommer.conf.settings) FEEDERD_ALLOW_EC2_LAUNCHES (in module media_nommer.conf.settings) FEEDERD_AUTO_SCALE_INTERVAL (in module media_nommer.conf.settings) FEEDERD_JOB_STATE_CHANGE_CHECK_INTERVAL (in module media_nommer.conf.settings)

FEEDERD_PRUNE_JOBS_INTERVAL (in module media_nommer.conf.settings) FFmpegNommer (class in media_nommer.ec2nommerd.nommers.ffmpeg) FINISHED_STATES (media_nommer.core.job_state_backend.JobStateBackend attribute)

G

get_backend_for_protocol() (in module media_nommer.core.storage_backends) get_backend_for_uri() (in module media_nommer.core.storage_backends) get_cached_jobs() (media_nommer.feederd.job_cache.JobCache class method) get_instance_id() (media_nommer.ec2nommerd.node_state.NodeStateManager class method) get_instances() (media_nommer.feederd.ec2_instance_manager.EC2InstanceManager class method)

get_job() (media_nommer.feederd.job_cache.JobCache class method) get_job_object_from_id() (media_nommer.core.job_state_backend.JobStateBackend class method) get_jobs_with_state() (media_nommer.feederd.job_cache.JobCache class method) get_num_active_threads() (media_nommer.ec2nommerd.node_state.NodeStateManager class method) get_unfinished_jobs() (media_nommer.core.job_state_backend.JobStateBackend class method)

I

i_did_something() (media_nommer.ec2nommerd.node_state.NodeStateManager class method) is_ec2_instance() (media_nommer.ec2nommerd.node_state.NodeStateManager class method)

is_finished() (media_nommer.core.job_state_backend.EncodingJob method) is_job_cached() (media_nommer.feederd.job_cache.JobCache class method)

J

JOB_OVERFLOW_THRESH (in module media_nommer.conf.settings) JOB_STATES (media_nommer.core.job_state_backend.JobStateBackend attribute)

JobCache (class in media_nommer.feederd.job_cache) JobStateBackend (class in media_nommer.core.job_state_backend)

L

last_dtime_i_did_something (media_nommer.ec2nommerd.node_state.NodeStateManager attribute)

load_recent_jobs_at_startup() (media_nommer.feederd.job_cache.JobCache class method)

M

MAX_ENCODING_JOBS_PER_EC2_INSTANCE (in module media_nommer.conf.settings) MAX_NUM_EC2_INSTANCES (in module media_nommer.conf.settings) media_nommer.conf (module) media_nommer.conf.settings (module) media_nommer.conf.utils (module) media_nommer.core (module) media_nommer.core.job_state_backend (module) media_nommer.core.storage_backends (module) media_nommer.core.storage_backends.s3 (module) media_nommer.ec2nommerd (module)

media_nommer.ec2nommerd.interval_tasks (module) media_nommer.ec2nommerd.node_state (module) media_nommer.ec2nommerd.nommers (module) media_nommer.ec2nommerd.nommers.base_nommer (module) media_nommer.ec2nommerd.nommers.ffmpeg (module) media_nommer.feederd (module) media_nommer.feederd.ec2_instance_manager (module) media_nommer.feederd.interval_tasks (module) media_nommer.feederd.job_cache (module)

N

NodeStateManager (class in media_nommer.ec2nommerd.node_state) NOMMERD_HEARTBEAT_INTERVAL (in module media_nommer.conf.settings) NOMMERD_MAX_INACTIVITY (in module media_nommer.conf.settings)

NOMMERD_NEW_JOB_CHECK_INTERVAL (in module media_nommer.conf.settings) NOMMERD_QTFASTSTART_BIN_PATH (in module media_nommer.conf.settings) NOMMERD_TERMINATE_WHEN_IDLE (in module media_nommer.conf.settings)

O

onomnom() (media_nommer.ec2nommerd.nommers.base_nommer.BaseNommer method)

P

pop_new_jobs_from_queue() (media_nommer.core.job_state_backend.JobStateBackend class method)

pop_state_changes_from_queue() (media_nommer.core.job_state_backend.JobStateBackend class method)

R

refresh_jobs_with_state_changes() (media_nommer.feederd.job_cache.JobCache class method) register_tasks() (in module media_nommer.ec2nommerd.interval_tasks) (in module media_nommer.feederd.interval_tasks)

remove_job() (media_nommer.feederd.job_cache.JobCache class method)

S

S3Backend (class in media_nommer.core.storage_backends.s3) save() (media_nommer.core.job_state_backend.EncodingJob method) send_instance_state_update() (media_nommer.ec2nommerd.node_state.NodeStateManager class method) set_job_state() (media_nommer.core.job_state_backend.EncodingJob method) SIMPLEDB_EC2_NOMMER_STATE_DOMAIN (in module media_nommer.conf.settings) SIMPLEDB_JOB_STATE_DOMAIN (in module media_nommer.conf.settings)

spawn_if_needed() (media_nommer.feederd.ec2_instance_manager.EC2InstanceManager class method) spawn_instances() (media_nommer.feederd.ec2_instance_manager.EC2InstanceManager class method) SQS_JOB_STATE_CHANGE_QUEUE_NAME (in module media_nommer.conf.settings) SQS_NEW_JOB_QUEUE_NAME (in module media_nommer.conf.settings) STORAGE_BACKENDS (in module media_nommer.conf.settings)

T

task_check_for_job_state_changes() (in module media_nommer.feederd.interval_tasks) task_check_for_new_jobs() (in module media_nommer.ec2nommerd.interval_tasks) task_heartbeat() (in module media_nommer.ec2nommerd.interval_tasks) task_manage_ec2_instances() (in module media_nommer.feederd.interval_tasks) task_prune_jobs() (in module media_nommer.feederd.interval_tasks)

threaded_check_for_job_state_changes() (in module media_nommer.feederd.interval_tasks) threaded_encode_job() (in module media_nommer.ec2nommerd.interval_tasks) threaded_heartbeat() (in module media_nommer.ec2nommerd.interval_tasks) threaded_manage_ec2_instances() (in module media_nommer.feederd.interval_tasks) threaded_prune_jobs() (in module media_nommer.feederd.interval_tasks)

U

uncache_finished_jobs() (media_nommer.feederd.job_cache.JobCache class method) update_job() (media_nommer.feederd.job_cache.JobCache class method) update_settings_from_module() (in module media_nommer.conf)

upload_file() (media_nommer.core.storage_backends.s3.S3Backend class method) upload_settings() (in module media_nommer.conf.utils) upload_to_destination() (media_nommer.ec2nommerd.nommers.base_nommer.BaseNommer method)

W

wipe_all_job_data() (media_nommer.core.job_state_backend.JobStateBackend class method)

wrapped_set_job_state() (media_nommer.ec2nommerd.nommers.base_nommer.BaseNommer method)