helper

Documentation

Index

• Constants
• func ExtractContainerId(containerID string) string
• func GenContainerStdoutLog(podLogDirPrefix string, namespace string, podName string, podUID string, ...) []string
• func GenTypePodSourceName(lgcNamespace string, podNamespace string, podName string, containerName string, ...) string
• func GetContainerIds(pod *corev1.Pod) sets.String
• func GetLogConfigRelatedPod(lgc *logconfigv1beta1.LogConfig, podsLister corev1listers.PodLister) ([]*corev1.Pod, error)
• func GetMatchedPodAnnotation(annotationKeys []string, pod *corev1.Pod) map[string]string
• func GetMatchedPodEnv(envKeys []string, pod *corev1.Pod, containerName string) map[string]string
• func GetMatchedPodLabel(labelKeys []string, pod *corev1.Pod) map[string]string
• func GetPathsFromSource(src *source.Config) []string
• func GetPathsFromSources(src []*source.Config) []string
• func GetPodRelatedClusterLogConfigs(pod *corev1.Pod, clgcLister logconfigLister.ClusterLogConfigLister) ([]*logconfigv1beta1.ClusterLogConfig, error)
• func GetPodRelatedLogConfigs(pod *corev1.Pod, lgcLister logconfigLister.LogConfigLister) ([]*logconfigv1beta1.LogConfig, error)
• func GetTypePodOriginSourceName(podSourceName string) string
• func IsPodReady(pod *corev1.Pod) bool
• func LabelsSubset(i map[string]string, j map[string]string) bool
• func MatchStringMap(new map[string]string, old map[string]string) bool
• func MetaNamespaceKey(namespace string, name string) string
• func PathEqual(p1 string, p2 string) bool
• func PathsInNode(podLogDirPrefix string, kubeletRootDir string, rootFsCollectionEnabled bool, ...) ([]string, error)
• func Selector(labelSelector map[string]string) (labels.Selector, error)
• func SetPathsToSource(src *source.Config, paths []string)
• func ToPipeline(lgc *logconfigv1beta1.LogConfig, sinkLister v1beta1.SinkLister, ...) (*control.PipelineConfig, error)
• func ToPipelineInterceptor(interceptorsRaw string, interceptorRef string, ...) ([]*interceptor.Config, error)
• func ToPipelineSink(sinkRaw string, sinkRef string, sinkLister v1beta1.SinkLister) (*sink.Config, error)
• func ToPipelineSources(sources string) ([]*source.Config, error)
• type FuncGetRelatedPod
• type Workload
  • func GetWorkload(pod *corev1.Pod) Workload

Constants

const MatchAllToken = "*"

Functions

func ExtractContainerId

func ExtractContainerId(containerID string) string

func GenContainerStdoutLog

func GenContainerStdoutLog(podLogDirPrefix string, namespace string, podName string, podUID string, containerName string) []string

func GenTypePodSourceName

func GenTypePodSourceName(lgcNamespace string, podNamespace string, podName string, containerName string, sourceName string) string

func GetContainerIds

func GetContainerIds(pod *corev1.Pod) sets.String

func GetLogConfigRelatedPod

func GetLogConfigRelatedPod(lgc *logconfigv1beta1.LogConfig, podsLister corev1listers.PodLister) ([]*corev1.Pod, error)

func GetMatchedPodAnnotation

func GetMatchedPodAnnotation(annotationKeys []string, pod *corev1.Pod) map[string]string

func GetMatchedPodEnv

func GetMatchedPodEnv(envKeys []string, pod *corev1.Pod, containerName string) map[string]string

func GetMatchedPodLabel

func GetMatchedPodLabel(labelKeys []string, pod *corev1.Pod) map[string]string

func GetPathsFromSource

func GetPathsFromSource(src *source.Config) []string

func GetPathsFromSources

func GetPathsFromSources(src []*source.Config) []string

func GetPodRelatedClusterLogConfigs

func GetPodRelatedClusterLogConfigs(pod *corev1.Pod, clgcLister logconfigLister.ClusterLogConfigLister) ([]*logconfigv1beta1.ClusterLogConfig, error)

func GetPodRelatedLogConfigs

func GetPodRelatedLogConfigs(pod *corev1.Pod, lgcLister logconfigLister.LogConfigLister) ([]*logconfigv1beta1.LogConfig, error)

func GetTypePodOriginSourceName

func GetTypePodOriginSourceName(podSourceName string) string

func IsPodReady

func IsPodReady(pod *corev1.Pod) bool

func LabelsSubset

func LabelsSubset(i map[string]string, j map[string]string) bool

LabelsSubset checks if i is subset of j

func MatchStringMap

func MatchStringMap(new map[string]string, old map[string]string) bool

func MetaNamespaceKey

func MetaNamespaceKey(namespace string, name string) string

func PathEqual

func PathEqual(p1 string, p2 string) bool

PathEqual Compare whether the two paths are same, ignoring the suffix '/'

func PathsInNode

func PathsInNode(podLogDirPrefix string, kubeletRootDir string, rootFsCollectionEnabled bool, runtime runtime.Runtime,
	paths []string, pod *corev1.Pod, containerId string, containerName string) ([]string, error)

func Selector

func Selector(labelSelector map[string]string) (labels.Selector, error)

func SetPathsToSource

func SetPathsToSource(src *source.Config, paths []string)

func ToPipeline

func ToPipeline(lgc *logconfigv1beta1.LogConfig, sinkLister v1beta1.SinkLister, interceptorLister v1beta1.InterceptorLister) (*control.PipelineConfig, error)

func ToPipelineInterceptor

func ToPipelineInterceptor(interceptorsRaw string, interceptorRef string, interceptorLister v1beta1.InterceptorLister) ([]*interceptor.Config, error)

func ToPipelineSink

func ToPipelineSink(sinkRaw string, sinkRef string, sinkLister v1beta1.SinkLister) (*sink.Config, error)

func ToPipelineSources

func ToPipelineSources(sources string) ([]*source.Config, error)

Types

type FuncGetRelatedPod

type FuncGetRelatedPod func() ([]*corev1.Pod, error)

type Workload

type Workload struct {
	Kind string
	Name string
}

func GetWorkload

func GetWorkload(pod *corev1.Pod) Workload