Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Newer
Older
100644 88 lines (76 sloc) 2.803 kb
b2c8070 @nrs135 [feature] mongo: New files for mongo API.
nrs135 authored
1
2 (* OP codes *)
3 val _OP_REPLY : int
4 val _OP_MSG : int
5 val _OP_UPDATE : int
6 val _OP_INSERT : int
7 val _RESERVED : int
8 val _OP_QUERY : int
9 val _OP_GET_MORE : int
10 val _OP_DELETE : int
11 val _OP_KILL_CURSORS : int
12
13 (* OP_INSERT *)
14 val _ContinueOnError : int
15
16 (* OP_UPDATE *)
17 val _Upsert : int
18 val _MultiUpdate : int
19
20 (* OP_QUERY *)
21 val _TailableCursor : int
22 val _SlaveOk : int
23 val _OplogReplay : int
24 val _NoCursorTimeout : int
25 val _AwaitData : int
26 val _Exhaust : int
27 val _Partial : int
28
29 (* OP_DELETE *)
30 val _SingleRemove : int
31
32 (* OP_REPLY *)
33 val _CursorNotFound : int
34 val _QueryFailure : int
35 val _ShardConfigStale : int
36 val _AwaitCapable : int
37
38 type mongo_buf = Bson.buf
39
40 val add_bson : mongo_buf -> Bson.buf -> unit
41 val get : mongo_buf -> string
42 val export : mongo_buf -> string * int
b4861d3 @nrs135 [feature] stdlib: Implemented import and copy in Mongo.
nrs135 authored
43 val import : string -> mongo_buf
44 val copy : mongo_buf -> mongo_buf
86efce2 @nrs135 [feature] stdlib: Added send_with_error, send command, piggyback get…
nrs135 authored
45 val concat : mongo_buf -> mongo_buf -> mongo_buf
46 val append : mongo_buf -> mongo_buf -> unit
bc98b99 @nrs135 [feature] stdlib: Added socket pool, fixed major problem with reconn…
nrs135 authored
47 val length : mongo_buf -> int
48 val clip : mongo_buf -> int -> unit
b2c8070 @nrs135 [feature] mongo: New files for mongo API.
nrs135 authored
49 val set_header_len : mongo_buf -> int -> unit
50 val set_header : mongo_buf -> int32 -> int -> int -> unit
2cc8f8d @nrs135 [feature] stdlib: Added buffer reuse to Mongo.
nrs135 authored
51 val get_buf : ?hint:int -> unit -> Buf.t
52 val free_buf : Buf.t -> unit
b2c8070 @nrs135 [feature] mongo: New files for mongo API.
nrs135 authored
53 val create : int -> mongo_buf
54 val init : ?hint:int -> int -> int32 -> int -> int -> mongo_buf
55 val clear : mongo_buf -> unit
56 val reset : mongo_buf -> unit
2cc8f8d @nrs135 [feature] stdlib: Added buffer reuse to Mongo.
nrs135 authored
57 val free : mongo_buf -> unit
b2c8070 @nrs135 [feature] mongo: New files for mongo API.
nrs135 authored
58 val start_insert : mongo_buf -> int32 -> int -> string -> unit
59 val start_update : mongo_buf -> int32 -> int -> string -> unit
60 val start_query : mongo_buf -> int32 -> int -> string -> int -> int -> unit
d292986 @nrs135 [feature] stdlib: Added slaveok mode to MongoDB driver.
nrs135 authored
61 val set_query_flags : mongo_buf -> int -> unit
62 val get_opCode : mongo_buf -> int
b2c8070 @nrs135 [feature] mongo: New files for mongo API.
nrs135 authored
63 val start_getmore : mongo_buf -> int32 -> string -> int -> int64 -> unit
64 val start_delete : mongo_buf -> int32 -> int -> string -> unit
65 val start_kill_cursors : mongo_buf -> int32 -> int64 list -> unit
66 val start_msg : mongo_buf -> int32 -> string -> unit
67 val bson_init : mongo_buf -> unit
68 val bson_finish : mongo_buf -> unit
69 val finish : mongo_buf -> unit
940c5b0 @nrs135 [feature] libbase: Added reply parser to Mongo.
nrs135 authored
70
71 val reply_messageLength : (Buf.buf * int * int) -> int
72 val reply_requestId : (Buf.buf * int * int) -> int
73 val reply_responseTo : (Buf.buf * int * int) -> int
74 val reply_opCode : (Buf.buf * int * int) -> int
75 val reply_responseFlags : (Buf.buf * int * int) -> int
76 val reply_cursorID : (Buf.buf * int * int) -> int64
77 val reply_startingFrom : (Buf.buf * int * int) -> int
78 val reply_numberReturned : (Buf.buf * int * int) -> int
79 val reply_document_pos : (Buf.buf * int * int) -> int -> (int * int) option
d0d36b7 @nrs135 [feature] stdlib: Added logging functions to low-level mongo driver …
nrs135 authored
80
81 val string_of_message_buf : Buf.buf -> string
82 val string_of_message_str : string -> string
83 val string_of_message_reply : Buf.buf * int * int -> string
959a59f @nrs135 [feature] stdlib: Enabled requestId checking for MongoDriver.send_wi…
nrs135 authored
84
85 val mongo_buf_requestId : mongo_buf -> int
bc98b99 @nrs135 [feature] stdlib: Added socket pool, fixed major problem with reconn…
nrs135 authored
86 val mongo_buf_refresh_requestId : mongo_buf -> int32 -> unit
959a59f @nrs135 [feature] stdlib: Enabled requestId checking for MongoDriver.send_wi…
nrs135 authored
87 val mongo_buf_responseTo : mongo_buf -> int
Something went wrong with that request. Please try again.