utils

package
v1.116.0 Latest Latest
Warning

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

 Go to latest Published: May 20, 2026 License: MIT Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ApplyApplicationWithSync 

func ApplyApplicationWithSync(client kubernetes.Interface, radixclient radixclient.Interface, kedaClient kedav2.Interface, commonTestUtils *commontest.Utils, applicationBuilder operatorutils.ApplicationBuilder) error

ApplyApplicationWithSync syncs based on application builder, and default builder for registration.

func ApplyDeploymentWithSync 

func ApplyDeploymentWithSync(client kubernetes.Interface, radixclient radixclient.Interface, kedaClient kedav2.Interface, dynamicClient dynamicclient.Client, commonTestUtils *commontest.Utils, secretproviderclient secretsstorevclient.Interface, certClient *certfake.Clientset, deploymentBuilder operatorutils.DeploymentBuilder) error

ApplyDeploymentWithSync syncs based on deployment builder, and default builders for application and registration.

func ApplyRegistrationWithSync 

func ApplyRegistrationWithSync(client kubernetes.Interface, radixclient radixclient.Interface, kedaClient kedav2.Interface, commonTestUtils *commontest.Utils, registrationBuilder operatorutils.RegistrationBuilder) error

ApplyRegistrationWithSync syncs based on registration builder

func GetBatchJobStatusByJobApiCondition 

func GetBatchJobStatusByJobApiCondition(conditionType v1.RadixBatchConditionType) models.ScheduledBatchJobStatus

GetBatchJobStatusByJobApiCondition Get batch job status by job api condition

func GetBatchJobStatusByJobApiStatus 

func GetBatchJobStatusByJobApiStatus(status v1.RadixBatchJobApiStatus) models.ScheduledBatchJobStatus

GetBatchJobStatusByJobApiStatus Get batch job status by job api status

func GetComponentEnvironmentConfig 

func GetComponentEnvironmentConfig(ra *radixv1.RadixApplication, envName, componentName string) radixv1.RadixCommonEnvironmentConfig

GetComponentEnvironmentConfig Gets environment config of component

func IsBefore 

func IsBefore(j, i Job) bool

IsBefore Checks that job-j is before job-i

Types

type Job 

type Job interface {
	GetCreated() *time.Time
	GetStarted() *time.Time
	GetEnded() *time.Time
	GetStatus() string
}

type KubeUtil 

type KubeUtil interface {
	GetUserKubernetesClient(string, radixmodels.Impersonation, ...RestClientConfigOption) (kubernetes.Interface, radixclient.Interface, kedav2.Interface, secretproviderclient.Interface, tektonclient.Interface, certclient.Interface)
	GetServerKubernetesClient(...RestClientConfigOption) (kubernetes.Interface, radixclient.Interface, kedav2.Interface, secretproviderclient.Interface, tektonclient.Interface, certclient.Interface)
}

KubeUtil Interface to be mocked in tests

func NewKubeUtil 

func NewKubeUtil() KubeUtil

NewKubeUtil Constructor

type RadixMiddleware 

type RadixMiddleware struct {
	// contains filtered or unexported fields
}

RadixMiddleware The middleware between router and radix handler functions

func NewRadixMiddleware 

func NewRadixMiddleware(kubeUtil KubeUtil, path, method string, allowUnauthenticatedUsers bool, kubeApiQPS float32, kubeApiBurst int, next models.RadixHandlerFunc) *RadixMiddleware

NewRadixMiddleware Constructor for radix middleware

func (*RadixMiddleware) ServeHTTP 

func (handler *RadixMiddleware) ServeHTTP(w http.ResponseWriter, r *http.Request)

Handle Wraps radix handler methods

type RestClientConfigOption 

type RestClientConfigOption func(*restclient.Config)

func WithBurst 

func WithBurst(burst int) RestClientConfigOption

func WithQPS 

func WithQPS(qps float32) RestClientConfigOption

Source Files

View all Source files

Directories

Path Synopsis
mock
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.
mock
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.