feat: add environment variable support for etcd adapter address and APISIX key prefix

Author: zhu327

internal/adc/client/kind_executor.go

@@ -34,12 +34,30 @@ import (
 )
 
 const (
-	// etcdAdapterAddr is the address for the local etcd adapter
-	etcdAdapterAddr = "127.0.0.1:12379"
-	// apisixKeyPrefix is the prefix for all APISIX resources in etcd
-	apisixKeyPrefix = "/apisix"
+	// Default values for environment variables
+	defaultEtcdAdapterAddr = "127.0.0.1:12379"
+	defaultApisixKeyPrefix = "/apisix"
+
+	// Environment variable names
+	envEtcdAdapterAddr = "ETCD_ADAPTER_ADDR"
+	envApisixKeyPrefix = "APISIX_KEY_PREFIX"
 )
 
+// getConfig returns configuration values from environment variables with defaults
+func getConfig() (etcdAdapterAddr, apisixKeyPrefix string) {
+	etcdAdapterAddr = os.Getenv(envEtcdAdapterAddr)
+	if etcdAdapterAddr == "" {
+		etcdAdapterAddr = defaultEtcdAdapterAddr
+	}
+
+	apisixKeyPrefix = os.Getenv(envApisixKeyPrefix)
+	if apisixKeyPrefix == "" {
+		apisixKeyPrefix = defaultApisixKeyPrefix
+	}
+
+	return
+}
+
 // KindExecutor implements ADCExecutor interface using Kine to sync resources
 type KindExecutor struct {
 	log logr.Logger
@@ -52,6 +70,7 @@ type KindExecutor struct {
 func newEtcdAdapter(log logr.Logger) adapter.Adapter {
 	a := adapter.NewEtcdAdapter(nil)
 
+	etcdAdapterAddr, _ := getConfig()
 	ln, err := net.Listen("tcp", etcdAdapterAddr)
 	if err != nil {
 		panic(err)
@@ -200,6 +219,7 @@ func (e *KindExecutor) applyCacheChange(event kine.Event) error {
 // convertToAdapterEvent converts a kine event to an adapter event
 func (e *KindExecutor) convertToAdapterEvent(event kine.Event) (*adapter.Event, error) {
 	// Build key with /apisix prefix
+	_, apisixKeyPrefix := getConfig()
 	key := fmt.Sprintf("%s/%s/%s", apisixKeyPrefix, event.ResourceType, event.ResourceID)
 
 	adapterEvent := &adapter.Event{