src tx.ts

0% Statements 0/0

0% Branches 0/0

0% Functions 0/0

0% Lines 0/0

Press n or j to go to the next uncovered block, b, p or k for the previous block.


1
2
3
4
5
6
7
8
9
10
11
12
13  
 
 
 
 
 
 
 
 
 
 
 
  import type { Abortable } from 'node:events'
 
export interface TX extends Abortable {
	sessionId: string
	transactionId: string
	// Node hosting the transaction's session. Unary tx RPCs (UpdateOffsetsInTransaction)
	// must land on this node — the session does not exist elsewhere.
	nodeId?: bigint
	onRollback: (fn: (error: unknown, signal?: AbortSignal) => Promise<void> | void) => void
	onCommit: (fn: (signal?: AbortSignal) => Promise<void> | void) => void
	onClose: (fn: (committed: boolean, signal?: AbortSignal) => Promise<void> | void) => void
}