Class: Webhookdb::Replicator::AtomSingleFeedV1::Backfiller

Inherits:
Base::ServiceBackfiller show all
Includes:
Backfiller::Bulk
Defined in:
lib/webhookdb/replicator/atom_single_feed_v1.rb

Instance Attribute Summary collapse

Attributes inherited from Base::ServiceBackfiller

#server_error_backoff, #server_error_retries, #svc

Instance Method Summary collapse

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

Returns:

  • (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