summa 0.8.8

Fast full-text search server
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

pub enum KafkaConsumingStatus {
    Consumed,
}

#[derive(thiserror::Error, Debug)]
pub enum KafkaConsumingError {
    #[error("empty_payload_error")]
    EmptyPayload,
    #[error("empty_operation_error")]
    EmptyOperation,
    #[error("index_error: {0}")]
    Index(crate::errors::Error),
    #[error("kafka_error: {0}")]
    Kafka(rdkafka::error::KafkaError),
    #[error("parse_document_error: {0}")]
    ParseDocument(crate::errors::Error),
    #[error("proto_decode_error: {0}")]
    ProtoDecode(prost::DecodeError),
}