1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207420842094210421142124213421442154216421742184219422042214222422342244225422642274228422942304231423242334234423542364237423842394240424142424243424442454246424742484249425042514252425342544255425642574258425942604261426242634264426542664267426842694270427142724273427442754276427742784279428042814282428342844285428642874288428942904291429242934294429542964297429842994300430143024303430443054306430743084309431043114312431343144315431643174318431943204321432243234324432543264327432843294330433143324333433443354336433743384339434043414342434343444345434643474348434943504351435243534354435543564357435843594360436143624363436443654366436743684369437043714372437343744375437643774378437943804381438243834384438543864387438843894390439143924393439443954396439743984399440044014402440344044405440644074408440944104411441244134414441544164417441844194420442144224423442444254426442744284429443044314432443344344435443644374438443944404441444244434444444544464447444844494450445144524453445444554456445744584459446044614462446344644465446644674468446944704471447244734474447544764477447844794480448144824483448444854486448744884489449044914492449344944495449644974498449945004501450245034504450545064507450845094510451145124513451445154516451745184519452045214522452345244525452645274528452945304531453245334534453545364537453845394540454145424543454445454546454745484549455045514552455345544555455645574558455945604561456245634564456545664567456845694570457145724573457445754576457745784579458045814582458345844585458645874588458945904591459245934594459545964597459845994600460146024603460446054606460746084609461046114612461346144615461646174618461946204621462246234624462546264627462846294630463146324633463446354636463746384639464046414642464346444645464646474648464946504651465246534654465546564657465846594660466146624663466446654666466746684669467046714672467346744675467646774678467946804681468246834684468546864687468846894690469146924693469446954696469746984699470047014702470347044705470647074708470947104711471247134714471547164717471847194720472147224723472447254726472747284729473047314732473347344735473647374738473947404741474247434744474547464747474847494750475147524753475447554756475747584759476047614762476347644765476647674768476947704771477247734774477547764777477847794780478147824783478447854786478747884789479047914792479347944795479647974798479948004801480248034804480548064807480848094810481148124813481448154816481748184819482048214822482348244825482648274828482948304831483248334834483548364837483848394840484148424843484448454846484748484849485048514852485348544855485648574858485948604861486248634864486548664867486848694870487148724873487448754876487748784879488048814882488348844885488648874888488948904891489248934894489548964897489848994900490149024903490449054906490749084909491049114912491349144915491649174918491949204921492249234924492549264927492849294930493149324933493449354936493749384939494049414942494349444945494649474948494949504951495249534954495549564957495849594960496149624963496449654966496749684969497049714972497349744975497649774978497949804981498249834984498549864987498849894990499149924993499449954996499749984999500050015002500350045005500650075008500950105011501250135014501550165017501850195020502150225023502450255026502750285029503050315032503350345035503650375038503950405041504250435044504550465047504850495050505150525053505450555056505750585059506050615062506350645065506650675068506950705071507250735074507550765077507850795080508150825083508450855086508750885089509050915092509350945095509650975098509951005101510251035104510551065107510851095110511151125113511451155116511751185119512051215122512351245125512651275128512951305131513251335134513551365137513851395140514151425143514451455146514751485149515051515152515351545155515651575158515951605161516251635164516551665167516851695170517151725173517451755176517751785179518051815182518351845185518651875188518951905191519251935194519551965197519851995200520152025203520452055206520752085209521052115212521352145215521652175218521952205221522252235224522552265227522852295230523152325233523452355236523752385239524052415242524352445245524652475248524952505251525252535254525552565257525852595260526152625263526452655266526752685269527052715272527352745275527652775278527952805281528252835284528552865287528852895290529152925293529452955296529752985299530053015302530353045305530653075308530953105311531253135314531553165317531853195320532153225323532453255326532753285329533053315332533353345335533653375338533953405341534253435344534553465347534853495350535153525353535453555356535753585359536053615362536353645365536653675368536953705371537253735374537553765377537853795380538153825383538453855386538753885389539053915392539353945395539653975398539954005401540254035404540554065407540854095410541154125413541454155416541754185419542054215422542354245425542654275428542954305431543254335434543554365437543854395440544154425443544454455446544754485449545054515452545354545455545654575458545954605461546254635464546554665467546854695470547154725473547454755476547754785479548054815482548354845485548654875488548954905491549254935494549554965497549854995500550155025503550455055506550755085509551055115512551355145515551655175518551955205521552255235524552555265527552855295530553155325533553455355536553755385539554055415542554355445545554655475548554955505551555255535554555555565557555855595560556155625563556455655566556755685569557055715572557355745575557655775578557955805581558255835584558555865587558855895590559155925593559455955596559755985599560056015602560356045605560656075608560956105611561256135614561556165617561856195620562156225623562456255626562756285629563056315632563356345635563656375638563956405641564256435644564556465647564856495650565156525653565456555656565756585659566056615662566356645665566656675668566956705671567256735674567556765677567856795680568156825683568456855686568756885689569056915692569356945695569656975698569957005701570257035704570557065707570857095710571157125713571457155716571757185719572057215722572357245725572657275728572957305731573257335734573557365737573857395740574157425743574457455746574757485749575057515752575357545755575657575758575957605761576257635764576557665767576857695770577157725773577457755776577757785779578057815782578357845785578657875788578957905791579257935794579557965797579857995800580158025803580458055806580758085809581058115812581358145815581658175818581958205821582258235824582558265827582858295830583158325833583458355836583758385839584058415842584358445845584658475848584958505851585258535854585558565857585858595860586158625863586458655866586758685869587058715872587358745875587658775878587958805881588258835884588558865887588858895890589158925893589458955896589758985899590059015902590359045905590659075908590959105911591259135914591559165917591859195920592159225923592459255926592759285929593059315932593359345935593659375938593959405941594259435944594559465947594859495950595159525953595459555956595759585959596059615962596359645965596659675968596959705971597259735974597559765977597859795980598159825983598459855986598759885989599059915992599359945995599659975998599960006001600260036004600560066007600860096010601160126013601460156016601760186019602060216022602360246025602660276028602960306031603260336034603560366037603860396040604160426043604460456046604760486049605060516052605360546055605660576058605960606061606260636064606560666067606860696070607160726073607460756076607760786079608060816082608360846085608660876088608960906091609260936094609560966097609860996100610161026103610461056106610761086109611061116112611361146115611661176118611961206121612261236124612561266127612861296130613161326133613461356136613761386139614061416142614361446145614661476148614961506151615261536154615561566157615861596160616161626163616461656166616761686169617061716172617361746175617661776178617961806181618261836184618561866187618861896190619161926193619461956196619761986199620062016202620362046205620662076208620962106211621262136214621562166217621862196220622162226223622462256226622762286229623062316232623362346235623662376238623962406241624262436244624562466247624862496250625162526253625462556256625762586259626062616262626362646265626662676268626962706271627262736274627562766277627862796280628162826283628462856286628762886289629062916292629362946295629662976298629963006301630263036304630563066307630863096310631163126313631463156316631763186319632063216322632363246325632663276328632963306331633263336334633563366337633863396340634163426343634463456346634763486349635063516352635363546355635663576358635963606361636263636364636563666367636863696370637163726373637463756376637763786379638063816382638363846385638663876388638963906391639263936394639563966397639863996400640164026403640464056406640764086409641064116412641364146415641664176418641964206421642264236424642564266427642864296430643164326433643464356436643764386439644064416442644364446445644664476448644964506451645264536454645564566457645864596460646164626463646464656466646764686469647064716472647364746475647664776478647964806481648264836484648564866487648864896490649164926493649464956496649764986499650065016502650365046505650665076508650965106511651265136514651565166517651865196520652165226523652465256526652765286529653065316532653365346535653665376538653965406541654265436544654565466547654865496550655165526553655465556556655765586559656065616562656365646565656665676568656965706571657265736574657565766577657865796580658165826583658465856586658765886589659065916592659365946595659665976598659966006601660266036604660566066607660866096610661166126613661466156616661766186619662066216622662366246625662666276628662966306631663266336634663566366637663866396640664166426643664466456646664766486649665066516652665366546655665666576658665966606661666266636664666566666667666866696670667166726673667466756676667766786679668066816682668366846685668666876688668966906691669266936694669566966697669866996700670167026703670467056706670767086709671067116712671367146715671667176718671967206721672267236724672567266727672867296730673167326733673467356736673767386739674067416742674367446745674667476748674967506751675267536754675567566757675867596760676167626763676467656766676767686769677067716772677367746775677667776778677967806781678267836784678567866787678867896790679167926793679467956796679767986799680068016802680368046805680668076808680968106811681268136814681568166817681868196820682168226823682468256826682768286829683068316832683368346835683668376838683968406841684268436844684568466847684868496850685168526853685468556856685768586859686068616862686368646865686668676868686968706871687268736874687568766877687868796880688168826883688468856886688768886889689068916892689368946895689668976898689969006901690269036904690569066907690869096910691169126913691469156916691769186919692069216922692369246925692669276928692969306931693269336934693569366937693869396940694169426943694469456946694769486949695069516952695369546955695669576958695969606961696269636964696569666967696869696970697169726973697469756976697769786979698069816982698369846985698669876988698969906991699269936994699569966997699869997000700170027003700470057006700770087009701070117012701370147015701670177018701970207021702270237024702570267027702870297030703170327033703470357036703770387039704070417042704370447045704670477048704970507051705270537054705570567057705870597060706170627063706470657066706770687069707070717072707370747075707670777078707970807081708270837084708570867087708870897090709170927093709470957096709770987099710071017102710371047105710671077108710971107111711271137114711571167117711871197120712171227123712471257126712771287129713071317132713371347135713671377138713971407141714271437144714571467147714871497150715171527153715471557156715771587159716071617162716371647165716671677168716971707171717271737174717571767177717871797180718171827183718471857186718771887189719071917192719371947195719671977198719972007201720272037204720572067207720872097210721172127213721472157216721772187219722072217222722372247225722672277228722972307231723272337234723572367237723872397240724172427243724472457246724772487249725072517252725372547255725672577258725972607261726272637264726572667267726872697270727172727273727472757276727772787279728072817282728372847285728672877288728972907291729272937294729572967297729872997300730173027303730473057306730773087309731073117312731373147315731673177318731973207321732273237324732573267327732873297330733173327333733473357336733773387339734073417342734373447345734673477348734973507351735273537354735573567357735873597360736173627363736473657366736773687369737073717372737373747375737673777378737973807381738273837384738573867387738873897390739173927393739473957396739773987399740074017402740374047405740674077408740974107411741274137414741574167417741874197420742174227423742474257426742774287429743074317432743374347435743674377438743974407441744274437444744574467447744874497450745174527453745474557456745774587459746074617462746374647465746674677468746974707471747274737474747574767477747874797480748174827483748474857486748774887489 |
- import type { DeserializeOptions , ObjectIdLike , SerializeOptions } from 'bson';
- import { Binary , BSON , BSONRegExp , BSONSymbol , BSONType , Code , DBRef , Decimal128 , deserialize , Document , Double , Int32 , Long , MaxKey , MinKey , ObjectId , serialize , Timestamp , UUID } from 'bson';
- import type { SrvRecord } from 'dns';
- import { EventEmitter } from 'events';
- import type { Socket , TcpNetConnectOpts } from 'net';
- import { Readable , Writable } from 'stream';
- import type { ConnectionOptions as ConnectionOptions_2 , TLSSocket , TLSSocketOptions } from 'tls';
- export declare abstract class AbstractCursor<TSchema = any, CursorEvents extends AbstractCursorEvents = AbstractCursorEvents> extends TypedEventEmitter<CursorEvents> {
-
-
-
-
-
-
-
-
-
-
-
-
- static readonly CLOSE: "close";
-
- get id(): Long | undefined;
-
-
-
- get namespace(): MongoDBNamespace;
- get readPreference(): ReadPreference;
- get readConcern(): ReadConcern | undefined;
-
-
-
- get closed(): boolean;
- get killed(): boolean;
- get loadBalanced(): boolean;
-
- bufferedCount(): number;
-
- readBufferedDocuments(number?: number): TSchema[];
- [Symbol.asyncIterator](): AsyncGenerator<TSchema, void, void>;
- stream(options?: CursorStreamOptions): Readable & AsyncIterable<TSchema>;
- hasNext(): Promise<boolean>;
-
- next(): Promise<TSchema | null>;
-
- tryNext(): Promise<TSchema | null>;
-
- forEach(iterator: (doc: TSchema) => boolean | void): Promise<void>;
- close(): Promise<void>;
-
- toArray(): Promise<TSchema[]>;
-
- addCursorFlag(flag: CursorFlag, value: boolean): this;
-
- map<T = any>(transform: (doc: TSchema) => T): AbstractCursor<T>;
- /**
- * Set the ReadPreference for the cursor.
- *
- * @param readPreference - The new read preference for the cursor.
- */
- withReadPreference(readPreference: ReadPreferenceLike): this;
- /**
- * Set the ReadPreference for the cursor.
- *
- * @param readPreference - The new read preference for the cursor.
- */
- withReadConcern(readConcern: ReadConcernLike): this;
- /**
- * Set a maxTimeMS on the cursor query, allowing for hard timeout limits on queries (Only supported on MongoDB 2.6 or higher)
- *
- * @param value - Number of milliseconds to wait before aborting the query.
- */
- maxTimeMS(value: number): this;
- /**
- * Set the batch size for the cursor.
- *
- * @param value - The number of documents to return per batch. See {@link https://www.mongodb.com/docs/manual/reference/command/find/|find command documentation}.
- */
- batchSize(value: number): this;
- /**
- * Rewind this cursor to its uninitialized state. Any options that are present on the cursor will
- * remain in effect. Iterating this cursor will cause new queries to be sent to the server, even
- * if the resultant data has already been retrieved by this cursor.
- */
- rewind(): void;
- /**
- * Returns a new uninitialized copy of this cursor, with options matching those that have been set on the current instance
- */
- abstract clone(): AbstractCursor<TSchema>;
- /* Excluded from this release type: _initialize */
- /* Excluded from this release type: getMore */
- /* Excluded from this release type: [kInit] */
- }
- /** @public */
- export declare type AbstractCursorEvents = {
- [AbstractCursor.CLOSE](): void;
- };
- /** @public */
- export declare interface AbstractCursorOptions extends BSONSerializeOptions {
- session?: ClientSession;
- readPreference?: ReadPreferenceLike;
- readConcern?: ReadConcernLike;
- /**
- * Specifies the number of documents to return in each response from MongoDB
- */
- batchSize?: number;
- /**
- * When applicable `maxTimeMS` controls the amount of time the initial command
- * that constructs a cursor should take. (ex. find, aggregate, listCollections)
- */
- maxTimeMS?: number;
- /**
- * When applicable `maxAwaitTimeMS` controls the amount of time subsequent getMores
- * that a cursor uses to fetch more data should take. (ex. cursor.next())
- */
- maxAwaitTimeMS?: number;
- /**
- * Comment to apply to the operation.
- *
- * In server versions pre-4.4, 'comment' must be string. A server
- * error will be thrown if any other type is provided.
- *
- * In server versions 4.4 and above, 'comment' can be any valid BSON type.
- */
- comment?: unknown;
- /**
- * By default, MongoDB will automatically close a cursor when the
- * client has exhausted all results in the cursor. However, for [capped collections](https:
- * you may use a Tailable Cursor that remains open after the client exhausts
- * the results in the initial cursor.
- */
- tailable?: boolean;
-
- awaitData?: boolean;
- noCursorTimeout?: boolean;
- }
- export declare type AcceptedFields<TSchema, FieldType, AssignableType> = {
- readonly [key in KeysOfAType<TSchema, FieldType>]?: AssignableType;
- };
- export declare type AddToSetOperators<Type> = {
- $each?: Array<Flatten<Type>>;
- };
- export declare class Admin {
-
-
-
- command(command: Document, options?: RunCommandOptions): Promise<Document>;
-
- buildInfo(options?: CommandOperationOptions): Promise<Document>;
-
- serverInfo(options?: CommandOperationOptions): Promise<Document>;
-
- serverStatus(options?: CommandOperationOptions): Promise<Document>;
-
- ping(options?: CommandOperationOptions): Promise<Document>;
-
- removeUser(username: string, options?: RemoveUserOptions): Promise<boolean>;
-
- validateCollection(collectionName: string, options?: ValidateCollectionOptions): Promise<Document>;
-
- listDatabases(options?: ListDatabasesOptions): Promise<ListDatabasesResult>;
-
- replSetGetStatus(options?: CommandOperationOptions): Promise<Document>;
- }
- export declare interface AggregateOptions extends CommandOperationOptions {
-
- allowDiskUse?: boolean;
-
- batchSize?: number;
-
- bypassDocumentValidation?: boolean;
-
- cursor?: Document;
-
- maxTimeMS?: number;
-
- maxAwaitTimeMS?: number;
-
- collation?: CollationOptions;
-
- hint?: Hint;
-
- let?: Document;
- out?: string;
- }
- export declare class AggregationCursor<TSchema = any> extends AbstractCursor<TSchema> {
-
-
-
- get pipeline(): Document[];
- clone(): AggregationCursor<TSchema>;
- map<T>(transform: (doc: TSchema) => T): AggregationCursor<T>;
-
-
- explain(verbosity?: ExplainVerbosityLike): Promise<Document>;
-
- group<T = TSchema>($group: Document): AggregationCursor<T>;
-
- limit($limit: number): this;
-
- match($match: Document): this;
-
- out($out: {
- db: string;
- coll: string;
- } | string): this;
-
- project<T extends Document = Document>($project: Document): AggregationCursor<T>;
-
- lookup($lookup: Document): this;
-
- redact($redact: Document): this;
-
- skip($skip: number): this;
-
- sort($sort: Sort): this;
-
- unwind($unwind: Document | string): this;
-
- geoNear($geoNear: Document): this;
- }
- export declare interface AggregationCursorOptions extends AbstractCursorOptions, AggregateOptions {
- }
- export declare type AlternativeType<T> = T extends ReadonlyArray<infer U> ? T | RegExpOrString<U> : RegExpOrString<T>;
- export declare type AnyBulkWriteOperation<TSchema extends Document = Document> = {
- insertOne: InsertOneModel<TSchema>;
- } | {
- replaceOne: ReplaceOneModel<TSchema>;
- } | {
- updateOne: UpdateOneModel<TSchema>;
- } | {
- updateMany: UpdateManyModel<TSchema>;
- } | {
- deleteOne: DeleteOneModel<TSchema>;
- } | {
- deleteMany: DeleteManyModel<TSchema>;
- };
- export declare type AnyError = MongoError | Error;
- export declare type ArrayElement<Type> = Type extends ReadonlyArray<infer Item> ? Item : never;
- export declare type ArrayOperator<Type> = {
- $each?: Array<Flatten<Type>>;
- $slice?: number;
- $position?: number;
- $sort?: Sort;
- };
- export declare interface Auth {
-
- username?: string;
-
- password?: string;
- }
- export declare const AuthMechanism: Readonly<{
- readonly MONGODB_AWS: "MONGODB-AWS";
- readonly MONGODB_CR: "MONGODB-CR";
- readonly MONGODB_DEFAULT: "DEFAULT";
- readonly MONGODB_GSSAPI: "GSSAPI";
- readonly MONGODB_PLAIN: "PLAIN";
- readonly MONGODB_SCRAM_SHA1: "SCRAM-SHA-1";
- readonly MONGODB_SCRAM_SHA256: "SCRAM-SHA-256";
- readonly MONGODB_X509: "MONGODB-X509";
-
- readonly MONGODB_OIDC: "MONGODB-OIDC";
- }>;
- export declare type AuthMechanism = (typeof AuthMechanism)[keyof typeof AuthMechanism];
- export declare interface AuthMechanismProperties extends Document {
- SERVICE_HOST?: string;
- SERVICE_NAME?: string;
- SERVICE_REALM?: string;
- CANONICALIZE_HOST_NAME?: GSSAPICanonicalizationValue;
- AWS_SESSION_TOKEN?: string;
-
- REQUEST_TOKEN_CALLBACK?: OIDCRequestFunction;
-
- REFRESH_TOKEN_CALLBACK?: OIDCRefreshFunction;
-
- PROVIDER_NAME?: 'aws' | 'azure';
-
- ALLOWED_HOSTS?: string[];
-
- TOKEN_AUDIENCE?: string;
- }
- export declare type AutoEncryptionExtraOptions = NonNullable<AutoEncryptionOptions['extraOptions']>;
- export declare const AutoEncryptionLoggerLevel: Readonly<{
- readonly FatalError: 0;
- readonly Error: 1;
- readonly Warning: 2;
- readonly Info: 3;
- readonly Trace: 4;
- }>;
- export declare type AutoEncryptionLoggerLevel = (typeof AutoEncryptionLoggerLevel)[keyof typeof AutoEncryptionLoggerLevel];
- export declare interface AutoEncryptionOptions {
-
-
- keyVaultClient?: MongoClient;
-
- keyVaultNamespace?: string;
-
- kmsProviders?: {
-
- aws?: {
-
- accessKeyId: string;
-
- secretAccessKey: string;
-
- sessionToken?: string;
- } | Record<string, never>;
-
- local?: {
-
- key: Buffer | string;
- };
-
- azure?: {
-
- tenantId: string;
-
- clientId: string;
-
- clientSecret: string;
-
- identityPlatformEndpoint?: string | undefined;
- } | {
-
- accessToken: string;
- } | Record<string, never>;
-
- gcp?: {
-
- email: string;
-
- privateKey: string | Buffer;
-
- endpoint?: string | undefined;
- } | {
-
- accessToken: string;
- } | Record<string, never>;
-
- kmip?: {
-
- endpoint?: string;
- };
- };
-
- schemaMap?: Document;
-
- encryptedFieldsMap?: Document;
-
- bypassAutoEncryption?: boolean;
-
- bypassQueryAnalysis?: boolean;
- options?: {
-
- logger?: (level: AutoEncryptionLoggerLevel, message: string) => void;
- };
- extraOptions?: {
-
- mongocryptdURI?: string;
-
- mongocryptdBypassSpawn?: boolean;
-
- mongocryptdSpawnPath?: string;
-
- mongocryptdSpawnArgs?: string[];
-
- cryptSharedLibPath?: string;
-
- cryptSharedLibRequired?: boolean;
-
- };
- proxyOptions?: ProxyOptions;
-
- tlsOptions?: CSFLEKMSTlsOptions;
- }
- export declare interface AWSEncryptionKeyOptions {
-
- region: string;
-
- key: string;
-
- endpoint?: string | undefined;
- }
- export declare interface AzureEncryptionKeyOptions {
-
- keyName: string;
-
- keyVaultEndpoint: string;
-
- keyVersion?: string | undefined;
- }
- export declare class Batch<T = Document> {
- originalZeroIndex: number;
- currentIndex: number;
- originalIndexes: number[];
- batchType: BatchType;
- operations: T[];
- size: number;
- sizeBytes: number;
- constructor(batchType: BatchType, originalZeroIndex: number);
- }
- export declare const BatchType: Readonly<{
- readonly INSERT: 1;
- readonly UPDATE: 2;
- readonly DELETE: 3;
- }>;
- export declare type BatchType = (typeof BatchType)[keyof typeof BatchType];
- export { Binary }
- export declare type BitwiseFilter = number | Binary | ReadonlyArray<number>;
- export { BSON }
- export { BSONRegExp }
- export declare interface BSONSerializeOptions extends Omit<SerializeOptions, 'index'>, Omit<DeserializeOptions, 'evalFunctions' | 'cacheFunctions' | 'cacheFunctionsCrc32' | 'allowObjectSmallerThanBufferSize' | 'index' | 'validation'> {
-
- raw?: boolean;
-
- enableUtf8Validation?: boolean;
- }
- export { BSONSymbol }
- export { BSONType }
- export declare type BSONTypeAlias = keyof typeof BSONType;
- export declare abstract class BulkOperationBase {
- isOrdered: boolean;
-
- operationId?: number;
-
-
- insert(document: Document): BulkOperationBase;
-
- find(selector: Document): FindOperators;
-
- raw(op: AnyBulkWriteOperation): this;
- get bsonOptions(): BSONSerializeOptions;
- get writeConcern(): WriteConcern | undefined;
- get batches(): Batch[];
- execute(options?: BulkWriteOptions): Promise<BulkWriteResult>;
-
- abstract addToOperationsList(batchType: BatchType, document: Document | UpdateStatement | DeleteStatement): this;
- }
- export declare interface BulkWriteOperationError {
- index: number;
- code: number;
- errmsg: string;
- errInfo: Document;
- op: Document | UpdateStatement | DeleteStatement;
- }
- export declare interface BulkWriteOptions extends CommandOperationOptions {
-
- bypassDocumentValidation?: boolean;
-
- ordered?: boolean;
-
- forceServerObjectId?: boolean;
-
- let?: Document;
- }
- export declare class BulkWriteResult {
- private readonly result;
-
- readonly insertedCount: number;
-
- readonly matchedCount: number;
-
- readonly modifiedCount: number;
-
- readonly deletedCount: number;
-
- readonly upsertedCount: number;
-
- readonly upsertedIds: {
- [key: number]: any;
- };
-
- readonly insertedIds: {
- [key: number]: any;
- };
- private static generateIdMap;
-
-
- get ok(): number;
-
-
- getUpsertedIdAt(index: number): Document | undefined;
-
- getRawResponse(): Document;
-
- hasWriteErrors(): boolean;
-
- getWriteErrorCount(): number;
-
- getWriteErrorAt(index: number): WriteError | undefined;
-
- getWriteErrors(): WriteError[];
-
- getWriteConcernError(): WriteConcernError | undefined;
- toString(): string;
- isOk(): boolean;
- }
- export declare type Callback<T = any> = (error?: AnyError, result?: T) => void;
- export declare class CancellationToken extends TypedEventEmitter<{
- cancel(): void;
- }> {
- }
- export declare class ChangeStream<TSchema extends Document = Document, TChange extends Document = ChangeStreamDocument<TSchema>> extends TypedEventEmitter<ChangeStreamEvents<TSchema, TChange>> {
- pipeline: Document[];
-
- options: ChangeStreamOptions & {
- writeConcern?: never;
- };
- parent: MongoClient | Db | Collection;
- namespace: MongoDBNamespace;
- type: symbol;
-
- streamOptions?: CursorStreamOptions;
-
-
-
-
- static readonly RESPONSE: "response";
-
- static readonly MORE: "more";
-
- static readonly INIT: "init";
-
- static readonly CLOSE: "close";
-
- static readonly CHANGE: "change";
-
- static readonly END: "end";
-
- static readonly ERROR: "error";
-
- static readonly RESUME_TOKEN_CHANGED: "resumeTokenChanged";
-
-
-
- get resumeToken(): ResumeToken;
-
- hasNext(): Promise<boolean>;
-
- next(): Promise<TChange>;
-
- tryNext(): Promise<TChange | null>;
- [Symbol.asyncIterator](): AsyncGenerator<TChange, void, void>;
-
- get closed(): boolean;
-
- close(): Promise<void>;
-
- stream(options?: CursorStreamOptions): Readable & AsyncIterable<TChange>;
-
-
-
-
-
-
-
-
-
- }
- export declare interface ChangeStreamCollModDocument extends ChangeStreamDocumentCommon, ChangeStreamDocumentCollectionUUID {
-
- operationType: 'modify';
- }
- export declare interface ChangeStreamCreateDocument extends ChangeStreamDocumentCommon, ChangeStreamDocumentCollectionUUID {
-
- operationType: 'create';
- }
- export declare interface ChangeStreamCreateIndexDocument extends ChangeStreamDocumentCommon, ChangeStreamDocumentCollectionUUID, ChangeStreamDocumentOperationDescription {
-
- operationType: 'createIndexes';
- }
- export declare interface ChangeStreamDeleteDocument<TSchema extends Document = Document> extends ChangeStreamDocumentCommon, ChangeStreamDocumentKey<TSchema>, ChangeStreamDocumentCollectionUUID {
-
- operationType: 'delete';
-
- ns: ChangeStreamNameSpace;
-
- fullDocumentBeforeChange?: TSchema;
- }
- export declare type ChangeStreamDocument<TSchema extends Document = Document> = ChangeStreamInsertDocument<TSchema> | ChangeStreamUpdateDocument<TSchema> | ChangeStreamReplaceDocument<TSchema> | ChangeStreamDeleteDocument<TSchema> | ChangeStreamDropDocument | ChangeStreamRenameDocument | ChangeStreamDropDatabaseDocument | ChangeStreamInvalidateDocument | ChangeStreamCreateIndexDocument | ChangeStreamCreateDocument | ChangeStreamCollModDocument | ChangeStreamDropIndexDocument | ChangeStreamShardCollectionDocument | ChangeStreamReshardCollectionDocument | ChangeStreamRefineCollectionShardKeyDocument;
- export declare interface ChangeStreamDocumentCollectionUUID {
-
- collectionUUID: Binary;
- }
- export declare interface ChangeStreamDocumentCommon {
-
- _id: ResumeToken;
-
- clusterTime?: Timestamp;
-
- txnNumber?: number;
-
- lsid?: ServerSessionId;
-
- splitEvent?: ChangeStreamSplitEvent;
- }
- export declare interface ChangeStreamDocumentKey<TSchema extends Document = Document> {
-
- documentKey: {
- _id: InferIdType<TSchema>;
- [shardKey: string]: any;
- };
- }
- export declare interface ChangeStreamDocumentOperationDescription {
-
- operationDescription?: Document;
- }
- export declare interface ChangeStreamDropDatabaseDocument extends ChangeStreamDocumentCommon {
-
- operationType: 'dropDatabase';
-
- ns: {
- db: string;
- };
- }
- export declare interface ChangeStreamDropDocument extends ChangeStreamDocumentCommon, ChangeStreamDocumentCollectionUUID {
-
- operationType: 'drop';
-
- ns: ChangeStreamNameSpace;
- }
- export declare interface ChangeStreamDropIndexDocument extends ChangeStreamDocumentCommon, ChangeStreamDocumentCollectionUUID, ChangeStreamDocumentOperationDescription {
-
- operationType: 'dropIndexes';
- }
- export declare type ChangeStreamEvents<TSchema extends Document = Document, TChange extends Document = ChangeStreamDocument<TSchema>> = {
- resumeTokenChanged(token: ResumeToken): void;
- init(response: any): void;
- more(response?: any): void;
- response(): void;
- end(): void;
- error(error: Error): void;
- change(change: TChange): void;
- } & AbstractCursorEvents;
- export declare interface ChangeStreamInsertDocument<TSchema extends Document = Document> extends ChangeStreamDocumentCommon, ChangeStreamDocumentKey<TSchema>, ChangeStreamDocumentCollectionUUID {
-
- operationType: 'insert';
-
- fullDocument: TSchema;
-
- ns: ChangeStreamNameSpace;
- }
- export declare interface ChangeStreamInvalidateDocument extends ChangeStreamDocumentCommon {
-
- operationType: 'invalidate';
- }
- export declare interface ChangeStreamNameSpace {
- db: string;
- coll: string;
- }
- export declare interface ChangeStreamOptions extends Omit<AggregateOptions, 'writeConcern'> {
-
- fullDocument?: string;
-
- fullDocumentBeforeChange?: string;
-
- maxAwaitTimeMS?: number;
-
- resumeAfter?: ResumeToken;
-
- startAfter?: ResumeToken;
-
- startAtOperationTime?: OperationTime;
-
- batchSize?: number;
-
- showExpandedEvents?: boolean;
- }
- export declare interface ChangeStreamRefineCollectionShardKeyDocument extends ChangeStreamDocumentCommon, ChangeStreamDocumentCollectionUUID, ChangeStreamDocumentOperationDescription {
-
- operationType: 'refineCollectionShardKey';
- }
- export declare interface ChangeStreamRenameDocument extends ChangeStreamDocumentCommon, ChangeStreamDocumentCollectionUUID {
-
- operationType: 'rename';
-
- to: {
- db: string;
- coll: string;
- };
-
- ns: ChangeStreamNameSpace;
- }
- export declare interface ChangeStreamReplaceDocument<TSchema extends Document = Document> extends ChangeStreamDocumentCommon, ChangeStreamDocumentKey<TSchema> {
-
- operationType: 'replace';
-
- fullDocument: TSchema;
-
- ns: ChangeStreamNameSpace;
-
- fullDocumentBeforeChange?: TSchema;
- }
- export declare interface ChangeStreamReshardCollectionDocument extends ChangeStreamDocumentCommon, ChangeStreamDocumentCollectionUUID, ChangeStreamDocumentOperationDescription {
-
- operationType: 'reshardCollection';
- }
- export declare interface ChangeStreamShardCollectionDocument extends ChangeStreamDocumentCommon, ChangeStreamDocumentCollectionUUID, ChangeStreamDocumentOperationDescription {
-
- operationType: 'shardCollection';
- }
- export declare interface ChangeStreamSplitEvent {
-
- fragment: number;
-
- of: number;
- }
- export declare interface ChangeStreamUpdateDocument<TSchema extends Document = Document> extends ChangeStreamDocumentCommon, ChangeStreamDocumentKey<TSchema>, ChangeStreamDocumentCollectionUUID {
-
- operationType: 'update';
-
- fullDocument?: TSchema;
-
- updateDescription: UpdateDescription<TSchema>;
-
- ns: ChangeStreamNameSpace;
-
- fullDocumentBeforeChange?: TSchema;
- }
- export declare class ClientEncryption {
-
-
-
-
-
-
-
-
-
- constructor(client: MongoClient, options: ClientEncryptionOptions);
-
- createDataKey(provider: ClientEncryptionDataKeyProvider, options?: ClientEncryptionCreateDataKeyProviderOptions): Promise<UUID>;
-
- rewrapManyDataKey(filter: Filter<DataKey>, options: ClientEncryptionRewrapManyDataKeyProviderOptions): Promise<{
- bulkWriteResult?: BulkWriteResult;
- }>;
-
- deleteKey(_id: Binary): Promise<DeleteResult>;
-
- getKeys(): FindCursor<DataKey>;
-
- getKey(_id: Binary): Promise<DataKey | null>;
-
- getKeyByAltName(keyAltName: string): Promise<WithId<DataKey> | null>;
-
- addKeyAltName(_id: Binary, keyAltName: string): Promise<WithId<DataKey> | null>;
-
- removeKeyAltName(_id: Binary, keyAltName: string): Promise<WithId<DataKey> | null>;
-
- createEncryptedCollection<TSchema extends Document = Document>(db: Db, name: string, options: {
- provider: ClientEncryptionDataKeyProvider;
- createCollectionOptions: Omit<CreateCollectionOptions, 'encryptedFields'> & {
- encryptedFields: Document;
- };
- masterKey?: AWSEncryptionKeyOptions | AzureEncryptionKeyOptions | GCPEncryptionKeyOptions;
- }): Promise<{
- collection: Collection<TSchema>;
- encryptedFields: Document;
- }>;
-
- encrypt(value: unknown, options: ClientEncryptionEncryptOptions): Promise<Binary>;
-
- encryptExpression(expression: Document, options: ClientEncryptionEncryptOptions): Promise<Binary>;
-
- decrypt<T = any>(value: Binary): Promise<T>;
-
- static get libmongocryptVersion(): string;
-
- }
- export declare interface ClientEncryptionCreateDataKeyProviderOptions {
-
- masterKey?: AWSEncryptionKeyOptions | AzureEncryptionKeyOptions | GCPEncryptionKeyOptions | undefined;
-
- keyAltNames?: string[] | undefined;
-
- keyMaterial?: Buffer | Binary;
- }
- export declare type ClientEncryptionDataKeyProvider = 'aws' | 'azure' | 'gcp' | 'local' | 'kmip';
- export declare interface ClientEncryptionEncryptOptions {
-
- algorithm: 'AEAD_AES_256_CBC_HMAC_SHA_512-Deterministic' | 'AEAD_AES_256_CBC_HMAC_SHA_512-Random' | 'Indexed' | 'Unindexed' | 'RangePreview';
-
- keyId?: Binary;
-
- keyAltName?: string;
-
- contentionFactor?: bigint | number;
-
- queryType?: 'equality' | 'rangePreview';
-
- rangeOptions?: RangeOptions;
- }
- export declare interface ClientEncryptionEncryptOptions {
-
- algorithm: 'AEAD_AES_256_CBC_HMAC_SHA_512-Deterministic' | 'AEAD_AES_256_CBC_HMAC_SHA_512-Random' | 'Indexed' | 'Unindexed' | 'RangePreview';
-
- keyId?: Binary;
-
- keyAltName?: string;
-
- contentionFactor?: bigint | number;
-
- queryType?: 'equality' | 'rangePreview';
-
- rangeOptions?: RangeOptions;
- }
- export declare interface ClientEncryptionOptions {
-
- keyVaultNamespace: string;
-
- keyVaultClient?: MongoClient | undefined;
-
- kmsProviders?: KMSProviders;
-
- proxyOptions?: ProxyOptions;
-
- tlsOptions?: CSFLEKMSTlsOptions;
- }
- export declare interface ClientEncryptionRewrapManyDataKeyProviderOptions {
- provider: ClientEncryptionDataKeyProvider;
- masterKey?: AWSEncryptionKeyOptions | AzureEncryptionKeyOptions | GCPEncryptionKeyOptions | undefined;
- }
- export declare interface ClientEncryptionRewrapManyDataKeyProviderOptions {
- provider: ClientEncryptionDataKeyProvider;
- masterKey?: AWSEncryptionKeyOptions | AzureEncryptionKeyOptions | GCPEncryptionKeyOptions | undefined;
- }
- export declare interface ClientEncryptionRewrapManyDataKeyResult {
-
- bulkWriteResult?: BulkWriteResult;
- }
- export declare type ClientEncryptionTlsOptions = Pick<MongoClientOptions, 'tlsCAFile' | 'tlsCertificateKeyFile' | 'tlsCertificateKeyFilePassword'>;
- export declare interface ClientMetadata {
- driver: {
- name: string;
- version: string;
- };
- os: {
- type: string;
- name?: NodeJS.Platform;
- architecture?: string;
- version?: string;
- };
- platform: string;
- application?: {
- name: string;
- };
-
- env?: {
- name: 'aws.lambda' | 'gcp.func' | 'azure.func' | 'vercel';
- timeout_sec?: Int32;
- memory_mb?: Int32;
- region?: string;
- url?: string;
- };
- }
- export declare interface ClientMetadataOptions {
- driverInfo?: {
- name?: string;
- version?: string;
- platform?: string;
- };
- appName?: string;
- }
- export declare class ClientSession extends TypedEventEmitter<ClientSessionEvents> {
-
-
- hasEnded: boolean;
- clientOptions?: MongoOptions;
- supports: {
- causalConsistency: boolean;
- };
- clusterTime?: ClusterTime;
- operationTime?: Timestamp;
- explicit: boolean;
-
- defaultTransactionOptions: TransactionOptions;
- transaction: Transaction;
-
-
-
-
-
-
-
- get id(): ServerSessionId | undefined;
- get serverSession(): ServerSession;
-
- get snapshotEnabled(): boolean;
- get loadBalanced(): boolean;
-
-
-
- get isPinned(): boolean;
-
- endSession(options?: EndSessionOptions): Promise<void>;
-
- advanceOperationTime(operationTime: Timestamp): void;
-
- advanceClusterTime(clusterTime: ClusterTime): void;
-
- equals(session: ClientSession): boolean;
-
- incrementTransactionNumber(): void;
-
- inTransaction(): boolean;
-
- startTransaction(options?: TransactionOptions): void;
-
- commitTransaction(): Promise<void>;
-
- abortTransaction(): Promise<void>;
-
- toBSON(): never;
-
- withTransaction<T = any>(fn: WithTransactionCallback<T>, options?: TransactionOptions): Promise<T>;
- }
- export declare type ClientSessionEvents = {
- ended(session: ClientSession): void;
- };
- export declare interface ClientSessionOptions {
-
- causalConsistency?: boolean;
-
- snapshot?: boolean;
-
- defaultTransactionOptions?: TransactionOptions;
-
-
-
- }
- export declare interface CloseOptions {
- force?: boolean;
- }
- export declare interface ClusteredCollectionOptions extends Document {
- name?: string;
- key: Document;
- unique: boolean;
- }
- export declare interface ClusterTime {
- clusterTime: Timestamp;
- signature: {
- hash: Binary;
- keyId: Long;
- };
- }
- export { Code }
- export declare interface CollationOptions {
- locale: string;
- caseLevel?: boolean;
- caseFirst?: string;
- strength?: number;
- numericOrdering?: boolean;
- alternate?: string;
- maxVariable?: string;
- backwards?: boolean;
- normalization?: boolean;
- }
- export declare class Collection<TSchema extends Document = Document> {
-
-
-
-
- get dbName(): string;
-
- get collectionName(): string;
-
- get namespace(): string;
-
-
- get readConcern(): ReadConcern | undefined;
-
- get readPreference(): ReadPreference | undefined;
- get bsonOptions(): BSONSerializeOptions;
-
- get writeConcern(): WriteConcern | undefined;
-
- get hint(): Hint | undefined;
- set hint(v: Hint | undefined);
-
- insertOne(doc: OptionalUnlessRequiredId<TSchema>, options?: InsertOneOptions): Promise<InsertOneResult<TSchema>>;
-
- insertMany(docs: OptionalUnlessRequiredId<TSchema>[], options?: BulkWriteOptions): Promise<InsertManyResult<TSchema>>;
-
- bulkWrite(operations: AnyBulkWriteOperation<TSchema>[], options?: BulkWriteOptions): Promise<BulkWriteResult>;
-
- updateOne(filter: Filter<TSchema>, update: UpdateFilter<TSchema> | Partial<TSchema>, options?: UpdateOptions): Promise<UpdateResult<TSchema>>;
-
- replaceOne(filter: Filter<TSchema>, replacement: WithoutId<TSchema>, options?: ReplaceOptions): Promise<UpdateResult<TSchema> | Document>;
-
- updateMany(filter: Filter<TSchema>, update: UpdateFilter<TSchema>, options?: UpdateOptions): Promise<UpdateResult<TSchema>>;
-
- deleteOne(filter?: Filter<TSchema>, options?: DeleteOptions): Promise<DeleteResult>;
-
- deleteMany(filter?: Filter<TSchema>, options?: DeleteOptions): Promise<DeleteResult>;
-
- rename(newName: string, options?: RenameOptions): Promise<Collection>;
-
- drop(options?: DropCollectionOptions): Promise<boolean>;
-
- findOne(): Promise<WithId<TSchema> | null>;
- findOne(filter: Filter<TSchema>): Promise<WithId<TSchema> | null>;
- findOne(filter: Filter<TSchema>, options: FindOptions): Promise<WithId<TSchema> | null>;
- findOne<T = TSchema>(): Promise<T | null>;
- findOne<T = TSchema>(filter: Filter<TSchema>): Promise<T | null>;
- findOne<T = TSchema>(filter: Filter<TSchema>, options?: FindOptions): Promise<T | null>;
-
- find(): FindCursor<WithId<TSchema>>;
- find(filter: Filter<TSchema>, options?: FindOptions): FindCursor<WithId<TSchema>>;
- find<T extends Document>(filter: Filter<TSchema>, options?: FindOptions): FindCursor<T>;
-
- options(options?: OperationOptions): Promise<Document>;
-
- isCapped(options?: OperationOptions): Promise<boolean>;
-
- createIndex(indexSpec: IndexSpecification, options?: CreateIndexesOptions): Promise<string>;
-
- createIndexes(indexSpecs: IndexDescription[], options?: CreateIndexesOptions): Promise<string[]>;
-
- dropIndex(indexName: string, options?: DropIndexesOptions): Promise<Document>;
-
- dropIndexes(options?: DropIndexesOptions): Promise<boolean>;
-
- listIndexes(options?: ListIndexesOptions): ListIndexesCursor;
-
- indexExists(indexes: string | string[], options?: IndexInformationOptions): Promise<boolean>;
-
- indexInformation(options?: IndexInformationOptions): Promise<Document>;
-
- estimatedDocumentCount(options?: EstimatedDocumentCountOptions): Promise<number>;
-
- countDocuments(filter?: Document, options?: CountDocumentsOptions): Promise<number>;
-
- distinct<Key extends keyof WithId<TSchema>>(key: Key): Promise<Array<Flatten<WithId<TSchema>[Key]>>>;
- distinct<Key extends keyof WithId<TSchema>>(key: Key, filter: Filter<TSchema>): Promise<Array<Flatten<WithId<TSchema>[Key]>>>;
- distinct<Key extends keyof WithId<TSchema>>(key: Key, filter: Filter<TSchema>, options: DistinctOptions): Promise<Array<Flatten<WithId<TSchema>[Key]>>>;
- distinct(key: string): Promise<any[]>;
- distinct(key: string, filter: Filter<TSchema>): Promise<any[]>;
- distinct(key: string, filter: Filter<TSchema>, options: DistinctOptions): Promise<any[]>;
-
- indexes(options?: IndexInformationOptions): Promise<Document[]>;
-
- findOneAndDelete(filter: Filter<TSchema>, options: FindOneAndDeleteOptions & {
- includeResultMetadata: true;
- }): Promise<ModifyResult<TSchema>>;
- findOneAndDelete(filter: Filter<TSchema>, options: FindOneAndDeleteOptions & {
- includeResultMetadata: false;
- }): Promise<WithId<TSchema> | null>;
- findOneAndDelete(filter: Filter<TSchema>, options: FindOneAndDeleteOptions): Promise<WithId<TSchema> | null>;
- findOneAndDelete(filter: Filter<TSchema>): Promise<WithId<TSchema> | null>;
-
- findOneAndReplace(filter: Filter<TSchema>, replacement: WithoutId<TSchema>, options: FindOneAndReplaceOptions & {
- includeResultMetadata: true;
- }): Promise<ModifyResult<TSchema>>;
- findOneAndReplace(filter: Filter<TSchema>, replacement: WithoutId<TSchema>, options: FindOneAndReplaceOptions & {
- includeResultMetadata: false;
- }): Promise<WithId<TSchema> | null>;
- findOneAndReplace(filter: Filter<TSchema>, replacement: WithoutId<TSchema>, options: FindOneAndReplaceOptions): Promise<WithId<TSchema> | null>;
- findOneAndReplace(filter: Filter<TSchema>, replacement: WithoutId<TSchema>): Promise<WithId<TSchema> | null>;
-
- findOneAndUpdate(filter: Filter<TSchema>, update: UpdateFilter<TSchema>, options: FindOneAndUpdateOptions & {
- includeResultMetadata: true;
- }): Promise<ModifyResult<TSchema>>;
- findOneAndUpdate(filter: Filter<TSchema>, update: UpdateFilter<TSchema>, options: FindOneAndUpdateOptions & {
- includeResultMetadata: false;
- }): Promise<WithId<TSchema> | null>;
- findOneAndUpdate(filter: Filter<TSchema>, update: UpdateFilter<TSchema>, options: FindOneAndUpdateOptions): Promise<WithId<TSchema> | null>;
- findOneAndUpdate(filter: Filter<TSchema>, update: UpdateFilter<TSchema>): Promise<WithId<TSchema> | null>;
-
- aggregate<T extends Document = Document>(pipeline?: Document[], options?: AggregateOptions): AggregationCursor<T>;
-
- watch<TLocal extends Document = TSchema, TChange extends Document = ChangeStreamDocument<TLocal>>(pipeline?: Document[], options?: ChangeStreamOptions): ChangeStream<TLocal, TChange>;
-
- initializeUnorderedBulkOp(options?: BulkWriteOptions): UnorderedBulkOperation;
-
- initializeOrderedBulkOp(options?: BulkWriteOptions): OrderedBulkOperation;
-
- count(filter?: Filter<TSchema>, options?: CountOptions): Promise<number>;
-
- listSearchIndexes(options?: ListSearchIndexesOptions): ListSearchIndexesCursor;
-
- listSearchIndexes(name: string, options?: ListSearchIndexesOptions): ListSearchIndexesCursor;
-
- createSearchIndex(description: SearchIndexDescription): Promise<string>;
-
- createSearchIndexes(descriptions: SearchIndexDescription[]): Promise<string[]>;
-
- dropSearchIndex(name: string): Promise<void>;
-
- updateSearchIndex(name: string, definition: Document): Promise<void>;
- }
- export declare interface CollectionInfo extends Document {
- name: string;
- type?: string;
- options?: Document;
- info?: {
- readOnly?: false;
- uuid?: Binary;
- };
- idIndex?: Document;
- }
- export declare interface CollectionOptions extends BSONSerializeOptions, WriteConcernOptions {
-
- readConcern?: ReadConcernLike;
-
- readPreference?: ReadPreferenceLike;
- }
- export declare class CommandFailedEvent {
- address: string;
- connectionId?: string | number;
- requestId: number;
- duration: number;
- commandName: string;
- failure: Error;
- serviceId?: ObjectId;
-
-
- get hasServiceId(): boolean;
- }
- export declare interface CommandOperationOptions extends OperationOptions, WriteConcernOptions, ExplainOptions {
-
- readConcern?: ReadConcernLike;
-
- collation?: CollationOptions;
- maxTimeMS?: number;
-
- comment?: unknown;
-
- retryWrites?: boolean;
- dbName?: string;
- authdb?: string;
- noResponse?: boolean;
- }
- export declare class CommandStartedEvent {
- commandObj?: Document;
- requestId: number;
- databaseName: string;
- commandName: string;
- command: Document;
- address: string;
- connectionId?: string | number;
- serviceId?: ObjectId;
-
-
- get hasServiceId(): boolean;
- }
- export declare class CommandSucceededEvent {
- address: string;
- connectionId?: string | number;
- requestId: number;
- duration: number;
- commandName: string;
- reply: unknown;
- serviceId?: ObjectId;
-
-
- get hasServiceId(): boolean;
- }
- export declare type CommonEvents = 'newListener' | 'removeListener';
- export declare const Compressor: Readonly<{
- readonly none: 0;
- readonly snappy: 1;
- readonly zlib: 2;
- readonly zstd: 3;
- }>;
- export declare type Compressor = (typeof Compressor)[CompressorName];
- export declare type CompressorName = keyof typeof Compressor;
- export declare type Condition<T> = AlternativeType<T> | FilterOperators<AlternativeType<T>>;
- export declare class ConnectionCheckedInEvent extends ConnectionPoolMonitoringEvent {
-
- connectionId: number | '<monitor>';
-
-
- }
- export declare class ConnectionCheckedOutEvent extends ConnectionPoolMonitoringEvent {
-
- connectionId: number | '<monitor>';
-
-
- }
- export declare class ConnectionCheckOutFailedEvent extends ConnectionPoolMonitoringEvent {
-
- reason: string;
-
-
-
- }
- export declare class ConnectionCheckOutStartedEvent extends ConnectionPoolMonitoringEvent {
-
-
- }
- export declare class ConnectionClosedEvent extends ConnectionPoolMonitoringEvent {
-
- connectionId: number | '<monitor>';
-
- reason: string;
- serviceId?: ObjectId;
-
-
-
- }
- export declare class ConnectionCreatedEvent extends ConnectionPoolMonitoringEvent {
-
- connectionId: number | '<monitor>';
-
-
- }
- export declare type ConnectionEvents = {
- commandStarted(event: CommandStartedEvent): void;
- commandSucceeded(event: CommandSucceededEvent): void;
- commandFailed(event: CommandFailedEvent): void;
- clusterTimeReceived(clusterTime: Document): void;
- close(): void;
- message(message: any): void;
- pinned(pinType: string): void;
- unpinned(pinType: string): void;
- };
- export declare interface ConnectionOptions extends SupportedNodeConnectionOptions, StreamDescriptionOptions, ProxyOptions {
- id: number | '<monitor>';
- generation: number;
- hostAddress: HostAddress;
-
- serverApi?: ServerApi;
- monitorCommands: boolean;
-
- credentials?: MongoCredentials;
- connectTimeoutMS?: number;
- tls: boolean;
- noDelay?: boolean;
- socketTimeoutMS?: number;
- cancellationToken?: CancellationToken;
- metadata: ClientMetadata;
- }
- export declare class ConnectionPoolClearedEvent extends ConnectionPoolMonitoringEvent {
-
- interruptInUseConnections?: boolean;
-
-
- }
- export declare class ConnectionPoolClosedEvent extends ConnectionPoolMonitoringEvent {
-
-
- }
- export declare class ConnectionPoolCreatedEvent extends ConnectionPoolMonitoringEvent {
-
- options: Pick<ConnectionPoolOptions, 'maxPoolSize' | 'minPoolSize' | 'maxConnecting' | 'maxIdleTimeMS' | 'waitQueueTimeoutMS'>;
-
-
- }
- export declare type ConnectionPoolEvents = {
- connectionPoolCreated(event: ConnectionPoolCreatedEvent): void;
- connectionPoolReady(event: ConnectionPoolReadyEvent): void;
- connectionPoolClosed(event: ConnectionPoolClosedEvent): void;
- connectionPoolCleared(event: ConnectionPoolClearedEvent): void;
- connectionCreated(event: ConnectionCreatedEvent): void;
- connectionReady(event: ConnectionReadyEvent): void;
- connectionClosed(event: ConnectionClosedEvent): void;
- connectionCheckOutStarted(event: ConnectionCheckOutStartedEvent): void;
- connectionCheckOutFailed(event: ConnectionCheckOutFailedEvent): void;
- connectionCheckedOut(event: ConnectionCheckedOutEvent): void;
- connectionCheckedIn(event: ConnectionCheckedInEvent): void;
- } & Omit<ConnectionEvents, 'close' | 'message'>;
- export declare abstract class ConnectionPoolMonitoringEvent {
-
- time: Date;
-
- address: string;
-
-
- }
- export declare interface ConnectionPoolOptions extends Omit<ConnectionOptions, 'id' | 'generation'> {
-
- maxPoolSize: number;
-
- minPoolSize: number;
-
- maxConnecting: number;
-
- maxIdleTimeMS: number;
-
- waitQueueTimeoutMS: number;
-
- loadBalanced: boolean;
-
- }
- export declare class ConnectionPoolReadyEvent extends ConnectionPoolMonitoringEvent {
-
-
- }
- export declare class ConnectionReadyEvent extends ConnectionPoolMonitoringEvent {
-
- connectionId: number | '<monitor>';
-
-
- }
- export declare interface ConnectOptions {
- readPreference?: ReadPreference;
- }
- export declare interface CountDocumentsOptions extends AggregateOptions {
-
- skip?: number;
-
- limit?: number;
- }
- export declare interface CountOptions extends CommandOperationOptions {
-
- skip?: number;
-
- limit?: number;
-
- maxTimeMS?: number;
-
- hint?: string | Document;
- }
- export declare interface CreateCollectionOptions extends CommandOperationOptions {
-
- capped?: boolean;
-
- autoIndexId?: boolean;
-
- size?: number;
-
- max?: number;
-
- flags?: number;
-
- storageEngine?: Document;
-
- validator?: Document;
-
- validationLevel?: string;
-
- validationAction?: string;
-
- indexOptionDefaults?: Document;
-
- viewOn?: string;
-
- pipeline?: Document[];
-
- pkFactory?: PkFactory;
-
- timeseries?: TimeSeriesCollectionOptions;
-
- clusteredIndex?: ClusteredCollectionOptions;
-
- expireAfterSeconds?: number;
-
- encryptedFields?: Document;
-
- changeStreamPreAndPostImages?: {
- enabled: boolean;
- };
- }
- export declare interface CreateIndexesOptions extends Omit<CommandOperationOptions, 'writeConcern'> {
-
- background?: boolean;
-
- unique?: boolean;
-
- name?: string;
-
- partialFilterExpression?: Document;
-
- sparse?: boolean;
-
- expireAfterSeconds?: number;
-
- storageEngine?: Document;
-
- commitQuorum?: number | string;
-
- version?: number;
- weights?: Document;
- default_language?: string;
- language_override?: string;
- textIndexVersion?: number;
- '2dsphereIndexVersion'?: number;
- bits?: number;
-
- min?: number;
-
- max?: number;
- bucketSize?: number;
- wildcardProjection?: Document;
-
- hidden?: boolean;
- }
- export declare type CSFLEKMSTlsOptions = {
- aws?: ClientEncryptionTlsOptions;
- gcp?: ClientEncryptionTlsOptions;
- kmip?: ClientEncryptionTlsOptions;
- local?: ClientEncryptionTlsOptions;
- azure?: ClientEncryptionTlsOptions;
- };
- export declare const CURSOR_FLAGS: readonly ["tailable", "oplogReplay", "noCursorTimeout", "awaitData", "exhaust", "partial"];
- export declare type CursorFlag = (typeof CURSOR_FLAGS)[number];
- export declare interface CursorStreamOptions {
-
- transform?(this: void, doc: Document): Document;
- }
- export declare interface DataKey {
- _id: UUID;
- version?: number;
- keyAltNames?: string[];
- keyMaterial: Binary;
- creationDate: Date;
- updateDate: Date;
- status: number;
- masterKey: Document;
- }
- export declare class Db {
-
-
- static SYSTEM_NAMESPACE_COLLECTION: string;
- static SYSTEM_INDEX_COLLECTION: string;
- static SYSTEM_PROFILE_COLLECTION: string;
- static SYSTEM_USER_COLLECTION: string;
- static SYSTEM_COMMAND_COLLECTION: string;
- static SYSTEM_JS_COLLECTION: string;
-
- constructor(client: MongoClient, databaseName: string, options?: DbOptions);
- get databaseName(): string;
- get options(): DbOptions | undefined;
-
- get secondaryOk(): boolean;
- get readConcern(): ReadConcern | undefined;
-
- get readPreference(): ReadPreference;
- get bsonOptions(): BSONSerializeOptions;
- get writeConcern(): WriteConcern | undefined;
- get namespace(): string;
-
- createCollection<TSchema extends Document = Document>(name: string, options?: CreateCollectionOptions): Promise<Collection<TSchema>>;
-
- command(command: Document, options?: RunCommandOptions): Promise<Document>;
-
- aggregate<T extends Document = Document>(pipeline?: Document[], options?: AggregateOptions): AggregationCursor<T>;
-
- admin(): Admin;
-
- collection<TSchema extends Document = Document>(name: string, options?: CollectionOptions): Collection<TSchema>;
-
- stats(options?: DbStatsOptions): Promise<Document>;
-
- listCollections(filter: Document, options: Exclude<ListCollectionsOptions, 'nameOnly'> & {
- nameOnly: true;
- }): ListCollectionsCursor<Pick<CollectionInfo, 'name' | 'type'>>;
- listCollections(filter: Document, options: Exclude<ListCollectionsOptions, 'nameOnly'> & {
- nameOnly: false;
- }): ListCollectionsCursor<CollectionInfo>;
- listCollections<T extends Pick<CollectionInfo, 'name' | 'type'> | CollectionInfo = Pick<CollectionInfo, 'name' | 'type'> | CollectionInfo>(filter?: Document, options?: ListCollectionsOptions): ListCollectionsCursor<T>;
-
- renameCollection<TSchema extends Document = Document>(fromCollection: string, toCollection: string, options?: RenameOptions): Promise<Collection<TSchema>>;
-
- dropCollection(name: string, options?: DropCollectionOptions): Promise<boolean>;
-
- dropDatabase(options?: DropDatabaseOptions): Promise<boolean>;
-
- collections(options?: ListCollectionsOptions): Promise<Collection[]>;
-
- createIndex(name: string, indexSpec: IndexSpecification, options?: CreateIndexesOptions): Promise<string>;
-
- removeUser(username: string, options?: RemoveUserOptions): Promise<boolean>;
-
- setProfilingLevel(level: ProfilingLevel, options?: SetProfilingLevelOptions): Promise<ProfilingLevel>;
-
- profilingLevel(options?: ProfilingLevelOptions): Promise<string>;
-
- indexInformation(name: string, options?: IndexInformationOptions): Promise<Document>;
-
- watch<TSchema extends Document = Document, TChange extends Document = ChangeStreamDocument<TSchema>>(pipeline?: Document[], options?: ChangeStreamOptions): ChangeStream<TSchema, TChange>;
-
- runCursorCommand(command: Document, options?: RunCursorCommandOptions): RunCommandCursor;
- }
- export declare interface DbOptions extends BSONSerializeOptions, WriteConcernOptions {
-
- authSource?: string;
-
- forceServerObjectId?: boolean;
-
- readPreference?: ReadPreferenceLike;
-
- pkFactory?: PkFactory;
-
- readConcern?: ReadConcern;
-
- retryWrites?: boolean;
- }
- export { DBRef }
- export declare interface DbStatsOptions extends CommandOperationOptions {
-
- scale?: number;
- }
- export { Decimal128 }
- export declare interface DeleteManyModel<TSchema extends Document = Document> {
-
- filter: Filter<TSchema>;
-
- collation?: CollationOptions;
-
- hint?: Hint;
- }
- export declare interface DeleteOneModel<TSchema extends Document = Document> {
-
- filter: Filter<TSchema>;
-
- collation?: CollationOptions;
-
- hint?: Hint;
- }
- export declare interface DeleteOptions extends CommandOperationOptions, WriteConcernOptions {
-
- ordered?: boolean;
-
- collation?: CollationOptions;
-
- hint?: string | Document;
-
- let?: Document;
- }
- export declare interface DeleteResult {
-
- acknowledged: boolean;
-
- deletedCount: number;
- }
- export declare interface DeleteStatement {
-
- q: Document;
-
- limit: number;
-
- collation?: CollationOptions;
-
- hint?: Hint;
- }
- export { deserialize }
- export declare type DistinctOptions = CommandOperationOptions;
- export { Document }
- export { Double }
- export declare interface DriverInfo {
- name?: string;
- version?: string;
- platform?: string;
- }
- export declare interface DropCollectionOptions extends CommandOperationOptions {
-
- encryptedFields?: Document;
- }
- export declare type DropDatabaseOptions = CommandOperationOptions;
- export declare type DropIndexesOptions = CommandOperationOptions;
- export declare interface EndSessionOptions {
-
- force?: boolean;
- forceClear?: boolean;
- }
- export declare type EnhancedOmit<TRecordOrUnion, KeyUnion> = string extends keyof TRecordOrUnion ? TRecordOrUnion : TRecordOrUnion extends any ? Pick<TRecordOrUnion, Exclude<keyof TRecordOrUnion, KeyUnion>> : never;
- export declare interface ErrorDescription extends Document {
- message?: string;
- errmsg?: string;
- $err?: string;
- errorLabels?: string[];
- errInfo?: Document;
- }
- export declare interface EstimatedDocumentCountOptions extends CommandOperationOptions {
-
- maxTimeMS?: number;
- }
- export declare type EventEmitterWithState = {
-
- };
- export declare type EventsDescription = Record<string, GenericListener>;
- export declare interface ExplainOptions {
-
- explain?: ExplainVerbosityLike;
- }
- export declare const ExplainVerbosity: Readonly<{
- readonly queryPlanner: "queryPlanner";
- readonly queryPlannerExtended: "queryPlannerExtended";
- readonly executionStats: "executionStats";
- readonly allPlansExecution: "allPlansExecution";
- }>;
- export declare type ExplainVerbosity = string;
- export declare type ExplainVerbosityLike = ExplainVerbosity | boolean;
- export declare type Filter<TSchema> = {
- [P in keyof WithId<TSchema>]?: Condition<WithId<TSchema>[P]>;
- } & RootFilterOperators<WithId<TSchema>>;
- export declare type FilterOperations<T> = T extends Record<string, any> ? {
- [key in keyof T]?: FilterOperators<T[key]>;
- } : FilterOperators<T>;
- export declare interface FilterOperators<TValue> extends NonObjectIdLikeDocument {
- $eq?: TValue;
- $gt?: TValue;
- $gte?: TValue;
- $in?: ReadonlyArray<TValue>;
- $lt?: TValue;
- $lte?: TValue;
- $ne?: TValue;
- $nin?: ReadonlyArray<TValue>;
- $not?: TValue extends string ? FilterOperators<TValue> | RegExp : FilterOperators<TValue>;
-
- $exists?: boolean;
- $type?: BSONType | BSONTypeAlias;
- $expr?: Record<string, any>;
- $jsonSchema?: Record<string, any>;
- $mod?: TValue extends number ? [number, number] : never;
- $regex?: TValue extends string ? RegExp | BSONRegExp | string : never;
- $options?: TValue extends string ? string : never;
- $geoIntersects?: {
- $geometry: Document;
- };
- $geoWithin?: Document;
- $near?: Document;
- $nearSphere?: Document;
- $maxDistance?: number;
- $all?: ReadonlyArray<any>;
- $elemMatch?: Document;
- $size?: TValue extends ReadonlyArray<any> ? number : never;
- $bitsAllClear?: BitwiseFilter;
- $bitsAllSet?: BitwiseFilter;
- $bitsAnyClear?: BitwiseFilter;
- $bitsAnySet?: BitwiseFilter;
- $rand?: Record<string, never>;
- }
- export declare class FindCursor<TSchema = any> extends AbstractCursor<TSchema> {
-
-
-
-
- clone(): FindCursor<TSchema>;
- map<T>(transform: (doc: TSchema) => T): FindCursor<T>;
-
-
-
- count(options?: CountOptions): Promise<number>;
-
- explain(verbosity?: ExplainVerbosityLike): Promise<Document>;
-
- filter(filter: Document): this;
-
- hint(hint: Hint): this;
-
- min(min: Document): this;
-
- max(max: Document): this;
-
- returnKey(value: boolean): this;
-
- showRecordId(value: boolean): this;
-
- addQueryModifier(name: string, value: string | boolean | number | Document): this;
-
- comment(value: string): this;
-
- maxAwaitTimeMS(value: number): this;
-
- maxTimeMS(value: number): this;
-
- project<T extends Document = Document>(value: Document): FindCursor<T>;
-
- sort(sort: Sort | string, direction?: SortDirection): this;
-
- allowDiskUse(allow?: boolean): this;
-
- collation(value: CollationOptions): this;
-
- limit(value: number): this;
-
- skip(value: number): this;
- }
- export declare interface FindOneAndDeleteOptions extends CommandOperationOptions {
-
- hint?: Document;
-
- projection?: Document;
-
- sort?: Sort;
-
- let?: Document;
-
- includeResultMetadata?: boolean;
- }
- export declare interface FindOneAndReplaceOptions extends CommandOperationOptions {
-
- bypassDocumentValidation?: boolean;
-
- hint?: Document;
-
- projection?: Document;
-
- returnDocument?: ReturnDocument;
-
- sort?: Sort;
-
- upsert?: boolean;
-
- let?: Document;
-
- includeResultMetadata?: boolean;
- }
- export declare interface FindOneAndUpdateOptions extends CommandOperationOptions {
-
- arrayFilters?: Document[];
-
- bypassDocumentValidation?: boolean;
-
- hint?: Document;
-
- projection?: Document;
-
- returnDocument?: ReturnDocument;
-
- sort?: Sort;
-
- upsert?: boolean;
-
- let?: Document;
-
- includeResultMetadata?: boolean;
- }
- export declare class FindOperators {
- bulkOperation: BulkOperationBase;
-
-
- update(updateDocument: Document | Document[]): BulkOperationBase;
-
- updateOne(updateDocument: Document | Document[]): BulkOperationBase;
-
- replaceOne(replacement: Document): BulkOperationBase;
-
- deleteOne(): BulkOperationBase;
-
- delete(): BulkOperationBase;
-
- upsert(): this;
-
- collation(collation: CollationOptions): this;
-
- arrayFilters(arrayFilters: Document[]): this;
-
- hint(hint: Hint): this;
- }
- export declare interface FindOptions<TSchema extends Document = Document> extends Omit<CommandOperationOptions, 'writeConcern'> {
-
- limit?: number;
-
- sort?: Sort;
-
- projection?: Document;
-
- skip?: number;
-
- hint?: Hint;
-
- timeout?: boolean;
-
- tailable?: boolean;
-
- awaitData?: boolean;
-
- batchSize?: number;
-
- returnKey?: boolean;
-
- min?: Document;
-
- max?: Document;
-
- maxTimeMS?: number;
-
- maxAwaitTimeMS?: number;
-
- noCursorTimeout?: boolean;
-
- collation?: CollationOptions;
-
- allowDiskUse?: boolean;
-
- singleBatch?: boolean;
-
- allowPartialResults?: boolean;
-
- showRecordId?: boolean;
-
- let?: Document;
-
- oplogReplay?: boolean;
- }
- export declare type Flatten<Type> = Type extends ReadonlyArray<infer Item> ? Item : Type;
- export declare interface GCPEncryptionKeyOptions {
-
- projectId: string;
-
- location: string;
-
- keyRing: string;
-
- keyName: string;
-
- keyVersion?: string | undefined;
-
- endpoint?: string | undefined;
- }
- export declare type GenericListener = (...args: any[]) => void;
- export declare class GridFSBucket extends TypedEventEmitter<GridFSBucketEvents> {
-
-
- static readonly INDEX: "index";
- constructor(db: Db, options?: GridFSBucketOptions);
-
- openUploadStream(filename: string, options?: GridFSBucketWriteStreamOptions): GridFSBucketWriteStream;
-
- openUploadStreamWithId(id: ObjectId, filename: string, options?: GridFSBucketWriteStreamOptions): GridFSBucketWriteStream;
-
- openDownloadStream(id: ObjectId, options?: GridFSBucketReadStreamOptions): GridFSBucketReadStream;
-
- delete(id: ObjectId): Promise<void>;
-
- find(filter?: Filter<GridFSFile>, options?: FindOptions): FindCursor<GridFSFile>;
-
- openDownloadStreamByName(filename: string, options?: GridFSBucketReadStreamOptionsWithRevision): GridFSBucketReadStream;
-
- rename(id: ObjectId, filename: string): Promise<void>;
-
- drop(): Promise<void>;
- }
- export declare type GridFSBucketEvents = {
- index(): void;
- };
- export declare interface GridFSBucketOptions extends WriteConcernOptions {
-
- bucketName?: string;
-
- chunkSizeBytes?: number;
-
- readPreference?: ReadPreference;
- }
- export declare class GridFSBucketReadStream extends Readable {
-
-
- static readonly FILE: "file";
-
-
-
- start(start?: number): this;
-
- end(end?: number): this;
-
- abort(): Promise<void>;
- }
- export declare interface GridFSBucketReadStreamOptions {
- sort?: Sort;
- skip?: number;
-
- start?: number;
-
- end?: number;
- }
- export declare interface GridFSBucketReadStreamOptionsWithRevision extends GridFSBucketReadStreamOptions {
-
- revision?: number;
- }
- export declare class GridFSBucketWriteStream extends Writable {
- bucket: GridFSBucket;
-
- chunks: Collection<GridFSChunk>;
-
- files: Collection<GridFSFile>;
-
- filename: string;
-
- options: GridFSBucketWriteStreamOptions;
-
- done: boolean;
-
- id: ObjectId;
-
- chunkSizeBytes: number;
-
- bufToStore: Buffer;
-
- length: number;
-
- n: number;
-
- pos: number;
-
- state: {
-
- streamEnd: boolean;
-
- outstandingRequests: number;
-
- errored: boolean;
-
- aborted: boolean;
- };
-
- writeConcern?: WriteConcern;
-
- gridFSFile: GridFSFile | null;
-
-
-
-
-
- abort(): Promise<void>;
- }
- export declare interface GridFSBucketWriteStreamOptions extends WriteConcernOptions {
-
- chunkSizeBytes?: number;
-
- id?: ObjectId;
-
- metadata?: Document;
-
- contentType?: string;
-
- aliases?: string[];
- }
- export declare interface GridFSChunk {
- _id: ObjectId;
- files_id: ObjectId;
- n: number;
- data: Buffer | Uint8Array;
- }
- export declare interface GridFSFile {
- _id: ObjectId;
- length: number;
- chunkSize: number;
- filename: string;
- contentType?: string;
- aliases?: string[];
- metadata?: Document;
- uploadDate: Date;
- }
- export declare const GSSAPICanonicalizationValue: Readonly<{
- readonly on: true;
- readonly off: false;
- readonly none: "none";
- readonly forward: "forward";
- readonly forwardAndReverse: "forwardAndReverse";
- }>;
- export declare type GSSAPICanonicalizationValue = (typeof GSSAPICanonicalizationValue)[keyof typeof GSSAPICanonicalizationValue];
- export declare interface HedgeOptions {
-
- enabled?: boolean;
- }
- export declare type Hint = string | Document;
- export declare class HostAddress {
- host: string | undefined;
- port: number | undefined;
- socketPath: string | undefined;
- isIPv6: boolean;
- constructor(hostString: string);
- inspect(): string;
- toString(): string;
- static fromString(this: void, s: string): HostAddress;
- static fromHostPort(host: string, port: number): HostAddress;
- static fromSrvRecord({ name, port }: SrvRecord): HostAddress;
- toHostPort(): {
- host: string;
- port: number;
- };
- }
- export declare interface IdPServerInfo {
- issuer: string;
- clientId: string;
- requestScopes?: string[];
- }
- export declare interface IdPServerResponse {
- accessToken: string;
- expiresInSeconds?: number;
- refreshToken?: string;
- }
- export declare interface IndexDescription extends Pick<CreateIndexesOptions, 'background' | 'unique' | 'partialFilterExpression' | 'sparse' | 'hidden' | 'expireAfterSeconds' | 'storageEngine' | 'version' | 'weights' | 'default_language' | 'language_override' | 'textIndexVersion' | '2dsphereIndexVersion' | 'bits' | 'min' | 'max' | 'bucketSize' | 'wildcardProjection'> {
- collation?: CollationOptions;
- name?: string;
- key: {
- [key: string]: IndexDirection;
- } | Map<string, IndexDirection>;
- }
- export declare type IndexDirection = -1 | 1 | '2d' | '2dsphere' | 'text' | 'geoHaystack' | 'hashed' | number;
- export declare interface IndexInformationOptions {
- full?: boolean;
- readPreference?: ReadPreference;
- session?: ClientSession;
- }
- export declare type IndexSpecification = OneOrMore<string | [string, IndexDirection] | {
- [key: string]: IndexDirection;
- } | Map<string, IndexDirection>>;
- export declare type InferIdType<TSchema> = TSchema extends {
- _id: infer IdType;
- } ? Record<any, never> extends IdType ? never : IdType : TSchema extends {
- _id?: infer IdType;
- } ? unknown extends IdType ? ObjectId : IdType : ObjectId;
- export declare interface InsertManyResult<TSchema = Document> {
-
- acknowledged: boolean;
-
- insertedCount: number;
-
- insertedIds: {
- [key: number]: InferIdType<TSchema>;
- };
- }
- export declare interface InsertOneModel<TSchema extends Document = Document> {
-
- document: OptionalId<TSchema>;
- }
- export declare interface InsertOneOptions extends CommandOperationOptions {
-
- bypassDocumentValidation?: boolean;
-
- forceServerObjectId?: boolean;
- }
- export declare interface InsertOneResult<TSchema = Document> {
-
- acknowledged: boolean;
-
- insertedId: InferIdType<TSchema>;
- }
- export { Int32 }
- export declare type IntegerType = number | Int32 | Long | bigint;
- export declare type IsAny<Type, ResultIfAny, ResultIfNotAny> = true extends false & Type ? ResultIfAny : ResultIfNotAny;
- export declare type Join<T extends unknown[], D extends string> = T extends [] ? '' : T extends [string | number] ? `${T[0]}` : T extends [string | number, ...infer R] ? `${T[0]}${D}${Join<R, D>}` : string;
- export declare type KeysOfAType<TSchema, Type> = {
- [key in keyof TSchema]: NonNullable<TSchema[key]> extends Type ? key : never;
- }[keyof TSchema];
- export declare type KeysOfOtherType<TSchema, Type> = {
- [key in keyof TSchema]: NonNullable<TSchema[key]> extends Type ? never : key;
- }[keyof TSchema];
- export declare interface KMSProviders {
-
- aws?: {
-
- accessKeyId: string;
-
- secretAccessKey: string;
-
- sessionToken?: string;
- } | Record<string, never>;
-
- local?: {
-
- key: Buffer | string;
- };
-
- kmip?: {
-
- endpoint?: string;
- };
-
- azure?: {
-
- tenantId: string;
-
- clientId: string;
-
- clientSecret: string;
-
- identityPlatformEndpoint?: string | undefined;
- } | {
-
- accessToken: string;
- } | Record<string, never>;
-
- gcp?: {
-
- email: string;
-
- privateKey: string | Buffer;
-
- endpoint?: string | undefined;
- } | {
-
- accessToken: string;
- } | Record<string, never>;
- }
- export declare const LEGAL_TCP_SOCKET_OPTIONS: readonly ["family", "hints", "localAddress", "localPort", "lookup"];
- export declare const LEGAL_TLS_SOCKET_OPTIONS: readonly ["ALPNProtocols", "ca", "cert", "checkServerIdentity", "ciphers", "crl", "ecdhCurve", "key", "minDHSize", "passphrase", "pfx", "rejectUnauthorized", "secureContext", "secureProtocol", "servername", "session"];
- export declare class ListCollectionsCursor<T extends Pick<CollectionInfo, 'name' | 'type'> | CollectionInfo = Pick<CollectionInfo, 'name' | 'type'> | CollectionInfo> extends AbstractCursor<T> {
- parent: Db;
- filter: Document;
- options?: ListCollectionsOptions;
- constructor(db: Db, filter: Document, options?: ListCollectionsOptions);
- clone(): ListCollectionsCursor<T>;
-
- }
- export declare interface ListCollectionsOptions extends Omit<CommandOperationOptions, 'writeConcern'> {
-
- nameOnly?: boolean;
-
- authorizedCollections?: boolean;
-
- batchSize?: number;
- }
- export declare interface ListDatabasesOptions extends CommandOperationOptions {
-
- filter?: Document;
-
- nameOnly?: boolean;
-
- authorizedDatabases?: boolean;
- }
- export declare interface ListDatabasesResult {
- databases: ({
- name: string;
- sizeOnDisk?: number;
- empty?: boolean;
- } & Document)[];
- totalSize?: number;
- totalSizeMb?: number;
- ok: 1 | 0;
- }
- export declare class ListIndexesCursor extends AbstractCursor {
- parent: Collection;
- options?: ListIndexesOptions;
- constructor(collection: Collection, options?: ListIndexesOptions);
- clone(): ListIndexesCursor;
-
- }
- export declare interface ListIndexesOptions extends Omit<CommandOperationOptions, 'writeConcern'> {
-
- batchSize?: number;
- }
- export declare class ListSearchIndexesCursor extends AggregationCursor<{
- name: string;
- }> {
-
- }
- export declare type ListSearchIndexesOptions = AggregateOptions;
- export { Long }
- export declare type MatchKeysAndValues<TSchema> = Readonly<Partial<TSchema>> & Record<string, any>;
- export { MaxKey }
- export { MinKey }
- export declare interface ModifyResult<TSchema = Document> {
- value: WithId<TSchema> | null;
- lastErrorObject?: Document;
- ok: 0 | 1;
- }
- export declare const MONGO_CLIENT_EVENTS: readonly ["connectionPoolCreated", "connectionPoolReady", "connectionPoolCleared", "connectionPoolClosed", "connectionCreated", "connectionReady", "connectionClosed", "connectionCheckOutStarted", "connectionCheckOutFailed", "connectionCheckedOut", "connectionCheckedIn", "commandStarted", "commandSucceeded", "commandFailed", "serverOpening", "serverClosed", "serverDescriptionChanged", "topologyOpening", "topologyClosed", "topologyDescriptionChanged", "error", "timeout", "close", "serverHeartbeatStarted", "serverHeartbeatSucceeded", "serverHeartbeatFailed"];
- export declare class MongoAPIError extends MongoDriverError {
-
- constructor(message: string, options?: {
- cause?: Error;
- });
- get name(): string;
- }
- export declare class MongoAWSError extends MongoRuntimeError {
-
- constructor(message: string);
- get name(): string;
- }
- export declare class MongoAzureError extends MongoRuntimeError {
-
- constructor(message: string);
- get name(): string;
- }
- export declare class MongoBatchReExecutionError extends MongoAPIError {
-
- constructor(message?: string);
- get name(): string;
- }
- export declare class MongoBulkWriteError extends MongoServerError {
- result: BulkWriteResult;
- writeErrors: OneOrMore<WriteError>;
- err?: WriteConcernError;
-
- constructor(error: {
- message: string;
- code: number;
- writeErrors?: WriteError[];
- } | WriteConcernError | AnyError, result: BulkWriteResult);
- get name(): string;
-
- get insertedCount(): number;
-
- get matchedCount(): number;
-
- get modifiedCount(): number;
-
- get deletedCount(): number;
-
- get upsertedCount(): number;
-
- get insertedIds(): {
- [key: number]: any;
- };
-
- get upsertedIds(): {
- [key: number]: any;
- };
- }
- export declare class MongoChangeStreamError extends MongoRuntimeError {
-
- constructor(message: string);
- get name(): string;
- }
- export declare class MongoClient extends TypedEventEmitter<MongoClientEvents> {
-
-
-
-
-
- constructor(url: string, options?: MongoClientOptions);
-
- get options(): Readonly<MongoOptions>;
- get serverApi(): Readonly<ServerApi | undefined>;
-
-
-
- get readConcern(): ReadConcern | undefined;
- get writeConcern(): WriteConcern | undefined;
- get readPreference(): ReadPreference;
- get bsonOptions(): BSONSerializeOptions;
-
- connect(): Promise<this>;
-
-
- close(force?: boolean): Promise<void>;
-
- db(dbName?: string, options?: DbOptions): Db;
-
- static connect(url: string, options?: MongoClientOptions): Promise<MongoClient>;
-
- startSession(options?: ClientSessionOptions): ClientSession;
-
- withSession<T = any>(executor: WithSessionCallback<T>): Promise<T>;
- withSession<T = any>(options: ClientSessionOptions, executor: WithSessionCallback<T>): Promise<T>;
-
- watch<TSchema extends Document = Document, TChange extends Document = ChangeStreamDocument<TSchema>>(pipeline?: Document[], options?: ChangeStreamOptions): ChangeStream<TSchema, TChange>;
- }
- export declare type MongoClientEvents = Pick<TopologyEvents, (typeof MONGO_CLIENT_EVENTS)[number]> & {
- open(mongoClient: MongoClient): void;
- };
- export declare interface MongoClientOptions extends BSONSerializeOptions, SupportedNodeConnectionOptions {
-
- replicaSet?: string;
-
- tls?: boolean;
-
- ssl?: boolean;
-
- tlsCertificateKeyFile?: string;
-
- tlsCertificateKeyFilePassword?: string;
-
- tlsCAFile?: string;
-
- tlsCRLFile?: string;
-
- tlsAllowInvalidCertificates?: boolean;
-
- tlsAllowInvalidHostnames?: boolean;
-
- tlsInsecure?: boolean;
-
- connectTimeoutMS?: number;
-
- socketTimeoutMS?: number;
-
- compressors?: CompressorName[] | string;
-
- zlibCompressionLevel?: 0 | 1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9 | undefined;
-
- srvMaxHosts?: number;
-
- srvServiceName?: string;
-
- maxPoolSize?: number;
-
- minPoolSize?: number;
-
- maxConnecting?: number;
-
- maxIdleTimeMS?: number;
-
- waitQueueTimeoutMS?: number;
-
- readConcern?: ReadConcernLike;
-
- readConcernLevel?: ReadConcernLevel;
-
- readPreference?: ReadPreferenceMode | ReadPreference;
-
- maxStalenessSeconds?: number;
-
- readPreferenceTags?: TagSet[];
-
- auth?: Auth;
-
- authSource?: string;
-
- authMechanism?: AuthMechanism;
-
- authMechanismProperties?: AuthMechanismProperties;
-
- localThresholdMS?: number;
-
- serverSelectionTimeoutMS?: number;
-
- heartbeatFrequencyMS?: number;
-
- minHeartbeatFrequencyMS?: number;
-
- appName?: string;
-
- retryReads?: boolean;
-
- retryWrites?: boolean;
-
- directConnection?: boolean;
-
- loadBalanced?: boolean;
-
- w?: W;
-
- wtimeoutMS?: number;
-
- journal?: boolean;
-
- writeConcern?: WriteConcern | WriteConcernSettings;
-
- noDelay?: boolean;
-
- forceServerObjectId?: boolean;
-
- pkFactory?: PkFactory;
-
- monitorCommands?: boolean;
-
- serverApi?: ServerApi | ServerApiVersion;
-
- autoEncryption?: AutoEncryptionOptions;
-
- driverInfo?: DriverInfo;
-
- proxyHost?: string;
-
- proxyPort?: number;
-
- proxyUsername?: string;
-
- proxyPassword?: string;
-
-
-
- }
- export declare class MongoCompatibilityError extends MongoAPIError {
-
- constructor(message: string);
- get name(): string;
- }
- export declare class MongoCredentials {
-
- readonly username: string;
-
- readonly password: string;
-
- readonly source: string;
-
- readonly mechanism: AuthMechanism;
-
- readonly mechanismProperties: AuthMechanismProperties;
- constructor(options: MongoCredentialsOptions);
-
- equals(other: MongoCredentials): boolean;
-
- resolveAuthMechanism(hello?: Document): MongoCredentials;
- validate(): void;
- static merge(creds: MongoCredentials | undefined, options: Partial<MongoCredentialsOptions>): MongoCredentials;
- }
- export declare interface MongoCredentialsOptions {
- username?: string;
- password: string;
- source: string;
- db?: string;
- mechanism?: AuthMechanism;
- mechanismProperties: AuthMechanismProperties;
- }
- export declare class MongoCryptAzureKMSRequestError extends MongoCryptError {
-
- body?: Document;
-
- constructor(message: string, body?: Document);
- get name(): string;
- }
- export declare class MongoCryptCreateDataKeyError extends MongoCryptError {
- encryptedFields: Document;
-
- constructor(encryptedFields: Document, { cause }: {
- cause: Error;
- });
- get name(): string;
- }
- export declare class MongoCryptCreateEncryptedCollectionError extends MongoCryptError {
- encryptedFields: Document;
-
- constructor(encryptedFields: Document, { cause }: {
- cause: Error;
- });
- get name(): string;
- }
- export declare class MongoCryptError extends MongoError {
-
- constructor(message: string, options?: {
- cause?: Error;
- });
- get name(): string;
- }
- export declare class MongoCryptInvalidArgumentError extends MongoCryptError {
-
- constructor(message: string);
- get name(): string;
- }
- export declare class MongoCryptKMSRequestNetworkTimeoutError extends MongoCryptError {
- get name(): string;
- }
- export declare class MongoCursorExhaustedError extends MongoAPIError {
-
- constructor(message?: string);
- get name(): string;
- }
- export declare class MongoCursorInUseError extends MongoAPIError {
-
- constructor(message?: string);
- get name(): string;
- }
- export declare class MongoDBCollectionNamespace extends MongoDBNamespace {
- collection: string;
- constructor(db: string, collection: string);
- static fromString(namespace?: string): MongoDBCollectionNamespace;
- }
- export declare class MongoDBNamespace {
- db: string;
- collection?: string | undefined;
-
- constructor(db: string, collection?: string | undefined);
- toString(): string;
- withCollection(collection: string): MongoDBCollectionNamespace;
- static fromString(namespace?: string): MongoDBNamespace;
- }
- export declare class MongoDecompressionError extends MongoRuntimeError {
-
- constructor(message: string);
- get name(): string;
- }
- export declare class MongoDriverError extends MongoError {
-
- constructor(message: string, options?: {
- cause?: Error;
- });
- get name(): string;
- }
- export declare class MongoError extends Error {
-
-
- code?: number | string;
- topologyVersion?: TopologyVersion;
- connectionGeneration?: number;
- cause?: Error;
-
- constructor(message: string, options?: {
- cause?: Error;
- });
-
- get name(): string;
-
- get errmsg(): string;
-
- hasErrorLabel(label: string): boolean;
- addErrorLabel(label: string): void;
- get errorLabels(): string[];
- }
- export declare const MongoErrorLabel: Readonly<{
- readonly RetryableWriteError: "RetryableWriteError";
- readonly TransientTransactionError: "TransientTransactionError";
- readonly UnknownTransactionCommitResult: "UnknownTransactionCommitResult";
- readonly ResumableChangeStreamError: "ResumableChangeStreamError";
- readonly HandshakeError: "HandshakeError";
- readonly ResetPool: "ResetPool";
- readonly InterruptInUseConnections: "InterruptInUseConnections";
- readonly NoWritesPerformed: "NoWritesPerformed";
- }>;
- export declare type MongoErrorLabel = (typeof MongoErrorLabel)[keyof typeof MongoErrorLabel];
- export declare class MongoExpiredSessionError extends MongoAPIError {
-
- constructor(message?: string);
- get name(): string;
- }
- export declare class MongoGridFSChunkError extends MongoRuntimeError {
-
- constructor(message: string);
- get name(): string;
- }
- export declare class MongoGridFSStreamError extends MongoRuntimeError {
-
- constructor(message: string);
- get name(): string;
- }
- export declare class MongoInvalidArgumentError extends MongoAPIError {
-
- constructor(message: string);
- get name(): string;
- }
- export declare class MongoKerberosError extends MongoRuntimeError {
-
- constructor(message: string);
- get name(): string;
- }
- export declare class MongoMissingCredentialsError extends MongoAPIError {
-
- constructor(message: string);
- get name(): string;
- }
- export declare class MongoMissingDependencyError extends MongoAPIError {
-
- constructor(message: string, options?: {
- cause?: Error;
- });
- get name(): string;
- }
- export declare class MongoNetworkError extends MongoError {
-
-
- constructor(message: string, options?: MongoNetworkErrorOptions);
- get name(): string;
- }
- export declare interface MongoNetworkErrorOptions {
-
- beforeHandshake?: boolean;
- cause?: Error;
- }
- export declare class MongoNetworkTimeoutError extends MongoNetworkError {
-
- constructor(message: string, options?: MongoNetworkErrorOptions);
- get name(): string;
- }
- export declare class MongoNotConnectedError extends MongoAPIError {
-
- constructor(message: string);
- get name(): string;
- }
- export declare interface MongoOptions extends Required<Pick<MongoClientOptions, 'autoEncryption' | 'connectTimeoutMS' | 'directConnection' | 'driverInfo' | 'forceServerObjectId' | 'minHeartbeatFrequencyMS' | 'heartbeatFrequencyMS' | 'localThresholdMS' | 'maxConnecting' | 'maxIdleTimeMS' | 'maxPoolSize' | 'minPoolSize' | 'monitorCommands' | 'noDelay' | 'pkFactory' | 'raw' | 'replicaSet' | 'retryReads' | 'retryWrites' | 'serverSelectionTimeoutMS' | 'socketTimeoutMS' | 'srvMaxHosts' | 'srvServiceName' | 'tlsAllowInvalidCertificates' | 'tlsAllowInvalidHostnames' | 'tlsInsecure' | 'waitQueueTimeoutMS' | 'zlibCompressionLevel'>>, SupportedNodeConnectionOptions {
- appName?: string;
- hosts: HostAddress[];
- srvHost?: string;
- credentials?: MongoCredentials;
- readPreference: ReadPreference;
- readConcern: ReadConcern;
- loadBalanced: boolean;
- serverApi: ServerApi;
- compressors: CompressorName[];
- writeConcern: WriteConcern;
- dbName: string;
- metadata: ClientMetadata;
-
- proxyHost?: string;
- proxyPort?: number;
- proxyUsername?: string;
- proxyPassword?: string;
-
-
-
-
-
- tls: boolean;
- tlsCAFile?: string;
- tlsCRLFile?: string;
- tlsCertificateKeyFile?: string;
-
-
- }
- export declare class MongoParseError extends MongoDriverError {
-
- constructor(message: string);
- get name(): string;
- }
- export declare class MongoRuntimeError extends MongoDriverError {
-
- constructor(message: string, options?: {
- cause?: Error;
- });
- get name(): string;
- }
- export declare class MongoServerClosedError extends MongoAPIError {
-
- constructor(message?: string);
- get name(): string;
- }
- export declare class MongoServerError extends MongoError {
- codeName?: string;
- writeConcernError?: Document;
- errInfo?: Document;
- ok?: number;
- [key: string]: any;
-
- constructor(message: ErrorDescription);
- get name(): string;
- }
- export declare class MongoServerSelectionError extends MongoSystemError {
-
- constructor(message: string, reason: TopologyDescription);
- get name(): string;
- }
- export declare class MongoSystemError extends MongoError {
-
- reason?: TopologyDescription;
-
- constructor(message: string, reason: TopologyDescription);
- get name(): string;
- }
- export declare class MongoTailableCursorError extends MongoAPIError {
-
- constructor(message?: string);
- get name(): string;
- }
- export declare class MongoTopologyClosedError extends MongoAPIError {
-
- constructor(message?: string);
- get name(): string;
- }
- export declare class MongoTransactionError extends MongoAPIError {
-
- constructor(message: string);
- get name(): string;
- }
- export declare class MongoUnexpectedServerResponseError extends MongoRuntimeError {
-
- constructor(message: string);
- get name(): string;
- }
- export declare class MongoWriteConcernError extends MongoServerError {
-
- result?: Document;
-
- constructor(message: ErrorDescription, result?: Document);
- get name(): string;
- }
- export declare type MonitorEvents = {
- serverHeartbeatStarted(event: ServerHeartbeatStartedEvent): void;
- serverHeartbeatSucceeded(event: ServerHeartbeatSucceededEvent): void;
- serverHeartbeatFailed(event: ServerHeartbeatFailedEvent): void;
- resetServer(error?: MongoError): void;
- resetConnectionPool(): void;
- close(): void;
- } & EventEmitterWithState;
- export declare interface MonitorOptions extends Omit<ConnectionOptions, 'id' | 'generation' | 'hostAddress'> {
- connectTimeoutMS: number;
- heartbeatFrequencyMS: number;
- minHeartbeatFrequencyMS: number;
- }
- export declare type NestedPaths<Type, Depth extends number[]> = Depth['length'] extends 8 ? [] : Type extends string | number | bigint | boolean | Date | RegExp | Buffer | Uint8Array | ((...args: any[]) => any) | {
- _bsontype: string;
- } ? [] : Type extends ReadonlyArray<infer ArrayType> ? [] | [number, ...NestedPaths<ArrayType, [...Depth, 1]>] : Type extends Map<string, any> ? [string] : Type extends object ? {
- [Key in Extract<keyof Type, string>]: Type[Key] extends Type ? [Key] : Type extends Type[Key] ? [Key] : Type[Key] extends ReadonlyArray<infer ArrayType> ? Type extends ArrayType ? [Key] : ArrayType extends Type ? [Key] : [
- Key,
- ...NestedPaths<Type[Key], [...Depth, 1]>
- ] :
- [
- Key,
- ...NestedPaths<Type[Key], [...Depth, 1]>
- ] | [Key];
- }[Extract<keyof Type, string>] : [];
- export declare type NestedPathsOfType<TSchema, Type> = KeysOfAType<{
- [Property in Join<NestedPaths<TSchema, []>, '.'>]: PropertyType<TSchema, Property>;
- }, Type>;
- export declare type NonObjectIdLikeDocument = {
- [key in keyof ObjectIdLike]?: never;
- } & Document;
- export declare type NotAcceptedFields<TSchema, FieldType> = {
- readonly [key in KeysOfOtherType<TSchema, FieldType>]?: never;
- };
- export declare type NumericType = IntegerType | Decimal128 | Double;
- export { ObjectId }
- export declare interface OIDCCallbackContext {
- refreshToken?: string;
- timeoutSeconds?: number;
- timeoutContext?: AbortSignal;
- version: number;
- }
- export declare type OIDCRefreshFunction = (info: IdPServerInfo, context: OIDCCallbackContext) => Promise<IdPServerResponse>;
- export declare type OIDCRequestFunction = (info: IdPServerInfo, context: OIDCCallbackContext) => Promise<IdPServerResponse>;
- export declare type OneOrMore<T> = T | ReadonlyArray<T>;
- export declare type OnlyFieldsOfType<TSchema, FieldType = any, AssignableType = FieldType> = IsAny<TSchema[keyof TSchema], Record<string, FieldType>, AcceptedFields<TSchema, FieldType, AssignableType> & NotAcceptedFields<TSchema, FieldType> & Record<string, AssignableType>>;
- export declare interface OperationOptions extends BSONSerializeOptions {
-
- session?: ClientSession;
- willRetryWrite?: boolean;
-
- readPreference?: ReadPreferenceLike;
-
- omitReadPreference?: boolean;
- }
- export declare type OperationTime = Timestamp;
- export declare type OptionalId<TSchema> = EnhancedOmit<TSchema, '_id'> & {
- _id?: InferIdType<TSchema>;
- };
- export declare type OptionalUnlessRequiredId<TSchema> = TSchema extends {
- _id: any;
- } ? TSchema : OptionalId<TSchema>;
- export declare class OrderedBulkOperation extends BulkOperationBase {
-
- addToOperationsList(batchType: BatchType, document: Document | UpdateStatement | DeleteStatement): this;
- }
- export declare interface PkFactory {
- createPk(): any;
- }
- export declare const ProfilingLevel: Readonly<{
- readonly off: "off";
- readonly slowOnly: "slow_only";
- readonly all: "all";
- }>;
- export declare type ProfilingLevel = (typeof ProfilingLevel)[keyof typeof ProfilingLevel];
- export declare type ProfilingLevelOptions = CommandOperationOptions;
- export declare type PropertyType<Type, Property extends string> = string extends Property ? unknown : Property extends keyof Type ? Type[Property] : Property extends `${number}` ? Type extends ReadonlyArray<infer ArrayType> ? ArrayType : unknown : Property extends `${infer Key}.${infer Rest}` ? Key extends `${number}` ? Type extends ReadonlyArray<infer ArrayType> ? PropertyType<ArrayType, Rest> : unknown : Key extends keyof Type ? Type[Key] extends Map<string, infer MapType> ? MapType : PropertyType<Type[Key], Rest> : unknown : unknown;
- export declare interface ProxyOptions {
- proxyHost?: string;
- proxyPort?: number;
- proxyUsername?: string;
- proxyPassword?: string;
- }
- export declare type PullAllOperator<TSchema> = ({
- readonly [key in KeysOfAType<TSchema, ReadonlyArray<any>>]?: TSchema[key];
- } & NotAcceptedFields<TSchema, ReadonlyArray<any>>) & {
- readonly [key: string]: ReadonlyArray<any>;
- };
- export declare type PullOperator<TSchema> = ({
- readonly [key in KeysOfAType<TSchema, ReadonlyArray<any>>]?: Partial<Flatten<TSchema[key]>> | FilterOperations<Flatten<TSchema[key]>>;
- } & NotAcceptedFields<TSchema, ReadonlyArray<any>>) & {
- readonly [key: string]: FilterOperators<any> | any;
- };
- export declare type PushOperator<TSchema> = ({
- readonly [key in KeysOfAType<TSchema, ReadonlyArray<any>>]?: Flatten<TSchema[key]> | ArrayOperator<Array<Flatten<TSchema[key]>>>;
- } & NotAcceptedFields<TSchema, ReadonlyArray<any>>) & {
- readonly [key: string]: ArrayOperator<any> | any;
- };
- export declare interface RangeOptions {
- min?: any;
- max?: any;
- sparsity: Long;
- precision?: number;
- }
- export declare class ReadConcern {
- level: ReadConcernLevel | string;
-
- constructor(level: ReadConcernLevel);
-
- static fromOptions(options?: {
- readConcern?: ReadConcernLike;
- level?: ReadConcernLevel;
- }): ReadConcern | undefined;
- static get MAJORITY(): 'majority';
- static get AVAILABLE(): 'available';
- static get LINEARIZABLE(): 'linearizable';
- static get SNAPSHOT(): 'snapshot';
- toJSON(): Document;
- }
- export declare const ReadConcernLevel: Readonly<{
- readonly local: "local";
- readonly majority: "majority";
- readonly linearizable: "linearizable";
- readonly available: "available";
- readonly snapshot: "snapshot";
- }>;
- export declare type ReadConcernLevel = (typeof ReadConcernLevel)[keyof typeof ReadConcernLevel];
- export declare type ReadConcernLike = ReadConcern | {
- level: ReadConcernLevel;
- } | ReadConcernLevel;
- export declare class ReadPreference {
- mode: ReadPreferenceMode;
- tags?: TagSet[];
- hedge?: HedgeOptions;
- maxStalenessSeconds?: number;
- minWireVersion?: number;
- static PRIMARY: "primary";
- static PRIMARY_PREFERRED: "primaryPreferred";
- static SECONDARY: "secondary";
- static SECONDARY_PREFERRED: "secondaryPreferred";
- static NEAREST: "nearest";
- static primary: ReadPreference;
- static primaryPreferred: ReadPreference;
- static secondary: ReadPreference;
- static secondaryPreferred: ReadPreference;
- static nearest: ReadPreference;
-
- constructor(mode: ReadPreferenceMode, tags?: TagSet[], options?: ReadPreferenceOptions);
- get preference(): ReadPreferenceMode;
- static fromString(mode: string): ReadPreference;
-
- static fromOptions(options?: ReadPreferenceFromOptions): ReadPreference | undefined;
-
- static translate(options: ReadPreferenceLikeOptions): ReadPreferenceLikeOptions;
-
- static isValid(mode: string): boolean;
-
- isValid(mode?: string): boolean;
-
- secondaryOk(): boolean;
-
- equals(readPreference: ReadPreference): boolean;
-
- toJSON(): Document;
- }
- export declare interface ReadPreferenceFromOptions extends ReadPreferenceLikeOptions {
- session?: ClientSession;
- readPreferenceTags?: TagSet[];
- hedge?: HedgeOptions;
- }
- export declare type ReadPreferenceLike = ReadPreference | ReadPreferenceMode;
- export declare interface ReadPreferenceLikeOptions extends ReadPreferenceOptions {
- readPreference?: ReadPreferenceLike | {
- mode?: ReadPreferenceMode;
- preference?: ReadPreferenceMode;
- tags?: TagSet[];
- maxStalenessSeconds?: number;
- };
- }
- export declare const ReadPreferenceMode: Readonly<{
- readonly primary: "primary";
- readonly primaryPreferred: "primaryPreferred";
- readonly secondary: "secondary";
- readonly secondaryPreferred: "secondaryPreferred";
- readonly nearest: "nearest";
- }>;
- export declare type ReadPreferenceMode = (typeof ReadPreferenceMode)[keyof typeof ReadPreferenceMode];
- export declare interface ReadPreferenceOptions {
-
- maxStalenessSeconds?: number;
-
- hedge?: HedgeOptions;
- }
- export declare type RegExpOrString<T> = T extends string ? BSONRegExp | RegExp | T : T;
- export declare type RemoveUserOptions = CommandOperationOptions;
- export declare interface RenameOptions extends CommandOperationOptions {
-
- dropTarget?: boolean;
-
- new_collection?: boolean;
- }
- export declare interface ReplaceOneModel<TSchema extends Document = Document> {
-
- filter: Filter<TSchema>;
-
- replacement: WithoutId<TSchema>;
-
- collation?: CollationOptions;
-
- hint?: Hint;
-
- upsert?: boolean;
- }
- export declare interface ReplaceOptions extends CommandOperationOptions {
-
- bypassDocumentValidation?: boolean;
-
- collation?: CollationOptions;
-
- hint?: string | Document;
-
- upsert?: boolean;
-
- let?: Document;
- }
- export declare interface ResumeOptions {
- startAtOperationTime?: Timestamp;
- batchSize?: number;
- maxAwaitTimeMS?: number;
- collation?: CollationOptions;
- readPreference?: ReadPreference;
- resumeAfter?: ResumeToken;
- startAfter?: ResumeToken;
- fullDocument?: string;
- }
- export declare type ResumeToken = unknown;
- export declare const ReturnDocument: Readonly<{
- readonly BEFORE: "before";
- readonly AFTER: "after";
- }>;
- export declare type ReturnDocument = (typeof ReturnDocument)[keyof typeof ReturnDocument];
- export declare interface RootFilterOperators<TSchema> extends Document {
- $and?: Filter<TSchema>[];
- $nor?: Filter<TSchema>[];
- $or?: Filter<TSchema>[];
- $text?: {
- $search: string;
- $language?: string;
- $caseSensitive?: boolean;
- $diacriticSensitive?: boolean;
- };
- $where?: string | ((this: TSchema) => boolean);
- $comment?: string | Document;
- }
- export declare class RunCommandCursor extends AbstractCursor {
- readonly command: Readonly<Record<string, any>>;
- readonly getMoreOptions: {
- comment?: any;
- maxAwaitTimeMS?: number;
- batchSize?: number;
- };
-
- setComment(comment: any): this;
-
- setMaxTimeMS(maxTimeMS: number): this;
-
- setBatchSize(batchSize: number): this;
-
- clone(): never;
-
- withReadConcern(_: ReadConcernLike): never;
-
- addCursorFlag(_: string, __: boolean): never;
-
- maxTimeMS(_: number): never;
-
- batchSize(_: number): never;
-
-
-
-
- }
- export declare type RunCommandOptions = {
-
- session?: ClientSession;
-
- readPreference?: ReadPreferenceLike;
- } & BSONSerializeOptions;
- export declare type RunCursorCommandOptions = {
- readPreference?: ReadPreferenceLike;
- session?: ClientSession;
- } & BSONSerializeOptions;
- export declare type SchemaMember<T, V> = {
- [P in keyof T]?: V;
- } | {
- [key: string]: V;
- };
- export declare interface SearchIndexDescription {
-
- name?: string;
-
- definition: Document;
- }
- export declare interface SelectServerOptions {
- readPreference?: ReadPreferenceLike;
-
- serverSelectionTimeoutMS?: number;
- session?: ClientSession;
- }
- export { serialize }
- export declare interface ServerApi {
- version: ServerApiVersion;
- strict?: boolean;
- deprecationErrors?: boolean;
- }
- export declare const ServerApiVersion: Readonly<{
- readonly v1: "1";
- }>;
- export declare type ServerApiVersion = (typeof ServerApiVersion)[keyof typeof ServerApiVersion];
- export declare class ServerCapabilities {
- maxWireVersion: number;
- minWireVersion: number;
- constructor(hello: Document);
- get hasAggregationCursor(): boolean;
- get hasWriteCommands(): boolean;
- get hasTextSearch(): boolean;
- get hasAuthCommands(): boolean;
- get hasListCollectionsCommand(): boolean;
- get hasListIndexesCommand(): boolean;
- get supportsSnapshotReads(): boolean;
- get commandsTakeWriteConcern(): boolean;
- get commandsTakeCollation(): boolean;
- }
- export declare class ServerClosedEvent {
-
- topologyId: number;
-
- address: string;
-
- }
- export declare class ServerDescription {
- address: string;
- type: ServerType;
- hosts: string[];
- passives: string[];
- arbiters: string[];
- tags: TagSet;
- error: MongoError | null;
- topologyVersion: TopologyVersion | null;
- minWireVersion: number;
- maxWireVersion: number;
- roundTripTime: number;
- lastUpdateTime: number;
- lastWriteDate: number;
- me: string | null;
- primary: string | null;
- setName: string | null;
- setVersion: number | null;
- electionId: ObjectId | null;
- logicalSessionTimeoutMinutes: number | null;
- $clusterTime?: ClusterTime;
-
- get hostAddress(): HostAddress;
- get allHosts(): string[];
-
- get isReadable(): boolean;
-
- get isDataBearing(): boolean;
-
- get isWritable(): boolean;
- get host(): string;
- get port(): number;
-
- equals(other?: ServerDescription | null): boolean;
- }
- export declare class ServerDescriptionChangedEvent {
-
- topologyId: number;
-
- address: string;
-
- previousDescription: ServerDescription;
-
- newDescription: ServerDescription;
-
- }
- export declare type ServerEvents = {
- serverHeartbeatStarted(event: ServerHeartbeatStartedEvent): void;
- serverHeartbeatSucceeded(event: ServerHeartbeatSucceededEvent): void;
- serverHeartbeatFailed(event: ServerHeartbeatFailedEvent): void;
-
- descriptionReceived(description: ServerDescription): void;
- closed(): void;
- ended(): void;
- } & ConnectionPoolEvents & EventEmitterWithState;
- export declare class ServerHeartbeatFailedEvent {
-
- connectionId: string;
-
- duration: number;
-
- failure: Error;
-
- awaited: boolean;
-
- }
- export declare class ServerHeartbeatStartedEvent {
-
- connectionId: string;
-
- awaited: boolean;
-
- }
- export declare class ServerHeartbeatSucceededEvent {
-
- connectionId: string;
-
- duration: number;
-
- reply: Document;
-
- awaited: boolean;
-
- }
- export declare class ServerOpeningEvent {
-
- topologyId: number;
-
- address: string;
-
- }
- export declare class ServerSession {
- id: ServerSessionId;
- lastUse: number;
- txnNumber: number;
- isDirty: boolean;
-
-
- hasTimedOut(sessionTimeoutMinutes: number): boolean;
-
- }
- export declare type ServerSessionId = {
- id: Binary;
- };
- export declare const ServerType: Readonly<{
- readonly Standalone: "Standalone";
- readonly Mongos: "Mongos";
- readonly PossiblePrimary: "PossiblePrimary";
- readonly RSPrimary: "RSPrimary";
- readonly RSSecondary: "RSSecondary";
- readonly RSArbiter: "RSArbiter";
- readonly RSOther: "RSOther";
- readonly RSGhost: "RSGhost";
- readonly Unknown: "Unknown";
- readonly LoadBalancer: "LoadBalancer";
- }>;
- export declare type ServerType = (typeof ServerType)[keyof typeof ServerType];
- export declare type SetFields<TSchema> = ({
- readonly [key in KeysOfAType<TSchema, ReadonlyArray<any> | undefined>]?: OptionalId<Flatten<TSchema[key]>> | AddToSetOperators<Array<OptionalId<Flatten<TSchema[key]>>>>;
- } & NotAcceptedFields<TSchema, ReadonlyArray<any> | undefined>) & {
- readonly [key: string]: AddToSetOperators<any> | any;
- };
- export declare type SetProfilingLevelOptions = CommandOperationOptions;
- export declare type Sort = string | Exclude<SortDirection, {
- $meta: string;
- }> | string[] | {
- [key: string]: SortDirection;
- } | Map<string, SortDirection> | [string, SortDirection][] | [string, SortDirection];
- export declare type SortDirection = 1 | -1 | 'asc' | 'desc' | 'ascending' | 'descending' | {
- $meta: string;
- };
- export declare type Stream = Socket | TLSSocket;
- export declare class StreamDescription {
- address: string;
- type: string;
- minWireVersion?: number;
- maxWireVersion?: number;
- maxBsonObjectSize: number;
- maxMessageSizeBytes: number;
- maxWriteBatchSize: number;
- compressors: CompressorName[];
- compressor?: CompressorName;
- logicalSessionTimeoutMinutes?: number;
- loadBalanced: boolean;
- __nodejs_mock_server__?: boolean;
- zlibCompressionLevel?: number;
- constructor(address: string, options?: StreamDescriptionOptions);
- receiveResponse(response: Document | null): void;
- }
- export declare interface StreamDescriptionOptions {
- compressors?: CompressorName[];
- logicalSessionTimeoutMinutes?: number;
- loadBalanced: boolean;
- }
- export declare type StrictFilter<TSchema> = Partial<TSchema> | ({
- [Property in Join<NestedPaths<WithId<TSchema>, []>, '.'>]?: Condition<PropertyType<WithId<TSchema>, Property>>;
- } & RootFilterOperators<WithId<TSchema>>);
- export declare type StrictMatchKeysAndValues<TSchema> = Readonly<{
- [Property in Join<NestedPaths<TSchema, []>, '.'>]?: PropertyType<TSchema, Property>;
- } & {
- [Property in `${NestedPathsOfType<TSchema, any[]>}.$${`[${string}]` | ''}`]?: ArrayElement<PropertyType<TSchema, Property extends `${infer Key}.$${string}` ? Key : never>>;
- } & {
- [Property in `${NestedPathsOfType<TSchema, Record<string, any>[]>}.$${`[${string}]` | ''}.${string}`]?: any;
- } & Document>;
- export declare type StrictUpdateFilter<TSchema> = {
- $currentDate?: OnlyFieldsOfType<TSchema, Date | Timestamp, true | {
- $type: 'date' | 'timestamp';
- }>;
- $inc?: OnlyFieldsOfType<TSchema, NumericType | undefined>;
- $min?: StrictMatchKeysAndValues<TSchema>;
- $max?: StrictMatchKeysAndValues<TSchema>;
- $mul?: OnlyFieldsOfType<TSchema, NumericType | undefined>;
- $rename?: Record<string, string>;
- $set?: StrictMatchKeysAndValues<TSchema>;
- $setOnInsert?: StrictMatchKeysAndValues<TSchema>;
- $unset?: OnlyFieldsOfType<TSchema, any, '' | true | 1>;
- $addToSet?: SetFields<TSchema>;
- $pop?: OnlyFieldsOfType<TSchema, ReadonlyArray<any>, 1 | -1>;
- $pull?: PullOperator<TSchema>;
- $push?: PushOperator<TSchema>;
- $pullAll?: PullAllOperator<TSchema>;
- $bit?: OnlyFieldsOfType<TSchema, NumericType | undefined, {
- and: IntegerType;
- } | {
- or: IntegerType;
- } | {
- xor: IntegerType;
- }>;
- } & Document;
- export declare type SupportedNodeConnectionOptions = SupportedTLSConnectionOptions & SupportedTLSSocketOptions & SupportedSocketOptions;
- export declare type SupportedSocketOptions = Pick<TcpNetConnectOpts, (typeof LEGAL_TCP_SOCKET_OPTIONS)[number]>;
- export declare type SupportedTLSConnectionOptions = Pick<ConnectionOptions_2, Extract<keyof ConnectionOptions_2, (typeof LEGAL_TLS_SOCKET_OPTIONS)[number]>>;
- export declare type SupportedTLSSocketOptions = Pick<TLSSocketOptions, Extract<keyof TLSSocketOptions, (typeof LEGAL_TLS_SOCKET_OPTIONS)[number]>>;
- export declare type TagSet = {
- [key: string]: string;
- };
- export declare interface TimeSeriesCollectionOptions extends Document {
- timeField: string;
- metaField?: string;
- granularity?: 'seconds' | 'minutes' | 'hours' | string;
- bucketMaxSpanSeconds?: number;
- bucketRoundingSeconds?: number;
- }
- export { Timestamp }
- export declare class TopologyClosedEvent {
-
- topologyId: number;
-
- }
- export declare class TopologyDescription {
- type: TopologyType;
- setName: string | null;
- maxSetVersion: number | null;
- maxElectionId: ObjectId | null;
- servers: Map<string, ServerDescription>;
- stale: boolean;
- compatible: boolean;
- compatibilityError?: string;
- logicalSessionTimeoutMinutes: number | null;
- heartbeatFrequencyMS: number;
- localThresholdMS: number;
- commonWireVersion: number;
-
- constructor(topologyType: TopologyType, serverDescriptions?: Map<string, ServerDescription> | null, setName?: string | null, maxSetVersion?: number | null, maxElectionId?: ObjectId | null, commonWireVersion?: number | null, options?: TopologyDescriptionOptions | null);
-
-
- get error(): MongoServerError | null;
-
- get hasKnownServers(): boolean;
-
- get hasDataBearingServers(): boolean;
-
- }
- export declare class TopologyDescriptionChangedEvent {
-
- topologyId: number;
-
- previousDescription: TopologyDescription;
-
- newDescription: TopologyDescription;
-
- }
- export declare interface TopologyDescriptionOptions {
- heartbeatFrequencyMS?: number;
- localThresholdMS?: number;
- }
- export declare type TopologyEvents = {
-
- serverOpening(event: ServerOpeningEvent): void;
- serverClosed(event: ServerClosedEvent): void;
- serverDescriptionChanged(event: ServerDescriptionChangedEvent): void;
- topologyClosed(event: TopologyClosedEvent): void;
- topologyOpening(event: TopologyOpeningEvent): void;
- topologyDescriptionChanged(event: TopologyDescriptionChangedEvent): void;
- error(error: Error): void;
-
- close(): void;
- timeout(): void;
- } & Omit<ServerEvents, 'connect'> & ConnectionPoolEvents & ConnectionEvents & EventEmitterWithState;
- export declare class TopologyOpeningEvent {
-
- topologyId: number;
-
- }
- export declare const TopologyType: Readonly<{
- readonly Single: "Single";
- readonly ReplicaSetNoPrimary: "ReplicaSetNoPrimary";
- readonly ReplicaSetWithPrimary: "ReplicaSetWithPrimary";
- readonly Sharded: "Sharded";
- readonly Unknown: "Unknown";
- readonly LoadBalanced: "LoadBalanced";
- }>;
- export declare type TopologyType = (typeof TopologyType)[keyof typeof TopologyType];
- export declare interface TopologyVersion {
- processId: ObjectId;
- counter: Long;
- }
- export declare class Transaction {
-
- options: TransactionOptions;
-
-
-
-
- get recoveryToken(): Document | undefined;
- get isPinned(): boolean;
-
- get isStarting(): boolean;
-
- get isActive(): boolean;
- get isCommitted(): boolean;
-
-
-
- }
- export declare interface TransactionOptions extends CommandOperationOptions {
-
- readConcern?: ReadConcernLike;
-
- writeConcern?: WriteConcern;
-
- readPreference?: ReadPreferenceLike;
-
- maxCommitTimeMS?: number;
- }
- export declare interface TypedEventEmitter<Events extends EventsDescription> extends EventEmitter {
- addListener<EventKey extends keyof Events>(event: EventKey, listener: Events[EventKey]): this;
- addListener(event: CommonEvents, listener: (eventName: string | symbol, listener: GenericListener) => void): this;
- addListener(event: string | symbol, listener: GenericListener): this;
- on<EventKey extends keyof Events>(event: EventKey, listener: Events[EventKey]): this;
- on(event: CommonEvents, listener: (eventName: string | symbol, listener: GenericListener) => void): this;
- on(event: string | symbol, listener: GenericListener): this;
- once<EventKey extends keyof Events>(event: EventKey, listener: Events[EventKey]): this;
- once(event: CommonEvents, listener: (eventName: string | symbol, listener: GenericListener) => void): this;
- once(event: string | symbol, listener: GenericListener): this;
- removeListener<EventKey extends keyof Events>(event: EventKey, listener: Events[EventKey]): this;
- removeListener(event: CommonEvents, listener: (eventName: string | symbol, listener: GenericListener) => void): this;
- removeListener(event: string | symbol, listener: GenericListener): this;
- off<EventKey extends keyof Events>(event: EventKey, listener: Events[EventKey]): this;
- off(event: CommonEvents, listener: (eventName: string | symbol, listener: GenericListener) => void): this;
- off(event: string | symbol, listener: GenericListener): this;
- removeAllListeners<EventKey extends keyof Events>(event?: EventKey | CommonEvents | symbol | string): this;
- listeners<EventKey extends keyof Events>(event: EventKey | CommonEvents | symbol | string): Events[EventKey][];
- rawListeners<EventKey extends keyof Events>(event: EventKey | CommonEvents | symbol | string): Events[EventKey][];
- emit<EventKey extends keyof Events>(event: EventKey | symbol, ...args: Parameters<Events[EventKey]>): boolean;
- listenerCount<EventKey extends keyof Events>(type: EventKey | CommonEvents | symbol | string): number;
- prependListener<EventKey extends keyof Events>(event: EventKey, listener: Events[EventKey]): this;
- prependListener(event: CommonEvents, listener: (eventName: string | symbol, listener: GenericListener) => void): this;
- prependListener(event: string | symbol, listener: GenericListener): this;
- prependOnceListener<EventKey extends keyof Events>(event: EventKey, listener: Events[EventKey]): this;
- prependOnceListener(event: CommonEvents, listener: (eventName: string | symbol, listener: GenericListener) => void): this;
- prependOnceListener(event: string | symbol, listener: GenericListener): this;
- eventNames(): string[];
- getMaxListeners(): number;
- setMaxListeners(n: number): this;
- }
- export declare class TypedEventEmitter<Events extends EventsDescription> extends EventEmitter {
-
-
-
- }
- export declare class UnorderedBulkOperation extends BulkOperationBase {
-
- handleWriteError(callback: Callback, writeResult: BulkWriteResult): boolean;
- addToOperationsList(batchType: BatchType, document: Document | UpdateStatement | DeleteStatement): this;
- }
- export declare interface UpdateDescription<TSchema extends Document = Document> {
-
- updatedFields?: Partial<TSchema>;
-
- removedFields?: string[];
-
- truncatedArrays?: Array<{
-
- field: string;
-
- newSize: number;
- }>;
-
- disambiguatedPaths?: Document;
- }
- export declare type UpdateFilter<TSchema> = {
- $currentDate?: OnlyFieldsOfType<TSchema, Date | Timestamp, true | {
- $type: 'date' | 'timestamp';
- }>;
- $inc?: OnlyFieldsOfType<TSchema, NumericType | undefined>;
- $min?: MatchKeysAndValues<TSchema>;
- $max?: MatchKeysAndValues<TSchema>;
- $mul?: OnlyFieldsOfType<TSchema, NumericType | undefined>;
- $rename?: Record<string, string>;
- $set?: MatchKeysAndValues<TSchema>;
- $setOnInsert?: MatchKeysAndValues<TSchema>;
- $unset?: OnlyFieldsOfType<TSchema, any, '' | true | 1>;
- $addToSet?: SetFields<TSchema>;
- $pop?: OnlyFieldsOfType<TSchema, ReadonlyArray<any>, 1 | -1>;
- $pull?: PullOperator<TSchema>;
- $push?: PushOperator<TSchema>;
- $pullAll?: PullAllOperator<TSchema>;
- $bit?: OnlyFieldsOfType<TSchema, NumericType | undefined, {
- and: IntegerType;
- } | {
- or: IntegerType;
- } | {
- xor: IntegerType;
- }>;
- } & Document;
- export declare interface UpdateManyModel<TSchema extends Document = Document> {
-
- filter: Filter<TSchema>;
-
- update: UpdateFilter<TSchema> | UpdateFilter<TSchema>[];
-
- arrayFilters?: Document[];
-
- collation?: CollationOptions;
-
- hint?: Hint;
-
- upsert?: boolean;
- }
- export declare interface UpdateOneModel<TSchema extends Document = Document> {
-
- filter: Filter<TSchema>;
-
- update: UpdateFilter<TSchema> | UpdateFilter<TSchema>[];
-
- arrayFilters?: Document[];
-
- collation?: CollationOptions;
-
- hint?: Hint;
-
- upsert?: boolean;
- }
- export declare interface UpdateOptions extends CommandOperationOptions {
-
- arrayFilters?: Document[];
-
- bypassDocumentValidation?: boolean;
-
- collation?: CollationOptions;
-
- hint?: Hint;
-
- upsert?: boolean;
-
- let?: Document;
- }
- export declare interface UpdateResult<TSchema extends Document = Document> {
-
- acknowledged: boolean;
-
- matchedCount: number;
-
- modifiedCount: number;
-
- upsertedCount: number;
-
- upsertedId: InferIdType<TSchema> | null;
- }
- export declare interface UpdateStatement {
-
- q: Document;
-
- u: Document | Document[];
-
- upsert?: boolean;
-
- multi?: boolean;
-
- collation?: CollationOptions;
-
- arrayFilters?: Document[];
-
- hint?: Hint;
- }
- export { UUID }
- export declare interface ValidateCollectionOptions extends CommandOperationOptions {
-
- background?: boolean;
- }
- export declare type W = number | 'majority';
- export declare type WithId<TSchema> = EnhancedOmit<TSchema, '_id'> & {
- _id: InferIdType<TSchema>;
- };
- export declare type WithoutId<TSchema> = Omit<TSchema, '_id'>;
- export declare type WithSessionCallback<T = unknown> = (session: ClientSession) => Promise<T>;
- export declare type WithTransactionCallback<T = any> = (session: ClientSession) => Promise<T>;
- export declare class WriteConcern {
-
- readonly w?: W;
-
- readonly journal?: boolean;
-
- readonly wtimeoutMS?: number;
-
- wtimeout?: number;
-
- j?: boolean;
-
- fsync?: boolean | 1;
-
- constructor(w?: W, wtimeoutMS?: number, journal?: boolean, fsync?: boolean | 1);
-
- static apply(command: Document, writeConcern: WriteConcern): Document;
-
- static fromOptions(options?: WriteConcernOptions | WriteConcern | W, inherit?: WriteConcernOptions | WriteConcern): WriteConcern | undefined;
- }
- export declare class WriteConcernError {
-
- constructor(error: WriteConcernErrorData);
-
- get code(): number | undefined;
-
- get errmsg(): string | undefined;
-
- get errInfo(): Document | undefined;
- toJSON(): WriteConcernErrorData;
- toString(): string;
- }
- export declare interface WriteConcernErrorData {
- code: number;
- errmsg: string;
- errInfo?: Document;
- }
- export declare interface WriteConcernOptions {
-
- writeConcern?: WriteConcern | WriteConcernSettings;
- }
- export declare interface WriteConcernSettings {
-
- w?: W;
-
- wtimeoutMS?: number;
-
- journal?: boolean;
-
- j?: boolean;
-
- wtimeout?: number;
-
- fsync?: boolean | 1;
- }
- export declare class WriteError {
- err: BulkWriteOperationError;
- constructor(err: BulkWriteOperationError);
-
- get code(): number;
-
- get index(): number;
-
- get errmsg(): string | undefined;
-
- get errInfo(): Document | undefined;
-
- getOperation(): Document;
- toJSON(): {
- code: number;
- index: number;
- errmsg?: string;
- op: Document;
- };
- toString(): string;
- }
- export { }
|