Class: Webhookdb::Replicator::AtomSingleFeedV1::Backfiller
- Inherits:
-
Base::ServiceBackfiller
- Object
- Backfiller
- Base::ServiceBackfiller
- Webhookdb::Replicator::AtomSingleFeedV1::Backfiller
- Includes:
- Backfiller::Bulk
- Defined in:
- lib/webhookdb/replicator/atom_single_feed_v1.rb
Instance Attribute Summary collapse
-
#upserting_replicator ⇒ Object
readonly
Returns the value of attribute upserting_replicator.
Attributes inherited from Base::ServiceBackfiller
#server_error_backoff, #server_error_retries, #svc
Instance Method Summary collapse
- #conditional_upsert? ⇒ Boolean
-
#initialize(replicator) ⇒ Backfiller
constructor
A new instance of Backfiller.
- #prepare_body(body) ⇒ Object
- #upsert_page_size ⇒ Object
Methods included from Backfiller::Bulk
#dry_run?, #flush_pending_inserts, #handle_item, #pending_inserts, #remote_key_column_name
Methods inherited from Base::ServiceBackfiller
#__retryordie, #fetch_backfill_page, #handle_item
Methods inherited from Backfiller
#_fetch_backfill_page_with_retry, #backfill, do_retry_wait, #fetch_backfill_page, #handle_item, #max_backfill_retry_attempts, #wait_for_retry_attempt
Constructor Details
#initialize(replicator) ⇒ Backfiller
Returns a new instance of Backfiller.
79 80 81 82 |
# File 'lib/webhookdb/replicator/atom_single_feed_v1.rb', line 79 def initialize(replicator) super @upserting_replicator = @svc end |
Instance Attribute Details
#upserting_replicator ⇒ Object (readonly)
Returns the value of attribute upserting_replicator.
77 78 79 |
# File 'lib/webhookdb/replicator/atom_single_feed_v1.rb', line 77 def upserting_replicator @upserting_replicator end |
Instance Method Details
#conditional_upsert? ⇒ Boolean
85 |
# File 'lib/webhookdb/replicator/atom_single_feed_v1.rb', line 85 def conditional_upsert? = true |
#prepare_body(body) ⇒ Object
86 |
# File 'lib/webhookdb/replicator/atom_single_feed_v1.rb', line 86 def prepare_body(body) = body |
#upsert_page_size ⇒ Object
84 |
# File 'lib/webhookdb/replicator/atom_single_feed_v1.rb', line 84 def upsert_page_size = 500 |