kubequery

package
v1.116.0-rc.1 Latest Latest
Warning

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

Go to latest
Published: May 19, 2026 License: MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source
const RadixMetadataAnnotation = "radix.equinor.com/secret-metadata"

Variables

This section is empty.

Functions

func GetCertificateRequestsForEnvironment

func GetCertificateRequestsForEnvironment(ctx context.Context, client certclient.Interface, appName, envName string) ([]cmv1.CertificateRequest, error)

GetCertificateRequestsForEnvironment returns all CertificateRequests in the environment namespace. CertificateRequests are not filtered by app and envionment labels since cert-manager is managing these objects, and we have no control of what labels cert-manager will set. All we know is that a CertificateRequest is owned by a Certificate, and this is what we use to find correspnding CertificateRequests for a given Certificate.

func GetCertificatesForEnvironment

func GetCertificatesForEnvironment(ctx context.Context, client certclient.Interface, appName, envName string) ([]cmv1.Certificate, error)

GetCertificatesForEnvironment returns all Certificates for the specified application and environment.

func GetDNSAliases

func GetDNSAliases(ctx context.Context, client radixclient.Interface, radixApplication *radixv1.RadixApplication) []radixv1.RadixDNSAlias

GetDNSAliases returns all RadixDNSAliases for the specified application.

func GetDeploymentsForEnvironment

func GetDeploymentsForEnvironment(ctx context.Context, client kubernetes.Interface, appName, envName string) ([]appsv1.Deployment, error)

GetDeploymentsForEnvironment returns all Deployments for the specified application and environment.

func GetEventsForEnvironment

func GetEventsForEnvironment(ctx context.Context, client kubernetes.Interface, appName, envName string) ([]corev1.Event, error)

GetEventsForEnvironment returns all Events for the specified application and environment.

func GetHorizontalPodAutoscalersForEnvironment

func GetHorizontalPodAutoscalersForEnvironment(ctx context.Context, client kubernetes.Interface, appName, envName string) ([]autoscalingv2.HorizontalPodAutoscaler, error)

GetHorizontalPodAutoscalersForEnvironment returns all HorizontalPodAutoscalers for the specified application and environment.

func GetLatestRadixDeployment

func GetLatestRadixDeployment(ctx context.Context, radixClient radixclient.Interface, appName, envName string) (*radixv1.RadixDeployment, error)

GetLatestRadixDeployment returns the last active Radix Deployment found in environment, will be nil if not found

func GetPodsForEnvironmentComponents

func GetPodsForEnvironmentComponents(ctx context.Context, client kubernetes.Interface, appName, envName string) ([]corev1.Pod, error)

GetPodsForEnvironmentComponents returns all Radix component pods for the specified application and environments.

func GetRadixApplication

func GetRadixApplication(ctx context.Context, client radixclient.Interface, appName string) (*radixv1.RadixApplication, error)

GetRadixApplication returns the RadixApplication for the specified application name.

func GetRadixBatch

func GetRadixBatch(ctx context.Context, radixClient radixclient.Interface, appName, envName, jobComponentName, batchName string, batchType kube.RadixBatchType) (*radixv1.RadixBatch, error)

GetRadixBatch Get Radix batch

func GetRadixBatches

func GetRadixBatches(ctx context.Context, radixClient radixclient.Interface, appName, envName, jobComponentName string, batchType kube.RadixBatchType) ([]*radixv1.RadixBatch, error)

GetRadixBatches Get Radix batches

func GetRadixBatchesForJobComponent

func GetRadixBatchesForJobComponent(ctx context.Context, client radixclient.Interface, appName, envName, jobComponentName string, batchType kube.RadixBatchType) ([]radixv1.RadixBatch, error)

func GetRadixDeploymentByName

func GetRadixDeploymentByName(ctx context.Context, radixClient radixclient.Interface, appName, envName, deploymentName string) (*radixv1.RadixDeployment, error)

GetRadixDeploymentByName returns a RadixDeployment for an application and namespace

func GetRadixDeploymentsForEnvironment

func GetRadixDeploymentsForEnvironment(ctx context.Context, radixClient radixclient.Interface, appName, envName string) ([]radixv1.RadixDeployment, error)

GetRadixDeploymentsForEnvironment returns all RadixDeployments for the specified application and environment.

func GetRadixDeploymentsForEnvironments

func GetRadixDeploymentsForEnvironments(ctx context.Context, client radixclient.Interface, appName string, envNames []string, parallelism int) ([]radixv1.RadixDeployment, error)

GetRadixDeploymentsForEnvironments returns all RadixDeployments for the specified application and environments. Go routines are used to query RDs per environment, and number of concurrent Go routines is controlled with the parallelism parameter.

func GetRadixDeploymentsMapForEnvironment

func GetRadixDeploymentsMapForEnvironment(ctx context.Context, radixClient radixclient.Interface, appName, envName string) (map[string]radixv1.RadixDeployment, error)

GetRadixDeploymentsMapForEnvironment returns all RadixDeployments for the specified application and environment as a map by names.

func GetRadixEnvironment

func GetRadixEnvironment(ctx context.Context, client radixclient.Interface, appName, envName string) (*radixv1.RadixEnvironment, error)

GetRadixEnvironment returns the RadixEnvironment for the specified application and environment.

func GetRadixEnvironments

func GetRadixEnvironments(ctx context.Context, client radixclient.Interface, appName string) ([]radixv1.RadixEnvironment, error)

GetRadixEnvironments returns all RadixEnvironments for the specified application.

func GetRadixJob

func GetRadixJob(ctx context.Context, client radixclient.Interface, appName, jobName string) (*radixv1.RadixJob, error)

GetRadixJob returns the RadixJob for the specified application and job name.

func GetRadixJobs

func GetRadixJobs(ctx context.Context, client radixclient.Interface, appName string) ([]radixv1.RadixJob, error)

GetRadixJobs returns all RadixJobs for the specified application.

func GetRadixRegistration

func GetRadixRegistration(ctx context.Context, client radixclient.Interface, appName string) (*radixv1.RadixRegistration, error)

GetRadixRegistration returns the RadixRegistration for the specified application name.

func GetScaledObjectsForEnvironment

func GetScaledObjectsForEnvironment(ctx context.Context, kedaClient versioned.Interface, appName, envName string) ([]v1alpha1.ScaledObject, error)

GetScaledObjectsForEnvironment returns all ScaledObjects for the specified application and environment.

func GetSecretProviderClassesForEnvironment

func GetSecretProviderClassesForEnvironment(ctx context.Context, client secretProviderClient.Interface, appName, envName string) ([]secretsstorev1.SecretProviderClass, error)

GetSecretProviderClassesForEnvironment returns all SecretProviderClasses for the specified application and environment.

func GetSecretsForEnvironment

func GetSecretsForEnvironment(ctx context.Context, client kubernetes.Interface, appName, envName string, req ...labels.Requirement) ([]corev1.Secret, error)

GetSecretsForEnvironment returns all Secrets for the specified application and environment.

func IsRadixApplicationAdmin

func IsRadixApplicationAdmin(ctx context.Context, kubeClient kubernetes.Interface, appName string) (bool, error)

func PatchSecretMetadata

func PatchSecretMetadata(secret *corev1.Secret, key string, updatedAt time.Time) error

PatchSecretMetadata sets the updatedAt in a metadata annotation on the secret

Types

type SecretMetadata

type SecretMetadata map[string]SecretMetadataItem

func GetSecretMetadata

func GetSecretMetadata(ctx context.Context, secret *corev1.Secret) *SecretMetadata

GetSecretMetadata returns a nullsafe SecretMetadata that reads metadata from the secret

func (*SecretMetadata) GetUpdated

func (m *SecretMetadata) GetUpdated(key string) *time.Time

GetUpdated reads the updated time from the secret

type SecretMetadataItem

type SecretMetadataItem struct {
	Updated *time.Time `json:"updated,omitempty"`
}

Jump to

Keyboard shortcuts

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