Module: PushmiPullyu
- Defined in:
- lib/pushmi_pullyu.rb,
lib/pushmi_pullyu/version.rb
Overview
PushmiPullyu main module
Defined Under Namespace
Modules: AIP, Logging Classes: CLI, PreservationQueue, SwiftDepositer
Constant Summary collapse
- DEFAULTS =
{ aip_version: 'lightaip-2.0', daemonize: false, debug: false, logdir: 'log', minimum_age: 0, monitor: false, piddir: 'tmp/pids', workdir: 'tmp/work', process_name: 'pushmi_pullyu', queue_name: 'dev:pmpy_queue', ingestion_prefix: 'prod:pmpy_ingest_attempt:', ingestion_attempts: 15, first_failed_wait: 10, redis: { url: 'redis://localhost:6379' }, swift: { tenant: 'tester', username: 'test:tester', password: 'testing', auth_url: 'http://localhost:8080/auth/v1.0', project_name: 'demo', project_domain_name: 'default', container: 'era', auth_version: 'v3', user_domain: 'default' }, rollbar: {}, # rubocop disable: Style/FetchEnvVar jupiter: { user: ENV.fetch('JUPITER_USER', nil), api_key: ENV.fetch('JUPITER_API_KEY', nil), jupiter_url: ENV.fetch('JUPITER_URL', nil) || 'http://era.lvh.me:3000/', aip_api_path: ENV.fetch('JUPITER_AIP_API_PATH', nil) || 'aip/v1' } # rubocop enable: Style/FetchEnvVar }.freeze
- VERSION =
'2.1.6'.freeze
Class Method Summary collapse
- .application_log_file ⇒ Object
- .continue_polling? ⇒ Boolean
- .logger ⇒ Object
- .logger=(log) ⇒ Object
- .options ⇒ Object
- .options=(opts) ⇒ Object
- .override_options(opts) ⇒ Object
- .reset_logger=(status) ⇒ Object
- .reset_logger? ⇒ Boolean
- .server_running=(status) ⇒ Object
- .server_running? ⇒ Boolean
Class Method Details
.application_log_file ⇒ Object
69 70 71 |
# File 'lib/pushmi_pullyu.rb', line 69 def self.application_log_file "#{[:logdir]}/#{[:process_name]}.log" end |
.continue_polling? ⇒ Boolean
93 94 95 |
# File 'lib/pushmi_pullyu.rb', line 93 def self.continue_polling? server_running? && !reset_logger? end |
.logger ⇒ Object
73 74 75 |
# File 'lib/pushmi_pullyu.rb', line 73 def self.logger PushmiPullyu::Logging.logger end |
.logger=(log) ⇒ Object
77 78 79 |
# File 'lib/pushmi_pullyu.rb', line 77 def self.logger=(log) PushmiPullyu::Logging.logger = log end |
.options ⇒ Object
57 58 59 |
# File 'lib/pushmi_pullyu.rb', line 57 def self. @options ||= DEFAULTS.dup end |
.options=(opts) ⇒ Object
61 62 63 |
# File 'lib/pushmi_pullyu.rb', line 61 def self.(opts) .deep_merge!(opts) end |
.override_options(opts) ⇒ Object
65 66 67 |
# File 'lib/pushmi_pullyu.rb', line 65 def self.(opts) @options = opts end |
.reset_logger=(status) ⇒ Object
85 86 87 |
# File 'lib/pushmi_pullyu.rb', line 85 def self.reset_logger=(status) @reset_logger = status end |
.reset_logger? ⇒ Boolean
97 98 99 |
# File 'lib/pushmi_pullyu.rb', line 97 def self.reset_logger? @reset_logger end |
.server_running=(status) ⇒ Object
81 82 83 |
# File 'lib/pushmi_pullyu.rb', line 81 def self.server_running=(status) @server_running = status end |
.server_running? ⇒ Boolean
89 90 91 |
# File 'lib/pushmi_pullyu.rb', line 89 def self.server_running? @server_running end |