Method: Fluent::GoogleCloudOutput#start

Defined in:

lib/fluent/plugin/out_google_cloud.rb

#start ⇒ Object

# File 'lib/fluent/plugin/out_google_cloud.rb', line 636

def start
  super
  init_api_client
  @successful_call = false
  @timenanos_warning = false

  if @statusz_port > 0
    @log.info "Starting statusz server on port #{@statusz_port}"
    server_create(:out_google_cloud_statusz,
                  @statusz_port,
                  bind: '127.0.0.1') do |data, conn|
      if data.split(' ')[1] == '/statusz'
        write_html_response(data, conn, 200, Statusz.response(self))
      else
        write_html_response(data, conn, 404, "Not found\n")
      end
    end
  end
end