@eveble/eveble

Hierarchy

• CommitStorage

Implemented by

• CommitMongoDBStorage

Index

Methods

• findById
• findLastVersionById
• flagAndResolveCommitAsTimeouted
• flagCommitAsFailed
• flagCommitAsPublished
• generateId
• getAllCommits
• getCommits
• hasBySourceId
• lockCommit
• save

Methods

findById

▸ findById(commitId: string): Promise‹Commit | undefined›

Parameters:

Name	Type
commitId	string

Returns: Promise‹Commit | undefined›

▸ findById(commitId: string): Promise‹Commit | undefined›

Parameters:

Name	Type
commitId	string

Returns: Promise‹Commit | undefined›

---

findLastVersionById

▸ findLastVersionById(eventSourceableId: string | Stringifiable): Promise‹number | undefined›

Parameters:

Name	Type
eventSourceableId	string | Stringifiable

Returns: Promise‹number | undefined›

▸ findLastVersionById(eventSourceableId: string | Stringifiable): Promise‹number | undefined›

Parameters:

Name	Type
eventSourceableId	string | Stringifiable

Returns: Promise‹number | undefined›

---

flagAndResolveCommitAsTimeouted

▸ flagAndResolveCommitAsTimeouted(commitId: string, appId: string, workerId: string, failedAt: Date): Promise‹Commit | undefined›

Parameters:

Name	Type
commitId	string
appId	string
workerId	string
failedAt	Date

Returns: Promise‹Commit | undefined›

▸ flagAndResolveCommitAsTimeouted(commitId: string, appId: string, workerId: string, failedAt: Date): Promise‹Commit | undefined›

Parameters:

Name	Type
commitId	string
appId	string
workerId	string
failedAt	Date

Returns: Promise‹Commit | undefined›

---

flagCommitAsFailed

▸ flagCommitAsFailed(commitId: string, appId: string, workerId: string, failedAt: Date): Promise‹boolean›

Parameters:

Name	Type
commitId	string
appId	string
workerId	string
failedAt	Date

Returns: Promise‹boolean›

▸ flagCommitAsFailed(commitId: string, appId: string, workerId: string, failedAt: Date): Promise‹boolean›

Parameters:

Name	Type
commitId	string
appId	string
workerId	string
failedAt	Date

Returns: Promise‹boolean›

---

flagCommitAsPublished

▸ flagCommitAsPublished(commitId: string, appId: string, workerId: string, publishedAt: Date): Promise‹boolean›

Parameters:

Name	Type
commitId	string
appId	string
workerId	string
publishedAt	Date

Returns: Promise‹boolean›

▸ flagCommitAsPublished(commitId: string, appId: string, workerId: string, publishedAt: Date): Promise‹boolean›

Parameters:

Name	Type
commitId	string
appId	string
workerId	string
publishedAt	Date

Returns: Promise‹boolean›

---

generateId

▸ generateId(): Promise‹string›

Returns: Promise‹string›

▸ generateId(): Promise‹string›

Returns: Promise‹string›

---

getAllCommits

▸ getAllCommits(): Promise‹Commit[]›

Returns: Promise‹Commit[]›

▸ getAllCommits(): Promise‹Commit[]›

Returns: Promise‹Commit[]›

---

getCommits

▸ getCommits(eventSourceableId: string | Stringifiable, versionOffset: number): Promise‹Commit[]›

Parameters:

Name	Type
eventSourceableId	string | Stringifiable
versionOffset	number

Returns: Promise‹Commit[]›

▸ getCommits(eventSourceableId: string | Stringifiable, versionOffset: number): Promise‹Commit[]›

Parameters:

Name	Type
eventSourceableId	string | Stringifiable
versionOffset	number

Returns: Promise‹Commit[]›

---

hasBySourceId

▸ hasBySourceId(eventSourceableId: string | Stringifiable): Promise‹boolean›

Parameters:

Name	Type
eventSourceableId	string | Stringifiable

Returns: Promise‹boolean›

▸ hasBySourceId(eventSourceableId: string | Stringifiable): Promise‹boolean›

Parameters:

Name	Type
eventSourceableId	string | Stringifiable

Returns: Promise‹boolean›

---

lockCommit

▸ lockCommit(commitId: string, appId: string, workerId: string, registeredAndNotReceivedYetFilter: Record‹string, any›): Promise‹Commit | undefined›

Parameters:

Name	Type
commitId	string
appId	string
workerId	string
registeredAndNotReceivedYetFilter	Record‹string, any›

Returns: Promise‹Commit | undefined›

▸ lockCommit(commitId: string, appId: string, workerId: string, registeredAndNotReceivedYetFilter: Record‹string, any›): Promise‹Commit | undefined›

Parameters:

Name	Type
commitId	string
appId	string
workerId	string
registeredAndNotReceivedYetFilter	Record‹string, any›

Returns: Promise‹Commit | undefined›

---

save

▸ save(commit: Commit): Promise‹string›

Parameters:

Name	Type
commit	Commit

Returns: Promise‹string›

▸ save(commit: Commit): Promise‹string›

Parameters:

Name	Type
commit	Commit

Returns: Promise‹string›