Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/KuiBaDB/KuiBaDB
/ functions
Functions
599 in github.com/KuiBaDB/KuiBaDB
⨍
Functions
599
◇
Types & classes
209
↓ 1 callers
Function
get_proc
(state: &SessionState, oid: Oid)
src/catalog.rs:187
↓ 1 callers
Function
get_relopt
(stmt: &syn::CreateTableStmt, state: &mut SessionState)
src/commands/tablecmds.rs:80
↓ 1 callers
Method
get_snap
(&self)
src/access/xact.rs:151
↓ 1 callers
Function
get_type_desc
LookupTypeNameExtended
src/commands/tablecmds.rs:30
↓ 1 callers
Function
get_type_input_info
(state: &SessionState, oid: Oid)
src/catalog.rs:280
↓ 1 callers
Function
get_type_output_info
(state: &SessionState, oid: Oid)
src/catalog.rs:269
↓ 1 callers
Method
get_xid_status
(&self, cache: &mut L1CacheT, xid: Xid)
src/access/clog.rs:96
↓ 1 callers
Function
getrel
(sess: &mut SessionState, table: Oid)
src/access/rel.rs:124
↓ 1 callers
Function
getrelattrs
(sess: &mut SessionState, table: Oid)
src/access/rel.rs:84
↓ 1 callers
Function
getrelopt
(sess: &mut SessionState, table: Oid)
src/access/rel.rs:53
↓ 1 callers
Function
global_release
(lock: &LockState, mode: LockMode)
src/access/lmgr.rs:303
↓ 1 callers
Method
grant
(&mut self, mode: LockMode)
src/access/lmgr.rs:137
↓ 1 callers
Function
handle_cancel_request
(cancelmap: &Mutex<CancelMap>, cancel_req: protocol::CancelRequest)
src/lib.rs:253
↓ 1 callers
Method
has_null
(&self)
src/datums.rs:396
↓ 1 callers
Method
hash
(&self, md5h: &mut md5::Context)
src/access.rs:128
↓ 1 callers
Function
hdr
(d: &[u8])
src/access/wal.rs:690
↓ 1 callers
Function
indatums2data
( indatums: Vec<Datums>, typmods: &[Rc<Datums>], typins: &[FmgrInfo], worker: &WorkerState, )
src/commands/copy.rs:61
↓ 1 callers
Method
init
(datadir: &str)
src/lib.rs:546
↓ 1 callers
Method
init
(&mut self, blkrows: u32)
src/access/csmvcc.rs:97
↓ 1 callers
Function
insert_cancel_map
(cancelmap: &Mutex<CancelMap>, sessid: u32, key: u32)
src/lib.rs:224
↓ 1 callers
Function
insert_create_l0file_wal
( sess: &mut SessionState, table: TableId, startid: u32, endid: u32, )
src/access/sv.rs:443
↓ 1 callers
Function
insert_xmin_wal
insert wal record for set_page_xmin().
src/access/csmvcc.rs:302
↓ 1 callers
Function
ioerr
(state: u32)
src/utils/sb.rs:272
↓ 1 callers
Function
is_shared_rel
IsSharedRelation
src/catalog.rs:310
↓ 1 callers
Function
just_dirtied
(state: u32)
src/utils/sb.rs:264
↓ 1 callers
Function
kb_analyze
parse_analyze
src/parser/sem.rs:355
↓ 1 callers
Function
left_oper
( session: &mut SessionState, opname: &Vec<syn::StrVal>, oprright: Oid, )
src/parser/sem.rs:213
↓ 1 callers
Method
load
()
src/access/wal.rs:129
↓ 1 callers
Method
load
(k: &Self::K, _ctx: &Self::LoadCtx, dat: &Self::CommonData)
src/access/slru.rs:66
↓ 1 callers
Function
load_guc
(gucstate: &mut GucState, guckey: &str, gucval: &Yaml)
src/guc.rs:196
↓ 1 callers
Function
load_gucs
()
build.rs:65
↓ 1 callers
Function
local_acquire
( locallocks: &mut [LocalLock<'_>; LOCKMODESNUM], mode: LockMode, )
src/access/lmgr.rs:250
↓ 1 callers
Function
local_release
( locallocks: &mut [LocalLock<'_>; LOCKMODESNUM], mode: LockMode, )
src/access/lmgr.rs:322
↓ 1 callers
Method
lock_dbobj
(&mut self, cls: Oid, obj: Oid, mode: LockMode)
src/access/lmgr.rs:435
↓ 1 callers
Method
lock_ns
(&mut self, ns: Oid, mode: LockMode)
src/access/lmgr.rs:444
↓ 1 callers
Method
lock_rel
(&mut self, rel: Oid, mode: LockMode)
src/access/lmgr.rs:448
↓ 1 callers
Method
lock_release
(&mut self, tag: &LockTag, mode: LockMode)
src/access/lmgr.rs:397
↓ 1 callers
Function
lock_stmt
(sess: &mut SessionState, lock: &syn::LockStmt<'_>)
src/commands/lockcmds.rs:18
↓ 1 callers
Function
log_commit_rec
(sess: &mut SessionState, commit_time: KBSystemTime)
src/access/xact.rs:357
↓ 1 callers
Function
log_nextoid
(sess: &mut SessionState, nextoid: u32)
src/access/xact.rs:459
↓ 1 callers
Method
lookup_explicit_namespace
(&self, nspname: &str)
src/catalog/namespace.rs:158
↓ 1 callers
Method
lsn
(&self)
src/access/wal.rs:290
↓ 1 callers
Function
lsn_in_file
(filelsn: Lsn, len: u64, lsn: Lsn)
src/access/wal.rs:314
↓ 1 callers
Function
main
()
kw.py:4
↓ 1 callers
Function
new_ckpt_rec
(ckpt: &Ckpt)
src/access/wal.rs:79
↓ 1 callers
Function
new_fifo_sb
(cap: usize, valctx: V::CommonData)
src/utils/sb.rs:559
↓ 1 callers
Method
new_oid
(&mut self)
src/access/xact.rs:702
↓ 1 callers
Function
new_sessid
(lastused: &mut u32)
src/bin/kuiba/main.rs:18
↓ 1 callers
Function
new_session
()
src/test.rs:31
↓ 1 callers
Function
new_session_state
(global_state: &GlobalState)
src/test.rs:27
↓ 1 callers
Function
oid_is_ns
(sess: &SessionState, nsoid: Oid)
src/catalog/namespace.rs:83
↓ 1 callers
Method
on_create_slot
(&mut self, _k: &K)
src/utils/sb.rs:522
↓ 1 callers
Method
on_drop_slot
(&mut self, _k: &K, _s: &Self::Data)
src/utils/sb.rs:528
↓ 1 callers
Method
on_error
(&self, err: &anyhow::Error, stream: &mut SockWriter)
src/utils.rs:168
↓ 1 callers
Method
on_use_slot
(&self, _k: &K, _s: &Self::Data)
src/utils/sb.rs:527
↓ 1 callers
Method
open_file
(&mut self)
src/access/wal.rs:416
↓ 1 callers
Method
open_wal
( &mut self, tli: TimeLineID, lsn: Lsn, )
src/access/wal.rs:347
↓ 1 callers
Function
oper
( session: &mut SessionState, opname: &Vec<syn::StrVal>, oprleft: Oid, oprright: Oid, )
src/parser/sem.rs:204
↓ 1 callers
Function
parse
(query: &str)
src/parser.rs:20
↓ 1 callers
Function
parse_copyopts
(copy: &'syn syn::CopyStmt<'_>)
src/commands/copy.rs:203
↓ 1 callers
Function
parse_lsn
(v: &[u8])
src/access/wal.rs:570
↓ 1 callers
Function
parse_tli
(v: &[u8])
src/access/wal.rs:564
↓ 1 callers
Method
pin
PinBuffer
src/utils/sb.rs:349
↓ 1 callers
Method
pin_locked
(&self, mut g: SlotLockGuard<V, E>)
src/utils/sb.rs:363
↓ 1 callers
Function
planner
(_state: &mut SessionState, parse: &sem::Query)
src/optimizer.rs:51
↓ 1 callers
Function
postgres_main
(global_state: GlobalState, streamv: TcpStream, sessid: u32)
src/lib.rs:380
↓ 1 callers
Method
prevent_in_transblock
(&self, stmt: &str)
src/access/xact.rs:712
↓ 1 callers
Function
process_utility
( stmt: &sem::UtilityStmt, state: &mut SessionState, )
src/utility.rs:173
↓ 1 callers
Function
pwritev
(fd: RawFd, iov: &[IoVec<&[u8]>], offset: off_t)
src/utils.rs:415
↓ 1 callers
Method
qualname_get_create_ns
( &self, names: &'a Vec<syn::StrVal>, )
src/catalog/namespace.rs:88
↓ 1 callers
Function
read_manifest
(path: &str, enable_cs_wal: bool)
src/access/sv.rs:220
↓ 1 callers
Function
read_message
(stream: &mut SockReader)
src/protocol.rs:34
↓ 1 callers
Method
read_record
(&mut self)
src/access/wal.rs:441
↓ 1 callers
Method
receive
( &mut self, tuples: &[Rc<Datums>], orownum: u32, worker: &WorkerState, )
src/access.rs:82
↓ 1 callers
Method
recently_redo_lsn
(&self)
src/access/wal.rs:1038
↓ 1 callers
Function
record_tran_abort
(sess: &mut SessionState)
src/access/xact.rs:379
↓ 1 callers
Function
record_tran_commit
(sess: &mut SessionState)
src/access/xact.rs:362
↓ 1 callers
Method
recycle
(&mut self, lsn: Lsn)
src/access/wal.rs:357
↓ 1 callers
Function
redo
(datadir: &str)
src/access/redo.rs:43
↓ 1 callers
Method
relname_get_oid
(&mut self, n: &str)
src/catalog/namespace.rs:230
↓ 1 callers
Method
renew
(&mut self)
src/lib.rs:530
↓ 1 callers
Function
report_all_gucs
(gucvals: &guc::GucState, stream: &mut SockWriter)
src/protocol.rs:398
↓ 1 callers
Function
report_guc
( name: &str, gucvals: &guc::GucState, gucidx: guc::GucIdx, stream: &mut SockWriter, )
src/protocol.rs:382
↓ 1 callers
Method
require_transblock
(&self, stmt: &str)
src/access/xact.rs:723
↓ 1 callers
Method
resize_fixedlen
(&mut self, ndatum: u32, typlen: usize, typalign: usize)
src/datums.rs:184
↓ 1 callers
Method
resize_pool
(&mut self, parallel: usize)
src/utils.rs:195
↓ 1 callers
Method
seen_xid
(&mut self, xid: Xid)
src/access/redo.rs:35
↓ 1 callers
Function
ser_be_i16
(out: &mut Vec<u8>, val: i16)
src/utils/ser.rs:141
↓ 1 callers
Function
ser_fixed_nonull
( out: &mut Vec<u8>, typlen: i16, rownum: u32, colidx: usize, input: &[(Vec<Rc<Datums>>, u
src/datums.rs:509
↓ 1 callers
Function
ser_u16
(out: &mut Vec<u8>, val: u16)
src/utils/ser.rs:117
↓ 1 callers
Function
ser_u64_at
(out: &mut Vec<u8>, idx: usize, val: u64)
src/utils/ser.rs:105
↓ 1 callers
Function
ser_update_l0file
(out: &mut Vec<u8>, table: TableId, files: &[FileMeta])
src/access/sv.rs:439
↓ 1 callers
Method
serialize
(&self)
src/protocol.rs:259
↓ 1 callers
Function
serialize_errmsg
(typ: u8, fields: &ErrFields)
src/protocol.rs:199
↓ 1 callers
Method
set_blk_rows
(&mut self, blkrows: u32)
src/access/csmvcc.rs:76
↓ 1 callers
Method
set_blk_xmin
Set the xmin of [sr, er) to xid.
src/access/csmvcc.rs:329
↓ 1 callers
Function
set_bool_guc
(idx: gucdef::B, val: bool, gucstate: &mut GucState)
src/guc.rs:192
↓ 1 callers
Method
set_fixedlen_at
(&mut self, idx: isize, val: T)
src/datums.rs:233
↓ 1 callers
Function
set_guc
(stmt: &syn::VariableSetStmt, state: &mut SessionState)
src/utility.rs:107
↓ 1 callers
Function
set_int_guc
(idx: gucdef::I, val: i32, gucstate: &mut GucState)
src/guc.rs:180
← previous
next →
301–400 of 599, ranked by callers