Functions — github.com/JagritGumber/evolvsql

hub / github.com/JagritGumber/evolvsql / functions

Functions735 in github.com/JagritGumber/evolvsql

⨍ Functions 735◇ Types & classes 48

↓ 3 callersFunctionapply_default

Apply column default value (literal or NEXTVAL for sequences).

native/engine/src/executor/helpers.rs:92

↓ 3 callersFunctionclear_env

()

native/engine/src/wal/tests/recovery/nif_boot.rs:21

↓ 3 callersMethodcol_idx

(&self)

native/engine/src/hnsw.rs:63

↓ 3 callersFunctiondelete_all

(schema: &str, name: &str)

native/engine/src/storage.rs:169

↓ 3 callersFunctionestimate_row_bytes

Rough byte estimate for a row, used for flush threshold decisions. Includes the fixed MemRow overhead plus variable-length payload.

native/engine/src/memtable/bytes.rs:7

↓ 3 callersFunctionextract_col_name

Extract column name from ColumnRef.

native/engine/src/executor/resolve.rs:106

↓ 3 callersFunctionextract_string_fields

Extract string fields from a ColumnRef.

native/engine/src/executor/resolve.rs:7

↓ 3 callersFunctionint_schema

()

native/engine/src/segment/tests/zone_maps.rs:5

↓ 3 callersFunctionis_aggregate

Check if function name is an aggregate.

native/engine/src/executor/aggregate.rs:14

↓ 3 callersFunctionlast_peer_pos

Find the last peer position for RANGE frame semantics. Peers are rows with equal ORDER BY values.

native/engine/src/window.rs:338

↓ 3 callersMethodmetric

(&self)

native/engine/src/hnsw.rs:67

↓ 3 callersFunctionnextval

(schema: &str, name: &str)

native/engine/src/sequence.rs:40

↓ 3 callersFunctionparse_error

(data: &[u8])

native/cli/src/wire.rs:322

↓ 3 callersMethodread_column

Read a single column's values. This is the primary columnar access path: callers scan only the columns they need.

native/engine/src/segment/reader.rs:60

↓ 3 callersFunctionrebuild_indexes

Rebuild all indexes from current rows. Used after UPDATE and DELETE to ensure composite PK index consistency.

native/engine/src/storage.rs:270

↓ 3 callersFunctionreset

()

native/engine/src/storage.rs:982

↓ 3 callersFunctionsetup

(name: &str)

native/engine/src/wal/tests/recovery/alter_then_mutate.rs:11

↓ 3 callersFunctionsetval

(schema: &str, name: &str, value: i64)

native/engine/src/sequence.rs:60

↓ 3 callersFunctionsimulate_restart

(path: &std::path::Path)

native/engine/src/wal/tests/recovery/ddl_phantom_wal.rs:28

↓ 3 callersFunctiontest_table

()

native/engine/src/catalog.rs:175

↓ 3 callersFunctionwipe_and_recover

()

native/engine/src/wal/tests/recovery/alter_then_mutate.rs:21

↓ 2 callersFunctionadd_to_working_indexes

Add a row's values to working (cloned) indexes.

native/engine/src/storage.rs:583

↓ 2 callersFunctionalter_add_column

Add a column to all existing rows (appends default_val to each row).

native/engine/src/storage.rs:902

↓ 2 callersFunctionalter_drop_column

Drop a column from all existing rows by index.

native/engine/src/storage.rs:912

↓ 2 callersFunctionalter_table_add_column

()

native/engine/src/executor/tests/ddl.rs:5

↓ 2 callersFunctionalter_table_drop_column

()

native/engine/src/executor/tests/ddl.rs:29

↓ 2 callersFunctionappend_create_table

Append a CreateTable entry. The full table definition is serialized so recovery can recreate catalog + storage state without re-parsing SQL.

native/engine/src/wal/manager/ops.rs:51

↓ 2 callersFunctionappend_update

Append an Update entry. `old_row` identifies the row being replaced; recovery finds the matching row by content.

native/engine/src/wal/manager/ops.rs:31

↓ 2 callersFunctionapply_offset_limit

(select: &pg_query::protobuf::SelectStmt, rows: &mut Vec<Vec<ArenaValue>>)

native/engine/src/executor/select_post.rs:122

↓ 2 callersFunctionassert_wal_contiguous

()

native/engine/src/wal/tests/concurrent_ddl_dml.rs:42

↓ 2 callersFunctionbuild_unique_checks

Build list of unique/PK constraint column indices.

native/engine/src/executor/insert_conflict.rs:12

↓ 2 callersMethodcmp

(&self, other: &Self)

native/engine/src/hnsw.rs:303

↓ 2 callersFunctioncompute_aggregate

Compute aggregate function result (COUNT, SUM, AVG, MIN, MAX, STRING_AGG, BOOL_AND/OR).

native/engine/src/executor/aggregate_compute.rs:7

↓ 2 callersFunctioncompute_bool_agg

(fc: &pg_query::protobuf::FuncCall, rows: &[Vec<ArenaValue>], ctx: &JoinContext, arena: &mut QueryArena, is_an

native/engine/src/executor/aggregate_compute.rs:106

↓ 2 callersFunctioncompute_min_max

(fc: &pg_query::protobuf::FuncCall, rows: &[Vec<ArenaValue>], ctx: &JoinContext, arena: &mut QueryArena, is_mi

native/engine/src/executor/aggregate_compute.rs:77

↓ 2 callersFunctioncurrval

(schema: &str, name: &str)

native/engine/src/sequence.rs:52

↓ 2 callersFunctiondelete_where

()

native/engine/src/executor/tests/delete.rs:5

↓ 2 callersFunctionenable_at_lsn

Enable the WAL with an explicit path and starting LSN. Used by recovery to resume the LSN counter past the existing entries.

native/engine/src/wal/manager/lifecycle.rs:15

↓ 2 callersFunctionencode_frame

Encode a single WAL frame: [frame_len: u32 LE] [lsn: u64 LE] [tag: u8] [payload] [crc32: u32 LE]

native/engine/src/wal/writer.rs:222

↓ 2 callersMethodencode_payload

Encode the operation payload using bincode.

native/engine/src/wal/entry.rs:88

↓ 2 callersFunctionensure_hnsw_index

Ensure the table has an HNSW index on the given column. Creates the index if it doesn't exist yet, and bulk-inserts existing rows.

native/engine/src/storage.rs:824

↓ 2 callersFunctioneval_arithmetic

(op: &str, left: &ArenaValue, right: &ArenaValue, arena: &QueryArena)

native/engine/src/executor/expr_ops.rs:48

↓ 2 callersFunctioneval_having_expr

( node: &NodeEnum, group_rows: &[Vec<ArenaValue>], ctx: &JoinContext, arena: &mut QueryArena, )

native/engine/src/executor/having.rs:19

↓ 2 callersFunctionexec_select_raw_post_filter

Shared post-filter logic: aggregates, ORDER BY, LIMIT, projection.

native/engine/src/executor/select_post.rs:15

↓ 2 callersFunctionextract_type_name

Extract type name from ColumnDef.

native/engine/src/executor/ddl.rs:112

↓ 2 callersFunctionformat_float

(f: f64)

native/engine/src/types.rs:158

↓ 2 callersMethodgreedy_closest

Greedy closest traversal at a given level.

native/engine/src/hnsw.rs:153

↓ 2 callersFunctionhas_hnsw_index

Check if a table has an HNSW index and return the indexed column index.

native/engine/src/storage.rs:880

↓ 2 callersFunctioninsert_batch_checked

Insert multiple rows atomically with uniqueness checks. All rows are validated against existing data AND each other before any are committed. If any r

native/engine/src/storage.rs:365

↓ 2 callersMethodpath

Path of the underlying WAL file.

native/engine/src/wal/writer.rs:142

↓ 2 callersFunctionrename_column

(schema: &str, table_name: &str, old_name: &str, new_name: &str)

native/engine/src/catalog.rs:152

↓ 2 callersFunctionreset_everything

()

native/engine/src/wal/tests/concurrent_ddl_dml.rs:35

↓ 2 callersFunctionresolve_targets

Resolve SELECT target list to Column or Expr variants.

native/engine/src/executor/resolve.rs:115

↓ 2 callersFunctionrun_one

(conn: &mut wire::Connection, sql: &str, timing: bool)

native/cli/src/main.rs:142

↓ 2 callersMethodsearch_layer

Beam search at a single layer. Returns (distance, node_id) sorted ascending.

native/engine/src/hnsw.rs:177

↓ 2 callersFunctionset_env

(path: &std::path::Path)

native/engine/src/wal/tests/recovery/nif_boot.rs:12

↓ 2 callersFunctionsetup

(name: &str)

native/engine/src/wal/tests/recovery/serial_cleanup.rs:22

↓ 2 callersFunctionsetup

(name: &str)

native/engine/src/wal/tests/recovery/null_updates.rs:10

↓ 2 callersFunctionsetup_table_indexes

Build all indexes for a freshly-created table from its catalog entry. Single-column PK or UNIQUE columns get per-column hash indexes; composite PK (>1

native/engine/src/storage.rs:119

↓ 2 callersFunctionsplit_seq_fqn

Parse a NextVal default's "schema.name" string into its parts.

native/engine/src/wal/recovery/apply/sequences.rs:20

↓ 2 callersMethodtag

(&self)

native/engine/src/wal/entry.rs:71

↓ 2 callersFunctionteardown

(path: &std::path::PathBuf)

native/engine/src/wal/tests/recovery/serial_cleanup.rs:32

↓ 2 callersFunctiontmp_integration_path

(name: &str)

native/engine/src/wal/tests/storage_integration.rs:8

↓ 2 callersFunctiontmp_manager_path

(name: &str)

native/engine/src/wal/tests/manager_tests.rs:4

↓ 2 callersFunctionupdate_rows_checked

Update matching rows with validation. Returns error if any updater fails. Fixes: intra-batch uniqueness check (#3) and panic-safe atomic swap (#6).

native/engine/src/storage.rs:734

↓ 2 callersFunctionwipe_and_recover

()

native/engine/src/wal/tests/recovery/null_updates.rs:20

↓ 1 callersFunctionadd_pk_index

native/engine/src/storage.rs:93

↓ 1 callersFunctionadd_unique_index

native/engine/src/storage.rs:79

↓ 1 callersFunctionadvance_all_to_max

Walk every catalog table; for each column with a NextVal default, scan storage for the max int value and setval the sequence so the next nextval produ

native/engine/src/wal/recovery/apply/sequences.rs:41

↓ 1 callersFunctionappend_alter_add_column

Append an ALTER TABLE ADD COLUMN entry. fill_value is the resolved default used to backfill existing rows at ALTER time.

native/engine/src/wal/manager/ops.rs:65

↓ 1 callersFunctionappend_alter_drop_column

(schema: &str, table: &str, column: &str)

native/engine/src/wal/manager/ops.rs:74

↓ 1 callersFunctionappend_drop_table

Append a DropTable entry.

native/engine/src/wal/manager/ops.rs:56

↓ 1 callersFunctionappend_rename_column

(schema: &str, table: &str, old_column: &str, new_column: &str)

native/engine/src/wal/manager/ops.rs:90

↓ 1 callersFunctionappend_rename_table

(schema: &str, old_name: &str, new_name: &str)

native/engine/src/wal/manager/ops.rs:82

↓ 1 callersFunctionapply_alter

Apply a single ALTER op. Returns Ok(true) if applied, Ok(false) if skipped (table missing from a partial replay, or target state already reached), Err

native/engine/src/wal/recovery/apply/alter.rs:25

↓ 1 callersFunctionapply_delete

(schema: &str, table: &str, old_row: &[Value])

native/engine/src/wal/recovery/apply/mod.rs:77

↓ 1 callersFunctionapply_entries

Apply a list of entries to storage. Insert uses the unchecked path since constraints were already validated when logged. Update and Delete match rows

native/engine/src/wal/recovery/apply/mod.rs:13

↓ 1 callersFunctionapply_on_conflict_update

Apply ON CONFLICT DO UPDATE SET assignments with EXCLUDED pseudo-table.

native/engine/src/executor/insert_conflict.rs:50

↓ 1 callersFunctionapply_update

(schema: &str, table: &str, old_row: &[Value], new_row: &[Value])

native/engine/src/wal/recovery/apply/mod.rs:64

↓ 1 callersFunctionbuild_columns

(targets: &[SelectTarget], ctx: &JoinContext, _arena: &QueryArena)

native/engine/src/executor/select_post.rs:84

↓ 1 callersFunctionbuild_window_positions

(targets: &[SelectTarget])

native/engine/src/executor/select_post.rs:110

↓ 1 callersMethodbytes_ref

(&self)

native/engine/src/arena.rs:104

↓ 1 callersFunctioncheck_all_unique

Validate ALL unique constraints for a row (not filtered by conflict target).

native/engine/src/storage.rs:625

↓ 1 callersFunctioncheck_unique_against

Validate uniqueness of `new_row` against `all_rows`, excluding row at `skip_idx`.

native/engine/src/executor/insert_conflict.rs:80

↓ 1 callersFunctionclassify_node

(node: &NodeEnum)

native/engine/src/parser.rs:27

↓ 1 callersMethodcolumns

All column metadata (schema + zone maps).

native/engine/src/segment/reader.rs:49

↓ 1 callersFunctioncompute_aggregate_window

Compute aggregate window function (SUM/COUNT/AVG/MIN/MAX OVER). Uses default RANGE frame: UNBOUNDED PRECEDING to CURRENT ROW with peer groups.

native/engine/src/window.rs:445

↓ 1 callersFunctioncompute_avg

(fc: &pg_query::protobuf::FuncCall, rows: &[Vec<ArenaValue>], ctx: &JoinContext, arena: &mut QueryArena)

native/engine/src/executor/aggregate_compute.rs:63

↓ 1 callersFunctioncompute_count

(fc: &pg_query::protobuf::FuncCall, rows: &[Vec<ArenaValue>], ctx: &JoinContext, arena: &mut QueryArena)

native/engine/src/executor/aggregate_compute.rs:24

↓ 1 callersFunctioncompute_frame_aggregate

Compute an aggregate over a frame slice of pre-evaluated values.

native/engine/src/window.rs:491

↓ 1 callersFunctioncompute_ranking

Compute ranking function values for one partition.

native/engine/src/window.rs:272

↓ 1 callersFunctioncompute_string_agg

(fc: &pg_query::protobuf::FuncCall, rows: &[Vec<ArenaValue>], ctx: &JoinContext, arena: &mut QueryArena)

native/engine/src/executor/aggregate_compute.rs:89

↓ 1 callersFunctioncompute_sum

(fc: &pg_query::protobuf::FuncCall, rows: &[Vec<ArenaValue>], ctx: &JoinContext, arena: &mut QueryArena)

native/engine/src/executor/aggregate_compute.rs:42

↓ 1 callersFunctioncompute_value

Compute value function results (LAG, LEAD, FIRST_VALUE, LAST_VALUE, NTH_VALUE) for one partition.

native/engine/src/window.rs:362

↓ 1 callersFunctioncompute_zone_map

Compute (min, max, null_count) for a column's values. Used during segment writing to build zone maps. NULL values are excluded from min/max; if all va

native/engine/src/segment/zone_map.rs:10

↓ 1 callersMethoddecode

Decode an operation from its tag and payload bytes.

native/engine/src/wal/entry.rs:93

↓ 1 callersFunctiondecode_header

Decode the fixed-size header. Returns (row_count, col_count, footer_offset).

native/engine/src/segment/format.rs:53

↓ 1 callersFunctiondelete_all_returning

()

native/engine/src/executor/tests/returning.rs:82

↓ 1 callersFunctiondelete_where_returning

Delete matching rows and return the deleted rows (for RETURNING clause). WAL-first: writes the WAL entries before mutating in-memory state.

native/engine/src/storage.rs:225

↓ 1 callersFunctiondrop_table

(schema: &str, name: &str)

native/engine/src/catalog.rs:65

← previous next →101–200 of 735, ranked by callers