Versions in this module Expand all Collapse all v0 v0.0.2 Mar 6, 2018 v0.0.1 Feb 13, 2018 Changes in this version + func AddMeta(r Request, meta map[string]*bson.Document) error + func CurrentRequestID() int32 + func NextRequestID() int32 + type Codec interface + func NewWireProtocolCodec() Codec + type Decoder interface + Decode func(io.Reader) (Message, error) + type Encoder interface + Encode func(io.Writer, ...Message) error + type Message interface + type Query struct + Flags QueryFlags + FullCollectionName string + NumberToReturn int32 + NumberToSkip int32 + Query interface{} + ReqID int32 + ReturnFieldsSelector interface{} + func (m *Query) RequestID() int32 + type QueryFlags int32 + const AwaitData + const Exhaust + const NoCursorTimeout + const OplogReplay + const Partial + const SlaveOK + const TailableCursor + type Reply struct + CursorID int64 + DocumentsBytes []byte + NumberReturned int32 + ReqID int32 + RespTo int32 + ResponseFlags ReplyFlags + StartingFrom int32 + func (m *Reply) Iter() *ReplyIter + func (m *Reply) ResponseTo() int32 + type ReplyFlags int32 + const AwaitCapable + const CursorNotFound + const QueryFailure + type ReplyIter struct + func (i *ReplyIter) Err() error + func (i *ReplyIter) NextBytes() (bson.Reader, error) + type Request interface + RequestID func() int32 + func NewCommand(requestID int32, dbName string, slaveOK bool, cmd interface{}) Request + type Response interface + ResponseTo func() int32
Go to main page