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 ¶
SetupWithManager sets up the controller with the Manager.
Click to show internal directories.
Click to hide internal directories.