input

package

v0.71.0 Latest Latest Go to latest Published: Jan 7, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Details

View Source

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

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

This section is empty.

This section is empty.

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

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

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

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

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

GetPods returns the list of pods managed by the LoggerController.

func (c *LoggerController) Run()

Run starts the logger pods and sends log records.

func (c *LoggerController) Wait()

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

type LoggerControllerConfig struct {
	NumberOfClusters int
	NumberOfLogs     int
}

LoggerControllerConfig holds the configuration for the LoggerController.

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(namespace, podName, container string) Pod

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

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

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