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

Inherits:
Struct
  • Object
show all
Defined in:
lib/fluent/plugin/out_forward.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



272
273
274
 
# File 'lib/fluent/plugin/out_forward.rb', line 272

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



272
273
274
 
# File 'lib/fluent/plugin/out_forward.rb', line 272

def chunk_id_base64
  @chunk_id_base64
end

#node ⇒ Object

Returns the value of attribute node

Returns:

  • (Object) —

    the current value of node



272
273
274
 
# File 'lib/fluent/plugin/out_forward.rb', line 272

def node
  @node
end

#sock ⇒ Object

Returns the value of attribute sock

Returns:

  • (Object) —

    the current value of sock



272
273
274
 
# File 'lib/fluent/plugin/out_forward.rb', line 272

def sock
  @sock
end

#time ⇒ Object

Returns the value of attribute time

Returns:

  • (Object) —

    the current value of time



272
273
274
 
# File 'lib/fluent/plugin/out_forward.rb', line 272

def time
  @time
end

#timeout ⇒ Object

Returns the value of attribute timeout

Returns:

  • (Object) —

    the current value of timeout



272
273
274
 
# File 'lib/fluent/plugin/out_forward.rb', line 272

def timeout
  @timeout
end

Instance Method Details

#expired?(now) ⇒ Boolean

Returns:

  • (Boolean) 


273
274
275
 
# File 'lib/fluent/plugin/out_forward.rb', line 273

def expired?(now)
  time + timeout < now
end