msg

type Codec interface {
	Encoder
	Decoder
}

type Decoder interface {
	// Decode decodes one message from the reader.
	Decode(io.Reader) (Message, error)
}

type Encoder interface {
	// Encode encodes a number of messages to the writer.
	Encode(io.Writer, ...Message) error
}

type Message interface {
	// contains filtered or unexported methods
}

type Query struct {
	ReqID                int32
	Flags                QueryFlags
	FullCollectionName   string
	NumberToSkip         int32
	NumberToReturn       int32
	Query                interface{}
	ReturnFieldsSelector interface{}
}

type QueryFlags int32

type Reply struct {
	ReqID          int32
	RespTo         int32
	ResponseFlags  ReplyFlags
	CursorID       int64
	StartingFrom   int32
	NumberReturned int32
	DocumentsBytes []byte
}

type ReplyFlags int32

type ReplyIter struct {
	// contains filtered or unexported fields
}

type Request interface {
	Message
	RequestID() int32
}

type Response interface {
	Message
	ResponseTo() int32
}