operatorutil

Documentation

Overview

Copyright 2023 Google LLC

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

https://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Constants
• func IsPodMonitoringFailure(pm monitoringv1.PodMonitoringCRD, expectedFn func(message string) error) error
• func IsPodMonitoringReady(pm monitoringv1.PodMonitoringCRD, targetStatusEnabled bool) error
• func IsPodMonitoringSuccess(pm monitoringv1.PodMonitoringCRD, targetStatusEnabled bool) error
• func SyntheticAppDeploy(ctx context.Context, kubeClient client.Client, namespace, name string, ...) (*appsv1.Deployment, error)
• func WaitForCollectionReady(ctx context.Context, kubeClient client.Client, operatorNamespace string) error
• func WaitForNodeMonitoringReady(ctx context.Context, kubeClient client.Client, operatorNamespace string, ...) error
• func WaitForOperatorReady(ctx context.Context, kubeClient client.Client, operatorNamespace string) error
• func WaitForPodMonitoringFailure(ctx context.Context, kubeClient client.Client, ...) error
• func WaitForPodMonitoringReady(ctx context.Context, kubeClient client.Client, operatorNamespace string, ...) error
• func WaitForPodMonitoringSuccess(ctx context.Context, kubeClient client.Client, ...) error

Constants

const (
	SyntheticAppPortName      = "web"
	SyntheticAppContainerName = "go-synthetic"
)

Functions

func IsPodMonitoringFailure

func IsPodMonitoringFailure(pm monitoringv1.PodMonitoringCRD, expectedFn func(message string) error) error

func IsPodMonitoringReady

func IsPodMonitoringReady(pm monitoringv1.PodMonitoringCRD, targetStatusEnabled bool) error

func IsPodMonitoringSuccess

func IsPodMonitoringSuccess(pm monitoringv1.PodMonitoringCRD, targetStatusEnabled bool) error

func SyntheticAppDeploy

func SyntheticAppDeploy(ctx context.Context, kubeClient client.Client, namespace, name string, args []string) (*appsv1.Deployment, error)

func WaitForCollectionReady

func WaitForCollectionReady(ctx context.Context, kubeClient client.Client, operatorNamespace string) error

func WaitForNodeMonitoringReady

func WaitForNodeMonitoringReady(ctx context.Context, kubeClient client.Client, operatorNamespace string, nm monitoringv1.MonitoringCRD) error

func WaitForOperatorReady

func WaitForOperatorReady(ctx context.Context, kubeClient client.Client, operatorNamespace string) error

func WaitForPodMonitoringFailure

func WaitForPodMonitoringFailure(ctx context.Context, kubeClient client.Client, pm monitoringv1.PodMonitoringCRD, expectedFn func(message string) error) error

func WaitForPodMonitoringReady

func WaitForPodMonitoringReady(ctx context.Context, kubeClient client.Client, operatorNamespace string, pm monitoringv1.PodMonitoringCRD, targetStatusEnabled bool) error

func WaitForPodMonitoringSuccess

func WaitForPodMonitoringSuccess(ctx context.Context, kubeClient client.Client, pm monitoringv1.PodMonitoringCRD) error