wire

package module

Go to main page

Versions in this module

v0

v0.0.13

Oct 8, 2024

Changes in this version

type OpMsg

+ func (msg *OpMsg) DecodeDeepDocument() (*wirebson.Document, error)

v0.0.12

Sep 23, 2024

v0.0.11

Sep 19, 2024

v0.0.10

Sep 13, 2024

Changes in this version

type MsgBody

+ StringIndent func() string

type OpMsg

+ func (msg *OpMsg) StringIndent() string

type OpQuery

+ func (query *OpQuery) StringIndent() string

type OpReply

+ func (reply *OpReply) StringIndent() string

v0.0.9

Sep 5, 2024

v0.0.8

Aug 29, 2024

Changes in this version

+ var Debug bool

v0.0.7

Aug 6, 2024

v0.0.6

Aug 6, 2024

Changes in this version

+ var CheckNaNs bool

v0.0.5

Jul 30, 2024

v0.0.4

Jul 30, 2024

Changes in this version

+ type OpMsgSection struct

+ Identifier string

+ Kind byte

+ func (msg *OpMsgSection) Documents() []wirebson.RawDocument

v0.0.3

Jul 25, 2024

Changes in this version

type OpMsg

+ func MustOpMsg(pairs ...any) *OpMsg

v0.0.2

Jul 17, 2024

v0.0.1

Jul 15, 2024

Changes in this version

+ const MaxMsgLen

+ const MsgHeaderLen

+ const OpCodeCompressed

+ const OpCodeDelete

+ const OpCodeGetByOID

+ const OpCodeGetMore

+ const OpCodeInsert

+ const OpCodeKillCursors

+ const OpCodeMsg

+ const OpCodeQuery

+ const OpCodeReply

+ const OpCodeUpdate

+ const OpMsgChecksumPresent

+ const OpMsgExhaustAllowed

+ const OpMsgMoreToCome

+ const OpQueryAwaitData

+ const OpQueryExhaust

+ const OpQueryNoCursorTimeout

+ const OpQueryOplogReplay

+ const OpQueryPartial

+ const OpQuerySlaveOk

+ const OpQueryTailableCursor

+ const OpReplyAwaitCapable

+ const OpReplyCursorNotFound

+ const OpReplyQueryFailure

+ const OpReplyShardConfigStale

+ var ErrZeroRead = errors.New("zero bytes read")

+ func ReadMessage(r *bufio.Reader) (*MsgHeader, MsgBody, error)

+ func WriteMessage(w *bufio.Writer, header *MsgHeader, msg MsgBody) error

+ type MsgBody interface

+ StringBlock func() string

+ StringFlow func() string

+ UnmarshalBinaryNocopy func([]byte) error

+ type MsgHeader struct

+ MessageLength int32

+ OpCode OpCode

+ RequestID int32

+ ResponseTo int32

+ func (msg *MsgHeader) MarshalBinary() ([]byte, error)

+ func (msg *MsgHeader) String() string

+ type OpCode int32

+ func (i OpCode) String() string

+ type OpMsg struct

+ Flags OpMsgFlags

+ func NewOpMsg(doc wirebson.AnyDocument) (*OpMsg, error)

+ func (msg *OpMsg) MarshalBinary() ([]byte, error)

+ func (msg *OpMsg) RawDocument() (wirebson.RawDocument, error)

+ func (msg *OpMsg) RawSection0() wirebson.RawDocument

+ func (msg *OpMsg) RawSections() (wirebson.RawDocument, []byte)

+ func (msg *OpMsg) Sections() []opMsgSection

+ func (msg *OpMsg) SetSections(sections ...opMsgSection) error

+ func (msg *OpMsg) String() string

+ func (msg *OpMsg) StringBlock() string

+ func (msg *OpMsg) StringFlow() string

+ func (msg *OpMsg) UnmarshalBinaryNocopy(b []byte) error

+ type OpMsgFlagBit flagBit

+ func (i OpMsgFlagBit) String() string

+ type OpMsgFlags flags

+ func (f OpMsgFlags) FlagSet(bit OpMsgFlagBit) bool

+ func (f OpMsgFlags) String() string

+ type OpQuery struct

+ Flags OpQueryFlags

+ FullCollectionName string

+ NumberToReturn int32

+ NumberToSkip int32

+ func NewOpQuery(doc wirebson.AnyDocument) (*OpQuery, error)

+ func (query *OpQuery) MarshalBinary() ([]byte, error)

+ func (query *OpQuery) Query() *wirebson.Document

+ func (query *OpQuery) String() string

+ func (query *OpQuery) StringBlock() string

+ func (query *OpQuery) StringFlow() string

+ func (query *OpQuery) UnmarshalBinaryNocopy(b []byte) error

+ type OpQueryFlagBit flagBit

+ func (i OpQueryFlagBit) String() string

+ type OpQueryFlags flags

+ func (f OpQueryFlags) FlagSet(bit OpQueryFlagBit) bool

+ func (f OpQueryFlags) String() string

+ type OpReply struct

+ CursorID int64

+ Flags OpReplyFlags

+ StartingFrom int32

+ func NewOpReply(doc wirebson.AnyDocument) (*OpReply, error)

+ func (reply *OpReply) Document() (*wirebson.Document, error)

+ func (reply *OpReply) MarshalBinary() ([]byte, error)

+ func (reply *OpReply) RawDocument() wirebson.RawDocument

+ func (reply *OpReply) SetDocument(doc *wirebson.Document)

+ func (reply *OpReply) String() string

+ func (reply *OpReply) StringBlock() string

+ func (reply *OpReply) StringFlow() string

+ func (reply *OpReply) UnmarshalBinaryNocopy(b []byte) error

+ type OpReplyFlagBit flagBit

+ func (i OpReplyFlagBit) String() string

+ type OpReplyFlags flags

+ func (f OpReplyFlags) FlagSet(bit OpReplyFlagBit) bool

+ func (f OpReplyFlags) String() string

+ type Record struct

+ Body MsgBody

+ BodyB []byte

+ Header *MsgHeader

+ HeaderB []byte

+ func LoadRecords(dir string, limit int) ([]Record, error)

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