Module request 

Worker requests.

Structs

BuildIndexRequest 🔒

BulkColumn 🔒

A column of the batch of a bulk insert.

BulkInsertRequest 🔒

CompactionFailed 🔒

A failing compaction result.

CompactionFinished 🔒

Notifies a compaction job has finished.

CopyRegionFromFinished 🔒

CopyRegionFromRequest 🔒

DiscardUnflushedResult 🔒

Notifies the result of discarding unflushed data from a region.

EnterStagingResult 🔒

Notifies the region the result of entering staging.

FlushFailed 🔒

Notifies a flush job is failed.

FlushFinished 🔒

Notifies a flush job is finished.

IndexBuildFinished 🔒

IndexBuildStopped 🔒

Notifies an index build job has been stopped.

OptionOutputTx 🔒

Optional output result sender.

OutputTx

Oneshot output result sender.

RegionChangeResult 🔒

Notifies the region the result of writing region change action.

RegionEditRequest 🔒

Request to edit a region directly.

RegionEditResult 🔒

Notifies the regin the result of editing region.

RegionSyncRequest 🔒

RemapManifestsRequest 🔒

RowColumn 🔒

A column of the rows of a WriteRequest.

SenderBulkRequest 🔒

SenderDdlRequest 🔒

Sender and Ddl request.

SenderWriteRequest 🔒

Sender and write request.

TruncateResult 🔒

Notifies the truncate result of a region.

Waiters 🔒

WorkerRequestWithTime 🔒

Request sent to a worker with timestamp

WriteRequest

Request to write a region.

Enums

BackgroundNotify 🔒

Notification from a background job.

CompactionUnitNotification 🔒

A local unit event carries only identity, never an input reservation lease.

DdlRequest 🔒

DDL request to a region.

WorkerRequest 🔒

Request sent to a worker

Traits

OnFailure 🔒

Callback on failure.

RequestColumn 🔒

A column of a write request, as check_request_columns sees it.

Functions

check_bulk_insert_batch

Checks the batch of a bulk insert against the region schema with the rules WriteRequest::check_schema applies to rows: column names are unique, every column is a column of the region with its Arrow type and contains nulls only if the region column is nullable, and a missing column is nullable or has a default value. Tags may use any string encoding. Sparse batches may carry the tags in one encoded primary key column instead. Returns whether the batch misses columns that the writer fills.

check_column_can_be_filled 🔒

Checks that a write may leave out column, which is then filled with its default value or null.

check_request_columns 🔒

Checks the columns of a write request against the region schema. Each column must be a column of the region, have its data type and, if the request carries one, its semantic type, and contain nulls only if the region column is nullable. check_missing checks the region columns that the request doesn’t have. Returns whether there are such columns.

validate_proto_value 🔒

Validate proto value schema.