Documentation
¶
Index ¶
- Constants
- type Config
- type Source
- func (s *Source) Aggregate(ctx context.Context, pipelineString string, canonical, readOnly bool, ...) ([]any, error)
- func (s *Source) DeleteMany(ctx context.Context, filterString, database, collection string) (any, error)
- func (s *Source) DeleteOne(ctx context.Context, filterString, database, collection string) (any, error)
- func (s *Source) Find(ctx context.Context, filterString, database, collection string, ...) ([]any, error)
- func (s *Source) FindOne(ctx context.Context, filterString, database, collection string, ...) ([]any, error)
- func (s *Source) InsertMany(ctx context.Context, jsonData string, canonical bool, ...) ([]any, error)
- func (s *Source) InsertOne(ctx context.Context, jsonData string, canonical bool, ...) (any, error)
- func (s *Source) MongoClient() *mongo.Client
- func (s *Source) SourceType() string
- func (s *Source) ToConfig() sources.SourceConfig
- func (s *Source) UpdateMany(ctx context.Context, filterString string, canonical bool, ...) ([]any, error)
- func (s *Source) UpdateOne(ctx context.Context, filterString string, canonical bool, ...) (any, error)
Constants ¶
View Source
const SourceType string = "mongodb"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Name string `yaml:"name" validate:"required"`
Type string `yaml:"type" validate:"required"`
Uri string `yaml:"uri" validate:"required"` // MongoDB Atlas connection URI
}
func (Config) Initialize ¶
func (Config) SourceConfigType ¶
type Source ¶
func (*Source) DeleteMany ¶
func (*Source) InsertMany ¶
func (*Source) MongoClient ¶
func (*Source) SourceType ¶
func (*Source) ToConfig ¶
func (s *Source) ToConfig() sources.SourceConfig
func (*Source) UpdateMany ¶
Click to show internal directories.
Click to hide internal directories.