wiremessage

Jul 14, 2022

retracted

Changes in this version

type CompressorID

+ func (id CompressorID) String() string

Nov 23, 2021

Changes in this version

type QueryFlag

+ const SecondaryOK

Mar 9, 2021 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Dec 16, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Mar 9, 2021 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Feb 2, 2021 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Jan 19, 2021 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Dec 1, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Nov 3, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Oct 7, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Sep 1, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Jul 30, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Changes in this version

+ func ReadMsgSectionRawDocumentSequence(src []byte) (identifier string, data []byte, rem []byte, ok bool)

Jul 13, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Jun 9, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Apr 10, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Aug 10, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Aug 4, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Jul 8, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Jun 3, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

May 5, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Apr 7, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Mar 3, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Feb 5, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Jan 8, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Dec 10, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Changes in this version

+ const DefaultZstdLevel

type CompressorID

+ const CompressorZstd

Dec 17, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Nov 5, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Oct 7, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Sep 5, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Aug 13, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

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