later 0.0.27

SQLite format 3

@  "."
".zp
��

��
)�J�
�'���
n_
�
U
UI]7
indexsqlite_autoindex_later_partition_lease_1later_partition_lease�<E3
�
indexlater_partition_job_head_idxlater_partition_jobCREATE INDEX later_partition_job_head_idx
    ON later_partition_job (namespace, topic, partition_id, sequence, earliest_run_at)�I3
�Oindexlater_partition_job_job_id_idxlater_partition_jobCREATE UNIQUE INDEX later_partition_job_job_id_idx
    ON later_partition_job (namespace, job_id)�j33
�{tablelater_partition_joblater_partition_jobCREATE TABLE later_partition_job (
    namespace TEXT NOT NULL,
    topic TEXT NOT NULL,
    partition_id INTEGER NOT NULL,
    sequence INTEGER NOT NULL,
    job_id TEXT NOT NULL,
    payload_type TEXT NOT NULL,
    earliest_run_at INTEGER NOT NULL,
    PRIMARY KEY (namespace, topic, partition_id, sequence)
)EY3
indexsqlite_autoindex_later_partition_job_1later_partition_job�==
�Otablelater_partition_sequencelater_partition_sequenceCREATE TABLE later_partition_sequence (
    namespace TEXT NOT NULL,
    topic TEXT NOT NULL,
    partition_id INTEGER NOT NULL,
    next_sequence INTEGER NOT NULL DEFAULT 1,
    PRIMARY KEY (namespace, topic, partition_id)
)Oc=
indexsqlite_autoindex_later_partition_sequence_1later_partition_sequence�>##
�Ctablelater_topiclater_topicCREATE TABLE later_topic (
    namespace TEXT NOT NULL,
    topic TEXT NOT NULL,
    partition_count INTEGER NOT NULL,
    PRIMARY KEY (namespace, topic)
)5I#
indexsqlite_autoindex_later_topic_1later_topic�G3
�+indexlater_job_execution_lease_idxlater_job_executionCREATE INDEX later_job_execution_lease_idx ON later_job_execution (lease_until)�s
33
�
tablelater_job_executionlater_job_executionCREATE TABLE later_job_execution (
    namespace TEXT NOT NULL,
    job_id TEXT NOT NULL,
    lease_owner TEXT NOT NULL,
    lease_until INTEGER NOT NULL,
    PRIMARY KEY (namespace, job_id)
)�_55
�atablelater_delivery_queuelater_delivery_queue	CREATE TABLE later_delivery_queue (
    sequence INTEGER PRIMARY KEY AUTOINCREMENT,
    namespace TEXT NOT NULL,
    queue_name TEXT NOT NULL,
    payload BLOB NOT NULL,
    available_at INTEGER NOT NULL,
    lease_owner TEXT,
    lease_until INTEGER,
    attempt_count INTEGER NOT NULL DEFAULT 0
)�p33
�tablelater_storage_rangelater_storage_rangeCREATE TABLE later_storage_range (
    sequence INTEGER PRIMARY KEY AUTOINCREMENT,
    range_key TEXT NOT NULL,
    value BLOB NOT NULL, date_expire INTEGER,
    UNIQUE (range_key, value)
)EY3
indexsqlite_autoindex_later_job_execution_1later_job_execution
E ��CI5
�indexlater_delivery_queue_claim_idxlater_delivery_queue
CREATE INDEX later_delivery_queue_claim_idx
    ON later_delivery_queue (namespace, queue_name, available_at, lease_until, sequence)�E3
�Aindexlater_storage_range_page_idxlater_storage_rangeCREATE INDEX later_storage_range_page_idx
    ON later_storage_range (range_key, sequence)P++
Ytablesqlite_sequencesqlite_sequenceCREATE TABLE sqlite_sequence(name,seq)�.33
�]tablelater_storage_rangelater_storag�-
O3
�eindexlater_storage_range_live_page_idxlater_storage_rangeCREATE INDEX later_storage_range_live_page_idx
    ON later_storage_range (range_key, sequence, date_expire)EY3
indexsqlite_autoindex_later_storage_range_1later_storage_range�&G'
�kindexlater_storage_date_expire_idxlater_storageCREATE INDEX later_storage_date_expire_idx
    ON later_storage (date_expire)
    WHERE date_expire IS NOT NULL�q
''
�!tablelater_storagelater_storageCREATE TABLE later_storage (
    key TEXT PRIMARY KEY NOT NULL,
    value BLOB NOT NULL,
    counter_value INTEGER,
    date_created INTEGER NOT NULL,
    date_updated INTEGER,
    date_expire INTEGER
)9M'
indexsqlite_autoindex_later_storage_1later_storage








	














_��(
5��S	�	+5��gF��A�
���pI]7
indexsqlite_autoindex_later�J77
�3tablelater_partition_leaselater_partition_leaseCREATE TABLE later_partition_lease (
    namespace TEXT NOT NULL,
    topic TEXT NOT NULL,
    partition_id INTEGER NOT NULL,
    owner TEXT NOT NULL,
    lease_until INTEGER NOT NULL, lease_epoch INTEGER NOT NULL DEFAULT 0,
    PRIMARY KEY (namespace, topic, partition_id)
)�<E3
�
indexlater_partition_job_head_idxlater_partition_jobCREATE INDEX later_partition_job_head_idx
    ON later_partition_job (namespace, topic, partition_id, sequence, earliest_run_at)�I3
�Oindexlater_partition_job_job_id_idxlater_partition_jobCREATE UNIQUE INDEX later_partition_job_job_id_idx
    ON later_partition_job (namespace, job_id)EY3
indexsqlite_autoindex_later_partition_job_1later_partition_job�j33
�{tablelater_partition_joblater_partition_jobCREATE TABLE later_partition_job (
    namespace TEXT NOT NULL,
    topic TEXT NOT NULL,
    partition_id INTEGER NOT NULL,
    sequence INTEGER NOT NULL,
    job_id TEXT NOT NULL,
    payload_type TEXT NOT NULL,
    earliest_run_at INTEGER NOT NULL,
    PRIMARY KEY (namespace, topic, partition_id, sequence)
)Oc=
indexsqlite_autoindex_later_partition_sequence_1later_partition_sequence�==
�Otablelater_partition_sequencelater_partition_sequenceCREATE TABLE later_partition_sequence (
    namespace TEXT NOT NULL,
    topic TEXT NOT NULL,
    partition_id INTEGER NOT NULL,
    next_sequence INTEGER NOT NULL DEFAULT 1,
    PRIMARY KEY (namespace, topic, partition_id)
)5I#
indexsqlite_autoindex_later_topic_1later_topic�>##
�Ctablelater_topiclater_topicCREATE TABLE later_topic (
    namespace TEXT NOT NULL,
    topic TEXT NOT NULL,
    partition_count INTEGER NOT NULL,
    PRIMARY KEY (namespace, topic)
)�G3
�+indexlater_job_execution_lease_idxlater_job_executionCREATE INDEX later_job_execution_lease_idx ON later_job_execution (lease_until)EY3
indexsqlite_autoindex_later_job_execution_1later_job_execution
�s
33
�
tablelater_job_executionlater_job_executionCREATE TABLE later_job_execution (
    namespace TEXT NOT NULL,
    job_id TEXT NOT NULL,
    lease_owner TEXT NOT NULL,
    lease_until INTEGER NOT NULL,
    PRIMARY KEY (namespace, job_id)
)�CI5
�indexlater_delivery_queue_claim_idxlater_delivery_queue
CREATE INDEX later_delivery_queue_claim_idx
    ON later_delivery_queue (namespace, queue_name, available_at, lease_until, sequence)�_55
�atablelater_delivery_queuelater_delivery_queue	CREATE TABLE later_delivery_queue (
    sequence INTEGER PRIMARY KEY AUTOINCREMENT,
    namespace TEXT NOT NULL,
    queue_name TEXT NOT NULL,
    payload BLOB NOT NULL,
    available_at INTEGER NOT NULL,
    lease_owner TEXT,
    lease_until INTEGER,
    attempt_count INTEGER NOT NULL DEFAULT 0
)�-
O3
�eindexlater_storage_range_live_page_idxlater_storage_rangeCREATE INDEX later_storage_range_live_page_idx
    ON later_storage_range (range_key, sequence, date_expire)�E3
�Aindexlater_storage_range_page_idxlater_storage_rangeCREATE INDEX later_storage_range_page_idx
    ON later_storage_range (range_key, sequence)P++
Ytablesqlite_sequencesqlite_sequenceCREATE TABLE sqlite_sequence(name,seq)EY3
indexsqlite_autoindex_later_storage_range_1later_storage_range�p33
�tablelater_storage_rangelater_storage_rangeCREATE TABLE later_storage_range (
    sequence INTEGER PRIMARY KEY AUTOINCREMENT,
    range_key TEXT NOT NULL,
    value BLOB NOT NULL, date_expire INTEGER,
    UNIQUE (range_key, value)
)�&G'
�kindexlater_storage_date_expire_idxlater_storageCREATE INDEX later_storage_date_expire_idx
    ON later_storage (date_expire)
    WHERE date_expire IS NOT NULL9M'
indexsqlite_autoindex_later_storage_1later_storage�q
''
�!tablelater_storagelater_storageCREATE TABLE later_storage (
    key TEXT PRIMARY KEY NOT NULL,
    value BLOB NOT NULL,
    counter_value INTEGER,
    date_created INTEGER NOT NULL,
    date_updated INTEGER,
    date_expire INTEGER
)

k�Q
�D�U
E	��U�I��i��
�
	k�.G3
�Iindexlater_job_execution_lease_idxlater_job_executionCREATE INDEX later_job_execution_lease_idx
    ON later_job_execution (namespace, lease_until)�C-[?
�yindexlater_log_consumer_offset_partition_idxlater_log_consumer_offset.CREATE INDEX later_log_consumer_offset_partition_idx
    ON later_log_consumer_offset (namespace, topic, partition_id)�>,S3
�indexlater_storage_range_date_expire_idxlater_storage_range-CREATE INDEX later_storage_range_date_expire_idx
    ON later_storage_range (date_expire)
    WHERE date_expire IS NOT NULLO+c=
indexsqlite_autoindex_later_log_consumer_lease_1later_log_consumer_lease,�*==
�tablelater_log_consumer_leaselater_log_consumer_lease+CREATE TABLE later_log_consumer_lease (
    namespace TEXT NOT NULL,
    topic TEXT NOT NULL,
    group_name TEXT NOT NULL,
    partition_id INTEGER NOT NULL,
    member_id TEXT NOT NULL,
    lease_until INTEGER NOT NULL,
    lease_epoch INTEGER NOT NULL DEFAULT 1,
    PRIMARY KEY (namespace, topic, group_name, partition_id)
)Q)e?
indexsqlite_autoindex_later_log_consumer_member_1later_log_consumer_member*�7(??
�}tablelater_log_consumer_memberlater_log_consumer_member)CREATE TABLE later_log_consumer_member (
    namespace TEXT NOT NULL,
    topic TEXT NOT NULL,
    group_name TEXT NOT NULL,
    member_id TEXT NOT NULL,
    heartbeat_at INTEGER NOT NULL,
    PRIMARY KEY (namespace, topic, group_name, member_id)
)Q'e?
indexsqlite_autoindex_later_log_consumer_offset_1later_log_consumer_offset(�b&??
�Stablelater_log_consumer_offsetlater_log_consumer_offset'CREATE TABLE later_log_consumer_offset (
    namespace TEXT NOT NULL,
    topic TEXT NOT NULL,
    group_name TEXT NOT NULL,
    partition_id INTEGER NOT NULL,
    next_offset INTEGER NOT NULL,
    committed_at INTEGER NOT NULL,
    PRIMARY KEY (namespace, topic, group_name, partition_id)
)�$%?-
�iindexlater_log_record_read_idxlater_log_record&CREATE INDEX later_log_record_read_idx
    ON later_log_record (namespace, topic, partition_id, record_offset)?$S-
indexsqlite_autoindex_later_log_record_1later_log_record%�e#--
�}tablelater_log_recordlater_log_record$CREATE TABLE later_log_record (
    namespace TEXT NOT NULL,
    topic TEXT NOT NULL,
    partition_id INTEGER NOT NULL,
    record_offset INTEGER NOT NULL,
    record_key BLOB NOT NULL,
    payload BLOB NOT NULL,
    created_at INTEGER NOT NULL,
    PRIMARY KEY (namespace, topic, partition_id, record_offset)
)E"Y3
indexsqlite_autoindex_later_log_partition_1later_log_partition#�
!33
�Atablelater_log_partitionlater_log_partition"CREATE TABLE later_log_partition (
    namespace TEXT NOT NULL,
    topic TEXT NOT NULL,
    partition_id INTEGER NOT NULL,
    next_offset INTEGER NOT NULL DEFAULT 1,
    PRIMARY KEY (namespace, topic, partition_id)
)�# I5
�Uindexlater_partition_head_ready_idxlater_partition_head!CREATE INDEX later_partition_head_ready_idx
    ON later_partition_head (namespace, earliest_run_at)G[5
indexsqlite_autoindex_later_partition_head_1later_partition_head �C55
�)tablelater_partition_headlater_partition_headCREATE TABLE later_partition_head (
    namespace TEXT NOT NULL,
    topic TEXT NOT NULL,
    partition_id INTEGER NOT NULL,
    sequence INTEGER NOT NULL,
    job_id TEXT NOT NULL,
    earliest_run_at INTEGER NOT NULL,
    PRIMARY KEY (namespace, topic, partition_id)
)�A%
�=indexlater_worker_heartbeat_idxlater_workerCREATE INDEX later_worker_heartbeat_idx
    ON later_worker (namespace, heartbeat_until)7K%
indexsqlite_autoindex_later_worker_1later_worker�A%%
�Etablelater_workerlater_workerCREATE TABLE later_worker (
    namespace TEXT NOT NULL,
    owner TEXT NOT NULL,
    heartbeat_until INTEGER NOT NULL,
    PRIMARY KEY (namespace, owner)
)�K7
�Eindexlater_partition_lease_owner_idxlater_partition_leaseCREATE INDEX later_partition_lease_owner_idx
    ON later_partition_lease (namespace, owner)I]7
indexsqlite_autoindex_later_partition_lease_1later_partition_lease