sof 0.18.2

Solana Observer Framework for low-latency shred ingestion and plugin-driven transaction observation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78

#[cfg(feature = "gossip-bootstrap")]
pub(super) use std::collections::HashSet;
#[cfg(feature = "gossip-bootstrap")]
pub(super) use std::net::{IpAddr, Ipv4Addr};
#[cfg(feature = "gossip-bootstrap")]
pub(super) use std::num::NonZeroUsize;
#[cfg(feature = "gossip-bootstrap")]
pub(super) use std::sync::atomic::AtomicBool;
pub(super) use std::{
    collections::{HashMap, VecDeque},
    net::SocketAddr,
    str::FromStr,
    sync::{
        Arc,
        atomic::{AtomicU64, Ordering},
    },
    time::{Duration, Instant},
};

pub(super) use super::super::config::*;
pub(super) use super::super::state::{
    CommitmentSlotTracker, ForkTracker, ForkTrackerUpdate, OutstandingRepairRequests,
    ShredDedupeCache, ShredDedupeIdentity, ShredDedupeObservation, ShredDedupeStage,
    SlotCoverageWindow, note_latest_shred_slot,
};
#[cfg(feature = "gossip-bootstrap")]
pub(super) use crate::framework::ClusterTopologyEvent;
#[cfg(feature = "gossip-bootstrap")]
pub(super) use crate::repair::MissingShredRequest;
#[cfg(feature = "gossip-bootstrap")]
pub(super) use crate::repair::MissingShredRequestKind;
pub(super) use crate::{
    event::{TxCommitmentStatus, TxKind, TxObservedEvent},
    framework::{
        CheckpointBarrierReason, DatasetEvent, DerivedStateHost, DiskDerivedStateReplaySource,
        FeedWatermarks, InMemoryDerivedStateReplaySource, ObservedRecentBlockhashEvent, PluginHost,
        PluginHostBuilder, RawPacketEvent, ReorgEvent, RuntimeExtensionDispatchMetrics,
        RuntimeExtensionHost, RuntimeExtensionHostBuilder, ShredEvent, SlotStatusEvent,
    },
    ingest,
    reassembly::dataset::DataSetReassembler,
    relay::{RecentShredRingBuffer, SharedRelayCache},
    repair::MissingShredTracker,
    shred::{
        fec::FecRecoverer,
        wire::{ParseError, ParsedShredHeader, parse_shred_header},
    },
    verify::{ShredVerifier, VerifyStatus},
};
#[cfg(feature = "gossip-bootstrap")]
pub(super) use arcshift::ArcShift;
pub(super) use crossbeam_queue::ArrayQueue;
pub(super) use solana_entry::entry::{Entry, MaxDataShredsLen};
#[cfg(feature = "gossip-bootstrap")]
pub(super) use solana_gossip::{
    cluster_info::{ClusterInfo, NodeConfig},
    contact_info::ContactInfo,
    gossip_service::GossipService,
    node::Node,
};
#[cfg(feature = "gossip-bootstrap")]
pub(super) use solana_keypair::Keypair;
#[cfg(feature = "gossip-bootstrap")]
pub(super) use solana_net_utils::{
    PortRange, get_cluster_shred_version, get_public_ip_addr_with_binding,
};
#[cfg(feature = "gossip-bootstrap")]
pub(super) use solana_pubkey::Pubkey;
pub(super) use solana_sdk_ids::{compute_budget, vote};
#[cfg(feature = "gossip-bootstrap")]
pub(super) use solana_signer::Signer;
#[cfg(feature = "gossip-bootstrap")]
pub(super) use solana_streamer::{quic::DEFAULT_QUIC_ENDPOINTS, socket::SocketAddrSpace};
pub(super) use tokio::{sync::mpsc, task::JoinHandle, time::interval};
pub(super) use wincode::{
    Deserialize as _,
    containers::{Elem, Vec as WincodeVec},
};