es

package
v1.8.7 Latest Latest
Warning

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

 Go to latest Published: May 20, 2022 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EsServiceMap = map[int]func(conn *escache.EsConnect) (EsInterface, error){
	6: NewEsServiceV6,
	7: NewEsServiceV7,
	8: NewEsServiceV8,
}
View Source 
var VerError = errors.New("ES版本暂只支持6,7")

Functions

This section is empty.

Types

type EsInterface 

type EsInterface interface {
	SnapshotRepositoryList(ctx *fiber.Ctx, esSnapshotInfo *escache.EsSnapshotInfo) (err error)
	SnapshotCreateRepository(ctx *fiber.Ctx, snapshotCreateRepository *escache.SnapshotCreateRepository) (err error)
	CleanupeRepository(ctx *fiber.Ctx, repository *escache.CleanupeRepository) (err error)
	SnapshotDeleteRepository(ctx *fiber.Ctx, repository *escache.SnapshotDeleteRepository) (err error)
	CreateSnapshot(ctx *fiber.Ctx, snapshot *escache.CreateSnapshot) (err error)
	SnapshotList(ctx *fiber.Ctx, list *escache.SnapshotList) (err error)
	SnapshotDelete(ctx *fiber.Ctx, snapshotDelete *escache.SnapshotDelete) (err error)
	SnapshotDetail(ctx *fiber.Ctx, detail *escache.SnapshotDetail) (err error)
	SnapshotRestore(ctx *fiber.Ctx, restore *escache.SnapshotRestore) (err error)
	SnapshotStatus(ctx *fiber.Ctx, status *escache.SnapshotStatus) (err error)
	Cat(ctx *fiber.Ctx, rest *escache.EsCat) (err error)
	RunDsl(ctx *fiber.Ctx, optimize *escache.EsRest) (err error)
	Optimize(ctx *fiber.Ctx, optimize *escache.EsOptimize) (err error)
	RecoverCanWrite(ctx *fiber.Ctx) (err error)
	EsDocDeleteRowByID(ctx *fiber.Ctx, id *escache.EsDocDeleteRowByID) (err error)
	EsDocUpdateByID(ctx *fiber.Ctx, id *escache.EsDocUpdateByID) (err error)
	EsDocInsert(ctx *fiber.Ctx, id *escache.EsDocUpdateByID) (err error)
	EsIndexCreate(ctx *fiber.Ctx, info *escache.EsIndexInfo) (err error)
	EsIndexDelete(ctx *fiber.Ctx, info *escache.EsIndexInfo) (err error)
	EsIndexGetSettings(ctx *fiber.Ctx, info *escache.EsIndexInfo) (err error)
	EsIndexGetSettingsInfo(ctx *fiber.Ctx, info *escache.EsIndexInfo) (err error)
	EsIndexGetAlias(ctx *fiber.Ctx, info *escache.EsAliasInfo) (err error)
	EsIndexOperateAlias(ctx *fiber.Ctx, info *escache.EsAliasInfo) (err error)
	EsIndexReindex(ctx *fiber.Ctx, info *escache.EsReIndexInfo) (err error)
	EsIndexIndexNames(ctx *fiber.Ctx) (err error)
	EsIndexStats(ctx *fiber.Ctx, info *escache.EsIndexInfo) (err error)
	EsIndexCatStatus(ctx *fiber.Ctx, info *escache.EsIndexInfo) (err error)
	EsMappingList(ctx *fiber.Ctx, properties *escache.EsMapGetProperties) (err error)
	UpdateMapping(ctx *fiber.Ctx, mapping *escache.UpdateMapping) (err error)
	TaskList(ctx *fiber.Ctx) (err error)
	Cancel(ctx *fiber.Ctx, task *escache.CancelTask) (err error)
	CrudGetList(ctx *fiber.Ctx, task *escache.CrudFilter) (err error)
	CrudGetDSL(ctx *fiber.Ctx, task *escache.CrudFilter) (err error)
}

func NewEsService 

func NewEsService(conn *escache.EsConnect) (EsInterface, error)

func NewEsServiceV6 

func NewEsServiceV6(connect *escache.EsConnect) (service EsInterface, err error)

func NewEsServiceV7 

func NewEsServiceV7(connect *escache.EsConnect) (service EsInterface, err error)

func NewEsServiceV8 

func NewEsServiceV8(connect *escache.EsConnect) (service EsInterface, err error)

type EsServiceV6 

type EsServiceV6 struct {
	response.Response
	request.Request
	// contains filtered or unexported fields
}

func (EsServiceV6) Cancel 

func (this EsServiceV6) Cancel(ctx *fiber.Ctx, cancelTask *escache.CancelTask) (err error)

func (EsServiceV6) Cat 

func (this EsServiceV6) Cat(ctx *fiber.Ctx, esCat *escache.EsCat) (err error)

func (EsServiceV6) CleanupeRepository 

func (this EsServiceV6) CleanupeRepository(ctx *fiber.Ctx, cleanupeRepository *escache.CleanupeRepository) (err error)

func (EsServiceV6) CreateSnapshot 

func (this EsServiceV6) CreateSnapshot(ctx *fiber.Ctx, createSnapshot *escache.CreateSnapshot) (err error)

func (EsServiceV6) CrudGetDSL 

func (this EsServiceV6) CrudGetDSL(ctx *fiber.Ctx, crudFilter *escache.CrudFilter) (err error)

func (EsServiceV6) CrudGetList 

func (this EsServiceV6) CrudGetList(ctx *fiber.Ctx, crudFilter *escache.CrudFilter) (err error)

func (EsServiceV6) EsDocDeleteRowByID 

func (this EsServiceV6) EsDocDeleteRowByID(ctx *fiber.Ctx, esDocDeleteRowByID *escache.EsDocDeleteRowByID) (err error)

func (EsServiceV6) EsDocInsert 

func (this EsServiceV6) EsDocInsert(ctx *fiber.Ctx, esDocUpdateByID *escache.EsDocUpdateByID) (err error)

func (EsServiceV6) EsDocUpdateByID 

func (this EsServiceV6) EsDocUpdateByID(ctx *fiber.Ctx, esDocUpdateByID *escache.EsDocUpdateByID) (err error)

func (EsServiceV6) EsIndexCatStatus 

func (this EsServiceV6) EsIndexCatStatus(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV6) EsIndexCreate 

func (this EsServiceV6) EsIndexCreate(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV6) EsIndexDelete 

func (this EsServiceV6) EsIndexDelete(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV6) EsIndexGetAlias 

func (this EsServiceV6) EsIndexGetAlias(ctx *fiber.Ctx, esAliasInfo *escache.EsAliasInfo) (err error)

func (EsServiceV6) EsIndexGetSettings 

func (this EsServiceV6) EsIndexGetSettings(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV6) EsIndexGetSettingsInfo 

func (this EsServiceV6) EsIndexGetSettingsInfo(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV6) EsIndexIndexNames 

func (this EsServiceV6) EsIndexIndexNames(ctx *fiber.Ctx) (err error)

func (EsServiceV6) EsIndexOperateAlias 

func (this EsServiceV6) EsIndexOperateAlias(ctx *fiber.Ctx, esAliasInfo *escache.EsAliasInfo) (err error)

func (EsServiceV6) EsIndexReindex 

func (this EsServiceV6) EsIndexReindex(ctx *fiber.Ctx, esReIndexInfo *escache.EsReIndexInfo) (err error)

func (EsServiceV6) EsIndexStats 

func (this EsServiceV6) EsIndexStats(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV6) EsMappingList 

func (this EsServiceV6) EsMappingList(ctx *fiber.Ctx, esConnect *escache.EsMapGetProperties) (err error)

func (EsServiceV6) Optimize 

func (this EsServiceV6) Optimize(ctx *fiber.Ctx, esOptimize *escache.EsOptimize) (err error)

func (EsServiceV6) RecoverCanWrite 

func (this EsServiceV6) RecoverCanWrite(ctx *fiber.Ctx) (err error)

func (EsServiceV6) RunDsl 

func (this EsServiceV6) RunDsl(ctx *fiber.Ctx, esRest *escache.EsRest) (err error)

func (EsServiceV6) SnapshotCreateRepository 

func (this EsServiceV6) SnapshotCreateRepository(ctx *fiber.Ctx, snapshotCreateRepository *escache.SnapshotCreateRepository) (err error)

func (EsServiceV6) SnapshotDelete 

func (this EsServiceV6) SnapshotDelete(ctx *fiber.Ctx, snapshotDelete *escache.SnapshotDelete) (err error)

func (EsServiceV6) SnapshotDeleteRepository 

func (this EsServiceV6) SnapshotDeleteRepository(ctx *fiber.Ctx, repository *escache.SnapshotDeleteRepository) (err error)

func (EsServiceV6) SnapshotDetail 

func (this EsServiceV6) SnapshotDetail(ctx *fiber.Ctx, snapshotDetail *escache.SnapshotDetail) (err error)

func (EsServiceV6) SnapshotList 

func (this EsServiceV6) SnapshotList(ctx *fiber.Ctx, snapshotList *escache.SnapshotList) (err error)

func (EsServiceV6) SnapshotRepositoryList 

func (this EsServiceV6) SnapshotRepositoryList(ctx *fiber.Ctx, esSnapshotInfo *escache.EsSnapshotInfo) (err error)

func (EsServiceV6) SnapshotRestore 

func (this EsServiceV6) SnapshotRestore(ctx *fiber.Ctx, snapshotRestore *escache.SnapshotRestore) (err error)

func (EsServiceV6) SnapshotStatus 

func (this EsServiceV6) SnapshotStatus(ctx *fiber.Ctx, snapshotStatus *escache.SnapshotStatus) (err error)

func (EsServiceV6) TaskList 

func (this EsServiceV6) TaskList(ctx *fiber.Ctx) (err error)

func (EsServiceV6) UpdateMapping 

func (this EsServiceV6) UpdateMapping(ctx *fiber.Ctx, updateMapping *escache.UpdateMapping) (err error)

type EsServiceV7 

type EsServiceV7 struct {
	response.Response
	request.Request
	// contains filtered or unexported fields
}

func (EsServiceV7) Cancel 

func (this EsServiceV7) Cancel(ctx *fiber.Ctx, cancelTask *escache.CancelTask) (err error)

func (EsServiceV7) Cat 

func (this EsServiceV7) Cat(ctx *fiber.Ctx, esCat *escache.EsCat) (err error)

func (EsServiceV7) CleanupeRepository 

func (this EsServiceV7) CleanupeRepository(ctx *fiber.Ctx, cleanupeRepository *escache.CleanupeRepository) (err error)

func (EsServiceV7) CreateSnapshot 

func (this EsServiceV7) CreateSnapshot(ctx *fiber.Ctx, createSnapshot *escache.CreateSnapshot) (err error)

func (EsServiceV7) CrudGetDSL 

func (this EsServiceV7) CrudGetDSL(ctx *fiber.Ctx, crudFilter *escache.CrudFilter) (err error)

func (EsServiceV7) CrudGetList 

func (this EsServiceV7) CrudGetList(ctx *fiber.Ctx, crudFilter *escache.CrudFilter) (err error)

func (EsServiceV7) EsDocDeleteRowByID 

func (this EsServiceV7) EsDocDeleteRowByID(ctx *fiber.Ctx, esDocDeleteRowByID *escache.EsDocDeleteRowByID) (err error)

func (EsServiceV7) EsDocInsert 

func (this EsServiceV7) EsDocInsert(ctx *fiber.Ctx, esDocUpdateByID *escache.EsDocUpdateByID) (err error)

func (EsServiceV7) EsDocUpdateByID 

func (this EsServiceV7) EsDocUpdateByID(ctx *fiber.Ctx, esDocUpdateByID *escache.EsDocUpdateByID) (err error)

func (EsServiceV7) EsIndexCatStatus 

func (this EsServiceV7) EsIndexCatStatus(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV7) EsIndexCreate 

func (this EsServiceV7) EsIndexCreate(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV7) EsIndexDelete 

func (this EsServiceV7) EsIndexDelete(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV7) EsIndexGetAlias 

func (this EsServiceV7) EsIndexGetAlias(ctx *fiber.Ctx, esAliasInfo *escache.EsAliasInfo) (err error)

func (EsServiceV7) EsIndexGetSettings 

func (this EsServiceV7) EsIndexGetSettings(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV7) EsIndexGetSettingsInfo 

func (this EsServiceV7) EsIndexGetSettingsInfo(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV7) EsIndexIndexNames 

func (this EsServiceV7) EsIndexIndexNames(ctx *fiber.Ctx) (err error)

func (EsServiceV7) EsIndexOperateAlias 

func (this EsServiceV7) EsIndexOperateAlias(ctx *fiber.Ctx, esAliasInfo *escache.EsAliasInfo) (err error)

func (EsServiceV7) EsIndexReindex 

func (this EsServiceV7) EsIndexReindex(ctx *fiber.Ctx, esReIndexInfo *escache.EsReIndexInfo) (err error)

func (EsServiceV7) EsIndexStats 

func (this EsServiceV7) EsIndexStats(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV7) EsMappingList 

func (this EsServiceV7) EsMappingList(ctx *fiber.Ctx, esConnect *escache.EsMapGetProperties) (err error)

func (EsServiceV7) Optimize 

func (this EsServiceV7) Optimize(ctx *fiber.Ctx, esOptimize *escache.EsOptimize) (err error)

func (EsServiceV7) RecoverCanWrite 

func (this EsServiceV7) RecoverCanWrite(ctx *fiber.Ctx) (err error)

func (EsServiceV7) RunDsl 

func (this EsServiceV7) RunDsl(ctx *fiber.Ctx, esRest *escache.EsRest) (err error)

func (EsServiceV7) SnapshotCreateRepository 

func (this EsServiceV7) SnapshotCreateRepository(ctx *fiber.Ctx, snapshotCreateRepository *escache.SnapshotCreateRepository) (err error)

func (EsServiceV7) SnapshotDelete 

func (this EsServiceV7) SnapshotDelete(ctx *fiber.Ctx, snapshotDelete *escache.SnapshotDelete) (err error)

func (EsServiceV7) SnapshotDeleteRepository 

func (this EsServiceV7) SnapshotDeleteRepository(ctx *fiber.Ctx, repository *escache.SnapshotDeleteRepository) (err error)

func (EsServiceV7) SnapshotDetail 

func (this EsServiceV7) SnapshotDetail(ctx *fiber.Ctx, snapshotDetail *escache.SnapshotDetail) (err error)

func (EsServiceV7) SnapshotList 

func (this EsServiceV7) SnapshotList(ctx *fiber.Ctx, snapshotList *escache.SnapshotList) (err error)

func (EsServiceV7) SnapshotRepositoryList 

func (this EsServiceV7) SnapshotRepositoryList(ctx *fiber.Ctx, esSnapshotInfo *escache.EsSnapshotInfo) (err error)

func (EsServiceV7) SnapshotRestore 

func (this EsServiceV7) SnapshotRestore(ctx *fiber.Ctx, snapshotRestore *escache.SnapshotRestore) (err error)

func (EsServiceV7) SnapshotStatus 

func (this EsServiceV7) SnapshotStatus(ctx *fiber.Ctx, snapshotStatus *escache.SnapshotStatus) (err error)

func (EsServiceV7) TaskList 

func (this EsServiceV7) TaskList(ctx *fiber.Ctx) (err error)

func (EsServiceV7) UpdateMapping 

func (this EsServiceV7) UpdateMapping(ctx *fiber.Ctx, updateMapping *escache.UpdateMapping) (err error)

type EsServiceV8 

type EsServiceV8 struct {
	response.Response
	request.Request
	// contains filtered or unexported fields
}

func (EsServiceV8) Cancel 

func (this EsServiceV8) Cancel(ctx *fiber.Ctx, cancelTask *escache.CancelTask) (err error)

func (EsServiceV8) Cat 

func (this EsServiceV8) Cat(ctx *fiber.Ctx, esCat *escache.EsCat) (err error)

func (EsServiceV8) CleanupeRepository 

func (this EsServiceV8) CleanupeRepository(ctx *fiber.Ctx, cleanupeRepository *escache.CleanupeRepository) (err error)

func (EsServiceV8) CreateSnapshot 

func (this EsServiceV8) CreateSnapshot(ctx *fiber.Ctx, createSnapshot *escache.CreateSnapshot) (err error)

func (EsServiceV8) CrudGetDSL 

func (this EsServiceV8) CrudGetDSL(ctx *fiber.Ctx, crudFilter *escache.CrudFilter) (err error)

func (EsServiceV8) CrudGetList 

func (this EsServiceV8) CrudGetList(ctx *fiber.Ctx, crudFilter *escache.CrudFilter) (err error)

func (EsServiceV8) EsDocDeleteRowByID 

func (this EsServiceV8) EsDocDeleteRowByID(ctx *fiber.Ctx, esDocDeleteRowByID *escache.EsDocDeleteRowByID) (err error)

func (EsServiceV8) EsDocInsert 

func (this EsServiceV8) EsDocInsert(ctx *fiber.Ctx, esDocUpdateByID *escache.EsDocUpdateByID) (err error)

func (EsServiceV8) EsDocUpdateByID 

func (this EsServiceV8) EsDocUpdateByID(ctx *fiber.Ctx, esDocUpdateByID *escache.EsDocUpdateByID) (err error)

func (EsServiceV8) EsIndexCatStatus 

func (this EsServiceV8) EsIndexCatStatus(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV8) EsIndexCreate 

func (this EsServiceV8) EsIndexCreate(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV8) EsIndexDelete 

func (this EsServiceV8) EsIndexDelete(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV8) EsIndexGetAlias 

func (this EsServiceV8) EsIndexGetAlias(ctx *fiber.Ctx, esAliasInfo *escache.EsAliasInfo) (err error)

func (EsServiceV8) EsIndexGetSettings 

func (this EsServiceV8) EsIndexGetSettings(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV8) EsIndexGetSettingsInfo 

func (this EsServiceV8) EsIndexGetSettingsInfo(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV8) EsIndexIndexNames 

func (this EsServiceV8) EsIndexIndexNames(ctx *fiber.Ctx) (err error)

func (EsServiceV8) EsIndexOperateAlias 

func (this EsServiceV8) EsIndexOperateAlias(ctx *fiber.Ctx, esAliasInfo *escache.EsAliasInfo) (err error)

func (EsServiceV8) EsIndexReindex 

func (this EsServiceV8) EsIndexReindex(ctx *fiber.Ctx, esReIndexInfo *escache.EsReIndexInfo) (err error)

func (EsServiceV8) EsIndexStats 

func (this EsServiceV8) EsIndexStats(ctx *fiber.Ctx, esIndexInfo *escache.EsIndexInfo) (err error)

func (EsServiceV8) EsMappingList 

func (this EsServiceV8) EsMappingList(ctx *fiber.Ctx, esConnect *escache.EsMapGetProperties) (err error)

func (EsServiceV8) Optimize 

func (this EsServiceV8) Optimize(ctx *fiber.Ctx, esOptimize *escache.EsOptimize) (err error)

func (EsServiceV8) RecoverCanWrite 

func (this EsServiceV8) RecoverCanWrite(ctx *fiber.Ctx) (err error)

func (EsServiceV8) RunDsl 

func (this EsServiceV8) RunDsl(ctx *fiber.Ctx, esRest *escache.EsRest) (err error)

func (EsServiceV8) SnapshotCreateRepository 

func (this EsServiceV8) SnapshotCreateRepository(ctx *fiber.Ctx, snapshotCreateRepository *escache.SnapshotCreateRepository) (err error)

func (EsServiceV8) SnapshotDelete 

func (this EsServiceV8) SnapshotDelete(ctx *fiber.Ctx, snapshotDelete *escache.SnapshotDelete) (err error)

func (EsServiceV8) SnapshotDeleteRepository 

func (this EsServiceV8) SnapshotDeleteRepository(ctx *fiber.Ctx, repository *escache.SnapshotDeleteRepository) (err error)

func (EsServiceV8) SnapshotDetail 

func (this EsServiceV8) SnapshotDetail(ctx *fiber.Ctx, snapshotDetail *escache.SnapshotDetail) (err error)

func (EsServiceV8) SnapshotList 

func (this EsServiceV8) SnapshotList(ctx *fiber.Ctx, snapshotList *escache.SnapshotList) (err error)

func (EsServiceV8) SnapshotRepositoryList 

func (this EsServiceV8) SnapshotRepositoryList(ctx *fiber.Ctx, esSnapshotInfo *escache.EsSnapshotInfo) (err error)

func (EsServiceV8) SnapshotRestore 

func (this EsServiceV8) SnapshotRestore(ctx *fiber.Ctx, snapshotRestore *escache.SnapshotRestore) (err error)

func (EsServiceV8) SnapshotStatus 

func (this EsServiceV8) SnapshotStatus(ctx *fiber.Ctx, snapshotStatus *escache.SnapshotStatus) (err error)

func (EsServiceV8) TaskList 

func (this EsServiceV8) TaskList(ctx *fiber.Ctx) (err error)

func (EsServiceV8) UpdateMapping 

func (this EsServiceV8) UpdateMapping(ctx *fiber.Ctx, updateMapping *escache.UpdateMapping) (err error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.