test

Documentation

Index

• Variables
• 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
  • 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
• type LeaseStore
  • func NewLeaseStore(ctx context.Context) *LeaseStore
  • func (ls *LeaseStore) LeaseExpired() <-chan string
  • func (ls *LeaseStore) New(tokenID string, ttl time.Duration) *Lease
• type Reconciler
• type RunningAgent
• type StartAgentOption
  • func WithContext(ctx context.Context) StartAgentOption
• type StartAgentOptions
  • func (o *StartAgentOptions) Apply(opts ...StartAgentOption)

Variables

var TestDataFS embed.FS

Functions

func LoadPlugins

func LoadPlugins(loader *plugins.PluginLoader) int

func NewApiExtensionTestPlugin

func NewApiExtensionTestPlugin(
	srv apiextensions.ManagementAPIExtensionServer,
	svcDesc *grpc.ServiceDesc,
	impl interface{},
) *plugin.ClientConfig

func NewTestClusterStore

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

func NewTestKeyValueStore

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

func NewTestKeyValueStoreBroker

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

func NewTestKeyringStore

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

func NewTestKeyringStoreBroker

func NewTestKeyringStoreBroker(ctrl *gomock.Controller) storage.KeyringStoreBroker

func NewTestRBACStore

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

func NewTestStorageBackend

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

func NewTestTokenStore

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

func StartStandaloneTestEnvironment

func StartStandaloneTestEnvironment()

func TestData

func TestData(filename string) []byte

Types

type Environment

type Environment struct {
	TestBin           string
	Logger            *zap.SugaredLogger
	CRDDirectoryPaths []string
	// contains filtered or unexported fields
}

func (*Environment) EtcdClient

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

func (*Environment) GatewayConfig

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

func (*Environment) GatewayTLSConfig

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

func (*Environment) GetAgent

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

func (*Environment) NewManagementClient

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

func (*Environment) PrometheusAPIEndpoint

func (e *Environment) PrometheusAPIEndpoint() string

func (*Environment) Start

func (e *Environment) Start() error

func (*Environment) StartAgent

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

func (*Environment) StartK8s

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

func (*Environment) StartManager

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

func (*Environment) StartPrometheus

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

func (*Environment) Stop

func (e *Environment) Stop() error

type Lease

type Lease struct {
	ID         int64
	Expiration time.Time
	TokenID    string
}

type LeaseStore

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

func NewLeaseStore

func NewLeaseStore(ctx context.Context) *LeaseStore

func (*LeaseStore) LeaseExpired

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

func (*LeaseStore) New

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

type Reconciler

type Reconciler interface {
	SetupWithManager(ctrl.Manager) error
}

type RunningAgent

type RunningAgent struct {
	*agent.Agent
	*sync.Mutex
}

type StartAgentOption

type StartAgentOption func(*StartAgentOptions)

func WithContext

func WithContext(ctx context.Context) StartAgentOption

type StartAgentOptions

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

func (*StartAgentOptions) Apply

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