Enum Feature 

pub enum Feature {
    TestDummy,
    TimeTravel,
    GlueSchemaRegistry,
    SnowflakeSink,
    RedisSinkStream,
    DynamoDbSink,
    OpenSearchSink,
    BigQuerySink,
    ClickHouseSharedEngine,
    SecretManagement,
    SqlServerSink,
    SqlServerCdcSource,
    CdcAutoSchemaChange,
    IcebergSinkWithGlue,
    ElasticDiskCache,
    ResourceGroup,
    DatabaseFailureIsolation,
    IcebergCompaction,
    SinkAutoSchemaChange,
    StateTableMemoryPreload,
    LocalityBackfill,
    SinkSinceTimestamp,
}

A set of features that are available based on the license.

JSON schema

{
 "title": "Feature",
 "description": "A set of features that are available based on the license.",
 "oneOf": [
   {
     "description": "A dummy feature for testing purposes.",
     "type": "string",
     "const": "TestDummy"
   },
   {
     "description": "Query historical data within the retention period.",
     "type": "string",
     "const": "TimeTravel"
   },
   {
     "description": "Use Schema Registry from AWS Glue rather than Confluent.",
     "type": "string",
     "const": "GlueSchemaRegistry"
   },
   {
     "description": "Delivering data to SnowFlake.",
     "type": "string",
     "const": "SnowflakeSink"
   },
   {
     "description": "Delivering data to redis stream.",
     "type": "string",
     "const": "RedisSinkStream"
   },
   {
     "description": "Delivering data to DynamoDb.",
     "type": "string",
     "const": "DynamoDbSink"
   },
   {
     "description": "Delivering data to OpenSearch.",
     "type": "string",
     "const": "OpenSearchSink"
   },
   {
     "description": "Delivering data to BigQuery.",
     "type": "string",
     "const": "BigQuerySink"
   },
   {
     "description": "Delivering data to Shared tree on clickhouse cloud",
     "type": "string",
     "const": "ClickHouseSharedEngine"
   },
   {
     "description": "Secret management.",
     "type": "string",
     "const": "SecretManagement"
   },
   {
     "description": "Sink data from RisingWave to SQL Server.",
     "type": "string",
     "const": "SqlServerSink"
   },
   {
     "description": "CDC source connector for Sql Server.",
     "type": "string",
     "const": "SqlServerCdcSource"
   },
   {
     "description": "Auto replicate upstream DDL to CDC Table.",
     "type": "string",
     "const": "CdcAutoSchemaChange"
   },
   {
     "description": "Delivering data to Iceberg with Glue catalog.",
     "type": "string",
     "const": "IcebergSinkWithGlue"
   },
   {
     "description": "Disk cache and refilling to boost performance and reduce object store access cost.",
     "type": "string",
     "const": "ElasticDiskCache"
   },
   {
     "description": "Resource group to isolate workload and failure.",
     "type": "string",
     "const": "ResourceGroup"
   },
   {
     "description": "Failure isolation between databases.",
     "type": "string",
     "const": "DatabaseFailureIsolation"
   },
   {
     "description": "Auto iceberg compaction.",
     "type": "string",
     "const": "IcebergCompaction"
   },
   {
     "description": "Sink auto schema change.",
     "type": "string",
     "const": "SinkAutoSchemaChange"
   },
   {
     "description": "Support state table memory preload for boosting performance.",
     "type": "string",
     "const": "StateTableMemoryPreload"
   },
   {
     "description": "Support locality backfill for complex streaming queries.",
     "type": "string",
     "const": "LocalityBackfill"
   },
   {
     "description": "Create sinks from a historical timestamp.",
     "type": "string",
     "const": "SinkSinceTimestamp"
   }
 ]
}

Variants

TestDummy

A dummy feature for testing purposes.

TimeTravel

Query historical data within the retention period.

GlueSchemaRegistry

Use Schema Registry from AWS Glue rather than Confluent.

SnowflakeSink

Delivering data to SnowFlake.

RedisSinkStream

Delivering data to redis stream.

DynamoDbSink

Delivering data to DynamoDb.

OpenSearchSink

Delivering data to OpenSearch.

BigQuerySink

Delivering data to BigQuery.

ClickHouseSharedEngine

Delivering data to Shared tree on clickhouse cloud

SecretManagement

Secret management.

SqlServerSink

Sink data from RisingWave to SQL Server.

SqlServerCdcSource

CDC source connector for Sql Server.

CdcAutoSchemaChange

Auto replicate upstream DDL to CDC Table.

IcebergSinkWithGlue

Delivering data to Iceberg with Glue catalog.

ElasticDiskCache

Disk cache and refilling to boost performance and reduce object store access cost.

ResourceGroup

Resource group to isolate workload and failure.

DatabaseFailureIsolation

Failure isolation between databases.

IcebergCompaction

Auto iceberg compaction.

SinkAutoSchemaChange

Sink auto schema change.

StateTableMemoryPreload

Support state table memory preload for boosting performance.

LocalityBackfill

Support locality backfill for complex streaming queries.

SinkSinceTimestamp

Create sinks from a historical timestamp.

Implementations

impl Feature

pub fn name(self) -> &'static str

Name of the feature.

pub fn description(self) -> &'static str

Description of the feature.

pub fn all() -> &'static [Feature]

Get a slice of all features.

pub(crate) fn all_as_of_2_5() -> &'static [Feature]

Get a slice of all features available as of 2.5 (before we introduce custom tier).

impl Feature

pub(crate) fn check_available_with( self, manager: &LicenseManager, ) -> Result<(), FeatureNotAvailable>

Check whether the feature is available based on the given license manager.

pub fn check_available(self) -> Result<(), FeatureNotAvailable>

Check whether the feature is available based on the current license.

Trait Implementations

impl Clone for Feature

fn clone(&self) -> Feature

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Feature

impl Debug for Feature

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Feature

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for Feature

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

Formats the value using the given formatter.

impl EnumMessage for Feature

fn get_message(&self) -> Option<&'static str>

fn get_detailed_message(&self) -> Option<&'static str>

fn get_documentation(&self) -> Option<&'static str>

Get the doc comment associated with a variant if it exists.

fn get_serializations(&self) -> &'static [&'static str]

impl Eq for Feature

impl<'_derivative_strum> From<&'_derivative_strum Feature> for &'static str

fn from(x: &'_derivative_strum Feature) -> &'static str

Converts to this type from the input type.

impl From<&Feature> for Feature

fn from(value: &Feature) -> Self

Converts to this type from the input type.

impl From<Feature> for &'static str

fn from(x: Feature) -> &'static str

Converts to this type from the input type.

impl FromStr for Feature

type Err = ConversionError

The associated error which can be returned from parsing.

fn from_str(value: &str) -> Result<Self, ConversionError>

Parses a string s to return a value of this type.

impl Hash for Feature

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Ord for Feature

fn cmp(&self, other: &Feature) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

impl PartialEq for Feature

fn eq(&self, other: &Feature) -> 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 PartialOrd for Feature

fn partial_cmp(&self, other: &Feature) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

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

Tests less than (for self and other) and is used by the < operator.

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

Tests less than or equal to (for self and other) and is used by the <= operator.

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

Tests greater than (for self and other) and is used by the > operator.

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

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl Serialize for Feature

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Feature

impl TryFrom<&String> for Feature

type Error = ConversionError

The type returned in the event of a conversion error.

fn try_from(value: &String) -> Result<Self, ConversionError>

Performs the conversion.

impl TryFrom<&str> for Feature

type Error = ConversionError

The type returned in the event of a conversion error.

fn try_from(value: &str) -> Result<Self, ConversionError>

Performs the conversion.

impl TryFrom<String> for Feature

type Error = ConversionError

The type returned in the event of a conversion error.

fn try_from(value: String) -> Result<Self, ConversionError>

Performs the conversion.

impl VariantArray for Feature

const VARIANTS: &'static [Self]