Versions in this module Expand all Collapse all v0 v0.4.0 Mar 31, 2022 Changes in this version + var TestDataFS embed.FS + func LoadPlugins(loader *plugins.PluginLoader) int + func NewApiExtensionTestPlugin(srv apiextensions.ManagementAPIExtensionServer, svcDesc *grpc.ServiceDesc, ...) *plugin.ClientConfig + func NewTestClusterStore(ctrl *gomock.Controller) storage.ClusterStore + 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) storage.KeyringStoreBroker + func NewTestRBACStore(ctrl *gomock.Controller) storage.RBACStore + 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 Environment struct + CRDDirectoryPaths []string + Logger *zap.SugaredLogger + TestBin string + func (e *Environment) EtcdClient() (*clientv3.Client, error) + 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() 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 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 Reconciler interface + SetupWithManager func(ctrl.Manager) error + type RunningAgent struct + type StartAgentOption func(*StartAgentOptions) + func WithContext(ctx context.Context) StartAgentOption + type StartAgentOptions struct + func (o *StartAgentOptions) Apply(opts ...StartAgentOption)