Documentation
¶
Index ¶
- type ArangoClient
- type MongoProvider
- func (mp *MongoProvider) Close(ctx context.Context) error
- func (mp *MongoProvider) CountDocuments(ctx context.Context) (int, error)
- func (mp *MongoProvider) FetchById(ctx context.Context, id string) (models.MongoRecord, error)
- func (mp *MongoProvider) QueryMostRecent(ctx context.Context, count int) ([]models.MongoRecord, error)
- func (mp *MongoProvider) QueryUnpopulated(ctx context.Context) ([]models.MongoRecord, error)
- func (mp *MongoProvider) QueryUnpopulatedBson(ctx context.Context) ([]bson.M, error)
- func (mp *MongoProvider) UpdateDocument(ctx context.Context, mr models.MongoRecord) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ArangoClient ¶
type ArangoClient struct {
// contains filtered or unexported fields
}
TODO: This Client is shared between the Populator and Populator-API. Meanwhile both the Subscriber and Calculator ALSO have their own respective Arango clients. Need to look at how this sprawl can be refactored to reduce duplication and maintenance overhead.
func NewArangoClient ¶
func NewArangoClient(configs []config.DatabaseInfo, logger interfaces.Logger) (*ArangoClient, error)
func (*ArangoClient) QueryAnnotations ¶
func (c *ArangoClient) QueryAnnotations(ctx context.Context, key string) ([]documents.Annotation, error)
func (*ArangoClient) QueryScore ¶
type MongoProvider ¶
type MongoProvider struct {
// contains filtered or unexported fields
}
func NewMongoProvider ¶
func NewMongoProvider(configs []config.DatabaseInfo, logger interfaces.Logger) (*MongoProvider, error)
func (*MongoProvider) CountDocuments ¶
func (mp *MongoProvider) CountDocuments(ctx context.Context) (int, error)
func (*MongoProvider) FetchById ¶
func (mp *MongoProvider) FetchById(ctx context.Context, id string) (models.MongoRecord, error)
func (*MongoProvider) QueryMostRecent ¶
func (mp *MongoProvider) QueryMostRecent(ctx context.Context, count int) ([]models.MongoRecord, error)
func (*MongoProvider) QueryUnpopulated ¶
func (mp *MongoProvider) QueryUnpopulated(ctx context.Context) ([]models.MongoRecord, error)
func (*MongoProvider) QueryUnpopulatedBson ¶
QueryUnpopulatedBson is available for testing should you want to output the raw BSON returned by Mongo for debugging map operations to JSON.
func (*MongoProvider) UpdateDocument ¶
func (mp *MongoProvider) UpdateDocument(ctx context.Context, mr models.MongoRecord) error
Source Files
Click to show internal directories.
Click to hide internal directories.