Index

A

AbcBuffer (class in unistream.abstraction) AbcCheckPoint (class in unistream.abstraction)

AbcConsumer (class in unistream.abstraction) AbcProducer (class in unistream.abstraction) AbcRecord (class in unistream.abstraction)

B

BaseBuffer (class in unistream.buffer) BaseCheckPoint (class in unistream.checkpoint) BaseConsumer (class in unistream.consumer)

BaseProducer (class in unistream.producer) BaseRecord (class in unistream.record) BufferIsEmptyError

C

clear_memory_queue() (unistream.buffers.file_buffer.FileBuffer method) clear_wal() (unistream.buffers.file_buffer.FileBuffer method) commit() (unistream.abstraction.AbcBuffer method) (unistream.buffers.file_buffer.FileBuffer method) (unistream.consumer.BaseConsumer method)

create_at_datetime (unistream.abstraction.AbcRecord property)

D

DataClassRecord (class in unistream.records.dataclass) deserialize() (unistream.abstraction.AbcRecord class method) (unistream.records.dataclass.DataClassRecord class method) dump() (unistream.abstraction.AbcCheckPoint method) (unistream.checkpoints.simple.SimpleCheckpoint method) dump_as_failed_or_exhausted() (unistream.abstraction.AbcCheckPoint method) (unistream.checkpoints.simple.SimpleCheckpoint method)

dump_as_in_progress() (unistream.abstraction.AbcCheckPoint method) (unistream.checkpoints.simple.SimpleCheckpoint method) dump_as_succeeded() (unistream.abstraction.AbcCheckPoint method) (unistream.checkpoints.simple.SimpleCheckpoint method) dump_records() (unistream.abstraction.AbcCheckPoint method) (unistream.checkpoints.simple.SimpleCheckpoint method)

E

emit() (unistream.abstraction.AbcBuffer method) (unistream.buffers.file_buffer.FileBuffer method)

F

FileBuffer (class in unistream.buffers.file_buffer)

G

get_not_succeeded_records() (unistream.checkpoint.BaseCheckPoint method) get_records() (unistream.abstraction.AbcConsumer method) (unistream.consumer.BaseConsumer method) (unistream.consumers.simple.SimpleConsumer method)

get_tracker() (unistream.checkpoint.BaseCheckPoint method)

I

is_ready_for_next_batch() (unistream.checkpoint.BaseCheckPoint method)

is_record_locked() (unistream.checkpoint.BaseCheckPoint method)

L

load() (unistream.abstraction.AbcCheckPoint class method) (unistream.checkpoints.simple.SimpleCheckpoint class method)

load_records() (unistream.abstraction.AbcCheckPoint method) (unistream.checkpoints.simple.SimpleCheckpoint method)

M

mark_as_failed_or_exhausted() (unistream.abstraction.AbcCheckPoint method) (unistream.checkpoint.BaseCheckPoint method) mark_as_in_progress() (unistream.abstraction.AbcCheckPoint method) (unistream.checkpoint.BaseCheckPoint method) mark_as_succeeded() (unistream.abstraction.AbcCheckPoint method) (unistream.checkpoint.BaseCheckPoint method) module unistream unistream.abstraction unistream.api unistream.buffer unistream.buffers unistream.buffers.file_buffer unistream.checkpoint unistream.checkpoints unistream.checkpoints.simple unistream.consumer unistream.consumers unistream.consumers.simple unistream.exc unistream.logger unistream.producer unistream.producers unistream.producers.simple unistream.record unistream.records unistream.records.dataclass unistream.utils

N

new() (unistream.abstraction.AbcBuffer class method) (unistream.abstraction.AbcConsumer class method) (unistream.abstraction.AbcProducer class method) (unistream.buffers.file_buffer.FileBuffer class method) (unistream.consumers.simple.SimpleConsumer class method) (unistream.producers.simple.SimpleProducer class method)

P

process_batch() (unistream.consumer.BaseConsumer method) process_failed_record() (unistream.abstraction.AbcConsumer method) (unistream.consumer.BaseConsumer method) process_record() (unistream.abstraction.AbcConsumer method) (unistream.consumer.BaseConsumer method)

ProcessError put() (unistream.abstraction.AbcBuffer method) (unistream.abstraction.AbcProducer method) (unistream.buffers.file_buffer.FileBuffer method) (unistream.producer.BaseProducer method)

R

RetryConfig (class in unistream.producer)

run() (unistream.consumer.BaseConsumer method)

S

send() (unistream.abstraction.AbcProducer method) (unistream.producers.simple.SimpleProducer method) SendError serialize() (unistream.abstraction.AbcRecord method) (unistream.records.dataclass.DataClassRecord method) shall_we_retry() (unistream.producer.RetryConfig method)

should_i_emit() (unistream.abstraction.AbcBuffer method) (unistream.buffers.file_buffer.FileBuffer method) SimpleCheckpoint (class in unistream.checkpoints.simple) SimpleConsumer (class in unistream.consumers.simple) SimpleProducer (class in unistream.producers.simple) StatusEnum (class in unistream.checkpoint) StreamIsClosedError

T

Tracker (class in unistream.checkpoint)

U

unistream module unistream.abstraction module unistream.api module unistream.buffer module unistream.buffers module unistream.buffers.file_buffer module unistream.checkpoint module unistream.checkpoints module unistream.checkpoints.simple module unistream.consumer module unistream.consumers module

unistream.consumers.simple module unistream.exc module unistream.logger module unistream.producer module unistream.producers module unistream.producers.simple module unistream.record module unistream.records module unistream.records.dataclass module unistream.utils module update_for_new_batch() (unistream.checkpoint.BaseCheckPoint method)