mongoutil

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

type Config struct {
	Uri         string
	Address     []string
	Database    string
	Username    string
	Password    string
	AuthSource  string
	MaxPoolSize int
	MaxRetry    int
	MongoMode   string // "replicaSet" or "standalone"

	ReplicaSet     *ReplicaSetConfig
	ReadPreference *ReadPrefConfig
	WriteConcern   *WriteConcernConfig
}

type ReadPrefConfig struct {
	Mode         string              `json:"mode" yaml:"mode" config:"allowempty"`                 // primary, secondary, secondaryPreferred, nearest
	TagSets      []map[string]string `json:"tagSets" yaml:"tagSets" config:"allowempty"`           // Tag sets
	MaxStaleness time.Duration       `json:"maxStaleness" yaml:"maxStaleness" config:"allowempty"` // Maximum staleness time
}

type ReplicaSetConfig struct {
	Name         string        `json:"name" yaml:"name" config:"allowempty"`                 // Replica set name
	Hosts        []string      `json:"hosts" yaml:"hosts" config:"allowempty"`               // Replica set host list
	ReadConcern  string        `json:"readConcern" yaml:"readConcern" config:"allowempty"`   // Read concern level: local, available, majority, linearizable, snapshot
	MaxStaleness time.Duration `json:"maxStaleness" yaml:"maxStaleness" config:"allowempty"` // Maximum staleness time
}

type WriteConcernConfig struct {
	W        any           `json:"w" yaml:"w" config:"allowempty"`               // Write node count or tag (int, "majority", or custom tag)
	J        bool          `json:"j" yaml:"j" config:"allowempty"`               // Whether to wait for journal confirmation
	WTimeout time.Duration `json:"wtimeout" yaml:"wtimeout" config:"allowempty"` // Write timeout duration
}