Code

Add Advanced Pub/Sub feature#1582

Code

Merged

OlivierHecart merged 91 commits intomaineclipse-zenoh/zenoh:mainfrom dev/advanced_pubsubeclipse-zenoh/zenoh:dev/advanced_pubsubCopy head branch name to clipboardDec 11, 2024

+3,695-167

Commits

Commits on Nov 5, 2024

• Expose and use ke macro

  OlivierHecart

  committed
  2cc7f12

  Copy full SHA for 2cc7f12

Commits on Nov 8, 2024

• Fix SourceInfo publication

  OlivierHecart

  committed
  163d3d5

  Copy full SHA for 163d3d5

• Add AdvancedPublisher AdvancedSubscriber and AdvancedSubscriber

  OlivierHecart

  committed
  43a5d3c

  Copy full SHA for 43a5d3c

• Fix doctests

  OlivierHecart

  committed
  9f076a7

  Copy full SHA for 9f076a7

• Fix doc warnings

  OlivierHecart

  committed
  3935974

  Copy full SHA for 3935974

Commits on Nov 13, 2024

• Remove debug trace

  OlivierHecart

  committed
  405d76e

  Copy full SHA for 405d76e

• Add history test

  OlivierHecart

  committed
  71b22d3

  Copy full SHA for 71b22d3

• Fix periodic queries

  OlivierHecart

  committed
  af1b2a2

  Copy full SHA for af1b2a2

• Remove debug trace

  OlivierHecart

  committed
  bd32356

  Copy full SHA for bd32356

• Lower test debug level

  OlivierHecart

  committed
  4e4bbb6

  Copy full SHA for 4e4bbb6

• Add retransmission tests

  OlivierHecart

  committed
  f36c890

  Copy full SHA for f36c890

• Liveliness sub callback shoud increase pending queries counter

  OlivierHecart

  committed
  23f145d

  Copy full SHA for 23f145d

• Liveliness sub callback shoud spawn periodic queries when enbaled

  OlivierHecart

  committed
  de396a4

  Copy full SHA for de396a4

• Add late_joiner test

  OlivierHecart

  committed
  ff24135

  Copy full SHA for ff24135

Commits on Nov 14, 2024

• Only treat pending samples when there are no more pending queries

  OlivierHecart

  committed
  975aba4

  Copy full SHA for 975aba4

• Apply proper sequencing for history

  OlivierHecart

  committed
  5d9ac8d

  Copy full SHA for 5d9ac8d

• Improve AdvancedSubscriber

  OlivierHecart

  committed
  2305b41

  Copy full SHA for 2305b41

• Code reorg

  OlivierHecart

  committed
  883885b

  Copy full SHA for 883885b

• Code reorg

  OlivierHecart

  committed
  3201700

  Copy full SHA for 3201700

• Fix deduplication

  OlivierHecart

  committed
  ded789c

  Copy full SHA for ded789c

Commits on Nov 15, 2024

• Subscribe to liveliness tokens with history

  OlivierHecart

  committed
  e033553

  Copy full SHA for e033553

• Update builders

  OlivierHecart

  committed
  acaf341

  Copy full SHA for acaf341

• Add examples

  OlivierHecart

  committed
  ef63165

  Copy full SHA for ef63165

• Fix rustdoc

  OlivierHecart

  committed
  788a8e5

  Copy full SHA for 788a8e5

Commits on Nov 18, 2024

• Move stuff in State

  OlivierHecart

  committed
  a40639c

  Copy full SHA for a40639c

• Code reorg

  OlivierHecart

  committed
  e1caa06

  Copy full SHA for e1caa06

• Add smaple_miss_callback

  OlivierHecart

  committed
  ee1895f

  Copy full SHA for ee1895f

• Add sample miss test

  OlivierHecart

  committed
  c8a43d1

  Copy full SHA for c8a43d1

• Update z_advanced_sub example

  OlivierHecart

  committed
  d11243d

  Copy full SHA for d11243d

Commits on Nov 21, 2024

• Explicit use in examples

  OlivierHecart

  committed
  eb6dbf6

  Copy full SHA for eb6dbf6

Commits on Nov 28, 2024

• Update API

  OlivierHecart

  committed
  ee93de1

  Copy full SHA for ee93de1

• Fix rustdoc

  OlivierHecart

  committed
  596d0ed

  Copy full SHA for 596d0ed

• Allow sample miss detection when recovery disabled

  OlivierHecart

  committed
  35ae472

  Copy full SHA for 35ae472

• Add miss_sample_callback to DataSubscriberBuilderExt

  OlivierHecart

  committed
  52bec17

  Copy full SHA for 52bec17

• Add sample_miss_detection to PublisherBuilderExt

  OlivierHecart

  committed
  a16d64c

  Copy full SHA for a16d64c

• Add test_advanced_sample_miss test

  OlivierHecart

  committed
  5662f34

  Copy full SHA for 5662f34

• Merge branch 'main' into dev/advanced_pubsub

  OlivierHecart

  committed
  18adcc7

  Copy full SHA for 18adcc7

• Deliver sample even when no miss callback

  OlivierHecart

  committed
  6da5655

  Copy full SHA for 6da5655

• Replace sample_miss_callback with sample_miss_listener

  OlivierHecart

  committed
  3449d73

  Copy full SHA for 3449d73

Commits on Nov 29, 2024

• Merge branch 'main' into dev/advanced_pubsub

  OlivierHecart

  committed
  76344c9

  Copy full SHA for 76344c9

• Fix clippy warnings

  OlivierHecart

  committed
  ba72a96

  Copy full SHA for ba72a96

• Fix tests

  OlivierHecart

  committed
  4df529e

  Copy full SHA for 4df529e

• Add HistoryConf max_samples option

  OlivierHecart

  committed
  443d540

  Copy full SHA for 443d540

• Add HistoryConf max_age option

  OlivierHecart

  committed
  f9c7d0e

  Copy full SHA for f9c7d0e

Commits on Dec 2, 2024

• Use BTreeMap

  OlivierHecart

  committed
  3b28b04

  Copy full SHA for 3b28b04

Commits on Dec 4, 2024

• Add meta_keyexpr option

  OlivierHecart

  committed
  9e7a99b

  Copy full SHA for 9e7a99b

• Add late_joiner_detection and meta_keyexpr options on Subcriber side

  OlivierHecart

  committed
  43d9d79

  Copy full SHA for 43d9d79

• Renaming

  OlivierHecart

  committed
  54dc83c

  Copy full SHA for 54dc83c

• Merge branch 'main' into dev/advanced_pubsub

  OlivierHecart

  committed
  aacea79

  Copy full SHA for aacea79

• Fix compilation issues

  OlivierHecart

  committed
  9d18085

  Copy full SHA for 9d18085

Commits on Dec 5, 2024

• Remove AdvancedCache from public API

  OlivierHecart

  committed
  7d3ab8d

  Copy full SHA for 7d3ab8d

• Update Session admin to match AdvancedSub

  OlivierHecart

  committed
  e59e76b

  Copy full SHA for e59e76b

• Gather constants

  OlivierHecart

  committed
  71ce64b

  Copy full SHA for 71ce64b

• Fix doc build

  OlivierHecart

  committed
  8810b37

  Copy full SHA for 8810b37

• Renaming

  OlivierHecart

  committed
  dba1d50

  Copy full SHA for dba1d50

• Mark PublicationCache and QueryingSubscriber as deprecated and remove related examples

  OlivierHecart

  committed
  95ce535

  Copy full SHA for 95ce535

• Remove z_pub_cache and z_query_sub entries from zenoh-ext examples README

  OlivierHecart

  committed
  6023920

  Copy full SHA for 6023920

• Add z_advanced_pub and z_advanced_sub to zenoh-ext examples Cargo.toml

  OlivierHecart

  committed
  dbd7d22

  Copy full SHA for dbd7d22

• Add CacheConfig replies_qos option

  OlivierHecart

  committed
  7537985

  Copy full SHA for 7537985

• Call cache directly from publisher

  OlivierHecart

  committed
  f850eaa

  Copy full SHA for f850eaa

Commits on Dec 6, 2024

• Update doc

  OlivierHecart

  committed
  1799a95

  Copy full SHA for 1799a95

• Add missing unstable tags

  OlivierHecart

  committed
  feeb7ef

  Copy full SHA for feeb7ef

• Add missing unstable tags

  OlivierHecart

  committed
  cd68431

  Copy full SHA for cd68431

• Add missing unstable tags

  OlivierHecart

  committed
  c9cc963

  Copy full SHA for c9cc963

• Add unstable tag everywhere

  OlivierHecart

  committed
  2d6550d

  Copy full SHA for 2d6550d

Commits on Dec 9, 2024

• Add missing AdvancedSubscriber methods

  OlivierHecart

  committed
  ab05e1e

  Copy full SHA for ab05e1e

• Fix WeakSession::Session internal function

  OlivierHecart

  committed
  1bae945

  Copy full SHA for 1bae945

• Expose missing SampleMissListener and related structs

  OlivierHecart

  committed
  5ca2e50

  Copy full SHA for 5ca2e50

• Add AdvancedPublisherBuilderExt::advanced function

  OlivierHecart

  committed
  7c374c4

  Copy full SHA for 7c374c4

• Add missing AdvancedPublisherBuilder functions

  OlivierHecart

  committed
  0ffb133

  Copy full SHA for 0ffb133

• Fix doctests

  OlivierHecart

  committed
  dc9200c

  Copy full SHA for dc9200c

• Expose Miss struct

  OlivierHecart

  committed
  6e9f9b9

  Copy full SHA for 6e9f9b9

• impl QoSBuilderTrait for AdvancedPublisherBuilder

  OlivierHecart

  committed
  d3a78a0

  Copy full SHA for d3a78a0

• Propagate PublisherBuilder values to AdvancedPublisherBuilder

  OlivierHecart

  committed
  7332d02

  Copy full SHA for 7332d02

• Rename AdvancedSubscriber::close()

  OlivierHecart

  committed
  b63c080

  Copy full SHA for b63c080

• Add unstable tags

  OlivierHecart

  committed
  4aaca6e

  Copy full SHA for 4aaca6e

• Add AdvancedSubscriber::detect_publishers function

  OlivierHecart

  committed
  a8bb82f

  Copy full SHA for a8bb82f

• Remove debug println

  OlivierHecart

  committed
  2df37bc

  Copy full SHA for 2df37bc

• Renaming

  OlivierHecart

  committed
  fe51436

  Copy full SHA for fe51436

• Add unstable tags

  OlivierHecart

  committed
  0bc7233

  Copy full SHA for 0bc7233

• Use std Range

  OlivierHecart

  committed
  00963f3

  Copy full SHA for 00963f3

Commits on Dec 10, 2024

• Spawn Timer in a tokio runtime

  OlivierHecart

  committed
  3c6ba61

  Copy full SHA for 3c6ba61

• Fix panic when last_delivered is None

  OlivierHecart

  committed
  18682ff

  Copy full SHA for 18682ff

• Release lock before calling get

  OlivierHecart

  committed
  24e1ede

  Copy full SHA for 24e1ede

• Update key mapping

  OlivierHecart

  committed
  87acf15

  Copy full SHA for 87acf15

• Improve doc

  OlivierHecart

  committed
  6332331

  Copy full SHA for 6332331

• fix: fix callback API (#1647)

  wyfo

  authored
  b807ee8

  Copy full SHA for b807ee8

• Update doc

  OlivierHecart

  committed
  2096085

  Copy full SHA for 2096085

• Fix ke_liveliness

  OlivierHecart

  committed
  dce3304

  Copy full SHA for dce3304

• Fix doc

  OlivierHecart

  committed
  e547a23

  Copy full SHA for e547a23

Commits on Dec 11, 2024

• Fix doc

  OlivierHecart

  committed
  e870d79

  Copy full SHA for e870d79