Struct paxakos::node_builder::NodeBuilder

pub struct NodeBuilder<N: Node, V = IndiscriminateVoterFor<N>, B = InMemoryBuffer<RoundNumOf<N>, CoordNumOf<N>, LogEntryOf<N>>> { /* fields omitted */ }

Node builder with all essential information set.

Implementations

impl<N, V, B> NodeBuilder<N, V, B> where
    N: NodeImpl + 'static,
    V: Voter<State = StateOf<N>, RoundNum = RoundNumOf<N>, CoordNum = CoordNumOf<N>, Abstain = AbstainOf<N>, Yea = YeaOf<N>, Nay = NayOf<N>>,
    B: Buffer<RoundNum = RoundNumOf<N>, CoordNum = CoordNumOf<N>, Entry = LogEntryOf<N>>, 

pub fn buffering_applied_entries_in<T: Buffer<RoundNum = RoundNumOf<N>, CoordNum = CoordNumOf<N>, Entry = LogEntryOf<N>>>(
    self,
    buffer: T
) -> NodeBuilder<N, V, T>

Sets the applied entry buffer.

pub fn traced_by<T: Into<Box<dyn Tracer<InvocationOf<N>>>>>(
    self,
    tracer: T
) -> Self

Tracer to record events with.

pub fn voting_with<T>(self, voter: T) -> NodeBuilder<N, T, B>

Sets the voting strategy to use.

pub fn using(self, kit: NodeKit<InvocationOf<N>>) -> Self

Sets the node kit to use.

pub fn decorated_with<D>(
    self,
    arguments: <D as Decoration>::Arguments
) -> NodeBuilder<D, V, B> where
    D: Decoration<Decorated = N, Invocation = InvocationOf<N>, Communicator = CommunicatorOf<N>>, 

Adds a decoration to wrap around the resulting node.

pub fn spawn(
    self
) -> LocalBoxFuture<'static, SpawnResult<(RequestHandlerFor<N>, Shell<N>)>> where
    StateOf<N>: State<Context = ()>, 

Spawns the node into context ().

pub fn spawn_in(
    self,
    context: ContextOf<N>
) -> LocalBoxFuture<'static, SpawnResult<(RequestHandlerFor<N>, Shell<N>)>>

Spawns the node in the given context.

Trait Implementations

impl<N, V, B> AutofillBuilderExt for NodeBuilder<N, V, B> where
    N: NodeImpl + 'static,
    V: Voter<State = StateOf<N>, RoundNum = RoundNumOf<N>, CoordNum = CoordNumOf<N>, Abstain = AbstainOf<N>, Yea = YeaOf<N>, Nay = NayOf<N>>,
    B: Buffer<RoundNum = RoundNumOf<N>, CoordNum = CoordNumOf<N>, Entry = LogEntryOf<N>>, 

type Node = N

Node type to be decorated.

type Voter = V

Voter type.

type Buffer = B

Buffer type.

fn fill_gaps<C>(
    self,
    config: C
) -> NodeBuilder<Autofill<Self::Node, C>, Self::Voter, Self::Buffer> where
    C: Config<Node = Self::Node> + 'static, 

Decorates the node with Autofill using the given configuration.

impl<N, V, B> EnsureLeadershipBuilderExt for NodeBuilder<N, V, B> where
    N: NodeImpl + 'static,
    V: Voter<State = StateOf<N>, RoundNum = RoundNumOf<N>, CoordNum = CoordNumOf<N>, Abstain = AbstainOf<N>, Yea = YeaOf<N>, Nay = NayOf<N>>,
    B: Buffer<RoundNum = RoundNumOf<N>, CoordNum = CoordNumOf<N>, Entry = LogEntryOf<N>>, 

type Node = N

type Voter = V

type Buffer = B

fn ensure_leadership<C, P>(
    self,
    configure: C
) -> NodeBuilder<EnsureLeadership<Self::Node, P>, Self::Voter, Self::Buffer> where
    C: FnOnce(EnsureLeadershipBuilderBlank<N>) -> EnsureLeadershipBuilder<N, P>,
    P: Fn() -> LogEntryOf<N> + 'static, 

impl<N, V, B, I> HeartbeatsBuilderExt<I> for NodeBuilder<N, V, B> where
    N: NodeImpl + MaybeLeadershipAwareNode<I> + 'static,
    V: Voter<State = StateOf<N>, RoundNum = RoundNumOf<N>, CoordNum = CoordNumOf<N>, Abstain = AbstainOf<N>, Yea = YeaOf<N>, Nay = NayOf<N>>,
    B: Buffer<RoundNum = RoundNumOf<N>, CoordNum = CoordNumOf<N>, Entry = LogEntryOf<N>>, 

type Node = N

Node type to be decorated.

type Voter = V

Voter type.

type Buffer = B

Buffer type.

fn send_heartbeats<C>(
    self,
    config: C
) -> NodeBuilder<Heartbeats<Self::Node, C, I>, Self::Voter, Self::Buffer> where
    C: Config<Node = Self::Node> + 'static, 

Decorates the node with Heartbeats using the given configuration.

impl<N, V, B> MasterLeasesBuilderExt for NodeBuilder<N, V, B> where
    N: NodeImpl + 'static,
    V: Voter<State = StateOf<N>, RoundNum = RoundNumOf<N>, CoordNum = CoordNumOf<N>, Abstain = AbstainOf<N>, Yea = YeaOf<N>, Nay = NayOf<N>>,
    B: Buffer<RoundNum = RoundNumOf<N>, CoordNum = CoordNumOf<N>, Entry = LogEntryOf<N>>, 

type Node = N

type Voter = V

type Buffer = B

fn maintain_master_lease<C>(
    self,
    communicator_subscription: Subscription<NodeIdOf<Self::Node>>,
    voter_subscription: Subscription<NodeIdOf<Self::Node>>,
    config: C
) -> NodeBuilder<MasterLeases<Self::Node, C>, Self::Voter, Self::Buffer> where
    C: Config<Node = Self::Node> + 'static, 

impl<N, V, B> ReleaserBuilderExt for NodeBuilder<N, V, B> where
    N: NodeImpl + 'static,
    EventOf<N>: AsLeaseEvent,
    V: Voter<State = StateOf<N>, RoundNum = RoundNumOf<N>, CoordNum = CoordNumOf<N>, Abstain = AbstainOf<N>, Yea = YeaOf<N>, Nay = NayOf<N>>,
    B: Buffer<RoundNum = RoundNumOf<N>, CoordNum = CoordNumOf<N>, Entry = LogEntryOf<N>>, 

type Node = N

type Voter = V

type Buffer = B

fn release_leases<C, P>(
    self,
    configure: C
) -> NodeBuilder<Releaser<Self::Node, P>, Self::Voter, Self::Buffer> where
    EventOf<N>: AsLeaseEvent,
    C: FnOnce(ReleaserBuilderBlank<N>) -> ReleaserBuilder<N, P>,
    P: Fn(<<EventOf<N> as AsLeaseEvent>::Lease as Lease>::Id) -> LogEntryOf<N> + 'static, 

impl<N, V, B> TrackLeadershipBuilderExt for NodeBuilder<N, V, B> where
    N: NodeImpl + 'static,
    V: Voter<State = StateOf<N>, RoundNum = RoundNumOf<N>, CoordNum = CoordNumOf<N>, Abstain = AbstainOf<N>, Yea = YeaOf<N>, Nay = NayOf<N>>,
    B: Buffer<RoundNum = RoundNumOf<N>, CoordNum = CoordNumOf<N>, Entry = LogEntryOf<N>>, 

type Node = N

type Voter = V

type Buffer = B

fn track_leadership(
    self
) -> NodeBuilder<TrackLeadership<Self::Node>, Self::Voter, Self::Buffer>