whylogs.api.logger.experimental.logger.actor.mp_queue_wrapper#

Module Contents#

Classes#

MPQueueWrapper

Implementation of QueueWrapper sufficient for use in the threaded actor.

Attributes#

MPWrapperType

whylogs.api.logger.experimental.logger.actor.mp_queue_wrapper.MPWrapperType#
class whylogs.api.logger.experimental.logger.actor.mp_queue_wrapper.MPQueueWrapper#

Bases: whylogs.api.logger.experimental.logger.actor.actor.QueueWrapper[MPWrapperType], Generic[MPWrapperType]

Implementation of QueueWrapper sufficient for use in the threaded actor.

send(message: MPWrapperType, timeout: float = DEFAULT_TIMEOUT) → None#
Parameters

  • message (MPWrapperType) –

  • timeout (float) –

Return type

None

send_many(messages: List[MPWrapperType], timeout: float = DEFAULT_TIMEOUT) → None#
Parameters

  • messages (List[MPWrapperType]) –

  • timeout (float) –

Return type

None

get(timeout: float = DEFAULT_TIMEOUT) → Optional[MPWrapperType]#
Parameters

timeout (float) –

Return type

Optional[MPWrapperType]

get_many(timeout: float = DEFAULT_TIMEOUT, max: Optional[int] = None) → List[MPWrapperType]#
Parameters

  • timeout (float) –

  • max (Optional[int]) –

Return type

List[MPWrapperType]

size() → int#
Return type

int

close() → None#
Return type

None