protocol

type CSString []byte

type Document []byte

type Message interface {
	WriteTo(w io.Writer) error
	GetOpCode() OpCode
	GetMsgHeader() *MsgHeader
	String() string
}

type MsgHeader struct {
	// MessageLength is the total message size, including this header
	MessageLength int32
	// RequestID is the identifier for this message
	RequestID int32
	// ResponseTo is the RequestID of the message being responded to. used in DB responses
	ResponseTo int32
	// OpCode is the request type, see consts above.
	OpCode OpCode
	// Message raw content
	Message []byte
}

type OpCode int32

type OpQuery struct {
	// MsgHeader standard message header
	MsgHeader *MsgHeader
	// Flags bit vector of query options.
	Flags int32
	// FullCollectionName "dbname.collectionname"
	FullCollectionName CSString
	// number of documents to skip
	NumberToSkip int32
	// number of documents to return
	NumberToReturn int32
	//  in the first OP_REPLY batch
	Query Document
	// Optional. Selector indicating the fields
	ReturnFieldsSelector Document
}

type OpReply struct {
	// MsgHeader standard message header
	MsgHeader *MsgHeader
	// ResponseFlags bit vector.
	ResponseFlags int32
	// CursorID cursor id if client needs to do get more's
	CursorID int64
	// StartingFrom where in the cursor this reply is starting
	StartingFrom int32
	// NumberReturned number of documents in the reply
	NumberReturned int32
	// Documents
	Documents []Document
}

type WriteError struct {
	Index   int32
	Code    int32
	Message string `bson:"errmsg"`
}

type WriteResult struct {
	Result        int32        `bson:"ok"`
	InsertedCount int32        `bson:"n"`
	WriteErrors   []WriteError `bson:"writeErrors"`
}