source

package
v0.0.0-...-fbbe22e Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const HostAuditLogTemplate = `` /* 295-byte string literal not displayed */
View Source 
const (
	InternalMetricsSourceName = "internal_metrics"
)
View Source 
const JournalLogTemplate = `` /* 134-byte string literal not displayed */
View Source 
const K8sAuditLogTemplate = `` /* 304-byte string literal not displayed */
View Source 
const OVNAuditLogTemplate = `` /* 301-byte string literal not displayed */
View Source 
const OpenshiftAuditLogTemplate = `` /* 386-byte string literal not displayed */

Variables

This section is empty.

Functions

func ContainerPathGlobFrom 

func ContainerPathGlobFrom(namespaces, containers []string, extensions ...string) string

ContainerPathGlobFrom formats a list of kubernetes container file paths to include/exclude for collection given a list of namespaces and containers and return a string that is in a form directly usable by a vector kubernetes_log config. The result is a set of file paths assumed to be at the well known location and structure of CRIO pod logs. Container and namespace includes are combined in their various permutations as well as excludes to allow collection (or exclusion) of specific containers from specific namespaces The format rules: 

namespaces:
  namespace:     /var/log/pods/namespace_*/*/*.log
  **namespace:   /var/log/pods/*namespace_*/*/*.log
  **name*pace**: /var/log/pods/*name*pace*/*/*.log
  namespace**:   /var/log/pods/namespace*/*/*.log
containers:
  container:    /var/log/pods/*/container/*.log
  *cont**iner*:    /var/log/pods/*/*cont*iner*/*.log
  cont**iner*:    /var/log/pods/*/cont*iner*/*.log

func LabelSelectorFrom 

func LabelSelectorFrom(selector *metav1.LabelSelector) string

func MetricsSources 

func MetricsSources(id string) []framework.Element

func NewHttpSource 

func NewHttpSource(id, inputName string, input obs.InputSpec) (framework.Element, string)

func NewItemsTransform 

func NewItemsTransform(id, inputs string) (framework.Element, string)

func NewSplitTransform 

func NewSplitTransform(id, inputs string) (framework.Element, string)

func NewSyslogSource 

func NewSyslogSource(id, inputName string, input obs.InputSpec) framework.Element

Types

type ContainerPathGlobBuilder 

type ContainerPathGlobBuilder struct {
	// contains filtered or unexported fields
}

func NewContainerPathGlobBuilder 

func NewContainerPathGlobBuilder() *ContainerPathGlobBuilder

func (*ContainerPathGlobBuilder) AddCombined 

func (b *ContainerPathGlobBuilder) AddCombined(ncs ...NamespaceContainer) *ContainerPathGlobBuilder

func (*ContainerPathGlobBuilder) AddContainers 

func (b *ContainerPathGlobBuilder) AddContainers(containers ...string) *ContainerPathGlobBuilder

func (*ContainerPathGlobBuilder) AddExtensions 

func (b *ContainerPathGlobBuilder) AddExtensions(extensions ...string) *ContainerPathGlobBuilder

func (*ContainerPathGlobBuilder) AddNamespaces 

func (b *ContainerPathGlobBuilder) AddNamespaces(namespaces ...string) *ContainerPathGlobBuilder

func (*ContainerPathGlobBuilder) AddOther 

func (b *ContainerPathGlobBuilder) AddOther(other ...string) *ContainerPathGlobBuilder

AddOther takes an argument and joins it with the well known container path

func (*ContainerPathGlobBuilder) Build 

func (b *ContainerPathGlobBuilder) Build(excludeNSFromContainers ...string) string

type HostAuditLog 

type HostAuditLog = framework.ConfLiteral

func NewHostAuditLog 

func NewHostAuditLog(id string) HostAuditLog

type HttpReceiver 

type HttpReceiver struct {
	ID            string
	InputName     string
	ListenAddress string
	ListenPort    int32
	Format        string
}

func (HttpReceiver) Name 

func (HttpReceiver) Name() string

func (HttpReceiver) Template 

func (i HttpReceiver) Template() string

type InternalMetrics 

type InternalMetrics struct {
	ID                string
	ScrapeIntervalSec int
}

func (InternalMetrics) Name 

func (InternalMetrics) Name() string

func (InternalMetrics) Template 

func (i InternalMetrics) Template() string

type JournalLog 

type JournalLog = framework.ConfLiteral

func NewJournalLog 

func NewJournalLog(id string) JournalLog

type K8sAuditLog 

type K8sAuditLog = framework.ConfLiteral

func NewK8sAuditLog 

func NewK8sAuditLog(id string) K8sAuditLog

type KubernetesLogs 

type KubernetesLogs struct {
	framework.ComponentID
	Desc               string
	IncludePaths       string
	ExcludePaths       string
	ExtraLabelSelector string
}

func NewKubernetesLogs 

func NewKubernetesLogs(id, includes, excludes string) KubernetesLogs

NewKubernetesLogs element which always excludes temp and gzip files

func (KubernetesLogs) Name 

func (kl KubernetesLogs) Name() string

func (KubernetesLogs) Template 

func (kl KubernetesLogs) Template() string

type NamespaceContainer 

type NamespaceContainer struct {
	Namespace string
	Container string
}

type OVNAuditLog 

type OVNAuditLog = framework.ConfLiteral

func NewOVNAuditLog 

func NewOVNAuditLog(id string) OVNAuditLog

type OpenshiftAuditLog 

type OpenshiftAuditLog = framework.ConfLiteral

func NewOpenshiftAuditLog 

func NewOpenshiftAuditLog(id string) OpenshiftAuditLog

type SyslogReceiver 

type SyslogReceiver struct {
	ID            string
	InputName     string
	ListenAddress string
	ListenPort    int32
}

func (SyslogReceiver) Name 

func (SyslogReceiver) Name() string

func (SyslogReceiver) Template 

func (i SyslogReceiver) Template() string

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.