8000 feat(plugin/venom): add kafka executor from venom 0.22.0 (#3368) · ovh/cds@1b6ddbe · GitHub
[go: up one dir, main page]
More Web Proxy on the site http://driver.im/
Skip to content

Commit 1b6ddbe

Browse files
yesnaultyesnault
authored
feat(plugin/venom): add kafka executor from venom 0.22.0 (#3368)
Signed-off-by: Yvonnick Esnault <yvonnick.esnault@corp.ovh.com>
1 parent 79ab195 commit 1b6ddbe

File tree

14 files changed

+2035
-4
lines changed

14 files changed

+2035
-4
lines changed

‎Gopkg.lock

Lines changed: 10 additions & 3 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎Gopkg.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@
163163

164164
[[constraint]]
165165
name = "github.com/ovh/venom"
166-
version = "0.21.3"
166+
version = "0.22.0"
167167

168168
[prune]
169169
non-go = true

‎contrib/grpcplugins/action/venom/main.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ import (
2020
"github.com/ovh/venom/executors/exec"
2121
"github.com/ovh/venom/executors/http"
2222
"github.com/ovh/venom/executors/imap"
23+
"github.com/ovh/venom/executors/kafka"
2324
"github.com/ovh/venom/executors/ovhapi"
2425
"github.com/ovh/venom/executors/readfile"
2526
"github.com/ovh/venom/executors/redis"
@@ -80,6 +81,7 @@ func (actPlugin *venomActionPlugin) Run(ctx context.Context, q *actionplugin.Act
8081
v.RegisterExecutor(imap.Name, imap.New())
8182
v.RegisterExecutor(ovhapi.Name, ovhapi.New())
8283
v.RegisterExecutor(readfile.Name, readfile.New())
84+
v.RegisterExecutor(kafka.Name, kafka.New())
8385
v.RegisterExecutor(redis.Name, redis.New())
8486
v.RegisterExecutor(smtp.Name, smtp.New())
8587
v.RegisterExecutor(ssh.Name, ssh.New())

‎vendor/github.com/bsm/sarama-cluster/LICENSE

Lines changed: 22 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎vendor/github.com/bsm/sarama-cluster/balancer.go

Lines changed: 170 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎vendor/github.com/bsm/sarama-cluster/client.go

Lines changed: 50 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎vendor/github.com/bsm/sarama-cluster/cluster.go

Lines changed: 25 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)
0