Struct stack_epic_servers::Server

pub struct Server {
    pub config: ServerConfig,
    pub p2p: Arc<Server>,
    pub chain: Arc<Chain>,
    pub tx_pool: ServerTxPool,
    pub sync_state: Arc<SyncState>,
    pub stop_state: Arc<StopState>,
    /* private fields */
}

Epic server holding internal structures.

Fields

config: ServerConfig

server config

p2p: Arc<Server>

handle to our network server

chain: Arc<Chain>

data store access

tx_pool: ServerTxPool

in-memory transaction pool

sync_state: Arc<SyncState>

Whether we’re currently syncing

stop_state: Arc<StopState>

Stop flag

Implementations

impl Server

pub fn start<F>( config: ServerConfig, logs_rx: Option<Receiver<LogEntry>>, info_callback: F, stop_state: Option<Arc<StopState>>, api_chan: &'static mut (Sender<()>, Receiver<()>) ) -> Result<(), Error>

where F: FnMut(Server, Option<Receiver<LogEntry>>),

Instantiates and starts a new server. Optionally takes a callback for the server to send an ARC copy of itself, to allow another process to poll info about the server status

pub fn new( config: ServerConfig, stop_state: Option<Arc<StopState>>, api_chan: &'static mut (Sender<()>, Receiver<()>) ) -> Result<Server, Error>

Instantiates a new server associated with the provided future reactor.

pub fn connect_peer(&self, addr: PeerAddr) -> Result<(), Error>

Asks the server to connect to a peer at the provided network address.

pub fn ping_peers(&self) -> Result<(), Error>

Ping all peers, mostly useful for tests to have connected peers share their heights

pub fn peer_count(&self) -> u32

Number of peers

pub fn start_stratum_server(&self, config: StratumServerConfig)

Start a minimal “stratum” mining service on a separate thread

pub fn start_test_miner( &self, wallet_listener_url: Option<String>, stop_state: Arc<StopState> )

Start mining for blocks internally on a separate thread. Relies on internal miner, and should only be used for automated testing. Burns reward if wallet_listener_url is ‘None’

pub fn head(&self) -> Result<Tip, Error>

The chain head

pub fn header_head(&self) -> Result<Tip, Error>

The head of the block header chain

pub fn protocol_version() -> ProtocolVersion

The p2p layer protocol version for this node.

pub fn get_server_stats(&self) -> Result<ServerStats, Error>

Returns a set of stats about this server. This and the ServerStats structure can be updated over time to include any information needed by tests or other consumers

pub fn stop(self)

Stop the server.

pub fn pause(&self)

Pause the p2p server.

pub fn resume(&self)

Resume p2p server. TODO - We appear not to resume the p2p server (peer connections) here?

pub fn stop_test_miner(&self, stop: Arc<StopState>)

Stops the test miner without stopping the p2p layer