whylogs.api.logger.experimental.logger.actor.faster_fifo_queue_wrapper#

Module Contents#

Classes#

FasterQueueWrapper

Implementation of QueueWrapper sufficient for use in the threaded actor.

Attributes#

FasterQueueMessageType

whylogs.api.logger.experimental.logger.actor.faster_fifo_queue_wrapper.FasterQueueMessageType#
class whylogs.api.logger.experimental.logger.actor.faster_fifo_queue_wrapper.FasterQueueWrapper(config: whylogs.api.logger.experimental.logger.actor.actor.QueueConfig)#

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

Implementation of QueueWrapper sufficient for use in the threaded actor.

Parameters

config (whylogs.api.logger.experimental.logger.actor.actor.QueueConfig) –

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

  • message (FasterQueueMessageType) –

  • timeout (float) –

Return type

None

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

  • messages (List[FasterQueueMessageType]) –

  • timeout (float) –

Return type

None

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

timeout (float) –

Return type

Optional[FasterQueueMessageType]

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

  • timeout (float) –

  • max (Optional[int]) –

Return type

List[FasterQueueMessageType]

size() → int#
Return type

int

close() → None#
Return type

None