Module ra_system

Data Types

config()

config() = #{name := atom(), names := names(), data_dir := file:filename(), wal_data_dir => file:filename(), wal_max_size_bytes => non_neg_integer(), wal_compute_checksums => boolean(), wal_max_batch_size => non_neg_integer(), wal_max_entries => undefined | non_neg_integer(), wal_write_strategy => default | o_sync | sync_after_notify, wal_sync_method => datasync | sync | none, wal_hibernate_after => non_neg_integer(), wal_garbage_collect => boolean(), wal_pre_allocate => boolean(), segment_max_entries => non_neg_integer(), segment_max_pending => non_neg_integer(), segment_compute_checksums => boolean(), snapshot_chunk_size => non_neg_integer(), receive_snapshot_timeout => non_neg_integer(), default_max_pipeline_count => non_neg_integer(), default_max_append_entries_rpc_batch_size => non_neg_integer(), message_queue_data => on_heap | off_heap, wal_min_heap_size => non_neg_integer(), wal_min_bin_vheap_size => non_neg_integer(), server_min_bin_vheap_size => non_neg_integer(), server_min_heap_size => non_neg_integer(), compress_mem_tables => boolean(), low_priority_commands_flush_size => non_neg_integer(), low_priority_commands_in_memory_size => non_neg_integer(), server_recovery_strategy => undefined | registered | {module(), atom(), list()}}

names()

names() = #{wal := atom(), wal_sup := atom(), log_sup := atom(), log_ets := atom(), log_meta := atom(), open_mem_tbls := atom(), closed_mem_tbls := atom(), segment_writer := atom(), server_sup := atom(), directory := atom(), directory_rev := atom()}

Function Index

default_config/0
derive_names/1
fetch/1
fetch/2
lookup_name/2
start/1
start_default/0
stop/1
stop_default/0
store/1

Function Details

default_config/0

default_config() -> ra_system:config()

derive_names/1

derive_names(SysName) -> any()

fetch/1

fetch(Name::atom()) -> config() | undefined

fetch/2

fetch(Name::atom(), Node::atom()) -> config() | undefined | {badrpc, term()}

lookup_name/2

lookup_name(System::atom(), Key::atom()) -> {ok, atom()} | {error, system_not_started}

start/1

start(Config::ra_system:config()) -> supervisor:startchild_ret()

start_default/0

start_default() -> supervisor:startchild_ret()

stop/1

stop(System::ra_system:config() | atom()) -> ok | {error, any()}

stop_default/0

stop_default() -> ok | {error, any()}

store/1

store(Config::config()) -> ok


Generated by EDoc