utils

package
v0.15.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 4, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DeleteAgent added in v0.10.1

func DeleteAgent(name, namespace string) error

DeleteAgent deletes an agent resource

func GetNonEmptyLines

func GetNonEmptyLines(output string) []string

GetNonEmptyLines converts given command output string into individual objects according to line breakers, and ignores the empty elements in it.

func GetProjectDir

func GetProjectDir() (string, error)

GetProjectDir will return the directory where the project is

func GetRequest added in v0.15.1

func GetRequest(url string) ([]byte, int, error)

GetRequest sends a GET request and returns the response body, status code, and error. This function does not treat non-200 status codes as errors, allowing callers to explicitly check for specific status codes like 404.

func InstallCertManager

func InstallCertManager() error

InstallCertManager installs the cert manager bundle.

func InstallPrometheusOperator

func InstallPrometheusOperator() error

InstallPrometheusOperator installs the prometheus Operator to be used to export the enabled metrics.

func IsCertManagerCRDsInstalled

func IsCertManagerCRDsInstalled() bool

IsCertManagerCRDsInstalled checks if any Cert Manager CRDs are installed by verifying the existence of key CRDs related to Cert Manager.

func IsPrometheusCRDsInstalled

func IsPrometheusCRDsInstalled() bool

IsPrometheusCRDsInstalled checks if any Prometheus CRDs are installed by verifying the existence of key CRDs related to Prometheus.

func LoadImageToKindClusterWithName

func LoadImageToKindClusterWithName(name string) error

LoadImageToKindClusterWithName loads a local docker image to the kind cluster

func MakeServiceRequest added in v0.10.1

func MakeServiceRequest(
	namespace, serviceName string,
	servicePort int,
	requestFunc RequestFunc,
) (body []byte, statusCode int, err error)

MakeServiceRequest establishes a port-forward to the service, makes an HTTP request, and cleans up. The requestFunc receives the base URL (e.g., "http://localhost:12345") and performs the actual request. Non-2xx HTTP status codes are returned successfully (not treated as errors), allowing callers to verify specific status codes like 404.

func PortForwardPod added in v0.10.1

func PortForwardPod(ctx context.Context, namespace, podName string, port int) (int, error)

PortForwardPod creates a port forward to a specific pod

func PortForwardService added in v0.10.1

func PortForwardService(ctx context.Context, namespace, serviceName string, port int) (int, error)

PortForwardService creates a port forward to a service by resolving it to a pod

func PostRequest added in v0.15.1

func PostRequest(url string, payload any, headers map[string]string) ([]byte, int, error)

PostRequest sends a POST request with a JSON payload and custom headers, returning the response body, status code, and error. This function does not treat non-200 status codes as errors.

func Run

func Run(cmd *exec.Cmd) (string, error)

Run executes the provided command within this context

func UninstallCertManager

func UninstallCertManager()

UninstallCertManager uninstalls the cert manager

func UninstallPrometheusOperator

func UninstallPrometheusOperator()

UninstallPrometheusOperator uninstalls the prometheus

func VerifyDeploymentReady added in v0.10.1

func VerifyDeploymentReady(name, namespace string, timeout time.Duration) error

VerifyDeploymentReady verifies that a deployment is ready within the given timeout

Types

type RequestFunc added in v0.10.1

type RequestFunc func(baseURL string) (body []byte, statusCode int, err error)

RequestFunc defines a function that makes an HTTP request given a base URL (host:port)

Jump to

Keyboard shortcuts

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