CollectorService

* Collector Service actor * Sends: * (dartReadRR, immutable(DARTIndex)[]) to TaskNames.dart * (consensusContract(), immutable(CollectedSignedContract)*) to TaskNames.tvm * (signedContract(), immutable(CollectedSignedContract)*) to TaskNames.tvm

@safe

struct CollectorService {

ActorHandle dart_handle;

ActorHandle tvm_handle;

this(immutable(TaskNames) tn);

immutable(SignedContract)*[uint] contracts;

bool[uint] is_consensus_contract;

immutable(Document)[][uint] reads;

Topic reject;

SecureNet net;

void task();

void read_indices(dartReadRR req, immutable(SignedContract)* s_contract);

void consensus_signed_contract(consensusContract , immutable(SignedContract*)[] signed_contracts);

void signed_contract(inputContract , immutable(SignedContract)* s_contract);

void rpc_contract(inputHiRPC , immutable(HiRPC.Receiver) receiver);

void receive_recorder(dartReadRR.Response res, immutable(RecordFactory.Recorder) recorder);

}

Constructors

this this(immutable(TaskNames) tn): Undocumented in source.

Members

Functions

consensus_signed_contract void consensus_signed_contract(consensusContract , immutable(SignedContract*)[] signed_contracts): Undocumented in source. Be warned that the author may not have intended to support it.
read_indices void read_indices(dartReadRR req, immutable(SignedContract)* s_contract): Undocumented in source. Be warned that the author may not have intended to support it.
receive_recorder void receive_recorder(dartReadRR.Response res, immutable(RecordFactory.Recorder) recorder): Undocumented in source. Be warned that the author may not have intended to support it.
rpc_contract void rpc_contract(inputHiRPC , immutable(HiRPC.Receiver) receiver): Undocumented in source. Be warned that the author may not have intended to support it.
signed_contract void signed_contract(inputContract , immutable(SignedContract)* s_contract): Undocumented in source. Be warned that the author may not have intended to support it.
task void task(): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

contracts immutable(SignedContract)*[uint] contracts;: Undocumented in source.
dart_handle ActorHandle dart_handle;: Undocumented in source.
is_consensus_contract bool[uint] is_consensus_contract;: Undocumented in source.
net SecureNet net;: Undocumented in source.
reads immutable(Document)[][uint] reads;: Undocumented in source.
reject Topic reject;: Undocumented in source.
tvm_handle ActorHandle tvm_handle;: Undocumented in source.

CollectorService

Constructors

Members

Functions

Variables

Meta

Source