[dubbo-go-pixiu] branch develop updated (bf6dde0 -> 9f72545)

[al...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

alexstocks pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go-pixiu.git.


    from bf6dde0  Merge pull request #309 from dongzl/repeat-registry
     new 3b37a3c  Feat: event mesh (#286)
     new 1e75e1e  polish kafka init (#287)
     new 9e58649  merge from another branch
     new 89552f4  Merge branch 'develop' into eventmesh
     new f06e488  Merge remote-tracking branch 'origin/eventmesh' into eventmeshnew
     new 175d4f3  fix review
     new 947972c  fix log
     new 4cce011  Merge branch 'develop' into eventmesh
     new 42d5b86  Merge remote-tracking branch 'origin/eventmesh' into eventmeshnew
     new 84c4282  fix
     new 4b03d0f  fix
     new 3c13d5b  Merge branch 'develop' into eventmesh
     new db49d94  Merge remote-tracking branch 'origin/eventmesh' into eventmeshnew
     new 9d792b5  fix conflict
     new b97b380  Merge branch 'develop' into eventmesh
     new 500dba7  Merge remote-tracking branch 'origin/eventmesh' into eventmeshnew
     new 19f75a4  fix conflict
     new 2ff6a88  Merge branch 'develop' into eventmesh
     new aa2ada5  Merge remote-tracking branch 'origin/eventmesh' into eventmeshnew
     new 9f72545  Merge pull request #300 from tydhot/eventmesh

The 1283 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 go.mod                                             |   1 +
 go.sum                                             |   8 +
 pkg/client/mq/config.go                            |  62 +++++
 pkg/client/mq/facade.go                            |  90 ++++++++
 pkg/client/mq/kafka_facade.go                      | 250 +++++++++++++++++++++
 pkg/client/mq/mq.go                                | 156 +++++++++++++
 pkg/client/mq/msg.go                               |  64 ++++++
 pkg/common/constant/key.go                         |   6 +
 .../{recovery/recovery.go => event/event.go}       |  49 ++--
 9 files changed, 661 insertions(+), 25 deletions(-)
 create mode 100644 pkg/client/mq/config.go
 create mode 100644 pkg/client/mq/facade.go
 create mode 100644 pkg/client/mq/kafka_facade.go
 create mode 100644 pkg/client/mq/mq.go
 create mode 100644 pkg/client/mq/msg.go
 copy pkg/filter/{recovery/recovery.go => event/event.go} (69%)