dataplane

package
v2.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 9, 2026 License: Apache-2.0 Imports: 43 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// ControllerName is the name used for logging and event recording.
	ControllerName = "keg-dataplane"

	// DefaultKafkaPort is the default port exposed by the Kafka listener.
	DefaultKafkaPort int32 = 9092

	// DefaultHealthPort is the default port used for the keg health endpoint.
	DefaultHealthPort int32 = 8080

	// KonnectCertVolumeName is the name of the volume that holds the Konnect mTLS certificate.
	KonnectCertVolumeName = "konnect-cert"

	// KonnectCertMountPath is the path where the Konnect certificate Secret is mounted in the keg container.
	KonnectCertMountPath = "/var/konnect-client-certificate/"
)
View Source
const (
	// EnvKonnectRegion is the keg environment variable for the Konnect region.
	EnvKonnectRegion = "KONG_KONNECT_REGION"
	// EnvKonnectGatewayClusterID is the keg environment variable for the Konnect gateway cluster ID.
	EnvKonnectGatewayClusterID = "KONG_KONNECT_GATEWAY_CLUSTER_ID"
	// EnvKonnectClientCertPath is the keg environment variable for the Konnect mTLS client certificate path.
	EnvKonnectClientCertPath = "KONG_KONNECT_CLIENT_CERT_PATH"
	// EnvKonnectClientKeyPath is the keg environment variable for the Konnect mTLS client key path.
	EnvKonnectClientKeyPath = "KONG_KONNECT_CLIENT_KEY_PATH"
	// EnvKonnectDomain is the keg environment variable for the Konnect domain override.
	EnvKonnectDomain = "KONG_KONNECT_DOMAIN"
	// EnvKonnectAPIRequestTimeout is the keg environment variable for the Konnect API request timeout.
	EnvKonnectAPIRequestTimeout = "KONG_KONNECT_API_REQUEST_TIMEOUT"
	// EnvKonnectInsecureSkipVerify is the keg environment variable to skip TLS verification.
	// For testing only.
	EnvKonnectInsecureSkipVerify = "KONG_KONNECT_INSECURE_SKIP_VERIFY"

	// EnvConfigPollInterval is the keg environment variable for the config poll interval.
	EnvConfigPollInterval = "KEG__CONFIG_POLL_INTERVAL"
	// EnvEnableDebugEndpoints is the keg environment variable to enable debug endpoints.
	EnvEnableDebugEndpoints = "KEG__ENABLE_DEBUG_ENDPOINTS"

	// EnvObsLogFlags is the keg environment variable for log level flags.
	EnvObsLogFlags = "KEG__OBSERVABILITY__LOG_FLAGS"
	// EnvObsLogFormat is the keg environment variable for the log output format.
	EnvObsLogFormat = "KEG__OBSERVABILITY__LOG_FORMAT"
	// EnvObsMetricsRollupAllowMap is the keg environment variable for the metrics rollup allow map.
	EnvObsMetricsRollupAllowMap = "KEG__OBSERVABILITY__METRICS_ROLLUP_ALLOW_MAP"
	// EnvObsPolicyErrorsInfoLogInterval is the keg environment variable for the policy errors info log interval.
	EnvObsPolicyErrorsInfoLogInterval = "KEG__OBSERVABILITY__POLICY_ERRORS_INFO_LOG_INTERVAL"

	// EnvRuntimeHealthAddr is the keg environment variable for the health listener address and port.
	EnvRuntimeHealthAddr = "KEG__RUNTIME__HEALTH_LISTENER_ADDRESS_PORT"
	// EnvRuntimeDrainDuration is the keg environment variable for the drain duration.
	EnvRuntimeDrainDuration = "KEG__RUNTIME__DRAIN_DURATION"
	// EnvRuntimeShutdownTimeout is the keg environment variable for the graceful shutdown timeout.
	EnvRuntimeShutdownTimeout = "KEG__RUNTIME__SHUTDOWN_TIMEOUT"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Reconciler

type Reconciler struct {
	client.Client

	// LoggingMode controls the format of log output.
	LoggingMode logging.Mode

	ClusterCASecretName      string
	ClusterCASecretNamespace string
	SecretLabelSelector      string
	CertTTL                  time.Duration

	// TypeConverter is injected via the TypeConverterProvider at controller
	// registration time.  It is used for both diff-before-apply and
	// structured-merge-diff based PodTemplateSpec merging.
	TypeConverter managedfields.TypeConverter
	// contains filtered or unexported fields
}

Reconciler reconciles a KegDataPlane object.

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, egdp *eventgatewayv1alpha1.KegDataPlane) (res ctrl.Result, err error)

Reconcile moves the current state of a KegDataPlane toward the desired state.

func (*Reconciler) SetupWithManager

func (r *Reconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL