sigil-ingestor · crate

Source: sigil/node/sigil-ingestor/src/lib.rs. SHA-256: 381d8cf903b34ca6d7c5a060d069fc7438ac08ba3fb2f83a393a71610cf9ffc7.

This reference follows declared source modules, retains conditional attributes, and includes public declarations and implementation methods. Private-module re-exports and trait resolution require the compiler; this is a source reference, not a claim that every listed item is a root import. Function bodies and constant values are omitted.

::IngestorError

#[derive(Debug, Error)]
pub enum IngestorError {
    #[error("config IO: {0}")]
    Io(#[from] std::io::Error),
    #[error("config parse: {0}")]
    Toml(#[from] toml::de::Error),
    #[error("invalid config: {0}")]
    InvalidConfig(String),
    #[error("invalid hash: {0}")]
    InvalidHash(String),
}

Source line: 18.

::ConfiguredSourceKind

#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "snake_case")]
pub enum ConfiguredSourceKind {
    InZone,
    CrossZone,
    ComputeCompletion,
    TimeBlockHeight,
    TimeAttestedWallClock,
    TeeAttested,
}

Source line: 31.

::ConfiguredSourceKind::event_source_kind

pub fn event_source_kind(&self) -> EventSourceKind;

Source line: 41.

::IngestorSourceConfig

#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
pub struct IngestorSourceConfig {
pub name: String,
pub subscription_id: String,
pub kind: ConfiguredSourceKind,
#[serde(default = "default_confirmations")]
pub confirmation_depth: u64,
#[serde(default = "default_poll_interval_secs")]
pub poll_interval_secs: u64
}

Source line: 53.

::IngestorConfig

#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
pub struct IngestorConfig {
pub ingestor_did: String,
pub node_rpc_url: String,
pub local_state_path: String,
#[serde(default = "default_fee_per_delivery")]
pub fee_per_delivery: u64,
#[serde(default)]
pub dry_run: bool,
#[serde(default)]
pub sources: Vec<IngestorSourceConfig>
}

Source line: 64.

::IngestorConfig::from_path

pub fn from_path(path: &Path) -> Result<Self, IngestorError>;

Source line: 89.

::IngestorConfig::validate

pub fn validate(&self) -> Result<(), IngestorError>;

Source line: 94.

::IngestorSourceConfig::validate

pub fn validate(&self) -> Result<(), IngestorError>;

Source line: 119.

::validate_rpc_url

pub fn validate_rpc_url(url: &str) -> Result<(), IngestorError>;

Source line: 140.

::parse_hash

pub fn parse_hash(value: &str) -> Result<SigilHash, IngestorError>;

Source line: 156.

::build_block_height_delivery

pub fn build_block_height_delivery(
    subscription_id: SigilHash,
    ingestor_did: String,
    target_height: u64,
    payload: serde_json::Value,
) -> EventDeliveryData;

Source line: 160.

sigil-ingestor · crate

On this page