mirrors/external-dns
1
0
Fork 0
mirror of https://github.com/kubernetes-sigs/external-dns.git synced 2025-08-06 01:26:59 +02:00
Code Issues Packages Projects Releases Wiki Activity

Move echoSource into targetfiltersource_test.go

Browse Source
This commit is contained in:
Fredrik Larsson 2023-05-17 15:47:14 +02:00
parent 8533cb229a
commit d7d5a2d404
3 changed files with 41 additions and 87 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
source/echo.go
View File

@ -1,41 +0,0 @@
/*
Copyright 2023 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.
*/
package source
import (
"context"
"sigs.k8s.io/external-dns/endpoint"
)
// echoSource is a Source that returns the endpoints passed in on creation.
type echoSource struct {
endpoints []*endpoint.Endpoint
}
func (e *echoSource) AddEventHandler(ctx context.Context, handler func()) {
}
// Endpoints returns all of the endpoints passed in on creation
func (e *echoSource) Endpoints(ctx context.Context) ([]*endpoint.Endpoint, error) {
return e.endpoints, nil
}
// NewEchoSource creates a new echoSource.
func NewEchoSource(endpoints []*endpoint.Endpoint) Source {
return &echoSource{endpoints: endpoints}
}

46
source/echo_test.go
View File

@ -1,46 +0,0 @@
/*
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.
*/
package source
import (
"context"
"testing"
"sigs.k8s.io/external-dns/endpoint"
)
func TestEchoSourceReturnGivenSources(t *testing.T) {
startEndpoints := []*endpoint.Endpoint{{
DNSName: "foo.bar.com",
RecordType: "A",
Targets: endpoint.Targets{"1.2.3.4"},
RecordTTL: endpoint.TTL(300),
Labels: endpoint.Labels{},
}}
e := NewEchoSource(startEndpoints)
endpoints, err := e.Endpoints(context.Background())
if err != nil {
t.Errorf("Expected no error but got %s", err.Error())
}
for i, endpoint := range endpoints {
if endpoint != startEndpoints[i] {
t.Errorf("Expected %s but got %s", startEndpoints[i], endpoint)
}
}
}

41
source/targetfiltersource_test.go
View File

@ -26,6 +26,47 @@ import (
"sigs.k8s.io/external-dns/endpoint"
)
// echoSource is a Source that returns the endpoints passed in on creation.
type echoSource struct {
endpoints []*endpoint.Endpoint
}
func (e *echoSource) AddEventHandler(ctx context.Context, handler func()) {
}
// Endpoints returns all of the endpoints passed in on creation
func (e *echoSource) Endpoints(ctx context.Context) ([]*endpoint.Endpoint, error) {
return e.endpoints, nil
}
// NewEchoSource creates a new echoSource.
func NewEchoSource(endpoints []*endpoint.Endpoint) Source {
return &echoSource{endpoints: endpoints}
}
func TestEchoSourceReturnGivenSources(t *testing.T) {
startEndpoints := []*endpoint.Endpoint{{
DNSName: "foo.bar.com",
RecordType: "A",
Targets: endpoint.Targets{"1.2.3.4"},
RecordTTL: endpoint.TTL(300),
Labels: endpoint.Labels{},
}}
e := NewEchoSource(startEndpoints)
endpoints, err := e.Endpoints(context.Background())
if err != nil {
t.Errorf("Expected no error but got %s", err.Error())
}
for i, endpoint := range endpoints {
if endpoint != startEndpoints[i] {
t.Errorf("Expected %s but got %s", startEndpoints[i], endpoint)
}
}
}
func TestTargetFilterSource(t *testing.T) {
t.Parallel()