index

Documentation

Index

• type ExtInterceptorConfig
• type LogConfigTypeClusterIndex
  • func NewLogConfigTypeLoggieIndex() *LogConfigTypeClusterIndex
  • func (index *LogConfigTypeClusterIndex) DeleteConfig(logConfigKey string) bool
  • func (index *LogConfigTypeClusterIndex) GetAll() *control.PipelineRawConfig
  • func (index *LogConfigTypeClusterIndex) GetAllConfigMap() map[string]*TypeClusterPipeConfig
  • func (index *LogConfigTypeClusterIndex) GetConfig(logConfigKey string) ([]pipeline.ConfigRaw, bool)
  • func (index *LogConfigTypeClusterIndex) SetConfig(logConfigKey string, p []pipeline.ConfigRaw, lgc *v1beta1.LogConfig)
  • func (index *LogConfigTypeClusterIndex) ValidateAndSetConfig(logConfigKey string, p []pipeline.ConfigRaw, lgc *v1beta1.LogConfig) error
• type LogConfigTypeNodeIndex
  • func NewLogConfigTypeNodeIndex() *LogConfigTypeNodeIndex
  • func (index *LogConfigTypeNodeIndex) DeleteConfig(logConfigKey string) bool
  • func (index *LogConfigTypeNodeIndex) GetAll() *control.PipelineRawConfig
  • func (index *LogConfigTypeNodeIndex) GetAllConfigMap() map[string]*TypeNodePipeConfig
  • func (index *LogConfigTypeNodeIndex) GetConfig(logConfigKey string) ([]pipeline.ConfigRaw, bool)
  • func (index *LogConfigTypeNodeIndex) SetConfig(logConfigKey string, p []pipeline.ConfigRaw, lgc *v1beta1.LogConfig)
  • func (index *LogConfigTypeNodeIndex) ValidateAndSetConfig(logConfigKey string, p []pipeline.ConfigRaw, 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) GetAll() *control.PipelineRawConfig
  • func (p *LogConfigTypePodIndex) GetAllConfigMap() map[string]*TypePodPipeConfig
  • func (p *LogConfigTypePodIndex) GetAllGroupByLogConfig() *control.PipelineRawConfig
  • func (p *LogConfigTypePodIndex) GetPipeConfigs(namespace string, podName string, lgcNamespace string, lgcName string) *pipeline.ConfigRaw
  • func (p *LogConfigTypePodIndex) GetPipeConfigsByPod(namespace string, podName string) []pipeline.ConfigRaw
  • func (p *LogConfigTypePodIndex) IsPodExist(namespace string, podName string) bool
  • func (p *LogConfigTypePodIndex) SetConfigs(namespace string, podName string, lgcNamespace string, lgcName string, ...)
  • func (p *LogConfigTypePodIndex) ValidateAndSetConfigs(namespace string, podName string, lgcNamespace string, lgcName string, ...) error
• type TypeClusterPipeConfig
• type TypeNodePipeConfig
• type TypePodPipeConfig

Types

type ExtInterceptorConfig

type ExtInterceptorConfig struct {
	interceptor.ExtensionConfig `yaml:",inline,omitempty"`
	cfg.CommonCfg               `yaml:",inline,omitempty"`
}

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.PipelineRawConfig

func (*LogConfigTypeClusterIndex) GetAllConfigMap

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

func (*LogConfigTypeClusterIndex) GetConfig

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

func (*LogConfigTypeClusterIndex) SetConfig

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

func (*LogConfigTypeClusterIndex) ValidateAndSetConfig

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

type LogConfigTypeNodeIndex

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

func NewLogConfigTypeNodeIndex

func NewLogConfigTypeNodeIndex() *LogConfigTypeNodeIndex

func (*LogConfigTypeNodeIndex) DeleteConfig

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

func (*LogConfigTypeNodeIndex) GetAll

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

func (*LogConfigTypeNodeIndex) GetAllConfigMap

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

func (*LogConfigTypeNodeIndex) GetConfig

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

func (*LogConfigTypeNodeIndex) SetConfig

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

func (*LogConfigTypeNodeIndex) ValidateAndSetConfig

func (index *LogConfigTypeNodeIndex) ValidateAndSetConfig(logConfigKey string, p []pipeline.ConfigRaw, 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) GetAll

func (p *LogConfigTypePodIndex) GetAll() *control.PipelineRawConfig

func (*LogConfigTypePodIndex) GetAllConfigMap

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

func (*LogConfigTypePodIndex) GetAllGroupByLogConfig

func (p *LogConfigTypePodIndex) GetAllGroupByLogConfig() *control.PipelineRawConfig

func (*LogConfigTypePodIndex) GetPipeConfigs

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

func (*LogConfigTypePodIndex) GetPipeConfigsByPod

func (p *LogConfigTypePodIndex) GetPipeConfigsByPod(namespace string, podName string) []pipeline.ConfigRaw

func (*LogConfigTypePodIndex) IsPodExist

func (p *LogConfigTypePodIndex) IsPodExist(namespace string, podName string) bool

func (*LogConfigTypePodIndex) SetConfigs

func (p *LogConfigTypePodIndex) SetConfigs(namespace string, podName string, lgcNamespace string, lgcName string, cfg *pipeline.ConfigRaw, lgc *v1beta1.LogConfig)

func (*LogConfigTypePodIndex) ValidateAndSetConfigs

func (p *LogConfigTypePodIndex) ValidateAndSetConfigs(namespace string, podName string, lgcNamespace string, lgcName string,
	cfg *pipeline.ConfigRaw, lgc *v1beta1.LogConfig) error

type TypeClusterPipeConfig

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

type TypeNodePipeConfig

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

type TypePodPipeConfig

type TypePodPipeConfig struct {
	Raw *pipeline.ConfigRaw
	Lgc *v1beta1.LogConfig
}