eswebclient

package
v1.4.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
const ESServerName = "web.esserver.com"

Variables

This section is empty.

Functions

func InjectEsWebClient

func InjectEsWebClient(s *EsWebClient)

func LoadEsWebClient

func LoadEsWebClient() baseiface.ISingleton

Types

type EsWebClient

type EsWebClient struct {
	*webclient.WebClient
}

依赖 suite.Suite

func DefaultEs added in v1.2.6

func DefaultEs() *EsWebClient

func FindBeanEsWebClient

func FindBeanEsWebClient() *EsWebClient

func NewEsWebClient

func NewEsWebClient() *EsWebClient

func (*EsWebClient) BulkCreate

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

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

return webcli.Update(cmd, id, jsonutils.Stru2Map(stru))

}

func (*EsWebClient) BulkDelete

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

func (*EsWebClient) BulkIndex

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

func (*EsWebClient) BulkScriptUpdate

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

func (*EsWebClient) BulkUpdate

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

func (*EsWebClient) BulkUpsert

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

func (*EsWebClient) Cmd

func (*EsWebClient) CmdBulkCreate

func (this *EsWebClient) CmdBulkCreate(cmd *pagereq.CmdRequest) *basedto.IchubResult

func (*EsWebClient) CmdBulkDelete

func (this *EsWebClient) CmdBulkDelete(cmd *pagereq.CmdRequest) *basedto.IchubResult

func (*EsWebClient) CmdBulkIndex

func (this *EsWebClient) CmdBulkIndex(cmd *pagereq.CmdRequest) *basedto.IchubResult

func (*EsWebClient) CmdBulkUpdate

func (this *EsWebClient) CmdBulkUpdate(cmd *pagereq.CmdRequest) *basedto.IchubResult

func (*EsWebClient) CmdDelete

func (this *EsWebClient) CmdDelete(index schema.Tabler, ids []string) *basedto.IchubResult

func (*EsWebClient) CreateAlias

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

func (*EsWebClient) CreateIndexIfNotExist

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

func (*EsWebClient) CreateIndexesIfNotExist

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

func (*EsWebClient) Delete

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

func (*EsWebClient) DeleteByQuery

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

func (*EsWebClient) ExecuteQuery

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

func (*EsWebClient) ExistId

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

func (*EsWebClient) Filter

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

func (*EsWebClient) GeneralQuerySource

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

func (*EsWebClient) Get

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

func (*EsWebClient) HttpCliQuery

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

hhtpcliqueryAgg

func (*EsWebClient) HttpCliQueryNew

func (webcli *EsWebClient) HttpCliQueryNew(q *pagereqcli.HttpCliQuery, query elastic.Query) *page.PageResult

func (*EsWebClient) HttpQuery

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

func (*EsWebClient) HttpQuerySource

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

func (*EsWebClient) InsertIfNotExists

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

func (*EsWebClient) Keyword

func (this *EsWebClient) Keyword(req *pagees.PageEsRequest) *page.PageResult

func (*EsWebClient) MetaCreateIndex

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

func (*EsWebClient) MetaDropIndex

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

func (*EsWebClient) MetaGetMapping

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

func (*EsWebClient) MetaIndexExists

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

func (*EsWebClient) Metadata

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

func (*EsWebClient) Must

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

func (*EsWebClient) MustNot

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

func (*EsWebClient) Query

func (this *EsWebClient) Query(req *pagereq.QueryRequest) *page.PageResult

func (*EsWebClient) QueryAs

func (this *EsWebClient) QueryAs(req *pagereq.QueryRequest, out interface{}) *page.PageResult

func (*EsWebClient) Should

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

func (*EsWebClient) Single added in v1.0.8

func (this *EsWebClient) Single() bool

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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