Class: Webhookdb::Replicator::IntercomV1Mixin::Backfiller

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

Instance Attribute Summary

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, #update_where_expr, #upsert_update_expr

Methods inherited from Base::ServiceBackfiller

#__retryordie, #fetch_backfill_page, #handle_item, #initialize

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

This class inherits a constructor from Webhookdb::Replicator::Base::ServiceBackfiller

Instance Method Details

#conditional_upsert? ⇒ Boolean

We don’t want to override newer items from webhooks, so use conditional upsert.

Returns:

  • (Boolean) 


150
 
# File 'lib/webhookdb/replicator/intercom_v1_mixin.rb', line 150

def conditional_upsert? = true

#prepare_body(_body) ⇒ Object 



147
 
# File 'lib/webhookdb/replicator/intercom_v1_mixin.rb', line 147

def prepare_body(_body) = nil

#upsert_page_size ⇒ Object

Upsert for each API call



146
 
# File 'lib/webhookdb/replicator/intercom_v1_mixin.rb', line 146

def upsert_page_size = Webhookdb::Intercom.page_size

#upserting_replicator ⇒ Object 



148
149
 
# File 'lib/webhookdb/replicator/intercom_v1_mixin.rb', line 148

def upserting_replicator = self.svc
# We don't want to override newer items from webhooks, so use conditional upsert.