Defined in File http_server_source_stage.hpp
Base Type
public mrc::pymrc::PythonSource< std::shared_ptr< MessageMeta > >
-
class HttpServerSourceStage : public mrc::pymrc::PythonSource<std::shared_ptr<MessageMeta>>
-
Public Types
- using base_t = mrc::pymrc::PythonSource<std::shared_ptr<MessageMeta>>
Public Functions
- HttpServerSourceStage(std::string bind_address = "127.0.0.1", unsigned short port = 8080, std::string endpoint = "/message", std::string method = "POST", unsigned accept_status = 201, float sleep_time = 0.1f, long queue_timeout = 5, std::size_t max_queue_size = 1024, unsigned short num_server_threads = 1, std::size_t max_payload_size = DefaultMaxPayloadSize, std::chrono::seconds request_timeout = std::chrono::seconds(30), bool lines = false, std::size_t stop_after = 0)
- ~HttpServerSourceStage() override
- void close()