strimzi

Documentation

Index

• Variables
• func IsInstalled(ctx context.Context, c kubernetes.Interface) (bool, error)
• type GroupVersionKindResource

Variables

var (
	// RequiredKinds are Strimzi kinds used by YAKS for materializing integrations.
	// They must be present on the cluster.
	RequiredKinds = []GroupVersionKindResource{
		{
			GroupVersionKind: schema.GroupVersionKind{
				Kind:    "KafkaTopic",
				Group:   "kafka.strimzi.io",
				Version: "v1beta2",
			},
			Resource: "kafkatopics",
		},
	}
)

Functions

func IsInstalled

func IsInstalled(ctx context.Context, c kubernetes.Interface) (bool, error)

IsInstalled returns true if we are connected to a cluster with Strimzi installed

This method should not be called from the operator, as it might require permissions that are not available.

Types

type GroupVersionKindResource

type GroupVersionKindResource struct {
	schema.GroupVersionKind
	Resource string
}

GroupVersionKindResource --.