processor

Documentation

Index

• Constants
• type ConfigProvider
• type DevNullConfigProvider
  • func (*DevNullConfigProvider) GetConfPath(pod *v1.Pod) string
• type FileBeatConfigProvider
  • func (*FileBeatConfigProvider) GetConfPath(pod *v1.Pod) string
• type KConfig
  • func NewKConfig(logHost string, tplFile string, provider ConfigProvider) *KConfig
  • func (c *KConfig) Process(ctx context.Context, items *entity.ConfigItems, pod *v1.Pod) (err error)
  • func (c *KConfig) Setup() error

Constants

const FilebeatConfPath = "/usr/share/filebeat/prospectors.d"

Types

type ConfigProvider

type ConfigProvider interface {
	GetConfPath(pod *v1.Pod) string
}

type DevNullConfigProvider

type DevNullConfigProvider struct {
}

func (*DevNullConfigProvider) GetConfPath

func (*DevNullConfigProvider) GetConfPath(pod *v1.Pod) string

type FileBeatConfigProvider

type FileBeatConfigProvider struct {
}

func (*FileBeatConfigProvider) GetConfPath

func (*FileBeatConfigProvider) GetConfPath(pod *v1.Pod) string

type KConfig

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

func NewKConfig

func NewKConfig(logHost string, tplFile string, provider ConfigProvider) *KConfig

func (*KConfig) Process

func (c *KConfig) Process(ctx context.Context, items *entity.ConfigItems, pod *v1.Pod) (err error)

func (*KConfig) Setup

func (c *KConfig) Setup() error