helpers

Documentation

Index

• func AddUserToKubeConfig(userName, userToken string)
• func Cf(args ...string) *Session
• func CreateSelfSignedCertificatePEM() []byte
• func CreateTrustedCertificatePEM(userName string, validFor time.Duration) []byte
• 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 EventuallyPollingInterval() time.Duration
• func EventuallyShouldHold(condition func(g Gomega))
• func EventuallyTimeout() time.Duration
• func GetApiServerRoot() string
• func GetDefaultedEnvVar(envVarName, defaultValue string) string
• func GetInClusterURL(appGUID string) string
• func GetRequiredEnvVar(envVarName string) string
• func NewActualRestyResponse(response *resty.Response) actualRestyResponse
• func NewCachedClient(cfg *rest.Config) (client.Client, context.CancelFunc)
• func NewK8sManager(testEnv *envtest.Environment, managerRolePath string) manager.Manager
• func NewUncachedClient(cfg *rest.Config) client.Client
• func RemoveUserFromKubeConfig(userName string)
• func SetupTestEnvUser(testEnv *envtest.Environment, roleDefinitionPath string) *rest.Config
• func StartK8sManager(k8sManager manager.Manager) context.CancelFunc
• func ZipDirectory(srcDir string) string
• type CorrelatedRestyClient
  • 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
  • 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 NewSyncClient(k8sClient client.Client) *SyncClient
  • func (c *SyncClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
  • func (c *SyncClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
  • func (c *SyncClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error
  • func (c *SyncClient) Status() client.SubResourceWriter

Functions

func AddUserToKubeConfig

func AddUserToKubeConfig(userName, userToken string)

func Cf

func Cf(args ...string) *Session

func CreateSelfSignedCertificatePEM

func CreateSelfSignedCertificatePEM() []byte

func CreateTrustedCertificatePEM

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

func EnsureCreate

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

func EnsureDelete

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

func EnsurePatch

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

func EventuallyPollingInterval

func EventuallyPollingInterval() time.Duration

func EventuallyShouldHold

func EventuallyShouldHold(condition func(g Gomega))

func EventuallyTimeout

func EventuallyTimeout() time.Duration

func GetApiServerRoot

func GetApiServerRoot() string

func GetDefaultedEnvVar

func GetDefaultedEnvVar(envVarName, defaultValue string) string

func GetInClusterURL

func GetInClusterURL(appGUID string) string

func GetRequiredEnvVar

func GetRequiredEnvVar(envVarName string) string

func NewActualRestyResponse

func NewActualRestyResponse(response *resty.Response) actualRestyResponse

func NewCachedClient

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

func NewK8sManager

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

func NewUncachedClient

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

func RemoveUserFromKubeConfig

func RemoveUserFromKubeConfig(userName string)

func SetupTestEnvUser

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

func StartK8sManager

func StartK8sManager(k8sManager manager.Manager) context.CancelFunc

func ZipDirectory

func ZipDirectory(srcDir string) string

Types

type CorrelatedRestyClient

type CorrelatedRestyClient struct {
	*resty.Client
	// contains filtered or unexported fields
}

func NewCorrelatedRestyClient

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

func (*CorrelatedRestyClient) R

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

func (*CorrelatedRestyClient) SetAuthScheme

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

func (*CorrelatedRestyClient) SetAuthToken

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

func (*CorrelatedRestyClient) SetTLSClientConfig

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

type ServiceAccountFactory

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

func NewServiceAccountFactory

func NewServiceAccountFactory(rootNamespace string) *ServiceAccountFactory

func (*ServiceAccountFactory) CreateAdminServiceAccount

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

func (*ServiceAccountFactory) CreateServiceAccount

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

func (*ServiceAccountFactory) DeleteServiceAccount

func (f *ServiceAccountFactory) DeleteServiceAccount(name string)

func (*ServiceAccountFactory) FullyQualifiedName

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

type SyncClient

type SyncClient struct {
	client.Client
}

func NewSyncClient

func NewSyncClient(k8sClient client.Client) *SyncClient

func (*SyncClient) Create

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

func (*SyncClient) Delete

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

func (*SyncClient) Patch

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

func (*SyncClient) Status

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