elsearm

Dec 14, 2021

Changes in this version

+ func IndexNamesWithAffix(indexNames []string) []string

Jul 14, 2021

Changes in this version

+ func SetDocumentID(model interface{}, id string) error

+ type AutomaticIDModel interface

+ SetDocumentID func(id string) error

Oct 27, 2020

Changes in this version

+ type BulkIndexer struct

+ func NewBulkIndexer(bulk esutil.BulkIndexer) *BulkIndexer

+ func (indexer *BulkIndexer) CreateWithoutID(model interface{}) error

+ func (indexer *BulkIndexer) Delete(model interface{}) error

+ func (indexer *BulkIndexer) Update(model interface{}) error

+ func (indexer *BulkIndexer) WithContext(ctx context.Context) *BulkIndexer

Sep 14, 2020

Changes in this version

type Indexer

+ func (indexer *Indexer) Scroll(model interface{}, reqFuncs ...func(*esapi.ScrollRequest)) (*SearchResult, error)

+ type SearchResponse struct

+ Hits struct{ ... }

+ ScrollID string

+ func (res *SearchResponse) SetResult(models interface{}) error

+ type SearchResult struct

+ ScrollID string

+ Total int

+ TotalAccuracy string

Sep 9, 2020

Changes in this version

+ func IndexNameWithAffix(indexName string) string

+ func SearchIndexName(model interface{}) []string

+ type CustomSearchIndexNameModel interface

+ GetSearchIndexName func() []string

Sep 9, 2020

Changes in this version

+ func Zero() *int

type ErrorResponse

+ Err struct{ ... }

type Indexer

+ Q *esapi.API

+ func (indexer *Indexer) Count(model interface{}, reqFuncs ...func(*esapi.CountRequest)) (int, error)

+ func (indexer *Indexer) CreateWithoutID(model interface{}, reqFuncs ...func(*esapi.IndexRequest)) error

+ func (indexer *Indexer) Do(req Request, models ...interface{}) error

+ func (indexer *Indexer) Search(model interface{}, reqFuncs ...func(*esapi.SearchRequest)) error

+ func (indexer *Indexer) WithContext(ctx context.Context) *Indexer

+ type Request interface

+ Do func(ctx context.Context, transport esapi.Transport) (*esapi.Response, error)

Sep 3, 2020

Changes in this version

+ type ErrorResponse struct

+ Error struct{ ... }

+ Status uint

Sep 2, 2020

Changes in this version

+ func DefaultDocumentBody(model interface{}) (io.Reader, error)

+ func DefaultDocumentID(model interface{}) string

+ func DefaultIndexName(model interface{}) string

+ func DefaultParseDocument(model interface{}, reader io.Reader) error

+ func DocumentBody(model interface{}) (io.Reader, error)

+ func DocumentID(model interface{}) string

+ func IndexName(model interface{}) string

+ func MustDocumentBody(model interface{}) io.Reader

+ func ParseDocument(model interface{}, reader io.Reader) error

+ func SetGlobalConfig(cfg GlobalConfig)

+ type CustomDocumentBodyModel interface

+ GetDocumentBody func() (io.Reader, error)

+ ParseDocument func(io.Reader) error

+ type CustomDocumentIdModel interface

+ GetDocumentID func() string

+ type CustomIndexNameModel interface

+ GetIndexName func() string

+ type GlobalConfig struct

+ IndexNamePrefix string

+ IndexNameSuffix string

+ type Indexer struct

+ func NewIndexer(client *elasticsearch.Client) *Indexer

+ func (indexer *Indexer) CreateIndex(model interface{}, baseReqs ...*esapi.IndicesCreateRequest) error

+ func (indexer *Indexer) CreateIndexIfNotExist(model interface{}, baseReqs ...*esapi.IndicesCreateRequest) error

+ func (indexer *Indexer) Delete(model interface{}, baseReqs ...*esapi.DeleteRequest) error

+ func (indexer *Indexer) DeleteIndex(model interface{}) error

+ func (indexer *Indexer) Get(model interface{}, baseReqs ...*esapi.GetRequest) error

+ func (indexer *Indexer) Update(model interface{}, baseReqs ...*esapi.IndexRequest) error