Datacratic::FlumeRpcEndpoint Struct Reference

#include <flume_endpoint.h>

List of all members.

Classes
struct	Handler
Public Member Functions
	FlumeRpcEndpoint (int port)
void	init (int port)
void	shutdown ()
void	recordEvent (const std::string &event, EventType type=ET_COUNT, float value=1.0)
Public Attributes
boost::function< void(int64_t timestamp, int priority, const std::string &body, int64_t nanos, const std::string &host, const std::map< std::string, std::string > &meta)>	onFlumeMessage
boost::function< void()>	onClose
std::function< void(std::string, EventType, float)>	onEvent

---

Detailed Description

This class implements an endpoint for the Flume RPC protocol.

Definition at line 28 of file flume_endpoint.h.

---

Member Function Documentation

void Datacratic::FlumeRpcEndpoint::init

(

int

port

)

Initialize to listen on the given port.

Definition at line 116 of file flume_endpoint.cc.

void Datacratic::FlumeRpcEndpoint::recordEvent	(	const std::string &	event,
		EventType	type = ET_COUNT,
		float	value = 1.0
	)		[inline]

Function to record that something has happened.

Definition at line 52 of file flume_endpoint.h.

---

Member Data Documentation

boost::function<void ()> Datacratic::FlumeRpcEndpoint::onClose

Function to be called when we get a close message.

Definition at line 49 of file flume_endpoint.h.

boost::function<void (int64_t timestamp, int priority, const std::string & body, int64_t nanos, const std::string & host, const std::map<std::string, std::string> & meta)> Datacratic::FlumeRpcEndpoint::onFlumeMessage

Function called when we get a Flume message.

Definition at line 46 of file flume_endpoint.h.

---

The documentation for this struct was generated from the following files:

• soa/logger/flume_endpoint.h
• soa/logger/flume_endpoint.cc