mongopkg

Documentation

Index

• Constants
• func NewMongoClient(config *Config, logger log.Logger) (*mongo.Client, error)
• func NewMonitor(logger log.Logger, opts ...MonitorOption) *event.CommandMonitor
• type Config
• type MonitorOption
  • func WithSlowThreshold(slowThreshold time.Duration) MonitorOption

Constants

const (
	OperationSet          = "$set"
	OperationIn           = "$in"
	OperationNotIn        = "$nin"
	OperationGte          = "$gte"
	OperationGt           = "$gt"
	OperationLte          = "$lte"
	OperationLt           = "$lt"
	OperationOr           = "$or"
	OperationUnset        = "$unset"
	OperationRegex        = "$regex"
	OperationInc          = "$inc"
	OperationPull         = "$pull"
	OperationNin          = "$nin"
	OperationNe           = "$ne"
	OperationEq           = "$eq"
	OperationMatch        = "$match"
	OperationGroup        = "$group"
	OperationLookup       = "$lookup"
	OperationProject      = "$project"
	OperationAddFields    = "$addFields"
	OperationBucket       = "$bucket"
	OperationBucketAuto   = "$bucketAuto"
	OperationChangeStream = "$changeStream"
	OperationCollStats    = "$collStats"
	OperationCount        = "$count"

	FieldFrom         = "from"
	FieldLocalField   = "localField"
	FieldForeignField = "foreignField"
	FieldAs           = "as"
	FieldLet          = "let"
	FieldPipeline     = "pipeline"
)

Functions

func NewMongoClient

func NewMongoClient(config *Config, logger log.Logger) (*mongo.Client, error)

NewMongoClient ...

func NewMonitor

func NewMonitor(logger log.Logger, opts ...MonitorOption) *event.CommandMonitor

NewMonitor ...

Types

type Config

type Config struct {
	AppName           string
	Hosts             []string
	Addr              string
	MaxPoolSize       uint32
	MinPoolSize       uint32
	MaxConnecting     uint32
	ConnectTimeout    *durationpb.Duration
	Timeout           *durationpb.Duration
	HeartbeatInterval *durationpb.Duration
	MaxConnIdleTime   *durationpb.Duration
	SlowThreshold     *durationpb.Duration

	// Debug Deprecated
	Debug bool
}

Config ...

type MonitorOption

type MonitorOption func(*monitorOption)

func WithSlowThreshold

func WithSlowThreshold(slowThreshold time.Duration) MonitorOption

WithSlowThreshold 慢查询阈值