Versions in this module Expand all Collapse all v1 v1.8.7 May 20, 2022 Changes in this version + var EsServiceMap = map[int]func(conn *escache.EsConnect) (EsInterface, error) + var VerError = errors.New("ES版本暂只支持6,7") + type EsInterface interface + Cancel func(ctx *fiber.Ctx, task *escache.CancelTask) (err error) + Cat func(ctx *fiber.Ctx, rest *escache.EsCat) (err error) + CleanupeRepository func(ctx *fiber.Ctx, repository *escache.CleanupeRepository) (err error) + CreateSnapshot func(ctx *fiber.Ctx, snapshot *escache.CreateSnapshot) (err error) + CrudGetDSL func(ctx *fiber.Ctx, task *escache.CrudFilter) (err error) + CrudGetList func(ctx *fiber.Ctx, task *escache.CrudFilter) (err error) + EsDocDeleteRowByID func(ctx *fiber.Ctx, id *escache.EsDocDeleteRowByID) (err error) + EsDocInsert func(ctx *fiber.Ctx, id *escache.EsDocUpdateByID) (err error) + EsDocUpdateByID func(ctx *fiber.Ctx, id *escache.EsDocUpdateByID) (err error) + EsIndexCatStatus func(ctx *fiber.Ctx, info *escache.EsIndexInfo) (err error) + EsIndexCreate func(ctx *fiber.Ctx, info *escache.EsIndexInfo) (err error) + EsIndexDelete func(ctx *fiber.Ctx, info *escache.EsIndexInfo) (err error) + EsIndexGetAlias func(ctx *fiber.Ctx, info *escache.EsAliasInfo) (err error) + EsIndexGetSettings func(ctx *fiber.Ctx, info *escache.EsIndexInfo) (err error) + EsIndexGetSettingsInfo func(ctx *fiber.Ctx, info *escache.EsIndexInfo) (err error) + EsIndexIndexNames func(ctx *fiber.Ctx) (err error) + EsIndexOperateAlias func(ctx *fiber.Ctx, info *escache.EsAliasInfo) (err error) + EsIndexReindex func(ctx *fiber.Ctx, info *escache.EsReIndexInfo) (err error) + EsIndexStats func(ctx *fiber.Ctx, info *escache.EsIndexInfo) (err error) + EsMappingList func(ctx *fiber.Ctx, properties *escache.EsMapGetProperties) (err error) + Optimize func(ctx *fiber.Ctx, optimize *escache.EsOptimize) (err error) + RecoverCanWrite func(ctx *fiber.Ctx) (err error) + RunDsl func(ctx *fiber.Ctx, optimize *escache.EsRest) (err error) + SnapshotCreateRepository func(ctx *fiber.Ctx, snapshotCreateRepository *escache.SnapshotCreateRepository) (err error) + SnapshotDelete func(ctx *fiber.Ctx, snapshotDelete *escache.SnapshotDelete) (err error) + SnapshotDeleteRepository func(ctx *fiber.Ctx, repository *escache.SnapshotDeleteRepository) (err error) + SnapshotDetail func(ctx *fiber.Ctx, detail *escache.SnapshotDetail) (err error) + SnapshotList func(ctx *fiber.Ctx, list *escache.SnapshotList) (err error) + SnapshotRepositoryList func(ctx *fiber.Ctx, esSnapshotInfo *escache.EsSnapshotInfo) (err error) + SnapshotRestore func(ctx *fiber.Ctx, restore *escache.SnapshotRestore) (err error) + SnapshotStatus func(ctx *fiber.Ctx, status *escache.SnapshotStatus) (err error) + TaskList func(ctx *fiber.Ctx) (err error) + UpdateMapping func(ctx *fiber.Ctx, mapping *escache.UpdateMapping) (err error) + func NewEsService(conn *escache.EsConnect) (EsInterface, error) + func NewEsServiceV6(connect *escache.EsConnect) (service EsInterface, err error) + func NewEsServiceV7(connect *escache.EsConnect) (service EsInterface, err error) + func NewEsServiceV8(connect *escache.EsConnect) (service EsInterface, err error) + type EsServiceV6 struct + func (this EsServiceV6) Cancel(ctx *fiber.Ctx, cancelTask *escache.CancelTask) (err error) + func (this EsServiceV6) Cat(ctx *fiber.Ctx, esCat *escache.EsCat) (err error) + func (this EsServiceV6) CleanupeRepository(ctx *fiber.Ctx, cleanupeRepository *escache.CleanupeRepository) (err error) + func (this EsServiceV6) CreateSnapshot(ctx *fiber.Ctx, createSnapshot *escache.CreateSnapshot) (err error) + func (this EsServiceV6) CrudGetDSL(ctx *fiber.Ctx, crudFilter *escache.CrudFilter) (err error) + func (this EsServiceV6) CrudGetList(ctx *fiber.Ctx, crudFilter *escache.CrudFilter) (err error) + func (this EsServiceV6) EsDocDeleteRowByID(ctx *fiber.Ctx, esDocDeleteRowByID *escache.EsDocDeleteRowByID) (err error) + func (this EsServiceV6) EsDocInsert(ctx *fiber.Ctx, esDocUpdateByID *escache.EsDocUpdateByID) (err error) + func (this EsServiceV6) EsDocUpdateByID(ctx *fiber.Ctx, esDocUpdateByID *escache.EsDocUpdateByID) (err error) + func (this EsServiceV6) EsIndexCatStatus(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV6) EsIndexCreate(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV6) EsIndexDelete(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV6) EsIndexGetAlias(ctx *fiber.Ctx, esAliasInfo *escache.EsAliasInfo) (err error) + func (this EsServiceV6) EsIndexGetSettings(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV6) EsIndexGetSettingsInfo(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV6) EsIndexIndexNames(ctx *fiber.Ctx) (err error) + func (this EsServiceV6) EsIndexOperateAlias(ctx *fiber.Ctx, esAliasInfo *escache.EsAliasInfo) (err error) + func (this EsServiceV6) EsIndexReindex(ctx *fiber.Ctx, esReIndexInfo *escache.EsReIndexInfo) (err error) + func (this EsServiceV6) EsIndexStats(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV6) EsMappingList(ctx *fiber.Ctx, esConnect *escache.EsMapGetProperties) (err error) + func (this EsServiceV6) Optimize(ctx *fiber.Ctx, esOptimize *escache.EsOptimize) (err error) + func (this EsServiceV6) RecoverCanWrite(ctx *fiber.Ctx) (err error) + func (this EsServiceV6) RunDsl(ctx *fiber.Ctx, esRest *escache.EsRest) (err error) + func (this EsServiceV6) SnapshotCreateRepository(ctx *fiber.Ctx, snapshotCreateRepository *escache.SnapshotCreateRepository) (err error) + func (this EsServiceV6) SnapshotDelete(ctx *fiber.Ctx, snapshotDelete *escache.SnapshotDelete) (err error) + func (this EsServiceV6) SnapshotDeleteRepository(ctx *fiber.Ctx, repository *escache.SnapshotDeleteRepository) (err error) + func (this EsServiceV6) SnapshotDetail(ctx *fiber.Ctx, snapshotDetail *escache.SnapshotDetail) (err error) + func (this EsServiceV6) SnapshotList(ctx *fiber.Ctx, snapshotList *escache.SnapshotList) (err error) + func (this EsServiceV6) SnapshotRepositoryList(ctx *fiber.Ctx, esSnapshotInfo *escache.EsSnapshotInfo) (err error) + func (this EsServiceV6) SnapshotRestore(ctx *fiber.Ctx, snapshotRestore *escache.SnapshotRestore) (err error) + func (this EsServiceV6) SnapshotStatus(ctx *fiber.Ctx, snapshotStatus *escache.SnapshotStatus) (err error) + func (this EsServiceV6) TaskList(ctx *fiber.Ctx) (err error) + func (this EsServiceV6) UpdateMapping(ctx *fiber.Ctx, updateMapping *escache.UpdateMapping) (err error) + type EsServiceV7 struct + func (this EsServiceV7) Cancel(ctx *fiber.Ctx, cancelTask *escache.CancelTask) (err error) + func (this EsServiceV7) Cat(ctx *fiber.Ctx, esCat *escache.EsCat) (err error) + func (this EsServiceV7) CleanupeRepository(ctx *fiber.Ctx, cleanupeRepository *escache.CleanupeRepository) (err error) + func (this EsServiceV7) CreateSnapshot(ctx *fiber.Ctx, createSnapshot *escache.CreateSnapshot) (err error) + func (this EsServiceV7) CrudGetDSL(ctx *fiber.Ctx, crudFilter *escache.CrudFilter) (err error) + func (this EsServiceV7) CrudGetList(ctx *fiber.Ctx, crudFilter *escache.CrudFilter) (err error) + func (this EsServiceV7) EsDocDeleteRowByID(ctx *fiber.Ctx, esDocDeleteRowByID *escache.EsDocDeleteRowByID) (err error) + func (this EsServiceV7) EsDocInsert(ctx *fiber.Ctx, esDocUpdateByID *escache.EsDocUpdateByID) (err error) + func (this EsServiceV7) EsDocUpdateByID(ctx *fiber.Ctx, esDocUpdateByID *escache.EsDocUpdateByID) (err error) + func (this EsServiceV7) EsIndexCatStatus(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV7) EsIndexCreate(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV7) EsIndexDelete(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV7) EsIndexGetAlias(ctx *fiber.Ctx, esAliasInfo *escache.EsAliasInfo) (err error) + func (this EsServiceV7) EsIndexGetSettings(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV7) EsIndexGetSettingsInfo(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV7) EsIndexIndexNames(ctx *fiber.Ctx) (err error) + func (this EsServiceV7) EsIndexOperateAlias(ctx *fiber.Ctx, esAliasInfo *escache.EsAliasInfo) (err error) + func (this EsServiceV7) EsIndexReindex(ctx *fiber.Ctx, esReIndexInfo *escache.EsReIndexInfo) (err error) + func (this EsServiceV7) EsIndexStats(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV7) EsMappingList(ctx *fiber.Ctx, esConnect *escache.EsMapGetProperties) (err error) + func (this EsServiceV7) Optimize(ctx *fiber.Ctx, esOptimize *escache.EsOptimize) (err error) + func (this EsServiceV7) RecoverCanWrite(ctx *fiber.Ctx) (err error) + func (this EsServiceV7) RunDsl(ctx *fiber.Ctx, esRest *escache.EsRest) (err error) + func (this EsServiceV7) SnapshotCreateRepository(ctx *fiber.Ctx, snapshotCreateRepository *escache.SnapshotCreateRepository) (err error) + func (this EsServiceV7) SnapshotDelete(ctx *fiber.Ctx, snapshotDelete *escache.SnapshotDelete) (err error) + func (this EsServiceV7) SnapshotDeleteRepository(ctx *fiber.Ctx, repository *escache.SnapshotDeleteRepository) (err error) + func (this EsServiceV7) SnapshotDetail(ctx *fiber.Ctx, snapshotDetail *escache.SnapshotDetail) (err error) + func (this EsServiceV7) SnapshotList(ctx *fiber.Ctx, snapshotList *escache.SnapshotList) (err error) + func (this EsServiceV7) SnapshotRepositoryList(ctx *fiber.Ctx, esSnapshotInfo *escache.EsSnapshotInfo) (err error) + func (this EsServiceV7) SnapshotRestore(ctx *fiber.Ctx, snapshotRestore *escache.SnapshotRestore) (err error) + func (this EsServiceV7) SnapshotStatus(ctx *fiber.Ctx, snapshotStatus *escache.SnapshotStatus) (err error) + func (this EsServiceV7) TaskList(ctx *fiber.Ctx) (err error) + func (this EsServiceV7) UpdateMapping(ctx *fiber.Ctx, updateMapping *escache.UpdateMapping) (err error) + type EsServiceV8 struct + func (this EsServiceV8) Cancel(ctx *fiber.Ctx, cancelTask *escache.CancelTask) (err error) + func (this EsServiceV8) Cat(ctx *fiber.Ctx, esCat *escache.EsCat) (err error) + func (this EsServiceV8) CleanupeRepository(ctx *fiber.Ctx, cleanupeRepository *escache.CleanupeRepository) (err error) + func (this EsServiceV8) CreateSnapshot(ctx *fiber.Ctx, createSnapshot *escache.CreateSnapshot) (err error) + func (this EsServiceV8) CrudGetDSL(ctx *fiber.Ctx, crudFilter *escache.CrudFilter) (err error) + func (this EsServiceV8) CrudGetList(ctx *fiber.Ctx, crudFilter *escache.CrudFilter) (err error) + func (this EsServiceV8) EsDocDeleteRowByID(ctx *fiber.Ctx, esDocDeleteRowByID *escache.EsDocDeleteRowByID) (err error) + func (this EsServiceV8) EsDocInsert(ctx *fiber.Ctx, esDocUpdateByID *escache.EsDocUpdateByID) (err error) + func (this EsServiceV8) EsDocUpdateByID(ctx *fiber.Ctx, esDocUpdateByID *escache.EsDocUpdateByID) (err error) + func (this EsServiceV8) EsIndexCatStatus(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV8) EsIndexCreate(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV8) EsIndexDelete(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV8) EsIndexGetAlias(ctx *fiber.Ctx, esAliasInfo *escache.EsAliasInfo) (err error) + func (this EsServiceV8) EsIndexGetSettings(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV8) EsIndexGetSettingsInfo(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV8) EsIndexIndexNames(ctx *fiber.Ctx) (err error) + func (this EsServiceV8) EsIndexOperateAlias(ctx *fiber.Ctx, esAliasInfo *escache.EsAliasInfo) (err error) + func (this EsServiceV8) EsIndexReindex(ctx *fiber.Ctx, esReIndexInfo *escache.EsReIndexInfo) (err error) + func (this EsServiceV8) EsIndexStats(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error) + func (this EsServiceV8) EsMappingList(ctx *fiber.Ctx, esConnect *escache.EsMapGetProperties) (err error) + func (this EsServiceV8) Optimize(ctx *fiber.Ctx, esOptimize *escache.EsOptimize) (err error) + func (this EsServiceV8) RecoverCanWrite(ctx *fiber.Ctx) (err error) + func (this EsServiceV8) RunDsl(ctx *fiber.Ctx, esRest *escache.EsRest) (err error) + func (this EsServiceV8) SnapshotCreateRepository(ctx *fiber.Ctx, snapshotCreateRepository *escache.SnapshotCreateRepository) (err error) + func (this EsServiceV8) SnapshotDelete(ctx *fiber.Ctx, snapshotDelete *escache.SnapshotDelete) (err error) + func (this EsServiceV8) SnapshotDeleteRepository(ctx *fiber.Ctx, repository *escache.SnapshotDeleteRepository) (err error) + func (this EsServiceV8) SnapshotDetail(ctx *fiber.Ctx, snapshotDetail *escache.SnapshotDetail) (err error) + func (this EsServiceV8) SnapshotList(ctx *fiber.Ctx, snapshotList *escache.SnapshotList) (err error) + func (this EsServiceV8) SnapshotRepositoryList(ctx *fiber.Ctx, esSnapshotInfo *escache.EsSnapshotInfo) (err error) + func (this EsServiceV8) SnapshotRestore(ctx *fiber.Ctx, snapshotRestore *escache.SnapshotRestore) (err error) + func (this EsServiceV8) SnapshotStatus(ctx *fiber.Ctx, snapshotStatus *escache.SnapshotStatus) (err error) + func (this EsServiceV8) TaskList(ctx *fiber.Ctx) (err error) + func (this EsServiceV8) UpdateMapping(ctx *fiber.Ctx, updateMapping *escache.UpdateMapping) (err error)
Go to main page