destination

Documentation

Index

• func ComposeName(n string) string
• type Buffer
• type CommonSettings
  • func (cs *CommonSettings) GetName() string
  • func (cs *CommonSettings) SetInputs(inp []string)
• type CommonTLS
• type Elasticsearch
  • func NewElasticsearch(name string, cspec v1alpha1.ClusterLogDestinationSpec) *Elasticsearch
• type ElasticsearchAuth
• type ElasticsearchBatch
• type ElasticsearchBulk
• type ElasticsearchEncoding
• type ElasticsearchRegion
• type Healthcheck
• type Logstash
  • func NewLogstash(name string, cspec v1alpha1.ClusterLogDestinationSpec) *Logstash
• type LogstashEncoding
• type LogstashKeepalive
• type Loki
  • func NewLoki(name string, cspec v1alpha1.ClusterLogDestinationSpec) *Loki
• type LokiAuth
• type LokiEncoding
• type Vector
  • func NewVector(name string, cspec v1alpha1.ClusterLogDestinationSpec) *Vector
• type VectorKeepalive

Functions

func ComposeName

func ComposeName(n string) string

Types

type Buffer

type Buffer struct {
	Size uint32 `json:"max_size,omitempty"`
	Type string `json:"type,omitempty"`
}

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) GetName

func (cs *CommonSettings) GetName() string

func (*CommonSettings) SetInputs

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"`
}

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"`

	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"`
}

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 ElasticsearchEncoding

type ElasticsearchEncoding struct {
	ExceptFields    []string `json:"except_fields,omitempty"`
	OnlyFields      []string `json:"only_fields,omitempty"`
	TimestampFormat string   `json:"timestamp_format,omitempty"`
}

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 CommonTLS `json:"tls,omitempty"`

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

func NewLogstash

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

type LogstashEncoding

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

type LogstashKeepalive

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

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"`
}

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 LokiEncoding

type LokiEncoding struct {
	Codec           string   `json:"codec,omitempty"`
	OnlyFields      []string `json:"only_fields,omitempty"`
	TimestampFormat string   `json:"timestamp_format,omitempty"`
}

type Vector

type Vector struct {
	CommonSettings

	Version string `json:"version,omitempty"`

	Address string `json:"address"`

	TLS CommonTLS `json:"tls,omitempty"`

	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"`
}