mongodb

type ArrayExpr struct {
	Field string
	Type  string      // "elemMatch", "all", "size"
	Value interface{} // for size: int, for all: []interface{}, for elemMatch: bson.M
}

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

type Config struct {
	// URI is the MongoDB connection string (e.g., mongodb://localhost:27017)
	URI string

	// Database is the name of the database to connect to
	Database string

	// MinPoolSize is the minimum number of connections in the pool
	MinPoolSize uint64

	// MaxPoolSize is the maximum number of connections in the pool
	MaxPoolSize uint64

	// ConnectTimeout is the timeout for establishing a connection
	ConnectTimeout time.Duration

	// SocketTimeout is the timeout for socket reads/writes
	SocketTimeout time.Duration

	// ServerSelectionTimeout is the timeout for server selection
	ServerSelectionTimeout time.Duration

	// RetryWrites enables retryable writes
	RetryWrites bool

	// RetryReads enables retryable reads
	RetryReads bool

	// MaxRetries is the maximum number of retry attempts for transient failures
	MaxRetries int

	// RetryBackoff is the base backoff duration between retries
	RetryBackoff time.Duration

	// MaxRetryBackoff is the maximum backoff duration between retries
	MaxRetryBackoff time.Duration
}

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

type DSLQuery struct {
	Name       string
	Collection string
	Filter     map[string]interface{}
	Sort       map[string]string
	Limit      *int64
	Skip       *int64
	Select     []string
}

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

type Document map[string]interface{}

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

type Filter bson.M

type FilterExpr struct {
	Field    string
	Operator FilterOp
	Value    interface{}
	Options  string // for regex options like "i" (case-insensitive)
}

type FilterOp string

type FindOptions struct {
	Sort       bson.D
	Limit      int64
	Skip       int64
	Projection bson.M
}

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

type HealthCheckResult struct {
	// Status is the overall health status
	Status HealthStatus

	// Message provides additional details about the health status
	Message string

	// Latency is the time taken to perform the health check
	Latency time.Duration

	// Details contains additional health check information
	Details map[string]interface{}

	// Timestamp is when the health check was performed
	Timestamp time.Time
}

type HealthStatus string

type LogicalExpr struct {
	Type    string // "and", "or", "not"
	Filters []FilterExpr
	Groups  []LogicalExpr
}

type PoolStats struct {
	// TotalConnections is the total number of connections in the pool
	TotalConnections int
	// AvailableConnections is the number of available connections
	AvailableConnections int
	// InUseConnections is the number of connections currently in use
	InUseConnections int
}

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

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

type SortDirection int

type SortExpr struct {
	Field     string
	Direction SortDirection
}

type TestContainer struct {
	Container *mongodb.MongoDBContainer
	URI       string
	// contains filtered or unexported fields
}

type TestContainerConfig struct {
	// Image is the MongoDB image to use (default: mongo:7.0)
	Image string

	// Database is the database name to use
	Database string

	// ReplicaSet enables replica set mode (required for transactions)
	ReplicaSet bool
}

type Update bson.M