dcn::events Namespace Reference

Classes
struct	ChainBlockInfo
struct	ChangeRecord
struct	DecodedEvent
struct	EventKey
struct	EventKeyHash
class	EventRuntime
struct	EventRuntimeConfig
struct	EventShardId
struct	FinalityHeights
struct	FinalityState
class	IChainEventSource
class	IEmittedLogSource
class	IEventDecoder
class	IEventProjector
class	IEventShardRouter
class	IEventSink
class	IHotEventStore
struct	IngestResumeState
class	LocalEvmSource
class	MonthlyEventShardRouter
struct	ProjectorRetryConfig
class	PTEventDecoder
struct	RawChainLog
struct	SourcePoll
class	SQLiteHotStore

Enumerations
enum class	EventState : std::uint8_t { OBSERVED = 0 , SAFE = 1 , FINALIZED = 2 , REMOVED = 3 }
enum class	EventType : std::uint8_t { CONNECTOR_ADDED = 0 , TRANSFORMATION_ADDED = 1 , CONDITION_ADDED = 2 }

Functions
std::string	toString (EventState state)
std::string	toString (EventType type)
std::int64_t	reorgLookbackStart (std::int64_t next_from_block, std::size_t reorg_window_blocks)

Variables
constexpr std::string_view	CONNECTOR_ADDED_TYPE = "connector_added"
constexpr std::string_view	TRANSFORMATION_ADDED_TYPE = "transformation_added"
constexpr std::string_view	CONDITION_ADDED_TYPE = "condition_added"
constexpr std::string_view	OBSERVED_STATE = "observed"
constexpr std::string_view	SAFE_STATE = "safe"
constexpr std::string_view	FINALIZED_STATE = "finalized"
constexpr std::string_view	REMOVED_STATE = "removed"
constexpr std::string_view	FEED_PROJECTOR_ID = "feed"
constexpr std::string_view	REGISTRY_PROJECTOR_ID = "registry"
constexpr int	FEED_DEAD_LETTER_BIT = 1 << 0
constexpr int	REGISTRY_DEAD_LETTER_BIT = 1 << 1
constexpr std::size_t	DEFAULT_PROJECT_BATCH_SIZE = 256
constexpr const char *	CHANGE_RECORD_COLUMNS

Enumeration Type Documentation

EventState

enum class dcn::events::EventState : std::uint8_t

strong

Enumerator
OBSERVED
SAFE
FINALIZED
REMOVED

EventType

enum class dcn::events::EventType : std::uint8_t

strong

Enumerator
CONNECTOR_ADDED
TRANSFORMATION_ADDED
CONDITION_ADDED

Function Documentation

reorgLookbackStart()

std::int64_t dcn::events::reorgLookbackStart	(	std::int64_t	next_from_block,
		std::size_t	reorg_window_blocks )

toString() [1/2]

std::string dcn::events::toString

(

EventState

state

)

toString() [2/2]

std::string dcn::events::toString

(

EventType

type

)

Variable Documentation

CHANGE_RECORD_COLUMNS

const char* dcn::events::CHANGE_RECORD_COLUMNS

constexpr

Initial value:

=
        "n.chain_id, n.block_hash, n.log_index, n.change_seq, n.event_type, n.state, "
        "n.name, n.owner, r.data_hex, r.topic0, r.topic1, r.topic2, r.topic3, n.block_number, n.tx_index, "
        "n.tx_hash, n.block_time "

CONDITION_ADDED_TYPE

std::string_view dcn::events::CONDITION_ADDED_TYPE = "condition_added"

constexpr

CONNECTOR_ADDED_TYPE

std::string_view dcn::events::CONNECTOR_ADDED_TYPE = "connector_added"

constexpr

DEFAULT_PROJECT_BATCH_SIZE

std::size_t dcn::events::DEFAULT_PROJECT_BATCH_SIZE = 256

constexpr

FEED_DEAD_LETTER_BIT

int dcn::events::FEED_DEAD_LETTER_BIT = 1 << 0

constexpr

FEED_PROJECTOR_ID

std::string_view dcn::events::FEED_PROJECTOR_ID = "feed"

constexpr

FINALIZED_STATE

std::string_view dcn::events::FINALIZED_STATE = "finalized"

constexpr

OBSERVED_STATE

std::string_view dcn::events::OBSERVED_STATE = "observed"

constexpr

REGISTRY_DEAD_LETTER_BIT

int dcn::events::REGISTRY_DEAD_LETTER_BIT = 1 << 1

constexpr

REGISTRY_PROJECTOR_ID

std::string_view dcn::events::REGISTRY_PROJECTOR_ID = "registry"

constexpr

REMOVED_STATE

std::string_view dcn::events::REMOVED_STATE = "removed"

constexpr

SAFE_STATE

std::string_view dcn::events::SAFE_STATE = "safe"

constexpr

TRANSFORMATION_ADDED_TYPE

std::string_view dcn::events::TRANSFORMATION_ADDED_TYPE = "transformation_added"

constexpr