mongo

Documentation

Index

• func NewMongoGameWriter(client *MongoClient) *mongoGameWriter
• type DatabaseOldPromotionFilter
  • func NewDatabaseOldPromotionFilter(client *MongoClient) *DatabaseOldPromotionFilter
  • func (f *DatabaseOldPromotionFilter) Filter(ctx context.Context, games <-chan data.XboxStoreGame) <-chan data.XboxStoreGame
• type MongoClient
  • func NewClient(ctx context.Context, connectionString, database, collection string) (*MongoClient, error)
  • func (c *MongoClient) Close(ctx context.Context)
  • func (c *MongoClient) GetCollection() *mongo.Collection

Functions

func NewMongoGameWriter

func NewMongoGameWriter(client *MongoClient) *mongoGameWriter

Types

type DatabaseOldPromotionFilter

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

func NewDatabaseOldPromotionFilter

func NewDatabaseOldPromotionFilter(client *MongoClient) *DatabaseOldPromotionFilter

func (*DatabaseOldPromotionFilter) Filter

func (f *DatabaseOldPromotionFilter) Filter(ctx context.Context, games <-chan data.XboxStoreGame) <-chan data.XboxStoreGame

type MongoClient

type MongoClient struct {
	*mongo.Client
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ctx context.Context, connectionString, database, collection string) (*MongoClient, error)

func (*MongoClient) Close

func (c *MongoClient) Close(ctx context.Context)

func (*MongoClient) GetCollection

func (c *MongoClient) GetCollection() *mongo.Collection