class SearchIngest::Table(T)

Included Modules

Defined in:

search-ingest/table.cr

Constructors

Instance Method Summary

Instance methods inherited from module SearchIngest::Table::Interface

backfill backfill, consistent_index? consistent_index?, reindex reindex, start start, stop stop

Constructor Detail

def self.new(schema_data : Schemas, **args) #

[View source]

Instance Method Detail

def backfill : Bool #

Backfills from a table to all relevent indices


[View source]
def consistent_index? #

[View source]
def create_index #

Applies a schema to an index in elasticsearch


[View source]
def load_resources #

Override #load_resources in favour of the batching provided by #backfill


[View source]
def mapping_conflict? #

Diff the current mapping schema (if any) against provided mapping schema


[View source]
def on_reconnect #
Description copied from class PlaceOS::Resource(T)

Callback called when changefeed is reconnected


[View source]
def process_resource(action : PlaceOS::Resource::Action, resource model : T) : PlaceOS::Resource::Result #

[View source]
def reindex : Bool #

Clear, update mapping an ES index and refill with PostgreSQL records


[View source]
def schema_data : Schemas #

[View source]