Code

Subscribe message batching#45

Code

Open

Niranjan-Formant wants to merge 14 commits intomasterFormantIO/ros2-adapter:masterfrom subscribe-message-batchingFormantIO/ros2-adapter:subscribe-message-batchingCopy head branch name to clipboard

+407-171

Commits

Commits on Aug 7, 2023

• prelim version of batch_ingester: flush_once, message queue

  Niranjan-Formant

  committed
  7cd9948

• batched_ingsester with threading completed, tests TBD

  Niranjan-Formant

  committed
  bfdebf3

• ingester -> batchingester normal tests work

  Niranjan-Formant

  committed
  ef688f7

• added ingest_interval variable, tests specifcally for batched_ingester TBD

  Niranjan-Formant

  committed
  3f8f770

Commits on Aug 8, 2023

• BaseIngester class implemented; passes tests when integrated to Ingester class

  Niranjan-Formant

  committed
  05ca2bb

• Added types.py

  Niranjan-Formant

  committed
  12e85c3

• types.py added for ingester

  Niranjan-Formant

  committed
  e29e919

Commits on Aug 13, 2023

• Added prepare_datapoint to base_ingester + updated ingester

  Niranjan-Formant

  committed
  b350088

• Batched Ingester works + time specific tests TBD

  Niranjan-Formant

  committed
  0bd6ab1

Commits on Aug 16, 2023

• Added function var names + updated ingest_interval

  Niranjan-Formant

  committed
  2d4f122

• chooses between batch_ingester and ingester based on agent functionality

  Niranjan-Formant

  committed
  578ae56

Commits on Sep 6, 2023

• added test_subscribers_batched.py

  Niranjan-Formant

  committed
  32da665

Commits on Nov 8, 2023

• testing in progress

  Niranjan-Formant

  committed
  c5d29a6

• adding msg =

  Niranjan-Formant

  committed
  25f198d