Struct Validator 

pub struct Validator;

Validator for Rivven inputs

Implementations

impl Validator

pub fn validate_identifier(name: &str) -> Result<(), ValidationError>

Validate a SQL-style identifier (slot names, internal identifiers)

Security

Prevents SQL injection by rejecting:

• Empty strings
• Strings starting with numbers
• Special characters (quotes, semicolons, etc.)
• Excessively long strings

pub fn validate_topic_name(name: &str) -> Result<(), ValidationError>

Validate a topic name

Topic names follow Kafka conventions:

• Must start with alphanumeric character
• Can contain alphanumeric, dots, hyphens, and underscores
• Maximum 255 characters

pub fn validate_message_size( size: usize, max: usize, ) -> Result<(), ValidationError>

Validate message size

pub fn validate_partition( partition: u32, num_partitions: u32, ) -> Result<(), ValidationError>

Validate partition number

pub fn validate_consumer_group_id(id: &str) -> Result<(), ValidationError>

Validate consumer group ID

Uses the same rules as topic names

pub fn validate_client_id(id: &str) -> Result<(), ValidationError>

Validate client ID

Uses the same rules as topic names

pub fn sanitize_for_log(s: &str, max_len: usize) -> String

Sanitize a string for safe logging (remove control characters, truncate)