protocol

type Delete struct {
	*Header                          // A standard wire protocol header
	ZERO               int32         // 0 - reserved for future use
	FullCollectionName string        // "dbname.collectionname"
	Flags              Flag          // bit vector. see below
	Selector           bson.Document // the query to select the document
}

type Flag = wiremessage.MsgFlag

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

type Header struct {
	MessageLength int32  // total message size, including this
	RequestID     int32  // identifier for this message
	ResponseTo    int32  // requestID from the original request
	OpCode        OpCode // request type
}

type Insert struct {
	*Header                          // A standard wire protocol header
	Flags              Flag          // bit vector. see below
	FullCollectionName string        // "dbname.collectionname"
	Document           bson.Document // one or more documents to insert into the collection
}

type KillCursors struct {
	*Header                   // A standard wire protocol header
	ZERO              int32   // 0 - reserved for future use
	NumberOfCursorIDs int32   // number of documents to return
	CursorIDs         []int64 // cursorID from the OP_REPLY
}

type Message interface {
	// SetRequestID sets a message identifier.
	SetRequestID(id int32)
	// SetResponseTo sets a response message identifier.
	SetResponseTo(id int32)
	// GetMessageLength returns the message length.
	GetMessageLength() int32
	// GetRequestID returns the message identifier.
	GetRequestID() int32
	// GetResponseTo returns the response message identifier.
	GetResponseTo() int32
	// GetOpCode returns the operation code.
	GetOpCode() OpCode
	// Size returns the message size including the header.
	Size() int32
	// Bytes returns the binary description of BSON format.
	Bytes() []byte
	// String returns the string description.
	String() string
}

type MessageListener interface {
	MessageReceived(Message)
	MessageRespond(Message)
}

type Msg struct {
	*Header                   // A standard wire protocol header
	FlagBits    MsgFlag       // message flags
	Body        bson.Document // Body
	DocumentIDs []string
	Documents   []bson.Document // Document Sequence
	Checksum    uint32          // optional CRC-32C checksum
}

type MsgFlag = wiremessage.MsgFlag

type OpCode = wiremessage.OpCode

type Query struct {
	*Header                          // A standard wire protocol header
	Flags              Flag          // bit vector. see below
	FullCollectionName string        // "dbname.collectionname"
	NumberToSkip       int32         // number of documents to skip
	NumberToReturn     int32         // number of documents to return in the first OP_REPLY batch
	Query              bson.Document // query object.  See below for details.
}

type Reply struct {
	*Header                        // A standard wire protocol header
	ReplyFlags     ReplyFlag       // bit vector - see details below
	CursorID       int64           // cursor id if client needs to do get more's
	StartingFrom   int32           // where in the cursor this reply is starting
	NumberReturned int32           // number of documents in the reply
	Documents      []bson.Document // documents
}

type ReplyFlag = wiremessage.ReplyFlag

type Request interface {
	GetCode() OpCode
}

type Response interface {
	GetCode() OpCode
}

type Section = bsoncore.Document

type SectionType = wiremessage.SectionType

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