input

Documentation

Index

• Constants
• type LoggerController
  • func NewLoggerController(outputPlugin plugin.OutputPlugin, cfg LoggerControllerConfig) LoggerController
  • func (c *LoggerController) GetPods() []Pod
  • func (c *LoggerController) Run()
  • func (c *LoggerController) Wait()
• type LoggerControllerConfig
• type Pod
  • func NewPod(namespace, podName, container string) Pod
• type PodOutput

Constants

const NamespacePrefix = "shoot--logging--test-"

NamespacePrefix is the prefix used for the namespaces created by the logger controller.

Types

type LoggerController

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

LoggerController is responsible for managing the logger pods and sending log records.

func NewLoggerController

func NewLoggerController(outputPlugin plugin.OutputPlugin, cfg LoggerControllerConfig) LoggerController

NewLoggerController creates a new instance of LoggerController with the given plugin and configuration.

func (*LoggerController) GetPods

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

GetPods returns the list of pods managed by the LoggerController.

func (*LoggerController) Run

func (c *LoggerController) Run()

Run starts the logger pods and sends log records.

func (*LoggerController) Wait

func (c *LoggerController) Wait()

Wait waits for all logger pods to finish sending log records.

type LoggerControllerConfig

type LoggerControllerConfig struct {
	NumberOfClusters int
	NumberOfLogs     int
}

LoggerControllerConfig holds the configuration for the LoggerController.

type Pod

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

Pod is an interface that defines the methods for generating log records and getting output information.

func NewPod

func NewPod(namespace, podName, container string) Pod

NewPod creates a new Pod instance with the given namespace, pod name, and container name.

type PodOutput

type PodOutput interface {
	GetLabelSet() model.LabelSet
	GetGeneratedLogsCount() int
}

PodOutput is an interface that defines the methods for getting label set and generated logs count.