helpers

Oct 18, 2024

Changes in this version

+ func EnsureCreate(k8sClient client.Client, obj client.Object)

+ func EnsureDelete(k8sClient client.Client, obj client.Object)

+ func EnsurePatch[T any, PT k8s.ObjectWithDeepCopy[T]](k8sClient client.Client, obj PT, modifyFunc func(PT))

+ func GetInClusterURL(appGUID string) string

Jun 5, 2024

Changes in this version

+ func GetApiServerRoot() string

+ func ZipDirectory(srcDir string) string

Jan 23, 2024

Changes in this version

+ func NewUncachedClient(cfg *rest.Config) client.Client

Oct 30, 2023

Changes in this version

+ func Cf(args ...string) *gexec.Session

+ func EventuallyPollingInterval() time.Duration

Sep 28, 2023

Changes in this version

+ func AddUserToKubeConfig(userName, userToken string)

+ func CreateSelfSignedCertificatePEM() []byte

+ func CreateTrustedCertificatePEM(userName string, validFor time.Duration) []byte

+ func EventuallyTimeout() time.Duration

+ func GetDefaultedEnvVar(envVarName, defaultValue string) string

+ func GetRequiredEnvVar(envVarName string) string

+ func Kubectl(args ...string) *Session

+ func KubectlApply(stdinText string, sprintfArgs ...any) *Session

+ func KubectlWithCustomReporter(cmdStarter *commandstarter.CommandStarter, ...) *Session

+ func NewActualRestyResponse(response *resty.Response) actualRestyResponse

+ func RemoveUserFromKubeConfig(userName string)

+ type CorrelatedRestyClient struct

+ func NewCorrelatedRestyClient(apiServerRoot string, getCorrelationId func() string) *CorrelatedRestyClient

+ func (c *CorrelatedRestyClient) R() *resty.Request

+ func (c *CorrelatedRestyClient) SetAuthScheme(scheme string) *CorrelatedRestyClient

+ func (c *CorrelatedRestyClient) SetAuthToken(token string) *CorrelatedRestyClient

+ func (c *CorrelatedRestyClient) SetTLSClientConfig(config *tls.Config) *CorrelatedRestyClient

+ type ServiceAccountFactory struct

+ func NewServiceAccountFactory(rootNamespace string) *ServiceAccountFactory

+ func (f *ServiceAccountFactory) CreateAdminServiceAccount(adminServiceAccount string) string

+ func (f *ServiceAccountFactory) CreateServiceAccount(name string) string

+ func (f *ServiceAccountFactory) DeleteServiceAccount(name string)

+ func (f *ServiceAccountFactory) FullyQualifiedName(svcAcctName string) string

type SyncClient

+ func (c *SyncClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

Jul 17, 2023

Changes in this version

+ func EventuallyShouldHold(condition func(g Gomega))

+ func NewCachedClient(cfg *rest.Config) (client.Client, context.CancelFunc)

+ func NewK8sManager(testEnv *envtest.Environment, managerRolePath string) manager.Manager

+ func SetupTestEnvUser(testEnv *envtest.Environment, roleDefinitionPath string) *rest.Config

+ func StartK8sManager(k8sManager manager.Manager) context.CancelFunc

+ type SyncClient struct

+ func NewSyncClient(k8sClient client.Client) *SyncClient

+ func (c *SyncClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error

+ func (c *SyncClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error

+ func (c *SyncClient) Status() client.SubResourceWriter

May 24, 2022

Changes in this version

+ func CreateCertificatePEM() []byte