Documentation
¶
Overview ¶
ES引擎层
Index ¶
- Constants
- Variables
- func EsPwdESBDecrypt(cryptedStr string) (string, error)
- func EsPwdESBEncrypt(pwd string) (string, error)
- func NewEsClientV6(esConnectConfig *EsConnect) (esClient *elasticV6.Client, err error)
- func NewEsClientV7(esConnectConfig *EsConnect) (esClient *elasticV7.Client, err error)
- func NewEsClientV8(esConnectConfig *EsConnect) (esClient *elasticV7.Client, err error)
- type AnalysisFilter
- type CancelTask
- type CleanupeRepository
- type CreateSnapshot
- type CrudFilter
- type DeleteSnapshot
- type EsAliasInfo
- type EsCache
- type EsCat
- type EsClientV7
- type EsConnect
- type EsConnectID
- type EsDocDeleteRowByID
- type EsDocUpdateByID
- type EsIndexInfo
- type EsMapGetProperties
- type EsMappingInfo
- type EsOptimize
- type EsReIndexInfo
- type EsRest
- type EsSnapshotInfo
- type EsTaskInfo
- type Json
- type Page
- type SnapshotCreateRepository
- type SnapshotDelete
- type SnapshotDeleteRepository
- type SnapshotDetail
- type SnapshotList
- type SnapshotRestore
- type SnapshotStatus
- type Sort
- type SortStruct
- type TaskList
- type UpdateMapping
Constants ¶
View Source
const ( IndexNameNullError = 200001 AliasNameNullError = 200002 )
Variables ¶
View Source
var ParmasNullError = map[int]string{ IndexNameNullError: "索引名不能为空", AliasNameNullError: "别名不能为空", }
View Source
var ReqParmasValid = errors.New("请求参数无效")
默认异常
Functions ¶
func EsPwdESBDecrypt ¶
func EsPwdESBEncrypt ¶
func NewEsClientV6 ¶
func NewEsClientV7 ¶
Types ¶
type AnalysisFilter ¶
type AnalysisFilter struct {
FilterType string `json:"filterType"`
Filts []struct {
FilterType string `json:"filterType"`
Filts []struct {
ColumnName string `json:"columnName"`
Comparator string `json:"comparator"`
FilterType string `json:"filterType"`
Ftv interface{} `json:"ftv"`
} `json:"filts,omitempty"`
Relation string `json:"relation,omitempty"`
ColumnName string `json:"columnName,omitempty"`
Comparator string `json:"comparator,omitempty"`
Ftv interface{} `json:"ftv,omitempty"`
} `json:"filts"`
Relation string `json:"relation"`
}
type CancelTask ¶
type CleanupeRepository ¶
type CreateSnapshot ¶
type CreateSnapshot struct {
SnapshotName string `json:"snapshotName"`
RepositoryName string `json:"repositoryName"`
IndexList []string `json:"indexList"`
IncludeGlobalState *bool `json:"include_global_state"`
Partial *bool `json:"partial"`
Wait *bool `json:"wait"`
EsConnect int `json:"es_connect"`
}
type CrudFilter ¶
type CrudFilter struct {
Relation AnalysisFilter `json:"relation"`
SortList []SortStruct `json:"sort_list"`
EsConnect int `json:"es_connect"`
IndexName string `json:"index_name"`
Page int `json:"page"`
Limit int `json:"limit"`
}
type DeleteSnapshot ¶
type EsAliasInfo ¶
type EsClientV7 ¶
type EsConnect ¶
type EsConnectID ¶
type EsConnectID struct {
EsConnectID int `json:"es_connect"`
}
type EsDocDeleteRowByID ¶
type EsDocUpdateByID ¶
type EsIndexInfo ¶
type EsMapGetProperties ¶
type EsMappingInfo ¶
type EsOptimize ¶
type EsReIndexInfo ¶
type EsReIndexInfo struct {
EsConnect int `json:"es_connect"`
UrlValues struct {
Timeout string `json:"timeout"`
RequestsPerSecond int `json:"requests_per_second"`
Slices int `json:"slices"`
Scroll string `json:"scroll"`
WaitForActiveShards string `json:"wait_for_active_shards"`
Refresh string `json:"refresh"`
WaitForCompletion *bool `json:"wait_for_completion"`
} `json:"url_values"`
Body util.Map `json:"body"`
}
type EsSnapshotInfo ¶
type EsTaskInfo ¶
type SnapshotCreateRepository ¶
type SnapshotCreateRepository struct {
EsConnect int `json:"es_connect"`
Repository string `json:"name"`
Type string `json:"type"`
Location string `json:"location"`
Compress string `json:"compress"`
MaxRestoreBytesPerSec string `json:"max_restore_bytes_per_sec"`
MaxSnapshotBytesPerSec string `json:"max_snapshot_bytes_per_sec"`
ChunkSize string `json:"chunk_size"`
Readonly string `json:"readonly"`
}
type SnapshotDelete ¶
type SnapshotDetail ¶
type SnapshotList ¶
type SnapshotRestore ¶
type SnapshotRestore struct {
SnapshotName string `json:"snapshotName"`
RepositoryName string `json:"repositoryName"`
IndexList []string `json:"indexList"`
IncludeGlobalState *bool `json:"include_global_state"`
Partial *bool `json:"partial"`
Wait *bool `json:"wait"`
EsConnect int `json:"es_connect"`
RenamePattern string `json:"rename_pattern"`
RenameReplacement string `json:"rename_replacement"`
}
type SnapshotStatus ¶
type SortStruct ¶
Click to show internal directories.
Click to hide internal directories.