test

Documentation

Index

• func DrainChan(requests <-chan reconcile.Request, timeout time.Duration)
• func ExpectGetGlobalService(cli client.Client, key client.ObjectKey) apis.GlobalService
• func ExpectGlobalServiceNotFound(cli client.Client, key client.ObjectKey)
• func ExpectNamespaceExists(cli client.Client, name string)
• func ExpectNamespaceNotExists(cli client.Client, name string)
• func GenerateGetNameFunc(namePrefix string) func() string
• func PurgeAllEndpointSlices(cli client.Client, opts ...client.ListOption)
• func PurgeAllGlobalServices(cli client.Client, opts ...client.ListOption)
• func PurgeAllServices(cli client.Client, opts ...client.ListOption)
• func SetupLogger()
• func StartTestEnv() (env *envtest.Environment, cfg *rest.Config, cli client.Client, err error)
• func StartTestEnvWithCRD(CRDDirectoryPaths []string) (env *envtest.Environment, cfg *rest.Config, cli client.Client, err error)
• func StartTestEnvWithCRDAndScheme(CRDDirectoryPaths []string, scheme *runtime.Scheme) (env *envtest.Environment, cfg *rest.Config, cli client.Client, err error)
• func WrapReconcile(inner reconcile.Reconciler) (reconcile.Reconciler, chan reconcile.Request)
• func WrapReconcileFunc(inner reconcile.Func) (reconcile.Func, chan reconcile.Request)

Functions

func DrainChan

func DrainChan(requests <-chan reconcile.Request, timeout time.Duration)

DrainChan drains the request chan time for drainTimeout

func ExpectGetGlobalService

func ExpectGetGlobalService(cli client.Client, key client.ObjectKey) apis.GlobalService

func ExpectGlobalServiceNotFound

func ExpectGlobalServiceNotFound(cli client.Client, key client.ObjectKey)

func ExpectNamespaceExists

func ExpectNamespaceExists(cli client.Client, name string)

func ExpectNamespaceNotExists

func ExpectNamespaceNotExists(cli client.Client, name string)

func GenerateGetNameFunc

func GenerateGetNameFunc(namePrefix string) func() string

func PurgeAllEndpointSlices

func PurgeAllEndpointSlices(cli client.Client, opts ...client.ListOption)

func PurgeAllGlobalServices

func PurgeAllGlobalServices(cli client.Client, opts ...client.ListOption)

func PurgeAllServices

func PurgeAllServices(cli client.Client, opts ...client.ListOption)

func SetupLogger

func SetupLogger()

func StartTestEnv

func StartTestEnv() (env *envtest.Environment, cfg *rest.Config, cli client.Client, err error)

func StartTestEnvWithCRD

func StartTestEnvWithCRD(CRDDirectoryPaths []string) (env *envtest.Environment, cfg *rest.Config, cli client.Client, err error)

func StartTestEnvWithCRDAndScheme

func StartTestEnvWithCRDAndScheme(CRDDirectoryPaths []string, scheme *runtime.Scheme) (env *envtest.Environment, cfg *rest.Config, cli client.Client, err error)

func WrapReconcile

func WrapReconcile(inner reconcile.Reconciler) (reconcile.Reconciler, chan reconcile.Request)

WrapReconcile returns a reconcile.Reconcile implementation that delegates to inner and writes the request to requests after Reconcile is finished.

func WrapReconcileFunc

func WrapReconcileFunc(inner reconcile.Func) (reconcile.Func, chan reconcile.Request)

WrapReconcileFunc returns a reconcile.Func implementation that delegates to inner and writes the request to requests after Reconcile is finished.