elasticsearch

package
v1.2.7 Latest Latest
Warning

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

 Go to latest Published: May 31, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Copyright 2015 Google Inc. All Rights Reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2015 Google Inc. All Rights Reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2015 Google Inc. All Rights Reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

View Source 
const (
	ESIndex       = "heapster"
	ESClusterName = "default"
)

Variables

This section is empty.

Functions

func MetricFamilyTimestamp 

func MetricFamilyTimestamp(metricFamily core.MetricFamily) string

Types

type AWSSigningTransport 

type AWSSigningTransport struct {
	HTTPClient  *http.Client
	Credentials awsauth.Credentials
	Session     *session.Session
}

AWSSigningTransport used to sign outgoing requests to AWS ES

func (AWSSigningTransport) RoundTrip 

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

RoundTrip implementation

type Elastic2Wrapper added in v1.1.0 

type Elastic2Wrapper struct {
	// contains filtered or unexported fields
}

func NewEsClient2 added in v1.1.0 

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

func (*Elastic2Wrapper) AddAlias added in v1.1.0 

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

func (*Elastic2Wrapper) AddBulkReq added in v1.1.0 

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

func (*Elastic2Wrapper) CreateIndex added in v1.1.0 

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

func (*Elastic2Wrapper) ErrorStats added in v1.2.0 

func (es *Elastic2Wrapper) ErrorStats() int64

func (*Elastic2Wrapper) FlushBulk added in v1.1.0 

func (es *Elastic2Wrapper) FlushBulk() error

func (*Elastic2Wrapper) HasAlias added in v1.1.0 

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

func (*Elastic2Wrapper) IndexExists added in v1.1.0 

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

type Elastic5Wrapper added in v1.1.0 

type Elastic5Wrapper struct {
	// contains filtered or unexported fields
}

func NewEsClient5 added in v1.1.0 

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

func (*Elastic5Wrapper) AddAlias added in v1.1.0 

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

func (*Elastic5Wrapper) AddBulkReq added in v1.1.0 

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

func (*Elastic5Wrapper) CreateIndex added in v1.1.0 

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

func (*Elastic5Wrapper) ErrorStats added in v1.2.0 

func (es *Elastic5Wrapper) ErrorStats() int64

func (*Elastic5Wrapper) FlushBulk added in v1.1.0 

func (es *Elastic5Wrapper) FlushBulk() error

func (*Elastic5Wrapper) HasAlias added in v1.1.0 

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

func (*Elastic5Wrapper) IndexExists added in v1.1.0 

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

type Elastic6Wrapper added in v1.1.0 

type Elastic6Wrapper struct {
	// contains filtered or unexported fields
}

func NewEsClient6 added in v1.1.0 

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

func (*Elastic6Wrapper) AddAlias added in v1.1.0 

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

func (*Elastic6Wrapper) AddBulkReq added in v1.1.0 

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

func (*Elastic6Wrapper) CreateIndex added in v1.1.0 

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

func (*Elastic6Wrapper) ErrorStats added in v1.2.0 

func (es *Elastic6Wrapper) ErrorStats() int64

func (*Elastic6Wrapper) FlushBulk added in v1.1.0 

func (es *Elastic6Wrapper) FlushBulk() error

func (*Elastic6Wrapper) HasAlias added in v1.1.0 

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

func (*Elastic6Wrapper) IndexExists added in v1.1.0 

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

type Elastic7Wrapper added in v1.1.0 

type Elastic7Wrapper struct {
	// contains filtered or unexported fields
}

func NewEsClient7 added in v1.1.0 

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

func (*Elastic7Wrapper) AddAlias added in v1.1.0 

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

func (*Elastic7Wrapper) AddBulkReq added in v1.1.0 

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

func (*Elastic7Wrapper) CreateIndex added in v1.1.0 

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

func (*Elastic7Wrapper) ErrorStats added in v1.2.0 

func (es *Elastic7Wrapper) ErrorStats() int64

func (*Elastic7Wrapper) FlushBulk added in v1.1.0 

func (es *Elastic7Wrapper) FlushBulk() error

func (*Elastic7Wrapper) HasAlias added in v1.1.0 

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

func (*Elastic7Wrapper) IndexExists added in v1.1.0 

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

type ElasticConfig added in v1.1.0 

type ElasticConfig struct {
	Url         []string
	User        string
	Secret      string
	MaxRetries  *int
	HealthCheck *bool
	Timeout     *time.Duration
	HttpClient  *http.Client
	Sniff       *bool
}

type ElasticSearchService 

type ElasticSearchService struct {
	EsClient elasticWrapper

	ClusterName  string
	UseNamespace bool
	// contains filtered or unexported fields
}

func CreateElasticSearchService 

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

CreateElasticSearchConfig creates an ElasticSearch configuration struct which contains an ElasticSearch client for later use

func (*ElasticSearchService) ErrorStats added in v1.2.0 

func (esSvc *ElasticSearchService) ErrorStats() int64

func (*ElasticSearchService) FlushData 

func (esSvc *ElasticSearchService) FlushData() error

func (*ElasticSearchService) Index 

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

func (*ElasticSearchService) IndexAlias 

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

func (*ElasticSearchService) SaveData 

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

SaveDataIntoES save metrics and events to ES by using ES client

type UnsupportedVersion 

type UnsupportedVersion struct{}

func (UnsupportedVersion) Error 

func (UnsupportedVersion) Error() string

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.