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.0.1

Apr 18, 2019

v1.0.0

Mar 13, 2019

v1.0.0-rc2

Mar 7, 2019

v1.0.0-rc1

Feb 22, 2019

v0

v0.3.0

Feb 1, 2019

v0.2.0

Jan 8, 2019

Changes in this version

type GetMore

+ Zero int32

+ func (gm GetMore) CommandDocument() bsonx.Doc

+ func (gm GetMore) DatabaseName() string

type KillCursors

+ CollectionName string

+ DatabaseName string

+ Zero int32

+ func (kc KillCursors) CommandDocument() bsonx.Doc

type Query

+ BatchSize *int32

+ Limit *int32

+ SkipSet bool

+ func (q Query) CollectionName() string

+ func (q Query) CommandDocument() (bsonx.Doc, error)

+ func (q Query) DatabaseName() string

+ func (q Query) Legacy() bool

type Reply

+ func (r *Reply) GetMainLegacyDocument(fullCollectionName string) (bsonx.Doc, error)

v0.1.0

Dec 6, 2018

Changes in this version

+ const DefaultZlibLevel

+ const OpmsgWireVersion

+ var ErrHeaderIncorrectOpCode error = Error

+ var ErrHeaderInvalidLength error = Error

+ var ErrHeaderTooFewBytes error = Error

+ var ErrHeaderTooSmall error = Error

+ var ErrInvalidHeader error = Error

+ var ErrInvalidMessageLength = errors.New("the message length is too small, it must be at least 16")

+ var ErrUnknownOpCode = errors.New("the opcode is unknown")

+ func CurrentRequestID() int32

+ func NextRequestID() int32

+ func Validate([]byte) error

+ type Appender interface

+ AppendWireMessage func([]byte) ([]byte, error)

+ type Command struct

+ CommandArgs string

+ CommandName string

+ Database string

+ InputDocs []bson.Raw

+ Metadata string

+ MsgHeader Header

+ func (c *Command) UnmarshalWireMessage([]byte) error

+ func (c Command) AppendWireMessage([]byte) ([]byte, error)

+ func (c Command) Len() int

+ func (c Command) MarshalWireMessage() ([]byte, error)

+ func (c Command) String() string

+ func (c Command) ValidateWireMessage() error

+ type CommandReply struct

+ CommandReply bson.Raw

+ Metadata bson.Raw

+ MsgHeader Header

+ OutputDocs []bson.Raw

+ func (cr *CommandReply) UnmarshalWireMessage([]byte) error

+ func (cr CommandReply) AppendWireMessage([]byte) ([]byte, error)

+ func (cr CommandReply) Len() int

+ func (cr CommandReply) MarshalWireMessage() ([]byte, error)

+ func (cr CommandReply) String() string

+ func (cr CommandReply) ValidateWireMessage() error

+ type Compressed struct

+ CompressedMessage []byte

+ CompressorID CompressorID

+ MsgHeader Header

+ OriginalOpCode OpCode

+ UncompressedSize int32

+ func (c *Compressed) UnmarshalWireMessage(b []byte) error

+ func (c Compressed) AppendWireMessage(b []byte) ([]byte, error)

+ func (c Compressed) Len() int

+ func (c Compressed) MarshalWireMessage() ([]byte, error)

+ func (c Compressed) String() string

+ func (c Compressed) ValidateWireMessage() error

+ type CompressorID uint8

+ const CompressorNoOp

+ const CompressorSnappy

+ const CompressorZLib

+ type Delete struct

+ Flags DeleteFlag

+ FullCollectionName string

+ MsgHeader Header

+ Selector bson.Raw

+ func (d *Delete) UnmarshalWireMessage([]byte) error

+ func (d Delete) AppendWireMessage([]byte) ([]byte, error)

+ func (d Delete) Len() int

+ func (d Delete) MarshalWireMessage() ([]byte, error)

+ func (d Delete) String() string

+ func (d Delete) ValidateWireMessage() error

+ type DeleteFlag int32

+ const SingleRemove

+ type Error struct

+ Message string

+ Type ErrorType

+ func (e Error) Error() string

+ type ErrorType uint16

+ const ErrHeader

+ const ErrNil

+ const ErrOpCompressed

+ const ErrOpMsg

+ const ErrOpQuery

+ const ErrOpReply

+ const ErrRead

+ type GetMore struct

+ CursorID int64

+ FullCollectionName string

+ MsgHeader Header

+ NumberToReturn int32

+ func (gm *GetMore) UnmarshalWireMessage([]byte) error

+ func (gm GetMore) AppendWireMessage([]byte) ([]byte, error)

+ func (gm GetMore) Len() int

+ func (gm GetMore) MarshalWireMessage() ([]byte, error)

+ func (gm GetMore) String() string

+ func (gm GetMore) ValidateWireMessage() error

+ type Header struct

+ MessageLength int32

+ OpCode OpCode

+ RequestID int32

+ ResponseTo int32

+ func ReadHeader(b []byte, pos int32) (Header, error)

+ func (h *Header) SetDefaults(length int, opcode OpCode) error

+ func (h Header) AppendHeader(b []byte) []byte

+ func (h Header) String() string

+ type Insert struct

+ Documents []bson.Raw

+ Flags InsertFlag

+ FullCollectionName string

+ MsgHeader Header

+ func (i *Insert) UnmarshalWireMessage([]byte) error

+ func (i Insert) AppendWireMessage([]byte) ([]byte, error)

+ func (i Insert) Len() int

+ func (i Insert) MarshalWireMessage() ([]byte, error)

+ func (i Insert) String() string

+ func (i Insert) ValidateWireMessage() error

+ type InsertFlag int32

+ const ContinueOnError

+ type KillCursors struct

+ CursorIDs []int64

+ MsgHeader Header

+ NumberOfCursorIDs int32

+ func (kc *KillCursors) UnmarshalWireMessage([]byte) error

+ func (kc KillCursors) AppendWireMessage([]byte) ([]byte, error)

+ func (kc KillCursors) Len() int

+ func (kc KillCursors) MarshalWireMessage() ([]byte, error)

+ func (kc KillCursors) String() string

+ func (kc KillCursors) ValidateWireMessage() error

+ type Marshaler interface

+ MarshalWireMessage func() ([]byte, error)

+ type Msg struct

+ Checksum uint32

+ FlagBits MsgFlag

+ MsgHeader Header

+ Sections []Section

+ func (m *Msg) AcknowledgedWrite() bool

+ func (m *Msg) GetMainDocument() (bsonx.Doc, error)

+ func (m *Msg) GetSequenceArray() (bsonx.Arr, string, error)

+ func (m *Msg) UnmarshalWireMessage(b []byte) error

+ func (m Msg) AppendWireMessage(b []byte) ([]byte, error)

+ func (m Msg) Len() int

+ func (m Msg) MarshalWireMessage() ([]byte, error)

+ func (m Msg) String() string

+ func (m Msg) ValidateWireMessage() error

+ type MsgFlag uint32

+ const ChecksumPresent

+ const ExhaustAllowed

+ const MoreToCome

+ 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 (oc OpCode) String() string

+ type Query struct

+ Flags QueryFlag

+ FullCollectionName string

+ MsgHeader Header

+ NumberToReturn int32

+ NumberToSkip int32

+ Query bson.Raw

+ ReturnFieldsSelector bson.Raw

+ func (q *Query) AcknowledgedWrite() bool

+ func (q *Query) UnmarshalWireMessage(b []byte) error

+ func (q Query) AppendWireMessage(b []byte) ([]byte, error)

+ func (q Query) Len() int

+ func (q Query) MarshalWireMessage() ([]byte, error)

+ func (q Query) String() string

+ func (q Query) ValidateWireMessage() error

+ type QueryFlag int32

+ const AwaitData

+ const Exhaust

+ const NoCursorTimeout

+ const OplogReplay

+ const Partial

+ const SlaveOK

+ const TailableCursor

+ func (qf QueryFlag) String() string

+ type ReadWriteCloser interface

+ type ReadWriter interface

+ type Reader interface

+ ReadWireMessage func(context.Context) (WireMessage, error)

+ type Reply struct

+ CursorID int64

+ Documents []bson.Raw

+ MsgHeader Header

+ NumberReturned int32

+ ResponseFlags ReplyFlag

+ StartingFrom int32

+ func (r *Reply) GetMainDocument() (bsonx.Doc, error)

+ func (r *Reply) UnmarshalWireMessage(b []byte) error

+ func (r Reply) AppendWireMessage(b []byte) ([]byte, error)

+ func (r Reply) Len() int

+ func (r Reply) MarshalWireMessage() ([]byte, error)

+ func (r Reply) String() string

+ func (r Reply) ValidateWireMessage() error

+ type ReplyFlag int32

+ const AwaitCapable

+ const CursorNotFound

+ const QueryFailure

+ const ShardConfigStale

+ func (rf ReplyFlag) String() string

+ type Section interface

+ AppendSection func([]byte) []byte

+ Kind func() SectionType

+ Len func() int

+ type SectionBody struct

+ Document bson.Raw

+ PayloadType SectionType

+ func (sb SectionBody) AppendSection(dest []byte) []byte

+ func (sb SectionBody) Kind() SectionType

+ func (sb SectionBody) Len() int

+ type SectionDocumentSequence struct

+ Documents []bson.Raw

+ Identifier string

+ PayloadType SectionType

+ Size int32

+ func (sds SectionDocumentSequence) AppendSection(dest []byte) []byte

+ func (sds SectionDocumentSequence) Kind() SectionType

+ func (sds SectionDocumentSequence) Len() int

+ func (sds SectionDocumentSequence) PayloadLen() int

+ type SectionType uint8

+ const DocumentSequence

+ const SingleDocument

+ type Transformer interface

+ TransformWireMessage func(WireMessage) (WireMessage, error)

+ type Unmarshaler interface

+ UnmarshalWireMessage func([]byte) error

+ type Update struct

+ Flags UpdateFlag

+ FullCollectionName string

+ MsgHeader Header

+ Selector bson.Raw

+ Update bson.Raw

+ func (u *Update) UnmarshalWireMessage([]byte) error

+ func (u Update) AppendWireMessage([]byte) ([]byte, error)

+ func (u Update) Len() int

+ func (u Update) MarshalWireMessage() ([]byte, error)

+ func (u Update) String() string

+ func (u Update) ValidateWireMessage() error

+ type UpdateFlag int32

+ const MultiUpdate

+ const Upsert

+ type Validator interface

+ ValidateWireMessage func() error

+ type WireMessage interface

+ Len func() int

+ func ReadFrom(io.Reader) (WireMessage, error)

+ func Unmarshal([]byte) (WireMessage, error)

+ type Writer interface

+ WriteWireMessage func(context.Context, WireMessage) error