Class: Karafka::Pro::ScheduledMessages::Contracts::Message

Inherits:
Contracts::Base
  • Object
show all
Defined in:
lib/karafka/pro/scheduled_messages/contracts/message.rb

Overview

Future message expected format.

Our envelope always needs to comply with this format, otherwise we won’t have enough details to be able to dispatch the message

Constant Summary collapse

EXPECTED_SCHEDULE_HEADERS =

Headers we expect in each message of type “schedule” that goes to our scheduled messages topic

%w[
  schedule_schema_version
  schedule_target_epoch
  schedule_source_type
  schedule_target_topic
].freeze
EXPECTED_CANCEL_HEADERS =

Headers we expect in each message of type “cancel”

%w[
  schedule_schema_version
  schedule_source_type
].freeze

Method Summary

Methods inherited from Contracts::Base

#validate!