File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -38,7 +38,7 @@ changelog:
3838release :
3939 github :
4040 owner : cludden
41- name : benthos-kubernetes-input
41+ name : benthos-kubernetes
4242
4343dockers :
4444 - binaries :
@@ -47,6 +47,6 @@ dockers:
4747 - benthos
4848 dockerfile : Dockerfile
4949 image_templates :
50- - " cludden/benthos-kubernetes-input :latest"
51- - " cludden/benthos-kubernetes-input :{{ .Tag }}"
52- - " cludden/benthos-kubernetes-input :v{{ .Major }}"
50+ - " cludden/benthos-kubernetes:latest"
51+ - " cludden/benthos-kubernetes:{{ .Tag }}"
52+ - " cludden/benthos-kubernetes:v{{ .Major }}"
Original file line number Diff line number Diff line change 1- # benthos-kubernetes-input
2- a [ benthos] ( https://github.com/Jeffail/benthos ) kubernetes input plugin that streams resource messages based on one or more configured watches.
1+ # benthos-kubernetes
2+
3+ a kubernetes plugin [ benthos] ( https://github.com/Jeffail/benthos ) which includes the following components:
4+
5+ ** Inputs:**
6+
7+ - ` kubernetes ` streams kubernetes objects for one or more configured watches
8+
9+ ** Outputs:**
10+
11+ - ` kubernetes ` creates, updates, and deleted kubernetes objects
12+ - ` kubernetes_status ` writes object status to kubernetes
313
414## Installing
515- with Docker
Original file line number Diff line number Diff line change @@ -13,7 +13,7 @@ import (
1313 bmeta "github.com/Jeffail/benthos/v3/lib/message/metadata"
1414 "github.com/Jeffail/benthos/v3/lib/metrics"
1515 "github.com/Jeffail/benthos/v3/lib/types"
16- klog "github.com/cludden/benthos-kubernetes-input /log"
16+ klog "github.com/cludden/benthos-kubernetes/log"
1717 metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
1818 "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
1919 "k8s.io/apimachinery/pkg/labels"
@@ -200,7 +200,7 @@ func NewKubernetes(
200200 closedChan : make (chan struct {}),
201201 }
202202
203- // initalize manager
203+ // initalize controller manager
204204 cmgr , err := manager .New (config .GetConfigOrDie (), manager.Options {})
205205 if err != nil {
206206 log .Errorf ("error initializing controller manager: %v" , err )
You can’t perform that action at this time.
0 commit comments