testenv

Documentation

Index

• func AssetBinPath(name string) string
• func CreateObjects(objects []runtime.Object) error
• func DeleteObjects(objects []runtime.Object) error
• func GetChangedObjects(changes []Change) ([]runtime.Object, error)
• func GetClient() client.Client
• func GetScheme() *runtime.Scheme
• func ProjectDir() string
• func RunSpecsInEnvironment(t *testing.T, desc string)
• type Change
  • func GetChanges(c interface{}) []Change
• type Environment
  • func (e *Environment) GetClient() client.Client
  • func (e *Environment) GetConfig() *rest.Config
  • func (e *Environment) GetScheme() *runtime.Scheme
  • func (e *Environment) InstallCRDs(options envtest.CRDInstallOptions) ([]runtime.Object, error)
  • func (e *Environment) NewManager() (*Manager, error)
  • func (e *Environment) Start() (err error)
  • func (e *Environment) Stop() error
• type EventData
• type EventWatcher
  • func NewEventWatcher() *EventWatcher
  • func (e *EventWatcher) Shutdown()
  • func (e *EventWatcher) WaitForEventTimeout(expected interface{}, timeout time.Duration) bool
  • func (e *EventWatcher) WatchEvent(event *corev1.Event)
• type Manager
  • func NewManager() (*Manager, error)
  • func (m *Manager) GetClient() client.Client
  • func (m *Manager) Initialize() (err error)
  • func (m *Manager) Stop()
  • func (m *Manager) WaitForEvent(expected interface{}) bool
  • func (m *Manager) WaitForSync()
• type Recorder

Functions

func AssetBinPath

func AssetBinPath(name string) string

func CreateObjects

func CreateObjects(objects []runtime.Object) error

func DeleteObjects

func DeleteObjects(objects []runtime.Object) error

func GetChangedObjects

func GetChangedObjects(changes []Change) ([]runtime.Object, error)

func GetClient

func GetClient() client.Client

func GetScheme

func GetScheme() *runtime.Scheme

func ProjectDir

func ProjectDir() string

func RunSpecsInEnvironment

func RunSpecsInEnvironment(t *testing.T, desc string)

Types

type Change

type Change struct {
	schema.GroupVersionKind
	types.NamespacedName

	Type string
}

func GetChanges

func GetChanges(c interface{}) []Change

type Environment

type Environment struct {
	ControlPlane      *envtest.ControlPlane
	CRDInstallOptions envtest.CRDInstallOptions
	// contains filtered or unexported fields
}

var Env *Environment

Env is a global environment for testing. nolint: gochecknoglobals

func (*Environment) GetClient

func (e *Environment) GetClient() client.Client

func (*Environment) GetConfig

func (e *Environment) GetConfig() *rest.Config

func (*Environment) GetScheme

func (e *Environment) GetScheme() *runtime.Scheme

func (*Environment) InstallCRDs

func (e *Environment) InstallCRDs(options envtest.CRDInstallOptions) ([]runtime.Object, error)

func (*Environment) NewManager

func (e *Environment) NewManager() (*Manager, error)

func (*Environment) Start

func (e *Environment) Start() (err error)

func (*Environment) Stop

func (e *Environment) Stop() error

type EventData

type EventData struct {
	Type    string
	Reason  string
	Message string
}

type EventWatcher

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

func NewEventWatcher

func NewEventWatcher() *EventWatcher

func (*EventWatcher) Shutdown

func (e *EventWatcher) Shutdown()

func (*EventWatcher) WaitForEventTimeout

func (e *EventWatcher) WaitForEventTimeout(expected interface{}, timeout time.Duration) bool

func (*EventWatcher) WatchEvent

func (e *EventWatcher) WatchEvent(event *corev1.Event)

type Manager

type Manager struct {
	manager.Manager

	EventBroadcaster record.EventBroadcaster
	// contains filtered or unexported fields
}

func NewManager

func NewManager() (*Manager, error)

func (*Manager) GetClient

func (m *Manager) GetClient() client.Client

func (*Manager) Initialize

func (m *Manager) Initialize() (err error)

func (*Manager) Stop

func (m *Manager) Stop()

func (*Manager) WaitForEvent

func (m *Manager) WaitForEvent(expected interface{}) bool

func (*Manager) WaitForSync

func (m *Manager) WaitForSync()

type Recorder

type Recorder interface {
	Changes() []Change
}