elasticsearch

package
v1.8.8 Latest Latest
Warning

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

Go to latest
Published: Mar 27, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Authentication

type Authentication struct {
	// PlainTextConfig
	PlainText *PlainTextConfig
	// TLS authentication
	TLS *tlscommon.TLSConfig
}

func (*Authentication) ConfigureAuthenticationAndHTTP

func (config *Authentication) ConfigureAuthenticationAndHTTP(httpcfg *HTTPConfig, opts *elasticsearch.Config) error

type FlusherElasticSearch

type FlusherElasticSearch struct {
	// Convert ilogtail data convert config
	Convert convertConfig
	// Addresses elasticsearch addresses
	Addresses []string
	// Authentication
	Authentication Authentication
	// The container of logs
	Index string
	// HTTP config
	HTTPConfig *HTTPConfig
	// contains filtered or unexported fields
}

func NewFlusherElasticSearch

func NewFlusherElasticSearch() *FlusherElasticSearch

func (*FlusherElasticSearch) Description

func (f *FlusherElasticSearch) Description() string

func (*FlusherElasticSearch) Flush

func (f *FlusherElasticSearch) Flush(projectName string, logstoreName string, configName string, logGroupList []*protocol.LogGroup) error

func (*FlusherElasticSearch) Init

func (f *FlusherElasticSearch) Init(context pipeline.Context) error

func (*FlusherElasticSearch) IsReady

func (f *FlusherElasticSearch) IsReady(projectName string, logstoreName string, logstoreKey int64) bool

func (*FlusherElasticSearch) SetUrgent

func (f *FlusherElasticSearch) SetUrgent(flag bool)

func (*FlusherElasticSearch) Stop

func (f *FlusherElasticSearch) Stop() error

func (*FlusherElasticSearch) Validate

func (f *FlusherElasticSearch) Validate() error

type HTTPConfig

type HTTPConfig struct {
	MaxIdleConnsPerHost   int
	ResponseHeaderTimeout string
}

type PlainTextConfig

type PlainTextConfig struct {
	// The username for connecting to clickhouse.
	Username string
	// The password for connecting to clickhouse.
	Password string
}

func (*PlainTextConfig) ConfigurePlaintext

func (plainTextConfig *PlainTextConfig) ConfigurePlaintext(opts *elasticsearch.Config) error

Jump to

Keyboard shortcuts

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