fake

Documentation

Overview

Package fake provides fake dynamic clients and reactors for testing purposes.

Index

• func AddBasicReactors(f *testing.Fake)
• func AddCreateReactor(f *testing.Fake)
• func AddDeleteCollectionReactor(f *testing.Fake)
• func AddDeleteReactor(f *testing.Fake)
• func AddFilteringListReactor(f *testing.Fake)
• func AddFilteringWatchReactor(f *testing.Fake)
• func AddUpdateReactor(f *testing.Fake)
• func AddVerifyNamespaceReactor(f *testing.Fake, resources ...string)
• func ConflictOnUpdateReactor(f *testing.Fake, resource string)
• func FailingReaction(err error) func(obj interface{}) (bool, error)
• type DeleteCollectionReactor
• type FailOnActionReactor
  • func FailOnAction(f *testing.Fake, resource, verb string, customErr error, autoReset bool) *FailOnActionReactor
  • func (r *FailOnActionReactor) Fail(v bool)
• type FailingReactor
  • func NewFailingReactor(f *testing.Fake) *FailingReactor
  • func NewFailingReactorForResource(f *testing.Fake, resource string) *FailingReactor
  • func (f *FailingReactor) SetFailOnCreate(err error)
  • func (f *FailingReactor) SetFailOnDelete(err error)
  • func (f *FailingReactor) SetFailOnGet(err error)
  • func (f *FailingReactor) SetFailOnList(err error)
  • func (f *FailingReactor) SetFailOnUpdate(err error)
  • func (f *FailingReactor) SetResetOnFailure(v bool)
• type ReactingClient
  • func NewReactingClient(c client.Client) *ReactingClient
  • func (c *ReactingClient) AddReactor(verb VerbType, objType interface{}, r ReactionFunc) *ReactingClient
  • func (c *ReactingClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
  • func (c *ReactingClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
  • func (c *ReactingClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object, ...) error
  • func (c *ReactingClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
  • func (c *ReactingClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
• type ReactionFunc
• type VerbType
• type WatchReactor
  • func NewWatchReactor(f *testing.Fake) *WatchReactor
  • func (r *WatchReactor) AwaitNoWatchStarted(forResource string)
  • func (r *WatchReactor) AwaitNoWatchStopped(forResource string)
  • func (r *WatchReactor) AwaitWatchStarted(forResource string)
  • func (r *WatchReactor) AwaitWatchStopped(forResource string)

Functions

func AddBasicReactors

func AddBasicReactors(f *testing.Fake)

AddBasicReactors adds reactors to mimic real K8s behavior for create, update, delete, list, watchs.

func AddCreateReactor

func AddCreateReactor(f *testing.Fake)

AddCreateReactor adds a reactor to mimic real K8s create behavior to handle GenerateName, validation et al.

func AddDeleteCollectionReactor

func AddDeleteCollectionReactor(f *testing.Fake)

func AddDeleteReactor

func AddDeleteReactor(f *testing.Fake)

AddDeleteReactor adds a reactor to mimic real K8s delete behavior to handle ResourceVersion, DeletionTimestamp et al.

func AddFilteringListReactor

func AddFilteringListReactor(f *testing.Fake)

func AddFilteringWatchReactor

func AddFilteringWatchReactor(f *testing.Fake)

func AddUpdateReactor

func AddUpdateReactor(f *testing.Fake)

AddUpdateReactor adds a reactor to mimic real K8s update behavior to handle ResourceVersion et al.

func AddVerifyNamespaceReactor

func AddVerifyNamespaceReactor(f *testing.Fake, resources ...string)

func ConflictOnUpdateReactor

func ConflictOnUpdateReactor(f *testing.Fake, resource string)

func FailingReaction

func FailingReaction(err error) func(obj interface{}) (bool, error)

Types

type DeleteCollectionReactor

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

type FailOnActionReactor

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

func FailOnAction

func FailOnAction(f *testing.Fake, resource, verb string, customErr error, autoReset bool) *FailOnActionReactor

func (*FailOnActionReactor) Fail

func (r *FailOnActionReactor) Fail(v bool)

type FailingReactor

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

func NewFailingReactor

func NewFailingReactor(f *testing.Fake) *FailingReactor

func NewFailingReactorForResource

func NewFailingReactorForResource(f *testing.Fake, resource string) *FailingReactor

func (*FailingReactor) SetFailOnCreate

func (f *FailingReactor) SetFailOnCreate(err error)

func (*FailingReactor) SetFailOnDelete

func (f *FailingReactor) SetFailOnDelete(err error)

func (*FailingReactor) SetFailOnGet

func (f *FailingReactor) SetFailOnGet(err error)

func (*FailingReactor) SetFailOnList

func (f *FailingReactor) SetFailOnList(err error)

func (*FailingReactor) SetFailOnUpdate

func (f *FailingReactor) SetFailOnUpdate(err error)

func (*FailingReactor) SetResetOnFailure

func (f *FailingReactor) SetResetOnFailure(v bool)

type ReactingClient

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

func NewReactingClient

func NewReactingClient(c client.Client) *ReactingClient

func (*ReactingClient) AddReactor

func (c *ReactingClient) AddReactor(verb VerbType, objType interface{}, r ReactionFunc) *ReactingClient

func (*ReactingClient) Create

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

func (*ReactingClient) Delete

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

func (*ReactingClient) Get

func (c *ReactingClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object, opts ...client.GetOption) error

func (*ReactingClient) List

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

func (*ReactingClient) Update

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

type ReactionFunc

type ReactionFunc func(obj interface{}) (bool, error)

type VerbType

type VerbType int

const (
	Get VerbType = iota
	List
	Create
	Update
	Delete
)

type WatchReactor

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

func NewWatchReactor

func NewWatchReactor(f *testing.Fake) *WatchReactor

func (*WatchReactor) AwaitNoWatchStarted

func (r *WatchReactor) AwaitNoWatchStarted(forResource string)

func (*WatchReactor) AwaitNoWatchStopped

func (r *WatchReactor) AwaitNoWatchStopped(forResource string)

func (*WatchReactor) AwaitWatchStarted

func (r *WatchReactor) AwaitWatchStarted(forResource string)

func (*WatchReactor) AwaitWatchStopped

func (r *WatchReactor) AwaitWatchStopped(forResource string)