helpers

Documentation

Index

• Constants
• Variables
• func ConfigPath(name string, file string) string
• func FormatComponentID(name string) string
• func ListenOnAllLocalInterfacesAddress() string
• func MakeID(parts ...string) string
• func MakeInputID(parts ...string) string
• func MakeInputs(in ...string) string
• func MakeOutputID(parts ...string) string
• func MakePipelineID(parts ...string) string
• func MakeRouteInputID(rerouteId, sourceType string) string
• func SecretFrom(secretKey *v1.SecretReference) string
• func SecretPath(secretName string, file string) string
• func TrimSpaces(in []string) []string
• type ComponentReceiver
• type InputComponent

Constants

const VectorSecretID = "kubernetes_secret"

Variables

var (
	Replacer = strings.NewReplacer(" ", "_", "-", "_", ".", "_")
)

Functions

func ConfigPath

func ConfigPath(name string, file string) string

ConfigPath is the quoted path for any configmap visible to the collector

func FormatComponentID

func FormatComponentID(name string) string

func ListenOnAllLocalInterfacesAddress

func ListenOnAllLocalInterfacesAddress() string

func MakeID

func MakeID(parts ...string) string

MakeID given a list of components

func MakeInputID

func MakeInputID(parts ...string) string

MakeInputID for components that logically represent clf.input

func MakeInputs

func MakeInputs(in ...string) string

func MakeOutputID

func MakeOutputID(parts ...string) string

MakeOutPutID for components that logically represent clf.output

func MakePipelineID

func MakePipelineID(parts ...string) string

MakePipelineID for components that logically represent clf.pipeline (e.g. filters)

func MakeRouteInputID

func MakeRouteInputID(rerouteId, sourceType string) string

MakeRouteInputID appends sourceType to rerouteId for input ids

func SecretFrom

func SecretFrom(secretKey *v1.SecretReference) string

SecretFrom formated string SECRET[<secret_component_id>.<secret_name>#<secret_key>]

func SecretPath

func SecretPath(secretName string, file string) string

SecretPath is the quoted path for any secret visible to the collector

func TrimSpaces

func TrimSpaces(in []string) []string

Types

type ComponentReceiver

type ComponentReceiver interface {
	AddInputFrom(n InputComponent)
}

ComponentReceiver is a vector component that receives input from another component (e.g. transform, sink)

type InputComponent

type InputComponent interface {
	// InputIDs are the ids of config elemements to use as input to other components
	InputIDs() []string
}

InputComponent is a vector sink, transformation, source that is provided as input to other components