class Fluent::Plugin::ServiceDiscovery

Constants

DiscoveryMessage
SERVICE_IN
SERVICE_OUT
Service

Attributes

services[R]

Public Class Methods

new() click to toggle source
Calls superclass method Fluent::PluginLoggerMixin::new
# File lib/fluent/plugin/service_discovery.rb, line 54
def initialize
  @services = []

  super
end
service_in_msg(service) click to toggle source
# File lib/fluent/plugin/service_discovery.rb, line 45
def service_in_msg(service)
  DiscoveryMessage.new(SERVICE_IN, service)
end
service_out_msg(service) click to toggle source
# File lib/fluent/plugin/service_discovery.rb, line 49
def service_out_msg(service)
  DiscoveryMessage.new(SERVICE_OUT, service)
end

Public Instance Methods

start(queue = nil) click to toggle source
Calls superclass method Fluent::Plugin::Base#start
# File lib/fluent/plugin/service_discovery.rb, line 60
def start(queue = nil)
  super()
end