kubernetes/staging/src/k8s.io/sample-controller/controller_test.go

var alwaysReady …

var noResyncPeriodFunc …

type fixture …

func newFixture(t *testing.T) *fixture { … }

func newFoo(name string, replicas *int32) *samplecontroller.Foo { … }

func (f *fixture) newController(ctx context.Context) (*Controller, informers.SharedInformerFactory, kubeinformers.SharedInformerFactory) { … }

func (f *fixture) run(ctx context.Context, fooRef cache.ObjectName) { … }

func (f *fixture) runExpectError(ctx context.Context, fooRef cache.ObjectName) { … }

func (f *fixture) runController(ctx context.Context, fooRef cache.ObjectName, startInformers bool, expectError bool) { … }

// checkAction verifies that expected and actual actions are equal and both have
// same attached resources
func checkAction(expected, actual core.Action, t *testing.T) { … }

// filterInformerActions filters list and watch actions for testing resources.
// Since list and watch don't change resource state we can filter it to lower
// nose level in our tests.
func filterInformerActions(actions []core.Action) []core.Action { … }

func (f *fixture) expectCreateDeploymentAction(d *apps.Deployment) { … }

func (f *fixture) expectUpdateDeploymentAction(d *apps.Deployment) { … }

func (f *fixture) expectUpdateFooStatusAction(foo *samplecontroller.Foo) { … }

func getRef(foo *samplecontroller.Foo, t *testing.T) cache.ObjectName { … }

func TestCreatesDeployment(t *testing.T) { … }

func TestDoNothing(t *testing.T) { … }

func TestUpdateDeployment(t *testing.T) { … }

func TestNotControlledByUs(t *testing.T) { … }

func int32Ptr(i int32) *int32 { … }