repository

Documentation

Index

• Variables
• func CreateClient(config *config.MongoConfiguration) (*mongo.Client, error)
• type ElasticRepository
  • func NewElasticRepository(config *config.ElasticConfiguration) (*ElasticRepository, error)
  • func (r *ElasticRepository) GetStores(ctx context.Context, storeIDs []int64) (*[]model.Store, error)
  • func (r *ElasticRepository) UpdateStore(ctx context.Context, storeID string, enabled bool) error
• type MongoRepository
  • func NewMongoRepository(config *config.MongoConfiguration) (*MongoRepository, error)
  • func (r *MongoRepository) GetStores(ctx context.Context, storeIDs []int64) (*[]model.Store, error)
  • func (r *MongoRepository) UpdateStore(ctx context.Context, storeID string, enabled bool) error
• type StoreRepository

Variables

var ElasticStoresIndex = config.ElasticStoresIndex

Functions

func CreateClient

func CreateClient(config *config.MongoConfiguration) (*mongo.Client, error)

Types

type ElasticRepository

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

func NewElasticRepository

func NewElasticRepository(config *config.ElasticConfiguration) (*ElasticRepository, error)

func (*ElasticRepository) GetStores

func (r *ElasticRepository) GetStores(ctx context.Context, storeIDs []int64) (*[]model.Store, error)

func (*ElasticRepository) UpdateStore

func (r *ElasticRepository) UpdateStore(ctx context.Context, storeID string, enabled bool) error

type MongoRepository

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

func NewMongoRepository

func NewMongoRepository(config *config.MongoConfiguration) (*MongoRepository, error)

func (*MongoRepository) GetStores

func (r *MongoRepository) GetStores(ctx context.Context, storeIDs []int64) (*[]model.Store, error)

func (*MongoRepository) UpdateStore

func (r *MongoRepository) UpdateStore(ctx context.Context, storeID string, enabled bool) error

type StoreRepository

type StoreRepository interface {
	UpdateStore(context.Context, string, bool) error
	GetStores(context.Context, []int64) (*[]model.Store, error)
}