elasticsearch

package

Go to main page

Versions in this module

v1

v1.2.7

May 31, 2023

v1.2.0

Jun 2, 2020

Changes in this version

type AWSSigningTransport

+ Session *session.Session

type Elastic2Wrapper

+ func (es *Elastic2Wrapper) ErrorStats() int64

type Elastic5Wrapper

+ func (es *Elastic5Wrapper) ErrorStats() int64

type Elastic6Wrapper

+ func (es *Elastic6Wrapper) ErrorStats() int64

type Elastic7Wrapper

+ func (es *Elastic7Wrapper) ErrorStats() int64

type ElasticSearchService

+ func (esSvc *ElasticSearchService) ErrorStats() int64

v1.1.0

Oct 30, 2019

Changes in this version

+ type Elastic2Wrapper struct

+ func NewEsClient2(config ElasticConfig, bulkWorkers int) (*Elastic2Wrapper, error)

+ func (es *Elastic2Wrapper) AddAlias(index string, alias string) (bool, error)

+ func (es *Elastic2Wrapper) AddBulkReq(index, typeName string, data interface{}) error

+ func (es *Elastic2Wrapper) CreateIndex(name string, mapping string) (bool, error)

+ func (es *Elastic2Wrapper) FlushBulk() error

+ func (es *Elastic2Wrapper) HasAlias(indexName string, aliasName string) (bool, error)

+ func (es *Elastic2Wrapper) IndexExists(indices ...string) (bool, error)

+ type Elastic5Wrapper struct

+ func NewEsClient5(config ElasticConfig, bulkWorkers int, pipeline string) (*Elastic5Wrapper, error)

+ func (es *Elastic5Wrapper) AddAlias(index string, alias string) (bool, error)

+ func (es *Elastic5Wrapper) AddBulkReq(index, typeName string, data interface{}) error

+ func (es *Elastic5Wrapper) CreateIndex(name string, mapping string) (bool, error)

+ func (es *Elastic5Wrapper) FlushBulk() error

+ func (es *Elastic5Wrapper) HasAlias(indexName string, aliasName string) (bool, error)

+ func (es *Elastic5Wrapper) IndexExists(indices ...string) (bool, error)

+ type Elastic6Wrapper struct

+ func NewEsClient6(config ElasticConfig, bulkWorkers int, pipeline string) (*Elastic6Wrapper, error)

+ func (es *Elastic6Wrapper) AddAlias(index string, alias string) (bool, error)

+ func (es *Elastic6Wrapper) AddBulkReq(index, typeName string, data interface{}) error

+ func (es *Elastic6Wrapper) CreateIndex(name string, mapping string) (bool, error)

+ func (es *Elastic6Wrapper) FlushBulk() error

+ func (es *Elastic6Wrapper) HasAlias(indexName string, aliasName string) (bool, error)

+ func (es *Elastic6Wrapper) IndexExists(indices ...string) (bool, error)

+ type Elastic7Wrapper struct

+ func NewEsClient7(config ElasticConfig, bulkWorkers int, pipeline string) (*Elastic7Wrapper, error)

+ func (es *Elastic7Wrapper) AddAlias(index string, alias string) (bool, error)

+ func (es *Elastic7Wrapper) AddBulkReq(index, typeName string, data interface{}) error

+ func (es *Elastic7Wrapper) CreateIndex(name string, mapping string) (bool, error)

+ func (es *Elastic7Wrapper) FlushBulk() error

+ func (es *Elastic7Wrapper) HasAlias(indexName string, aliasName string) (bool, error)

+ func (es *Elastic7Wrapper) IndexExists(indices ...string) (bool, error)

+ type ElasticConfig struct

+ HealthCheck *bool

+ HttpClient *http.Client

+ MaxRetries *int

+ Secret string

+ Sniff *bool

+ Timeout *time.Duration

+ Url []string

+ User string

type ElasticSearchService

+ UseNamespace bool

v1.0.0

Jul 13, 2019

Changes in this version

+ const ESClusterName

+ const ESIndex

+ func MetricFamilyTimestamp(metricFamily core.MetricFamily) string

+ func NewMockClient() *esClient

+ type AWSSigningTransport struct

+ Credentials awsauth.Credentials

+ HTTPClient *http.Client

+ func (a AWSSigningTransport) RoundTrip(req *http.Request) (*http.Response, error)

+ type ElasticSearchService struct

+ ClusterName string

+ EsClient *esClient

+ func CreateElasticSearchService(uri *url.URL) (*ElasticSearchService, error)

+ func (esSvc *ElasticSearchService) FlushData() error

+ func (esSvc *ElasticSearchService) Index(date time.Time) string

+ func (esSvc *ElasticSearchService) IndexAlias(typeName string) string

+ func (esSvc *ElasticSearchService) SaveData(date time.Time, typeName string, sinkData []interface{}) error

+ type UnsupportedVersion struct

+ func (UnsupportedVersion) Error() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL