Electric.ShapeCache.CrashingFileStorage (electric v1.2.4)

A thing wrapper module around PureFileStorage that can be configured to raise an error after a certain number of writes.

Summary

Functions

append_to_log!(log_items, opts)

Callback implementation for c:Electric.ShapeCache.Storage.append_to_log!/2.

cleanup!(opts)

Callback implementation for c:Electric.ShapeCache.Storage.cleanup!/1.

cleanup!(opts, shape_handle)

Callback implementation for c:Electric.ShapeCache.Storage.cleanup!/2.

cleanup_all!(opts)

Callback implementation for c:Electric.ShapeCache.Storage.cleanup_all!/1.

compact(opts, keep_complete_chunks)

Callback implementation for c:Electric.ShapeCache.Storage.compact/2.

for_shape(shape_handle, opts)

Callback implementation for c:Electric.ShapeCache.Storage.for_shape/2.

get_all_stored_shape_handles(opts)

Callback implementation for c:Electric.ShapeCache.Storage.get_all_stored_shape_handles/1.

get_all_stored_shapes(opts)

Callback implementation for c:Electric.ShapeCache.Storage.get_all_stored_shapes/1.

get_chunk_end_log_offset(offset, opts)

Callback implementation for c:Electric.ShapeCache.Storage.get_chunk_end_log_offset/2.

get_current_position(opts)

Callback implementation for c:Electric.ShapeCache.Storage.get_current_position/1.

get_log_stream(offset, max_offset, opts)

Callback implementation for c:Electric.ShapeCache.Storage.get_log_stream/3.

get_total_disk_usage(opts)

Callback implementation for c:Electric.ShapeCache.Storage.get_total_disk_usage/1.

hibernate(opts)

Callback implementation for c:Electric.ShapeCache.Storage.hibernate/1.

init_writer!(opts, shape_definition, storage_recovery_state)

Callback implementation for c:Electric.ShapeCache.Storage.init_writer!/3.

make_new_snapshot!(data_stream, opts)

Callback implementation for c:Electric.ShapeCache.Storage.make_new_snapshot!/2.

mark_snapshot_as_started(opts)

Callback implementation for c:Electric.ShapeCache.Storage.mark_snapshot_as_started/1.

metadata_backup_dir(opts)

Callback implementation for c:Electric.ShapeCache.Storage.metadata_backup_dir/1.

set_pg_snapshot(pg_snapshot, opts)

Callback implementation for c:Electric.ShapeCache.Storage.set_pg_snapshot/2.

shared_opts(opts)

Callback implementation for c:Electric.ShapeCache.Storage.shared_opts/1.

snapshot_started?(opts)

Callback implementation for c:Electric.ShapeCache.Storage.snapshot_started?/1.

stack_start_link(opts)

Callback implementation for c:Electric.ShapeCache.Storage.stack_start_link/1.

start_link(opts)

Callback implementation for c:Electric.ShapeCache.Storage.start_link/1.

terminate(opts)

Callback implementation for c:Electric.ShapeCache.Storage.terminate/1.