Class HttpServerSourceStage

• 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 live_endpoint = "/live", std::string ready_endpoint = "/ready", std::string method = "POST", std::string live_method = "GET", std::string ready_method = "GET", 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()