mongo_protocol

type BodyMsgSection struct {
	Kind byte
	Body bson.M
}

type ConnContext struct {
	net.Conn
	// contains filtered or unexported fields
}

type Delete struct {

	// 0 - reserved for future use
	ZERO int32
	// "dbname.collectionname"
	FullCollectionName string
	// bit vector - see below for details.
	Flags int32
	// query object.  See below for details.
	Selector bson.M
	// contains filtered or unexported fields
}

type DocumentSequenceMsgSection struct {
	Kind                       byte
	Size                       int32
	DocumentSequenceIdentifier string
	DocumentSequences          []bson.M
}

type GetMore struct {
	// 0 - reserved for future use
	ZERO int32
	// "dbname.collectionname"
	FullCollectionName string
	// number of documents to return
	NumberToReturn int32
	// cursorID from the OP_REPLY
	CursorID *int64
}

type Handler interface {
	Process(header *MsgHeader, r *Reader, conn *ConnContext) error
}

type Insert struct {
	// standard message header
	Header MsgHeader
	// bit vector - see below
	Flags int32
	// "dbname.collectionname"
	FullCollectionName string
	// one or more documents to insert into the collection
	Documents []bson.M
}

type KillCursors struct {
	// standard message header
	Header MsgHeader
	// 0 - reserved for future use
	ZERO int32
	// number of cursorIDs in message
	NumberOfCursorIDs int32
	// sequence of cursorIDs to close
	CursorIDs []int64
}

type Msg struct {
	FlatBits uint32
	Sections []MsgSection
}

type MsgHeader struct {
	MessageLength int32
	RequestID     int32
	ResponseTo    int32
	OpCode        OpCode
}

type MsgReply struct {
	*Msg
	Header *MsgHeader
}

type MsgSection interface {
	GetKind() byte
}

type OpCode int32

type PrintHandler struct {
}

type Query struct {
	// standard message header
	Header MsgHeader
	// bit vector of query options.  See below for details.
	Flags int32
	// "dbname.collectionname"
	FullCollectionName string
	// number of documents to skip
	NumberToSkip int32
	// number of documents to return
	NumberToReturn int32
	//  in the first OP_REPLY batch
	// query object.  See below for details.
	Query bson.M
	// Optional. Selector indicating the fields
	ReturnFieldsSelector bson.M
}

type QueryHandler interface {
	Support(query *Query) bool
	Process(query *Query, reply *Reply) error
}

type Reader struct {
	io.Reader
}

type Reply struct {
	// standard message header
	Header *MsgHeader
	// bit vector - see details below
	ResponseFlags ResponseFlags
	// cursor id if client needs to do get more's
	CursorID int64
	// where in the cursor this reply is starting
	StartingFrom int32
	// number of documents in the reply
	NumberReturned int32
	// documents
	Documents interface{}
}

type ResponseFlags int32

type Server struct {
	Port string
	// contains filtered or unexported fields
}

type UnMarshaler interface {
	UnMarshal(r *Reader) error
}

type Update struct {
	// standard message header
	Header MsgHeader
	// 0 - reserved for future use
	ZERO int32
	// "dbname.collectionname"
	FullCollectionName string
	// bit vector. see below
	Flags int32
	// the query to select the document
	Selector bson.M
	// specification of the update to perform
	Update bson.M
}

type Writer interface {
	Write(w io.Writer) error
}