Documentation ¶
Index ¶
- type BulkProcessor
- type ElasticSearchClient
- func (elasticSearchClient *ElasticSearchClient) CloseConnection()
- func (elasticSearchClient *ElasticSearchClient) CreateBulkProcessor(maxConnection int) *BulkProcessor
- func (elasticSearchClient *ElasticSearchClient) GetAllTypeForIndex(index string) ([]string, error)
- func (elasticSearchClient *ElasticSearchClient) GetConnection() *elastigo.Conn
- func (elasticSearchClient *ElasticSearchClient) Reconnect()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BulkProcessor ¶
type BulkProcessor struct {
// contains filtered or unexported fields
}
Bulk Process
func (*BulkProcessor) BufferIndex ¶
func (bulkProcessor *BulkProcessor) BufferIndex( index string, _type string, id string, jsonMap map[string]interface{}) error
WARNING: Due to goelstic's hard code channel size, if the buffered document amount reach 100, it will get stuck
func (*BulkProcessor) FlushAndStopBulkProcessor ¶
func (bulkProcessor *BulkProcessor) FlushAndStopBulkProcessor()
type ElasticSearchClient ¶
type ElasticSearchClient struct {
// contains filtered or unexported fields
}
func CreateElasticSearchClient ¶
func CreateElasticSearchClient(host []string, port int) *ElasticSearchClient
func (*ElasticSearchClient) CloseConnection ¶
func (elasticSearchClient *ElasticSearchClient) CloseConnection()
func (*ElasticSearchClient) CreateBulkProcessor ¶
func (elasticSearchClient *ElasticSearchClient) CreateBulkProcessor(maxConnection int) *BulkProcessor
func (*ElasticSearchClient) GetAllTypeForIndex ¶
func (elasticSearchClient *ElasticSearchClient) GetAllTypeForIndex(index string) ([]string, error)
Get all types for index
func (*ElasticSearchClient) GetConnection ¶
func (elasticSearchClient *ElasticSearchClient) GetConnection() *elastigo.Conn
func (*ElasticSearchClient) Reconnect ¶
func (elasticSearchClient *ElasticSearchClient) Reconnect()
Click to show internal directories.
Click to hide internal directories.