esreq

Documentation

Index

• func NewOfIndexObject[T baseindex.IndexObject]() T
• func NewOfIndexType[T baseindex.IndexMapping]() T
• type BaseRequest
  • func NewBaseRequest[T schema.Tabler]() *BaseRequest[T]
  • func (self *BaseRequest[T]) Cms2QueryReq(indexTable baseindex.IndexTable, id string) *pagereq.QueryRequest
  • func (self *BaseRequest[T]) Index() baseindex.IndexMapping
  • func (self *BaseRequest[T]) NewOfTablerType() T
  • func (self *BaseRequest[T]) SetIndex(index baseindex.IndexMapping)
• type CmdRequest
  • func DefaultCmd[T schema.Tabler]() *CmdRequest[T]
  • func DefaultCmdAs[T schema.Tabler](o T) *CmdRequest[T]
  • func (self *CmdRequest[T]) BulkDelete(ids ...any) *basedto.IchubResult
  • func (self *CmdRequest[T]) BulkUpsert() *basedto.IchubResult
  • func (self *CmdRequest[T]) CmsExistId(id string) *page.PageResult
  • func (self *CmdRequest[T]) Delete(id any) *basedto.IchubResult
  • func (self *CmdRequest[T]) DeleteByQuery() *basedto.IchubResult
  • func (self *CmdRequest[T]) Save(id any, doc map[string]any) *basedto.IchubResult
  • func (self *CmdRequest[T]) SaveIndex(index baseindex.IndexIface) *basedto.IchubResult
  • func (self *CmdRequest[T]) SaveStru(id any, stru any) *basedto.IchubResult
  • func (self *CmdRequest[T]) UpdataParam2Script(fieldAsParams map[string]interface{}) string
  • func (self *CmdRequest[T]) Update(ids any, doc map[string]any) *basedto.IchubResult
  • func (self *CmdRequest[T]) Update2Err(id any, doc map[string]any) error
  • func (self *CmdRequest[T]) UpdateByQuery(updateClause string, fieldParams map[string]any) *basedto.IchubResult
  • func (self *CmdRequest[T]) UpdateByQueryParam(fieldAsParams map[string]any) *basedto.IchubResult
  • func (self *CmdRequest[T]) UpdateIndex(doc baseindex.IndexIface) *basedto.IchubResult
  • func (self *CmdRequest[T]) UpdateStru(ids any, doc any) *basedto.IchubResult
  • func (self *CmdRequest[T]) WebSaveIndex(id any) *basedto.IchubResult
• type MetaRequest
  • func DefaultMeta[T baseindex.IndexMapping]() *MetaRequest[T]
  • func DefaultMetaAs[T baseindex.IndexObject](o T) *MetaRequest[T]
  • func (self *MetaRequest[T]) CreateIndexIfNotExist() *basedto.IchubResult
  • func (self *MetaRequest[T]) CreateIndexesIfNotExist() *basedto.IchubResult
  • func (self *MetaRequest[T]) MetaCreateIndex() *basedto.IchubResult
  • func (self *MetaRequest[T]) MetaDropIndex() *basedto.IchubResult
  • func (self *MetaRequest[T]) MetaGetMapping() *basedto.IchubResult
  • func (self *MetaRequest[T]) MetaIndexExists() *basedto.IchubResult
• type WebRequest
  • func Default[T schema.Tabler]() *WebRequest[T]
  • func DefaultAs[T schema.Tabler](o T) *WebRequest[T]
  • func DefaultOf[T schema.Tabler](generalQ elastic.Query) *WebRequest[T]
  • func (self *WebRequest[T]) ExistId(id string) *pagemodel.PageResult[T]
  • func (self *WebRequest[T]) FromPageResult(result *page.PageResult) *pagemodel.PageResult[T]
  • func (self *WebRequest[T]) GeneralQuery() *pagemodel.PageResult[T]
  • func (self *WebRequest[T]) GeneralQueryMax() *pagemodel.PageResult[T]
  • func (self *WebRequest[T]) GeneralQueryMaxMax() *pagemodel.PageResult[T]
  • func (self *WebRequest[T]) Get(ids any) *pagemodel.PageResult[T]
  • func (self *WebRequest[T]) GetIndex(indexTable baseindex.IndexTable, ids any) *pagemodel.PageResult[T]
  • func (self *WebRequest[T]) Query(q elastic.Query) *WebRequest[T]
  • func (self *WebRequest[T]) QueryResult() *pagemodel.PageResult[T]
  • func (self *WebRequest[T]) Result2List(result *page.PageResult) []T
  • func (self *WebRequest[T]) Result2Tablers(result *pagemodel.PageResult[T]) []schema.Tabler
  • func (self *WebRequest[T]) SetModels(models any) *WebRequest[T]
  • func (self *WebRequest[T]) Stru2Filter(result *pagemodel.PageResult[T]) []any

Functions

func NewOfIndexObject

func NewOfIndexObject[T baseindex.IndexObject]() T

func NewOfIndexType

func NewOfIndexType[T baseindex.IndexMapping]() T

Types

type BaseRequest

type BaseRequest[T schema.Tabler] struct {
	EsWebClient *eswebclient.EsWebClient
	// contains filtered or unexported fields
}

func NewBaseRequest

func NewBaseRequest[T schema.Tabler]() *BaseRequest[T]

func (*BaseRequest[T]) Cms2QueryReq

func (self *BaseRequest[T]) Cms2QueryReq(indexTable baseindex.IndexTable, id string) *pagereq.QueryRequest

func (*BaseRequest[T]) Index

func (self *BaseRequest[T]) Index() baseindex.IndexMapping

func (*BaseRequest[T]) NewOfTablerType

func (self *BaseRequest[T]) NewOfTablerType() T

func (*BaseRequest[T]) SetIndex

func (self *BaseRequest[T]) SetIndex(index baseindex.IndexMapping)

type CmdRequest

type CmdRequest[T schema.Tabler] struct {
	*pagereq.CmdRequest
	*BaseRequest[T]
}

func DefaultCmd

func DefaultCmd[T schema.Tabler]() *CmdRequest[T]

func DefaultCmdAs

func DefaultCmdAs[T schema.Tabler](o T) *CmdRequest[T]

func (*CmdRequest[T]) BulkDelete

func (self *CmdRequest[T]) BulkDelete(ids ...any) *basedto.IchubResult

func (*CmdRequest[T]) BulkUpsert

func (self *CmdRequest[T]) BulkUpsert() *basedto.IchubResult

func (*CmdRequest[T]) CmsExistId

func (self *CmdRequest[T]) CmsExistId(id string) *page.PageResult

func (*CmdRequest[T]) Delete

func (self *CmdRequest[T]) Delete(id any) *basedto.IchubResult

func (*CmdRequest[T]) DeleteByQuery

func (self *CmdRequest[T]) DeleteByQuery() *basedto.IchubResult

func (*CmdRequest[T]) Save

func (self *CmdRequest[T]) Save(id any, doc map[string]any) *basedto.IchubResult

func (*CmdRequest[T]) SaveIndex

func (self *CmdRequest[T]) SaveIndex(index baseindex.IndexIface) *basedto.IchubResult

func (*CmdRequest[T]) SaveStru

func (self *CmdRequest[T]) SaveStru(id any, stru any) *basedto.IchubResult

func (*CmdRequest[T]) UpdataParam2Script

func (self *CmdRequest[T]) UpdataParam2Script(fieldAsParams map[string]interface{}) string

func (*CmdRequest[T]) Update

func (self *CmdRequest[T]) Update(ids any, doc map[string]any) *basedto.IchubResult

func (*CmdRequest[T]) Update2Err

func (self *CmdRequest[T]) Update2Err(id any, doc map[string]any) error

func (*CmdRequest[T]) UpdateByQuery

func (self *CmdRequest[T]) UpdateByQuery(updateClause string, fieldParams map[string]any) *basedto.IchubResult

func (*CmdRequest[T]) UpdateByQueryParam

func (self *CmdRequest[T]) UpdateByQueryParam(fieldAsParams map[string]any) *basedto.IchubResult

参数名=字段名

func (*CmdRequest[T]) UpdateIndex

func (self *CmdRequest[T]) UpdateIndex(doc baseindex.IndexIface) *basedto.IchubResult

func (*CmdRequest[T]) UpdateStru

func (self *CmdRequest[T]) UpdateStru(ids any, doc any) *basedto.IchubResult

func (*CmdRequest[T]) WebSaveIndex

func (self *CmdRequest[T]) WebSaveIndex(id any) *basedto.IchubResult

type MetaRequest

type MetaRequest[T baseindex.IndexMapping] struct {
	*pagereq.MetadataRequest
	*BaseRequest[T]
}

func DefaultMeta

func DefaultMeta[T baseindex.IndexMapping]() *MetaRequest[T]

func DefaultMetaAs

func DefaultMetaAs[T baseindex.IndexObject](o T) *MetaRequest[T]

func (*MetaRequest[T]) CreateIndexIfNotExist

func (self *MetaRequest[T]) CreateIndexIfNotExist() *basedto.IchubResult

func (*MetaRequest[T]) CreateIndexesIfNotExist

func (self *MetaRequest[T]) CreateIndexesIfNotExist() *basedto.IchubResult

func (*MetaRequest[T]) MetaCreateIndex

func (self *MetaRequest[T]) MetaCreateIndex() *basedto.IchubResult

func (*MetaRequest[T]) MetaDropIndex

func (self *MetaRequest[T]) MetaDropIndex() *basedto.IchubResult

func (*MetaRequest[T]) MetaGetMapping

func (self *MetaRequest[T]) MetaGetMapping() *basedto.IchubResult

func (*MetaRequest[T]) MetaIndexExists

func (self *MetaRequest[T]) MetaIndexExists() *basedto.IchubResult

type WebRequest

type WebRequest[T schema.Tabler] struct {
	*BaseRequest[T]
	*pagereqcli.HttpCliQuery
	Records []T `json:"records"`
}

func Default

func Default[T schema.Tabler]() *WebRequest[T]

func DefaultAs

func DefaultAs[T schema.Tabler](o T) *WebRequest[T]

func DefaultOf

func DefaultOf[T schema.Tabler](generalQ elastic.Query) *WebRequest[T]

func (*WebRequest[T]) ExistId

func (self *WebRequest[T]) ExistId(id string) *pagemodel.PageResult[T]

func (*WebRequest[T]) FromPageResult

func (self *WebRequest[T]) FromPageResult(result *page.PageResult) *pagemodel.PageResult[T]

func (*WebRequest[T]) GeneralQuery

func (self *WebRequest[T]) GeneralQuery() *pagemodel.PageResult[T]

func (*WebRequest[T]) GeneralQueryMax

func (self *WebRequest[T]) GeneralQueryMax() *pagemodel.PageResult[T]

func (*WebRequest[T]) GeneralQueryMaxMax

func (self *WebRequest[T]) GeneralQueryMaxMax() *pagemodel.PageResult[T]

func (*WebRequest[T]) Get

func (self *WebRequest[T]) Get(ids any) *pagemodel.PageResult[T]

get

func (*WebRequest[T]) GetIndex

func (self *WebRequest[T]) GetIndex(indexTable baseindex.IndexTable, ids any) *pagemodel.PageResult[T]

func (*WebRequest[T]) Query

func (self *WebRequest[T]) Query(q elastic.Query) *WebRequest[T]

func (*WebRequest[T]) QueryResult

func (self *WebRequest[T]) QueryResult() *pagemodel.PageResult[T]

func (*WebRequest[T]) Result2List

func (self *WebRequest[T]) Result2List(result *page.PageResult) []T

func (*WebRequest[T]) Result2Tablers

func (self *WebRequest[T]) Result2Tablers(result *pagemodel.PageResult[T]) []schema.Tabler

func (*WebRequest[T]) SetModels

func (self *WebRequest[T]) SetModels(models any) *WebRequest[T]

func (*WebRequest[T]) Stru2Filter

func (self *WebRequest[T]) Stru2Filter(result *pagemodel.PageResult[T]) []any