index

Documentation

Index

• Constants
• type LogConfigTypeClusterIndex
  • func NewLogConfigTypeLoggieIndex() *LogConfigTypeClusterIndex
  • func (index *LogConfigTypeClusterIndex) DeleteConfig(logConfigKey string) bool
  • func (index *LogConfigTypeClusterIndex) GetAll() *control.PipelineConfig
  • func (index *LogConfigTypeClusterIndex) GetAllConfigMap() map[string]*TypeClusterPipeConfig
  • func (index *LogConfigTypeClusterIndex) GetConfig(logConfigKey string) ([]pipeline.Config, bool)
  • func (index *LogConfigTypeClusterIndex) SetConfig(logConfigKey string, p []pipeline.Config, lgc *v1beta1.LogConfig)
  • func (index *LogConfigTypeClusterIndex) ValidateAndSetConfig(logConfigKey string, p []pipeline.Config, lgc *v1beta1.LogConfig) error
• type LogConfigTypeNodeIndex
  • func NewLogConfigTypeNodeIndex() *LogConfigTypeNodeIndex
  • func (index *LogConfigTypeNodeIndex) DeleteConfig(logConfigKey string) bool
  • func (index *LogConfigTypeNodeIndex) GetAll() *control.PipelineConfig
  • func (index *LogConfigTypeNodeIndex) GetAllConfigMap() map[string]*TypeNodePipeConfig
  • func (index *LogConfigTypeNodeIndex) GetConfig(logConfigKey string) ([]pipeline.Config, bool)
  • func (index *LogConfigTypeNodeIndex) SetConfig(logConfigKey string, p []pipeline.Config, lgc *v1beta1.LogConfig)
  • func (index *LogConfigTypeNodeIndex) ValidateAndSetConfig(logConfigKey string, p []pipeline.Config, lgc *v1beta1.LogConfig) error
• type LogConfigTypePodIndex
  • func NewLogConfigTypePodIndex() *LogConfigTypePodIndex
  • func (p *LogConfigTypePodIndex) DeletePipeConfigsByLogConfigKey(lgcKey string) bool
  • func (p *LogConfigTypePodIndex) DeletePipeConfigsByPodKey(podKey string) bool
  • func (p *LogConfigTypePodIndex) GetAllConfigMap() map[string]*TypePodPipeConfig
  • func (p *LogConfigTypePodIndex) GetAllGroupByLogConfig(dynamicContainerLog bool) *control.PipelineConfig
  • func (p *LogConfigTypePodIndex) GetPipeConfigs(namespace string, podName string, lgcNamespace string, lgcName string) *pipeline.Config
  • func (p *LogConfigTypePodIndex) IgnoredPodKeyAndLgcKeys() map[string]struct{}
  • func (p *LogConfigTypePodIndex) IsPodUpdated(pod *corev1.Pod) bool
  • func (p *LogConfigTypePodIndex) SetConfigs(pod *corev1.Pod, lgcName string, cfg *pipeline.Config, lgc *v1beta1.LogConfig)
• type TypeClusterPipeConfig
• type TypeNodePipeConfig
• type TypePodPipeConfig

Constants

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

	K8sFieldsKey = "@privateK8sFields"
)

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

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

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

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

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

IgnoredPodKeyAndLgcKeys return map which key is podKey/overrideLgcKey

func (*LogConfigTypePodIndex) IsPodUpdated

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

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

type TypeNodePipeConfig

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

type TypePodPipeConfig

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
}