service

package
v1.2.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 20, 2024 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetTestKey added in v0.6.0 

func GetTestKey(k byte) []byte

GetTestKey encode test key

func GetTestValue added in v0.6.0 

func GetTestValue(k byte, wTxn txn.TxnMeta) []byte

GetTestValue encode test value based on the key and txn's snapshot timestamp

func NewTestClock added in v0.6.0 

func NewTestClock(start int64) clock.Clock

NewTestClock create test clock with start timestamp

func NewTestCommitRequest added in v0.6.0 

func NewTestCommitRequest(wTxn txn.TxnMeta) txn.TxnRequest

NewTestCommitRequest create a commit request

func NewTestCommitShardRequest added in v0.6.0 

func NewTestCommitShardRequest(wTxn txn.TxnMeta) txn.TxnRequest

NewTestCommitShardRequest create a commit DNShard request

func NewTestGetStatusRequest added in v0.6.0 

func NewTestGetStatusRequest(wTxn txn.TxnMeta, shard uint64) txn.TxnRequest

NewTestGetStatusRequest create a get status request

func NewTestPrepareRequest added in v0.6.0 

func NewTestPrepareRequest(wTxn txn.TxnMeta, shard uint64) txn.TxnRequest

NewTestPrepareRequest create a prepare request

func NewTestReadRequest added in v0.6.0 

func NewTestReadRequest(k byte, rTxn txn.TxnMeta, toShard uint64) txn.TxnRequest

NewTestReadRequest create a read request, using GetTestKey as the KV data for the test.

func NewTestRollbackRequest added in v0.6.0 

func NewTestRollbackRequest(wTxn txn.TxnMeta) txn.TxnRequest

NewTestRollbackRequest create a rollback request

func NewTestRollbackShardRequest added in v0.6.0 

func NewTestRollbackShardRequest(wTxn txn.TxnMeta) txn.TxnRequest

NewTestRollbackShardRequest create a rollback DNShard request

func NewTestSpecClock added in v0.6.0 

func NewTestSpecClock(fn func() int64) clock.Clock

NewTestSpecClock create test clock with timestamp factory

func NewTestTNShard added in v1.0.0 

func NewTestTNShard(id uint64) metadata.TNShard

NewTestTNShard create a test DNShard

func NewTestTimestamp added in v0.6.0 

func NewTestTimestamp(ts int64) timestamp.Timestamp

NewTestTimestamp create a test timestamp and set only the PhysicalTime field

func NewTestTxn added in v0.6.0 

func NewTestTxn(txnID byte, ts int64, shards ...uint64) txn.TxnMeta

NewTestTxn create a transaction, specifying both the transaction snapshot time and the DNShard for the transaction operation.

func NewTestTxnStorage added in v0.6.0 

func NewTestTxnStorage(log logservice.Client, clock clock.Clock) storage.TxnStorage

NewTestTxnStorage create a TxnStorage used to recovery tests

func NewTestWriteRequest added in v0.6.0 

func NewTestWriteRequest(k byte, wTxn txn.TxnMeta, toShard uint64) txn.TxnRequest

NewTestWriteRequest create a Write request, using GetTestKey and GetTestValue as the KV data for the test.

Types

type TestSender added in v0.6.0 

type TestSender struct {
	// contains filtered or unexported fields
}

TestSender test TxnSender for sending messages between TxnServices

func NewTestSender added in v0.6.0 

func NewTestSender(services ...TxnService) *TestSender

NewTestSender create test TxnSender

func (*TestSender) AddTxnService added in v0.6.0 

func (s *TestSender) AddTxnService(ts TxnService)

AddTxnService add txnservice into test TxnSender

func (*TestSender) Close added in v0.6.0 

func (s *TestSender) Close() error

Close close the test TxnSender

func (*TestSender) Send added in v0.6.0 

func (s *TestSender) Send(ctx context.Context, requests []txn.TxnRequest) (*rpc.SendResult, error)

Send TxnSender send

type TxnService 

type TxnService interface {
	// Shard returns the metadata of DNShard
	Shard() metadata.TNShard
	// Start start the txn service
	Start() error
	// Close close the txn service. Destroy TxnStorage if destroy is true.
	Close(destroy bool) error

	// Read handle txn read request from CN. For reuse, the response is provided by the
	// TODO: only read log tail.
	Read(ctx context.Context, request *txn.TxnRequest, response *txn.TxnResponse) error
	// Write handle txn write request from CN. For reuse, the response is provided by the caller
	Write(ctx context.Context, request *txn.TxnRequest, response *txn.TxnResponse) error
	// Commit handle txn commit request from CN. For reuse, the response is provided by the caller
	Commit(ctx context.Context, request *txn.TxnRequest, response *txn.TxnResponse) error
	// Rollback handle txn rollback request from CN. For reuse, the response is provided by the caller
	Rollback(ctx context.Context, request *txn.TxnRequest, response *txn.TxnResponse) error

	// Prepare handle txn prepare request from coordinator DN. For reuse, the response is provided by
	// the caller
	Prepare(ctx context.Context, request *txn.TxnRequest, response *txn.TxnResponse) error
	// GetStatus handle get txn status in current DNShard request from coordinator DN. For reuse, the
	// response is provided by the caller.
	GetStatus(ctx context.Context, request *txn.TxnRequest, response *txn.TxnResponse) error
	// CommitTNShard handle commit txn data in current DNShard request from coordinator DN. For reuse, the
	// response is provided by the caller.
	CommitTNShard(ctx context.Context, request *txn.TxnRequest, response *txn.TxnResponse) error
	// RollbackTNShard handle rollback txn data in current DNShard request from coordinator DN. For reuse,
	// the response is provided by the caller.
	RollbackTNShard(ctx context.Context, request *txn.TxnRequest, response *txn.TxnResponse) error

	// Debug handle txn debug request from CN. For reuse, the response is provided by the caller
	Debug(ctx context.Context, request *txn.TxnRequest, response *txn.TxnResponse) error
}

TxnService is a transaction service that runs on the DNStore and is used to receive transaction requests from the CN. In the case of a 2 pc distributed transaction, it acts as a transaction coordinator to handle distributed transactions.

The TxnService is managed by the DNStore and a TxnService serves only one DNShard.

The txn service use Clock-SI to implement distributed transaction.

func NewTestTxnService added in v0.6.0 

func NewTestTxnService(
	t *testing.T,
	shard uint64,
	sender rpc.TxnSender,
	clock clock.Clock) TxnService

NewTestTxnService create a test TxnService for test

func NewTestTxnServiceWithAllocator added in v0.8.0 

func NewTestTxnServiceWithAllocator(
	t *testing.T,
	shard uint64,
	sender rpc.TxnSender,
	clock clock.Clock,
	allocator lockservice.LockTableAllocator) TxnService

NewTestTxnServiceWithAllocator create a test TxnService for test

func NewTestTxnServiceWithLog added in v0.6.0 

func NewTestTxnServiceWithLog(
	t *testing.T,
	shard uint64,
	sender rpc.TxnSender,
	clock clock.Clock,
	log logservice.Client) TxnService

NewTestTxnServiceWithLog is similar to NewTestTxnService, used to recovery tests

func NewTestTxnServiceWithLogAndZombie added in v0.6.0 

func NewTestTxnServiceWithLogAndZombie(
	t *testing.T,
	shard uint64,
	sender rpc.TxnSender,
	clock clock.Clock,
	log logservice.Client,
	zombie time.Duration) TxnService

NewTestTxnServiceWithLogAndZombie is similar to NewTestTxnService, but with more args

func NewTestTxnServiceWithLogAndZombieAndLockTabkeAllocator added in v0.8.0 

func NewTestTxnServiceWithLogAndZombieAndLockTabkeAllocator(
	t *testing.T,
	shard uint64,
	sender rpc.TxnSender,
	clock clock.Clock,
	log logservice.Client,
	zombie time.Duration,
	allocator lockservice.LockTableAllocator) TxnService

NewTestTxnServiceWithLogAndZombieAndLockTabkeAllocator is similar to NewTestTxnService, but with more args

func NewTxnService added in v0.5.1 

func NewTxnService(
	shard metadata.TNShard,
	storage storage.TxnStorage,
	sender rpc.TxnSender,
	zombieTimeout time.Duration,
	allocator lockservice.LockTableAllocator) TxnService

NewTxnService create TxnService

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.