elasticsearch

Jun 28, 2017

Changes in this version

+ func NewMockClient() *esClient

+ type UnsupportedVersion struct

+ func (UnsupportedVersion) Error() string

Mar 17, 2017

Changes in this version

+ const ESClusterName

+ func MetricFamilyTimestamp(metricFamily core.MetricFamily) string

+ type ElasticSearchService struct

+ ClusterName string

+ EsClient *elastic.Client

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

+ func (esSvc *ElasticSearchService) FlushData() error

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

+ func (esSvc *ElasticSearchService) IndexAlias(date time.Time, typeName string) string

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

Sep 14, 2016

Changes in this version

+ type AWSSigningTransport struct

+ Credentials awsauth.Credentials

+ HTTPClient *http.Client

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

Jun 16, 2016

Changes in this version

+ const ESIndex

+ func SaveDataIntoES(esClient *elastic.Client, indexName string, typeName string, ...) error

+ type ElasticSearchConfig struct

+ EsClient *elastic.Client

+ EsNodes []string

+ EsUserName string

+ EsUserSecret string

+ Index string

+ NeedAuthen bool

+ func CreateElasticSearchConfig(uri *url.URL) (*ElasticSearchConfig, error)

+ type SaveDataFunc func(esClient *elastic.Client, indexName string, typeName string, ...) error