mongodb

Documentation

Index

• Constants
• func Init(ctx context.Context, cfg database.Config, logger *zap.Logger) storage.Statistical
• type MongoDB
  • func (mng *MongoDB) Close(ctx context.Context)
  • func (mng *MongoDB) Relevance(ctx context.Context, user string, opts storage.RelevanceOptions) (*storage.Relevance, error)
  • func (mng *MongoDB) UpdateRelevances(ctx context.Context, user string, relevances storage.Relevances) error

Constants

const (

	// ValueAllTime is the all time relevance statistics value for the time span key in the database.
	ValueAllTime = "all_time"
)

Functions

func Init

func Init(ctx context.Context, cfg database.Config, logger *zap.Logger) storage.Statistical

Init returns a new mongodb twitter storage.

Types

type MongoDB

type MongoDB struct {
	// contains filtered or unexported fields
}

MongoDB wraps database access.

func (*MongoDB) Close

func (mng *MongoDB) Close(ctx context.Context)

Close closes the database connection.

func (*MongoDB) Relevance

func (mng *MongoDB) Relevance(
	ctx context.Context,
	user string,
	opts storage.RelevanceOptions,
) (*storage.Relevance, error)

Relevance returns a relevance from the database.

func (*MongoDB) UpdateRelevances

func (mng *MongoDB) UpdateRelevances(
	ctx context.Context,
	user string,
	relevances storage.Relevances,
) error

UpdateRelevances updates the relevances into the database.