INNER CODE UNIT · Go

NewDynamicConfigDatabaseClient

istio-ecosystem/admiral · admiral/pkg/clusters/admiralDatabaseClient.go:166

func NewDynamicConfigDatabaseClient(path string, dynamoClientInitFunc func(role string, region string) (*DynamoClient, error)) (*DynamicConfigDatabaseClient, error) {
	var dynamicConfigClient = DynamicConfigDatabaseClient{}

	admiralConfig, err := ReadDynamoConfigForDynamoDB(path)
	if err != nil {
		return nil, fmt.Errorf("task=%v, error unmarshalling admiral config file, err: %v", common.DynamicConfigUpdate, err)
	}

	dynamicConfigClient.database = &admiralConfig.DynamicConfigDatabase
	dynamicConfigClient.database.TableName = common.GetAdmiralParams().DynamicConfigDynamoDBTableName
	dynamicConfigClient.dynamoClient, err = dynamoClientInitFunc(
		admiralConfig.WorkloadDatabase.Role,
		admiralConfig.WorkloadDatabase.Region,
	)
	if err != nil {
		return &dynamicConfigClient, fmt.Errorf("task=%v, unable to instantiate dynamo client for DynamicConfig, err: %v", common.DynamicConfigUpdate, err)
	}
	return &dynamicConfigClient, nil

View source record →