Function DecodeGlobalTable

internal/pulumi/resources/aws/dynamodb.go:250–284

DecodeGlobalTable decodes a DynamoDB GlobalTable (TableReplicas resource). Produces one replicated-write query per replica region.

(record resources.ResourceRecord, region, inputsJSON string)

// DecodeGlobalTable decodes a DynamoDB GlobalTable (TableReplicas resource).
// Produces one replicated-write query per replica region.
func DecodeGlobalTable(record resources.ResourceRecord, region, inputsJSON string) []resources.DecodedResource {
	isPAY := billingMode(record) == "PAY_PER_REQUEST"
	isIA := tableClass(record) == "STANDARD_IA"

	props := map[string]string{
		"type":        record.Type,
		"billingMode": billingMode(record),
		"tableClass":  tableClass(record),
	}

	replicaRegions := extractReplicas(record)
	if len(replicaRegions) == 0 {
		// No replicas declared — nothing to price.
		return nil
	}

	var results []resources.DecodedResource
	for _, replicaRegion := range replicaRegions {
		replicaWriteGroup := "DDB-ReplicatedWriteUnits"
		if isIA {
			replicaWriteGroup = "DDB-ReplicatedWriteUnitsIA"
		}
		// PAY_PER_REQUEST uses DDB-ReplicatedWriteUnits (on-demand replicated writes).
		if isPAY {
			replicaWriteGroup = "DDB-ReplicatedWriteUnits"
		}
		replicaProps := copyProps(props)
		replicaProps["replicaRegion"] = replicaRegion

		results = append(results, ddbEntry(record, replicaRegion, inputsJSON,
			"Replicated Write ("+replicaRegion+")", "DDB-Operation-ReplicatedWrite",
			map[string]string{"group": replicaWriteGroup, "operation": "CommittedThroughput"}, replicaProps))
	}
	return results
}

// DecodeKinesisStreamingDestination decodes a DynamoDB Kinesis Streaming Destination.
// Produces a single Kinesis data capture query.