Struct ChangeStreamRecord 

#[non_exhaustive]
pub struct ChangeStreamRecord {
    pub record: Option<Record>,
    /* private fields */
}

Spanner Change Streams enable customers to capture and stream out changes to their Spanner databases in real-time. A change stream can be created with option partition_mode=‘IMMUTABLE_KEY_RANGE’ or partition_mode=‘MUTABLE_KEY_RANGE’.

This message is only used in Change Streams created with the option partition_mode=‘MUTABLE_KEY_RANGE’. Spanner automatically creates a special Table-Valued Function (TVF) along with each Change Streams. The function provides access to the change stream’s records. The function is named READ_<change_stream_name> (where <change_stream_name> is the name of the change stream), and it returns a table with only one column called ChangeRecord.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

record: Option<Record>

One of the change stream subrecords.

Implementations

impl ChangeStreamRecord

pub fn new() -> Self

Creates a new default instance.

pub fn set_record<T: Into<Option<Record>>>(self, v: T) -> Self

Sets the value of record.

Note that all the setters affecting record are mutually exclusive.

pub fn data_change_record(&self) -> Option<&Box<DataChangeRecord>>

The value of record if it holds a DataChangeRecord, None if the field is not set or holds a different branch.

pub fn set_data_change_record<T: Into<Box<DataChangeRecord>>>( self, v: T, ) -> Self

Sets the value of record to hold a DataChangeRecord.

Note that all the setters affecting record are mutually exclusive.

pub fn heartbeat_record(&self) -> Option<&Box<HeartbeatRecord>>

The value of record if it holds a HeartbeatRecord, None if the field is not set or holds a different branch.

pub fn set_heartbeat_record<T: Into<Box<HeartbeatRecord>>>(self, v: T) -> Self

Sets the value of record to hold a HeartbeatRecord.

Note that all the setters affecting record are mutually exclusive.

pub fn partition_start_record(&self) -> Option<&Box<PartitionStartRecord>>

The value of record if it holds a PartitionStartRecord, None if the field is not set or holds a different branch.

pub fn set_partition_start_record<T: Into<Box<PartitionStartRecord>>>( self, v: T, ) -> Self

Sets the value of record to hold a PartitionStartRecord.

Note that all the setters affecting record are mutually exclusive.

pub fn partition_end_record(&self) -> Option<&Box<PartitionEndRecord>>

The value of record if it holds a PartitionEndRecord, None if the field is not set or holds a different branch.

pub fn set_partition_end_record<T: Into<Box<PartitionEndRecord>>>( self, v: T, ) -> Self

Sets the value of record to hold a PartitionEndRecord.

Note that all the setters affecting record are mutually exclusive.

pub fn partition_event_record(&self) -> Option<&Box<PartitionEventRecord>>

The value of record if it holds a PartitionEventRecord, None if the field is not set or holds a different branch.

pub fn set_partition_event_record<T: Into<Box<PartitionEventRecord>>>( self, v: T, ) -> Self

Sets the value of record to hold a PartitionEventRecord.

Note that all the setters affecting record are mutually exclusive.

Trait Implementations

impl Clone for ChangeStreamRecord

fn clone(&self) -> ChangeStreamRecord

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ChangeStreamRecord

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ChangeStreamRecord

fn default() -> ChangeStreamRecord

Returns the “default value” for a type.

impl Message for ChangeStreamRecord

fn typename() -> &'static str

The typename of this message.

impl PartialEq for ChangeStreamRecord

fn eq(&self, other: &ChangeStreamRecord) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ChangeStreamRecord