Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

wiremessage

package

Go to main page

Versions in this module

v1

v1.2.1

Jan 8, 2020

v1.2.0

Dec 10, 2019

Changes in this version

+ const DefaultZstdLevel

type CompressorID

+ const CompressorZstd

v1.1.4

Dec 17, 2019

v1.1.3

Nov 5, 2019

v1.1.2

Oct 7, 2019

v1.1.1

Sep 5, 2019

v1.1.0

Aug 13, 2019

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