external

package

v1.5.0 Latest Latest Go to latest Published: Aug 4, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/loggie-io/loggie

Links

Open Source Insights

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
type DynamicLogIndexer
type PathFieldsPair
- func GetDynamicPaths(pipelineName string, sourceName string) ([]PathFieldsPair, bool)
type PodIndexer

Constants ¶

View Source

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

View Source

const SystemContainerLogsPath = "containerLogs"

Variables ¶

View Source

var (
	Cluster string
)

Functions ¶

func DelDynamicPaths ¶ added in v1.3.0

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 ¶ added in v1.3.0

func InitDynamicLogIndexer()

func InitGlobalPodIndexer ¶

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

func SetDynamicPaths ¶ added in v1.3.0

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 ¶ added in v1.3.0

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 ¶ added in v1.3.0

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

func GetDynamicPaths ¶ added in v1.3.0

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)
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL