input

package

v0.2.1 Latest Latest Go to latest Published: Aug 29, 2020 License: MIT Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cludden/benthos-kubernetes-input

Links

Open Source Insights

Documentation ¶

Index ¶

func NewKubernetes(conf KubernetesConfig, mgr types.Manager, log log.Modular, stats metrics.Type) (input.Type, error)
type Kubernetes
type KubernetesConfig
- func NewKubernetesConfig() *KubernetesConfig
type Watch
- func (w *Watch) GVK() schema.GroupVersionKind
- func (w *Watch) Options() ([]builder.ForOption, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewKubernetes ¶

func NewKubernetes(
	conf KubernetesConfig,
	mgr types.Manager,
	log log.Modular,
	stats metrics.Type,
) (input.Type, error)

NewKubernetes creates a new kubernetes input type

Types ¶

type Kubernetes ¶

type Kubernetes struct {
	// contains filtered or unexported fields
}

Kubernetes input watches one or more k8s resources

func (*Kubernetes) CloseAsync ¶

func (k *Kubernetes) CloseAsync()

CloseAsync shuts down the input and stops processing requests.

func (*Kubernetes) Connected ¶

func (k *Kubernetes) Connected() bool

Connected returns true if this input is currently connected to its target.

func (*Kubernetes) Reconciler ¶ added in v0.2.0

func (k *Kubernetes) Reconciler(gvk schema.GroupVersionKind) reconcile.Reconciler

Reconciler returns a reconciler function scoped to the specified GVK

func (*Kubernetes) TransactionChan ¶

func (k *Kubernetes) TransactionChan() <-chan types.Transaction

TransactionChan returns a transactions channel for consuming messages from this input type.

func (*Kubernetes) WaitForClose ¶

func (k *Kubernetes) WaitForClose(timeout time.Duration) error

WaitForClose blocks until the input has closed down.

type KubernetesConfig ¶

type KubernetesConfig struct {
	Watches []Watch `json:"watches,omitempty" yaml:"watches,omitempty"`
}

KubernetesConfig defines runtime configuration for a kubernetes input

func NewKubernetesConfig ¶

func NewKubernetesConfig() *KubernetesConfig

NewKubernetesConfig creates a new KubernetesConfig with default values

type Watch ¶ added in v0.2.0

type Watch struct {
	Group      string    `json:"group" yaml:"group"`
	Version    string    `json:"version" yaml:"version"`
	Kind       string    `json:"kind" yaml:"kind"`
	Namespaces []string  `json:"namespaces,omitempty" yaml:"namespaces,omitempty"`
	Selector   *selector `json:"selector,omitempty" yaml:"selector,omitempty"`
}

Watch defines a controller configuration

func (*Watch) GVK ¶ added in v0.2.0

func (w *Watch) GVK() schema.GroupVersionKind

GVK returns a GroupVersionKind value

func (*Watch) Options ¶ added in v0.2.0

func (w *Watch) Options() ([]builder.ForOption, error)

Options returns a list of watch predicates using runtime config

Source Files ¶

View all Source files

kubernetes.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL