kilda.probe.messaging Namespace Reference

Classes
class	ExitFromLoop

Functions
def	send_with_context (context, message)
def	send (bootstrap_servers, topic, message)
def	receive_with_context_async (context, expected_count=None)
def	receive_with_context (context, callback, offset=None)
def	receive (bootstrap_servers, topic, callback, offset)
def	get_last_offset_with_context (context)
def	progress ()

Variables
	LOG = logging.getLogger(__name__)

Function Documentation

get_last_offset_with_context()

def kilda.probe.messaging.get_last_offset_with_context

(

context

)

Definition at line 95 of file messaging.py.

progress()

def kilda.probe.messaging.progress

(

)

Definition at line 107 of file messaging.py.

receive()

def kilda.probe.messaging.receive	(		bootstrap_servers,
			topic,
			callback,
			offset
	)

Definition at line 80 of file messaging.py.

receive_with_context()

def kilda.probe.messaging.receive_with_context	(		context,
			callback,
			offset = None
	)

Definition at line 75 of file messaging.py.

receive_with_context_async()

def kilda.probe.messaging.receive_with_context_async	(		context,
			expected_count = None
	)

Definition at line 43 of file messaging.py.

send()

def kilda.probe.messaging.send	(		bootstrap_servers,
			topic,
			message
	)

Definition at line 32 of file messaging.py.

send_with_context()

def kilda.probe.messaging.send_with_context	(		context,
			message
	)

Definition at line 28 of file messaging.py.

Variable Documentation

LOG

kilda.probe.messaging.LOG = logging.getLogger(__name__)

Definition at line 25 of file messaging.py.