6 #ifndef TORII_COMMAND_SERVICE_TRANSPORT_GRPC_HPP 7 #define TORII_COMMAND_SERVICE_TRANSPORT_GRPC_HPP 11 #include <rxcpp/rx-lite.hpp> 12 #include "endpoint.grpc.pb.h" 13 #include "endpoint.pb.h" 26 class TxStatusFactory;
27 class TransactionBatchParser;
28 class TransactionBatchFactory;
35 :
public iroha::protocol::CommandService_v1::Service {
58 std::shared_ptr<CommandService> command_service,
59 std::shared_ptr<iroha::torii::StatusBus> status_bus,
60 std::shared_ptr<shared_model::interface::TxStatusFactory>
62 std::shared_ptr<TransportFactoryType> transaction_factory,
63 std::shared_ptr<shared_model::interface::TransactionBatchParser>
65 std::shared_ptr<shared_model::interface::TransactionBatchFactory>
66 transaction_batch_factory,
67 rxcpp::observable<ConsensusGateEvent> consensus_gate_objects,
68 int maximum_rounds_without_update,
78 grpc::Status Torii(grpc::ServerContext *context,
80 google::protobuf::Empty *response)
override;
89 grpc::Status ListTorii(grpc::ServerContext *context,
90 const iroha::protocol::TxList *request,
91 google::protobuf::Empty *response)
override;
102 grpc::Status Status(grpc::ServerContext *context,
103 const iroha::protocol::TxStatusRequest *request,
104 iroha::protocol::ToriiResponse *response)
override;
115 grpc::Status StatusStream(
116 grpc::ServerContext *context,
117 const iroha::protocol::TxStatusRequest *request,
118 grpc::ServerWriter<iroha::protocol::ToriiResponse> *response_writer)
122 std::shared_ptr<CommandService> command_service_;
123 std::shared_ptr<iroha::torii::StatusBus> status_bus_;
124 std::shared_ptr<shared_model::interface::TxStatusFactory> status_factory_;
125 std::shared_ptr<TransportFactoryType> transaction_factory_;
126 std::shared_ptr<shared_model::interface::TransactionBatchParser>
128 std::shared_ptr<shared_model::interface::TransactionBatchFactory>
132 rxcpp::observable<ConsensusGateEvent> consensus_gate_objects_;
133 const int maximum_rounds_without_update_;
138 #endif // TORII_COMMAND_SERVICE_TRANSPORT_GRPC_HPP Definition: command_client.hpp:16
std::shared_ptr< Logger > LoggerPtr
Definition: logger_fwd.hpp:22
Definition: block_query.hpp:14
Definition: command_service_transport_grpc.hpp:42
Definition: command_executor.hpp:12
Definition: query_service.hpp:24
Definition: transaction.hpp:23
Definition: command_service_transport_grpc.hpp:34