Code

Initial kinesis + tower sink#93

Code

Merged

LucioFranco merged 10 commits intomastervectordotdev/vector:masterfrom kinesisvectordotdev/vector:kinesisCopy head branch name to clipboardFeb 27, 2019

+582-98

Commits

Commits on Feb 27, 2019

• First pass at a kinesis sink with tower

  LucioFranco

  committed
  6a4ed64

  Copy full SHA for 6a4ed64

• Move batcher into util

  LucioFranco

  committed
  85129b6

  Copy full SHA for 85129b6

• Add retry and timeouts for kinesis

  LucioFranco

  committed
  2deabec

  Copy full SHA for 2deabec

• Fix kinesis tests

  LucioFranco

  committed
  69ccf36

  Copy full SHA for 69ccf36

• Add useful debug bound

  LucioFranco

  committed
  994b556

  Copy full SHA for 994b556

• Fix unused variable

  LucioFranco

  committed
  d5795d2

  Copy full SHA for d5795d2

• Remove generic bounds for Batch and improve kinesis test

  LucioFranco

  committed
  81a6a6c

  Copy full SHA for 81a6a6c

• Clean up retry and fix tests

  LucioFranco

  committed
  4787262

  Copy full SHA for 4787262

• Reduce test timeout

  LucioFranco

  committed
  a9aad75

  Copy full SHA for a9aad75

• Fix the way we actually test cloudwatch and kinesis

  LucioFranco

  committed
  98804db

  Copy full SHA for 98804db