utils

Documentation

Index

• func ApplyApplicationWithSync(client kubernetes.Interface, radixclient radixclient.Interface, ...)
• func ApplyDeploymentWithSync(client kubernetes.Interface, radixclient radixclient.Interface, ...)
• func ApplyRegistrationWithSync(client kubernetes.Interface, radixclient radixclient.Interface, ...)
• func CreateApplicationConfig(client kubernetes.Interface, radixClient radixclient.Interface, ...) (*applicationconfig.ApplicationConfig, error)
• func IsBefore(j, i Job) bool
• func SetupTest() (*commontest.Utils, kubernetes.Interface, radixclient.Interface, ...)
• type DeployKey
  • func GenerateDeployKey() (*DeployKey, error)
• type Job
• type KubeUtil
  • func NewKubeUtil(useOutClusterClient bool) KubeUtil
• type RadixMiddleware
  • func NewRadixMiddleware(kubeUtil KubeUtil, path, method string, allowUnauthenticatedUsers bool, ...) *RadixMiddleware
  • func (handler *RadixMiddleware) Handle(w http.ResponseWriter, r *http.Request)
• type RestClientConfigOption
  • func WithBurst(burst int) RestClientConfigOption
  • func WithQPS(qps float32) RestClientConfigOption

Functions

func ApplyApplicationWithSync

func ApplyApplicationWithSync(client kubernetes.Interface, radixclient radixclient.Interface, commonTestUtils *commontest.Utils, applicationBuilder utils.ApplicationBuilder)

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

func ApplyDeploymentWithSync

func ApplyDeploymentWithSync(client kubernetes.Interface, radixclient radixclient.Interface, promclient prometheusclient.Interface, commonTestUtils *commontest.Utils, secretproviderclient secretsstorevclient.Interface, deploymentBuilder builders.DeploymentBuilder)

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

func ApplyRegistrationWithSync

func ApplyRegistrationWithSync(client kubernetes.Interface, radixclient radixclient.Interface, commonTestUtils *commontest.Utils, registrationBuilder utils.RegistrationBuilder)

ApplyRegistrationWithSync syncs based on registration builder

func CreateApplicationConfig

func CreateApplicationConfig(client kubernetes.Interface, radixClient radixclient.Interface, secretProviderClient secretsstorevclient.Interface, appName string) (*applicationconfig.ApplicationConfig, error)

CreateApplicationConfig creates an application config based on input

func IsBefore

func IsBefore(j, i Job) bool

IsBefore Checks that job-j is before job-i

func SetupTest

func SetupTest() (*commontest.Utils, kubernetes.Interface, radixclient.Interface, prometheusclient.Interface, secretsstorevclient.Interface)

Types

type DeployKey

type DeployKey struct {
	PrivateKey string
	PublicKey  string
}

DeployKey Represention of a deploy key pair

func GenerateDeployKey

func GenerateDeployKey() (*DeployKey, error)

GenerateDeployKey Generates a deploy key

type Job

type Job interface {
	GetCreated() string
	GetStarted() string
	GetEnded() string
	GetStatus() string
}

type KubeUtil

type KubeUtil interface {
	GetOutClusterKubernetesClient(string, ...RestClientConfigOption) (kubernetes.Interface, radixclient.Interface, secretProviderClient.Interface)
	GetOutClusterKubernetesClientWithImpersonation(string, radixmodels.Impersonation, ...RestClientConfigOption) (kubernetes.Interface, radixclient.Interface, secretProviderClient.Interface)
	GetInClusterKubernetesClient(...RestClientConfigOption) (kubernetes.Interface, radixclient.Interface, secretProviderClient.Interface)
}

KubeUtil Interface to be mocked in tests

func NewKubeUtil

func NewKubeUtil(useOutClusterClient bool) 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) Handle

func (handler *RadixMiddleware) Handle(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