Versions in this module Expand all Collapse all v1 v1.1.0 May 26, 2022 v1.0.0 May 26, 2022 Changes in this version + const DefaultZlibLevel + const OpmsgWireVersion + func AppendCompressedCompressedMessage(dst []byte, msg []byte) []byte + func AppendCompressedCompressorID(dst []byte, id CompressorID) []byte + func AppendCompressedOriginalOpCode(dst []byte, opcode OpCode) []byte + func AppendCompressedUncompressedSize(dst []byte, size int32) []byte + func AppendGetMoreCursorID(dst []byte, cursorID int64) []byte + func AppendGetMoreFullCollectionName(dst []byte, ns string) []byte + func AppendGetMoreNumberToReturn(dst []byte, numToReturn int32) []byte + func AppendGetMoreZero(dst []byte) []byte + func AppendHeader(dst []byte, length, reqid, respto int32, opcode OpCode) []byte + func AppendHeaderStart(dst []byte, reqid, respto int32, opcode OpCode) (index int32, b []byte) + func AppendKillCursorsCursorIDs(dst []byte, cursors []int64) []byte + func AppendKillCursorsNumberIDs(dst []byte, numIDs int32) []byte + func AppendKillCursorsZero(dst []byte) []byte + func AppendMsgFlags(dst []byte, flags MsgFlag) []byte + func AppendMsgSectionType(dst []byte, stype SectionType) []byte + func AppendQueryFlags(dst []byte, flags QueryFlag) []byte + func AppendQueryFullCollectionName(dst []byte, ns string) []byte + func AppendQueryNumberToReturn(dst []byte, nor int32) []byte + func AppendQueryNumberToSkip(dst []byte, skip int32) []byte + func AppendReplyCursorID(dst []byte, id int64) []byte + func AppendReplyFlags(dst []byte, flags ReplyFlag) []byte + func AppendReplyNumberReturned(dst []byte, nr int32) []byte + func AppendReplyStartingFrom(dst []byte, sf int32) []byte + func CurrentRequestID() int32 + func IsMsgMoreToCome(wm []byte) bool + func NextRequestID() int32 + func ReadCompressedCompressedMessage(src []byte, length int32) (msg []byte, rem []byte, ok bool) + func ReadCompressedUncompressedSize(src []byte) (size int32, rem []byte, ok bool) + func ReadKillCursorsCursorIDs(src []byte, numIDs int32) (cursorIDs []int64, rem []byte, ok bool) + func ReadKillCursorsNumberIDs(src []byte) (numIDs int32, rem []byte, ok bool) + func ReadKillCursorsZero(src []byte) (zero int32, rem []byte, ok bool) + func ReadMsgChecksum(src []byte) (checksum uint32, rem []byte, ok bool) + func ReadMsgSectionDocumentSequence(src []byte) (identifier string, docs []bsoncore.Document, rem []byte, ok bool) + func ReadMsgSectionSingleDocument(src []byte) (doc bsoncore.Document, rem []byte, ok bool) + func ReadQueryFullCollectionName(src []byte) (collname string, rem []byte, ok bool) + func ReadQueryNumberToReturn(src []byte) (ntr int32, rem []byte, ok bool) + func ReadQueryNumberToSkip(src []byte) (nts int32, rem []byte, ok bool) + func ReadQueryQuery(src []byte) (query bsoncore.Document, rem []byte, ok bool) + func ReadQueryReturnFieldsSelector(src []byte) (rfs bsoncore.Document, rem []byte, ok bool) + func ReadReplyCursorID(src []byte) (cursorID int64, rem []byte, ok bool) + func ReadReplyDocument(src []byte) (doc bsoncore.Document, rem []byte, ok bool) + func ReadReplyDocuments(src []byte) (docs []bsoncore.Document, rem []byte, ok bool) + func ReadReplyNumberReturned(src []byte) (numberReturned int32, rem []byte, ok bool) + func ReadReplyStartingFrom(src []byte) (startingFrom int32, rem []byte, ok bool) + type CompressorID uint8 + const CompressorNoOp + const CompressorSnappy + const CompressorZLib + func ReadCompressedCompressorID(src []byte) (id CompressorID, rem []byte, ok bool) + type MsgFlag uint32 + const ChecksumPresent + const ExhaustAllowed + const MoreToCome + func ReadMsgFlags(src []byte) (flags MsgFlag, rem []byte, ok bool) + type OpCode int32 + const OpCommand + const OpCommandReply + const OpCompressed + const OpDelete + const OpGetMore + const OpInsert + const OpKillCursors + const OpMsg + const OpQuery + const OpReply + const OpUpdate + func ReadCompressedOriginalOpCode(src []byte) (opcode OpCode, rem []byte, ok bool) + func ReadHeader(src []byte) (length, requestID, responseTo int32, opcode OpCode, rem []byte, ok bool) + func (oc OpCode) String() string + type QueryFlag int32 + const AwaitData + const Exhaust + const NoCursorTimeout + const OplogReplay + const Partial + const SlaveOK + const TailableCursor + func ReadQueryFlags(src []byte) (flags QueryFlag, rem []byte, ok bool) + func (qf QueryFlag) String() string + type ReplyFlag int32 + const AwaitCapable + const CursorNotFound + const QueryFailure + const ShardConfigStale + func ReadReplyFlags(src []byte) (flags ReplyFlag, rem []byte, ok bool) + func (rf ReplyFlag) String() string + type SectionType uint8 + const DocumentSequence + const SingleDocument + func ReadMsgSectionType(src []byte) (stype SectionType, rem []byte, ok bool) + type WireMessage []byte
Go to main page