Documentation ¶
Index ¶
- Constants
- func InjectEsWebClient(s *EsWebClient)
- func LoadEsWebClient() baseiface.ISingleton
- type EsWebClient
- func (webcli *EsWebClient) BulkCreate(tabler schema.Tabler, docs []*cmddto.BulkDoc) *basedto.IchubResult
- func (webcli *EsWebClient) BulkDelete(tabler schema.Tabler, ids ...any) *basedto.IchubResult
- func (webcli *EsWebClient) BulkIndex(tabler schema.Tabler, docs []*cmddto.BulkDoc) *basedto.IchubResult
- func (webcli *EsWebClient) BulkScriptUpdate(tabler schema.Tabler, docs []*cmddto.BulkDoc) *basedto.IchubResult
- func (webcli *EsWebClient) BulkUpdate(tabler schema.Tabler, docs []*cmddto.BulkDoc) *basedto.IchubResult
- func (webcli *EsWebClient) BulkUpsert(cmd *pagereq.CmdRequest) *basedto.IchubResult
- func (this *EsWebClient) Cmd(cmd *pagereq.CmdRequest) *basedto.IchubResult
- func (this *EsWebClient) CmdBulkCreate(cmd *pagereq.CmdRequest) *basedto.IchubResult
- func (this *EsWebClient) CmdBulkDelete(cmd *pagereq.CmdRequest) *basedto.IchubResult
- func (this *EsWebClient) CmdBulkIndex(cmd *pagereq.CmdRequest) *basedto.IchubResult
- func (this *EsWebClient) CmdBulkUpdate(cmd *pagereq.CmdRequest) *basedto.IchubResult
- func (this *EsWebClient) CmdDelete(index schema.Tabler, ids []string) *basedto.IchubResult
- func (this *EsWebClient) CreateAlias(indexname, aliasname string) *basedto.IchubResult
- func (webcli *EsWebClient) CreateIndexIfNotExist(index baseindex.IndexMapping) *basedto.IchubResult
- func (webcli *EsWebClient) CreateIndexesIfNotExist(indexes ...baseindex.IndexMapping) *basedto.IchubResult
- func (webcli *EsWebClient) Delete(tabler schema.Tabler, id any) *basedto.IchubResult
- func (webcli *EsWebClient) DeleteByQuery(req *pagereq.CmdRequest) *basedto.IchubResult
- func (webcli *EsWebClient) ExecuteQuery(q *pagereqcli.HttpCliQuery) *page.PageResult
- func (webcli *EsWebClient) ExistId(q *pagereq.QueryRequest) *page.PageResult
- func (this *EsWebClient) Filter(req *pagereq.QueryRequest) *page.PageResult
- func (webcli *EsWebClient) GeneralQuerySource(q *pagereqcli.HttpCliQuery) *page.PageResult
- func (this *EsWebClient) Get(IndexName, Id string) *page.PageResult
- func (webcli *EsWebClient) HttpCliQuery(q *pagereqcli.HttpCliQuery, query ...elastic.Query) *page.PageResult
- func (webcli *EsWebClient) HttpCliQueryNew(q *pagereqcli.HttpCliQuery, query elastic.Query) *page.PageResult
- func (webcli *EsWebClient) HttpQuery(q *pagereqcli.HttpCliQuery, query ...elastic.Query) *page.PageResult
- func (webcli *EsWebClient) HttpQuerySource(q *pagereqcli.HttpCliQuery) *page.PageResult
- func (webcli *EsWebClient) InsertIfNotExists(req *pagereq.CmdRequest) *basedto.IchubResult
- func (this *EsWebClient) Keyword(req *pagees.PageEsRequest) *page.PageResult
- func (webcli *EsWebClient) MetaCreateIndex(index baseindex.IndexMapping) *basedto.IchubResult
- func (webcli *EsWebClient) MetaDropIndex(index schema.Tabler) *basedto.IchubResult
- func (webcli *EsWebClient) MetaGetMapping(index schema.Tabler) *basedto.IchubResult
- func (webcli *EsWebClient) MetaIndexExists(index schema.Tabler) *basedto.IchubResult
- func (this *EsWebClient) Metadata(req *pagereq.MetadataRequest) *basedto.IchubResult
- func (this *EsWebClient) Must(req *pagereq.QueryRequest) *page.PageResult
- func (this *EsWebClient) MustNot(req *pagereq.QueryRequest) *page.PageResult
- func (this *EsWebClient) Query(req *pagereq.QueryRequest) *page.PageResult
- func (this *EsWebClient) QueryAs(req *pagereq.QueryRequest, out interface{}) *page.PageResult
- func (this *EsWebClient) Should(req *pagereq.QueryRequest) *page.PageResult
- func (this *EsWebClient) Single() bool
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 ¶
依赖 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 (this *EsWebClient) Cmd(cmd *pagereq.CmdRequest) *basedto.IchubResult
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
Click to show internal directories.
Click to hide internal directories.