helper

Mar 7, 2023

Changes in this version

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

Nov 2, 2022

Changes in this version

+ const MatchAllToken

+ func GenTypePodSourceName(podName string, containerName string, sourceName string) string

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

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

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

+ func GetTypePodOriginSourceName(podSourceName string) string

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

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

+ type Workload struct

+ Kind string

+ Name string

+ func GetWorkload(pod *corev1.Pod) Workload

Aug 26, 2022

Changes in this version

+ func PathEqual(p1 string, p2 string) bool

Jun 16, 2022

Changes in this version

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

Mar 9, 2022

Changes in this version

+ func ExtractContainerId(containerID string) string

+ func GenContainerdStdoutLog(podLogDirPrefix string, namespace string, podName string, podUID string, ...) []string

+ func GenDockerStdoutLog(dockerDataRoot string, containerId string) 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 GetPodRelatedClusterLogConfigs(pod *corev1.Pod, clgcLister logconfigLister.ClusterLogConfigLister) ([]*logconfigv1beta1.ClusterLogConfig, error)

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

+ func IsPodReady(pod *corev1.Pod) bool

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

+ func MetaNamespaceKey(namespace string, name string) string

+ func PathsInNode(kubeletRootDir string, paths []string, pod *corev1.Pod, containerName string) ([]string, error)

+ func ToPipeline(lgc *logconfigv1beta1.LogConfig, sinkLister v1beta1.SinkLister, ...) (*control.PipelineRawConfig, error)

+ func ToPipelineInterceptor(interceptorRef string, interceptorLister v1beta1.InterceptorLister) ([]cfg.CommonCfg, error)

+ func ToPipelineSink(sinkRef string, sinkLister v1beta1.SinkLister) (cfg.CommonCfg, error)

+ func ToPipelineSources(sources string) ([]cfg.CommonCfg, error)

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