wiremessage

package

Go to main page

Versions in this module

v0

v0.0.18

Nov 15, 2018 GO-2021-0112

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

v0.0.17

Oct 25, 2018 GO-2021-0112

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

v0.0.16

Oct 11, 2018 GO-2021-0112

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

v0.0.15

Sep 27, 2018 GO-2021-0112

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

v0.0.14

Sep 20, 2018 GO-2021-0112

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

v0.0.13

Sep 6, 2018 GO-2021-0112

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

v0.0.12

Aug 16, 2018 GO-2021-0112

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

v0.0.11

Aug 8, 2018 GO-2021-0112

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

v0.0.10

Jul 26, 2018 GO-2021-0112

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

Changes in this version

type Msg

+ func (m *Msg) AcknowledgedWrite() bool

+ func (m *Msg) GetMainDocument() (*bson.Document, error)

+ func (m *Msg) GetSequenceArray() (*bson.Array, string, error)

type Query

+ func (q *Query) AcknowledgedWrite() bool

type Reply

+ func (r *Reply) GetMainDocument() (*bson.Document, error)

v0.0.9

Jul 10, 2018 GO-2021-0112

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

Changes in this version

+ const OpmsgWireVersion

type ErrorType

+ const ErrOpMsg

+ const ErrRead

type Section

+ AppendSection func([]byte) []byte

+ Len func() int

type SectionBody

+ PayloadType SectionType

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

+ func (sb SectionBody) Len() int

type SectionDocumentSequence

+ PayloadType SectionType

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

+ func (sds SectionDocumentSequence) Len() int

+ func (sds SectionDocumentSequence) PayloadLen() int

+ type SectionType uint8

+ const DocumentSequence

+ const SingleDocument

v0.0.8

Jun 25, 2018 GO-2021-0112

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

Changes in this version

+ const DefaultZlibLevel

type CompressorID

+ const CompressorZLib

type ErrorType

+ const ErrOpCompressed

v0.0.7

Jun 12, 2018 GO-2021-0112

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

v0.0.6

May 31, 2018 GO-2021-0112

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

v0.0.5

May 17, 2018 GO-2021-0112

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

v0.0.4

May 2, 2018 GO-2021-0112

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

v0.0.3

Apr 18, 2018 GO-2021-0112

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

Changes in this version

+ 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.Reader

+ 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.Reader

+ Metadata bson.Reader

+ MsgHeader Header

+ OutputDocs []bson.Reader

+ 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([]byte) error

+ func (c Compressed) AppendWireMessage([]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 CompressorZLip

+ type Delete struct

+ Flags DeleteFlag

+ FullCollectionName string

+ MsgHeader Header

+ Selector bson.Reader

+ 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 ErrOpQuery

+ const ErrOpReply

+ 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.Reader

+ 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) UnmarshalWireMessage([]byte) error

+ func (m Msg) AppendWireMessage([]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.Reader

+ ReturnFieldsSelector bson.Reader

+ 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.Reader

+ MsgHeader Header

+ NumberReturned int32

+ ResponseFlags ReplyFlag

+ StartingFrom int32

+ 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

+ Kind func() uint8

+ type SectionBody struct

+ Document bson.Reader

+ func (sb SectionBody) Kind() uint8

+ type SectionDocumentSequence struct

+ Documents []bson.Reader

+ Identifier string

+ Size int32

+ func (sds SectionDocumentSequence) Kind() uint8

+ 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.Reader

+ Update bson.Reader

+ 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL