Documentation
¶
Index ¶
- func NewElasticsearch(name string, cspec v1alpha1.ClusterLogDestinationSpec) impl.LogDestination
- func NewLogstash(name string, cspec v1alpha1.ClusterLogDestinationSpec) impl.LogDestination
- func NewLoki(name string, cspec v1alpha1.ClusterLogDestinationSpec) impl.LogDestination
- type Buffer
- type CommonSettings
- type CommonTLS
- type Elasticsearch
- type ElasticsearchAuth
- type ElasticsearchBatch
- type ElasticsearchBulk
- type ElasticsearchEncoding
- type ElasticsearchRegion
- type Healthcheck
- type Logstash
- type LogstashEncoding
- type LogstashKeepalive
- type LogstashTLS
- type Loki
- type LokiAuth
- type LokiEncoding
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewElasticsearch ¶
func NewElasticsearch(name string, cspec v1alpha1.ClusterLogDestinationSpec) impl.LogDestination
func NewLogstash ¶
func NewLogstash(name string, cspec v1alpha1.ClusterLogDestinationSpec) impl.LogDestination
func NewLoki ¶
func NewLoki(name string, cspec v1alpha1.ClusterLogDestinationSpec) impl.LogDestination
Types ¶
type CommonSettings ¶
type CommonSettings struct {
Name string `json:"-"`
Type string `json:"type"`
Inputs []string `json:"inputs,omitempty"`
Healthcheck Healthcheck `json:"healthcheck"`
Buffer Buffer `json:"buffer,omitempty"`
}
func (*CommonSettings) AppendInputs ¶
func (cs *CommonSettings) AppendInputs(inp []string)
AppendInputs append inputs to destination. If input is already exists - skip it (dedup)
func (*CommonSettings) GetName ¶
func (cs *CommonSettings) GetName() string
type Elasticsearch ¶
type Elasticsearch struct {
CommonSettings
Endpoint string `json:"endpoint"`
Encoding ElasticsearchEncoding `json:"encoding,omitempty"`
Batch ElasticsearchBatch `json:"batch,omitempty"`
Auth ElasticsearchAuth `json:"auth,omitempty"`
TLS CommonTLS `json:"tls,omitempty"`
AWS ElasticsearchRegion `json:"aws,omitempty"`
Compression string `json:"compression,omitempty"`
Bulk ElasticsearchBulk `json:"bulk,omitempty"`
Pipeline string `json:"pipeline,omitempty"`
Mode string `json:"mode,omitempty"`
DocType string `json:"doc_type,omitempty"`
}
type ElasticsearchAuth ¶
type ElasticsearchAuth struct {
Password string `json:"password,omitempty"`
Strategy string `json:"strategy,omitempty"`
User string `json:"user,omitempty"`
AwsAccessKey string `json:"access_key_id,omitempty"`
AwsSecretKey string `json:"secret_access_key,omitempty"`
AwsAssumeRole string `json:"assume_role,omitempty"`
}
type ElasticsearchBatch ¶
type ElasticsearchBulk ¶
type ElasticsearchEncoding ¶
type ElasticsearchRegion ¶
type ElasticsearchRegion struct {
Region string `json:"region,omitempty"`
}
type Healthcheck ¶
type Healthcheck struct {
Enabled bool `json:"enabled"`
}
type Logstash ¶
type Logstash struct {
CommonSettings
Address string `json:"address"`
Encoding LogstashEncoding `json:"encoding,omitempty"`
Mode string `json:"mode"`
TLS LogstashTLS `json:"tls,omitempty"`
Keepalive LogstashKeepalive `json:"keepalive,omitempty"`
}
type LogstashEncoding ¶
type LogstashKeepalive ¶
type LogstashKeepalive struct {
TimeSecs int `json:"time_secs"`
}
type LogstashTLS ¶
type Loki ¶
type Loki struct {
CommonSettings
Encoding LokiEncoding `json:"encoding,omitempty"`
Endpoint string `json:"endpoint"`
Auth LokiAuth `json:"auth,omitempty"`
TLS CommonTLS `json:"tls,omitempty"`
Labels map[string]string `json:"labels,omitempty"`
RemoveLabelFields bool `json:"remove_label_fields"`
OutOfOrderAction string `json:"out_of_order_action"`
}
type LokiEncoding ¶
Click to show internal directories.
Click to hide internal directories.