Index A | B | C | D | E | F | G | I | K | L | M | N | P | R | S | T | U 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) AwsCloudWatchLogsProducer (class in unistream.producers.aws_cloudwatch_logs) AwsKinesisStreamConsumer (class in unistream.consumers.aws_kinesis) AwsKinesisStreamProducer (class in unistream.producers.aws_kinesis) B BaseAwsKinesisStreamConsumer (class in unistream.consumers.aws_kinesis) 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.dynamodb_s3.DynamoDBS3CheckPoint method) (unistream.checkpoints.simple.SimpleCheckpoint method) dump_as_failed_or_exhausted() (unistream.abstraction.AbcCheckPoint method) (unistream.checkpoints.dynamodb_s3.DynamoDBS3CheckPoint method) (unistream.checkpoints.simple.SimpleCheckpoint method) dump_as_in_progress() (unistream.abstraction.AbcCheckPoint method) (unistream.checkpoints.dynamodb_s3.DynamoDBS3CheckPoint method) (unistream.checkpoints.simple.SimpleCheckpoint method) dump_as_succeeded() (unistream.abstraction.AbcCheckPoint method) (unistream.checkpoints.dynamodb_s3.DynamoDBS3CheckPoint method) (unistream.checkpoints.simple.SimpleCheckpoint method) dump_records() (unistream.abstraction.AbcCheckPoint method) (unistream.checkpoints.dynamodb_s3.DynamoDBS3CheckPoint method) (unistream.checkpoints.simple.SimpleCheckpoint method) DynamoDBS3CheckPoint (class in unistream.checkpoints.dynamodb_s3) E emit() (unistream.abstraction.AbcBuffer method) (unistream.buffers.file_buffer.FileBuffer method) encode_dynamodb_item() (in module unistream.utils) F FileBuffer (class in unistream.buffers.file_buffer) from_get_record_data() (unistream.records.aws_kinesis.KinesisRecord class method) from_get_records_response() (unistream.records.aws_kinesis.KinesisGetRecordsResponseRecord class method) from_list_shards_response() (unistream.consumers.aws_kinesis.KinesisStreamShard class method) G get_not_succeeded_records() (unistream.checkpoint.BaseCheckPoint method) get_records() (unistream.abstraction.AbcConsumer method) (unistream.consumer.BaseConsumer method) (unistream.consumers.aws_kinesis.BaseAwsKinesisStreamConsumer 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) K KinesisGetRecordsResponseRecord (class in unistream.records.aws_kinesis) KinesisRecord (class in unistream.records.aws_kinesis) KinesisStreamShard (class in unistream.consumers.aws_kinesis) L load() (unistream.abstraction.AbcCheckPoint class method) (unistream.checkpoints.dynamodb_s3.DynamoDBS3CheckPoint class method) (unistream.checkpoints.simple.SimpleCheckpoint class method) load_records() (unistream.abstraction.AbcCheckPoint method) (unistream.checkpoints.dynamodb_s3.DynamoDBS3CheckPoint 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.dynamodb_s3 unistream.checkpoints.simple unistream.consumer unistream.consumers unistream.consumers.aws_kinesis unistream.consumers.simple unistream.exc unistream.logger unistream.producer unistream.producers unistream.producers.aws_cloudwatch_logs unistream.producers.aws_kinesis unistream.producers.simple unistream.record unistream.records unistream.records.aws_kinesis 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.aws_kinesis.BaseAwsKinesisStreamConsumer class method) (unistream.consumers.simple.SimpleConsumer class method) (unistream.producers.aws_cloudwatch_logs.AwsCloudWatchLogsProducer class method) (unistream.producers.aws_kinesis.AwsKinesisStreamProducer 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.aws_cloudwatch_logs.AwsCloudWatchLogsProducer method) (unistream.producers.aws_kinesis.AwsKinesisStreamProducer method) (unistream.producers.simple.SimpleProducer method) SendError serialize() (unistream.abstraction.AbcRecord method) (unistream.records.dataclass.DataClassRecord method) shall_we_retry() (unistream.producer.RetryConfig method) ShardHashKeyRange (class in unistream.consumers.aws_kinesis) ShardSequenceNumberRange (class in unistream.consumers.aws_kinesis) 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 to_dict() (unistream.checkpoints.dynamodb_s3.DynamoDBS3CheckPoint method) to_put_record_data() (unistream.records.aws_kinesis.KinesisRecord method) 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.dynamodb_s3 module unistream.checkpoints.simple module unistream.consumer module unistream.consumers module unistream.consumers.aws_kinesis module unistream.consumers.simple module unistream.exc module unistream.logger module unistream.producer module unistream.producers module unistream.producers.aws_cloudwatch_logs module unistream.producers.aws_kinesis module unistream.producers.simple module unistream.record module unistream.records module unistream.records.aws_kinesis module unistream.records.dataclass module unistream.utils module update_for_new_batch() (unistream.checkpoint.BaseCheckPoint method)