kubernetes

Apr 21, 2022

Changes in this version

+ func GetSecretsRefData(ctx context.Context, client ctrl.Reader, namespace string, ...) ([][]byte, error)

Jan 19, 2022

Changes in this version

+ const ConfigMapAutogenLabel

+ const ConfigMapOriginalFileNameLabel

+ func GetUnstructured(context context.Context, client ctrl.Reader, gvk schema.GroupVersionKind, ...) (*unstructured.Unstructured, error)

+ func LoadUnstructuredFromYaml(data string) (ctrl.Object, error)

+ func NewConfigMap(namespace, cmName, originalFilename string, generatedKey string, ...) *corev1.ConfigMap

Nov 10, 2021

Changes in this version

+ func GetClientFor(c client.Client, group string, version string) (*rest.RESTClient, error)

+ func GetDeploymentCondition(deployment appsv1.Deployment, conditionType appsv1.DeploymentConditionType) *appsv1.DeploymentCondition

+ func GetJobCondition(job batchv1.Job, conditionType batchv1.JobConditionType) *batchv1.JobCondition

+ func GetKnativeServiceCondition(service servingv1.Service, conditionType knative.ConditionType) *knative.Condition

+ func GetPodCondition(pod corev1.Pod, conditionType corev1.PodConditionType) *corev1.PodCondition

+ func ToYAMLNoManagedFields(value runtime.Object) ([]byte, error)

Sep 3, 2021

Changes in this version

+ type CLIPrinter struct

+ Format string

+ func (p *CLIPrinter) PrintObj(obj runtime.Object, output io.Writer) error

Aug 27, 2021

Changes in this version

+ const CamelCreatorLabelNamespace

+ const CamelCreatorLabelVersion

Jul 5, 2021

Changes in this version

+ func GetDeployment(context context.Context, client ctrl.Reader, name string, namespace string) (*appsv1.Deployment, error)

+ func IsConditionTrue(it *v1.Integration, conditionType v1.IntegrationConditionType) bool

+ func LookupConfigmap(ctx context.Context, c client.Client, ns string, name string) *corev1.ConfigMap

+ func LookupSecret(ctx context.Context, c client.Client, ns string, name string) *corev1.Secret

Jun 30, 2021

Changes in this version

type Collection

+ func (c *Collection) GetPodMonitor(filter func(*monitoringv1.PodMonitor) bool) *monitoringv1.PodMonitor

+ func (c *Collection) VisitPodMonitor(visitor func(*monitoringv1.PodMonitor))

Apr 13, 2021

Changes in this version

+ func GetSecretRefData(ctx context.Context, client ctrl.Reader, namespace string, ...) ([]byte, error)

+ func IsAPIResourceInstalled(c client.Client, groupVersion string, kind string) (bool, error)

+ func NewNodeSelectors(nsArray []string) (map[string]string, error)

+ func NewResourceRequirements(reqs []string) (corev1.ResourceRequirements, error)

+ func NewTolerations(taints []string) ([]corev1.Toleration, error)

Dec 22, 2020

Changes in this version

+ func PortForward(ctx context.Context, c client.Client, ns, labelSelector string, ...) error

type Collection

+ func (c *Collection) VisitPodTemplateMeta(visitor func(meta *metav1.ObjectMeta))

Oct 8, 2020

Changes in this version

type Collection

+ func (c *Collection) AddFirst(resource runtime.Object)

+ func (c *Collection) GetController(filter func(object runtime.Object) bool) runtime.Object

+ func (c *Collection) GetCronJob(filter func(job *v1beta1.CronJob) bool) *v1beta1.CronJob

Jul 21, 2020

Changes in this version

+ const CamelCreatorLabelKind

+ const CamelCreatorLabelName

+ const CamelCreatorLabelPrefix

+ func CheckPermission(client client.Client, group, resource, namespace, name, verb string) (bool, error)

+ func FilterCamelCreatorLabels(source map[string]string) map[string]string

+ func GetBuild(context context.Context, client client.Client, name string, namespace string) (*v1.Build, error)

+ func GetCamelCreator(obj runtime.Object) *v1.ObjectReference

+ func GetConfigMap(context context.Context, client k8sclient.Reader, name string, ...) (*corev1.ConfigMap, error)

+ func GetConfigMapRefValue(ctx context.Context, client k8sclient.Reader, namespace string, ...) (string, error)

+ func GetIntegration(context context.Context, client k8sclient.Reader, name string, ...) (*v1.Integration, error)

+ func GetIntegrationKit(context context.Context, client k8sclient.Reader, name string, ...) (*v1.IntegrationKit, error)

+ func GetIntegrationPlatform(context context.Context, client k8sclient.Reader, name string, ...) (*v1.IntegrationPlatform, error)

+ func GetSecret(context context.Context, client k8sclient.Reader, name string, ...) (*corev1.Secret, error)

+ func GetSecretRefValue(ctx context.Context, client k8sclient.Reader, namespace string, ...) (string, error)

+ func GetService(context context.Context, client k8sclient.Reader, name string, ...) (*corev1.Service, error)

+ func IsUnknownAPIError(err error) bool

+ func JSONToYAML(src []byte) ([]byte, error)

+ func LoadRawResourceFromYaml(data string) (runtime.Object, error)

+ func LoadResourceFromYaml(scheme *runtime.Scheme, data string) (runtime.Object, error)

+ func MergeCamelCreatorLabels(source map[string]string, target map[string]string) map[string]string

+ func MirrorReadyCondition(ctx context.Context, c client.Client, it *v1.Integration)

+ func ReplaceResource(ctx context.Context, c client.Client, res runtime.Object) error

+ func ReplaceResources(ctx context.Context, c client.Client, objects []runtime.Object) error

+ func Resolve(data *v1.DataSpec, mapLookup func(string) (*corev1.ConfigMap, error)) error

+ func ResolveIntegrationResources(context context.Context, client controller.Reader, integration *v1.Integration, ...) ([]v1.ResourceSpec, error)

+ func ResolveIntegrationSources(context context.Context, client controller.Reader, integration *v1.Integration, ...) ([]v1.SourceSpec, error)

+ func ResolveResource(elements []v1.ResourceSpec, mapLookup func(string) (*corev1.ConfigMap, error)) ([]v1.ResourceSpec, error)

+ func ResolveSources(elements []v1.SourceSpec, mapLookup func(string) (*corev1.ConfigMap, error)) ([]v1.SourceSpec, error)

+ func ResolveValueSource(ctx context.Context, client k8sclient.Reader, namespace string, ...) (string, error)

+ func RuntimeObjectFromUnstructured(scheme *runtime.Scheme, u *unstructured.Unstructured) (runtime.Object, error)

+ func SanitizeLabel(name string) string

+ func SanitizeName(name string) string

+ func ToJSON(value runtime.Object) ([]byte, error)

+ func ToYAML(value runtime.Object) ([]byte, error)

+ func WaitCondition(ctx context.Context, c client.Client, obj runtime.Object, ...) error

+ type Collection struct

+ func NewCollection(objects ...runtime.Object) *Collection

+ func (c *Collection) Add(resource runtime.Object)

+ func (c *Collection) AddAll(resource []runtime.Object)

+ func (c *Collection) AsKubernetesList() *corev1.List

+ func (c *Collection) GetConfigMap(filter func(*corev1.ConfigMap) bool) *corev1.ConfigMap

+ func (c *Collection) GetContainer(filter func(container *corev1.Container) bool) *corev1.Container

+ func (c *Collection) GetContainerByName(name string) *corev1.Container

+ func (c *Collection) GetDeployment(filter func(*appsv1.Deployment) bool) *appsv1.Deployment

+ func (c *Collection) GetDeploymentForIntegration(integration *v1.Integration) *appsv1.Deployment

+ func (c *Collection) GetKnativeService(filter func(*serving.Service) bool) *serving.Service

+ func (c *Collection) GetRoute(filter func(*routev1.Route) bool) *routev1.Route

+ func (c *Collection) GetService(filter func(*corev1.Service) bool) *corev1.Service

+ func (c *Collection) GetServiceForIntegration(integration *v1.Integration) *corev1.Service

+ func (c *Collection) GetServiceMonitor(filter func(*monitoringv1.ServiceMonitor) bool) *monitoringv1.ServiceMonitor

+ func (c *Collection) GetUserServiceForIntegration(integration *v1.Integration) *corev1.Service

+ func (c *Collection) HasDeployment(filter func(*appsv1.Deployment) bool) bool

+ func (c *Collection) HasKnativeTrigger(filter func(trigger *eventing.Trigger) bool) bool

+ func (c *Collection) Items() []runtime.Object

+ func (c *Collection) Remove(selector func(runtime.Object) bool) runtime.Object

+ func (c *Collection) RemoveConfigMap(filter func(*corev1.ConfigMap) bool) *corev1.ConfigMap

+ func (c *Collection) RemoveDeployment(filter func(*appsv1.Deployment) bool) *appsv1.Deployment

+ func (c *Collection) Size() int

+ func (c *Collection) Visit(visitor func(runtime.Object))

+ func (c *Collection) VisitConfigMap(visitor func(*corev1.ConfigMap))

+ func (c *Collection) VisitContainer(visitor func(container *corev1.Container))

+ func (c *Collection) VisitCronJob(visitor func(*v1beta1.CronJob))

+ func (c *Collection) VisitCronJobE(visitor func(*v1beta1.CronJob) error) error

+ func (c *Collection) VisitDeployment(visitor func(*appsv1.Deployment))

+ func (c *Collection) VisitDeploymentE(visitor func(*appsv1.Deployment) error) error

+ func (c *Collection) VisitE(visitor func(runtime.Object) error) error

+ func (c *Collection) VisitKnativeConfigurationSpec(visitor func(container *serving.ConfigurationSpec))

+ func (c *Collection) VisitKnativeService(visitor func(*serving.Service))

+ func (c *Collection) VisitKnativeServiceE(visitor func(*serving.Service) error) error

+ func (c *Collection) VisitKnativeTrigger(visitor func(trigger *eventing.Trigger))

+ func (c *Collection) VisitMetaObject(visitor func(metav1.Object))

+ func (c *Collection) VisitPodSpec(visitor func(container *corev1.PodSpec))

+ func (c *Collection) VisitRoute(visitor func(*routev1.Route))

+ func (c *Collection) VisitService(visitor func(*corev1.Service))

+ func (c *Collection) VisitServiceMonitor(visitor func(*monitoringv1.ServiceMonitor))

+ type ResourceCheckFunction func(interface{}) (bool, error)

+ type ResourceRetrieveFunction func() (interface{}, error)