Code

Shard map#1

Code

Open

mjneil wants to merge 21 commits intomastermjneil/kinesis-producer:masterfrom shard-mapmjneil/kinesis-producer:shard-mapCopy head branch name to clipboard

+4,338-350

Commits

Commits on May 20, 2020

• initial ShardMap implementation, build success

  mjneil

  committed
  b12936c

Commits on May 21, 2020

• better GetShardsFn

  mjneil

  committed
  febd36f

• fix existing tests

  mjneil

  committed
  9b75e4f

Commits on Jun 9, 2020

• add ShardMap tests

  mjneil

  committed
  f589e46

• readme updates

  mjneil

  committed
  bd6a572

• some fixes to examples

  mjneil

  committed
  39c3d73

Commits on Jun 10, 2020

• add benchmark test

  mjneil

  committed
  c1a6cb4

• add benchmarks

  mjneil

  committed
  6688fb4

Commits on Jun 11, 2020

• use error for failure chan with custom error types

  mjneil

  committed
  59f5701

Commits on Jun 12, 2020

• improved errors

  mjneil

  committed
  9621b9d

• fix errors

  mjneil

  committed
  8fabca5

Commits on Jun 16, 2020

• reaggreagte inflight requests on shard map updates

  mjneil

  committed
  5a16bbf

• always append records from update even when error

  mjneil

  committed
  542f754

Commits on Jun 17, 2020

• fix reaggregation of backlog during shard map update

  mjneil

  committed
  e2cf5ba

• send reaggregated records over backlog channel rather than immediate flush

  mjneil

  committed
  23399c0

Commits on Jun 18, 2020

• restructure loop using worker pool to fix concurrency issues with shard map refresh

  mjneil

  committed
  be6e967

Commits on Jun 19, 2020

• add back removed comment

  mjneil

  committed
  ba23d84

• shards may not come back sorted by kinesis

  mjneil

  committed
  3a09e30

Commits on Jun 24, 2020

• fix size calculations for proto format

  mjneil

  committed
  e118199

Commits on Jun 26, 2020

• fix readme examples

  mjneil

  committed
  f592ec8

Commits on Aug 7, 2020

• add deaggregation package

  mjneil

  committed
  472780f