Commits

Branch selector

 690f65b

User selector

All users

Datepicker

All time

Commit History

Commits on May 31, 2017

• PR changes

  

  Achille Roussel

  committed
  690f65b

  Copy full SHA for 690f65b

• vendor

  

  Achille Roussel

  committed
  cd366b9

  Copy full SHA for cd366b9

• add connection benchmarks

  

  Achille Roussel

  committed
  ccf5a42

  Copy full SHA for ccf5a42

• move consul => kafkaconsul

  

  Achille Roussel

  committed
  0efc520

  Copy full SHA for 0efc520

• port Reader to use Conn, drop sarama dependency

  

  Achille Roussel

  committed
  894ff5e

  Copy full SHA for 894ff5e

• get rid of outdated code

  

  Achille Roussel

  committed
  b20b363

  Copy full SHA for b20b363

• update .gitignore

  

  Achille Roussel

  committed
  e85a4b2

  Copy full SHA for e85a4b2

• implement batched reads

  

  Achille Roussel

  committed
  45fcddd

  Copy full SHA for 45fcddd

• remove dead code

  

  Achille Roussel

  committed
  a4db7a0

  Copy full SHA for a4db7a0

• return errShortBuffer when reading a string or bytes with not enough remaining bytes

  

  Achille Roussel

  committed
  da021cb

  Copy full SHA for da021cb

• cleanup in preparation of batch reader implementation

  

  Achille Roussel

  committed
  3258cb9

  Copy full SHA for 3258cb9

• refactor timeout computation to bound adjustment to the RTT

  

  Achille Roussel

  committed
  369023d

  Copy full SHA for 369023d

• refactor the kafka connection implementation in preparation for adding batched reads

  

  Achille Roussel

  committed
  6f20ba0

  Copy full SHA for 6f20ba0

• add comment

  

  Achille Roussel

  committed
  bb52187

  Copy full SHA for bb52187

• allow timeouts to return before the deadline

  

  Achille Roussel

  committed
  b7b4c1f

  Copy full SHA for b7b4c1f

• get rid of NoError

  

  Achille Roussel

  committed
  abf3cca

  Copy full SHA for abf3cca

• use NoError

  

  Achille Roussel

  committed
  bcf701c

  Copy full SHA for bcf701c

• reorganize the connection fields to make relations more explicit

  

  Achille Roussel

  committed
  feacaf8

  Copy full SHA for feacaf8

• cleanup

  

  Achille Roussel

  committed
  5dedc0c

  Copy full SHA for 5dedc0c

• refactor deadlines management

  

  Achille Roussel

  committed
  8346291

  Copy full SHA for 8346291

• pass nettest.TestConn

  

  Achille Roussel

  committed
  06bd316

  Copy full SHA for 06bd316

• remove unused timeout type

  

  Achille Roussel

  committed
  e7f830f

  Copy full SHA for e7f830f

• add batch writing test

  

  Achille Roussel

  committed
  2a2be49

  Copy full SHA for 2a2be49

• support batching writes

  

  Achille Roussel

  committed
  6b6cda8

  Copy full SHA for 6b6cda8

• add comment explaining the policy around errShortRead when fetching messages

  

  Achille Roussel

  committed
  9af7077

  Copy full SHA for 9af7077

• add ReadOffset + zero-allocation ReadOffsets

  

  Achille Roussel

  committed
  f86ba28

  Copy full SHA for f86ba28

• implement ReadAt

  

  Achille Roussel

  committed
  4725792

  Copy full SHA for 4725792

• working Read implementation

  

  Achille Roussel

  committed
  48e5aff

  Copy full SHA for 48e5aff

• fix reading message header

  

  Achille Roussel

  committed
  8ce091d

  Copy full SHA for 8ce091d

• almost complete fetch implementation

  

  Achille Roussel

  committed
  4e2a4e4

  Copy full SHA for 4e2a4e4

• working on reading messages

  

  Achille Roussel

  committed
  526b19e

  Copy full SHA for 526b19e

• add test for writing after closing the connection

  

  Achille Roussel

  committed
  0bc1c3d

  Copy full SHA for 0bc1c3d

• fix race

  

  Achille Roussel

  committed
  36356f3

  Copy full SHA for 36356f3

• support streaming of arrays in responses from the kafka server

  

  Achille Roussel

  committed
  fa3b362

  Copy full SHA for fa3b362

• add support for reading the first and last offsets of a topic/partition

  

  Achille Roussel

  committed
  cc7fc22

  Copy full SHA for cc7fc22

Pagination

Previous

Next