simple_service Member List

This is the complete list of members for simple_service, including all inherited members.

add_async_child(endpoint_ptr_t a_endpoint_ptr)	service
add_child(endpoint_ptr_t a_endpoint_ptr)	service
async_map_t typedef	service
authenticate(const uuid_t &a_key) const	endpoint	protected
bind_key(amqp_channel_ptr a_channel, const std::string &a_exchange, const std::string &a_queue_name, const std::string &a_routing_key)	core	protectedstatic
bind_keys()	service	protectedvirtual
check_key(const uuid_t &a_key) const	endpoint	inline
clock_t typedef	scheduler<>
concurrent_receiver()	concurrent_receiver
concurrent_receiver(const concurrent_receiver &)=delete	concurrent_receiver
concurrent_receiver(concurrent_receiver &&a_orig)	concurrent_receiver
core(const scarab::param_node &a_config=scarab::param_node(), const std::string &a_broker_address="", unsigned a_port=0, const std::string &a_auth_file="", const bool a_make_connection=true)	core
core(const bool a_make_connection, const scarab::param_node &a_config=scarab::param_node())	core
core(const core &a_orig)	core
core(core &&a_orig)	core
disable_lockout(const uuid_t &a_key, bool a_force=false)	endpoint
do_cmd_request(const request_ptr_t a_request)	simple_service	virtual
do_get_request(const request_ptr_t a_request)	simple_service	inlinevirtual
do_run_request(const request_ptr_t a_request)	simple_service	inlinevirtual
do_send(message_ptr_t a_message, const std::string &a_exchange, bool a_expect_reply) const	core	protected
do_set_request(const request_ptr_t a_request)	simple_service	inlinevirtual
duration_t typedef	scheduler<>
enable_lockout(const scarab::param_node &a_tag)	endpoint	inline
enable_lockout(const scarab::param_node &a_tag, uuid_t a_key)	endpoint
endpoint(const std::string &a_name)	endpoint
endpoint(const endpoint &a_orig)	endpoint
endpoint(endpoint &&a_orig)	endpoint
events_map_t typedef	scheduler<>
executable_t typedef	scheduler<>
execute()	simple_service
dripline::service::execute(const std::string &a_name, uuid_t a_id, const std::string &a_routing_key)	heartbeater
f_cv	scheduler<>
f_executor_mutex	scheduler<>
f_heartbeat_thread	heartbeater	protected
f_scheduler_mutex	scheduler<>
f_scheduler_thread	scheduler<>
handle_message_chunk(amqp_envelope_ptr a_envelope)	receiver
heartbeater(service_ptr_t a_service=service_ptr_t())	heartbeater
heartbeater(const heartbeater &)=delete	heartbeater
heartbeater(heartbeater &&a_orig)	heartbeater
is_locked() const	endpoint	inline
listen()	service
listen_for_message(amqp_envelope_ptr &a_envelope, amqp_channel_ptr a_channel, const std::string &a_consumer_tag, int a_timeout_ms=0, bool a_do_ack=true)	core	static
listen_on_queue()	service	virtual
listener()	listener
listener(const listener &)=delete	listener
listener(listener &&a_orig)	listener
listener_receiver()	listener_receiver	inline
listener_receiver(const listener_receiver &)=delete	listener_receiver
listener_receiver(listener_receiver &&a_orig)	listener_receiver	inline
mv_accessible(int, return)	simple_service
on_alert_message(const alert_ptr_t a_alert)	endpoint	virtual
on_reply_message(const reply_ptr_t a_reply)	endpoint	virtual
on_request_message(const request_ptr_t a_request)	service	protectedvirtual
open_channel() const	core	protected
open_channels()	service	protectedvirtual
operator=(const service &)=delete	service
operator=(service &&a_orig)	service
dripline::core::operator=(const core &a_orig)	core
dripline::core::operator=(core &&a_orig)	core
dripline::endpoint::operator=(const endpoint &a_orig)	endpoint
dripline::endpoint::operator=(endpoint &&a_orig)	endpoint
dripline::listener_receiver::operator=(const listener_receiver &)=delete	listener_receiver
dripline::listener_receiver::operator=(listener_receiver &&a_orig)	listener_receiver	inline
dripline::listener::operator=(const listener &)=delete	listener
dripline::listener::operator=(listener &&a_orig)	listener
dripline::concurrent_receiver::operator=(const concurrent_receiver &)=delete	concurrent_receiver
dripline::concurrent_receiver::operator=(concurrent_receiver &&a_orig)	concurrent_receiver
dripline::receiver::operator=(const receiver &a_orig)=delete	receiver
dripline::receiver::operator=(receiver &&a_orig)	receiver
dripline::heartbeater::operator=(const heartbeater &)=delete	heartbeater
dripline::heartbeater::operator=(heartbeater &&a_orig)	heartbeater
scheduler<>::operator=(const scheduler &)=delete	scheduler<>
scheduler<>::operator=(scheduler &&)	scheduler<>
process_message(message_ptr_t a_message)	concurrent_receiver	virtual
process_message_pack(incoming_message_pack &a_pack, const std::string &a_message_id)	receiver
process_received_reply(incoming_message_pack &a_pack, const std::string &a_message_id)	receiver	protected
receiver()	receiver
dripline::listener_receiver::receiver(const receiver &a_orig)=delete	receiver
dripline::listener_receiver::receiver(receiver &&a_orig)	receiver
remove_queue()	service	protectedvirtual
dripline::core::remove_queue(amqp_channel_ptr a_channel, const std::string &a_queue_name)	core	protectedstatic
s_offline	core	static
schedule(executable_t an_executable, time_point_t an_exe_time)	scheduler<>
schedule(executable_t an_executable, duration_t an_interval, time_point_t an_exe_time=std::chrono::system_clock ::now())	scheduler<>
scheduler()	scheduler<>
scheduler(const scheduler &)=delete	scheduler<>
scheduler(scheduler &&)	scheduler<>
send(request_ptr_t a_request) const	service	inlinevirtual
send(reply_ptr_t a_reply) const	service	inlinevirtual
send(alert_ptr_t a_alert) const	service	inlinevirtual
send_noreply(message_ptr_t a_message, const std::string &a_exchange) const	core	protected
send_reply(reply_ptr_t a_reply) const	service	virtual
send_withreply(message_ptr_t a_message, std::string &a_reply_consumer_tag, const std::string &a_exchange) const	core	protected
service(const scarab::param_node &a_config=scarab::param_node(), const std::string &a_queue_name="", const std::string &a_broker_address="", unsigned a_port=0, const std::string &a_auth_file="", const bool a_make_connection=true)	service
service(const bool a_make_connection, const scarab::param_node &a_config=scarab::param_node())	service
service(const service &)=delete	service
service(service &&a_orig)	service
setup_exchange(amqp_channel_ptr a_channel, const std::string &a_exchange)	core	protectedstatic
setup_queue(amqp_channel_ptr a_channel, const std::string &a_queue_name)	core	protectedstatic
setup_queues()	service	protectedvirtual
simple_service(const scarab::param_node &a_config=scarab::param_node())	simple_service
snake_case_mv_accessible(status, status)	service
snake_case_mv_accessible(bool, enable_scheduling)	service
snake_case_mv_accessible(uuid_t, id)	service
dripline::core::snake_case_mv_accessible(unsigned, port)	core
dripline::core::snake_case_mv_accessible(unsigned, max_payload_size)	core
dripline::core::snake_case_mv_accessible(bool, make_connection)	core
dripline::endpoint::snake_case_mv_accessible(uuid_t, lockout_key)	endpoint	protected
dripline::listener_receiver::snake_case_mv_accessible(unsigned, listen_timeout_ms)	listener
dripline::listener_receiver::snake_case_mv_accessible(unsigned, single_message_wait_ms)	receiver
dripline::heartbeater::snake_case_mv_accessible(unsigned, heartbeat_interval_s)	heartbeater
dripline::heartbeater::snake_case_mv_accessible(unsigned, check_timeout_ms)	heartbeater
scheduler<>::snake_case_mv_accessible(duration_t, exe_buffer)	scheduler<>
scheduler<>::snake_case_mv_accessible(duration_t, cycle_time)	scheduler<>
snake_case_mv_atomic(bool, stop)	heartbeater
snake_case_mv_referrable(sync_map_t, sync_children)	service
snake_case_mv_referrable(async_map_t, async_children)	service
snake_case_mv_referrable(std::string, broadcast_key)	service
dripline::core::snake_case_mv_referrable(std::string, address)	core
dripline::core::snake_case_mv_referrable(std::string, username)	core
dripline::core::snake_case_mv_referrable(std::string, password)	core
dripline::core::snake_case_mv_referrable(std::string, requests_exchange)	core
dripline::core::snake_case_mv_referrable(std::string, alerts_exchange)	core
dripline::core::snake_case_mv_referrable(std::string, heartbeat_routing_key)	core
dripline::endpoint::snake_case_mv_referrable(std::string, name)	endpoint
dripline::endpoint::snake_case_mv_referrable(service_ptr_t, service)	endpoint
dripline::endpoint::snake_case_mv_referrable(scarab::param_node, lockout_tag)	endpoint	protected
dripline::listener_receiver::snake_case_mv_referrable(amqp_channel_ptr, channel)	listener
dripline::listener_receiver::snake_case_mv_referrable(std::string, consumer_tag)	listener
dripline::listener_receiver::snake_case_mv_referrable(std::thread, listener_thread)	listener
dripline::listener_receiver::snake_case_mv_referrable(scarab::concurrent_queue< message_ptr_t >, message_queue)	concurrent_receiver	protected
dripline::concurrent_receiver::snake_case_mv_referrable(std::thread, receiver_thread)	concurrent_receiver	protected
dripline::receiver::snake_case_mv_referrable(incoming_message_map, incoming_messages)	receiver
dripline::heartbeater::snake_case_mv_referrable(service_ptr_t, service)	heartbeater
snake_case_mv_referrable_const(simple_executor, the_executor)	scheduler<>
snake_case_mv_referrable_const(events_map_t, events)	scheduler<>
sort_message(const message_ptr_t a_request)	endpoint
start()	service
start_consuming()	service	protectedvirtual
dripline::core::start_consuming(amqp_channel_ptr a_channel, const std::string &a_queue_name)	core	protectedstatic
status enum name	service	protected
stop()	service
stop_consuming()	service	protectedvirtual
dripline::core::stop_consuming(amqp_channel_ptr a_channel, std::string &a_consumer_tag)	core	protectedstatic
submit_alert_message(const alert_ptr_t a_alert)	endpoint
submit_message(message_ptr_t a_message)	service	virtual
submit_reply_message(const reply_ptr_t a_reply)	endpoint
submit_request_message(const request_ptr_t a_request)	endpoint
sync_map_t typedef	service
time_point_t typedef	scheduler<>
unschedule(int an_id)	scheduler<>
wait_for_message(incoming_message_pack &a_pack, const std::string &a_message_id)	receiver
wait_for_reply(const sent_msg_pkg_ptr a_receive_reply, int a_timeout_ms=0)	receiver
wait_for_reply(const sent_msg_pkg_ptr a_receive_reply, bool &a_chan_valid, int a_timeout_ms=0)	receiver
~concurrent_receiver()	concurrent_receiver	virtual
~core()	core	virtual
~endpoint()	endpoint	virtual
~heartbeater()	heartbeater	virtual
~listener()	listener	virtual
~receiver()	receiver	virtual
~scheduler()	scheduler<>	virtual
~service()	service	virtual
~simple_service()	simple_service	virtual