testutils

package
v0.0.0-alpha.0....-ec243c9 Latest Latest
Warning

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

 Go to latest Published: Dec 4, 2024 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AsLearner 

func AsLearner(member *etcdserverpb.Member) *etcdserverpb.Member

func AssertBundleCorrectness 

func AssertBundleCorrectness(t *testing.T, secrets []corev1.Secret, bundles []corev1.ConfigMap)

func AssertCertificateCorrectness 

func AssertCertificateCorrectness(t *testing.T, secrets []corev1.Secret)

AssertCertificateCorrectness ensures that the certificates are signed by the correct signer

func AssertMatchingBundles 

func AssertMatchingBundles(t *testing.T, expectedBundle []*x509.Certificate, actualBundle []*x509.Certificate)

func AssertNodeSpecificCertificates 

func AssertNodeSpecificCertificates(t *testing.T, node *corev1.Node, secrets []corev1.Secret)

func BootstrapConfigMap 

func BootstrapConfigMap(configs ...func(bootstrap *corev1.ConfigMap)) *corev1.ConfigMap

func ClusterConfigConfigMap 

func ClusterConfigConfigMap(maxLearner int) *corev1.ConfigMap

func DefaultEtcdMembers 

func DefaultEtcdMembers() []*etcdserverpb.Member

func EndpointsConfigMap 

func EndpointsConfigMap(configs ...func(endpoints *corev1.ConfigMap)) *corev1.ConfigMap

func FakeClusterVersionLister 

func FakeClusterVersionLister(t *testing.T, clusterVersion *configv1.ClusterVersion) configv1listers.ClusterVersionLister

func FakeConfigMap 

func FakeConfigMap(namespace string, name string, data map[string]string) *corev1.ConfigMap

func FakeEtcdBootstrapMember 

func FakeEtcdBootstrapMember(member int) *etcdserverpb.Member

func FakeEtcdMember 

func FakeEtcdMember(member int, etcdMock []*mockserver.MockServer) *etcdserverpb.Member

func FakeEtcdMemberWithoutServer 

func FakeEtcdMemberWithoutServer(member int) *etcdserverpb.Member

func FakeInfrastructureTopology 

func FakeInfrastructureTopology(topologyMode configv1.TopologyMode) *configv1.Infrastructure

func FakeNetwork 

func FakeNetwork(isIPv6 bool) *configv1.Network

FakeNetwork creates a fake network. !isIpv6 serviceNetwork = []string{"10.0.1.0/24"} isIPv6 serviceNetwork = []string{"2001:4860:4860::8888/32"}

func FakeNetworkLister 

func FakeNetworkLister(t *testing.T, isIPv6 bool) configv1listers.NetworkLister

FakeNetworkLister creates a fake lister. !isIpv6 serviceNetwork = []string{"10.0.1.0/24"} isIPv6 serviceNetwork = []string{"2001:4860:4860::8888/32"}

func FakeNode 

func FakeNode(name string, configs ...func(node *corev1.Node)) *corev1.Node

func FakePod 

func FakePod(name string, configs ...func(node *corev1.Pod)) *corev1.Pod

func FakeSecret 

func FakeSecret(namespace, name string, cert map[string][]byte) *corev1.Secret

func FakeSecretWithAnnotations 

func FakeSecretWithAnnotations(namespace, name string, cert map[string][]byte, annotations map[string]string) *corev1.Secret

func MustAbsPath 

func MustAbsPath(path string) string

func StaticPodOperatorStatus 

func StaticPodOperatorStatus(configs ...func(status *operatorv1.StaticPodOperatorStatus)) *operatorv1.StaticPodOperatorStatus

func WithAllocatableStorage 

func WithAllocatableStorage(allocatable int64) func(*corev1.Node)

func WithBootstrapIP 

func WithBootstrapIP(ip string) func(*corev1.ConfigMap)

func WithBootstrapStatus 

func WithBootstrapStatus(status string) func(*corev1.ConfigMap)

func WithCreationTimestamp 

func WithCreationTimestamp(time metav1.Time) func(pod *corev1.Pod)

func WithEndpoint 

func WithEndpoint(memberID uint64, peerURl string) func(*corev1.ConfigMap)

func WithLatestRevision 

func WithLatestRevision(latest int32) func(status *operatorv1.StaticPodOperatorStatus)

func WithMasterLabel 

func WithMasterLabel() func(*corev1.Node)

func WithNodeInternalIP 

func WithNodeInternalIP(ip string) func(*corev1.Node)

func WithNodeStatusAtCurrentRevision 

func WithNodeStatusAtCurrentRevision(current int32) func(*operatorv1.StaticPodOperatorStatus)

func WithNodeStatusAtCurrentRevisionNamed 

func WithNodeStatusAtCurrentRevisionNamed(current int32, name string) func(*operatorv1.StaticPodOperatorStatus)

func WithPodLabels 

func WithPodLabels(labels map[string]string) func(pod *corev1.Pod)

func WithPodStatus 

func WithPodStatus(status corev1.PodPhase) func(pod *corev1.Pod)

func WithScheduledNodeName 

func WithScheduledNodeName(name string) func(pod *corev1.Pod)

Types

type FakeNodeLister 

type FakeNodeLister struct {
	Nodes []*corev1.Node
}

func (*FakeNodeLister) Get 

func (f *FakeNodeLister) Get(name string) (*corev1.Node, error)

func (*FakeNodeLister) List 

func (f *FakeNodeLister) List(selector labels.Selector) ([]*corev1.Node, error)

type FakePodLister 

type FakePodLister struct {
	PodList []*corev1.Pod
}

func (*FakePodLister) List 

func (f *FakePodLister) List(selector labels.Selector) ([]*corev1.Pod, error)

func (*FakePodLister) Pods 

func (f *FakePodLister) Pods(namespace string) corev1listers.PodNamespaceLister

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.