testing

Documentation

Index

• Constants
• func FakeStartSyncer(t *testing.T, ctx *synccontext.RegisterContext, ...) (*synccontext.SyncContext, syncer.Base)
• func NewFakeMapper(scheme *runtime.Scheme) meta.RESTMapper
• func NewFakeRegisterContext(pClient *FakeIndexClient, vClient *FakeIndexClient) *synccontext.RegisterContext
• func NewScheme() *runtime.Scheme
• func RunTests(t *testing.T, tests []*SyncTest)
• type Compare
• type FakeIndexClient
  • func NewFakeClient(scheme *runtime.Scheme, objs ...runtime.Object) *FakeIndexClient
  • func (fc *FakeIndexClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
  • func (fc *FakeIndexClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
  • func (fc *FakeIndexClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error
  • func (fc *FakeIndexClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object) error
  • func (fc *FakeIndexClient) IndexField(ctx context.Context, obj client.Object, field string, ...) error
  • func (fc *FakeIndexClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
  • func (fc *FakeIndexClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error
  • func (fc *FakeIndexClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
• type SyncTest
  • func (s *SyncTest) Run(t *testing.T)

Constants

const (
	FakeClientResourceVersion = "999"
)

Functions

func FakeStartSyncer

func FakeStartSyncer(t *testing.T, ctx *synccontext.RegisterContext, create func(ctx *synccontext.RegisterContext) (syncer.Base, error)) (*synccontext.SyncContext, syncer.Base)

func NewFakeMapper

func NewFakeMapper(scheme *runtime.Scheme) meta.RESTMapper

NewFakeMapper creates a new fake mapper

func NewFakeRegisterContext

func NewFakeRegisterContext(pClient *FakeIndexClient, vClient *FakeIndexClient) *synccontext.RegisterContext

func NewScheme

func NewScheme() *runtime.Scheme

NewScheme creates a new scheme

func RunTests

func RunTests(t *testing.T, tests []*SyncTest)

Types

type Compare

type Compare func(obj1 runtime.Object, obj2 runtime.Object) bool

type FakeIndexClient

type FakeIndexClient struct {
	client.Client
	// contains filtered or unexported fields
}

func NewFakeClient

func NewFakeClient(scheme *runtime.Scheme, objs ...runtime.Object) *FakeIndexClient

NewFakeClient creates a new fake client for the standard schema

func (*FakeIndexClient) Create

func (fc *FakeIndexClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error

func (*FakeIndexClient) Delete

func (fc *FakeIndexClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

func (*FakeIndexClient) DeleteAllOf

func (fc *FakeIndexClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error

func (*FakeIndexClient) Get

func (fc *FakeIndexClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object) error

func (*FakeIndexClient) IndexField

func (fc *FakeIndexClient) IndexField(ctx context.Context, obj client.Object, field string, extractValue client.IndexerFunc) error

func (*FakeIndexClient) List

func (fc *FakeIndexClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

func (*FakeIndexClient) Patch

func (fc *FakeIndexClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error

func (*FakeIndexClient) Update

func (fc *FakeIndexClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

type SyncTest

type SyncTest struct {
	Name string

	InitialPhysicalState []runtime.Object
	InitialVirtualState  []runtime.Object

	ExpectedPhysicalState map[schema.GroupVersionKind][]runtime.Object
	ExpectedVirtualState  map[schema.GroupVersionKind][]runtime.Object

	Sync    func(ctx *synccontext.RegisterContext)
	Compare Compare
}

func (*SyncTest) Run

func (s *SyncTest) Run(t *testing.T)