testutil

package
v0.0.0-...-dcfb068 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 19, 2024 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Overview

Copyright 2019 The Kubernetes Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateZoneID

func CreateZoneID(region, zone string) string

CreateZoneID returns a single zoneID for a given region and zone.

func GetKey

func GetKey(obj interface{}, t *testing.T) string

GetKey is a helper function used by controllers unit tests to get the key for a given kubernetes resource.

func GetZones

func GetZones(nodeHandler *FakeNodeHandler) []string

GetZones returns list of zones for all Nodes stored in FakeNodeHandler

func NewNode

func NewNode(name string) *v1.Node

NewNode is a helper function for creating Nodes for testing.

func NewPod

func NewPod(name, host string) *v1.Pod

NewPod is a helper function for creating Pods for testing.

Types

type FakeLegacyHandler

type FakeLegacyHandler struct {
	v1core.CoreV1Interface
	// contains filtered or unexported fields
}

FakeLegacyHandler is a fake implementation of CoreV1Interface.

func (*FakeLegacyHandler) Nodes

Nodes return fake NodeInterfaces.

type FakeNodeHandler

type FakeNodeHandler struct {
	*fake.Clientset

	// Input: Hooks determine if request is valid or not
	CreateHook func(*FakeNodeHandler, *v1.Node) bool
	Existing   []*v1.Node

	// Output
	CreatedNodes        []*v1.Node
	DeletedNodes        []*v1.Node
	UpdatedNodes        []*v1.Node
	UpdatedNodeStatuses []*v1.Node
	RequestCount        int

	DeleteWaitChan chan struct{}
	PatchWaitChan  chan struct{}
	// contains filtered or unexported fields
}

FakeNodeHandler is a fake implementation of NodesInterface and NodeInterface. It allows test cases to have fine-grained control over mock behaviors. We also need PodsInterface and PodInterface to test list & delete pods, which is implemented in the embedded client.Fake field.

func (*FakeNodeHandler) Apply

Apply applies a NodeApplyConfiguration to a Node in the fake store.

func (*FakeNodeHandler) ApplyStatus

ApplyStatus applies a status of a Node in the fake store.

func (*FakeNodeHandler) Core

Core returns fake CoreInterface.

func (*FakeNodeHandler) CoreV1

CoreV1 returns fake CoreV1Interface

func (*FakeNodeHandler) Create

func (m *FakeNodeHandler) Create(_ context.Context, node *v1.Node, _ metav1.CreateOptions) (*v1.Node, error)

Create adds a new Node to the fake store.

func (*FakeNodeHandler) Delete

Delete deletes a Node from the fake store.

func (*FakeNodeHandler) DeleteCollection

func (m *FakeNodeHandler) DeleteCollection(_ context.Context, opt metav1.DeleteOptions, listOpts metav1.ListOptions) error

DeleteCollection deletes a collection of Nodes from the fake store.

func (*FakeNodeHandler) Get

func (m *FakeNodeHandler) Get(_ context.Context, name string, opts metav1.GetOptions) (*v1.Node, error)

Get returns a Node from the fake store.

func (*FakeNodeHandler) GetUpdatedNodesCopy

func (m *FakeNodeHandler) GetUpdatedNodesCopy() []*v1.Node

GetUpdatedNodesCopy returns a slice of Nodes with updates applied.

func (*FakeNodeHandler) List

List returns a list of Nodes from the fake store.

func (*FakeNodeHandler) Patch

func (m *FakeNodeHandler) Patch(_ context.Context, name string, pt types.PatchType, data []byte, _ metav1.PatchOptions, subresources ...string) (*v1.Node, error)

Patch patches a Node in the fake store.

func (*FakeNodeHandler) PatchStatus

func (m *FakeNodeHandler) PatchStatus(ctx context.Context, nodeName string, data []byte) (*v1.Node, error)

PatchStatus patches a status of a Node in the fake store.

func (*FakeNodeHandler) Update

func (m *FakeNodeHandler) Update(_ context.Context, node *v1.Node, _ metav1.UpdateOptions) (*v1.Node, error)

Update updates a Node in the fake store.

func (*FakeNodeHandler) UpdateStatus

func (m *FakeNodeHandler) UpdateStatus(_ context.Context, node *v1.Node, _ metav1.UpdateOptions) (*v1.Node, error)

UpdateStatus updates a status of a Node in the fake store.

func (*FakeNodeHandler) Watch

Watch watches Nodes in a fake store.

type FakeRecorder

type FakeRecorder struct {
	sync.Mutex

	Events []*v1.Event
	// contains filtered or unexported fields
}

FakeRecorder is used as a fake during testing.

func NewFakeRecorder

func NewFakeRecorder() *FakeRecorder

NewFakeRecorder returns a pointer to a newly constructed FakeRecorder.

func (*FakeRecorder) AnnotatedEventf

func (f *FakeRecorder) AnnotatedEventf(obj runtime.Object, annotations map[string]string, eventtype, reason, messageFmt string, args ...interface{})

AnnotatedEventf emits a fake formatted event to the fake recorder

func (*FakeRecorder) Event

func (f *FakeRecorder) Event(obj runtime.Object, eventtype, reason, message string)

Event emits a fake event to the fake recorder

func (*FakeRecorder) Eventf

func (f *FakeRecorder) Eventf(obj runtime.Object, related runtime.Object, eventtype, reason, action, messageFmt string, args ...interface{})

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL