Class: Fluent::Plugin::ForwardOutput::AckHandler::Ack

Inherits:

Struct

• Object
• Struct
• Fluent::Plugin::ForwardOutput::AckHandler::Ack

Defined in:

lib/fluent/plugin/out_forward/ack_handler.rb

Instance Attribute Summary

• #chunk_id ⇒ Object

  Returns the value of attribute chunk_id.

• #handler ⇒ Object

  Returns the value of attribute handler.

• #node ⇒ Object

  Returns the value of attribute node.

Instance Method Summary

• #enqueue(sock) ⇒ Object

Instance Attribute Details

#chunk_id ⇒ Object

Returns the value of attribute chunk_id

Returns:

• (Object) —

  the current value of chunk_id

# File 'lib/fluent/plugin/out_forward/ack_handler.rb', line 94

def chunk_id
  @chunk_id
end

#handler ⇒ Object

Returns the value of attribute handler

Returns:

• (Object) —

  the current value of handler

# File 'lib/fluent/plugin/out_forward/ack_handler.rb', line 94

def handler
  @handler
end

#node ⇒ Object

Returns the value of attribute node

Returns:

• (Object) —

  the current value of node

# File 'lib/fluent/plugin/out_forward/ack_handler.rb', line 94

def node
  @node
end

Instance Method Details

#enqueue(sock) ⇒ Object

# File 'lib/fluent/plugin/out_forward/ack_handler.rb', line 95

def enqueue(sock)
  handler.enqueue(node, sock, chunk_id)
end