mongo_repository

Documentation

Index

• type BrandRepository
  • func NewBrandRepository(client mongo_client.MongoClient) BrandRepository
• type BrandRepositoryImpl
  • func (r *BrandRepositoryImpl) Create(ctx context.Context, input *CreateBrandParams, ...) (*mongo_document.Brand, error)
  • func (r *BrandRepositoryImpl) FindOneBy(ctx context.Context, input *FindOneBrandByParams, ...) (*mongo_document.Brand, error)
  • func (r *BrandRepositoryImpl) Update(ctx context.Context, brandId primitive.ObjectID, input *UpdateBrandParams, ...) (bool, error)
• type CompetitorRepository
  • func NewCompetitorRepository(client mongo_client.MongoClient) CompetitorRepository
• type CompetitorRepositoryImpl
  • func (r *CompetitorRepositoryImpl) Create(ctx context.Context, input *CreateCompetitorParams, ...) (*mongo_document.Competitor, error)
• type CreateBrandParams
• type CreateCompetitorParams
• type FindOneBrandByParams
• type UpdateBrandParams

Types

type BrandRepository

type BrandRepository interface {
	Create(ctx context.Context, input *CreateBrandParams, opts ...*options.InsertOneOptions) (*mongo_document.Brand, error)
	FindOneBy(ctx context.Context, input *FindOneBrandByParams, opts ...*options.FindOneOptions) (*mongo_document.Brand, error)
	Update(ctx context.Context, brandId primitive.ObjectID, input *UpdateBrandParams, opts ...*options.UpdateOptions) (bool, error)
}

func NewBrandRepository

func NewBrandRepository(client mongo_client.MongoClient) BrandRepository

type BrandRepositoryImpl

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

func (*BrandRepositoryImpl) Create

func (r *BrandRepositoryImpl) Create(ctx context.Context, input *CreateBrandParams, opts ...*options.InsertOneOptions) (*mongo_document.Brand, error)

func (*BrandRepositoryImpl) FindOneBy

func (r *BrandRepositoryImpl) FindOneBy(ctx context.Context, input *FindOneBrandByParams, opts ...*options.FindOneOptions) (*mongo_document.Brand, error)

func (*BrandRepositoryImpl) Update

func (r *BrandRepositoryImpl) Update(ctx context.Context, brandId primitive.ObjectID, input *UpdateBrandParams, opts ...*options.UpdateOptions) (bool, error)

type CompetitorRepository

type CompetitorRepository interface {
	Create(ctx context.Context, input *CreateCompetitorParams, opts ...*options.InsertOneOptions) (*mongo_document.Competitor, error)
}

func NewCompetitorRepository

func NewCompetitorRepository(client mongo_client.MongoClient) CompetitorRepository

type CompetitorRepositoryImpl

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

func (*CompetitorRepositoryImpl) Create

func (r *CompetitorRepositoryImpl) Create(ctx context.Context, input *CreateCompetitorParams, opts ...*options.InsertOneOptions) (*mongo_document.Competitor, error)

type CreateBrandParams

type CreateBrandParams struct {
	Email      string
	Status     string
	BrandTerms []string
}

type CreateCompetitorParams

type CreateCompetitorParams struct {
	Term     string
	Device   string
	Domain   string
	FoundAt  primitive.Timestamp
	BrandID  primitive.ObjectID
	Location string
}

type FindOneBrandByParams

type FindOneBrandByParams struct {
	ID     string
	Email  string
	Status string
}

type UpdateBrandParams

type UpdateBrandParams struct {
	Email      string               `bson:"email,omitempty"`
	Status     string               `bson:"status,omitempty"`
	Results    []primitive.ObjectID `bson:"results,omitempty"`
	BrandTerms []string             `bson:"brand_terms,omitempty"`
}