es

Documentation

Index

• func NewCommodityElastic(client *elastic.Client) repository.CommodityElastic
• type CommodityElastic
  • func (es *CommodityElastic) AddItem(ctx context.Context, indexName string, spu *model.Spu) error
  • func (es *CommodityElastic) BuildQuery(req *commodity.ViewSpuReq) *elastic.BoolQuery
  • func (es *CommodityElastic) CreateIndex(ctx context.Context, indexName string) error
  • func (es *CommodityElastic) IsExist(ctx context.Context, indexName string) bool
  • func (es *CommodityElastic) RemoveItem(ctx context.Context, indexName string, id int64) error
  • func (es *CommodityElastic) SearchItems(ctx context.Context, indexName string, query *commodity.ViewSpuReq) ([]int64, int64, error)
  • func (es *CommodityElastic) UpdateItem(ctx context.Context, indexName string, spu *model.Spu) error

Functions

func NewCommodityElastic

func NewCommodityElastic(client *elastic.Client) repository.CommodityElastic

Types

type CommodityElastic

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

func (*CommodityElastic) AddItem

func (es *CommodityElastic) AddItem(ctx context.Context, indexName string, spu *model.Spu) error

func (*CommodityElastic) BuildQuery

func (es *CommodityElastic) BuildQuery(req *commodity.ViewSpuReq) *elastic.BoolQuery

func (*CommodityElastic) CreateIndex

func (es *CommodityElastic) CreateIndex(ctx context.Context, indexName string) error

func (*CommodityElastic) IsExist

func (es *CommodityElastic) IsExist(ctx context.Context, indexName string) bool

func (*CommodityElastic) RemoveItem

func (es *CommodityElastic) RemoveItem(ctx context.Context, indexName string, id int64) error

func (*CommodityElastic) SearchItems

func (es *CommodityElastic) SearchItems(ctx context.Context, indexName string, query *commodity.ViewSpuReq) ([]int64, int64, error)

func (*CommodityElastic) UpdateItem

func (es *CommodityElastic) UpdateItem(ctx context.Context, indexName string, spu *model.Spu) error