pub struct NodeBuilder<B, S>where
B: Blockstore + 'static,
S: Store + 'static,{ /* private fields */ }
Expand description
Node
builder.
Implementations§
Source§impl NodeBuilder<InMemoryBlockstore, InMemoryStore>
impl NodeBuilder<InMemoryBlockstore, InMemoryStore>
Sourcepub fn new() -> Self
pub fn new() -> Self
Creates a new NodeBuilder
which uses in-memory stores.
After the creation you can call NodeBuilder::blockstore
and NodeBuilder::store
to use other stores.
§Example
let node = NodeBuilder::new()
.network(Network::Mainnet)
.start()
.await
.unwrap();
Source§impl<B, S> NodeBuilder<B, S>where
B: Blockstore + 'static,
S: Store + 'static,
impl<B, S> NodeBuilder<B, S>where
B: Blockstore + 'static,
S: Store + 'static,
Sourcepub async fn start_subscribed(self) -> Result<(Node<B, S>, EventSubscriber)>
pub async fn start_subscribed(self) -> Result<(Node<B, S>, EventSubscriber)>
Creates and starts a new Celestia Node
.
Returns Node
along with EventSubscriber
. Use this to avoid missing
any events that will be generated on the construction of the node.
Sourcepub fn blockstore<B2>(self, blockstore: B2) -> NodeBuilder<B2, S>where
B2: Blockstore + 'static,
pub fn blockstore<B2>(self, blockstore: B2) -> NodeBuilder<B2, S>where
B2: Blockstore + 'static,
Set the Blockstore
for Bitswap.
Default: InMemoryBlockstore
Sourcepub fn store<S2>(self, store: S2) -> NodeBuilder<B, S2>where
S2: Store + 'static,
pub fn store<S2>(self, store: S2) -> NodeBuilder<B, S2>where
S2: Store + 'static,
Set the Store
for headers.
Default: InMemoryStore
Sourcepub fn keypair(self, keypair: Keypair) -> Self
pub fn keypair(self, keypair: Keypair) -> Self
Set the keypair to be used as Node
s identity.
Default: Random generated with Keypair::generate_ed25519
.
Sourcepub fn bootnodes<I>(self, addrs: I) -> Selfwhere
I: IntoIterator<Item = Multiaddr>,
pub fn bootnodes<I>(self, addrs: I) -> Selfwhere
I: IntoIterator<Item = Multiaddr>,
Set the bootstrap nodes to connect and trust.
Default: Network::canonical_bootnodes
Sourcepub fn listen<I>(self, addrs: I) -> Selfwhere
I: IntoIterator<Item = Multiaddr>,
pub fn listen<I>(self, addrs: I) -> Selfwhere
I: IntoIterator<Item = Multiaddr>,
Set the addresses where Node
will listen for incoming connections.
Sourcepub fn sync_batch_size(self, batch_size: u64) -> Self
pub fn sync_batch_size(self, batch_size: u64) -> Self
Maximum number of headers in batch while syncing.
Default: 512
Sourcepub fn sampling_window(self, dur: Duration) -> Self
pub fn sampling_window(self, dur: Duration) -> Self
Set sampling window.
Sampling window defines maximum age of a block considered for syncing and sampling.
Default if InMemoryStore
/InMemoryBlockstore
are used: 60 seconds.
Default: 30 days.
Minimum: 60 seconds.
Sourcepub fn pruning_delay(self, dur: Duration) -> Self
pub fn pruning_delay(self, dur: Duration) -> Self
Set pruning delay.
Pruning delay defines how much time the pruner should wait after sampling window in order to prune the block.
Default if InMemoryStore
/InMemoryBlockstore
are used: 60 seconds.
Default: 1 hour.
Minimum: 60 seconds.
Trait Implementations§
Source§impl Default for NodeBuilder<InMemoryBlockstore, InMemoryStore>
impl Default for NodeBuilder<InMemoryBlockstore, InMemoryStore>
Auto Trait Implementations§
impl<B, S> Freeze for NodeBuilder<B, S>
impl<B, S> RefUnwindSafe for NodeBuilder<B, S>where
B: RefUnwindSafe,
S: RefUnwindSafe,
impl<B, S> Send for NodeBuilder<B, S>
impl<B, S> Sync for NodeBuilder<B, S>
impl<B, S> Unpin for NodeBuilder<B, S>
impl<B, S> UnwindSafe for NodeBuilder<B, S>where
B: UnwindSafe,
S: UnwindSafe,
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> FmtForward for T
impl<T> FmtForward for T
Source§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
self
to use its Binary
implementation when Debug
-formatted.Source§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
self
to use its Display
implementation when
Debug
-formatted.Source§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
self
to use its LowerExp
implementation when
Debug
-formatted.Source§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
self
to use its LowerHex
implementation when
Debug
-formatted.Source§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
self
to use its Octal
implementation when Debug
-formatted.Source§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
self
to use its Pointer
implementation when
Debug
-formatted.Source§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
self
to use its UpperExp
implementation when
Debug
-formatted.Source§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
self
to use its UpperHex
implementation when
Debug
-formatted.Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
Source§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
Source§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read moreSource§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read moreSource§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
Source§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
Source§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
self
, then passes self.as_ref()
into the pipe function.Source§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
self
, then passes self.as_mut()
into the pipe
function.Source§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self
, then passes self.deref()
into the pipe function.Source§impl<T> Tap for T
impl<T> Tap for T
Source§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B>
of a value. Read moreSource§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B>
of a value. Read moreSource§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R>
view of a value. Read moreSource§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R>
view of a value. Read moreSource§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target
of a value. Read moreSource§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target
of a value. Read moreSource§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap()
only in debug builds, and is erased in release builds.Source§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut()
only in debug builds, and is erased in release
builds.Source§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.tap_borrow()
only in debug builds, and is erased in release
builds.Source§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.tap_borrow_mut()
only in debug builds, and is erased in release
builds.Source§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.tap_ref()
only in debug builds, and is erased in release
builds.Source§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.tap_ref_mut()
only in debug builds, and is erased in release
builds.Source§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref()
only in debug builds, and is erased in release
builds.