mongo

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) Init(ctx context.Context, shouldEnableReadConcern, shouldEnableWriteConcern bool) (err error)

Types

type Mongo

type Mongo struct {
	URI               string
	Database          string
	TopicsCollection  string
	ContentCollection string
	Connection        *dpMongoDriver.MongoConnection
	Username          string
	Password          string

	IsSSL bool
	// contains filtered or unexported fields
}

Mongo represents a simplistic MongoDB config, with session, health and lock clients

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

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

func (*Mongo) Init

func (m *Mongo) Init(ctx context.Context, shouldEnableReadConcern, shouldEnableWriteConcern bool) (err error)

Init creates a new mongoConnection with a strong consistency and a write mode of "majority".