usp_k8s_pods

package
v1.22.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 21, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type K8sEntity

type K8sEntity struct {
	Namespace     string `json:"namespace" msgpack:"namespace"`
	PodName       string `json:"pod_name" msgpack:"pod_name"`
	PodID         string `json:"pod_id" msgpack:"pod_id"`
	ContainerName string `json:"container_name" msgpack:"container_name"`
}

type K8sLogLine

type K8sLogLine struct {
	Entity K8sEntity `json:"entity" msgpack:"entity"`
	Line   string    `json:"line" msgpack:"line"`
}

type K8sLogProcessor

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

func NewK8sLogProcessor

func NewK8sLogProcessor(root string, cOpt uspclient.ClientOptions, rtOptions runtimeOptions) (*K8sLogProcessor, error)

func (*K8sLogProcessor) Close

func (klp *K8sLogProcessor) Close() error

func (*K8sLogProcessor) Lines

func (klp *K8sLogProcessor) Lines() chan K8sLogLine

type K8sPodsAdapter

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

func NewK8sPodsAdapter

func NewK8sPodsAdapter(conf K8sPodsConfig) (*K8sPodsAdapter, chan struct{}, error)

func (*K8sPodsAdapter) Close

func (a *K8sPodsAdapter) Close() error

type K8sPodsConfig

type K8sPodsConfig struct {
	ClientOptions   uspclient.ClientOptions `json:"client_options" yaml:"client_options"`
	WriteTimeoutSec uint64                  `json:"write_timeout_sec,omitempty" yaml:"write_timeout_sec,omitempty"`
	Root            string                  `json:"root" yaml:"root"`
	IncludePodsRE   string                  `json:"include_pods_re" yaml:"include_pods_re"`
	ExcludePodsRE   string                  `json:"exclude_pods_re" yaml:"exclude_pods_re"`
}

func (*K8sPodsConfig) Validate

func (c *K8sPodsConfig) Validate() error

Jump to

Keyboard shortcuts

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