mongoatlas

func (*Config) GetIngestrURI ¶

func (c *Config) GetIngestrURI() string

func (*DB) GetDatabaseSummary ¶ added in v0.11.646

func (db *DB) GetDatabaseSummary(ctx context.Context) (*ansisql.DBDatabase, error)

GetDatabaseSummary enumerates the databases and collections on the Atlas cluster so `bruin import database` can turn them into assets.

func (*DB) GetIngestrURI ¶

func (db *DB) GetIngestrURI() (string, error)

func (*DB) GetTableSummary ¶ added in v0.11.646

func (db *DB) GetTableSummary(ctx context.Context, tableName string, schemaOnly bool) (*diff.TableSummaryResult, error)

GetTableSummary implements diff.TableSummarizer for MongoDB Atlas collections. It reuses the shared MongoDB summarizer; the table identifier is a collection name, optionally qualified as "database.collection".

func (*DB) IsSchemaless ¶ added in v0.11.646

func (db *DB) IsSchemaless() bool

IsSchemaless reports that MongoDB Atlas has no fixed, catalog-defined schema; the schema is inferred from documents. It implements diff.SchemalessSummarizer so data-diff skips ALTER TABLE statement generation for MongoDB Atlas sources.

func (*DB) Limit ¶ added in v0.11.644

func (db *DB) Limit(q string, limit int64) string

func (*DB) Ping ¶ added in v0.11.334

func (db *DB) Ping(ctx context.Context) error

func (*DB) Select ¶ added in v0.11.644

func (db *DB) Select(ctx context.Context, q *query.Query) ([][]interface{}, error)

func (*DB) SelectWithSchema ¶ added in v0.11.644

func (db *DB) SelectWithSchema(ctx context.Context, q *query.Query) (*query.QueryResult, error)