Class: LogStruct::Log::GoodJob::Enqueue

Inherits:
T::Struct
  • Object
show all
Extended by:
T::Sig
Includes:
Interfaces::CommonFields, Shared::SerializeCommon
Defined in:
lib/log_struct/log/good_job/enqueue.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Shared::SerializeCommon

#as_json, #serialize, #serialize_common

Methods included from Interfaces::CommonFields

#serialize

Constructor Details

#initialize(source: Source::Job, event: Event::Enqueue, timestamp:, level: Level::Info, job_id: nil, job_class: nil, queue_name: nil, arguments: nil, executions: nil, duration_ms:, scheduled_at: nil, enqueue_caller: nil) ⇒ void

Parameters:

  • source (Source::Job) (defaults to: Source::Job) —

    Shared/common fields

  • event (Event) (defaults to: Event::Enqueue)
  • timestamp (Time)
  • level (Level) (defaults to: Level::Info)
  • job_id (String, nil) (defaults to: nil)
  • job_class (String, nil) (defaults to: nil)
  • queue_name (Symbol, nil) (defaults to: nil)
  • arguments (Array<T.untyped>, nil) (defaults to: nil)
  • executions (Integer, nil) (defaults to: nil)
  • duration_ms (Float) —

    Event-specific fields

  • scheduled_at (Time, nil) (defaults to: nil)
  • enqueue_caller (String, nil) (defaults to: nil) 



# File ''

const :source, Source::Job, default: Source::Job
const :event, Event, default: Event::Enqueue
const :timestamp, Time, factory: -> { Time.now }
const :level, Level, default: Level::Info
const :job_id, T.nilable(String), default: nil
const :job_class, T.nilable(String), default: nil
const :queue_name, T.nilable(Symbol), default: nil
const :arguments, T.nilable(T::Array[T.untyped]), default: nil
const :executions, T.nilable(Integer), default: nil
const :duration_ms, Float
const :scheduled_at, T.nilable(Time), default: nil
const :enqueue_caller, T.nilable(String), default: nil

Instance Attribute Details

#arguments ⇒ Array<T.untyped>? (readonly)

Returns the value of prop arguments.

Returns:

  • (Array<T.untyped>, nil) 



# File ''

const :arguments, T.nilable(T::Array[T.untyped]), default: nil

#duration_ms ⇒ Float (readonly)

Event-specific fields

Returns:

  • (Float) 



# File ''

const :duration_ms, Float

#enqueue_caller ⇒ String? (readonly)

Returns the value of prop enqueue_caller.

Returns:

  • (String, nil) 



# File ''

const :enqueue_caller, T.nilable(String), default: nil

#event ⇒ Event (readonly)

Returns the value of prop event.

Returns:




# File ''

const :event, Event, default: Event::Enqueue

#executions ⇒ Integer? (readonly)

Returns the value of prop executions.

Returns:

  • (Integer, nil) 



# File ''

const :executions, T.nilable(Integer), default: nil

#job_class ⇒ String? (readonly)

Returns the value of prop job_class.

Returns:

  • (String, nil) 



# File ''

const :job_class, T.nilable(String), default: nil

#job_id ⇒ String? (readonly)

Returns the value of prop job_id.

Returns:

  • (String, nil) 



# File ''

const :job_id, T.nilable(String), default: nil

#level ⇒ Level (readonly)

Returns the value of prop level.

Returns:




# File ''

const :level, Level, default: Level::Info

#queue_name ⇒ Symbol? (readonly)

Returns the value of prop queue_name.

Returns:

  • (Symbol, nil) 



# File ''

const :queue_name, T.nilable(Symbol), default: nil

#scheduled_at ⇒ Time? (readonly)

Returns the value of prop scheduled_at.

Returns:

  • (Time, nil) 



# File ''

const :scheduled_at, T.nilable(Time), default: nil

#source ⇒ Source::Job (readonly)

Shared/common fields

Returns:




# File ''

const :source, Source::Job, default: Source::Job

#timestamp ⇒ Time (readonly)

Returns the value of prop timestamp.

Returns:

  • (Time) 



# File ''

const :timestamp, Time, factory: -> { Time.now }

Instance Method Details

#to_h ⇒ Hash{LogStruct::LogField => T.untyped}

Returns:



48
49
50
51
52
53
54
55
56
57
58
59
 
# File 'lib/log_struct/log/good_job/enqueue.rb', line 48

def to_h
  h = T.let({}, T::Hash[LogStruct::LogField, T.untyped])
  h[LogField::JobId] = job_id unless job_id.nil?
  h[LogField::JobClass] = job_class unless job_class.nil?
  h[LogField::QueueName] = queue_name unless queue_name.nil?
  h[LogField::Arguments] = arguments unless arguments.nil?
  h[LogField::Executions] = executions unless executions.nil?
  h[LogField::DurationMs] = duration_ms
  h[LogField::ScheduledAt] = scheduled_at unless scheduled_at.nil?
  h[LogField::EnqueueCaller] = enqueue_caller unless enqueue_caller.nil?
  h
end