mongo

Documentation

Index

• type Mongo
  • func NewDBConnection(_ context.Context, cfg config.MongoConfig) (m *Mongo, err error)
  • 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)

Types

type Mongo

type Mongo struct {
	mongodriver.MongoDriverConfig

	Connection *mongodriver.MongoConnection
	// contains filtered or unexported fields
}

func NewDBConnection

func NewDBConnection(_ context.Context, cfg config.MongoConfig) (m *Mongo, err error)

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

func (m *Mongo) CheckTopicExists(ctx context.Context, id string) error

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

func (m *Mongo) Close(ctx context.Context) error

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

func (m *Mongo) GetContent(ctx context.Context, id string, queryTypeFlags int) (*models.ContentResponse, error)

GetContent retrieves a content document by its ID

func (*Mongo) GetTopic

func (m *Mongo) GetTopic(ctx context.Context, id string) (*models.TopicResponse, error)

GetTopic retrieves a topic document by its ID