Class: Fluent::Plugin::ForwardOutput::AckHandler::ACKWaitingSockInfo

Inherits:
Struct
  • Object
show all
Defined in:
lib/fluent/plugin/out_forward/ack_handler.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#chunk_id ⇒ Object

Returns the value of attribute chunk_id

Returns:

  • (Object) —

    the current value of chunk_id



88
89
90
 
# File 'lib/fluent/plugin/out_forward/ack_handler.rb', line 88

def chunk_id
  @chunk_id
end

#chunk_id_base64 ⇒ Object

Returns the value of attribute chunk_id_base64

Returns:

  • (Object) —

    the current value of chunk_id_base64



88
89
90
 
# File 'lib/fluent/plugin/out_forward/ack_handler.rb', line 88

def chunk_id_base64
  @chunk_id_base64
end

#expired_time ⇒ Object

Returns the value of attribute expired_time

Returns:

  • (Object) —

    the current value of expired_time



88
89
90
 
# File 'lib/fluent/plugin/out_forward/ack_handler.rb', line 88

def expired_time
  @expired_time
end

#node ⇒ Object

Returns the value of attribute node

Returns:

  • (Object) —

    the current value of node



88
89
90
 
# File 'lib/fluent/plugin/out_forward/ack_handler.rb', line 88

def node
  @node
end

#sock ⇒ Object

Returns the value of attribute sock

Returns:

  • (Object) —

    the current value of sock



88
89
90
 
# File 'lib/fluent/plugin/out_forward/ack_handler.rb', line 88

def sock
  @sock
end

Instance Method Details

#expired?(now) ⇒ Boolean

Returns:

  • (Boolean) 


89
90
91
 
# File 'lib/fluent/plugin/out_forward/ack_handler.rb', line 89

def expired?(now)
  expired_time < now
end