mongo

package

v2.1.0-alpha9 Latest Latest Go to latest Published: Apr 19, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

README ¶

Mongo Package Documentation

The mongo package encompasses the parser and mapping logic required to read MongoDB wire messages and capture or stub the outputs. Utilized by the hooks package, it assists in redirecting outgoing calls for the purpose of recording or stubbing the outputs.

Documentation ¶

Overview ¶

Package mongo provides functionality for working with MongoDB outgoing calls.

Index ¶

func IsIsMasterDoc(doc bsoncore.Document) bool
func IsIsMasterValueTruthy(val bsoncore.Value) bool
func IsWrite(command Command) bool
func NewMongo(logger *zap.Logger) integrations.Integrations
type Command
- func CommandAndCollection(msg bsoncore.Document) (Command, string)
type Message
type Mongo
type Operation
- func Decode(wm []byte, logger *zap.Logger) (Operation, models.MongoHeader, interface{}, error)
type TransactionDetails

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func IsIsMasterDoc ¶

func IsIsMasterDoc(doc bsoncore.Document) bool

func IsIsMasterValueTruthy ¶

func IsIsMasterValueTruthy(val bsoncore.Value) bool

func IsWrite ¶

func IsWrite(command Command) bool

func NewMongo ¶

func NewMongo(logger *zap.Logger) integrations.Integrations

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 = "tools"
)

constants for all the commands that can be proxied

func CommandAndCollection ¶

func CommandAndCollection(msg bsoncore.Document) (Command, string)

type Message ¶

type Message struct {
	Wm []byte
	Op Operation
}

type Mongo ¶

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

func (*Mongo) MatchType ¶

func (m *Mongo) MatchType(_ context.Context, buffer []byte) bool

MatchType determines if the outgoing network call is Mongo by comparing the message format with that of a mongo wire message.

func (*Mongo) MockOutgoing ¶

func (m *Mongo) MockOutgoing(ctx context.Context, src net.Conn, dstCfg *integrations.ConditionalDstCfg, mockDb integrations.MockMemDb, opts models.OutgoingOptions) error

func (*Mongo) RecordOutgoing ¶

func (m *Mongo) RecordOutgoing(ctx context.Context, src net.Conn, dst net.Conn, mocks chan<- *models.Mock, opts models.OutgoingOptions) error

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 ¶

func Decode(wm []byte, logger *zap.Logger) (Operation, models.MongoHeader, interface{}, error)

Decode (wm []byte) (Operation, int32, int32, int32, int32, error) {

type TransactionDetails ¶

type TransactionDetails struct {
	LsID               []byte
	TxnNumber          int64
	IsStartTransaction bool
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL