ensure ddb kvstore can use client_name as well (kvstore.name.ddb.clie…

…nt_name)

pkg/kvstore/configurable.go

@@ -18,13 +18,18 @@ const (
 	TypeRedis    = "redis"
 )
 
+type DdbSettings struct {
+	ClientName string `cfg:"client_name" default:"default"`
+}
+
 type ChainConfiguration struct {
 	Project             string                `cfg:"project"`
 	Family              string                `cfg:"family"`
 	Group               string                `cfg:"group"`
 	Application         string                `cfg:"application"`
 	Type                string                `cfg:"type" default:"chain" validate:"eq=chain"`
 	Elements            []string              `cfg:"elements" validate:"min=1"`
+	Ddb                 DdbSettings           `cfg:"ddb"`
 	Ttl                 time.Duration         `cfg:"ttl"`
 	BatchSize           int                   `cfg:"batch_size" default:"100" validate:"min=1"`
 	MissingCacheEnabled bool                  `cfg:"missing_cache_enabled" default:"false"`
@@ -80,6 +85,7 @@ func newKvStoreChainFromConfig[T any](ctx context.Context, config cfg.Config, lo
 			Group:       configuration.Group,
 			Application: configuration.Application,
 		},
+		DdbSettings:    configuration.Ddb,
 		Name:           name,
 		Ttl:            configuration.Ttl,
 		BatchSize:      configuration.BatchSize,

pkg/kvstore/ddb.go

@@ -40,6 +40,7 @@ func NewDdbKvStore[T any](ctx context.Context, config cfg.Config, logger log.Log
 	name := DdbBaseName(settings)
 
 	repository, err := ddb.NewRepository(ctx, config, logger, &ddb.Settings{
+		ClientName: settings.DdbSettings.ClientName,
 		ModelId: mdl.ModelId{
 			Project:     settings.Project,
 			Environment: settings.Environment,

pkg/kvstore/kvstore.go

@@ -13,6 +13,7 @@ import (
 
 type Settings struct {
 	cfg.AppId
+	DdbSettings    DdbSettings
 	Name           string
 	Ttl            time.Duration
 	BatchSize      int