Method: Karafka::Pro::RecurringTasks::Serializer#command

Defined in:
lib/karafka/pro/recurring_tasks/serializer.rb

#command(command_name, task_id) ⇒ String

Returns serialized and compressed command data.

Parameters:

  • command_name (String) —

    command name

  • task_id (String) —

    task id or ‘*’ to match all.

Returns:

  • (String) —

    serialized and compressed command data



47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
 
# File 'lib/karafka/pro/recurring_tasks/serializer.rb', line 47

def command(command_name, task_id)
  data = {
    schema_version: SCHEMA_VERSION,
    schedule_version: Karafka::Pro::RecurringTasks.schedule.version,
    dispatched_at: Time.now.to_f,
    type: 'command',
    command: {
      name: command_name
    },
    task: {
      id: task_id
    }
  }

  compress(
    serialize(data)
  )
end