destination

package
v1.63.6 Latest Latest
Warning

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

 Go to latest Published: Aug 29, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ComposeName added in v1.36.0 

func ComposeName(n string) string

Types

type Buffer 

type Buffer struct {
	MaxSize   uint32 `json:"max_size,omitempty"`
	Type      string `json:"type,omitempty"`
	MaxEvents uint32 `json:"max_events,omitempty"`
	WhenFull  string `json:"when_full,omitempty"`
}

type CEFEncoding added in v1.54.0 

type CEFEncoding struct {
	DeviceVendor       string            `json:"device_vendor,omitempty"`
	DeviceProduct      string            `json:"device_product,omitempty"`
	DeviceVersion      string            `json:"device_version,omitempty"`
	DeviceEventClassID string            `json:"device_event_class_id,omitempty"`
	Name               string            `json:"name,omitempty"`
	Severity           string            `json:"severity,omitempty"`
	Version            string            `json:"version,omitempty"`
	Extensions         map[string]string `json:"extensions,omitempty"`
}

type CommonSettings 

type CommonSettings struct {
	Name        string      `json:"-"`
	Type        string      `json:"type"`
	Inputs      set.Set     `json:"inputs,omitempty"`
	Healthcheck Healthcheck `json:"healthcheck"`
	Buffer      *Buffer     `json:"buffer,omitempty"`
}

func (*CommonSettings) GetName 

func (cs *CommonSettings) GetName() string

func (*CommonSettings) SetInputs added in v1.36.0 

func (cs *CommonSettings) SetInputs(inp []string)

type CommonTLS 

type CommonTLS struct {
	CAFile            string `json:"ca_file,omitempty"`
	CertFile          string `json:"crt_file,omitempty"`
	KeyFile           string `json:"key_file,omitempty"`
	KeyPass           string `json:"key_pass,omitempty"`
	VerifyHostname    bool   `json:"verify_hostname"`
	VerifyCertificate bool   `json:"verify_certificate"`

	Enabled bool `json:"enabled,omitempty"`
}

type Elasticsearch 

type Elasticsearch struct {
	CommonSettings

	Endpoint string `json:"endpoint"`

	Encoding Encoding `json:"encoding,omitempty"`

	Batch ElasticsearchBatch `json:"batch,omitempty"`

	Auth ElasticsearchAuth `json:"auth,omitempty"`

	TLS CommonTLS `json:"tls"`

	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"`
	SuppressTypeName bool   `json:"suppress_type_name"`
}

func NewElasticsearch 

func NewElasticsearch(name string, cspec v1alpha1.ClusterLogDestinationSpec) *Elasticsearch

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 ElasticsearchBatch struct {
	MaxSize     uint32 `json:"max_bytes,omitempty"`
	TimeoutSecs uint32 `json:"timeout_secs,omitempty"`
}

type ElasticsearchBulk 

type ElasticsearchBulk struct {
	Action string `json:"action,omitempty"`
	Index  string `json:"index,omitempty"`
}

type ElasticsearchRegion 

type ElasticsearchRegion struct {
	Region string `json:"region,omitempty"`
}

type Encoding added in v1.39.0 

type Encoding struct {
	ExceptFields    []string    `json:"except_fields,omitempty"`
	OnlyFields      []string    `json:"only_fields,omitempty"`
	Codec           string      `json:"codec,omitempty"`
	TimestampFormat string      `json:"timestamp_format,omitempty"`
	CEF             CEFEncoding `json:"cef,omitempty"`
}

type Healthcheck 

type Healthcheck struct {
	Enabled bool `json:"enabled"`
}

type Kafka added in v1.39.0 

type Kafka struct {
	CommonSettings

	BootstrapServers string `json:"bootstrap_servers,omitempty"`

	Encoding Encoding `json:"encoding,omitempty"`

	Topic       string `json:"topic"`
	KeyField    string `json:"key_field,omitempty"`
	Compression string `json:"compression,omitempty"`

	TLS CommonTLS `json:"tls"`

	SASL KafkaSASL `json:"sasl,omitempty"`
}

func NewKafka added in v1.39.0 

func NewKafka(name string, cspec v1alpha1.ClusterLogDestinationSpec) *Kafka

type KafkaSASL added in v1.53.0 

type KafkaSASL struct {
	Username  string `json:"username,omitempty"`
	Password  string `json:"password,omitempty"`
	Mechanism string `json:"mechanism,omitempty"`

	Enabled bool `json:"enabled,omitempty"`
}

type Logstash 

type Logstash struct {
	CommonSettings

	Address string `json:"address"`

	Encoding Encoding `json:"encoding,omitempty"`

	Mode string `json:"mode"`

	TLS CommonTLS `json:"tls"`

	Keepalive LogstashKeepalive `json:"keepalive,omitempty"`
}

func NewLogstash 

func NewLogstash(name string, cspec v1alpha1.ClusterLogDestinationSpec) *Logstash

type LogstashKeepalive 

type LogstashKeepalive struct {
	TimeSecs int `json:"time_secs"`
}

type Loki 

type Loki struct {
	CommonSettings

	Encoding Encoding `json:"encoding,omitempty"`

	TenantID string `json:"tenant_id,omitempty"`

	Endpoint string `json:"endpoint"`

	Auth LokiAuth `json:"auth,omitempty"`

	TLS CommonTLS `json:"tls"`

	Labels map[string]string `json:"labels,omitempty"`

	RemoveLabelFields bool `json:"remove_label_fields"`

	OutOfOrderAction string `json:"out_of_order_action"`
}

func NewLoki 

func NewLoki(name string, cspec v1alpha1.ClusterLogDestinationSpec) *Loki

type LokiAuth 

type LokiAuth struct {
	Password string `json:"password,omitempty"`
	Strategy string `json:"strategy,omitempty"`
	Token    string `json:"token,omitempty"`
	User     string `json:"user,omitempty"`
}

type Socket added in v1.62.0 

type Socket struct {
	CommonSettings

	Encoding Encoding `json:"encoding,omitempty"`

	Mode string `json:"mode,omitempty"`

	Address string `json:"address,omitempty"`

	TLS CommonTLS `json:"tls,omitempty"`
}

func NewSocket added in v1.62.0 

func NewSocket(name string, cspec v1alpha1.ClusterLogDestinationSpec) *Socket

type Splunk added in v1.42.0 

type Splunk struct {
	CommonSettings

	Encoding Encoding `json:"encoding,omitempty"`

	Compression string `json:"compression,omitempty"`

	DefaultToken string `json:"default_token,omitempty"`

	Endpoint string `json:"endpoint,omitempty"`

	Index string `json:"index,omitempty"`

	IndexedFields []string `json:"indexed_fields,omitempty"`

	TLS CommonTLS `json:"tls"`
}

func NewSplunk added in v1.42.0 

func NewSplunk(name string, cspec v1alpha1.ClusterLogDestinationSpec) *Splunk

type Vector 

type Vector struct {
	CommonSettings

	Version string `json:"version,omitempty"`

	Address string `json:"address"`

	TLS CommonTLS `json:"tls"`

	Keepalive VectorKeepalive `json:"keepalive,omitempty"`
}

func NewVector 

func NewVector(name string, cspec v1alpha1.ClusterLogDestinationSpec) *Vector

type VectorKeepalive 

type VectorKeepalive struct {
	TimeSecs int `json:"time_secs"`
}

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.