ElasticSearch

Jul 15, 2021

Changes in this version

type ElasticRepository

+ func (e *ElasticRepository) Add(id string, entity interface{}) (res *elastic.IndexResponse, err error)

+ func (e *ElasticRepository) AddMany(entityMap map[string]interface{}) (res *elastic.BulkResponse, err error)

+ func (e *ElasticRepository) Remove(ids ...string) (res *elastic.BulkResponse, err error)

+ func (e *ElasticRepository) Set(id string, doc map[string]interface{}) (res *elastic.UpdateResponse, err error)

+ func (e *ElasticRepository) SetMany(entityMap map[string]interface{}) (res *elastic.BulkResponse, err error)

type IElasticRepository

+ Add func(id string, entity interface{}) (res *elastic.IndexResponse, err error)

+ AddMany func(entityMap map[string]interface{}) (res *elastic.BulkResponse, err error)

+ Remove func(id ...string) (*elastic.BulkResponse, error)

+ Set func(id string, doc map[string]interface{}) (res *elastic.UpdateResponse, err error)

+ SetMany func(entityMap map[string]interface{}) (res *elastic.BulkResponse, err error)

Feb 27, 2021

Changes in this version

type ElasticRepository

+ func (elasti *ElasticRepository) UpdateMany(entityMap map[string]interface{}) (res *elastic.BulkResponse, err error)

type IElasticRepository

+ UpdateMany func(entityMap map[string]interface{}) (res *elastic.BulkResponse, err error)

Feb 23, 2021

Changes in this version

type ElasticContent

+ func (elasti *ElasticContent) GetElasticRepository(entity interface{}) IElasticRepository

type ElasticRepository

+ func (elasti *ElasticRepository) InsertMany(entityMap map[string]interface{}) (res *elastic.BulkResponse, err error)

type IElasticRepository

+ InsertMany func(entityMap map[string]interface{}) (res *elastic.BulkResponse, err error)

Jan 28, 2021

Changes in this version

+ type ElasticClient struct

+ Client *elastic.Client

+ Index string

+ func GetElasticClient(config map[string]string) (*ElasticClient, error)

+ type ElasticContent struct

+ func DataBaseMapping(client *ElasticClient) *ElasticContent

+ func (elasti *ElasticContent) GetRedisRepository(entity interface{}) IElasticRepository

+ type ElasticRepository struct

+ Content *ElasticContent

+ TableName string

+ func (elasti ElasticRepository) Delete(id string) (res *elastic.DeleteResponse, err error)

+ func (elasti ElasticRepository) GetById(id string, entity interface{}) error

+ func (elasti ElasticRepository) Insert(id string, entity interface{}) (res *elastic.IndexResponse, err error)

+ func (elasti ElasticRepository) Query(query elastic.Query) (result *elastic.SearchResult, err error)

+ func (elasti ElasticRepository) Search(query elastic.Query) (entity []interface{}, err error)

+ func (elasti ElasticRepository) SearchPage(query elastic.Query, PageIndex, PageSize int) (entity []interface{}, totalCount int64, err error)

+ func (elasti ElasticRepository) Update(id string, doc map[string]interface{}) (res *elastic.UpdateResponse, err error)

+ type IElasticRepository interface

+ Delete func(id string) (*elastic.DeleteResponse, error)

+ GetById func(id string, result interface{}) error

+ Insert func(id string, entity interface{}) (res *elastic.IndexResponse, err error)

+ Query func(query elastic.Query) (result *elastic.SearchResult, err error)

+ Search func(query elastic.Query) (entity []interface{}, err error)

+ SearchPage func(query elastic.Query, PageIndex, PageSize int) (entity []interface{}, totalCount int64, err error)

+ Update func(id string, doc map[string]interface{}) (res *elastic.UpdateResponse, err error)