aboutsummaryrefslogtreecommitdiff
path: root/weed/pb/server_address_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/pb/server_address_test.go')
-rw-r--r--weed/pb/server_address_test.go36
1 files changed, 36 insertions, 0 deletions
diff --git a/weed/pb/server_address_test.go b/weed/pb/server_address_test.go
new file mode 100644
index 000000000..f5a12427a
--- /dev/null
+++ b/weed/pb/server_address_test.go
@@ -0,0 +1,36 @@
+package pb
+
+import (
+ "reflect"
+ "testing"
+)
+
+func TestServerAddresses_ToAddressMapOrSrv_shouldRemovePrefix(t *testing.T) {
+ str := ServerAddresses("dnssrv+hello.srv.consul")
+
+ d := str.ToServiceDiscovery()
+
+ expected := ServerSrvAddress("hello.srv.consul")
+ if *d.srvRecord != expected {
+ t.Fatalf(`ServerAddresses("dnssrv+hello.srv.consul") = %s, expected %s`, *d.srvRecord, expected)
+ }
+}
+
+func TestServerAddresses_ToAddressMapOrSrv_shouldHandleIPPortList(t *testing.T) {
+ str := ServerAddresses("10.0.0.1:23,10.0.0.2:24")
+
+ d := str.ToServiceDiscovery()
+
+ if d.srvRecord != nil {
+ t.Fatalf(`ServerAddresses("dnssrv+hello.srv.consul") = %s, expected nil`, *d.srvRecord)
+ }
+
+ expected := []ServerAddress{
+ ServerAddress("10.0.0.1:23"),
+ ServerAddress("10.0.0.2:24"),
+ }
+
+ if !reflect.DeepEqual(d.list, expected) {
+ t.Fatalf(`Expected %q, got %q`, expected, d.list)
+ }
+}