117
118
if !applied {
119
>
// Classify the two CAS result rows by their "type" column. This is needed because
nexus_endpoint_store.go
120
>
// Cassandra returns rows in clustering key order while ScyllaDB returns them in
121
>
// statement order.
122
>
var previousPartitionStatus, previousEndpoint map[string]any
123
>
rowType, err := getTypedFieldFromRow[int]("type", row1)
124
>
if err != nil {
125
return fmt.Errorf("CreateOrUpdateNexusEndpoint: error reading type from CAS result row: %w", err)
126
}
128
>
case rowTypePartitionStatus:
129
>
previousPartitionStatus, previousEndpoint = row1, row2
130
case rowTypeNexusEndpoint:
131
previousPartitionStatus, previousEndpoint = row2, row1