testing

Documentation

Index

• Constants
• func CheckAction(expected, actual kubetesting.Action, t *testing.T)
• func CheckActions(expected, actual []kubetesting.Action, t *testing.T)
• func CheckEvents(expectedOrderedEvents []string, receivedEvents []string, t *testing.T)
• func DeepEqualDiff(expected, actual interface{}) (bool, string)
• func FilterActions(actions []kubetesting.Action) []kubetesting.Action
• func NewDiscoveryAction(_ string) kubetesting.ActionImpl
• func PrettyPrintActions(actions []kubetesting.Action, t *testing.T)
• func ShallowCheckAction(expected, actual kubetesting.Action, t *testing.T)
• func ShallowCheckActions(expected, actual []kubetesting.Action, t *testing.T)
• func YamlDiff(a interface{}, b interface{}) (string, error)
• type ControllerTestFixture
  • func NewControllerTestFixture(objects ...runtime.Object) *ControllerTestFixture
  • func (f *ControllerTestFixture) AddCluster() *FakeCluster
  • func (f *ControllerTestFixture) AddNamedCluster(name string) *FakeCluster
  • func (f *ControllerTestFixture) DynamicClientBuilder(kind *schema.GroupVersionKind, restConfig *rest.Config, ...) dynamic.Interface
  • func (f *ControllerTestFixture) Run(stopCh chan struct{})
• type FakeCluster
  • func NewNamedFakeCluster(name string) *FakeCluster
  • func (c *FakeCluster) AddMany(objects []runtime.Object)
  • func (c *FakeCluster) AddOne(object runtime.Object)
  • func (c *FakeCluster) InitializeDiscovery(resources []*v1.APIResourceList)
  • func (c *FakeCluster) InitializeDynamicClient(objects []runtime.Object)
• type FakeClusterClientStore
  • func NewFakeClusterClientStore(clusters map[string]*FakeCluster) *FakeClusterClientStore
  • func (s *FakeClusterClientStore) AddCluster(c *FakeCluster)
  • func (s *FakeClusterClientStore) AddEventHandlerCallback(c clusterclientstore.EventHandlerRegisterFunc)
  • func (s *FakeClusterClientStore) AddSubscriptionCallback(c clusterclientstore.SubscriptionRegisterFunc)
  • func (s *FakeClusterClientStore) GetClient(clusterName string, ua string) (kubernetes.Interface, error)
  • func (s *FakeClusterClientStore) GetConfig(clusterName string) (*rest.Config, error)
  • func (s *FakeClusterClientStore) GetInformerFactory(clusterName string) (informers.SharedInformerFactory, error)
  • func (s *FakeClusterClientStore) Run(stopCh <-chan struct{})

Constants

const (
	NoResyncPeriod time.Duration = 0

	ContextLines = 4

	TestNamespace = "test-namespace"
	TestApp       = "shipper-test"
	TestRegion    = "eu-west"
	TestCluster   = "test-cluster"

	E2ETestNamespaceLabel = "shipper-e2e-test"
)

Functions

func CheckAction

func CheckAction(expected, actual kubetesting.Action, t *testing.T)

CheckAction compares two individual actions and calls Errorf on t if it finds a difference.

func CheckActions

func CheckActions(expected, actual []kubetesting.Action, t *testing.T)

CheckActions takes a slice of expected actions and a slice of observed actions (typically obtained from fakeClient.Actions()) and compares them. Calls Errorf on t for every difference it finds.

func CheckEvents

func CheckEvents(expectedOrderedEvents []string, receivedEvents []string, t *testing.T)

func DeepEqualDiff

func DeepEqualDiff(expected, actual interface{}) (bool, string)

func FilterActions

func FilterActions(actions []kubetesting.Action) []kubetesting.Action

FilterActions, given a slice of observed actions, returns only those that change state. Useful for reducing the number of actions needed to check in tests.

func NewDiscoveryAction

func NewDiscoveryAction(_ string) kubetesting.ActionImpl

func PrettyPrintActions

func PrettyPrintActions(actions []kubetesting.Action, t *testing.T)

PrettyPrintActions pretty-prints a slice of actions, useful for creating a human-readable list for debugging.

func ShallowCheckAction

func ShallowCheckAction(expected, actual kubetesting.Action, t *testing.T)

ShallowCheckAction checks the verb, resource, and namespace without looking at the objects involved. This is a stand-in until we port the Installation controller to not use 'nil' as the object involved in the kubetesting.Actions it expects.

func ShallowCheckActions

func ShallowCheckActions(expected, actual []kubetesting.Action, t *testing.T)

ShallowCheckActions takes a slice of expected actions and a slice of observed actions (typically obtained from fakeClient.Actions()) and compares them shallowly. Calls Errorf on t for every difference it finds.

func YamlDiff

func YamlDiff(a interface{}, b interface{}) (string, error)

Types

type ControllerTestFixture

type ControllerTestFixture struct {
	ShipperClient          *shipperfake.Clientset
	ShipperInformerFactory shipperinformers.SharedInformerFactory

	Clusters           map[string]*FakeCluster
	ClusterClientStore *FakeClusterClientStore

	Recorder *record.FakeRecorder
}

func NewControllerTestFixture

func NewControllerTestFixture(objects ...runtime.Object) *ControllerTestFixture

func (*ControllerTestFixture) AddCluster

func (f *ControllerTestFixture) AddCluster() *FakeCluster

func (*ControllerTestFixture) AddNamedCluster

func (f *ControllerTestFixture) AddNamedCluster(name string) *FakeCluster

func (*ControllerTestFixture) DynamicClientBuilder

func (f *ControllerTestFixture) DynamicClientBuilder(
	kind *schema.GroupVersionKind,
	restConfig *rest.Config,
	cluster *shipper.Cluster,
) dynamic.Interface

func (*ControllerTestFixture) Run

func (f *ControllerTestFixture) Run(stopCh chan struct{})

type FakeCluster

type FakeCluster struct {
	Name string

	Client          *kubefake.Clientset
	DynamicClient   *fakedynamic.FakeDynamicClient
	InformerFactory informers.SharedInformerFactory
}

func NewNamedFakeCluster

func NewNamedFakeCluster(name string) *FakeCluster

func (*FakeCluster) AddMany

func (c *FakeCluster) AddMany(objects []runtime.Object)

func (*FakeCluster) AddOne

func (c *FakeCluster) AddOne(object runtime.Object)

func (*FakeCluster) InitializeDiscovery

func (c *FakeCluster) InitializeDiscovery(resources []*v1.APIResourceList)

func (*FakeCluster) InitializeDynamicClient

func (c *FakeCluster) InitializeDynamicClient(objects []runtime.Object)

type FakeClusterClientStore

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

FakeClusterClientStore is a fake implementation of a ClusterClientStore, allowing you to provide your own clientsets.

func NewFakeClusterClientStore

func NewFakeClusterClientStore(clusters map[string]*FakeCluster) *FakeClusterClientStore

func (*FakeClusterClientStore) AddCluster

func (s *FakeClusterClientStore) AddCluster(c *FakeCluster)

func (*FakeClusterClientStore) AddEventHandlerCallback

func (s *FakeClusterClientStore) AddEventHandlerCallback(c clusterclientstore.EventHandlerRegisterFunc)

func (*FakeClusterClientStore) AddSubscriptionCallback

func (s *FakeClusterClientStore) AddSubscriptionCallback(c clusterclientstore.SubscriptionRegisterFunc)

func (*FakeClusterClientStore) GetClient

func (s *FakeClusterClientStore) GetClient(clusterName string, ua string) (kubernetes.Interface, error)

func (*FakeClusterClientStore) GetConfig

func (s *FakeClusterClientStore) GetConfig(clusterName string) (*rest.Config, error)

func (*FakeClusterClientStore) GetInformerFactory

func (s *FakeClusterClientStore) GetInformerFactory(clusterName string) (informers.SharedInformerFactory, error)

func (*FakeClusterClientStore) Run

func (s *FakeClusterClientStore) Run(stopCh <-chan struct{})