components

type Builder[ComponentConfigType any] []ParserOption[ComponentConfigType]

type ComponentsPortsUrlPaths map[string][]PortUrlPaths

type Defaulter[ComponentConfigType any] func(logger *zap.Logger, defaultAddr string, defaultPort int32, config ComponentConfigType) (map[string]any, error)

type EnvVarGenerator[ComponentConfigType any] func(logger *zap.Logger, config ComponentConfigType) ([]corev1.EnvVar, error)

type GenericParser[T any] struct {
	// contains filtered or unexported fields
}

type MultiPortBuilder[ComponentConfigType any] []Builder[ComponentConfigType]

type MultiPortOption func(parser *MultiPortReceiver)

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

type MultiProtocolEndpointConfig struct {
	Protocols map[string]*SingleEndpointConfig `mapstructure:"protocols"`
}

type Parser interface {
	// GetDefaultConfig returns a config with set default values.
	// NOTE: Config merging must be done by the caller if desired.
	GetDefaultConfig(logger *zap.Logger, config any) (any, error)

	// Ports returns the service ports parsed based on the component's configuration where name is the component's name
	// of the form "name" or "type/name"
	Ports(logger *zap.Logger, name string, config any) ([]corev1.ServicePort, error)

	// GetRBACRules returns the rbac rules for this component
	GetRBACRules(logger *zap.Logger, config any) ([]rbacv1.PolicyRule, error)

	// GetLivenessProbe returns a liveness probe set for the collector
	GetLivenessProbe(logger *zap.Logger, config any) (*corev1.Probe, error)

	// GetEnvironmentVariables returns a list of environment variables for the collector
	GetEnvironmentVariables(logger *zap.Logger, config any) ([]corev1.EnvVar, error)

	// GetReadinessProbe returns a readiness probe set for the collector
	GetReadinessProbe(logger *zap.Logger, config any) (*corev1.Probe, error)

	// ParserType returns the type of this parser
	ParserType() string

	// ParserName is an internal name for the parser
	ParserName() string

	// PortsWithUrlPaths returns the service ports + URL paths parsed based on the receiver's configuration
	PortsWithUrlPaths(logger *zap.Logger, name string, config any) ([]PortUrlPaths, error)
}

type ParserOption[ComponentConfigType any] func(*Settings[ComponentConfigType])

type ParserRetriever func(string) Parser

type PortParser[ComponentConfigType any] func(logger *zap.Logger, name string, defaultPort *corev1.ServicePort, config ComponentConfigType) ([]corev1.ServicePort, error)

type PortRetriever interface {
	GetPortNum() (int32, error)
	//nolint:inamedparam
	GetPortNumOrDefault(*zap.Logger, int32) int32
}

type PortUrlPaths struct {
	Port     corev1.ServicePort
	UrlPaths []string
}

type ProbeGenerator[ComponentConfigType any] func(logger *zap.Logger, config ComponentConfigType) (*corev1.Probe, error)

type RBACRuleGenerator[ComponentConfigType any] func(logger *zap.Logger, config ComponentConfigType) ([]rbacv1.PolicyRule, error)

type Settings[ComponentConfigType any] struct {
	// contains filtered or unexported fields
}

type SingleEndpointConfig struct {
	Endpoint      string `mapstructure:"endpoint,omitempty" yaml:"endpoint,omitempty"`
	ListenAddress string `mapstructure:"listen_address,omitempty" yaml:"listen_address,omitempty"`
}