fluxcd
/
cli-utils
mirror of https://github.com/fluxcd/cli-utils.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

chore: Rename fake.FakeClusterReader to fake.ClusterReader

This commit is contained in:
Karl Isenberg 2022-02-15 15:17:19 -08:00
parent 94c0b1c6f0
commit f265615342
4 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/kstatus/polling/clusterreader/fake/fake.go
View File

@ -11,7 +11,7 @@ import (
"sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/controller-runtime/pkg/client"
) )
type FakeClusterReader struct { type ClusterReader struct {
NoopClusterReader NoopClusterReader
GetResource *unstructured.Unstructured GetResource *unstructured.Unstructured
@ -23,21 +23,21 @@ type FakeClusterReader struct {
SyncErr error SyncErr error
} }
func (f *FakeClusterReader) Get(_ context.Context, _ client.ObjectKey, u *unstructured.Unstructured) error { func (f *ClusterReader) Get(_ context.Context, _ client.ObjectKey, u *unstructured.Unstructured) error {
if f.GetResource != nil { if f.GetResource != nil {
u.Object = f.GetResource.Object u.Object = f.GetResource.Object
} }
return f.GetErr return f.GetErr
} }
func (f *FakeClusterReader) ListNamespaceScoped(_ context.Context, list *unstructured.UnstructuredList, _ string, _ labels.Selector) error { func (f *ClusterReader) ListNamespaceScoped(_ context.Context, list *unstructured.UnstructuredList, _ string, _ labels.Selector) error {
if f.ListResources != nil { if f.ListResources != nil {
list.Items = f.ListResources.Items list.Items = f.ListResources.Items
} }
return f.ListErr return f.ListErr
} }
func (f *FakeClusterReader) Sync(_ context.Context) error { func (f *ClusterReader) Sync(_ context.Context) error {
return f.SyncErr return f.SyncErr
} }

2
pkg/kstatus/polling/engine/engine_test.go
View File

@ -201,7 +201,7 @@ func TestNewStatusPollerRunnerCancellationWithMultipleResources(t *testing.T) {
engine := PollerEngine{ engine := PollerEngine{
Mapper: fakeMapper, Mapper: fakeMapper,
ClusterReaderFactory: ClusterReaderFactoryFunc(func(client.Reader, meta.RESTMapper, object.ObjMetadataSet) (ClusterReader, error) { ClusterReaderFactory: ClusterReaderFactoryFunc(func(client.Reader, meta.RESTMapper, object.ObjMetadataSet) (ClusterReader, error) {
return &fakecr.FakeClusterReader{ return &fakecr.ClusterReader{
SyncErr: context.Canceled, SyncErr: context.Canceled,
}, nil }, nil
}), }),

4
pkg/kstatus/polling/statusreaders/common_test.go
View File

@ -80,7 +80,7 @@ func TestLookupResource(t *testing.T) {
for tn, tc := range testCases { for tn, tc := range testCases {
t.Run(tn, func(t *testing.T) { t.Run(tn, func(t *testing.T) {
fakeReader := &fakecr.FakeClusterReader{ fakeReader := &fakecr.ClusterReader{
GetErr: tc.readerErr, GetErr: tc.readerErr,
} }
fakeMapper := fakemapper.NewFakeRESTMapper(deploymentGVK) fakeMapper := fakemapper.NewFakeRESTMapper(deploymentGVK)
@ -201,7 +201,7 @@ spec:
for tn, tc := range testCases { for tn, tc := range testCases {
t.Run(tn, func(t *testing.T) { t.Run(tn, func(t *testing.T) {
fakeClusterReader := &fakecr.FakeClusterReader{ fakeClusterReader := &fakecr.ClusterReader{
ListResources: &unstructured.UnstructuredList{ ListResources: &unstructured.UnstructuredList{
Items: tc.listObjects, Items: tc.listObjects,
}, },

2
pkg/kstatus/polling/statusreaders/deployment_test.go
View File

@ -85,7 +85,7 @@ func TestReadStatus(t *testing.T) {
for tn := range testCases { for tn := range testCases {
tc := testCases[tn] tc := testCases[tn]
t.Run(tn, func(t *testing.T) { t.Run(tn, func(t *testing.T) {
fakeReader := &fakecr.FakeClusterReader{ fakeReader := &fakecr.ClusterReader{
GetResource: tc.readerResource, GetResource: tc.readerResource,
GetErr: tc.readerErr, GetErr: tc.readerErr,
} }