247
ctx context.Context,
248
request *p.InternalRenameNamespaceRequest,
250
>
// Step 1.
251
>
if updateErr := m.session.Query(templateUpdateNamespaceByIdQuery,
252
>
request.Name,
253
>
request.Id,
254
>
).WithContext(ctx).Exec(); updateErr != nil {
255
return gocql.ConvertError("RenameNamespace", updateErr)
256
}
257
258
// Step 2.
259
>
batch := m.session.NewBatch(gocql.LoggedBatch).WithContext(ctx)
metadata_store.go
260
>
batch.Query(templateCreateNamespaceByNameQueryWithinBatchV2,
261
>
constNamespacePartition,
262
>
request.Id,
263
>
request.Name,
264
>
request.Namespace.Data,
265
>
request.Namespace.EncodingType.String(),
266
>
request.NotificationVersion,
267
>
request.IsGlobal,
268
>
)
269
>
batch.Query(templateDeleteNamespaceByNameQueryV2,
270
>
constNamespacePartition,
271
>
request.PreviousName,
272
>
)
273
>
m.updateMetadataBatch(batch, request.NotificationVersion)
274
>
275
>
previous := make(map[string]any)
276
>
applied, iter, err := m.session.MapExecuteBatchCAS(batch, previous)
277
>
if err != nil {
278
return gocql.ConvertError("RenameNamespace", err)
279
}
281
283
return serviceerror.NewUnavailable("RenameNamespace operation failed because of conditional failure.")
284
}