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

mongowire

package

Go to main page

Versions in this module

v0

v0.0.8

Jun 5, 2023

v0.0.7

Jun 5, 2023

v0.0.6

Oct 4, 2022

v0.0.5

Sep 29, 2022

v0.0.4

Sep 21, 2022

v0.0.3

Sep 14, 2022

v0.0.2

Aug 10, 2022

v0.0.1

Jun 2, 2022

Changes in this version

+ const HeaderLen

+ const OpCompressed

+ const OpDelete

+ const OpGetMore

+ const OpInsert

+ const OpKillCursors

+ const OpMessage

+ const OpMsg

+ const OpQuery

+ const OpReply

+ const OpUpdate

+ const Reserved

+ func MustReadInt32(r io.Reader) (n int32)

+ func MustReadInt64(r io.Reader) (n int64)

+ func MustReadUInt32(r io.Reader) (n uint32)

+ func MustReadUInt8(r io.Reader) (n uint8)

+ func ReadBytes(r io.Reader, n int) []byte

+ func ReadCString(r io.Reader) string

+ func ReadDocument(r io.Reader) (m bson.D)

+ func ReadDocuments(r io.Reader) (ms []bson.D)

+ func ReadInt32(r io.Reader) (n int32, err error)

+ func ReadInt64(r io.Reader) *int64

+ func ReadOne(r io.Reader) []byte

+ func ToJson(v interface{}, l int) string

+ type CountingReader struct

+ BytesRead int

+ func (r *CountingReader) Read(p []byte) (n int, err error)

+ type Crc32c struct

+ func (c *Crc32c) CheckCrc(crc uint32) bool

+ func (c *Crc32c) GetCrc() uint32

+ func (c *Crc32c) Init()

+ func (c *Crc32c) String() string

+ func (c *Crc32c) UpdateCrc(msg []byte)

+ func (c *Crc32c) Write(msg []byte) (int, error)

+ type MSGSection interface

+ MSGSection func()

+ type MSGSection_Body struct

+ Document bson.D

+ func (MSGSection_Body) MSGSection()

+ type MSGSection_DocumentSequence struct

+ Documents []bson.D

+ SequenceIdentifier string

+ Size int32

+ func (MSGSection_DocumentSequence) MSGSection()

+ type MessageHeader struct

+ MessageLength int32

+ OpCode OpCode

+ RequestID int32

+ ResponseTo int32

+ func ReadHeader(r io.Reader) (*MessageHeader, error)

+ func (m *MessageHeader) FromWire(b []byte)

+ func (m *MessageHeader) String() string

+ func (m *MessageHeader) WriteTo(w io.Writer) error

+ func (m MessageHeader) ToWire() ([]byte, error)

+ type OP_COMPRESSED struct

+ CompressedMessage []byte

+ CompressorID wiremessage.CompressorID

+ Header MessageHeader

+ OriginalOpcode OpCode

+ UncompressedSize int32

+ func (m *OP_COMPRESSED) GetHeader() MessageHeader

+ func (o *OP_COMPRESSED) FromWire(r io.Reader) error

+ func (o *OP_COMPRESSED) ToWire() ([]byte, error)

+ func (o *OP_COMPRESSED) WriteTo(w io.Writer) error

+ type OP_GETMORE struct

+ CursorID int64

+ Flags int32

+ FullCollectionName string

+ Header MessageHeader

+ NumberToReturn int32

+ func (m *OP_GETMORE) FromWire(r io.Reader)

+ func (m *OP_GETMORE) GetHeader() MessageHeader

+ type OP_KILL_CURSORS struct

+ CursorIDs []int64

+ Header MessageHeader

+ NumberOfCursorIDs int32

+ ZERO int32

+ func (m *OP_KILL_CURSORS) FromWire(r io.Reader)

+ func (m *OP_KILL_CURSORS) GetHeader() MessageHeader

+ type OP_MSG struct

+ Checksum uint32

+ Flags OP_MSG_Flags

+ Header MessageHeader

+ Sections []MSGSection

+ func (m *OP_MSG) GetHeader() MessageHeader

+ func (o *OP_MSG) FromWire(r io.Reader, crc *Crc32c, msgLen int) error

+ func (o *OP_MSG) ToWire() ([]byte, error)

+ func (o *OP_MSG) WriteTo(w io.Writer) error

+ type OP_MSG_Flags int32

+ func (f OP_MSG_Flags) ChecksumPresent() bool

+ func (f OP_MSG_Flags) MoreToCome() bool

+ type OP_QUERY struct

+ Flags OP_QUERY_Flags

+ FullCollectionName string

+ Header MessageHeader

+ NumberToReturn int32

+ NumberToSkip int32

+ Query bson.D

+ ReturnFieldsSelector bson.D

+ func (m *OP_QUERY) FromWire(r io.Reader)

+ func (m *OP_QUERY) GetHeader() MessageHeader

+ type OP_QUERY_Flags int32

+ func (f OP_QUERY_Flags) AwaitData() bool

+ func (f OP_QUERY_Flags) Exhaust() bool

+ func (f OP_QUERY_Flags) NoCursorTimeout() bool

+ func (f OP_QUERY_Flags) OplogReplay() bool

+ func (f OP_QUERY_Flags) Partial() bool

+ func (f OP_QUERY_Flags) SlaveOk() bool

+ func (f OP_QUERY_Flags) TailableCursor() bool

+ type OP_REPLY struct

+ CursorID int64

+ Documents []bson.D

+ Flags int32

+ Header MessageHeader

+ NumberReturned int32

+ StartingFrom int32

+ func (m *OP_REPLY) GetHeader() MessageHeader

+ func (o *OP_REPLY) ToWire() ([]byte, error)

+ func (o *OP_REPLY) WriteTo(w io.Writer) error

+ type OpCode int32

+ func (c OpCode) HasResponse() bool

+ func (c OpCode) IsMutation() bool

+ func (c OpCode) String() string

+ type Request struct

+ func NewRequest(c io.Reader) (*Request, error)

+ func NewRequestWithHeader(h MessageHeader, c io.Reader) *Request

+ func (req *Request) GetHeader() *MessageHeader

+ func (req *Request) GetOpCompressed() *OP_COMPRESSED

+ func (req *Request) GetOpKillCursors() *OP_KILL_CURSORS

+ func (req *Request) GetOpMore() *OP_GETMORE

+ func (req *Request) GetOpMsg() *OP_MSG

+ func (req *Request) GetOpQuery() *OP_QUERY

+ type WireSerializer interface

+ GetHeader func() MessageHeader

+ WriteTo func(io.Writer) error