index

package

v1.5.0 Latest Latest Go to latest Published: Aug 4, 2023 License: Apache-2.0 Imports: 10 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
type LogConfigTypeClusterIndex
- func NewLogConfigTypeLoggieIndex() *LogConfigTypeClusterIndex
type LogConfigTypeNodeIndex
- func NewLogConfigTypeNodeIndex() *LogConfigTypeNodeIndex
type LogConfigTypePodIndex
- func NewLogConfigTypePodIndex() *LogConfigTypePodIndex
type TypeClusterPipeConfig
type TypeNodePipeConfig
type TypePodPipeConfig

Constants ¶

View Source

const (
	OverrideLogConfigAnnotation        = "logconfig.loggie.io/override"
	OverrideClusterLogConfigAnnotation = "clusterlogconfig.loggie.io/override"

	K8sFieldsKey = "@privateK8sFields"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type LogConfigTypeClusterIndex ¶

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

func NewLogConfigTypeLoggieIndex ¶

func NewLogConfigTypeLoggieIndex() *LogConfigTypeClusterIndex

func (*LogConfigTypeClusterIndex) DeleteConfig ¶

func (index *LogConfigTypeClusterIndex) DeleteConfig(logConfigKey string) bool

func (*LogConfigTypeClusterIndex) GetAll ¶

func (index *LogConfigTypeClusterIndex) GetAll() *control.PipelineConfig

func (*LogConfigTypeClusterIndex) GetAllConfigMap ¶ added in v1.1.0

func (index *LogConfigTypeClusterIndex) GetAllConfigMap() map[string]*TypeClusterPipeConfig

func (*LogConfigTypeClusterIndex) GetConfig ¶

func (index *LogConfigTypeClusterIndex) GetConfig(logConfigKey string) ([]pipeline.Config, bool)

func (*LogConfigTypeClusterIndex) SetConfig ¶

func (index *LogConfigTypeClusterIndex) SetConfig(logConfigKey string, p []pipeline.Config, lgc *v1beta1.LogConfig)

func (*LogConfigTypeClusterIndex) ValidateAndSetConfig ¶

func (index *LogConfigTypeClusterIndex) ValidateAndSetConfig(logConfigKey string, p []pipeline.Config, lgc *v1beta1.LogConfig) error

type LogConfigTypeNodeIndex ¶

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

LogConfigTypeNodeIndex stores logConfigKey to pipeline configurations mapping cache for type: Node and type: Vm

func NewLogConfigTypeNodeIndex ¶

func NewLogConfigTypeNodeIndex() *LogConfigTypeNodeIndex

func (*LogConfigTypeNodeIndex) DeleteConfig ¶

func (index *LogConfigTypeNodeIndex) DeleteConfig(logConfigKey string) bool

func (*LogConfigTypeNodeIndex) GetAll ¶

func (index *LogConfigTypeNodeIndex) GetAll() *control.PipelineConfig

func (*LogConfigTypeNodeIndex) GetAllConfigMap ¶ added in v1.1.0

func (index *LogConfigTypeNodeIndex) GetAllConfigMap() map[string]*TypeNodePipeConfig

func (*LogConfigTypeNodeIndex) GetConfig ¶

func (index *LogConfigTypeNodeIndex) GetConfig(logConfigKey string) ([]pipeline.Config, bool)

func (*LogConfigTypeNodeIndex) SetConfig ¶

func (index *LogConfigTypeNodeIndex) SetConfig(logConfigKey string, p []pipeline.Config, lgc *v1beta1.LogConfig)

func (*LogConfigTypeNodeIndex) ValidateAndSetConfig ¶

func (index *LogConfigTypeNodeIndex) ValidateAndSetConfig(logConfigKey string, p []pipeline.Config, lgc *v1beta1.LogConfig) error

type LogConfigTypePodIndex ¶

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

func NewLogConfigTypePodIndex ¶

func NewLogConfigTypePodIndex() *LogConfigTypePodIndex

func (*LogConfigTypePodIndex) DeletePipeConfigsByLogConfigKey ¶

func (p *LogConfigTypePodIndex) DeletePipeConfigsByLogConfigKey(lgcKey string) bool

func (*LogConfigTypePodIndex) DeletePipeConfigsByPodKey ¶

func (p *LogConfigTypePodIndex) DeletePipeConfigsByPodKey(podKey string) bool

func (*LogConfigTypePodIndex) GetAllConfigMap ¶ added in v1.1.0

func (p *LogConfigTypePodIndex) GetAllConfigMap() map[string]*TypePodPipeConfig

func (*LogConfigTypePodIndex) GetAllGroupByLogConfig ¶

func (p *LogConfigTypePodIndex) GetAllGroupByLogConfig(dynamicContainerLog bool) *control.PipelineConfig

func (*LogConfigTypePodIndex) GetPipeConfigs ¶

func (p *LogConfigTypePodIndex) GetPipeConfigs(namespace string, podName string, lgcNamespace string, lgcName string) *pipeline.Config

func (*LogConfigTypePodIndex) IgnoredPodKeyAndLgcKeys ¶ added in v1.3.0

func (p *LogConfigTypePodIndex) IgnoredPodKeyAndLgcKeys() map[string]struct{}

IgnoredPodKeyAndLgcKeys return map which key is podKey/overrideLgcKey

func (*LogConfigTypePodIndex) IsPodUpdated ¶ added in v1.3.0

func (p *LogConfigTypePodIndex) IsPodUpdated(pod *corev1.Pod) bool

IsPodUpdated check weather pod is in the index or pod containers has changed.

func (*LogConfigTypePodIndex) SetConfigs ¶

func (p *LogConfigTypePodIndex) SetConfigs(pod *corev1.Pod, lgcName string, cfg *pipeline.Config, lgc *v1beta1.LogConfig)

type TypeClusterPipeConfig ¶ added in v1.1.0

type TypeClusterPipeConfig struct {
	Raw []pipeline.Config
	Lgc *v1beta1.LogConfig
}

type TypeNodePipeConfig ¶ added in v1.1.0

type TypeNodePipeConfig struct {
	Raw []pipeline.Config
	Lgc *v1beta1.LogConfig
}

type TypePodPipeConfig ¶ added in v1.1.0

type TypePodPipeConfig struct {
	Raw *pipeline.Config
	Lgc *v1beta1.LogConfig
	// ContainerIds is used to check whether containers in the Pod have been restarted or crashed.
	// If the containerId changes, the log path needs to be generated again
	ContainerIds sets.String
}

Source Files ¶

View all Source files

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