Class: Journaled::KinesisFailedEvent

Inherits:
Struct
  • Object
show all
Defined in:
lib/journaled/kinesis_failed_event.rb

Overview

Represents a failed event from Kinesis send operations

Used by both KinesisBatchSender and KinesisSequentialSender to represent events that failed to send to Kinesis, along with error details and whether the failure is transient (retriable) or permanent.

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#error_code ⇒ Object

Returns the value of attribute error_code

Returns:

  • (Object) —

    the current value of error_code



9
10
11
 
# File 'lib/journaled/kinesis_failed_event.rb', line 9

def error_code
  @error_code
end

#error_message ⇒ Object

Returns the value of attribute error_message

Returns:

  • (Object) —

    the current value of error_message



9
10
11
 
# File 'lib/journaled/kinesis_failed_event.rb', line 9

def error_message
  @error_message
end

#event ⇒ Object

Returns the value of attribute event

Returns:

  • (Object) —

    the current value of event



9
10
11
 
# File 'lib/journaled/kinesis_failed_event.rb', line 9

def event
  @event
end

#transient ⇒ Object

Returns the value of attribute transient

Returns:

  • (Object) —

    the current value of transient



9
10
11
 
# File 'lib/journaled/kinesis_failed_event.rb', line 9

def transient
  @transient
end

Instance Method Details

#permanent? ⇒ Boolean

Returns:

  • (Boolean) 


14
15
16
 
# File 'lib/journaled/kinesis_failed_event.rb', line 14

def permanent?
  !transient
end

#transient? ⇒ Boolean

Returns:

  • (Boolean) 


10
11
12
 
# File 'lib/journaled/kinesis_failed_event.rb', line 10

def transient?
  transient
end