test

Nov 17, 2023

Changes in this version

+ func StartSinkHTTPServer(ctx context.Context, path string, mut *SinkMutator) (address string)

type Environment

+ func (e *Environment) StartEmbeddedOTELCollector(parentCtx context.Context, config []byte, configPath string)

+ type SinkMutator struct

+ func NewSinkMutator(testFn func(bytes.Buffer)) *SinkMutator

+ func (sm *SinkMutator) SetFn(newFn func(bytes.Buffer))

Nov 3, 2023

Changes in this version

+ type CortexClientTlsConfig = struct

+ CAPath string

+ CertPath string

+ InsecureSkipVerify bool

+ KeyPath string

+ ServerName string

+ type CortexConfigOptions = struct

+ GrpcListenAddress string

+ GrpcListenNetwork string

+ GrpcListenPort int

+ HttpListenAddress string

+ HttpListenNetwork string

+ HttpListenPort int

+ RuntimeConfig string

+ StorageDir string

+ TLSCortexClientConfig CortexClientTlsConfig

+ TLSGatewayClientConfig CortexClientTlsConfig

+ TLSServerConfig CortexServerTlsConfig

+ type CortexServerTlsConfig = struct

+ ClientAuth string

+ ClientCAs string

+ TLSCertPath string

+ TLSKeyPath string

type Environment

+ func (e *Environment) AlertingClientTLSConfig() *tls.Config

+ func (e *Environment) AlertingDataDir() string

+ type ImplementationSpecificOverrides = struct

+ AlertManager configutil.AlertmanagerOverrideShape

+ MemberlistJoinAddrs []string

+ QueryFrontendAddress string

Aug 9, 2023

Changes in this version

+ type AlertManagerPorts struct

+ ApiPort int

+ ClusterPort int

+ EmbeddedPort int

type Environment

+ func (e *Environment) BootstrapNewAgent(id string, opts ...StartAgentOption) error

+ func (e *Environment) DeleteAgent(id string) error

+ func (e *Environment) GatewayClientTLSConfig() *tls.Config

+ func (e *Environment) NewStreamConnection(pins []string) (grpc.ClientConnInterface, <-chan error)

+ func (e *Environment) UnsafeStartPrometheus(ctx waitctx.PermissiveContext, opniAgentId string, ...) (int, error)

+ type TestPluginSet map[meta.PluginMode][]testPlugin

+ func (tp TestPluginSet) EnablePlugin(pkgName, pluginName string, mode meta.PluginMode, ...)

+ func (tp TestPluginSet) LoadPlugins(ctx context.Context, loader *plugins.PluginLoader, mode meta.PluginMode) int

Jun 7, 2023

Changes in this version

type TestAggregatorConfig

+ HealthCheckAddress string

Apr 26, 2023

Changes in this version

+ func EnablePlugin(mode meta.PluginMode, schemeFunc func(context.Context) meta.Scheme)

+ func FindTestBin() (string, error)

+ type EnvClientOption func(o *EnvClientOptions)

+ func WithClientCaching(memoryLimitBytes int64, _ time.Duration) EnvClientOption

+ type EnvClientOptions struct

type Environment

+ func EnvFromContext(ctx context.Context) *Environment

+ func (e *Environment) GetPorts() ServicePorts

+ func (e *Environment) SetPrometheusNodeConfigOverride(agentId string, override *OverridePrometheusConfig)

+ func (e *Environment) SimulateKubeObject(kPort int)

+ func (e *Environment) StartOTELCollectorContext(parentCtx waitctx.PermissiveContext, opniAgentId string, spec *otel.OTELSpec)

+ func (e *Environment) StartPrometheusContext(ctx waitctx.PermissiveContext, opniAgentId string, ...) int

+ type OverridePrometheusConfig struct

+ type ServicePorts struct

+ CortexGRPC int

+ CortexHTTP int

+ DisconnectPort int

+ Etcd int

+ GatewayGRPC int

+ GatewayHTTP int

+ GatewayMetrics int

+ Jetstream int

+ ManagementGRPC int

+ ManagementHTTP int

+ ManagementWeb int

+ NodeExporterPort int

+ TestEnvironment int

type StartAgentOption

+ func WithListenPort(port int) StartAgentOption

+ type TestAggregatorConfig struct

+ AgentEndpoint string

+ AggregatorAddress string

+ Containerized bool

+ LogsEnabled bool

+ Metrics otel.MetricsConfig

+ func (t TestAggregatorConfig) MetricReceivers() []string

+ type TestNodeConfig struct

+ AggregatorAddress string

+ Containerized bool

+ Instance string

+ Logs otel.LoggingConfig

+ Metrics otel.MetricsConfig

+ ReceiverFile string

+ func (t TestNodeConfig) MetricReceivers() []string

Apr 6, 2023

Changes in this version

type Environment

+ func (e *Environment) GetTempDirectory() string

+ func (e *Environment) StartGrafana(extraDockerArgs ...string)

+ func (e *Environment) WriteGrafanaConfig()

type PrometheusJob

+ MetricsPath string

Mar 17, 2023

Changes in this version

+ const MockClientCertName

+ var ErrContext_TestKeyringStore_Get = context.WithValue(context.Background(), errContextValue, "error")

+ func IfIntegration(f func())

+ func IfLabelFilterMatches(labels ginkgo.Labels, f func())

+ type AlarmPair = lo.Tuple2[*alertingv1.ListAlarmMessageRequest, int]

type AlertingServerUnit

+ OpniPort int

+ type NotificationPair = lo.Tuple2[*alertingv1.ListNotificationRequest, int]

+ type RoutableDataset struct

+ ExpectedAlarms []AlarmPair

+ ExpectedNotifications []NotificationPair

+ Routables []interfaces.Routable

+ func NewRoutableDataset() *RoutableDataset

type StartAgentOption

+ func WithLocalAgent() StartAgentOption

type TestCertManager

+ func (m *TestCertManager) GetClientCertRef(_ string) (corev1.LocalObjectReference, error)

+ type TestChallengeHandler struct

+ func NewTestChallengeHandler(fn challenges.HandlerFunc, kvs ...string) *TestChallengeHandler

+ func (t *TestChallengeHandler) DoChallenge(ss streams.Stream) (context.Context, error)

+ func (t *TestChallengeHandler) InterceptContext(ctx context.Context) context.Context

Mar 3, 2023

Changes in this version

type Environment

+ func (e *Environment) NewAlertNotificationsClient() alertingv1.AlertNotificationsClient

Feb 16, 2023

Changes in this version

+ const OpCreate

+ const OpDelete

+ const OpUpdate

+ func CreateRandomSetOfEndpoints() map[string]*alertingv1.FullAttachedEndpoint

+ func ExpectAlertManagerConfigToBeValid(env *Environment, tmpWritePath string, writeFile string, ctx context.Context, ...)

+ func ExpectConfigEqual(c1, c2 *config.Config, name ...string)

+ func ExpectConfigNotEqual(c1, c2 *config.Config, name ...string)

+ func ExpectRouterEqual(r1, r2 routing.OpniRouting, name ...string)

+ func ExpectRouterNotEqual(r1, r2 routing.OpniRouting, name ...string)

+ func ExpectToRecoverConfig(router routing.OpniRouting, name ...string)

+ func GenerateEndpoint(genId int, uuid string) *alertingv1.FullAttachedEndpoint

+ type AlertingServerUnit struct

+ AlertManagerPort int

+ CancelFunc context.CancelFunc

+ ClusterPort int

+ Ctx context.Context

+ type DefaultNamespaceSubTreeTestcase struct

+ Endpoints []*alertingv1.AlertEndpoint

+ func CreateRandomDefaultNamespacedTestcases(endpSet map[string]*alertingv1.FullAttachedEndpoint) []DefaultNamespaceSubTreeTestcase

type Environment

+ func (e *Environment) CreateWebhookServer(parentCtx context.Context, num int) []*MockIntegrationWebhookServer

+ func (e *Environment) NewAlertConditionsClient() alertingv1.AlertConditionsClient

+ func (e *Environment) NewAlertEndpointsClient() alertingv1.AlertEndpointsClient

+ func (e *Environment) NewAlertOpsClient() alertops.AlertingAdminClient

+ func (e *Environment) NewAlertTriggersClient() alertingv1.AlertTriggersClient

+ func (e *Environment) NewWebhookMemoryServer(parentCtx context.Context, webHookRoute string) *MockIntegrationWebhookServer

+ func (e *Environment) RunAlertManager(ctx context.Context, router routing.OpniRouting, tmpWritePath string, ...) (int, context.CancelFunc)

+ func (e *Environment) StartEmbeddedAlertManager(ctx context.Context, configFilePath string, opniPort *int) (webPort int, caF context.CancelFunc)

+ func (e *Environment) StartEmbeddedJetstream() (*nats.Conn, error)

type EnvironmentOption

+ func WithEnableAlertingClusterDriver(enable bool) EnvironmentOption

+ type IndividualEndpointTestcase struct

+ EndpointId string

+ Op int

+ UpdateEndpoint *alertingv1.AlertEndpoint

+ func CreateRandomIndividualEndpointTestcases(endpSet map[string]*alertingv1.FullAttachedEndpoint) []IndividualEndpointTestcase

+ type MockIntegrationWebhookServer struct

+ Addr string

+ Buffer []*config.WebhookMessage

+ EndpointId string

+ Port int

+ Webhook string

+ func (m *MockIntegrationWebhookServer) ClearBuffer()

+ func (m *MockIntegrationWebhookServer) Endpoint() *alertingv1.AlertEndpoint

+ func (m *MockIntegrationWebhookServer) GetBuffer() []*config.WebhookMessage

+ func (m *MockIntegrationWebhookServer) GetWebhook() string

+ func (m *MockIntegrationWebhookServer) WriteBuffer(msg *config.WebhookMessage)

+ type NamespaceSubTreeTestcase struct

+ ConditionId string

+ Endpoints *alertingv1.FullAttachedEndpoints

+ Namespace string

+ Op int

+ func CreateRandomNamespacedTestCases(n int, endpSet map[string]*alertingv1.FullAttachedEndpoint) []NamespaceSubTreeTestcase

+ type TestEnvAlertingClusterDriver struct

+ ConfigFile string

+ func NewTestEnvAlertingClusterDriver(env *Environment, opts ...alerting_drivers.AlertingManagerDriverOption) *TestEnvAlertingClusterDriver

+ func (l *TestEnvAlertingClusterDriver) ConfigureCluster(ctx context.Context, configuration *alertops.ClusterConfiguration) (*emptypb.Empty, error)

+ func (l *TestEnvAlertingClusterDriver) GetClusterConfiguration(ctx context.Context, empty *emptypb.Empty) (*alertops.ClusterConfiguration, error)

+ func (l *TestEnvAlertingClusterDriver) GetClusterStatus(ctx context.Context, empty *emptypb.Empty) (*alertops.InstallStatus, error)

+ func (l *TestEnvAlertingClusterDriver) GetRuntimeOptions() shared.AlertingClusterOptions

+ func (l *TestEnvAlertingClusterDriver) InstallCluster(ctx context.Context, empty *emptypb.Empty) (*emptypb.Empty, error)

+ func (l *TestEnvAlertingClusterDriver) Name() string

+ func (l *TestEnvAlertingClusterDriver) ShouldDisableNode(reference *corev1.Reference) error

+ func (l *TestEnvAlertingClusterDriver) StartAlertingBackendServer(ctx context.Context, configFilePath string) AlertingServerUnit

+ func (l *TestEnvAlertingClusterDriver) UninstallCluster(ctx context.Context, req *alertops.UninstallRequest) (*emptypb.Empty, error)

+ type TestEnvMetricsClusterDriver struct

+ Configuration *cortexops.ClusterConfiguration

+ Env *Environment

+ func NewTestEnvMetricsClusterDriver(env *Environment) *TestEnvMetricsClusterDriver

+ func (d *TestEnvMetricsClusterDriver) ConfigureCluster(_ context.Context, conf *cortexops.ClusterConfiguration) (*emptypb.Empty, error)

+ func (d *TestEnvMetricsClusterDriver) GetClusterConfiguration(context.Context, *emptypb.Empty) (*cortexops.ClusterConfiguration, error)

+ func (d *TestEnvMetricsClusterDriver) GetClusterStatus(context.Context, *emptypb.Empty) (*cortexops.InstallStatus, error)

+ func (d *TestEnvMetricsClusterDriver) Name() string

+ func (d *TestEnvMetricsClusterDriver) ShouldDisableNode(*corev1.Reference) error

+ func (d *TestEnvMetricsClusterDriver) UninstallCluster(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

Dec 17, 2022

Changes in this version

+ const MockCAName

+ type CrossDeviceTestFs struct

+ func (c *CrossDeviceTestFs) Rename(oldpath, newpath string) error

type Environment

+ func (e *Environment) GenerateNewTempDirectory(prefix string) string

+ func (e *Environment) NewGatewayConfig() *v1beta1.GatewayConfig

+ func (e *Environment) PutTestData(inputPath string, data []byte) string

+ type ModeAwareMemMapFs struct

+ Fs afero.Fs

+ func NewModeAwareMemFs() *ModeAwareMemMapFs

+ func (m *ModeAwareMemMapFs) Chmod(name string, mode os.FileMode) error

+ func (m *ModeAwareMemMapFs) Chown(name string, uid, gid int) error

+ func (m *ModeAwareMemMapFs) Chtimes(name string, atime time.Time, mtime time.Time) error

+ func (m *ModeAwareMemMapFs) Create(name string) (afero.File, error)

+ func (m *ModeAwareMemMapFs) Mkdir(name string, perm os.FileMode) error

+ func (m *ModeAwareMemMapFs) MkdirAll(path string, perm os.FileMode) error

+ func (m *ModeAwareMemMapFs) Name() string

+ func (m *ModeAwareMemMapFs) Open(name string) (afero.File, error)

+ func (m *ModeAwareMemMapFs) OpenFile(name string, flag int, perm os.FileMode) (afero.File, error)

+ func (m *ModeAwareMemMapFs) Remove(name string) error

+ func (m *ModeAwareMemMapFs) RemoveAll(path string) error

+ func (m *ModeAwareMemMapFs) Rename(oldname string, newname string) error

+ func (m *ModeAwareMemMapFs) Stat(name string) (os.FileInfo, error)

+ type TestCertManager struct

+ func (m *TestCertManager) GenerateAdminClientCert() error

+ func (m *TestCertManager) GenerateClientCert(user string) error

+ func (m *TestCertManager) GenerateHTTPCA() error

+ func (m *TestCertManager) GenerateRootCACert() error

+ func (m *TestCertManager) GenerateTransportCA() error

+ func (m *TestCertManager) GetAdminClientCert() (tls.Certificate, error)

+ func (m *TestCertManager) GetClientCert(user string) (tls.Certificate, error)

+ func (m *TestCertManager) GetHTTPCARef() (corev1.LocalObjectReference, error)

+ func (m *TestCertManager) GetHTTPRootCAs() (*x509.CertPool, error)

+ func (m *TestCertManager) GetTransportCARef() (corev1.LocalObjectReference, error)

+ func (m *TestCertManager) GetTransportRootCAs() (*x509.CertPool, error)

+ func (m *TestCertManager) PopulateK8sObjects(ctx context.Context, client ctrlclient.Client, namespace string) error

Nov 23, 2022

Changes in this version

+ func InjectStorageError(ctx context.Context, err error) context.Context

+ func InjectedStorageError(ctx context.Context) (error, bool)

Nov 16, 2022

Changes in this version

type Environment

+ func (e *Environment) JetStreamConfig() *v1beta1.JetStreamStorageSpec

type EnvironmentOption

+ func WithStorageBackend(backend v1beta1.StorageType) EnvironmentOption

Nov 8, 2022

Changes in this version

type Environment

+ func (e *Environment) StartAgentDisconnectServer()

+ func (e *Environment) StartNodeExporter()

type EnvironmentOption

+ func WithEnableDisconnectServer(enable bool) EnvironmentOption

+ func WithEnableNodeExporter(enable bool) EnvironmentOption

Oct 20, 2022

Changes in this version

+ func ExpectRuleGroupToExist(client cortexadmin.CortexAdminClient, ctx context.Context, tenant string, ...)

+ func RandomName(seed int64) string

+ func StandaloneHttpRequest(method string, url string, requestBody []byte, values url.Values, ...) (code int, body []byte, err error)

type CapabilityInfo

+ Storage storage.ClusterStore

type Environment

+ func (e *Environment) Context() context.Context

+ func (e *Environment) CortexTLSConfig() *tls.Config

+ func (e *Environment) GetAlertingManagementWebhookEndpoint() string

+ func (e *Environment) NewCortexOpsClient() cortexops.CortexOpsClient

+ func (e *Environment) StartCortex(ctx context.Context)

+ func (e *Environment) StartMockKubernetesMetricServer(ctx context.Context) (port int)

type EnvironmentOption

+ func WithAgentIdSeed(seed int64) EnvironmentOption

+ func WithDelayStartCortex(delay chan struct{}) EnvironmentOption

+ func WithDelayStartEtcd(delay chan struct{}) EnvironmentOption

+ func WithEnableCortexClusterDriver(enable bool) EnvironmentOption

+ func WithEnableJetstream(enable bool) EnvironmentOption

type RunningAgent

+ Agent agent.AgentInterface

type StartAgentOption

+ func WithAgentVersion(version string) StartAgentOption

+ type TestEnvClusterDriver struct

+ Configuration *cortexops.ClusterConfiguration

+ Env *Environment

+ func NewTestEnvClusterDriver(env *Environment) *TestEnvClusterDriver

+ func (d *TestEnvClusterDriver) ConfigureCluster(_ context.Context, conf *cortexops.ClusterConfiguration) (*emptypb.Empty, error)

+ func (d *TestEnvClusterDriver) GetClusterConfiguration(context.Context, *emptypb.Empty) (*cortexops.ClusterConfiguration, error)

+ func (d *TestEnvClusterDriver) GetClusterStatus(context.Context, *emptypb.Empty) (*cortexops.InstallStatus, error)

+ func (d *TestEnvClusterDriver) Name() string

+ func (d *TestEnvClusterDriver) ShouldDisableNode(*corev1.Reference) error

+ func (d *TestEnvClusterDriver) UninstallCluster(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

Jul 26, 2022

Changes in this version

+ const Temporal

+ func ContextWithAuthorizedID(ctx context.Context, clusterID string) context.Context

+ func LoadUnaryPlugins(loader *plugins.PluginLoader) int

+ func NewApiExtensionUnaryTestPlugin(srv apiextensions.UnaryAPIExtensionServer, svcDesc *grpc.ServiceDesc, ...) *plugin.ClientConfig

+ func NewOverridePrometheusConfig(configPath string, jobs []PrometheusJob) *overridePrometheusConfig

+ func NewTestFinder(ctrl *gomock.Controller, groups func() []rules.RuleGroup) notifier.Finder[rules.RuleGroup]

+ type BenchRunner struct

+ func (b *BenchRunner) StartWorker(ctx context.Context)

type Environment

+ func (e *Environment) ManagementClientConn() grpc.ClientConnInterface

+ func (e *Environment) NewBenchRunner(agent string, desc bench.WorkloadDesc) (*BenchRunner, error)

+ func (e *Environment) NewCortexAdminClient() cortexadmin.CortexAdminClient

+ func (e *Environment) StartInstrumentationServer(ctx context.Context) (int, chan bool)

type EnvironmentOption

+ func WithDefaultAgentOpts(opts ...StartAgentOption) EnvironmentOption

+ func WithEnableRealtimeServer(enable bool) EnvironmentOption

+ type HealthStore struct

+ GetHealthShouldFail bool

+ func (hb *HealthStore) GetHealth(context.Context, *emptypb.Empty, ...grpc.CallOption) (*corev1.Health, error)

+ func (hb *HealthStore) SetHealth(health *corev1.Health)

+ type PrometheusJob struct

+ JobName string

+ ScrapePort int

type StartAgentOption

+ func WithRemoteGatewayAddress(addr string) StartAgentOption

+ func WithRemoteKubeconfig(kubeconfig string) StartAgentOption

May 19, 2022

Changes in this version

+ const Controller

Apr 29, 2022

Changes in this version

+ const E2E

+ const Integration

+ const Slow

+ const TimeSensitive

+ const Unit

+ var Log = logger.New(logger.WithLogLevel(zap.DebugLevel)).Named("test")

+ var TestDataFS embed.FS

+ func DownloadCertManagerCRDs(scheme *runtime.Scheme) []*apiextensionsv1.CustomResourceDefinition

+ func EnableIfCI(decorator T) any

+ func LoadPlugins(loader *plugins.PluginLoader) int

+ func NewApiExtensionTestPlugin(srv apiextensions.ManagementAPIExtensionServer, svcDesc *grpc.ServiceDesc, ...) *plugin.ClientConfig

+ func NewTestCapabilityBackend(ctrl *gomock.Controller, capBackend *CapabilityInfo) capability.Backend

+ func NewTestCapabilityBackendClient(ctrl *gomock.Controller, capBackend *CapabilityInfo) capability.BackendClient

+ func NewTestClusterStore(ctrl *gomock.Controller) storage.ClusterStore

+ func NewTestIdentProvider(ctrl *gomock.Controller, id string) ident.Provider

+ func NewTestKeyValueStore(ctrl *gomock.Controller) storage.KeyValueStore

+ func NewTestKeyValueStoreBroker(ctrl *gomock.Controller) storage.KeyValueStoreBroker

+ func NewTestKeyringStore(ctrl *gomock.Controller, prefix string, ref *core.Reference) storage.KeyringStore

+ func NewTestKeyringStoreBroker(ctrl *gomock.Controller, handler ...KeyringStoreHandler) storage.KeyringStoreBroker

+ func NewTestRBACStore(ctrl *gomock.Controller) storage.RBACStore

+ func NewTestRuleFinder(ctrl *gomock.Controller, groups func() []rulefmt.RuleGroup) rules.RuleFinder

+ func NewTestStorageBackend(ctx context.Context, ctrl *gomock.Controller) storage.Backend

+ func NewTestTokenStore(ctx context.Context, ctrl *gomock.Controller) storage.TokenStore

+ func StartStandaloneTestEnvironment()

+ func TestData(filename string) []byte

+ type CapabilityInfo struct

+ CanInstall bool

+ InstallerTemplate string

+ Name string

+ type Environment struct

+ CRDDirectoryPaths []string

+ Logger *zap.SugaredLogger

+ Processes struct{ ... }

+ TestBin string

+ func (e *Environment) EtcdClient() (*clientv3.Client, error)

+ func (e *Environment) EtcdConfig() *v1beta1.EtcdStorageSpec

+ func (e *Environment) GatewayConfig() *v1beta1.GatewayConfig

+ func (e *Environment) GatewayTLSConfig() *tls.Config

+ func (e *Environment) GetAgent(id string) RunningAgent

+ func (e *Environment) NewManagementClient() management.ManagementClient

+ func (e *Environment) PrometheusAPIEndpoint() string

+ func (e *Environment) Start(opts ...EnvironmentOption) error

+ func (e *Environment) StartAgent(id string, token *core.BootstrapToken, pins []string, opts ...StartAgentOption) (int, <-chan error)

+ func (e *Environment) StartK8s() (*rest.Config, error)

+ func (e *Environment) StartManager(restConfig *rest.Config, reconcilers ...Reconciler) ctrl.Manager

+ func (e *Environment) StartPrometheus(opniAgentPort int) int

+ func (e *Environment) Stop() error

+ type EnvironmentOption func(*EnvironmentOptions)

+ func WithEnableCortex(enableCortex bool) EnvironmentOption

+ func WithEnableEtcd(enableEtcd bool) EnvironmentOption

+ func WithEnableGateway(enableGateway bool) EnvironmentOption

+ type EnvironmentOptions struct

+ func (o *EnvironmentOptions) Apply(opts ...EnvironmentOption)

+ type KeyringStoreHandler = func(_ context.Context, prefix string, ref *core.Reference) (storage.KeyringStore, error)

+ type Lease struct

+ Expiration time.Time

+ ID int64

+ TokenID string

+ type LeaseStore struct

+ func NewLeaseStore(ctx context.Context) *LeaseStore

+ func (ls *LeaseStore) LeaseExpired() <-chan string

+ func (ls *LeaseStore) New(tokenID string, ttl time.Duration) *Lease

+ type RunningAgent struct

+ type StartAgentOption func(*StartAgentOptions)

+ func WithContext(ctx context.Context) StartAgentOption

+ type StartAgentOptions struct

+ func (o *StartAgentOptions) Apply(opts ...StartAgentOption)

Oct 9, 2021

Changes in this version

+ var ExternalResources sync.WaitGroup

+ func StartControllerManager(ctx context.Context, testEnv *envtest.Environment)

Jul 13, 2021

Changes in this version

+ func RunTestEnvironment(testEnv *envtest.Environment, reconcilers ...Reconciler) (k8sManager ctrl.Manager, k8sClient client.Client)

+ type Reconciler interface

+ SetupWithManager func(ctrl.Manager) error