Documentation
¶
Index ¶
- type Mongo
- func (m *Mongo) CheckTopicExists(ctx context.Context, id string) error
- func (m *Mongo) Checker(ctx context.Context, state *healthcheck.CheckState) error
- func (m *Mongo) Close(ctx context.Context) error
- func (m *Mongo) GetContent(ctx context.Context, id string, queryTypeFlags int) (*models.ContentResponse, error)
- func (m *Mongo) GetTopic(ctx context.Context, id string) (*models.TopicResponse, error)
- func (m *Mongo) UpdateReleaseDate(ctx context.Context, id string, releaseDate time.Time) error
- func (m *Mongo) UpdateState(ctx context.Context, id, state string) error
- func (m *Mongo) UpdateTopic(ctx context.Context, host, id string, topic *models.TopicUpdate) error
- func (m *Mongo) UpsertTopic(ctx context.Context, id string, topic *models.TopicResponse) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Mongo ¶
type Mongo struct {
mongodriver.MongoDriverConfig
Connection *mongodriver.MongoConnection
// contains filtered or unexported fields
}
func NewDBConnection ¶ added in v0.8.0
NewDBConnection creates a new Mongo object encapsulating a connection to the mongo server/cluster with the given configuration, and a health client to check the health of the mongo server/cluster
func (*Mongo) CheckTopicExists ¶ added in v0.4.0
CheckTopicExists checks that the topic exists
func (*Mongo) Checker ¶
func (m *Mongo) Checker(ctx context.Context, state *healthcheck.CheckState) error
Checker is called by the healthcheck library to check the health state of this mongoDB instance
func (*Mongo) Close ¶
Close closes the mongo session and returns any error It is an error to call m.Close if m.Init() returned an error, and there is no open connection
func (*Mongo) GetContent ¶ added in v0.4.0
func (m *Mongo) GetContent(ctx context.Context, id string, queryTypeFlags int) (*models.ContentResponse, error)
GetContent retrieves a content document by its ID
func (*Mongo) UpdateReleaseDate ¶ added in v0.13.3
UpdateReleaseDate update releaseDate of document by its topic ID
func (*Mongo) UpdateState ¶ added in v0.15.0
UpdateState updates state field against next object
func (*Mongo) UpdateTopic ¶ added in v0.15.0
UpdateTopic updates the next instance with new values.
func (*Mongo) UpsertTopic ¶ added in v0.17.0
UpsertTopic creates or overwrites an existing topic (based on id) in mongodb with a new document
Source Files