Struct KafkaSpecRegistry 

pub struct KafkaSpecRegistry { /* private fields */ }

Kafka-specific spec registry implementation

Implementations

impl KafkaSpecRegistry

pub async fn new( config: KafkaConfig, topics: Arc<RwLock<HashMap<String, Topic>>>, ) -> Result<Self>

Create a new Kafka spec registry

pub fn find_fixture_by_topic(&self, topic: &str) -> Option<Arc<KafkaFixture>>

Find fixture by topic

pub async fn produce( &self, topic: &str, key: Option<&str>, value: &Value, ) -> Result<i64>

Produce a message to a topic

pub async fn fetch( &self, topic: &str, partition: i32, offset: i64, ) -> Result<Vec<KafkaMessage>>

Fetch messages from a topic partition

Trait Implementations

impl Debug for KafkaSpecRegistry

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

Formats the value using the given formatter.

impl SpecRegistry for KafkaSpecRegistry

fn protocol(&self) -> Protocol

Get the protocol this registry handles

fn operations(&self) -> Vec<SpecOperation>

Get all available operations/routes in this spec

fn find_operation(&self, operation: &str, path: &str) -> Option<SpecOperation>

Find an operation by path/name

fn validate_request( &self, request: &ProtocolRequest, ) -> Result<ValidationResult>

Validate a request against the spec

fn generate_mock_response( &self, request: &ProtocolRequest, ) -> Result<ProtocolResponse>

Generate a mock response for a request