Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion ingest/ledger_change_reader.go
Original file line number Diff line number Diff line change
Expand Up @@ -121,7 +121,7 @@ func (c *compactingChangeReader) Close() error {
}

// NewCompactingChangeReader wraps a given ChangeReader and returns a ChangeReader
// which compacts all the the Changes extracted from the input.
// which compacts all the Changes extracted from the input.
func NewCompactingChangeReader(input ChangeReader, config ChangeCompactorConfig) ChangeReader {
return &compactingChangeReader{
input: input,
Expand Down
2 changes: 1 addition & 1 deletion ingest/ledgerbackend/ledger_buffer.go
Original file line number Diff line number Diff line change
Expand Up @@ -159,7 +159,7 @@ func (lb *ledgerBuffer) worker(ctx context.Context) {
// When we store an object we still maintain the ledger buffer invariant because
// at this point the current task is finished and we add 1 ledger object to the priority queue.
// Thus, the number of tasks decreases by 1 and the priority queue length increases by 1.
// This keeps the overall total the same (<= BufferSize). As long as the the ledger buffer invariant
// This keeps the overall total the same (<= BufferSize). As long as the ledger buffer invariant
// was maintained in the previous state, it is still maintained during this state transition.
lb.storeObject(ledgerObject, sequence)
break
Expand Down