bec_lib.tests.utils.ConnectorMock

class ConnectorMock(bootstrap_server='localhost:0000', store_data=True)

Bases: ConnectorBase

Methods

delete	Delete a key
execute_pipeline	Execute a pipeline
get	Get a value
keys	Get keys that match the pattern
log_error	send an error as log
log_message	send a log message
log_warning	send a warning
lpush	Push a message to the left of the list
lrange	Get a range of values from the list
lset	Set a value in the list at the given index
pipeline	Create a pipeline for batch operations
poll_messages	Poll for new messages, receive them and execute callbacks
producer
raise_alarm
raise_warning	Raise a warning
raw_send	Send a raw message without using the BECMessage class
register	Register a callback for a topic or pattern
rpush	Push a message to the right of the list
send	Send a message
set	Set a value
set_and_publish	Set a value and publish it
shutdown	Shutdown the connector
unregister	Unregister a callback for a topic or pattern
xadd	Add a message to the stream
xrange	Read from the stream
xread	Read from the stream

delete(topic, pipe=None)

Delete a key

execute_pipeline(pipeline)

Execute a pipeline

get(topic, pipe=None)

Get a value

keys(*args, **kwargs)

Get keys that match the pattern

log_error(*args, **kwargs)

send an error as log

log_message(msg)

send a log message

log_warning(msg)

send a warning

lpush(topic, msg, pipe=None, max_size=None)

Push a message to the left of the list

lrange(topic, start, stop, pipe=None)

Get a range of values from the list

lset(topic: str, index: int, msgs: str, pipe=None) → None

Set a value in the list at the given index

pipeline()

Create a pipeline for batch operations

poll_messages(*args, **kwargs)

Poll for new messages, receive them and execute callbacks

raise_warning(msg)

Raise a warning

raw_send(topic, msg, pipe=None)

Send a raw message without using the BECMessage class

register(*args, **kwargs)

Register a callback for a topic or pattern

rpush(topic, msg, pipe=None)

Push a message to the right of the list

send(topic, msg, pipe=None)

Send a message

set(topic, msg, pipe=None, expire: int | None = None)

Set a value

set_and_publish(topic, msg, pipe=None, expire: int | None = None)

Set a value and publish it

shutdown()

Shutdown the connector

unregister(*args, **kwargs)

Unregister a callback for a topic or pattern

xadd(topic, msg_dict, max_size=None, pipe=None, expire: int | None = None)

Add a message to the stream

xrange(topic, min='-', max='+', pipe=None)

Read from the stream

xread(topic, id=None, count=None, block=None, pipe=None, from_start=False)

Read from the stream