risingwave_common::types::jsonb

Struct ToTextFormatter

struct ToTextFormatter;

Expand description

A custom implementation for serde_json::ser::Formatter to match PostgreSQL, which adds extra space after , and : in array and object.

Trait Implementations§

impl Formatter for ToTextFormatter

fn begin_array_value<W>(&mut self, writer: &mut W, first: bool) -> Result<()>
where W: ?Sized + Write,

Called before every array value. Writes a , if needed to the specified writer.

fn begin_object_key<W>(&mut self, writer: &mut W, first: bool) -> Result<()>
where W: ?Sized + Write,

Called before every object key.

fn begin_object_value<W>(&mut self, writer: &mut W) -> Result<()>
where W: ?Sized + Write,

Called before every object value. A : should be written to the specified writer by either this method or end_object_key.

fn write_null<W>(&mut self, writer: &mut W) -> Result<(), Error>
where W: Write + ?Sized,

Writes a null value to the specified writer.

fn write_bool<W>(&mut self, writer: &mut W, value: bool) -> Result<(), Error>
where W: Write + ?Sized,

Writes a true or false value to the specified writer.

fn write_i8<W>(&mut self, writer: &mut W, value: i8) -> Result<(), Error>
where W: Write + ?Sized,

Writes an integer value like -123 to the specified writer.

fn write_i16<W>(&mut self, writer: &mut W, value: i16) -> Result<(), Error>
where W: Write + ?Sized,

Writes an integer value like -123 to the specified writer.

fn write_i32<W>(&mut self, writer: &mut W, value: i32) -> Result<(), Error>
where W: Write + ?Sized,

Writes an integer value like -123 to the specified writer.

fn write_i64<W>(&mut self, writer: &mut W, value: i64) -> Result<(), Error>
where W: Write + ?Sized,

Writes an integer value like -123 to the specified writer.

fn write_i128<W>(&mut self, writer: &mut W, value: i128) -> Result<(), Error>
where W: Write + ?Sized,

Writes an integer value like -123 to the specified writer.

fn write_u8<W>(&mut self, writer: &mut W, value: u8) -> Result<(), Error>
where W: Write + ?Sized,

Writes an integer value like 123 to the specified writer.

fn write_u16<W>(&mut self, writer: &mut W, value: u16) -> Result<(), Error>
where W: Write + ?Sized,

Writes an integer value like 123 to the specified writer.

fn write_u32<W>(&mut self, writer: &mut W, value: u32) -> Result<(), Error>
where W: Write + ?Sized,

Writes an integer value like 123 to the specified writer.

fn write_u64<W>(&mut self, writer: &mut W, value: u64) -> Result<(), Error>
where W: Write + ?Sized,

Writes an integer value like 123 to the specified writer.

fn write_u128<W>(&mut self, writer: &mut W, value: u128) -> Result<(), Error>
where W: Write + ?Sized,

Writes an integer value like 123 to the specified writer.

fn write_f32<W>(&mut self, writer: &mut W, value: f32) -> Result<(), Error>
where W: Write + ?Sized,

Writes a floating point value like -31.26e+12 to the specified writer. Read more

fn write_f64<W>(&mut self, writer: &mut W, value: f64) -> Result<(), Error>
where W: Write + ?Sized,

Writes a floating point value like -31.26e+12 to the specified writer. Read more

fn write_number_str<W>( &mut self, writer: &mut W, value: &str, ) -> Result<(), Error>
where W: Write + ?Sized,

Writes a number that has already been rendered to a string.

fn begin_string<W>(&mut self, writer: &mut W) -> Result<(), Error>
where W: Write + ?Sized,

Called before each series of write_string_fragment and write_char_escape. Writes a " to the specified writer.

fn end_string<W>(&mut self, writer: &mut W) -> Result<(), Error>
where W: Write + ?Sized,

Called after each series of write_string_fragment and write_char_escape. Writes a " to the specified writer.

fn write_string_fragment<W>( &mut self, writer: &mut W, fragment: &str, ) -> Result<(), Error>
where W: Write + ?Sized,

Writes a string fragment that doesn’t need any escaping to the specified writer.

fn write_char_escape<W>( &mut self, writer: &mut W, char_escape: CharEscape, ) -> Result<(), Error>
where W: Write + ?Sized,

Writes a character escape code to the specified writer.

fn write_byte_array<W>( &mut self, writer: &mut W, value: &[u8], ) -> Result<(), Error>
where W: Write + ?Sized,

Writes the representation of a byte array. Formatters can choose whether to represent bytes as a JSON array of integers (the default), or some JSON string encoding like hex or base64.

fn begin_array<W>(&mut self, writer: &mut W) -> Result<(), Error>
where W: Write + ?Sized,

Called before every array. Writes a [ to the specified writer.

fn end_array<W>(&mut self, writer: &mut W) -> Result<(), Error>
where W: Write + ?Sized,

Called after every array. Writes a ] to the specified writer.

fn end_array_value<W>(&mut self, _writer: &mut W) -> Result<(), Error>
where W: Write + ?Sized,

Called after every array value.

fn begin_object<W>(&mut self, writer: &mut W) -> Result<(), Error>
where W: Write + ?Sized,

Called before every object. Writes a { to the specified writer.

fn end_object<W>(&mut self, writer: &mut W) -> Result<(), Error>
where W: Write + ?Sized,

Called after every object. Writes a } to the specified writer.

fn end_object_key<W>(&mut self, _writer: &mut W) -> Result<(), Error>
where W: Write + ?Sized,

Called after every object key. A : should be written to the specified writer by either this method or begin_object_value.

fn end_object_value<W>(&mut self, _writer: &mut W) -> Result<(), Error>
where W: Write + ?Sized,

Called after every object value.

fn write_raw_fragment<W>( &mut self, writer: &mut W, fragment: &str, ) -> Result<(), Error>
where W: Write + ?Sized,

Writes a raw JSON fragment that doesn’t need any escaping to the specified writer.

Auto Trait Implementations§

impl Freeze for ToTextFormatter

impl RefUnwindSafe for ToTextFormatter

impl Send for ToTextFormatter

impl Sync for ToTextFormatter

impl Unpin for ToTextFormatter

impl UnwindSafe for ToTextFormatter

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> Conv for T

fn conv<T>(self) -> T
where Self: Into<T>,

Converts self into T using Into<T>. Read more

impl<T> FmtForward for T

fn fmt_binary(self) -> FmtBinary<Self>
where Self: Binary,

Causes self to use its Binary implementation when Debug-formatted.

fn fmt_display(self) -> FmtDisplay<Self>
where Self: Display,

Causes self to use its Display implementation when Debug-formatted.

fn fmt_lower_exp(self) -> FmtLowerExp<Self>
where Self: LowerExp,

Causes self to use its LowerExp implementation when Debug-formatted.

fn fmt_lower_hex(self) -> FmtLowerHex<Self>
where Self: LowerHex,

Causes self to use its LowerHex implementation when Debug-formatted.

fn fmt_octal(self) -> FmtOctal<Self>
where Self: Octal,

Causes self to use its Octal implementation when Debug-formatted.

fn fmt_pointer(self) -> FmtPointer<Self>
where Self: Pointer,

Causes self to use its Pointer implementation when Debug-formatted.

fn fmt_upper_exp(self) -> FmtUpperExp<Self>
where Self: UpperExp,

Causes self to use its UpperExp implementation when Debug-formatted.

fn fmt_upper_hex(self) -> FmtUpperHex<Self>
where Self: UpperHex,

Causes self to use its UpperHex implementation when Debug-formatted.

fn fmt_list(self) -> FmtList<Self>
where &'a Self: for<'a> IntoIterator,

Formats each item in a sequence. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request

impl<T> IntoResult<T> for T

type Err = Infallible

fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>

impl<M> MetricVecRelabelExt for M

fn relabel( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>

Equivalent to [RelabeledMetricVec::with_metric_level].

fn relabel_n( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, relabel_num: usize, ) -> RelabeledMetricVec<M>

Equivalent to [RelabeledMetricVec::with_metric_level_relabel_n].

fn relabel_debug_1( self, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>

Equivalent to [RelabeledMetricVec::with_metric_level_relabel_n] with metric_level set to MetricLevel::Debug and relabel_num set to 1.

impl<T> Pipe for T
where T: ?Sized,

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R
where Self: Sized,

Pipes by value. This is generally the method you want to use. Read more

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R
where R: 'a,

Borrows self and passes that borrow into the pipe function. Read more

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R
where R: 'a,

Mutably borrows self and passes that borrow into the pipe function. Read more

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

Borrows self, then passes self.borrow() into the pipe function. Read more

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.borrow_mut() into the pipe function. Read more

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
where Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

Borrows self, then passes self.as_ref() into the pipe function.

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
where Self: AsMut<U>, U: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.as_mut() into the pipe function.

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

Borrows self, then passes self.deref() into the pipe function.

fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R, ) -> R
where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.deref_mut() into the pipe function.

impl<T> Pointable for T

const ALIGN: usize

The alignment of pointer.

type Init = T

The type for initializers.

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more

impl<T> Same for T

type Output = T

Should always be Self

impl<T> Scope for T

fn with<F, R>(self, f: F) -> R
where Self: Sized, F: FnOnce(Self) -> R,

Scoped with ownership.

fn with_ref<F, R>(&self, f: F) -> R
where F: FnOnce(&Self) -> R,

Scoped with reference.

fn with_mut<F, R>(&mut self, f: F) -> R
where F: FnOnce(&mut Self) -> R,

Scoped with mutable reference.

impl<T> Tap for T

fn tap(self, func: impl FnOnce(&Self)) -> Self

Immutable access to a value. Read more

fn tap_mut(self, func: impl FnOnce(&mut Self)) -> Self

Mutable access to a value. Read more

fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Immutable access to the Borrow<B> of a value. Read more

fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Mutable access to the BorrowMut<B> of a value. Read more

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Immutable access to the AsRef<R> view of a value. Read more

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Mutable access to the AsMut<R> view of a value. Read more

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Immutable access to the Deref::Target of a value. Read more

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Mutable access to the Deref::Target of a value. Read more

fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self

Calls .tap() only in debug builds, and is erased in release builds.

fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self

Calls .tap_mut() only in debug builds, and is erased in release builds.

fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Calls .tap_borrow() only in debug builds, and is erased in release builds.

fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Calls .tap_borrow_mut() only in debug builds, and is erased in release builds.

fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Calls .tap_ref() only in debug builds, and is erased in release builds.

fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Calls .tap_ref_mut() only in debug builds, and is erased in release builds.

fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Calls .tap_deref() only in debug builds, and is erased in release builds.

fn tap_deref_mut_dbg<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Calls .tap_deref_mut() only in debug builds, and is erased in release builds.

impl<T> TryConv for T

fn try_conv<T>(self) -> Result<T, Self::Error>
where Self: TryInto<T>,

Attempts to convert self into T using TryInto<T>. Read more

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

impl<T> LruValue for T
where T: Send + Sync,

impl<T> MaybeSend for T
where T: Send,

impl<T> Value for T
where T: Send + Sync + 'static,