logging

Documentation

Index

• type Buffer
• type Config
• type ConfigOutput
• type Filter
• type FilterKubernetes
• type Flow
  • func NewFlow(conf *FlowConfig) *Flow
• type FlowConfig
• type FlowSpec
• type Fluentbit
• type Fluentd
• type Image
• type KubernetesStorage
• type Logging
  • func New(spec *latest.LogCollection) *Logging
• type Loki
• type Match
• type Metadata
• type Metrics
• type Output
  • func NewOutput(clusterOutput bool, conf *ConfigOutput) *Output
• type OutputSpec
• type Parse
• type Parser
• type Pvc
• type PvcSpec
• type Requests
• type Resources
• type Scaling
• type Select
• type Spec
• type Storage
• type TagNormaliser

Types

type Buffer

type Buffer struct {
	Timekey       string `yaml:"timekey"`
	TimekeyWait   string `yaml:"timekey_wait"`
	TimekeyUseUtc bool   `yaml:"timekey_use_utc"`
}

type Config

type Config struct {
	Name             string
	Namespace        string
	ControlNamespace string
	Replicas         int
	NodeSelector     map[string]string
	Tolerations      k8s.Tolerations
	Fluentd          *latest.Fluentd
	FluentbitPVC     *Storage
}

type ConfigOutput

type ConfigOutput struct {
	Name      string
	Namespace string
	URL       string
}

type Filter

type Filter struct {
	Parser        *Parser        `yaml:"parser,omitempty"`
	TagNormaliser *TagNormaliser `yaml:"tag_normaliser,omitempty"`
}

type FilterKubernetes

type FilterKubernetes struct {
	KubeTagPrefix string `yaml:"Kube_Tag_Prefix"`
}

type Flow

type Flow struct {
	APIVersion string    `yaml:"apiVersion"`
	Kind       string    `yaml:"kind"`
	Metadata   *Metadata `yaml:"metadata"`
	Spec       *FlowSpec `yaml:"spec"`
}

func NewFlow

func NewFlow(conf *FlowConfig) *Flow

type FlowConfig

type FlowConfig struct {
	Name           string
	Namespace      string
	SelectLabels   map[string]string
	Outputs        []string
	ClusterOutputs []string
	ParserType     string
}

type FlowSpec

type FlowSpec struct {
	Filters           []*Filter `yaml:"filters,omitempty"`
	Match             []*Match  `yaml:"match,omitempty"`
	OutputRefs        []string  `yaml:"localOutputRefs"`
	ClusterOutputRefs []string  `yaml:"globalOutputRefs"`
}

type Fluentbit

type Fluentbit struct {
	Metrics             *Metrics           `yaml:"metrics,omitempty"`
	FilterKubernetes    *FilterKubernetes  `yaml:"filterKubernetes,omitempty"`
	Image               *Image             `yaml:"image,omitempty"`
	BufferStorageVolume *KubernetesStorage `yaml:"bufferStorageVolume,omitempty"`
	NodeSelector        map[string]string  `yaml:"nodeSelector,omitempty"`
	Tolerations         k8s.Tolerations    `yaml:"tolerations,omitempty"`
	Resources           *k8s.Resources     `yaml:"resources,omitempty"`
}

type Fluentd

type Fluentd struct {
	Metrics             *Metrics           `yaml:"metrics,omitempty"`
	BufferStorageVolume *KubernetesStorage `yaml:"bufferStorageVolume,omitempty"`
	LogLevel            string             `yaml:"logLevel,omitempty"`
	DisablePvc          bool               `yaml:"disablePvc"`
	Scaling             *Scaling           `yaml:"scaling,omitempty"`
	NodeSelector        map[string]string  `yaml:"nodeSelector,omitempty"`
	Tolerations         k8s.Tolerations    `yaml:"tolerations,omitempty"`
	Resources           *k8s.Resources     `yaml:"resources,omitempty"`
}

type Image

type Image struct {
	PullPolicy string `yaml:"pullPolicy"`
	Repository string `yaml:"repository"`
	Tag        string `yaml:"tag"`
}

type KubernetesStorage

type KubernetesStorage struct {
	Pvc *Pvc `yaml:"pvc,omitempty"`
}

type Logging

type Logging struct {
	APIVersion string    `yaml:"apiVersion"`
	Kind       string    `yaml:"kind"`
	Metadata   *Metadata `yaml:"metadata"`
	Spec       *Spec     `yaml:"spec"`
}

func New

func New(spec *latest.LogCollection) *Logging

type Loki

type Loki struct {
	URL                       string  `yaml:"url"`
	ConfigureKubernetesLabels bool    `yaml:"configure_kubernetes_labels"`
	Buffer                    *Buffer `yaml:"buffer"`
}

type Match

type Match struct {
	Select  *Select `yaml:"select"`
	Exclude *Select `yaml:"exlcude"`
}

type Metadata

type Metadata struct {
	Name      string `yaml:"name"`
	Namespace string `yaml:"namespace"`
}

type Metrics

type Metrics struct {
	Port int `yaml:"port"`
}

type Output

type Output struct {
	APIVersion string      `yaml:"apiVersion"`
	Kind       string      `yaml:"kind"`
	Metadata   *Metadata   `yaml:"metadata"`
	Spec       *OutputSpec `yaml:"spec"`
}

func NewOutput

func NewOutput(clusterOutput bool, conf *ConfigOutput) *Output

type OutputSpec

type OutputSpec struct {
	Loki *Loki `yaml:"loki"`
}

type Parse

type Parse struct {
	Type string `yaml:"type"`
}

type Parser

type Parser struct {
	RemoveKeyNameField bool   `yaml:"remove_key_name_field"`
	ReserveData        bool   `yaml:"reserve_data"`
	Parse              *Parse `yaml:"parse"`
}

type Pvc

type Pvc struct {
	PvcSpec *PvcSpec `yaml:"spec,omitempty"`
}

type PvcSpec

type PvcSpec struct {
	AccessModes      []string   `yaml:"accessModes,omitempty"`
	Resources        *Resources `yaml:"resources,omitempty"`
	StorageClassName string     `yaml:"storageClassName,omitempty"`
}

type Requests

type Requests struct {
	Storage string `yaml:"storage,omitempty"`
}

type Resources

type Resources struct {
	Requests *Requests `yaml:"requests,omitempty"`
}

type Scaling

type Scaling struct {
	Replicas int `yaml:"replicas"`
}

type Select

type Select struct {
	Labels     map[string]string `yaml:"labels,omitempty"`
	Hosts      []string          `yaml:"hosts,omitempty"`
	Namespaces []string          `yaml:"namespaces,omitempty"`
}

type Spec

type Spec struct {
	Fluentd                                      *Fluentd   `yaml:"fluentd"`
	Fluentbit                                    *Fluentbit `yaml:"fluentbit"`
	WatchNamespaces                              []string   `yaml:"watchNamespaces"`
	ControlNamespace                             string     `yaml:"controlNamespace"`
	EnableRecreateWorkloadOnImmutableFieldChange bool       `yaml:"enableRecreateWorkloadOnImmutableFieldChange"`
	FlowConfigCheckDisabled                      bool       `yaml:"flowConfigCheckDisabled"`
}

type Storage

type Storage struct {
	StorageClassName string
	AccessModes      []string
	Storage          string
}

type TagNormaliser

type TagNormaliser struct {
	Format string
}