HyperdriveDeliveryTrackingStore
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-delivery-tracking.store.ts:122
Implements
섹션 제목: “Implements”Constructors
섹션 제목: “Constructors”Constructor
섹션 제목: “Constructor”new HyperdriveDeliveryTrackingStore(
client,options?):HyperdriveDeliveryTrackingStore
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-delivery-tracking.store.ts:129
Parameters
섹션 제목: “Parameters”client
섹션 제목: “client”options?
섹션 제목: “options?”HyperdriveDeliveryTrackingStoreOptions = {}
Returns
섹션 제목: “Returns”HyperdriveDeliveryTrackingStore
Methods
섹션 제목: “Methods”close()
섹션 제목: “close()”close():
Promise<void>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-delivery-tracking.store.ts:729
Returns
섹션 제목: “Returns”Promise<void>
Implementation of
섹션 제목: “Implementation of”countBy()
섹션 제목: “countBy()”countBy(
filter,groupBy):Promise<DeliveryTrackingCountByRow[]>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-delivery-tracking.store.ts:442
Parameters
섹션 제목: “Parameters”filter
섹션 제목: “filter”groupBy
섹션 제목: “groupBy”readonly DeliveryTrackingCountByField[]
Returns
섹션 제목: “Returns”Promise<DeliveryTrackingCountByRow[]>
Implementation of
섹션 제목: “Implementation of”countRecords()
섹션 제목: “countRecords()”countRecords(
filter):Promise<number>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-delivery-tracking.store.ts:427
Parameters
섹션 제목: “Parameters”filter
섹션 제목: “filter”Returns
섹션 제목: “Returns”Promise<number>
Implementation of
섹션 제목: “Implementation of”DeliveryTrackingStore.countRecords
get()
섹션 제목: “get()”get(
messageId):Promise<TrackingRecord|undefined>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-delivery-tracking.store.ts:243
Parameters
섹션 제목: “Parameters”messageId
섹션 제목: “messageId”string
Returns
섹션 제목: “Returns”Promise<TrackingRecord | undefined>
Implementation of
섹션 제목: “Implementation of”init()
섹션 제목: “init()”init():
Promise<void>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-delivery-tracking.store.ts:177
Returns
섹션 제목: “Returns”Promise<void>
Implementation of
섹션 제목: “Implementation of”leaseDue()
섹션 제목: “leaseDue()”leaseDue(
now,limit,leaseUntil):Promise<TrackingRecord[] |undefined>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-delivery-tracking.store.ts:280
Like listDue, but also leases the records it returns: in the same
atomic step their nextCheckAt moves to leaseUntil, so other pollers
of the store skip them until the poll stores their next check or the
lease runs out. It resolves undefined when this store cannot lease
atomically. DeliveryTrackingService leases only with a store that has
both this and patchLeased, and otherwise uses listDue.
Parameters
섹션 제목: “Parameters”now
섹션 제목: “now”Date
limit
섹션 제목: “limit”number
leaseUntil
섹션 제목: “leaseUntil”Date
Returns
섹션 제목: “Returns”Promise<TrackingRecord[] | undefined>
Implementation of
섹션 제목: “Implementation of”DeliveryTrackingStore.leaseDue
listDue()
섹션 제목: “listDue()”listDue(
now,limit):Promise<TrackingRecord[]>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-delivery-tracking.store.ts:255
Parameters
섹션 제목: “Parameters”now
섹션 제목: “now”Date
limit
섹션 제목: “limit”number
Returns
섹션 제목: “Returns”Promise<TrackingRecord[]>
Implementation of
섹션 제목: “Implementation of”listRecords()
섹션 제목: “listRecords()”listRecords(
options):Promise<TrackingRecord[]>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-delivery-tracking.store.ts:393
Parameters
섹션 제목: “Parameters”options
섹션 제목: “options”Returns
섹션 제목: “Returns”Promise<TrackingRecord[]>
Implementation of
섹션 제목: “Implementation of”DeliveryTrackingStore.listRecords
patch()
섹션 제목: “patch()”patch(
messageId,patch):Promise<void>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-delivery-tracking.store.ts:486
Parameters
섹션 제목: “Parameters”messageId
섹션 제목: “messageId”string
patch
섹션 제목: “patch”Partial<TrackingRecord>
Returns
섹션 제목: “Returns”Promise<void>
Implementation of
섹션 제목: “Implementation of”patchLeased()
섹션 제목: “patchLeased()”patchLeased(
messageId,leaseUntil,patch):Promise<boolean>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-delivery-tracking.store.ts:513
Applies patch only while the record is still leased until leaseUntil
(its nextCheckAt equals it), and resolves whether it did. The check
and the write are one atomic step, as in leaseDue. A poll stores its
results this way, so one that ran past its lease cannot overwrite what
another poll stored since.
Parameters
섹션 제목: “Parameters”messageId
섹션 제목: “messageId”string
leaseUntil
섹션 제목: “leaseUntil”Date
patch
섹션 제목: “patch”Partial<TrackingRecord>
Returns
섹션 제목: “Returns”Promise<boolean>
Implementation of
섹션 제목: “Implementation of”DeliveryTrackingStore.patchLeased
releaseLeases()
섹션 제목: “releaseLeases()”releaseLeases(
messageIds,leaseUntil,nextCheckAt):Promise<void>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-delivery-tracking.store.ts:332
Hands back leases a poll did not finish: moves nextCheckAt to the
given time on those records whose nextCheckAt is still leaseUntil.
A record another poll has leased since is left alone. Without it,
DeliveryTrackingService lets such leases run out.
Parameters
섹션 제목: “Parameters”messageIds
섹션 제목: “messageIds”readonly string[]
leaseUntil
섹션 제목: “leaseUntil”Date
nextCheckAt
섹션 제목: “nextCheckAt”Date
Returns
섹션 제목: “Returns”Promise<void>
Implementation of
섹션 제목: “Implementation of”DeliveryTrackingStore.releaseLeases
upsert()
섹션 제목: “upsert()”upsert(
record):Promise<void>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-delivery-tracking.store.ts:199
Parameters
섹션 제목: “Parameters”record
섹션 제목: “record”Returns
섹션 제목: “Returns”Promise<void>