[IGNITE-15085] Implement tx coordination

• Type: Task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Labels: iep-61 ignite-3
• Epic Link: Ignite 3 transactions
• Assignee: Alexey Scherbakov
• Reporter: Alexey Scherbakov
• Reviewer: Alexander Lapin
• Created: 09/Jul/21 08:21
• Updated: 06/Dec/22 08:09
• Resolved: 28/Nov/21 12:54

Description

This ticket implies the implementation of tx coordination, as described in [1].
This includes:

• TxManager - top-level manager for tx state and coordination
• pre-writes - each tx write is pre-written to partition store in special format
• replicated tx state - tx state is stored in the partition's raft group
• integration with lock manager (see precaution chapter in [1])

The example of single key tx:

Tx client               TxCoordinator                                               Partition leaseholder.    
tx.start
            --------->  
			assign timestamp (id)
		        txstate = PENDING
            <---------		   	               
table.put(k,v)   
            --------->   
                        enlist(partition(k));
			lh = getLeaseholder(partition(k))
                        send UpsertCommand(k) to lh
				                                      ------------>
                                                                                     replicate txstate = PENDING
                                                                                     lockManager.tryAcquire(k,timestamp);
                                                                                     wait for completion async
                                                                                     prewrite(k, v) -- replicate to all replicas
                        repeat for each enlisted partition...
            <---------
tx.finish - commit or rollback
            --------->  
                        send finish request to all remote enlisted nodes
                                                                      ------------>
                                                                                     replicate txstate = COMMITTED/ABORTED
                        txState = COMMITTED/ABORTED                                  lockManager.tryRelease(k, timestamp)
							              <------------ 
                        		
			when all leasholders are replied,
			reply to initiator
	    <--------	

[1] https://github.com/apache/ignite-3/tree/main/modules/transactions

Issue Links

• Blocked: IGNITE-15991 Remove whitespace indents on empty lines
• causes: IGNITE-16004 Preserve key order in InternalTableImpl#collectMultiRowsResponses
• causes: IGNITE-15939 .NET: Fix tests related to reading non existing keys
• links to: GitHub Pull Request #400