StreamState Class Reference

#include <StreamState.h>

List of all members.

Public Types
enum	Class { INJECT, OTHER }
Public Member Functions
bool	is_injected_stream ()
	StreamState (Name stream_name, ptr< StreamDef > stream_def, Class clazz)
string	as_string () const
string	repr () const
ptr< StreamDef >	get_stream_def () const
void	set_definition (ptr< StreamDef > str)
const Name &	get_name () const
Schema	get_schema () const
void	incrStats (double tuples, double bytes)
void	endStatPeriod (double delta_time_msecs)
stream_stats	getStreamStats ()
double	n_tuples ()
Public Attributes
int	m_class
vector< Subscription >	m_fast_subs
bool	m_subscribed
pair< MedusaID, Subscription >	m_sub
int	m_nb_queries
StreamBuffer	m_buffer
double	m_tuples
double	m_bytes
stream_stats	m_stream_stats

---

Member Enumeration Documentation

enum StreamState::Class

Enumeration values: INJECT  OTHER

---

Constructor & Destructor Documentation

StreamState::StreamState (  Name  stream_name, ptr< StreamDef >  stream_def, Class  clazz )

---

Member Function Documentation

string StreamState::as_string (   )  const

void StreamState::endStatPeriod (  double  delta_time_msecs  )

const Name& StreamState::get_name (   )  const

Schema StreamState::get_schema (   )  const

ptr<StreamDef> StreamState::get_stream_def (   )  const

stream_stats StreamState::getStreamStats (   )

void StreamState::incrStats (  double  tuples, double  bytes )

bool StreamState::is_injected_stream (   )

double StreamState::n_tuples (   )

string StreamState::repr (   )  const

void StreamState::set_definition (  ptr< StreamDef >  str  )

---

Member Data Documentation

StreamBuffer StreamState::m_buffer

double StreamState::m_bytes

int StreamState::m_class

vector<Subscription> StreamState::m_fast_subs

int StreamState::m_nb_queries

stream_stats StreamState::m_stream_stats

pair<MedusaID,Subscription> StreamState::m_sub

bool StreamState::m_subscribed

double StreamState::m_tuples

---

The documentation for this class was generated from the following file:

• StreamState.h

---