453
func (m *MetadataStore) GetMetadata(
454
ctx context.Context,
456
>
var notificationVersion int64
457
>
query := m.session.Query(templateGetMetadataQueryV2, constNamespacePartition, namespaceMetadataRecordName).WithContext(ctx)
458
>
err := query.Scan(¬ificationVersion)
459
>
if err != nil {
460
>
if gocql.IsNotFoundError(err) {
461
>
// this error can be thrown in the very beginning,
462
>
// i.e. when namespaces is initialized
463
>
return &p.GetMetadataResponse{NotificationVersion: 0}, nil
464
>
}
465
return nil, err
466
}