helpers

Documentation

Index

• func EnsureCreate(k8sClient client.Client, obj client.Object)
• func EnsureDelete(k8sClient client.Client, obj client.Object)
• func EnsurePatch[T client.Object](k8sClient client.Client, obj T, modifyFunc func(T))
• 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 NewUncachedClient(cfg *rest.Config) client.Client
• func SetupTestEnvUser(testEnv *envtest.Environment, roleDefinitionPath string) *rest.Config
• func StartK8sManager(k8sManager manager.Manager) context.CancelFunc
• 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 EnsureCreate

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

func EnsureDelete

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

func EnsurePatch

func EnsurePatch[T client.Object](k8sClient client.Client, obj T, modifyFunc func(T))

func EventuallyShouldHold

func EventuallyShouldHold(condition func(g Gomega))

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 SetupTestEnvUser

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

func StartK8sManager

func StartK8sManager(k8sManager manager.Manager) context.CancelFunc

Types

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