input

Documentation

Index

• type LoggerController
  • func NewLoggerController(plugin valiplugin.Vali, cfg LoggerControllerConfig) LoggerController
  • func (c *LoggerController) GetPods() []Pod
  • func (c *LoggerController) Run()
  • func (c *LoggerController) Wait()
• type LoggerControllerConfig
• type Pod
  • func NewOperatorPod(namespace, podName, container string) Pod
  • func NewUserPod(namespace, podName, container string) Pod
• type PodOutput

Types

type LoggerController

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

func NewLoggerController

func NewLoggerController(plugin valiplugin.Vali, cfg LoggerControllerConfig) LoggerController

func (*LoggerController) GetPods

func (c *LoggerController) GetPods() []Pod

func (*LoggerController) Run

func (c *LoggerController) Run()

func (*LoggerController) Wait

func (c *LoggerController) Wait()

type LoggerControllerConfig

type LoggerControllerConfig struct {
	NumberOfClusters        int
	NumberOfOperatorLoggers int
	NumberOfUserLoggers     int
	NumberOfLogs            int
}

type Pod

type Pod interface {
	GenerateLogRecord() map[interface{}]interface{}
	GetOutput() PodOutput
}

func NewOperatorPod

func NewOperatorPod(namespace, podName, container string) Pod

NewOperatorPod creates new operator Pod

func NewUserPod

func NewUserPod(namespace, podName, container string) Pod

NewPod creates new Pod

type PodOutput

type PodOutput interface {
	GetLabelSet() model.LabelSet
	GetTenants() []string
	GetGeneratedLogsCount() int
}