class Fluent::RawTcpOutput::Node

Attributes

available[RW]
conf[R]
failure[RW]
host[R]
name[R]
port[R]

Public Class Methods

new(log, conf) click to toggle source
# File lib/fluent/plugin/out_rawtcp.rb, line 97
def initialize(log, conf)
  @log = log
  @conf = conf
  @name = @conf.name
  @host = @conf.host
  @port = @conf.port
  resolved_host  # check dns
end

Public Instance Methods

available?() click to toggle source
# File lib/fluent/plugin/out_rawtcp.rb, line 110
def available?
  @available
end
resolved_host() click to toggle source
# File lib/fluent/plugin/out_rawtcp.rb, line 118
def resolved_host
  @sockaddr = Socket.pack_sockaddr_in(@port, @host)
  port, rhost = Socket.unpack_sockaddr_in(@sockaddr)
  return rhost
end
standby?() click to toggle source
# File lib/fluent/plugin/out_rawtcp.rb, line 114
def standby?
  @conf.standby
end