proxygen
|
Public Member Functions | |
std::unique_ptr< folly::IOBuf > | encode (std::string &msg) override |
Public Member Functions inherited from wangle::MessageToByteEncoder< std::string > | |
folly::Future< folly::Unit > | write (Context *ctx, std::stringmsg) override |
Public Member Functions inherited from wangle::OutboundHandler< std::string, std::unique_ptr< folly::IOBuf > > | |
~OutboundHandler () override=default | |
virtual folly::Future< folly::Unit > | writeException (Context *ctx, folly::exception_wrapper e) |
virtual folly::Future< folly::Unit > | close (Context *ctx) |
Public Member Functions inherited from wangle::HandlerBase< OutboundHandlerContext< std::unique_ptr< folly::IOBuf > > > | |
virtual | ~HandlerBase ()=default |
virtual void | attachPipeline (OutboundHandlerContext< std::unique_ptr< folly::IOBuf > > *) |
virtual void | detachPipeline (OutboundHandlerContext< std::unique_ptr< folly::IOBuf > > *) |
OutboundHandlerContext< std::unique_ptr< folly::IOBuf > > * | getContext () |
Additional Inherited Members | |
Public Types inherited from wangle::MessageToByteEncoder< std::string > | |
typedef OutboundHandler< std::string, std::unique_ptr< folly::IOBuf > >::Context | Context |
Public Types inherited from wangle::OutboundHandler< std::string, std::unique_ptr< folly::IOBuf > > | |
typedef folly::Unit | rin |
typedef folly::Unit | rout |
typedef std::string | win |
typedef std::unique_ptr< folly::IOBuf > | wout |
typedef OutboundHandlerContext< std::unique_ptr< folly::IOBuf > > | Context |
Static Public Attributes inherited from wangle::OutboundHandler< std::string, std::unique_ptr< folly::IOBuf > > | |
static const HandlerDir | dir |
A simple encoder that encodes strings of messages to IOBuf. This is used in the ObservingPipeline to encode the messages broadcasted by the upstream to IOBuf so that it can be written to the client socket.
Definition at line 89 of file BroadcastProxy.cpp.
|
inlineoverridevirtual |
Implements wangle::MessageToByteEncoder< std::string >.
Definition at line 91 of file BroadcastProxy.cpp.
References folly::IOBuf::copyBuffer().