Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Emoji = "\U0001F430" + " Keploy:"
Functions ¶
func IsIsMasterDoc ¶
func IsIsMasterValueTruthy ¶
Types ¶
type Command ¶
type Command string
const ( Unknown Command = "unknown" AbortTransaction Command = "abortTransaction" Aggregate Command = "aggregate" CommitTransaction Command = "commandTransaction" Count Command = "count" CreateIndexes Command = "createIndexes" Delete Command = "delete" Distinct Command = "distinct" Drop Command = "drop" DropDatabase Command = "dropDatabase" DropIndexes Command = "dropIndexes" EndSessions Command = "endSessions" Find Command = "find" FindAndModify Command = "findAndModify" GetMore Command = "getMore" Insert Command = "insert" IsMaster Command = "isMaster" Ismaster Command = "ismaster" ListCollections Command = "listCollections" ListIndexes Command = "listIndexes" ListDatabases Command = "listDatabases" MapReduce Command = "mapReduce" Update Command = "update" )
type MongoParser ¶
type MongoParser struct {
// contains filtered or unexported fields
}
func NewMongoParser ¶
func (*MongoParser) OutgoingType ¶
func (m *MongoParser) OutgoingType(buffer []byte) bool
IsOutgoingMongo function determines if the outgoing network call is Mongo by comparing the message format with that of a mongo wire message.
func (*MongoParser) ProcessOutgoing ¶
type Operation ¶
type Operation interface { fmt.Stringer OpCode() wiremessage.OpCode Encode(responseTo, requestId int32) []byte IsIsMaster() bool IsIsAdminDB() bool CursorID() (cursorID int64, ok bool) RequestID() int32 Error() error Unacknowledged() bool CommandAndCollection() (Command, string) TransactionDetails() *TransactionDetails }
func Decode ¶
see https://github.com/mongodb/mongo-go-driver/blob/v1.7.2/x/mongo/driver/operation.go#L1361-L1426 func Decode(wm []byte) (Operation, int32, int32, int32, int32, error) {
type TransactionDetails ¶
Click to show internal directories.
Click to hide internal directories.