source

Documentation

Index

• Variables
• func New(k kube.Interfaces, resyncPeriod time.Duration, cfg *converter.Config) (runtime.Source, error)
• func ProcessEvent(cfg *converter.Config, spec kube.ResourceSpec, kind resource.EventKind, ...)
• func VerifyResourceTypesPresence(k kube.Interfaces) error

Variables

var (
	// APIVersionTag holds the API version of the resource.
	APIVersionTag tag.Key
	// GroupTag holds the group of the resource.
	GroupTag tag.Key
	// KindTag holds the kind of the resource.
	KindTag tag.Key
	// ErrorTag holds the error message of a handleEvent failure.
	ErrorTag tag.Key
)

Functions

func New

func New(k kube.Interfaces, resyncPeriod time.Duration, cfg *converter.Config) (runtime.Source, error)

New returns a Kubernetes implementation of runtime.Source.

func ProcessEvent

func ProcessEvent(cfg *converter.Config, spec kube.ResourceSpec, kind resource.EventKind, key resource.FullName, resourceVersion string,
	u *unstructured.Unstructured, ch chan resource.Event)

ProcessEvent process the incoming message and convert it to event

func VerifyResourceTypesPresence

func VerifyResourceTypesPresence(k kube.Interfaces) error

VerifyResourceTypesPresence verifies that all expected k8s resources types are present in the k8s apiserver.