mongodb

Documentation

Index

• func Init(ctx context.Context, cfg database.Config, logger *zap.Logger) storage.Twitter
• type MongoDB
  • func (mng *MongoDB) AddTweets(ctx context.Context, user string, tweets storage.Tweets) error
  • func (mng *MongoDB) Close(ctx context.Context)
  • func (mng *MongoDB) Tweets(ctx context.Context, user string, opts storage.TweetsOptions) (storage.Tweets, error)

Functions

func Init

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

Init returns a new mongodb twitter storage.

Types

type MongoDB

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

MongoDB wraps database access.

func (*MongoDB) AddTweets

func (mng *MongoDB) AddTweets(ctx context.Context, user string, tweets storage.Tweets) error

AddTweets stores tweets to the database.

func (*MongoDB) Close

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

Close closes the database connection.

func (*MongoDB) Tweets

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

Tweets returns tweets from the database.