Module worker

Source
Expand description

Structs and utilities for writing regions.

Modulesยง

handle_alter ๐Ÿ”’
Handling alter related requests.
handle_bulk_insert ๐Ÿ”’
Handles bulk insert requests.
handle_catchup ๐Ÿ”’
Handling catchup request.
handle_close ๐Ÿ”’
Handling close request.
handle_compaction ๐Ÿ”’
handle_create ๐Ÿ”’
Handling create request.
handle_drop ๐Ÿ”’
Handling drop request.
handle_flush ๐Ÿ”’
Handling flush related requests.
handle_manifest ๐Ÿ”’
Handles manifest.
handle_open ๐Ÿ”’
Handling open request.
handle_truncate ๐Ÿ”’
Handling truncate related requests.
handle_write ๐Ÿ”’
Handling write requests.

Structsยง

RegionWorker ๐Ÿ”’
Worker to write and alter regions bound to it.
RegionWorkerLoop ๐Ÿ”’
Background worker loop to handle requests.
StalledRequests ๐Ÿ”’
Buffer for stalled write requests.
WorkerGroup ๐Ÿ”’
A fixed size group of RegionWorkers.
WorkerListener ๐Ÿ”’
Wrapper that only calls event listener in tests.
WorkerStarter ๐Ÿ”’
Worker start config.

Constantsยง

CHECK_REGION_INTERVAL ๐Ÿ”’
Interval to check whether regions should flush.
DROPPING_MARKER_FILE ๐Ÿ”’
MAX_INITIAL_CHECK_DELAY_SECS ๐Ÿ”’
Max delay to check region periodical tasks.

Functionsยง

region_id_to_index ๐Ÿ”’
worker_init_check_delay ๐Ÿ”’
Computes a initial check delay for a worker.
write_cache_from_config ๐Ÿ”’

Type Aliasesยง

RequestBuffer ๐Ÿ”’
WorkerId ๐Ÿ”’
Identifier for a worker.