Merge pull request #625 from fluent/dns_roundrobin

out_forward: Support dns round robin
fluent · Jul 1, 2015 · e13cc27 · e13cc27
2 parents 6002b9b + a39ad3c
commit e13cc27
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 4 deletions.
diff --git a/example/in_forward.conf b/example/in_forward.conf
@@ -0,0 +1,7 @@
+<source>
+  type forward
+</source>
+
+<match test>
+  type stdout
+</match>
diff --git a/example/out_forward.conf b/example/out_forward.conf
@@ -1,24 +1,29 @@
 <source>
-  type forward
+  type dummy
+  tag test
 </source>
 
 <match test>
   type forward
 
   <server>
     # first server
+    host localhost
     port 24224
   </server>
   <server>
     # second server
+    host localhost
     port 24225
   </server>
   <server>
     # second server
+    host localhost
     port 24226
     standby
   </server>
 
+  flush_interval 1
   send_timeout 60
   heartbeat_type udp
   heartbeat_interval 1

diff --git a/lib/fluent/plugin/out_forward.rb b/lib/fluent/plugin/out_forward.rb
@@ -460,9 +460,8 @@ def resolved_host
       end
 
       def resolve_dns!
-        @sockaddr = Socket.pack_sockaddr_in(@port, @host)
-        port, resolved_host = Socket.unpack_sockaddr_in(@sockaddr)
-        return resolved_host
+        # sample to support dns round robin
+        Socket.getaddrinfo(@host, @port).sample[3]
       end
       private :resolve_dns!