package testing

import "k8s.io/kubernetes/pkg/controller/volume/persistentvolume/testing"

Index ¶

• Variables
• type ReactorError
• type VolumeReactor
• func NewVolumeReactor(ctx context.Context, client *fake.Clientset, fakeVolumeWatch, fakeClaimWatch *watch.FakeWatcher, errors []ReactorError) *VolumeReactor
• func (r *VolumeReactor) AddClaim(claim *v1.PersistentVolumeClaim)
• func (r *VolumeReactor) AddClaimBoundToVolume(claim *v1.PersistentVolumeClaim)
• func (r *VolumeReactor) AddClaimEvent(claim *v1.PersistentVolumeClaim)
• func (r *VolumeReactor) AddClaims(claims []*v1.PersistentVolumeClaim)
• func (r *VolumeReactor) AddVolume(volume *v1.PersistentVolume)
• func (r *VolumeReactor) AddVolumes(volumes []*v1.PersistentVolume)
• func (r *VolumeReactor) CheckClaims(expectedClaims []*v1.PersistentVolumeClaim) error
• func (r *VolumeReactor) CheckVolumes(expectedVolumes []*v1.PersistentVolume) error
• func (r *VolumeReactor) DeleteClaimEvent(claim *v1.PersistentVolumeClaim)
• func (r *VolumeReactor) DeleteVolume(name string)
• func (r *VolumeReactor) DeleteVolumeEvent(volume *v1.PersistentVolume)
• func (r *VolumeReactor) GetChangeCount() int
• func (r *VolumeReactor) MarkVolumeAvailable(name string)
• func (r *VolumeReactor) PopChange(ctx context.Context) interface{}
• func (r *VolumeReactor) React(ctx context.Context, action core.Action) (handled bool, ret runtime.Object, err error)
• func (r *VolumeReactor) SyncAll()
• func (r *VolumeReactor) Watch(gvr schema.GroupVersionResource, ns string) (watch.Interface, error)

Variables ¶

var ErrVersionConflict = errors.New("VersionError")

ErrVersionConflict is the error returned when resource version of requested object conflicts with the object in storage.

Types ¶

type ReactorError ¶

type ReactorError struct {
	Verb     string
	Resource string
	Error    error
}

ReactorError is an error that is returned by test reactor (=simulated etcd+/API server) when an action performed by the reactor matches given verb ("get", "update", "create", "delete" or "*"") on given resource ("persistentvolumes", "persistentvolumeclaims" or "*").

type VolumeReactor ¶

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

VolumeReactor is a core.Reactor that simulates etcd and API server. It stores:

• Latest version of claims volumes saved by the controller.
• Queue of all saves (to simulate "volume/claim updated" events). This queue contains all intermediate state of an object - e.g. a claim.VolumeName is updated first and claim.Phase second. This queue will then contain both updates as separate entries.
• Number of changes since the last call to VolumeReactor.syncAll().
• Optionally, volume and claim fake watchers which should be the same ones used by the controller. Any time an event function like deleteVolumeEvent is called to simulate an event, the reactor's stores are updated and the controller is sent the event via the fake watcher.
• Optionally, list of error that should be returned by reactor, simulating etcd / API server failures. These errors are evaluated in order and every error is returned only once. I.e. when the reactor finds matching ReactorError, it return appropriate error and removes the ReactorError from the list.

func NewVolumeReactor ¶

func NewVolumeReactor(ctx context.Context, client *fake.Clientset, fakeVolumeWatch, fakeClaimWatch *watch.FakeWatcher, errors []ReactorError) *VolumeReactor

NewVolumeReactor creates a volume reactor.

func (*VolumeReactor) AddClaim ¶

func (r *VolumeReactor) AddClaim(claim *v1.PersistentVolumeClaim)

AddClaim adds a PVC into VolumeReactor.

func (*VolumeReactor) AddClaimBoundToVolume ¶

func (r *VolumeReactor) AddClaimBoundToVolume(claim *v1.PersistentVolumeClaim)

AddClaimBoundToVolume adds a PVC and binds it to corresponding PV.

func (*VolumeReactor) AddClaimEvent ¶

func (r *VolumeReactor) AddClaimEvent(claim *v1.PersistentVolumeClaim)

AddClaimEvent simulates that a claim has been deleted in etcd and the controller receives 'claim added' event.

func (*VolumeReactor) AddClaims ¶

func (r *VolumeReactor) AddClaims(claims []*v1.PersistentVolumeClaim)

AddClaims adds PVCs into VolumeReactor.

func (*VolumeReactor) AddVolume ¶

func (r *VolumeReactor) AddVolume(volume *v1.PersistentVolume)

AddVolume adds a PV into VolumeReactor.

func (*VolumeReactor) AddVolumes ¶

func (r *VolumeReactor) AddVolumes(volumes []*v1.PersistentVolume)

AddVolumes adds PVs into VolumeReactor.

func (*VolumeReactor) CheckClaims ¶

func (r *VolumeReactor) CheckClaims(expectedClaims []*v1.PersistentVolumeClaim) error

CheckClaims compares all expectedClaims with set of claims at the end of the test and reports differences.

func (*VolumeReactor) CheckVolumes ¶

func (r *VolumeReactor) CheckVolumes(expectedVolumes []*v1.PersistentVolume) error

CheckVolumes compares all expectedVolumes with set of volumes at the end of the test and reports differences.

func (*VolumeReactor) DeleteClaimEvent ¶

func (r *VolumeReactor) DeleteClaimEvent(claim *v1.PersistentVolumeClaim)

DeleteClaimEvent simulates that a claim has been deleted in etcd and the controller receives 'claim deleted' event.

func (*VolumeReactor) DeleteVolume ¶

func (r *VolumeReactor) DeleteVolume(name string)

DeleteVolume deletes a PV by name.

func (*VolumeReactor) DeleteVolumeEvent ¶

func (r *VolumeReactor) DeleteVolumeEvent(volume *v1.PersistentVolume)

DeleteVolumeEvent simulates that a volume has been deleted in etcd and the controller receives 'volume deleted' event.

func (*VolumeReactor) GetChangeCount ¶

func (r *VolumeReactor) GetChangeCount() int

GetChangeCount returns changes since last sync.

func (*VolumeReactor) MarkVolumeAvailable ¶

func (r *VolumeReactor) MarkVolumeAvailable(name string)

MarkVolumeAvailable marks a PV available by name.

func (*VolumeReactor) PopChange ¶

func (r *VolumeReactor) PopChange(ctx context.Context) interface{}

PopChange returns one recorded updated object, either *v1.PersistentVolume or *v1.PersistentVolumeClaim. Returns nil when there are no changes.

func (*VolumeReactor) React ¶

func (r *VolumeReactor) React(ctx context.Context, action core.Action) (handled bool, ret runtime.Object, err error)

React is a callback called by fake kubeClient from the controller. In other words, every claim/volume change performed by the controller ends here. This callback checks versions of the updated objects and refuse those that are too old (simulating real etcd). All updated objects are stored locally to keep track of object versions and to evaluate test results. All updated objects are also inserted into changedObjects queue and optionally sent back to the controller via its watchers.

func (*VolumeReactor) SyncAll ¶

func (r *VolumeReactor) SyncAll()

SyncAll simulates the controller periodic sync of volumes and claim. It simply adds all these objects to the internal queue of updates. This method should be used when the test manually calls syncClaim/syncVolume. Test that use real controller loop (ctrl.Run()) will get periodic sync automatically.

func (*VolumeReactor) Watch ¶

func (r *VolumeReactor) Watch(gvr schema.GroupVersionResource, ns string) (watch.Interface, error)

Watch watches objects from the VolumeReactor. Watch returns a channel which will push added / modified / deleted object.

Source Files ¶

testing.go