663
100%
master: 100%

Ran 04 Oct 2016 10:21AM UTC

Jobs 2

Files 11

Run time 44s

Badge

Embed ▾

pending completion

Build # 663

Build Type

push

travis-ci

Committed by Joe Cross

Commit Message

impl Record minheap, Shard.read_version #17

`Shard.read_version` is used by Shard consumers to signal back to
the shard that a record has actually been read, and not just buffered.
This is done through `Shard.mark_read(sequence_number, read_version)`.

The read_version is incremented whenever the Shard's iterator changes
location; after which it will discard read acks for old read versions
(since the iterator is no longer where it was when the record being marked
was returned).

RecordHeap is a very simple wrapper around the fantastic stdlib's
heapq functions, and sorts buffered records by lowest
"ApproximateCreationDateTime".  The generating shard and read version for
that record are also stored with the record, so that the shard can be
notified when the record is finally consumed.

Some of the simple case for Coordinator.__next__ has been written; namely,
when there are records in the buffer.  Assumptions are made that the shard
which returned the record will also return a next shard (or None) and does
not handle expiration or exhaustion.

Run Details

1648 of 1833 relevant lines covered (89.91%)

0.9 hits per line

Jobs

ID	Job ID	Ran	Files	Coverage
1	663.1 (TOXENV=unit)	04 Oct 2016 10:21AM UTC	0	89.91	Travis Job 663.1
2	663.2 (TOXENV=integ)	04 Oct 2016 10:22AM UTC	0		Travis Job 663.2

Source Files on build 663

Detailed source file information is not available for this build.

numberoverzero / bloop / 663
100%
master: 100%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

Jobs

Source Files on build 663

numberoverzero / bloop / 663 100% master: 100%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

Jobs

Source Files on build 663

numberoverzero / bloop / 663
100%
master: 100%

README BADGES
x