Class: EventMeter::Processor::Result

Inherits:
Struct
  • Object
show all
Defined in:
lib/event_meter/processor.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#completeObject

Returns the value of attribute complete

Returns:

  • (Object)

    the current value of complete



5
6
7
# File 'lib/event_meter/processor.rb', line 5

def complete
  @complete
end

#event_nameObject

Returns the value of attribute event_name

Returns:

  • (Object)

    the current value of event_name



5
6
7
# File 'lib/event_meter/processor.rb', line 5

def event_name
  @event_name
end

#lockedObject

Returns the value of attribute locked

Returns:

  • (Object)

    the current value of locked



5
6
7
# File 'lib/event_meter/processor.rb', line 5

def locked
  @locked
end

#malformedObject

Returns the value of attribute malformed

Returns:

  • (Object)

    the current value of malformed



5
6
7
# File 'lib/event_meter/processor.rb', line 5

def malformed
  @malformed
end

#processedObject

Returns the value of attribute processed

Returns:

  • (Object)

    the current value of processed



5
6
7
# File 'lib/event_meter/processor.rb', line 5

def processed
  @processed
end

#skipped_already_processedObject

Returns the value of attribute skipped_already_processed

Returns:

  • (Object)

    the current value of skipped_already_processed



5
6
7
# File 'lib/event_meter/processor.rb', line 5

def skipped_already_processed
  @skipped_already_processed
end

#versionObject

Returns the value of attribute version

Returns:

  • (Object)

    the current value of version



5
6
7
# File 'lib/event_meter/processor.rb', line 5

def version
  @version
end

Class Method Details

.empty(definition) ⇒ Object



15
16
17
18
19
20
21
22
23
24
25
# File 'lib/event_meter/processor.rb', line 15

def self.empty(definition)
  new(
    event_name: definition.name,
    version: definition.version,
    processed: 0,
    skipped_already_processed: 0,
    malformed: 0,
    complete: true,
    locked: false
  )
end

.locked(definition) ⇒ Object



27
28
29
30
31
32
33
34
35
36
37
# File 'lib/event_meter/processor.rb', line 27

def self.locked(definition)
  new(
    event_name: definition.name,
    version: definition.version,
    processed: 0,
    skipped_already_processed: 0,
    malformed: 0,
    complete: false,
    locked: true
  )
end

.processed(definition, processed:, skipped_already_processed:, malformed:, complete:) ⇒ Object



39
40
41
42
43
44
45
46
47
48
49
# File 'lib/event_meter/processor.rb', line 39

def self.processed(definition, processed:, skipped_already_processed:, malformed:, complete:)
  new(
    event_name: definition.name,
    version: definition.version,
    processed: processed,
    skipped_already_processed: skipped_already_processed,
    malformed: malformed,
    complete: complete,
    locked: false
  )
end

Instance Method Details

#to_hObject



51
52
53
54
55
56
57
58
59
60
61
# File 'lib/event_meter/processor.rb', line 51

def to_h
  {
    event_name: event_name,
    version: version,
    processed: processed,
    skipped_already_processed: skipped_already_processed,
    malformed: malformed,
    complete: complete,
    locked: locked
  }
end