chore: upload --0.3.0 schema update script

Signed-off-by: usamoi <[email protected]>

src/datatype/binary_bvecf32.rs

@@ -7,7 +7,7 @@ use pgrx::datum::Internal;
 use pgrx::datum::IntoDatum;
 use pgrx::pg_sys::Oid;
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_bvecf32_send(vector: BVecf32Input<'_>) -> Bytea {
     use pgrx::pg_sys::StringInfoData;
     unsafe {
@@ -21,8 +21,9 @@ fn _vectors_bvecf32_send(vector: BVecf32Input<'_>) -> Bytea {
     }
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
-fn _vectors_bvecf32_recv(internal: Internal, _oid: Oid, _typmod: i32) -> BVecf32Output {
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
+fn _vectors_bvecf32_recv(internal: Internal, oid: Oid, typmod: i32) -> BVecf32Output {
+    let _ = (oid, typmod);
     use pgrx::pg_sys::StringInfo;
     unsafe {
         let buf: StringInfo = internal.into_datum().unwrap().cast_mut_ptr();

src/datatype/binary_svecf32.rs

@@ -8,7 +8,7 @@ use pgrx::datum::IntoDatum;
 use pgrx::pg_sys::Oid;
 use std::ffi::c_char;
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_svecf32_send(vector: SVecf32Input<'_>) -> Bytea {
     use pgrx::pg_sys::StringInfoData;
     unsafe {
@@ -27,8 +27,9 @@ fn _vectors_svecf32_send(vector: SVecf32Input<'_>) -> Bytea {
     }
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
-fn _vectors_svecf32_recv(internal: Internal, _oid: Oid, _typmod: i32) -> SVecf32Output {
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
+fn _vectors_svecf32_recv(internal: Internal, oid: Oid, typmod: i32) -> SVecf32Output {
+    let _ = (oid, typmod);
     use pgrx::pg_sys::StringInfo;
     unsafe {
         let buf: StringInfo = internal.into_datum().unwrap().cast_mut_ptr();

src/datatype/binary_vecf16.rs

@@ -7,7 +7,7 @@ use pgrx::datum::IntoDatum;
 use pgrx::pg_sys::Oid;
 use std::ffi::c_char;
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_vecf16_send(vector: Vecf16Input<'_>) -> Bytea {
     use pgrx::pg_sys::StringInfoData;
     unsafe {
@@ -21,8 +21,9 @@ fn _vectors_vecf16_send(vector: Vecf16Input<'_>) -> Bytea {
     }
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
-fn _vectors_vecf16_recv(internal: Internal, _oid: Oid, _typmod: i32) -> Vecf16Output {
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
+fn _vectors_vecf16_recv(internal: Internal, oid: Oid, typmod: i32) -> Vecf16Output {
+    let _ = (oid, typmod);
     use pgrx::pg_sys::StringInfo;
     unsafe {
         let buf: StringInfo = internal.into_datum().unwrap().cast_mut_ptr();

src/datatype/binary_vecf32.rs

@@ -7,7 +7,7 @@ use pgrx::datum::IntoDatum;
 use pgrx::pg_sys::Oid;
 use std::ffi::c_char;
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_vecf32_send(vector: Vecf32Input<'_>) -> Bytea {
     use pgrx::pg_sys::StringInfoData;
     unsafe {
@@ -21,8 +21,9 @@ fn _vectors_vecf32_send(vector: Vecf32Input<'_>) -> Bytea {
     }
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
-fn _vectors_vecf32_recv(internal: Internal, _oid: Oid, _typmod: i32) -> Vecf32Output {
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
+fn _vectors_vecf32_recv(internal: Internal, oid: Oid, typmod: i32) -> Vecf32Output {
+    let _ = (oid, typmod);
     use pgrx::pg_sys::StringInfo;
     unsafe {
         let buf: StringInfo = internal.into_datum().unwrap().cast_mut_ptr();

src/datatype/binary_veci8.rs

@@ -7,7 +7,7 @@ use pgrx::datum::IntoDatum;
 use pgrx::pg_sys::Oid;
 use std::ffi::c_char;
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_veci8_send(vector: Veci8Input<'_>) -> Bytea {
     use pgrx::pg_sys::StringInfoData;
     unsafe {
@@ -29,8 +29,9 @@ fn _vectors_veci8_send(vector: Veci8Input<'_>) -> Bytea {
     }
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
-fn _vectors_veci8_recv(internal: Internal, _oid: Oid, _typmod: i32) -> Veci8Output {
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
+fn _vectors_veci8_recv(internal: Internal, oid: Oid, typmod: i32) -> Veci8Output {
+    let _ = (oid, typmod);
     use pgrx::pg_sys::StringInfo;
     unsafe {
         let buf: StringInfo = internal.into_datum().unwrap().cast_mut_ptr();

src/datatype/casts.rs

@@ -8,12 +8,13 @@ use base::scalar::*;
 use base::vector::*;
 use num_traits::Zero;
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_cast_array_to_vecf32(
     array: pgrx::Array<f32>,
-    _typmod: i32,
+    typmod: i32,
     _explicit: bool,
 ) -> Vecf32Output {
+    let _ = typmod;
     check_value_dims_65535(array.len());
     let mut slice = vec![F32::zero(); array.len()];
     for (i, x) in array.iter().enumerate() {
@@ -22,7 +23,7 @@ fn _vectors_cast_array_to_vecf32(
     Vecf32Output::new(Vecf32Borrowed::new(&slice))
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_cast_vecf32_to_array(
     vector: Vecf32Input<'_>,
     _typmod: i32,
@@ -31,29 +32,27 @@ fn _vectors_cast_vecf32_to_array(
     vector.slice().iter().map(|x| x.to_f32()).collect()
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_cast_vecf32_to_vecf16(
     vector: Vecf32Input<'_>,
     _typmod: i32,
     _explicit: bool,
 ) -> Vecf16Output {
     let slice: Vec<F16> = vector.slice().iter().map(|&x| F16::from_f(x)).collect();
-
     Vecf16Output::new(Vecf16Borrowed::new(&slice))
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_cast_vecf16_to_vecf32(
     vector: Vecf16Input<'_>,
     _typmod: i32,
     _explicit: bool,
 ) -> Vecf32Output {
     let slice: Vec<F32> = vector.slice().iter().map(|&x| x.to_f()).collect();
-
     Vecf32Output::new(Vecf32Borrowed::new(&slice))
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_cast_vecf32_to_svecf32(
     vector: Vecf32Input<'_>,
     _typmod: i32,
@@ -78,18 +77,17 @@ fn _vectors_cast_vecf32_to_svecf32(
     ))
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_cast_svecf32_to_vecf32(
     vector: SVecf32Input<'_>,
     _typmod: i32,
     _explicit: bool,
 ) -> Vecf32Output {
     let slice = vector.for_borrow().to_vec();
-
     Vecf32Output::new(Vecf32Borrowed::new(&slice))
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_cast_vecf32_to_bvecf32(
     vector: Vecf32Input<'_>,
     _typmod: i32,
@@ -103,11 +101,10 @@ fn _vectors_cast_vecf32_to_bvecf32(
             _ => bad_literal("The vector contains a non-binary value."),
         }
     }
-
     BVecf32Output::new(values.for_borrow())
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_cast_bvecf32_to_vecf32(
     vector: BVecf32Input<'_>,
     _typmod: i32,
@@ -121,7 +118,7 @@ fn _vectors_cast_bvecf32_to_vecf32(
     Vecf32Output::new(Vecf32Borrowed::new(&data))
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_cast_veci8_to_vecf32(
     vector: Veci8Input<'_>,
     _typmod: i32,
@@ -133,7 +130,7 @@ fn _vectors_cast_veci8_to_vecf32(
     Vecf32Output::new(Vecf32Borrowed::new(&data))
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_cast_vecf32_to_veci8(
     vector: Vecf32Input<'_>,
     _typmod: i32,

src/datatype/functions_bvecf32.rs

@@ -3,14 +3,13 @@ use super::memory_vecf32::Vecf32Input;
 use base::scalar::*;
 use base::vector::*;
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_binarize(vector: Vecf32Input<'_>) -> BVecf32Output {
     let mut values = BVecf32Owned::new_zeroed(vector.len() as u16);
     for (i, &F32(x)) in vector.slice().iter().enumerate() {
         if x > 0. {
             values.set(i, true);
         }
     }
-
     BVecf32Output::new(values.for_borrow())
 }

src/datatype/functions_svecf32.rs

@@ -3,7 +3,7 @@ use crate::error::*;
 use base::scalar::*;
 use base::vector::*;
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_to_svector(
     dims: i32,
     index: pgrx::Array<i32>,

src/datatype/functions_veci8.rs

@@ -3,7 +3,7 @@ use crate::error::*;
 use base::scalar::*;
 use base::vector::*;
 
-#[pgrx::pg_extern(immutable, parallel_safe, strict)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_to_veci8(len: i32, alpha: f32, offset: f32, values: pgrx::Array<i32>) -> Veci8Output {
     check_value_dims_65535(len as usize);
     if (len as usize) != values.len() {

src/datatype/operators_bvecf32.rs

@@ -5,7 +5,7 @@ use base::scalar::*;
 use base::vector::*;
 use std::ops::Deref;
 
-#[pgrx::pg_extern(immutable, parallel_safe)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_bvecf32_operator_and(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) -> BVecf32Output {
     let n = check_matched_dims(lhs.dims() as _, rhs.dims() as _);
     let mut results = BVecf32Owned::new_zeroed(n.try_into().unwrap());
@@ -16,7 +16,7 @@ fn _vectors_bvecf32_operator_and(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) -
     BVecf32Output::new(results.for_borrow())
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_bvecf32_operator_or(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) -> BVecf32Output {
     check_matched_dims(lhs.dims() as _, rhs.dims() as _);
     let mut results = BVecf32Owned::new_zeroed(lhs.dims().try_into().unwrap());
@@ -27,7 +27,7 @@ fn _vectors_bvecf32_operator_or(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) ->
     BVecf32Output::new(results.for_borrow())
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_bvecf32_operator_xor(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) -> BVecf32Output {
     check_matched_dims(lhs.dims() as _, rhs.dims() as _);
     let mut results = BVecf32Owned::new_zeroed(lhs.dims().try_into().unwrap());
@@ -38,61 +38,61 @@ fn _vectors_bvecf32_operator_xor(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) -
     BVecf32Output::new(results.for_borrow())
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_bvecf32_operator_lt(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) -> bool {
     check_matched_dims(lhs.dims() as _, rhs.dims() as _);
     lhs.deref().for_borrow() < rhs.deref().for_borrow()
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_bvecf32_operator_lte(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) -> bool {
     check_matched_dims(lhs.dims() as _, rhs.dims() as _);
     lhs.deref().for_borrow() <= rhs.deref().for_borrow()
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_bvecf32_operator_gt(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) -> bool {
     check_matched_dims(lhs.dims() as _, rhs.dims() as _);
     lhs.deref().for_borrow() > rhs.deref().for_borrow()
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_bvecf32_operator_gte(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) -> bool {
     check_matched_dims(lhs.dims() as _, rhs.dims() as _);
     lhs.deref().for_borrow() >= rhs.deref().for_borrow()
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_bvecf32_operator_eq(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) -> bool {
     check_matched_dims(lhs.dims() as _, rhs.dims() as _);
     lhs.deref().for_borrow() == rhs.deref().for_borrow()
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_bvecf32_operator_neq(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) -> bool {
     check_matched_dims(lhs.dims() as _, rhs.dims() as _);
     lhs.deref().for_borrow() != rhs.deref().for_borrow()
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_bvecf32_operator_cosine(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) -> f32 {
     check_matched_dims(lhs.dims() as _, rhs.dims() as _);
     BVecf32Cos::distance(lhs.for_borrow(), rhs.for_borrow()).to_f32()
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_bvecf32_operator_dot(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) -> f32 {
     check_matched_dims(lhs.dims() as _, rhs.dims() as _);
     BVecf32Dot::distance(lhs.for_borrow(), rhs.for_borrow()).to_f32()
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_bvecf32_operator_l2(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) -> f32 {
     check_matched_dims(lhs.dims() as _, rhs.dims() as _);
     BVecf32L2::distance(lhs.for_borrow(), rhs.for_borrow()).to_f32()
 }
 
-#[pgrx::pg_extern(immutable, parallel_safe)]
+#[pgrx::pg_extern(immutable, strict, parallel_safe)]
 fn _vectors_bvecf32_operator_jaccard(lhs: BVecf32Input<'_>, rhs: BVecf32Input<'_>) -> f32 {
     check_matched_dims(lhs.dims() as _, rhs.dims() as _);
     BVecf32Jaccard::distance(lhs.for_borrow(), rhs.for_borrow()).to_f32()