API
#github.com/xulang-org/packages/mongodbMongoDB Document Database Native Driver for Xu Features Pure native MongoDB Wire Protocol (OP_MSG opcode 2012) implementation. Lightweight BSON encoding and decoding without external dependencies. Full session handshake (hello). Document CRUD: insert_one, find, drop_collection, run_command. Connection pooling via reusable TCP socket channels.
github.com/xulang-org/packages · 0.1.1 · Install and use
openpub fn open(addr string) ClientMongoDB Document Database Native Driver for Xu Features Pure native MongoDB Wire Protocol (OP_MSG opcode 2012) implementation. Lightweight BSON encoding and decoding without external dependencies. Full session handshake (hello). Document CRUD: insert_one, find, drop_collection, run_command. Connection pooling via reusable TCP socket channels. Throws on failure.
addr stringClient — a value of this type
open_poolpub fn open_pool(addr string, max_idle int) PoolOpen pool.
addr stringmax_idle intPool — a value of this type
encode_i32pub fn encode_i32(v int) stringLightweight BSON Encoder & Decoder for MongoDB Wire Protocol.
v intstring — result string
encode_i64pub fn encode_i64(v int) stringEncode.
v intstring — result string
decode_i32pub fn decode_i32(s &string, off int) intDecode.
s &stringoff intint — a value of this type
build_docpub fn build_doc(elements string) stringBuild doc.
elements stringstring — result string
bson_stringpub fn bson_string(name string, val string) stringBson string.
name stringval stringstring — result string
bson_int32pub fn bson_int32(name string, val int) stringBson int32.
name stringval intstring — result string
bson_int64pub fn bson_int64(name string, val int) stringBson int64.
name stringval intstring — result string
bson_boolpub fn bson_bool(name string, val bool) stringBson bool.
name stringval boolstring — result string
bson_docpub fn bson_doc(name string, doc_bytes string) stringBson doc.
name stringdoc_bytes stringstring — result string
bson_arraypub fn bson_array(name string, arr_bytes string) stringBson array.
name stringarr_bytes stringstring — result string
bson_object_idpub fn bson_object_id(name string, oid_bytes string) stringBson object id.
name stringoid_bytes stringstring — result string
bson_utc_datetimepub fn bson_utc_datetime(name string, millis int) stringBson utc datetime.
name stringmillis intstring — result string
bson_nullpub fn bson_null(name string) stringBson null.
name stringstring — result string
find_bson_stringpub fn find_bson_string(doc string, target_field string) stringFind bson string.
doc stringtarget_field stringstring — result string
is_bson_okpub fn is_bson_ok(doc string) boolWhether it is bson ok.
doc stringbool — true or false
struct Clientpub struct Client {
pub fd int
pub addr string
pub next_req_id int
}Public struct `Client`.
fd intaddr stringnext_req_id int(&mut Client) write_exactpub fn (c &mut Client) write_exact(data string) intMethod on `&mut Client`: write exact. Throws on failure.
c &mut Clientdata stringint — a value of this type
(&mut Client) read_exactpub fn (c &mut Client) read_exact(n int) stringMethod on `&mut Client`: read exact. Throws on failure.
c &mut Clientn intstring — result string
(&mut Client) run_commandpub fn (c &mut Client) run_command(db_name string, cmd_elements string) stringMethod on `&mut Client`: run command. Throws on failure.
c &mut Clientdb_name stringcmd_elements stringstring — result string
connectpub fn connect(addr string) Clientconnect; returns Client. Throws on failure.
addr stringClient — a value of this type
(&mut Client) hellopub fn (c &mut Client) hello() boolCall `hello` on `&mut Client`.
c &mut Clientbool — true or false
(&mut Client) insert_onepub fn (c &mut Client) insert_one(db_name string, col_name string, doc_bytes string) intMethod on `&mut Client`: insert one. Throws on failure.
c &mut Clientdb_name stringcol_name stringdoc_bytes stringint — a value of this type
(&mut Client) find_first_stringpub fn (c &mut Client) find_first_string(db_name string, col_name string, target_field string) stringMethod on `&mut Client`: find first string. Throws on failure.
c &mut Clientdb_name stringcol_name stringtarget_field stringstring — result string
(&mut Client) drop_collectionpub fn (c &mut Client) drop_collection(db_name string, col_name string) boolMethod on `&mut Client`: drop collection.
c &mut Clientdb_name stringcol_name stringbool — true or false
(&mut Client) closepub fn (c &mut Client) close()Method on `&mut Client`: close the resource.
c &mut Clientstruct Poolpub struct Pool {
pub addr string
pub idle chan int
pub max_idle int
}Connection Pool for MongoDB. Uses channel of socket file descriptors for lightweight and high-throughput pooling.
addr stringidle chan intmax_idle intnew_poolpub fn new_pool(addr string, max_idle int) PoolConstruct pool.
addr stringmax_idle intPool — a value of this type
(&Pool) getpub fn (p &Pool) get() ClientCall `get` on `&Pool`. Throws on failure.
p &PoolClient — a value of this type
(&Pool) put_connpub fn (p &Pool) put_conn(fd int)Method on `&Pool`: put connection.
p &Poolfd int(&Pool) putpub fn (p &Pool) put(c Client)Call `put` on `&Pool`.
p &Poolc Client(&Pool) hellopub fn (p &Pool) hello() boolCall `hello` on `&Pool`.
p &Poolbool — true or false
(&Pool) insert_onepub fn (p &Pool) insert_one(db_name string, col_name string, doc_bytes string) intMethod on `&Pool`: insert one. Throws on failure.
p &Pooldb_name stringcol_name stringdoc_bytes stringint — a value of this type
(&Pool) find_first_stringpub fn (p &Pool) find_first_string(db_name string, col_name string, target_field string) stringMethod on `&Pool`: find first string. Throws on failure.
p &Pooldb_name stringcol_name stringtarget_field stringstring — result string
(&Pool) drop_collectionpub fn (p &Pool) drop_collection(db_name string, col_name string) boolMethod on `&Pool`: drop collection.
p &Pooldb_name stringcol_name stringbool — true or false
(&Pool) closepub fn (p &Pool) close()Method on `&Pool`: close the resource.
p &Poolencode_op_msgpub fn encode_op_msg(request_id int, doc_bytes string) stringMongoDB OP_MSG (Opcode 2013) Wire Protocol Framer
request_id intdoc_bytes stringstring — result string
decode_op_msg_docpub fn decode_op_msg_doc(raw string) stringDecode. Throws on failure.
raw stringstring — result string