Documentation
¶
Index ¶
- func InjectEsWebClient(s *EsWebClient)
- func LoadEsWebClient() baseiface.ISingleton
- func MetaCreateIndex[T baseindex.IndexMapping]() *basedto.IchubResult
- func MetaNewIndexMapping[T baseindex.IndexMapping]() T
- type EsWebClient
- func (self *EsWebClient) BulkCreate(tabler schema.Tabler, docs []*cmddto.BulkDoc) *basedto.IchubResult
- func (self *EsWebClient) BulkDelete(tabler schema.Tabler, ids ...any) *basedto.IchubResult
- func (self *EsWebClient) BulkIndex(tabler schema.Tabler, docs []*cmddto.BulkDoc) *basedto.IchubResult
- func (self *EsWebClient) BulkScriptUpdate(tabler schema.Tabler, docs []*cmddto.BulkDoc) *basedto.IchubResult
- func (self *EsWebClient) BulkUpdate(tabler schema.Tabler, docs []*cmddto.BulkDoc) *basedto.IchubResult
- func (self *EsWebClient) BulkUpsert(cmd *pagereq.CmdRequest) *basedto.IchubResult
- func (self *EsWebClient) Cmd(req *pagereq.CmdRequest) *basedto.IchubResult
- func (self *EsWebClient) CreateAlias(indexname, aliasname string) *basedto.IchubResult
- func (self *EsWebClient) CreateIndexIfNotExist(index baseindex.IndexMapping) *basedto.IchubResult
- func (self *EsWebClient) CreateIndexesIfNotExist(indexes ...baseindex.IndexMapping) *basedto.IchubResult
- func (self *EsWebClient) Delete(tabler schema.Tabler, id any) *basedto.IchubResult
- func (self *EsWebClient) DeleteByQuery(req *pagereq.CmdRequest) *basedto.IchubResult
- func (self *EsWebClient) ExecuteQuery(q *pagereqcli.HttpCliQuery) *page.PageResult
- func (self *EsWebClient) ExistId(q *pagereq.QueryRequest) *page.PageResult
- func (self *EsWebClient) Filter(req *pagereq.QueryRequest) *page.PageResult
- func (self *EsWebClient) GeneralQuerySource(q *pagereqcli.HttpCliQuery) *page.PageResult
- func (self *EsWebClient) Get(IndexName, Id string) *page.PageResult
- func (self *EsWebClient) GetServiceAddr() string
- func (self *EsWebClient) Health() *basedto.IchubResult
- func (self *EsWebClient) HttpCliQuery(q *pagereq.QueryRequest, query ...elastic.Query) *page.PageResult
- func (self *EsWebClient) HttpCliQueryBase(q *pagereq.QueryRequest, query elastic.Query) *page.PageResult
- func (self *EsWebClient) HttpKeyword(q *pagereq.KeywordRequest) *page.PageResult
- func (self *EsWebClient) HttpQuery(q *pagereqcli.HttpCliQuery, query ...elastic.Query) *page.PageResult
- func (self *EsWebClient) HttpQuerySource(q *pagereqcli.HttpCliQuery) *page.PageResult
- func (self *EsWebClient) HttpQuerySourceAs(q *pagereqcli.HttpCliQuery, models any) *page.PageResult
- func (self *EsWebClient) InsertIfNotExists(req *pagereq.CmdRequest) *basedto.IchubResult
- func (self *EsWebClient) Keyword(q *pagereq.KeywordRequest) *page.PageResult
- func (self *EsWebClient) MetaCreateAlias(index schema.Tabler) *basedto.IchubResult
- func (self *EsWebClient) MetaCreateIndex(index baseindex.IndexMapping) *basedto.IchubResult
- func (self *EsWebClient) MetaDropIndex(index schema.Tabler) *basedto.IchubResult
- func (self *EsWebClient) MetaGetMapping(index schema.Tabler) *basedto.IchubResult
- func (self *EsWebClient) MetaIndexExists(index schema.Tabler) *basedto.IchubResult
- func (self *EsWebClient) MetaParse2Stru(index schema.Tabler) *basedto.IchubResult
- func (self *EsWebClient) Metadata(req *pagereq.MetadataRequest) *basedto.IchubResult
- func (self *EsWebClient) Must(req *pagereq.QueryRequest) *page.PageResult
- func (self *EsWebClient) MustNot(req *pagereq.QueryRequest) *page.PageResult
- func (self *EsWebClient) Query(q *pagereq.QueryRequest) *page.PageResult
- func (self *EsWebClient) QueryAs(req *pagereq.QueryRequest, out any) *page.PageResult
- func (self *EsWebClient) QueryPageui(req *pagereq.QueryRequest) *pageui.PageuiResult
- func (self *EsWebClient) QueryStats(q *pagereq.QueryRequest) *page.PageResult
- func (self *EsWebClient) ReopenEs() *page.PageResult
- func (self *EsWebClient) Should(req *pagereq.QueryRequest) *page.PageResult
- func (self *EsWebClient) ShowConfig120(envKey string) []string
- func (self *EsWebClient) Single() bool
- func (self *EsWebClient) Stat() *basedto.IchubResult
- func (self *EsWebClient) StopEs() *page.PageResult
- func (self *EsWebClient) Update(cmd *pagereq.CmdRequest, id any, doc map[string]any) *basedto.IchubResult
- func (self *EsWebClient) UpdateByQuery(req *pagereq.CmdRequest) *basedto.IchubResult
- func (self *EsWebClient) UpdateStru(cmd *pagereq.CmdRequest, id any, stru any) *basedto.IchubResult
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 ¶
依赖 suite.Suite
func Default ¶
func Default() *EsWebClient
func DefaultEs ¶
func DefaultEs() *EsWebClient
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 (self *EsWebClient) Cmd(req *pagereq.CmdRequest) *basedto.IchubResult
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
Click to show internal directories.
Click to hide internal directories.