Commit 39c7e06
authored
enhance: add message and msgstream msgpack adaptor (milvus-io#34874)
issue: milvus-io#33285
- make message builder and message conversion type safe
- add adaptor type and function to adapt old msgstream msgpack and
message interface
---------
Signed-off-by: chyezh <chyezh@outlook.com>1 parent 6c19f9b commit 39c7e06
42 files changed
Lines changed: 1758 additions & 661 deletions
File tree
- internal
- flushcommon/writebuffer
- mocks
- rootcoord/mocks
- streamingnode
- client/handler/producer
- server
- service/handler/producer
- wal
- adaptor
- interceptors/timetick
- utility
- util/flowgraph
- pkg
- mq/msgstream
- mqwrapper/pulsar
- streaming
- util/message
- adaptor
- messagepb
- walimpls
- impls
- pulsar
- rmq
- util/typeutil
- scripts
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
103 | 103 | | |
104 | 104 | | |
105 | 105 | | |
| 106 | + | |
106 | 107 | | |
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
0 commit comments