external

Documentation

Index

• Constants
• Variables
• func DelDynamicPaths(pipelineName string)
• func GetByContainerId(containerId string) *corev1.Pod
• func GetByPodNamespaceName(namespace string, name string) *corev1.Pod
• func GetByPodUid(uid string) *corev1.Pod
• func InitDynamicLogIndexer()
• func InitGlobalPodIndexer(podIndexer cache.Indexer, podLister v1.PodLister)
• func SetDynamicPaths(pipelineName string, sourceName string, pair []PathFieldsPair)
• type CustomPodIndexer
  • func (c *CustomPodIndexer) GetByContainerId(containerId string) (*corev1.Pod, error)
  • func (c *CustomPodIndexer) GetByNamespaceName(namespace string, name string) (*corev1.Pod, error)
  • func (c *CustomPodIndexer) GetByUid(uid string) (*corev1.Pod, error)
• type DynamicLogIndexer
• type PathFieldsPair
  • func GetDynamicPaths(pipelineName string, sourceName string) ([]PathFieldsPair, bool)
• type PodIndexer

Constants

const (
	IndexPodUid      = "pod.uid"
	IndexNamespace   = "namespace"
	IndexPodName     = "pod.name"
	IndexContainerId = "container.id"
)

const SystemContainerLogsPath = "containerLogs"

Variables

var (
	Cluster string
)

Functions

func DelDynamicPaths

func DelDynamicPaths(pipelineName string)

func GetByContainerId

func GetByContainerId(containerId string) *corev1.Pod

func GetByPodNamespaceName

func GetByPodNamespaceName(namespace string, name string) *corev1.Pod

func GetByPodUid

func GetByPodUid(uid string) *corev1.Pod

func InitDynamicLogIndexer

func InitDynamicLogIndexer()

func InitGlobalPodIndexer

func InitGlobalPodIndexer(podIndexer cache.Indexer, podLister v1.PodLister)

func SetDynamicPaths

func SetDynamicPaths(pipelineName string, sourceName string, pair []PathFieldsPair)

Types

type CustomPodIndexer

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

func (*CustomPodIndexer) GetByContainerId

func (c *CustomPodIndexer) GetByContainerId(containerId string) (*corev1.Pod, error)

func (*CustomPodIndexer) GetByNamespaceName

func (c *CustomPodIndexer) GetByNamespaceName(namespace string, name string) (*corev1.Pod, error)

func (*CustomPodIndexer) GetByUid

func (c *CustomPodIndexer) GetByUid(uid string) (*corev1.Pod, error)

type DynamicLogIndexer

type DynamicLogIndexer struct {
	PipelineSourceToPaths map[string][]PathFieldsPair // key: (pipelineName/sourceName), value: file source paths
	PipelineToSource      map[string]sets.String      // key: pipelineName, value: sourceName
	// contains filtered or unexported fields
}

DynamicLogIndexer store all paths corresponding to pipeline/source and associated fields.

type PathFieldsPair

type PathFieldsPair struct {
	Paths  []string
	Fields map[string]interface{}
}

func GetDynamicPaths

func GetDynamicPaths(pipelineName string, sourceName string) ([]PathFieldsPair, bool)

type PodIndexer

type PodIndexer interface {
	GetByNamespaceName(namespace string, name string) (*corev1.Pod, error)
	GetByUid(uid string) (*corev1.Pod, error)
	GetByContainerId(containerId string) (*corev1.Pod, error)
}