elasticsearch

package
v1.2.14 Latest Latest
Warning

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

 Go to latest Published: May 17, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewServiceScript added in v0.5.7 

func NewServiceScript(config interface{}) (res map[string]interface{}, err error)

func StartImportTask added in v0.0.9 

func StartImportTask(task *ImportTask)

Types

type BulkIndexByScrollResponse added in v0.0.6 

type BulkIndexByScrollResponse struct {
	*elastic.BulkIndexByScrollResponse
}

type BulkResponse added in v0.0.6 

type BulkResponse struct {
	*elastic.BulkResponse
}

type Config added in v0.0.6 

type Config struct {
	Url      string `json:"url,omitempty"`
	Username string `json:"username,omitempty"`
	Password string `json:"password,omitempty"`
	CertPath string `json:"certPath,omitempty"`
}

type DeleteResponse added in v0.0.6 

type DeleteResponse struct {
	*elastic.DeleteResponse
}

type HitData added in v0.0.6 

type HitData struct {
	Index   string `json:"_index,omitempty"`   // index name
	Type    string `json:"_type,omitempty"`    // type meta field
	Id      string `json:"_id,omitempty"`      // external or internal
	Uid     string `json:"_uid,omitempty"`     // uid meta field (see MapperService.java for all meta fields)
	Version *int64 `json:"_version,omitempty"` // version number, when Version is set to true in SearchService
	Source  string `json:"_source,omitempty"`  // stored document source
}

type IService 

type IService interface {
	// Close  关闭 elasticsearch 客户端
	Close()
	// Info  获取 elasticsearch 信息
	Info() (res *elastic.NodesInfoResponse, err error)
	// DeleteIndex  删除 索引
	DeleteIndex(indexName string) (err error)
	// CreateIndex  创建 索引
	CreateIndex(indexName string, bodyJSON map[string]interface{}) (err error)
	// Indexes  查询 索引
	Indexes() (indexes []*IndexInfo, err error)
	// GetMapping  查询 索引 配置
	GetMapping(indexName string) (res interface{}, err error)
	// PutMapping  设置 索引 配置
	PutMapping(indexName string, bodyJSON map[string]interface{}) (err error)
	// SetFieldType  设置 索引 字段类型
	SetFieldType(indexName string, fieldName string, fieldType string) (err error)
	// Search  搜索
	Search(indexName string, pageIndex int, pageSize int, whereList []*Where, orderList []*Order) (res *SearchResult, err error)
	// Insert  插入数据 并且 等待刷新
	Insert(indexName string, id string, doc interface{}) (res *InsertResponse, err error)
	// InsertNotWait  插入数据 不 等待刷新
	InsertNotWait(indexName string, id string, doc interface{}) (res *InsertResponse, err error)
	// BatchInsertNotWait  批量插入数据 不 等待刷新
	BatchInsertNotWait(docs []*InsertDoc) (res *BulkResponse, err error)
	// Update  更新数据 并且 等待刷新
	Update(indexName string, id string, doc interface{}) (res *UpdateResponse, err error)
	// UpdateNotWait  更新数据 不 等待刷新
	UpdateNotWait(indexName string, id string, doc interface{}) (res *UpdateResponse, err error)
	// Delete  删除 并且 等待刷新
	Delete(indexName string, id string) (res *DeleteResponse, err error)
	// DeleteNotWait  删除 不 等待刷新
	DeleteNotWait(indexName string, id string) (res *DeleteResponse, err error)
	// Reindex 修改索引名称
	Reindex(sourceIndexName string, toIndexName string) (res *BulkIndexByScrollResponse, err error)
	// IndexStat 索引状态
	IndexStat(indexName string) (res *IndicesStatsResponse, err error)
	// Scroll 滚动查询
	Scroll(indexName string, scrollId string, pageSize int, whereList []*Where, orderList []*Order) (res *SearchResult, err error)
	// IndexAlias 索引别名
	IndexAlias(indexName string, aliasName string) (res *IndexAliasResponse, err error)
	PerformRequest(options PerformRequestOptions) (res *PerformResponse, err error)
	QuerySql(query string) (res *QuerySqlResult, err error)
}

func New added in v0.0.6 

func New(config *Config) (IService, error)

type ImportTask added in v0.0.9 

type ImportTask struct {
	*Task
	ImportType string `json:"importType,omitempty"`

	Id         string                `json:"id,omitempty"`
	ColumnList []*StrategyDataColumn `json:"columnList"`
}

type IndexAliasResponse added in v0.0.6 

type IndexAliasResponse struct {
	*elastic.AliasResult
}

type IndexInfo added in v0.0.6 

type IndexInfo struct {
	IndexName string `json:"indexName"`
}

type IndicesStatsResponse added in v0.0.6 

type IndicesStatsResponse struct {
	*elastic.IndicesStatsResponse
}

type InsertDoc added in v0.0.6 

type InsertDoc struct {
	IndexName string
	Id        string
	Doc       interface{}
}

type InsertResponse added in v0.0.6 

type InsertResponse struct {
	*elastic.IndexResponse
}

type Order added in v0.0.6 

type Order struct {
	Name    string `json:"name"`
	AscDesc string `json:"ascDesc"`
}

type PerformRequestOptions added in v1.1.21 

type PerformRequestOptions struct {
	elastic.PerformRequestOptions
}

type PerformResponse added in v1.1.21 

type PerformResponse struct {
	Header http.Header
	Body   []byte
}

type QuerySqlResult added in v1.1.22 

type QuerySqlResult struct {
	Columns []*QuerySqlResultColumn `json:"columns"`
	Rows    [][]interface{}         `json:"rows"`
}

type QuerySqlResultColumn added in v1.1.22 

type QuerySqlResultColumn struct {
	Name string `json:"name"`
	Type string `json:"type"`
}

type SearchResult added in v0.0.6 

type SearchResult struct {
	TotalHits *elastic.TotalHits `json:"total,omitempty"`     // total number of hits found
	MaxScore  *float64           `json:"max_score,omitempty"` // maximum score of all hits
	Hits      []*HitData         `json:"hits,omitempty"`      // the actual hits returned
	ScrollId  string             `json:"_scroll_id,omitempty"`
}

type StrategyDataColumn added in v0.0.9 

type StrategyDataColumn struct {
	Name        string `json:"name,omitempty"`
	Value       string `json:"value,omitempty"`
	ReuseNumber int    `json:"reuseNumber,omitempty"`
}

type Task added in v0.0.9 

type Task struct {
	IndexName string `json:"indexName,omitempty"`
	TaskId    string `json:"taskId,omitempty"`

	DataNumber    int   `json:"dataNumber,omitempty"`
	BatchNumber   int   `json:"batchNumber,omitempty"`
	ThreadNumber  int   `json:"threadNumber,omitempty"`
	ErrorContinue bool  `json:"errorContinue"`
	UseTime       int64 `json:"useTime"`

	IsEnd     bool      `json:"isEnd"`
	StartTime time.Time `json:"startTime,omitempty"`
	NowTime   time.Time `json:"nowTime,omitempty"`
	EndTime   time.Time `json:"endTime,omitempty"`
	Error     string    `json:"error,omitempty"`
	IsStop    bool      `json:"isStop"`
	Service   IService  `json:"-"`

	ReadyDataStatisticsList []*data_engine.DataStatistics `json:"readyDataStatisticsList"`
	DoDataStatisticsList    []*data_engine.DataStatistics `json:"doDataStatisticsList"`

	ReadyDataStatistics *data_engine.DataStatistics `json:"readyDataStatistics"`
	DoDataStatistics    *data_engine.DataStatistics `json:"doDataStatistics"`
	// contains filtered or unexported fields
}

func CleanTask added in v0.0.9 

func CleanTask(taskKey string) *Task

func GetTask added in v0.0.9 

func GetTask(taskKey string) *Task

func StopTask added in v0.0.9 

func StopTask(taskKey string) *Task

func (*Task) Start added in v0.0.9 

func (this_ *Task) Start()

func (*Task) Statistics added in v0.0.9 

func (this_ *Task) Statistics()

func (*Task) StatisticsList added in v0.0.9 

func (this_ *Task) StatisticsList(list []*data_engine.DataStatistics) (statistics *data_engine.DataStatistics)

func (*Task) Stop added in v0.0.9 

func (this_ *Task) Stop()

type UpdateResponse added in v0.0.6 

type UpdateResponse struct {
	*elastic.UpdateResponse
}

type V7Service added in v0.0.6 

type V7Service struct {
	*Config
	// contains filtered or unexported fields
}

V7Service 注册处理器在线信息等

func (*V7Service) BatchInsertNotWait added in v0.0.6 

func (this_ *V7Service) BatchInsertNotWait(docs []*InsertDoc) (res *BulkResponse, err error)

func (*V7Service) Close added in v0.5.7 

func (this_ *V7Service) Close()

func (*V7Service) CreateIndex added in v0.0.6 

func (this_ *V7Service) CreateIndex(indexName string, bodyJSON map[string]interface{}) (err error)

func (*V7Service) Delete added in v0.0.6 

func (this_ *V7Service) Delete(indexName string, id string) (res *DeleteResponse, err error)

func (*V7Service) DeleteIndex added in v0.0.6 

func (this_ *V7Service) DeleteIndex(indexName string) (err error)

func (*V7Service) DeleteNotWait added in v0.5.7 

func (this_ *V7Service) DeleteNotWait(indexName string, id string) (res *DeleteResponse, err error)

func (*V7Service) GetClient added in v0.0.6 

func (this_ *V7Service) GetClient() (client *elastic.Client, err error)

func (*V7Service) GetMapping added in v0.0.6 

func (this_ *V7Service) GetMapping(indexName string) (res interface{}, err error)

func (*V7Service) IndexAlias added in v0.0.6 

func (this_ *V7Service) IndexAlias(indexName string, aliasName string) (res *IndexAliasResponse, err error)

func (*V7Service) IndexStat added in v0.0.6 

func (this_ *V7Service) IndexStat(indexName string) (res *IndicesStatsResponse, err error)

func (*V7Service) Indexes added in v0.0.6 

func (this_ *V7Service) Indexes() (indexes []*IndexInfo, err error)

func (*V7Service) Info added in v0.0.6 

func (this_ *V7Service) Info() (res *elastic.NodesInfoResponse, err error)

func (*V7Service) Insert added in v0.0.6 

func (this_ *V7Service) Insert(indexName string, id string, doc interface{}) (res *InsertResponse, err error)

func (*V7Service) InsertNotWait added in v0.0.6 

func (this_ *V7Service) InsertNotWait(indexName string, id string, doc interface{}) (res *InsertResponse, err error)

func (*V7Service) PerformRequest added in v1.1.21 

func (this_ *V7Service) PerformRequest(options PerformRequestOptions) (res *PerformResponse, err error)

func (*V7Service) PutMapping added in v0.0.6 

func (this_ *V7Service) PutMapping(indexName string, bodyJSON map[string]interface{}) (err error)

func (*V7Service) QuerySql added in v1.1.22 

func (this_ *V7Service) QuerySql(query string) (res *QuerySqlResult, err error)

func (*V7Service) Reindex added in v0.0.6 

func (this_ *V7Service) Reindex(sourceIndexName string, toIndexName string) (res *BulkIndexByScrollResponse, err error)

func (*V7Service) Scroll added in v0.0.6 

func (this_ *V7Service) Scroll(indexName string, scrollId string, pageSize int, whereList []*Where, orderList []*Order) (res *SearchResult, err error)

func (*V7Service) Search added in v0.0.6 

func (this_ *V7Service) Search(indexName string, pageIndex int, pageSize int, whereList []*Where, orderList []*Order) (res *SearchResult, err error)

func (*V7Service) SetFieldType added in v0.0.6 

func (this_ *V7Service) SetFieldType(indexName string, fieldName string, fieldType string) (err error)

func (*V7Service) Update added in v0.0.6 

func (this_ *V7Service) Update(indexName string, id string, doc interface{}) (res *UpdateResponse, err error)

func (*V7Service) UpdateNotWait added in v0.5.7 

func (this_ *V7Service) UpdateNotWait(indexName string, id string, doc interface{}) (res *UpdateResponse, err error)

type Where added in v0.0.6 

type Where struct {
	Name                    string `json:"name"`
	Value                   string `json:"value"`
	Before                  string `json:"before"`
	After                   string `json:"after"`
	CustomSql               string `json:"customSql"`
	SqlConditionalOperation string `json:"sqlConditionalOperation"`
	AndOr                   string `json:"andOr"`
}

Source Files

View all Source files

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.