mongo

Documentation

Index

• func IsIsMasterDoc(doc bsoncore.Document) bool
• func IsIsMasterValueTruthy(val bsoncore.Value) bool
• func IsWrite(command Command) bool
• type Command
  • func CommandAndCollection(msg bsoncore.Document) (Command, string)
• type Message
  • func IsMasterResponse(responseTo int32, topologyKind description.TopologyKind) (*Message, error)
• type Mongo
  • func Connect(log *zap.Logger, sd *statsd.Client, opts *options.ClientOptions, ping bool) (*Mongo, error)
  • func (m *Mongo) Close()
  • func (m *Mongo) Description() description.Topology
  • func (m *Mongo) RoundTrip(msg *Message, tags []string) (_ *Message, err error)
• type Operation
  • func Decode(wm []byte) (Operation, error)
• type TransactionDetails

Functions

func IsIsMasterDoc

func IsIsMasterDoc(doc bsoncore.Document) bool

func IsIsMasterValueTruthy

func IsIsMasterValueTruthy(val bsoncore.Value) bool

func IsWrite

func IsWrite(command Command) bool

Types

type Command

type Command string

const (
	Unknown           Command = "unknown"
	AbortTransaction  Command = "abortTransaction"
	Aggregate         Command = "aggregate"
	CommitTransaction Command = "commitTransaction"
	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"
)

func CommandAndCollection

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

type Message

type Message struct {
	Wm []byte
	Op Operation
}

func IsMasterResponse

func IsMasterResponse(responseTo int32, topologyKind description.TopologyKind) (*Message, error)

hard-coded response, emulating an upstream isMaster response from MongoDB

type Mongo

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

func Connect

func Connect(log *zap.Logger, sd *statsd.Client, opts *options.ClientOptions, ping bool) (*Mongo, error)

func (*Mongo) Close

func (m *Mongo) Close()

func (*Mongo) Description

func (m *Mongo) Description() description.Topology

func (*Mongo) RoundTrip

func (m *Mongo) RoundTrip(msg *Message, tags []string) (_ *Message, err error)

type Operation

type Operation interface {
	fmt.Stringer
	OpCode() wiremessage.OpCode
	Encode(responseTo int32) []byte
	IsIsMaster() bool
	CursorID() (cursorID int64, ok bool)
	RequestID() int32
	Error() error
	Unacknowledged() bool
	CommandAndCollection() (Command, string)
	TransactionDetails() *TransactionDetails
	ReadPref() (rpref *readpref.ReadPref, ok bool)
}

func Decode

func Decode(wm []byte) (Operation, error)

see https://github.com/mongodb/mongo-go-driver/blob/v1.7.2/x/mongo/driver/operation.go#L1361-L1426

type TransactionDetails

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