wiremessage

package

Go to main page

Versions in this module

v0

v0.0.18

Nov 15, 2018

v0.0.17

Oct 25, 2018

v0.0.16

Oct 11, 2018

v0.0.15

Sep 27, 2018

v0.0.14

Sep 20, 2018

v0.0.13

Sep 6, 2018

v0.0.12

Aug 16, 2018

v0.0.11

Aug 8, 2018

v0.0.10

Jul 26, 2018

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

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

Changes in this version

+ const DefaultZlibLevel

type CompressorID

+ const CompressorZLib

type ErrorType

+ const ErrOpCompressed

v0.0.7

Jun 12, 2018

v0.0.6

May 31, 2018

v0.0.5

May 17, 2018

v0.0.4

May 2, 2018

v0.0.3

Apr 18, 2018

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