eswebclient

package
v0.0.0-...-c26ccf8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 31, 2026 License: MulanPSL-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InjectEsWebClient

func InjectEsWebClient(s *EsWebClient)

func LoadEsWebClient

func LoadEsWebClient() baseiface.ISingleton

func MetaCreateIndex

func MetaCreateIndex[T baseindex.IndexMapping]() *basedto.IchubResult

func MetaNewIndexMapping

func MetaNewIndexMapping[T baseindex.IndexMapping]() T

Types

type EsWebClient

type EsWebClient struct {
	*webclient.WebClient
}

依赖 suite.Suite

func Default

func Default() *EsWebClient

func DefaultEs

func DefaultEs() *EsWebClient

func FindBeanEsWebClient

func FindBeanEsWebClient() *EsWebClient

FindBeanEsWebClient

func NewEsWebClient

func NewEsWebClient() *EsWebClient

func (*EsWebClient) BulkCreate

func (self *EsWebClient) BulkCreate(tabler schema.Tabler, docs []*cmddto.BulkDoc) *basedto.IchubResult

func (*EsWebClient) BulkDelete

func (self *EsWebClient) BulkDelete(tabler schema.Tabler, ids ...any) *basedto.IchubResult

func (*EsWebClient) BulkIndex

func (self *EsWebClient) BulkIndex(tabler schema.Tabler, docs []*cmddto.BulkDoc) *basedto.IchubResult

func (*EsWebClient) BulkScriptUpdate

func (self *EsWebClient) BulkScriptUpdate(tabler schema.Tabler, docs []*cmddto.BulkDoc) *basedto.IchubResult

func (*EsWebClient) BulkUpdate

func (self *EsWebClient) BulkUpdate(tabler schema.Tabler, docs []*cmddto.BulkDoc) *basedto.IchubResult

func (*EsWebClient) BulkUpsert

func (self *EsWebClient) BulkUpsert(cmd *pagereq.CmdRequest) *basedto.IchubResult

func (*EsWebClient) Cmd

func (*EsWebClient) CreateAlias

func (self *EsWebClient) CreateAlias(indexname, aliasname string) *basedto.IchubResult

func (*EsWebClient) CreateIndexIfNotExist

func (self *EsWebClient) CreateIndexIfNotExist(index baseindex.IndexMapping) *basedto.IchubResult

func (*EsWebClient) CreateIndexesIfNotExist

func (self *EsWebClient) CreateIndexesIfNotExist(indexes ...baseindex.IndexMapping) *basedto.IchubResult

func (*EsWebClient) Delete

func (self *EsWebClient) Delete(tabler schema.Tabler, id any) *basedto.IchubResult

func (*EsWebClient) DeleteByQuery

func (self *EsWebClient) DeleteByQuery(req *pagereq.CmdRequest) *basedto.IchubResult

func (*EsWebClient) ExecuteQuery

func (self *EsWebClient) ExecuteQuery(q *pagereqcli.HttpCliQuery) *page.PageResult

func (*EsWebClient) ExistId

func (self *EsWebClient) ExistId(q *pagereq.QueryRequest) *page.PageResult

func (*EsWebClient) Filter

func (self *EsWebClient) Filter(req *pagereq.QueryRequest) *page.PageResult

func (*EsWebClient) GeneralQuerySource

func (self *EsWebClient) GeneralQuerySource(q *pagereqcli.HttpCliQuery) *page.PageResult

func (*EsWebClient) Get

func (self *EsWebClient) Get(IndexName, Id string) *page.PageResult

func (*EsWebClient) GetServiceAddr

func (self *EsWebClient) GetServiceAddr() string

func (*EsWebClient) Health

func (self *EsWebClient) Health() *basedto.IchubResult

func (*EsWebClient) HttpCliQuery

func (self *EsWebClient) HttpCliQuery(q *pagereq.QueryRequest, query ...elastic.Query) *page.PageResult

hhtpcliqueryAgg

func (*EsWebClient) HttpCliQueryBase

func (self *EsWebClient) HttpCliQueryBase(q *pagereq.QueryRequest, query elastic.Query) *page.PageResult

func (*EsWebClient) HttpKeyword

func (self *EsWebClient) HttpKeyword(q *pagereq.KeywordRequest) *page.PageResult

func (*EsWebClient) HttpQuery

func (self *EsWebClient) HttpQuery(q *pagereqcli.HttpCliQuery, query ...elastic.Query) *page.PageResult

func (*EsWebClient) HttpQuerySource

func (self *EsWebClient) HttpQuerySource(q *pagereqcli.HttpCliQuery) *page.PageResult

func (*EsWebClient) HttpQuerySourceAs

func (self *EsWebClient) HttpQuerySourceAs(q *pagereqcli.HttpCliQuery, models any) *page.PageResult

[]esdto

func (*EsWebClient) InsertIfNotExists

func (self *EsWebClient) InsertIfNotExists(req *pagereq.CmdRequest) *basedto.IchubResult

func (*EsWebClient) Keyword

func (self *EsWebClient) Keyword(q *pagereq.KeywordRequest) *page.PageResult

func (*EsWebClient) MetaCreateAlias

func (self *EsWebClient) MetaCreateAlias(index schema.Tabler) *basedto.IchubResult

func (*EsWebClient) MetaCreateIndex

func (self *EsWebClient) MetaCreateIndex(index baseindex.IndexMapping) *basedto.IchubResult

func (*EsWebClient) MetaDropIndex

func (self *EsWebClient) MetaDropIndex(index schema.Tabler) *basedto.IchubResult

func (*EsWebClient) MetaGetMapping

func (self *EsWebClient) MetaGetMapping(index schema.Tabler) *basedto.IchubResult

func (*EsWebClient) MetaIndexExists

func (self *EsWebClient) MetaIndexExists(index schema.Tabler) *basedto.IchubResult

func (*EsWebClient) MetaParse2Stru

func (self *EsWebClient) MetaParse2Stru(index schema.Tabler) *basedto.IchubResult

func (*EsWebClient) Metadata

func (self *EsWebClient) Metadata(req *pagereq.MetadataRequest) *basedto.IchubResult

func (*EsWebClient) Must

func (self *EsWebClient) Must(req *pagereq.QueryRequest) *page.PageResult

func (*EsWebClient) MustNot

func (self *EsWebClient) MustNot(req *pagereq.QueryRequest) *page.PageResult

func (*EsWebClient) Query

func (self *EsWebClient) Query(q *pagereq.QueryRequest) *page.PageResult

func (*EsWebClient) QueryAs

func (self *EsWebClient) QueryAs(req *pagereq.QueryRequest, out any) *page.PageResult

func (*EsWebClient) QueryPageui

func (self *EsWebClient) QueryPageui(req *pagereq.QueryRequest) *pageui.PageuiResult

func (*EsWebClient) QueryStats

func (self *EsWebClient) QueryStats(q *pagereq.QueryRequest) *page.PageResult

func (*EsWebClient) ReopenEs

func (self *EsWebClient) ReopenEs() *page.PageResult

func (*EsWebClient) Should

func (self *EsWebClient) Should(req *pagereq.QueryRequest) *page.PageResult

func (*EsWebClient) ShowConfig120

func (self *EsWebClient) ShowConfig120(envKey string) []string

func (*EsWebClient) Single

func (self *EsWebClient) Single() bool

func (*EsWebClient) Stat

func (self *EsWebClient) Stat() *basedto.IchubResult

func (*EsWebClient) StopEs

func (self *EsWebClient) StopEs() *page.PageResult

func (*EsWebClient) Update

func (self *EsWebClient) Update(cmd *pagereq.CmdRequest, id any, doc map[string]any) *basedto.IchubResult

func (*EsWebClient) UpdateByQuery

func (self *EsWebClient) UpdateByQuery(req *pagereq.CmdRequest) *basedto.IchubResult

func (*EsWebClient) UpdateStru

func (self *EsWebClient) UpdateStru(cmd *pagereq.CmdRequest, id any, stru any) *basedto.IchubResult

Directories

Path Synopsis
@Time : 2021/10/19 20:31 @Author : Jasper @File : CmsListEs @Software: GoLand
@Time : 2021/10/19 20:31 @Author : Jasper @File : CmsListEs @Software: GoLand

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL