Code

Streams filters#893

Code

Merged

viktorerlingsson merged 24 commits intomaincloudamqp/lavinmq:mainfrom streams-filterscloudamqp/lavinmq:streams-filtersCopy head branch name to clipboardJan 23, 2025

+159

Commits

Commits on Jan 23, 2025

• add filtering functionality for streams

  viktorerlingsson

  committed
  2f56ef3

  Copy full SHA for 2f56ef3

• handle x-stream-match-unfiltered

  viktorerlingsson

  committed
  b1a4fbf

  Copy full SHA for b1a4fbf

• refactor

  viktorerlingsson

  committed
  fe33f30

  Copy full SHA for fe33f30

• add specs

  viktorerlingsson

  committed
  6bbffd5

  Copy full SHA for 6bbffd5

• lint

  viktorerlingsson

  committed
  9b92d9e

  Copy full SHA for 9b92d9e

• rename msg_filters->msg_filter

  viktorerlingsson

  committed
  540f5ec

  Copy full SHA for 540f5ec

• add spec for offset and filters

  viktorerlingsson

  committed
  3327c76

  Copy full SHA for 3327c76

• fixup! add spec for offset and filters

  viktorerlingsson

  committed
  53425ea

  Copy full SHA for 53425ea

• split string to array directly

  viktorerlingsson

  committed
  bce44c2

  Copy full SHA for bce44c2

• refactor

  Show description for 6c0085d
  

  viktorerlingsson

  and

  spuun

  committed
  6c0085d

  Copy full SHA for 6c0085d

• refactor

  Show description for 6d1d98b
  

  viktorerlingsson

  and

  spuun

  committed
  6d1d98b

  Copy full SHA for 6d1d98b

• remove comment

  Show description for 426e99f
  

  viktorerlingsson

  and

  spuun

  committed
  426e99f

  Copy full SHA for 426e99f

• remove redundant return

  Show description for d38729c
  

  viktorerlingsson

  and

  spuun

  committed
  d38729c

  Copy full SHA for d38729c

• add comments

  viktorerlingsson

  committed
  74348a4

  Copy full SHA for 74348a4

• format

  viktorerlingsson

  committed
  94036d1

  Copy full SHA for 94036d1

• refactor stream_consumer

  Show description for 8646770
  

  viktorerlingsson

  and

  carlhoerberg

  committed
  8646770

  Copy full SHA for 8646770

• refactor stream_consumer

  Show description for 18f5bc2
  

  viktorerlingsson

  and

  carlhoerberg

  committed
  18f5bc2

  Copy full SHA for 18f5bc2

• use bsearch to speed up

  Show description for e46504b
  

  viktorerlingsson

  and

  carlhoerberg

  committed
  e46504b

  Copy full SHA for e46504b

• remove redundant returns

  viktorerlingsson

  committed
  6497c05

  Copy full SHA for 6497c05

• move filter_match to stream_consumer

  Show description for a27d797
  

  viktorerlingsson

  and

  carlhoerberg

  committed
  a27d797

  Copy full SHA for a27d797

• x-stream-filter-value -> x-stream-filter for consumers

  viktorerlingsson

  committed
  38440ce

  Copy full SHA for 38440ce

• @filter is empty array as default instead of nil

  viktorerlingsson

  committed
  c50b1a6

  Copy full SHA for c50b1a6

• refactor

  Show description for 335c1e8
  

  viktorerlingsson

  and

  carlhoerberg

  committed
  335c1e8

  Copy full SHA for 335c1e8

• update changelog

  viktorerlingsson

  committed
  6bb2ae1

  Copy full SHA for 6bb2ae1