Documentation ¶
Index ¶
- type Authentication
- type FlusherElasticSearch
- func (f *FlusherElasticSearch) Description() string
- func (f *FlusherElasticSearch) Flush(projectName string, logstoreName string, configName string, ...) error
- func (f *FlusherElasticSearch) Init(context pipeline.Context) error
- func (f *FlusherElasticSearch) IsReady(projectName string, logstoreName string, logstoreKey int64) bool
- func (f *FlusherElasticSearch) SetUrgent(flag bool)
- func (f *FlusherElasticSearch) Stop() error
- func (f *FlusherElasticSearch) Validate() error
- type HTTPConfig
- type PlainTextConfig
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) 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 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
Click to show internal directories.
Click to hide internal directories.