dto

package
v0.0.7 Latest Latest
Warning

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

 Go to latest Published: Dec 26, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddAliasesReq 

type AddAliasesReq struct {
	EsConnectData     EsConnectData     `json:"es_connect_data"`
	AddAliasesReqData AddAliasesReqData `json:"add_aliases_req_data"`
}

type AddAliasesReqData 

type AddAliasesReqData struct {
	IndexName []string
	AliasName string
}

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 CancelTask struct {
	EsConnect int    `json:"es_connect"`
	TaskID    string `json:"task_id"`
}

type CatAliasesReq 

type CatAliasesReq struct {
	EsConnectData     EsConnectData     `json:"es_connect_data"`
	CatAliasesReqData CatAliasesReqData `json:"cat_aliases_req_data"`
}

type CatAliasesReqData 

type CatAliasesReqData struct {
	CatRequest proto.CatAliasesRequest
}

type CatAllocationRequest 

type CatAllocationRequest struct {
	EsConnectData            EsConnectData            `json:"es_connect_data"`
	CatAllocationRequestData CatAllocationRequestData `json:"cat_allocation_request_data"`
}

type CatAllocationRequestData 

type CatAllocationRequestData struct {
	CatRequest proto.CatAllocationRequest
}

type CatCountReq 

type CatCountReq struct {
	EsConnectData   EsConnectData   `json:"es_connect_data"`
	CatCountReqData CatCountReqData `json:"cat_count_req_data"`
}

type CatCountReqData 

type CatCountReqData struct {
	CatRequest proto.CatCountRequest
}

type CatHealthReq 

type CatHealthReq struct {
	EsConnectData    EsConnectData    `json:"es_connect_data"`
	CatHealthReqData CatHealthReqData `json:"cat_health_req_data"`
}

type CatHealthReqData 

type CatHealthReqData struct {
	CatRequest proto.CatHealthRequest
}

type CatNodeReqData 

type CatNodeReqData struct {
	H []string `json:"h"`
}

type CatNodesReq 

type CatNodesReq struct {
	EsConnectData  EsConnectData  `json:"es_connect_data"`
	CatNodeReqData CatNodeReqData `json:"cat_node_req_data"`
}

type CatShardsReq 

type CatShardsReq struct {
	EsConnectData    EsConnectData    `json:"es_connect_data"`
	CatShardsReqData CatShardsReqData `json:"cat_shards_req_data"`
}

type CatShardsReqData 

type CatShardsReqData struct {
	CatRequest proto.CatShardsRequest
}

type CleanupeRepository 

type CleanupeRepository struct {
	EsConnect  int    `json:"es_connect"` //es连接id
	Repository string `json:"name"`       //存储库名
}

type ClusterStatsReq 

type ClusterStatsReq struct {
	EsConnectData       EsConnectData       `json:"es_connect_data"`
	ClusterStatsReqData ClusterStatsReqData `json:"cluster_stats_req_data"`
}

type ClusterStatsReqData 

type ClusterStatsReqData struct {
	Human bool `json:"human"`
}

type CreateIndexReq 

type CreateIndexReq struct {
	EsConnectData      EsConnectData      `json:"es_connect_data"`
	CreateIndexReqData CreateIndexReqData `json:"create_index_req_data"`
}

type CreateIndexReqData 

type CreateIndexReqData struct {
	IndexCreateRequest proto.IndicesCreateRequest
	Body               interface{}
}

type CreateReq 

type CreateReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	CreateReqData CreateReqData `json:"create_req_data"`
}

type CreateReqData 

type CreateReqData struct {
	CreateRequest proto.CreateRequest
	Body          interface{}
}

type CreateSnapshot 

type CreateSnapshot struct {
	SnapshotName       string   `json:"snapshotName"`
	RepositoryName     string   `json:"repositoryName"`
	IndexList          []string `json:"indexList"`
	IgnoreUnavailable  *bool    `json:"ignore_unavailable"`
	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 DataxInfoDelReq 

type DataxInfoDelReq struct {
	ID int `json:"id"`
}

type DataxInfoInsertReq 

type DataxInfoInsertReq struct {
	IP       string `json:"ip"`
	Port     int    `json:"port"`
	DbName   string `json:"db_name"`
	Username string `json:"username"`
	Pwd      string `json:"pwd"`
	Remark   string `json:"remark"`
	Typ      string `json:"typ"`
}

func (DataxInfoInsertReq) Validate 

func (this DataxInfoInsertReq) Validate() (err error)

type DataxInfoListReq 

type DataxInfoListReq struct {
	Remark string `json:"remark"`
	Typ    string `json:"typ"`
	Page   int    `json:"page"`
	Limit  int    `json:"limit"`
}

type DataxInfoTestLinkReq 

type DataxInfoTestLinkReq struct {
	IP       string `json:"ip"`
	Port     int    `json:"port"`
	DbName   string `json:"db_name"`
	Username string `json:"username"`
	Pwd      string `json:"pwd"`
	Remark   string `json:"remark"`
	Typ      string `json:"typ"`
}

type DeleteByQueryReq 

type DeleteByQueryReq struct {
	EsConnectData        EsConnectData        `json:"es_connect_data"`
	DeleteByQueryReqData DeleteByQueryReqData `json:"delete_by_query_req_data"`
}

type DeleteByQueryReqData 

type DeleteByQueryReqData struct {
	IndexNames []string
	Documents  []string
	Body       interface{}
}
type DeleteEsLink struct {
	Id int `json:"id"`
}

type DeleteEsLinkCfg 

type DeleteEsLinkCfg struct {
	Id int `json:"id"`
}

type DeleteIndexReq 

type DeleteIndexReq struct {
	EsConnectData      EsConnectData      `json:"es_connect_data"`
	DeleteIndexReqData DeleteIndexReqData `json:"delete_index_req_data"`
}

type DeleteIndexReqData 

type DeleteIndexReqData struct {
	IndicesDeleteRequest proto.IndicesDeleteRequest
}

type DeleteReq 

type DeleteReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	DeleteReqData DeleteReqData `json:"delete_req_data"`
}

type DeleteReqData 

type DeleteReqData struct {
	DeleteRequest proto.DeleteRequest
}

type DeleteSnapshot 

type DeleteSnapshot struct {
	SnapshotName   string `json:"snapshotName"`
	RepositoryName string `json:"repositoryName"`
	EsConnect      int    `json:"es_connect"`
}

type DslHistoryListReq 

type DslHistoryListReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	IndexName     string        `json:"indexName"` // 索引名
	Date          []string      `json:"date"`      //开始时间与结束时间（格式：”年-月-日 时:分:秒“ ）
	Page          int           `json:"page"`      //拉取数据当前页
	Limit         int           `json:"limit"`     //拉取条数
}

type DslHistoryListReq2 

type DslHistoryListReq2 struct {
	IndexName string   `json:"indexName"` // 索引名
	Date      []string `json:"date"`      //开始时间与结束时间（格式：”年-月-日 时:分:秒“ ）
	Page      int      `json:"page"`      //拉取数据当前页
	Limit     int      `json:"limit"`     //拉取条数
}

type EsAliasInfo 

type EsAliasInfo struct {
	EsConnect        int         `json:"es_connect"`
	Settings         common.Json `json:"settings"`
	IndexName        string      `json:"index_name"`
	AliasName        string      `json:"alias_name"`
	NewAliasNameList []string    `json:"new_alias_name_list"`
	NewIndexList     []string    `json:"new_index_list"`
	Types            int         `json:"types"`
}

type EsCat 

type EsCat struct {
	EsConnect        int    `json:"es_connect"`
	Cat              string `json:"cat"`
	IndexBytesFormat string `json:"index_bytes_format"`
}

type EsConnectData 

type EsConnectData struct {
	UserID    int `json:"user_id"`
	EsConnect int `json:"es_connect"`
}

type EsDocDeleteRowByID 

type EsDocDeleteRowByID struct {
	EsConnect int    `json:"es_connect"`
	ID        string `json:"id"`
	IndexName string `json:"index_name"`
	Type      string `json:"type"`
}

type EsDocUpdateByID 

type EsDocUpdateByID struct {
	EsConnect int         `json:"es_connect"`
	ID        string      `json:"id"`
	JSON      common.Json `json:"json"`
	Type      string      `json:"type_name"`
	Index     string      `json:"index"`
}

type EsIndexInfo 

type EsIndexInfo struct {
	EsConnect int         `json:"es_connect"`
	Settings  common.Json `json:"settings"`
	IndexName string      `json:"index_name"`
	Types     string      `json:"types"`
}

type EsMapGetProperties 

type EsMapGetProperties struct {
	EsConnectID int    `json:"es_connect"`
	IndexName   string `json:"index_name"`
}

type EsMappingInfo 

type EsMappingInfo struct {
	IndexNameList []string    `json:"index_name_list"`
	EsConnect     int         `json:"es_connect"`
	Mappings      common.Json `json:"mappings"`
	IndexName     string      `json:"index_name"`
}

type EsOptimize 

type EsOptimize struct {
	EsConnect int    `json:"es_connect"`
	IndexName string `json:"index_name"`
}

type EsReIndexInfo 

type EsReIndexInfo struct {
	EsConnect int `json:"es_connect"`
	UrlValues struct {
		Timeout             int    `json:"timeout"`
		RequestsPerSecond   int    `json:"requests_per_second"`
		Slices              int    `json:"slices"`
		Scroll              string `json:"scroll"`
		WaitForActiveShards string `json:"wait_for_active_shards"`
		Refresh             *bool  `json:"refresh"`
		WaitForCompletion   *bool  `json:"wait_for_completion"`
	} `json:"url_values"`
	Body map[string]interface{} `json:"body"`
}

type EsRest 

type EsRest struct {
	EsConnect int    `json:"es_connect"`
	Body      string `json:"body"`
	Path      string `json:"path"`
}

type EsSnapshotInfo 

type EsSnapshotInfo struct {
	EsConnect        int      `json:"es_connect"`         //es连接id
	SnapshotInfoList []string `json:"snapshot_info_list"` //存储库
}

type EsTaskInfo 

type EsTaskInfo struct {
	EsConnect    int      `json:"es_connect"`
	TaskId       []string `json:"task_id"`
	Actions      []string `json:"actions"`
	NodeId       []string `json:"node_id"`
	ParentTaskId string   `json:"parent_task_id"`
}

type ExecSqlReq 

type ExecSqlReq struct {
	PluginId string        `json:"plugin_id"`
	Sql      string        `json:"sql"`
	Args     []interface{} `json:"args"`
}

type FlushReq 

type FlushReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	FlushReqData  FlushReqData  `json:"flush_req"`
}

type FlushReqData 

type FlushReqData struct {
	IndexNames []string `json:"index_names"`
}

type GetAliasesReq 

type GetAliasesReq struct {
	EsConnectData     EsConnectData     `json:"es_connect_data"`
	GetAliasesReqData GetAliasesReqData `json:"get_aliases_req_data"`
}

type GetAliasesReqData 

type GetAliasesReqData struct {
	IndexNames []string
}

type GetEsCfgRelation 

type GetEsCfgRelation struct {
	ID int `json:"id"`
}

type GetIndicesReq 

type GetIndicesReq struct {
	EsConnectData     EsConnectData     `json:"es_connect_data"`
	GetIndicesReqData GetIndicesReqData `json:"get_indices_req_data"`
}

type GetIndicesReqData 

type GetIndicesReqData struct {
	CatIndicesRequest proto.CatIndicesRequest
}

type GetMappingReq 

type GetMappingReq struct {
	EsConnectData     EsConnectData     `json:"es_connect_data"`
	GetMappingReqData GetMappingReqData `json:"get_mapping_req_data"`
}

type GetMappingReqData 

type GetMappingReqData struct {
	IndexNames []string
}

type GetRoles4UserIdReq added in v0.0.7 

type GetRoles4UserIdReq struct {
	UserId int `json:"user_id"`
}

type IndicesClearCacheReq 

type IndicesClearCacheReq struct {
	EsConnectData            EsConnectData            `json:"es_connect_data"`
	IndicesClearCacheReqData IndicesClearCacheReqData `json:"indices_clear_cache_req_data"`
}

type IndicesClearCacheReqData 

type IndicesClearCacheReqData struct {
	IndexNames []string `json:"index_names"`
}

type IndicesCloseReq 

type IndicesCloseReq struct {
	EsConnectData       EsConnectData       `json:"es_connect_data"`
	IndicesCloseReqData IndicesCloseReqData `json:"indices_close_req_data"`
}

type IndicesCloseReqData 

type IndicesCloseReqData struct {
	IndexNames []string `json:"index_names"`
}

type IndicesForcemergeReq 

type IndicesForcemergeReq struct {
	EsConnectData            EsConnectData            `json:"es_connect_data"`
	IndicesForcemergeReqData IndicesForcemergeReqData `json:"indices_forcemerge_req_data"`
}

type IndicesForcemergeReqData 

type IndicesForcemergeReqData struct {
	IndexNames     []string `json:"index_names"`
	MaxNumSegments *int     `json:"max_num_segments"`
}

type IndicesGetSettingsRequestReq 

type IndicesGetSettingsRequestReq struct {
	EsConnectData                    EsConnectData                    `json:"es_connect_data"`
	IndicesGetSettingsRequestReqData IndicesGetSettingsRequestReqData `json:"indices_get_settings_request_req_data"`
}

type IndicesGetSettingsRequestReqData 

type IndicesGetSettingsRequestReqData struct {
	IndicesGetSettingsRequest proto.IndicesGetSettingsRequest
}

type IndicesPutSettingsRequest 

type IndicesPutSettingsRequest struct {
	EsConnectData                 EsConnectData                 `json:"es_connect_data"`
	IndicesPutSettingsRequestData IndicesPutSettingsRequestData `json:"indices_put_settings_request_data"`
}

type IndicesPutSettingsRequestData 

type IndicesPutSettingsRequestData struct {
	IndexSettingsRequest proto.IndicesPutSettingsRequest
	Body                 interface{}
}

type IndicesSegmentsRequest 

type IndicesSegmentsRequest struct {
	EsConnectData              EsConnectData              `json:"es_connect_data"`
	IndicesSegmentsRequestData IndicesSegmentsRequestData `json:"indices_segments_request_data"`
}

type IndicesSegmentsRequestData 

type IndicesSegmentsRequestData struct {
	Human bool `json:"human"`
}
type InsertEsLink struct {
	Ip      string `json:"ip"`
	Remark  string `json:"remark"`
	Version int    `json:"version"`
	CfgIds  []int  `json:"cfgIds"`
}

type InsertEsLinkCfg 

type InsertEsLinkCfg struct {
	User       string   `json:"user"`
	Pwd        string   `json:"pwd"`
	Remark     string   `json:"remark"`
	RootPEM    string   ` json:"rootpem" `
	CertPEM    string   ` json:"certpem" `
	KeyPEM     string   `json:"keypem" `
	ShareRoles []string `json:"share_roles"`
}

type LoadDebugPlugin 

type LoadDebugPlugin struct {
	ID   string `json:"id"`
	Addr string `json:"addr"`
	Pid  int    `json:"pid"`
}

type MongoExecReq 

type MongoExecReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	DbName        string        `json:"db_name"`
	Command       bson.D        `json:"command"`
	Timeout       time.Duration `json:"timeout"`
}

type MoveToAnotherIndexAliasesReq 

type MoveToAnotherIndexAliasesReq struct {
	EsConnectData                    EsConnectData                    `json:"es_connect_data"`
	MoveToAnotherIndexAliasesReqData MoveToAnotherIndexAliasesReqData `json:"move_to_another_index_aliases_req_data"`
}

type MoveToAnotherIndexAliasesReqData 

type MoveToAnotherIndexAliasesReqData struct {
	Body proto.AliasAction
}

type MysqlExecReq 

type MysqlExecReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	Sql           string        `json:"sql"`
	Args          []interface{} `json:"args"`
	DbName        string        `json:"dbName"`
}

type MysqlSelectReq 

type MysqlSelectReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	Sql           string        `json:"sql"`
	Args          []interface{} `json:"args"`
	DbName        string        `json:"dbName"`
}

type OpenReq 

type OpenReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	OpenReqData   OpenReqData   `json:"open_req_data"`
}

type OpenReqData 

type OpenReqData struct {
	IndexNames []string `json:"index_names"`
}

type PerformRequest 

type PerformRequest struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	Request       *Request      `json:"request"`
}

type PingReq 

type PingReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
}

type PluginRunDsl 

type PluginRunDsl struct {
	EsConnectData *EsConnectData `json:"es_connect_data"`
	Params        url.Values     `json:"-"`
	HttpMethod    string         `json:"http_method"`
	Path          string         `json:"path"`
	Dsl           string         `json:"dsl"`
}

type PluginRunDsl2 

type PluginRunDsl2 struct {
	Params     url.Values `json:"-"`
	HttpMethod string     `json:"http_method"`
	Path       string     `json:"path"`
	Dsl        string     `json:"dsl"`
}

type PutMappingReq 

type PutMappingReq struct {
	EsConnectData     EsConnectData     `json:"es_connect_data"`
	PutMappingReqData PutMappingReqData `json:"put_mapping_req_data"`
}

type PutMappingReqData 

type PutMappingReqData struct {
	IndicesPutMappingRequest proto.IndicesPutMappingRequest
	Body                     interface{}
}

type RedisExecReq 

type RedisExecReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	Args          []interface{} `json:"args"`
	DbName        int           `json:"dbName"`
}

type RefreshReq 

type RefreshReq struct {
	EsConnectData  EsConnectData  `json:"es_connect_data"`
	RefreshReqData RefreshReqData `json:"refresh_req_data"`
}

type RefreshReqData 

type RefreshReqData struct {
	IndexNames []string `json:"index_names"`
}

type ReindexReq 

type ReindexReq struct {
	EsConnectData  EsConnectData  `json:"es_connect_data"`
	ReindexReqData ReindexReqData `json:"reindex_req_data"`
}

type ReindexReqData 

type ReindexReqData struct {
	ReindexRequest proto.ReindexRequest
	Body           interface{}
}

type RemoveAliasesReq 

type RemoveAliasesReq struct {
	EsConnectData        EsConnectData        `json:"es_connect_data"`
	RemoveAliasesReqData RemoveAliasesReqData `json:"remove_aliases_req_data"`
}

type RemoveAliasesReqData 

type RemoveAliasesReqData struct {
	IndexName []string
	AliasName []string
}

type Request 

type Request struct {
	Method        string
	URL           *url.URL
	Header        http.Header
	Form          url.Values
	PostForm      url.Values
	MultipartForm *multipart.Form
	JsonBody      string
}

type RestoreSnapshotReq 

type RestoreSnapshotReq struct {
	EsConnectData          EsConnectData          `json:"es_connect_data"`
	RestoreSnapshotReqData RestoreSnapshotReqData `json:"restore_snapshot_req_data"`
}

type RestoreSnapshotReqData 

type RestoreSnapshotReqData struct {
	Repository        string
	Snapshot          string
	WaitForCompletion *bool
	ReqJson           proto.Json
}

type SearchReq 

type SearchReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	SearchReqData SearchReqData `json:"search_req_data"`
}

type SearchReqData 

type SearchReqData struct {
	SearchRequest proto.SearchRequest
	Query         interface{}
}

type SelectReq 

type SelectReq struct {
	PluginId string        `json:"plugin_id"`
	Sql      string        `json:"sql"`
	Args     []interface{} `json:"args"`
}

type SelectType 

type SelectType struct {
	ID     int    `json:"id"`
	Remark string `json:"remark"`
	Typ    string `json:"typ"`
}

type ShowMongoDbsReq 

type ShowMongoDbsReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
}

type SnapshotCreateRepository 

type SnapshotCreateRepository struct {
	EsConnect              int    `json:"es_connect"`                 //es连接id
	Repository             string `json:"name"`                       //存储库名
	Type                   string `json:"type"`                       //类型 fs/url
	Location               string `json:"location"`                   //存储位置
	Compress               string `json:"compress"`                   //是否压缩 true/false
	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 SnapshotCreateRepositoryReq 

type SnapshotCreateRepositoryReq struct {
	EsConnectData                   EsConnectData                   `json:"es_connect_data"`
	SnapshotCreateRepositoryReqData SnapshotCreateRepositoryReqData `json:"snapshot_create_repository_req_data"`
}

type SnapshotCreateRepositoryReqData 

type SnapshotCreateRepositoryReqData struct {
	Repository string
	ReqJson    proto.Json
}

type SnapshotCreateReq 

type SnapshotCreateReq struct {
	EsConnectData         EsConnectData         `json:"es_connect_data"`
	SnapshotCreateReqData SnapshotCreateReqData `json:"snapshot_create_req_data"`
}

type SnapshotCreateReqData 

type SnapshotCreateReqData struct {
	Repository        string
	Snapshot          string
	WaitForCompletion *bool
	ReqJson           proto.Json
}

type SnapshotDelete 

type SnapshotDelete struct {
	EsConnect  int    `json:"es_connect"`
	Repository string `json:"repository"`
	Snapshot   string `json:"snapshot"`
}

type SnapshotDeleteRepository 

type SnapshotDeleteRepository struct {
	EsConnect  int    `json:"es_connect"` //es连接id
	Repository string `json:"name"`       //存储库名
}

type SnapshotDeleteRepositoryReq 

type SnapshotDeleteRepositoryReq struct {
	EsConnectData                   EsConnectData                   `json:"es_connect_data"`
	SnapshotDeleteRepositoryReqData SnapshotDeleteRepositoryReqData `json:"snapshot_delete_repository_req_data"`
}

type SnapshotDeleteRepositoryReqData 

type SnapshotDeleteRepositoryReqData struct {
	Repository []string
}

type SnapshotDeleteReq 

type SnapshotDeleteReq struct {
	EsConnectData         EsConnectData         `json:"es_connect_data"`
	SnapshotDeleteReqData SnapshotDeleteReqData `json:"snapshot_delete_req_data"`
}

type SnapshotDeleteReqData 

type SnapshotDeleteReqData struct {
	Repository string
	Snapshot   string
}

type SnapshotDetail 

type SnapshotDetail struct {
	EsConnect  int    `json:"es_connect"`
	Repository string `json:"repository"`
	Snapshot   string `json:"snapshot"`
}

type SnapshotGetRepositoryReq 

type SnapshotGetRepositoryReq struct {
	EsConnectData                EsConnectData                `json:"es_connect_data"`
	SnapshotGetRepositoryReqData SnapshotGetRepositoryReqData `json:"snapshot_get_repository_req_data"`
}

type SnapshotGetRepositoryReqData 

type SnapshotGetRepositoryReqData struct {
	Repository []string
}

type SnapshotList 

type SnapshotList struct {
	EsConnect  int    `json:"es_connect"`
	Repository string `json:"repository"`
}

type SnapshotRestore 

type SnapshotRestore struct {
	SnapshotName       string   `json:"snapshotName"`
	RepositoryName     string   `json:"repositoryName"`
	IndexList          []string `json:"indexList"`
	IgnoreUnavailable  *bool    `json:"ignore_unavailable"`
	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 SnapshotStatus struct {
	SnapshotName   string `json:"snapshot"`
	RepositoryName string `json:"repository"`
	EsConnect      int    `json:"es_connect"`
}

type SnapshotStatusReq 

type SnapshotStatusReq struct {
	EsConnectData         EsConnectData         `json:"es_connect_data"`
	SnapshotStatusReqData SnapshotStatusReqData `json:"snapshot_status_req_data"`
}

type SnapshotStatusReqData 

type SnapshotStatusReqData struct {
	Repository        string
	Snapshot          []string
	IgnoreUnavailable *bool
}

type SortStruct 

type SortStruct struct {
	Col      string `json:"col"`
	SortRule string `json:"sortRule"`
}

type SqlToDsl 

type SqlToDsl struct {
	Sql string `json:"sql"`
}

type StopDebugPlugin 

type StopDebugPlugin struct {
	ID string `json:"id"`
}

type TaskList 

type TaskList struct {
	EsConnect int `json:"es_connect"`
}

type TaskListReq 

type TaskListReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
}

type TasksCancelReq 

type TasksCancelReq struct {
	EsConnectData      EsConnectData      `json:"es_connect_data"`
	TasksCancelReqData TasksCancelReqData `json:"tasks_cancel_req_data"`
}

type TasksCancelReqData 

type TasksCancelReqData struct {
	TaskId string
}

type TransferLogReq 

type TransferLogReq struct {
	EsConnect int `json:"es_connect"`
}

type TransferReq 

type TransferReq struct {
	AutoIncrementId string `json:"autoIncrementId"`
	EsConnect       int    `json:"es_connect"`
	SelectType      string `json:"selectType"`
	Remark          string `json:"remark"`
	SelectTable     string `json:"selectTable"`
	TypeName        string `json:"type_name"`
	Cols            struct {
		TableCols []string `json:"tableCols"`
		EsCols    []struct {
			Col   string `json:"col"`
			TbCol string `json:"tbCol"`
		} `json:"esCols"`
	} `json:"cols"`
	IndexName       string `json:"indexName"`
	Reset           bool   `json:"reset"`
	GoNum           int    `json:"goNum"`
	EsFlushInterval int    `json:"esFlushInterval"`
	EsBufferSize    int    `json:"esBufferSize"`
	EsDocID         string `json:"esDocId"`
	BufferSize      int    `json:"bufferSize"`
	MaxIdleConns    int    `json:"maxIdleConns"`
	MaxOpenConns    int    `json:"maxOpenConns"`
	CrontabSpec     string `json:"crontab_spec"`
}

func (*TransferReq) ParseSelectType 

func (this *TransferReq) ParseSelectType() (*SelectType, error)
type UpdateEsLink struct {
	Id      int    `json:"id"`
	Ip      string `json:"ip"`
	Remark  string `json:"remark" `
	Version int    `json:"version"`
	CfgIds  []int  `json:"cfgIds"`
}

type UpdateEsLinkCfg 

type UpdateEsLinkCfg struct {
	Id         int      `json:"id"`
	User       string   `json:"user"`
	Pwd        string   `json:"pwd"`
	Remark     string   `json:"remark"`
	RootPEM    string   ` json:"rootpem" `
	CertPEM    string   ` json:"certpem" `
	KeyPEM     string   `json:"keypem" `
	ShareRoles []string `json:"share_roles"`
	LinkId     int      `json:"linkId"`
}

type UpdateMapping 

type UpdateMapping struct {
	EsConnect  int         `json:"es_connect"`
	IndexName  string      `json:"index_name"`
	TypeName   string      `json:"type_name"`
	Properties common.Json `json:"properties"`
}

type UpdateReq 

type UpdateReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	UpdateReqData UpdateReqData `json:"update_req_data"`
}

type UpdateReqData 

type UpdateReqData struct {
	UpdateRequest proto.UpdateRequest
	Body          interface{}
}

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.